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