fix async queries not cleared prior some sync queries

[m6w6/ext-pq] / src / php_pqconn_event.c

diff --git a/src/php_pqconn_event.c b/src/php_pqconn_event.c
index 802a9e482914235a3eeb39a081261b014871de4d..13e790a2cc3605472b11edcfde794e411d65472c 100644 (file)
--- a/src/php_pqconn_event.c
+++ b/src/php_pqconn_event.c
@@ -55,7 +55,7 @@ static inline PGresult *relisten(PGconn *conn, const char *channel_str, size_t c
                smart_str_appends(&cmd, quoted_channel);
                smart_str_0(&cmd);
 
                smart_str_appends(&cmd, quoted_channel);
                smart_str_0(&cmd);
 

-               res = PQexec(conn, smart_str_v(&cmd));
+               res = php_pq_exec(conn, smart_str_v(&cmd));

 
                smart_str_free(&cmd);
                PQfreemem(quoted_channel);
 
                smart_str_free(&cmd);
                PQfreemem(quoted_channel);