release MtmLock during GetLoggedPreparedXactState

kelvich · kelvich · commit 3846ecbda6af · 2018-01-29T18:22:08.000+03:00
diff --git a/arbiter.c b/arbiter.c
@@ -968,7 +968,12 @@ static void MtmReceiver(Datum arg)
 						tm = (MtmTransMap*)hash_search(MtmGid2State, msg->gid, HASH_FIND, NULL);
 						if (tm == NULL || tm->state == NULL)
 						{
-							XidStatus status = GetLoggedPreparedXactState(msg->gid);
+							XidStatus status;
+
+							MtmUnlock();
+							status = GetLoggedPreparedXactState(msg->gid);
+							MtmLock(LW_EXCLUSIVE);
+
 							if (status == TRANSACTION_STATUS_UNKNOWN)
 							{
 								MTM_ELOG(WARNING, "Request for unexisted transaction %s from node %d", msg->gid, node);

Original file line number	Diff line number	Diff line change
`@@ -968,7 +968,12 @@ static void MtmReceiver(Datum arg)`
`968`	`968`	`tm = (MtmTransMap*)hash_search(MtmGid2State, msg->gid, HASH_FIND, NULL);`
`969`	`969`	`if (tm == NULL \|\| tm->state == NULL)`
`970`	`970`	`{`
`971`		`- XidStatus status = GetLoggedPreparedXactState(msg->gid);`
	`971`	`+ XidStatus status;`
	`972`	`+`
	`973`	`+ MtmUnlock();`
	`974`	`+ status = GetLoggedPreparedXactState(msg->gid);`
	`975`	`+ MtmLock(LW_EXCLUSIVE);`
	`976`	`+`
`972`	`977`	`if (status == TRANSACTION_STATUS_UNKNOWN)`
`973`	`978`	`{`
`974`	`979`	`MTM_ELOG(WARNING, "Request for unexisted transaction %s from node %d", msg->gid, node);`