Fix deadlock problem with extend query.

Call synchronize() in Execute() if replication_strict is true.

diff --git a/pool_process_query.c b/pool_process_query.c
index 451b537b6da22e01e973d7fdba77d7e3cfb82744..b6c0cb584662768bce2044ae96ffd79bdd717245 100644 (file)
--- a/pool_process_query.c
+++ b/pool_process_query.c
@@ -782,6 +782,12 @@ static POOL_STATUS Execute(POOL_CONNECTION *frontend,
 
                if (!REPLICATION)
                        break;
+               else if (pool_config.replication_strict)
+               {
+                       pool_debug("waiting for backend completing the query");
+                       if (synchronize(cp))
+                               return POOL_END;
+               }
        }
 
        while ((kind = pool_read_kind(backend)),