Fixed a hangup when processing the COPY command in asynchronous mode.

Fix problem bucardo#98
true-alex · Sep 29, 2022 · ba2327e · ba2327e
1 parent 8366f25
commit ba2327e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dbdimp.c b/dbdimp.c
@@ -5318,6 +5318,9 @@ long pg_db_result (SV *h, imp_dbh_t *imp_dbh)
             TRACE_PQCLEAR;
             PQclear(result);
         }
+        if ( rows == -1 ) {
+            break;
+        }
     }
 
     if (NULL != imp_dbh->async_sth) {