external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix typo in GetCurrentDistributedTransctionId

pull/1504/head
Marco Slot 2017-07-20 11:18:42 +02:00
parent 165a4eb7cb
commit 18a6e478af
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/transaction/backend_data.c
View File

@ -145,7 +145,7 @@ get_current_transaction_id(PG_FUNCTION_ARGS)
ereport(ERROR, (errmsg("backend is not ready for distributed transactions"))); ereport(ERROR, (errmsg("backend is not ready for distributed transactions")));
} }
distributedTransctionId = GetCurrentDistributedTransctionId(); distributedTransctionId = GetCurrentDistributedTransactionId();
memset(values, 0, sizeof(values)); memset(values, 0, sizeof(values));
memset(isNulls, false, sizeof(isNulls)); 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. * returns a copy of it.
*/ */
DistributedTransactionId * DistributedTransactionId *
GetCurrentDistributedTransctionId(void) GetCurrentDistributedTransactionId(void)
{ {
DistributedTransactionId *currentDistributedTransactionId = DistributedTransactionId *currentDistributedTransactionId =
(DistributedTransactionId *) palloc(sizeof(DistributedTransactionId)); (DistributedTransactionId *) palloc(sizeof(DistributedTransactionId));

2
src/backend/distributed/transaction/remote_transaction.c
View File

@ -64,7 +64,7 @@ StartRemoteTransactionBegin(struct MultiConnection *connection)
* and send both in one step. The reason is purely performance, we don't want * and send both in one step. The reason is purely performance, we don't want
* seperate roundtrips for these two statements. * seperate roundtrips for these two statements.
*/ */
distributedTransactionId = GetCurrentDistributedTransctionId(); distributedTransactionId = GetCurrentDistributedTransactionId();
appendStringInfo(beginAndSetDistributedTransactionId, appendStringInfo(beginAndSetDistributedTransactionId,
"SELECT assign_distributed_transaction_id(%d, %ld, '%s')", "SELECT assign_distributed_transaction_id(%d, %ld, '%s')",
distributedTransactionId->initiatorNodeIdentifier, distributedTransactionId->initiatorNodeIdentifier,

2
src/include/distributed/transaction_identifier.h
View File

@ -34,6 +34,6 @@ typedef struct DistributedTransactionId
} DistributedTransactionId; } DistributedTransactionId;
extern DistributedTransactionId * GetCurrentDistributedTransctionId(void); extern DistributedTransactionId * GetCurrentDistributedTransactionId(void);
#endif /* TRANSACTION_IDENTIFIER_H */ #endif /* TRANSACTION_IDENTIFIER_H */