Commita989c73

committed

extended logging

1 parentdc1837c commita989c73Copy full SHA for a989c73

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -567,8 +567,9 @@ process_remote_commit(StringInfo in)`
`567`	`567`	`{`
`568`	`568`	`Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));`
`569`	`569`	`gid=pq_getmsgstring(in);`
`570`		`-MTM_LOG3("%d: PGLOGICAL_ABORT_PREPARED commit: gid=%s",MyProcPid,gid);`
	`570`	`+MTM_LOG1("%d: PGLOGICAL_ABORT_PREPARED commit: gid=%s",MyProcPid,gid);`
`571`	`571`	`if (MtmGetGlobalTransactionStatus(gid)!=TRANSACTION_STATUS_ABORTED) {`
	`572`	`+MTM_LOG1("%d: PGLOGICAL_ABORT_PREPARED commit: gid=%s #2",MyProcPid,gid);`
`572`	`573`	`StartTransactionCommand();`
`573`	`574`	`MtmSetCurrentTransactionGID(gid);`
`574`	`575`	`FinishPreparedTransaction(gid, false);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -160,7 +160,7 @@ pglogical_write_commit(StringInfo out, PGLogicalOutputData *data,`
`160`	`160`	`}`
`161`	`161`	`pq_sendbyte(out,'C');/* sending COMMIT */`
`162`	`162`
`163`		`-MTM_LOG2("PGLOGICAL_SEND commit: event=%d, gid=%s, commit_lsn=%lx, txn->end_lsn=%lx, xlog=%lx",flags,txn->gid,commit_lsn,txn->end_lsn,GetXLogInsertRecPtr());`
	`163`	`+MTM_LOG1("PGLOGICAL_SEND commit: event=%d, gid=%s, commit_lsn=%lx, txn->end_lsn=%lx, xlog=%lx",flags,txn->gid,commit_lsn,txn->end_lsn,GetXLogInsertRecPtr());`
`164`	`164`
`165`	`165`	`/* send the flags field */`
`166`	`166`	`pq_sendbyte(out,flags);`

Comments

(0)