|
8 | 8 | * |
9 | 9 | * |
10 | 10 | * IDENTIFICATION |
11 | | - * $PostgreSQL: pgsql/src/interfaces/libpq/fe-protocol3.c,v 1.10 2003/11/29 19:52:12 pgsql Exp $ |
| 11 | + * $PostgreSQL: pgsql/src/interfaces/libpq/fe-protocol3.c,v 1.11 2003/12/28 17:43:57 tgl Exp $ |
12 | 12 | * |
13 | 13 | *------------------------------------------------------------------------- |
14 | 14 | */ |
|
35 | 35 | #endif |
36 | 36 |
|
37 | 37 |
|
| 38 | +/* |
| 39 | + * This macro lists the backend message types that could be "long" (more |
| 40 | + * than a couple of kilobytes). |
| 41 | + */ |
| 42 | +#defineVALID_LONG_MESSAGE_TYPE(id) \ |
| 43 | +((id) == 'T' || (id) == 'D' || (id) == 'd' || (id) == 'V' || \ |
| 44 | + (id) == 'E' || (id) == 'N' || (id) == 'A') |
| 45 | + |
| 46 | + |
38 | 47 | staticvoidhandleSyncLoss(PGconn*conn,charid,intmsgLength); |
39 | 48 | staticintgetRowDescriptions(PGconn*conn); |
40 | 49 | staticintgetAnotherTuple(PGconn*conn,intmsgLength); |
@@ -83,8 +92,7 @@ pqParseInput3(PGconn *conn) |
83 | 92 | handleSyncLoss(conn,id,msgLength); |
84 | 93 | return; |
85 | 94 | } |
86 | | -if (msgLength>30000&& |
87 | | -!(id=='T'||id=='D'||id=='d')) |
| 95 | +if (msgLength>30000&& !VALID_LONG_MESSAGE_TYPE(id)) |
88 | 96 | { |
89 | 97 | handleSyncLoss(conn,id,msgLength); |
90 | 98 | return; |
@@ -1257,8 +1265,7 @@ pqFunctionCall3(PGconn *conn, Oid fnid, |
1257 | 1265 | handleSyncLoss(conn,id,msgLength); |
1258 | 1266 | break; |
1259 | 1267 | } |
1260 | | -if (msgLength>30000&& |
1261 | | -!(id=='T'||id=='D'||id=='d'||id=='V')) |
| 1268 | +if (msgLength>30000&& !VALID_LONG_MESSAGE_TYPE(id)) |
1262 | 1269 | { |
1263 | 1270 | handleSyncLoss(conn,id,msgLength); |
1264 | 1271 | break; |
|