From 18a6e478af80b3b15a4905f8fc3c4e0b4046c4c7 Mon Sep 17 00:00:00 2001 From: Marco Slot Date: Thu, 20 Jul 2017 11:18:42 +0200 Subject: [PATCH] Fix typo in GetCurrentDistributedTransctionId --- src/backend/distributed/transaction/backend_data.c | 6 +++--- src/backend/distributed/transaction/remote_transaction.c | 2 +- src/include/distributed/transaction_identifier.h | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/backend/distributed/transaction/backend_data.c b/src/backend/distributed/transaction/backend_data.c index 8732b1a4f..44445b610 100644 --- a/src/backend/distributed/transaction/backend_data.c +++ b/src/backend/distributed/transaction/backend_data.c @@ -145,7 +145,7 @@ get_current_transaction_id(PG_FUNCTION_ARGS) ereport(ERROR, (errmsg("backend is not ready for distributed transactions"))); } - distributedTransctionId = GetCurrentDistributedTransctionId(); + distributedTransctionId = GetCurrentDistributedTransactionId(); memset(values, 0, sizeof(values)); memset(isNulls, false, sizeof(isNulls)); @@ -434,11 +434,11 @@ UnSetDistributedTransactionId(void) /* - * GetCurrentDistributedTransctionId reads the backend's distributed transaction id and + * GetCurrentDistributedTransactionId reads the backend's distributed transaction id and * returns a copy of it. */ DistributedTransactionId * -GetCurrentDistributedTransctionId(void) +GetCurrentDistributedTransactionId(void) { DistributedTransactionId *currentDistributedTransactionId = (DistributedTransactionId *) palloc(sizeof(DistributedTransactionId)); diff --git a/src/backend/distributed/transaction/remote_transaction.c b/src/backend/distributed/transaction/remote_transaction.c index d215948ef..eeb662256 100644 --- a/src/backend/distributed/transaction/remote_transaction.c +++ b/src/backend/distributed/transaction/remote_transaction.c @@ -64,7 +64,7 @@ StartRemoteTransactionBegin(struct MultiConnection *connection) * and send both in one step. The reason is purely performance, we don't want * seperate roundtrips for these two statements. */ - distributedTransactionId = GetCurrentDistributedTransctionId(); + distributedTransactionId = GetCurrentDistributedTransactionId(); appendStringInfo(beginAndSetDistributedTransactionId, "SELECT assign_distributed_transaction_id(%d, %ld, '%s')", distributedTransactionId->initiatorNodeIdentifier, diff --git a/src/include/distributed/transaction_identifier.h b/src/include/distributed/transaction_identifier.h index 9e1de3f9d..64d333190 100644 --- a/src/include/distributed/transaction_identifier.h +++ b/src/include/distributed/transaction_identifier.h @@ -34,6 +34,6 @@ typedef struct DistributedTransactionId } DistributedTransactionId; -extern DistributedTransactionId * GetCurrentDistributedTransctionId(void); +extern DistributedTransactionId * GetCurrentDistributedTransactionId(void); #endif /* TRANSACTION_IDENTIFIER_H */