diff options
author | Tom Lane | 2022-05-12 19:17:30 +0000 |
---|---|---|
committer | Tom Lane | 2022-05-12 19:17:30 +0000 |
commit | 23e7b38bfe396f919fdb66057174d29e17086418 (patch) | |
tree | 335c3962ef8afe0f6193d0413dbc51642276b147 /contrib/postgres_fdw | |
parent | 93909599cdba64c8759d646983c0a4ef93de1e50 (diff) |
Pre-beta mechanical code beautification.
Run pgindent, pgperltidy, and reformat-dat-files.
I manually fixed a couple of comments that pgindent uglified.
Diffstat (limited to 'contrib/postgres_fdw')
-rw-r--r-- | contrib/postgres_fdw/connection.c | 10 | ||||
-rw-r--r-- | contrib/postgres_fdw/postgres_fdw.c | 10 |
2 files changed, 11 insertions, 9 deletions
diff --git a/contrib/postgres_fdw/connection.c b/contrib/postgres_fdw/connection.c index 541526ab80b..061ffaf329e 100644 --- a/contrib/postgres_fdw/connection.c +++ b/contrib/postgres_fdw/connection.c @@ -654,10 +654,10 @@ do_sql_command_end(PGconn *conn, const char *sql, bool consume_input) PGresult *res; /* - * If requested, consume whatever data is available from the socket. - * (Note that if all data is available, this allows pgfdw_get_result to - * call PQgetResult without forcing the overhead of WaitLatchOrSocket, - * which would be large compared to the overhead of PQconsumeInput.) + * If requested, consume whatever data is available from the socket. (Note + * that if all data is available, this allows pgfdw_get_result to call + * PQgetResult without forcing the overhead of WaitLatchOrSocket, which + * would be large compared to the overhead of PQconsumeInput.) */ if (consume_input && !PQconsumeInput(conn)) pgfdw_report_error(ERROR, NULL, conn, false, sql); @@ -1560,6 +1560,7 @@ pgfdw_finish_pre_commit_cleanup(List *pending_entries) entry = (ConnCacheEntry *) lfirst(lc); Assert(entry->changing_xact_state); + /* * We might already have received the result on the socket, so pass * consume_input=true to try to consume it first @@ -1634,6 +1635,7 @@ pgfdw_finish_pre_subcommit_cleanup(List *pending_entries, int curlevel) entry = (ConnCacheEntry *) lfirst(lc); Assert(entry->changing_xact_state); + /* * We might already have received the result on the socket, so pass * consume_input=true to try to consume it first diff --git a/contrib/postgres_fdw/postgres_fdw.c b/contrib/postgres_fdw/postgres_fdw.c index 0e5771c89d8..d56951153bb 100644 --- a/contrib/postgres_fdw/postgres_fdw.c +++ b/contrib/postgres_fdw/postgres_fdw.c @@ -1243,9 +1243,9 @@ postgresGetForeignPlan(PlannerInfo *root, if (best_path->fdw_private) { has_final_sort = boolVal(list_nth(best_path->fdw_private, - FdwPathPrivateHasFinalSort)); + FdwPathPrivateHasFinalSort)); has_limit = boolVal(list_nth(best_path->fdw_private, - FdwPathPrivateHasLimit)); + FdwPathPrivateHasLimit)); } if (IS_SIMPLE_REL(foreignrel)) @@ -1926,7 +1926,7 @@ postgresBeginForeignModify(ModifyTableState *mtstate, values_end_len = intVal(list_nth(fdw_private, FdwModifyPrivateLen)); has_returning = boolVal(list_nth(fdw_private, - FdwModifyPrivateHasReturning)); + FdwModifyPrivateHasReturning)); retrieved_attrs = (List *) list_nth(fdw_private, FdwModifyPrivateRetrievedAttrs); @@ -2686,11 +2686,11 @@ postgresBeginDirectModify(ForeignScanState *node, int eflags) dmstate->query = strVal(list_nth(fsplan->fdw_private, FdwDirectModifyPrivateUpdateSql)); dmstate->has_returning = boolVal(list_nth(fsplan->fdw_private, - FdwDirectModifyPrivateHasReturning)); + FdwDirectModifyPrivateHasReturning)); dmstate->retrieved_attrs = (List *) list_nth(fsplan->fdw_private, FdwDirectModifyPrivateRetrievedAttrs); dmstate->set_processed = boolVal(list_nth(fsplan->fdw_private, - FdwDirectModifyPrivateSetProcessed)); + FdwDirectModifyPrivateSetProcessed)); /* Create context for per-tuple temp workspace. */ dmstate->temp_cxt = AllocSetContextCreate(estate->es_query_cxt, |