Fix kind mismatch error in COPY FROM STDIN.

diff --git a/pool_process_query.c b/pool_process_query.c
index edaed2792fa8dd78a41e30fe7d61e0fcbb376285..192ab03cbbab397f53e9c446ddd0c3551ded4c29 100644 (file)
--- a/pool_process_query.c
+++ b/pool_process_query.c
@@ -1571,8 +1571,22 @@ static POOL_STATUS CopyDataRows(POOL_CONNECTION *frontend,
                        return POOL_END;
                if (REPLICATION)
                {
+                       if (pool_config.replication_strict)
+                       {
+                               pool_debug("waiting for master completing the copy");
+                               if (synchronize(MASTER(backend)))
+                                       return POOL_END;
+                       }
+
                        if (pool_flush(SECONDARY(backend)) <0)
                                return POOL_END;
+
+                       if (pool_config.replication_strict)
+                       {
+                               pool_debug("waiting for secondary completing the copy");
+                               if (synchronize(SECONDARY(backend)))
+                                       return POOL_END;
+                       }
                }
        }
        else