diff --git a/src/backend/distributed/transaction/worker_transaction.c b/src/backend/distributed/transaction/worker_transaction.c index 64f3f6460..00e6788e2 100644 --- a/src/backend/distributed/transaction/worker_transaction.c +++ b/src/backend/distributed/transaction/worker_transaction.c @@ -32,29 +32,6 @@ #include "utils/memutils.h" -/* - * SendCommandToWorker sends a command to a particular worker as part of the - * 2PC. - */ -void -SendCommandToWorker(char *nodeName, int32 nodePort, char *command) -{ - MultiConnection *transactionConnection = NULL; - char *nodeUser = CitusExtensionOwnerName(); - int connectionFlags = 0; - - BeginOrContinueCoordinatedTransaction(); - CoordinatedTransactionUse2PC(); - - transactionConnection = GetNodeUserDatabaseConnection(connectionFlags, nodeName, - nodePort, nodeUser, NULL); - - MarkRemoteTransactionCritical(transactionConnection); - RemoteTransactionBeginIfNecessary(transactionConnection); - ExecuteCriticalRemoteCommand(transactionConnection, command); -} - - /* * SendCommandToWorkers sends a command to all workers in * parallel. Commands are committed on the workers when the local diff --git a/src/include/distributed/worker_transaction.h b/src/include/distributed/worker_transaction.h index 871c1ac4c..4059e96af 100644 --- a/src/include/distributed/worker_transaction.h +++ b/src/include/distributed/worker_transaction.h @@ -28,7 +28,6 @@ typedef enum TargetWorkerSet /* Functions declarations for worker transactions */ extern List * GetWorkerTransactions(void); -extern void SendCommandToWorker(char *nodeName, int32 nodePort, char *command); extern void SendCommandToWorkers(TargetWorkerSet targetWorkerSet, char *command); extern void SendCommandToWorkersParams(TargetWorkerSet targetWorkerSet, char *command, int parameterCount, const Oid *parameterTypes,