End transaction if a participand disconnects from DTMD.

kvap · kvap · commit e5b999cdf257 · 2015-12-09T14:35:59.000+03:00
diff --git a/contrib/pg_dtm/dtmd/src/main.c b/contrib/pg_dtm/dtmd/src/main.c
@@ -167,8 +167,12 @@ static void ondisconnect(client_t client) {
 	
 	if ((t = CLIENT_XPART(client))) {
 		transaction_remove_listener(t, 's', client);
-		if (use_raft && (raft.role == ROLE_LEADER)) {
-			raft_emit(&raft, NEGATIVE, t->xid);
+		if (use_raft) {
+			if (raft.role == ROLE_LEADER) {
+				raft_emit(&raft, NEGATIVE, t->xid);
+			}
+		} else {
+			apply_clog_update(NEGATIVE, t->xid);
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -167,8 +167,12 @@ static void ondisconnect(client_t client) {`
`167`	`167`
`168`	`168`	`if ((t = CLIENT_XPART(client))) {`
`169`	`169`	`transaction_remove_listener(t, 's', client);`
`170`		`- if (use_raft && (raft.role == ROLE_LEADER)) {`
`171`		`- raft_emit(&raft, NEGATIVE, t->xid);`
	`170`	`+ if (use_raft) {`
	`171`	`+ if (raft.role == ROLE_LEADER) {`
	`172`	`+ raft_emit(&raft, NEGATIVE, t->xid);`
	`173`	`+ }`
	`174`	`+ } else {`
	`175`	`+ apply_clog_update(NEGATIVE, t->xid);`
`172`	`176`	`}`
`173`	`177`	`}`
`174`	`178`