diff options
Diffstat (limited to 'contrib/postgres_fdw/connection.c')
| -rw-r--r-- | contrib/postgres_fdw/connection.c | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/contrib/postgres_fdw/connection.c b/contrib/postgres_fdw/connection.c index 43c7fc9e080..8ca1c1c8986 100644 --- a/contrib/postgres_fdw/connection.c +++ b/contrib/postgres_fdw/connection.c @@ -486,11 +486,11 @@ pgfdw_get_result(PGconn *conn, const char *query) for (;;) { - PGresult *res; + PGresult *res; while (PQisBusy(conn)) { - int wc; + int wc; /* Sleep until there's something to do */ wc = WaitLatchOrSocket(MyLatch, @@ -675,9 +675,9 @@ pgfdw_xact_callback(XactEvent event, void *arg) /* * If a command has been submitted to the remote server by * using an asynchronous execution function, the command - * might not have yet completed. Check to see if a command - * is still being processed by the remote server, and if so, - * request cancellation of the command. + * might not have yet completed. Check to see if a + * command is still being processed by the remote server, + * and if so, request cancellation of the command. */ if (PQtransactionStatus(entry->conn) == PQTRANS_ACTIVE) { @@ -689,8 +689,8 @@ pgfdw_xact_callback(XactEvent event, void *arg) if (!PQcancel(cancel, errbuf, sizeof(errbuf))) ereport(WARNING, (errcode(ERRCODE_CONNECTION_FAILURE), - errmsg("could not send cancel request: %s", - errbuf))); + errmsg("could not send cancel request: %s", + errbuf))); PQfreeCancel(cancel); } } @@ -798,11 +798,11 @@ pgfdw_subxact_callback(SubXactEvent event, SubTransactionId mySubid, entry->have_error = true; /* - * If a command has been submitted to the remote server by using an - * asynchronous execution function, the command might not have yet - * completed. Check to see if a command is still being processed by - * the remote server, and if so, request cancellation of the - * command. + * If a command has been submitted to the remote server by using + * an asynchronous execution function, the command might not have + * yet completed. Check to see if a command is still being + * processed by the remote server, and if so, request cancellation + * of the command. */ if (PQtransactionStatus(entry->conn) == PQTRANS_ACTIVE) { |