From 47e67e81e674de459f38477fb43278ff70645393 Mon Sep 17 00:00:00 2001 From: Nitish Upreti Date: Fri, 24 Jun 2022 13:48:43 -0700 Subject: [PATCH] ReIndent --- src/backend/distributed/operations/worker_shard_copy.c | 4 +++- src/backend/distributed/operations/worker_split_copy_udf.c | 1 + .../expected/citus_split_shard_by_split_points_local.out | 0 3 files changed, 4 insertions(+), 1 deletion(-) delete mode 100644 src/test/regress/expected/citus_split_shard_by_split_points_local.out diff --git a/src/backend/distributed/operations/worker_shard_copy.c b/src/backend/distributed/operations/worker_shard_copy.c index c4d69e9f2..68728dfb6 100644 --- a/src/backend/distributed/operations/worker_shard_copy.c +++ b/src/backend/distributed/operations/worker_shard_copy.c @@ -124,7 +124,8 @@ ConnectToRemoteAndStartCopy(ShardCopyDestReceiver *copyDest) ReportConnectionError(copyDest->connection, ERROR); } - PGresult *result = GetRemoteCommandResult(copyDest->connection, true /* raiseInterrupts */); + PGresult *result = GetRemoteCommandResult(copyDest->connection, + true /* raiseInterrupts */); if (PQresultStatus(result) != PGRES_COPY_IN) { ReportResultError(copyDest->connection, result, ERROR); @@ -331,6 +332,7 @@ CreateShardCopyDestReceiver(EState *executorState, return (DestReceiver *) copyDest; } + /* * ShardCopyDestReceiverDestroy frees the DestReceiver. */ diff --git a/src/backend/distributed/operations/worker_split_copy_udf.c b/src/backend/distributed/operations/worker_split_copy_udf.c index b782c2196..66da99845 100644 --- a/src/backend/distributed/operations/worker_split_copy_udf.c +++ b/src/backend/distributed/operations/worker_split_copy_udf.c @@ -75,6 +75,7 @@ worker_split_copy(PG_FUNCTION_ARGS) PG_RETURN_VOID(); } + /* Parse a single SplitCopyInfo Tuple */ static void ParseSplitCopyInfoDatum(Datum splitCopyInfoDatum, SplitCopyInfo **splitCopyInfo) diff --git a/src/test/regress/expected/citus_split_shard_by_split_points_local.out b/src/test/regress/expected/citus_split_shard_by_split_points_local.out deleted file mode 100644 index e69de29bb..000000000