@@ -924,7 +924,7 @@ MtmEndTransaction(MtmCurrentTrans* x, bool commit)
924
924
* Send notification only if ABORT happens during transaction processing at replicas,
925
925
* do not send notification if ABORT is received from master
926
926
*/
927
- MTM_LOG2 ("%d: send ABORT notification abort transaction %d to coordinator %d" , MyProcPid , x -> gtid .xid , x -> gtid .node );
927
+ MTM_LOG1 ("%d: send ABORT notification abort transaction %d to coordinator %d" , MyProcPid , x -> gtid .xid , x -> gtid .node );
928
928
if (ts == NULL ) {
929
929
Assert (TransactionIdIsValid (x -> xid ));
930
930
ts = hash_search (MtmXid2State , & x -> xid , HASH_ENTER , NULL );
@@ -1379,7 +1379,7 @@ bool MtmRefreshClusterStatus(bool nowait)
1379
1379
for (ts = Mtm -> transListHead ; ts != NULL ; ts = ts -> next ) {
1380
1380
if (!ts -> votingCompleted && MtmIsCoordinator (ts )) {
1381
1381
if (ts -> status != TRANSACTION_STATUS_ABORTED ) {
1382
- MTM_LOG1 ("Rollback active transaction %d:%d" , ts -> gtid .node , ts -> gtid .xid );
1382
+ MTM_LOG1 ("1) Rollback active transaction %d:%d:%d " , ts -> gtid .node , ts -> gtid .xid , ts -> xid );
1383
1383
MtmAbortTransaction (ts );
1384
1384
}
1385
1385
MtmWakeUpBackend (ts );
@@ -1445,7 +1445,7 @@ void MtmOnNodeDisconnect(int nodeId)
1445
1445
for (ts = Mtm -> transListHead ; ts != NULL ; ts = ts -> next ) {
1446
1446
if (!ts -> votingCompleted && MtmIsCoordinator (ts )) {
1447
1447
if (ts -> status != TRANSACTION_STATUS_ABORTED ) {
1448
- MTM_LOG1 ("Rollback active transaction %d:%d" , ts -> gtid .node , ts -> gtid .xid );
1448
+ MTM_LOG1 ("2) Rollback active transaction %d:%d" , ts -> gtid .node , ts -> gtid .xid );
1449
1449
MtmAbortTransaction (ts );
1450
1450
}
1451
1451
MtmWakeUpBackend (ts );
0 commit comments