@@ -44,7 +44,7 @@ static Snapshot DtmGetSnapshot(Snapshot snapshot);
44
44
static void DtmCopySnapshot (Snapshot dst , Snapshot src );
45
45
static XidStatus DtmGetTransactionStatus (TransactionId xid , XLogRecPtr * lsn );
46
46
static void DtmSetTransactionStatus (TransactionId xid , int nsubxids , TransactionId * subxids , XidStatus status , XLogRecPtr lsn );
47
- static XidStatus DtmGetGloabalTransStatus (TransactionId xid );
47
+ static XidStatus DtmGetGlobalTransStatus (TransactionId xid );
48
48
static void DtmUpdateRecentXmin (void );
49
49
// static bool IsInDtmSnapshot(TransactionId xid);
50
50
static bool DtmTransactionIsInProgress (TransactionId xid );
@@ -188,9 +188,9 @@ static bool DtmTransactionIsInProgress(TransactionId xid)
188
188
return TransactionIdIsRunning (xid );// || IsInDtmSnapshot(xid);
189
189
}
190
190
191
- static XidStatus DtmGetGloabalTransStatus (TransactionId xid )
191
+ static XidStatus DtmGetGlobalTransStatus (TransactionId xid )
192
192
{
193
- XTM_TRACE ("XTM: DtmGetGloabalTransStatus \n" );
193
+ XTM_TRACE ("XTM: DtmGetGlobalTransStatus \n" );
194
194
while (true) {
195
195
XidStatus status ;
196
196
DtmEnsureConnection ();
@@ -214,7 +214,7 @@ static XidStatus DtmGetTransactionStatus(TransactionId xid, XLogRecPtr *lsn)
214
214
XTM_TRACE ("XTM: DtmGetTransactionStatus \n" );
215
215
#if 0
216
216
if (status == TRANSACTION_STATUS_IN_PROGRESS ) {
217
- status = DtmGetGloabalTransStatus (xid );
217
+ status = DtmGetGlobalTransStatus (xid );
218
218
if (status == TRANSACTION_STATUS_UNKNOWN ) {
219
219
status = TRANSACTION_STATUS_IN_PROGRESS ;
220
220
}
@@ -238,13 +238,13 @@ static void DtmSetTransactionStatus(TransactionId xid, int nsubxids, Transaction
238
238
if (!DtmGlobalSetTransStatus (DtmConn , DtmNodeId , xid , status ) && status != TRANSACTION_STATUS_ABORTED ) {
239
239
elog (ERROR , "DTMD failed to set transaction status" );
240
240
}
241
- status = DtmGetGloabalTransStatus (xid );
241
+ status = DtmGetGlobalTransStatus (xid );
242
242
Assert (status == TRANSACTION_STATUS_ABORTED || status == TRANSACTION_STATUS_COMMITTED );
243
243
} else {
244
244
elog (WARNING , "Set transaction %u status in local CLOG" , xid );
245
245
}
246
246
} else {
247
- XidStatus gs = DtmGetGloabalTransStatus (xid );
247
+ XidStatus gs = DtmGetGlobalTransStatus (xid );
248
248
if (gs != TRANSACTION_STATUS_UNKNOWN ) {
249
249
status = gs ;
250
250
}
0 commit comments