Commit0a5d843

committed

mention node number in 'aborted by DTM' error message

1 parent8b8666e commit0a5d843Copy full SHA for 0a5d843

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1075,6 +1075,7 @@ static void MtmReceiver(Datum arg)`
`1075`	`1075`	`if (ts->status!=TRANSACTION_STATUS_ABORTED) {`
`1076`	`1076`	`MTM_LOG1("Arbiter receive abort message for transaction %s (%llu) from node %d",ts->gid, (long64)ts->xid,node);`
`1077`	`1077`	`Assert(ts->status==TRANSACTION_STATUS_IN_PROGRESS);`
	`1078`	`+ts->aborted_by_node=node;`
`1078`	`1079`	`MtmAbortTransaction(ts);`
`1079`	`1080`	`}`
`1080`	`1081`	`if ((ts->participantsMask& ~Mtm->disabledNodeMask& ~ts->votedMask)==0) {`

Lines changed: 5 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -4750,8 +4750,12 @@ static bool MtmTwoPhaseCommit(MtmCurrentTrans* x)`
`4750`	`4750`	`}else {`
`4751`	`4751`	`Assert(x->isActive);`
`4752`	`4752`	`if (x->status==TRANSACTION_STATUS_ABORTED) {`
	`4753`	`+MtmTransState*ts;`
	`4754`	`+ts= (MtmTransState*)hash_search(MtmXid2State,&(x->xid),HASH_FIND,NULL);`
	`4755`	`+Assert(ts);`
	`4756`	`+`
`4753`	`4757`	`FinishPreparedTransaction(x->gid, false);`
`4754`		`-MTM_ELOG(ERROR,"Transaction %s (%llu) is aborted onneighbournode. Checkneighbour nodeslog to see error details.",x->gid, (long64)x->xid);`
	`4758`	`+MTM_ELOG(ERROR,"Transaction %s (%llu) is aborted on node %d. Checkitslog to see error details.",x->gid, (long64)x->xid,ts->aborted_by_node);`
`4755`	`4759`	`}else {`
`4756`	`4760`	`FinishPreparedTransaction(x->gid, true);`
`4757`	`4761`	`MTM_LOG2("Distributed transaction %s (%lld) is committed at %lld with LSN=%lld",x->gid, (long64)x->xid,MtmGetCurrentTime(), (long64)GetXLogInsertRecPtr());`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -267,6 +267,7 @@ typedef struct MtmTransState`
`267`	`267`	`nodemask_tparticipantsMask;/* Mask of nodes involved in transaction */`
`268`	`268`	`nodemask_tvotedMask;/* Mask of voted nodes */`
`269`	`269`	`TransactionIdxids[1];/* [Mtm->nAllNodes]: transaction ID at replicas */`
	`270`	`+intaborted_by_node;/* Store info about node on which this tx was aborted */`
`270`	`271`	`}MtmTransState;`
`271`	`272`
`272`	`273`	`typedefstruct {`

Comments

(0)