Remove unnecessary PQconsumeInput call from PQputCopyData; it's redundant

because pqSendSome will absorb input data anytime it'd be forced to block.
Avoiding a kernel call per PQputCopyData call helps COPY speed materially.

Alon Goldshuv

diff --git a/src/interfaces/libpq/fe-exec.c b/src/interfaces/libpq/fe-exec.c
index 2b324916df19d37b41cdf333ed5bbed5472718ba..4edb065c9cc341ad3028de587ca89469501d073e 100644 (file)
--- a/src/interfaces/libpq/fe-exec.c
+++ b/src/interfaces/libpq/fe-exec.c
@@ -8,7 +8,7 @@
  *
  *
  * IDENTIFICATION
- *   $PostgreSQL: pgsql/src/interfaces/libpq/fe-exec.c,v 1.178 2006/01/11 08:43:13 neilc Exp $
+ *   $PostgreSQL: pgsql/src/interfaces/libpq/fe-exec.c,v 1.179 2006/01/25 20:44:32 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -1476,13 +1476,13 @@ PQputCopyData(PGconn *conn, const char *buffer, int nbytes)
    }
 
    /*
-    * Check for NOTICE messages coming back from the server.  Since the
-    * server might generate multiple notices during the COPY, we have to
-    * consume those in a reasonably prompt fashion to prevent the comm
-    * buffers from filling up and possibly blocking the server.
+    * Process any NOTICE or NOTIFY messages that might be pending in the
+    * input buffer.  Since the server might generate many notices during
+    * the COPY, we want to clean those out reasonably promptly to prevent
+    * indefinite expansion of the input buffer.  (Note: the actual read
+    * of input data into the input buffer happens down inside pqSendSome,
+    * but it's not authorized to get rid of the data again.)
     */
-   if (!PQconsumeInput(conn))
-       return -1;              /* I/O failure */
    parseInput(conn);
 
    if (nbytes > 0)