Commit026ad4f

committed

Disable pglogical trace output

1 parentc7b969f commit026ad4fCopy full SHA for 026ad4f

File tree

-4

lines changed

-4

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -567,9 +567,9 @@ process_remote_commit(StringInfo in)`
`567`	`567`	`{`
`568`	`568`	`Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));`
`569`	`569`	`gid=pq_getmsgstring(in);`
`570`		`-MTM_LOG1("%d: PGLOGICAL_ABORT_PREPARED commit: gid=%s",MyProcPid,gid);`
	`570`	`+MTM_LOG2("%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`	`+MTM_LOG2("%d: PGLOGICAL_ABORT_PREPARED commit: gid=%s #2",MyProcPid,gid);`
`573`	`573`	`StartTransactionCommand();`
`574`	`574`	`MtmSetCurrentTransactionGID(gid);`
`575`	`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_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());`
	`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());`
`164`	`164`
`165`	`165`	`/* send the flags field */`
`166`	`166`	`pq_sendbyte(out,flags);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ def test_1_node_disconnect(self):`
`44`	`44`	`print(agg)`
`45`	`45`	`print(" ")`
`46`	`46`
`47`		`-subprocess.check_call(['blockade','join'])`
	`47`	`+#subprocess.check_call(['blockade','join'])`
`48`	`48`
`49`	`49`	`print('Waiting 15s to join node')`
`50`	`50`	`foriinrange(1000):`

Comments

(0)