pull/6029/head
Nitish Upreti 2022-06-24 13:48:43 -07:00
parent 9b45e3c6fc
commit 47e67e81e6
3 changed files with 4 additions and 1 deletions

View File

@ -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.
*/

View File

@ -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)