@@ -620,7 +620,7 @@ process_remote_commit(StringInfo in)
620
620
Assert (!TransactionIdIsValid (MtmGetCurrentTransactionId ()));
621
621
csn = pq_getmsgint64 (in );
622
622
gid = pq_getmsgstring (in );
623
- MTM_LOG1 ("PGLOGICAL_COMMIT_PREPARED commit: csn=%ld, gid=%s, lsn=%ld" , csn , gid , end_lsn );
623
+ MTM_LOG2 ("PGLOGICAL_COMMIT_PREPARED commit: csn=%ld, gid=%s, lsn=%ld" , csn , gid , end_lsn );
624
624
StartTransactionCommand ();
625
625
MtmBeginSession ();
626
626
MtmSetCurrentTransactionCSN (csn );
@@ -633,9 +633,9 @@ process_remote_commit(StringInfo in)
633
633
{
634
634
Assert (!TransactionIdIsValid (MtmGetCurrentTransactionId ()));
635
635
gid = pq_getmsgstring (in );
636
- MTM_LOG1 ("PGLOGICAL_ABORT_PREPARED commit: gid=%s" , gid );
636
+ MTM_LOG2 ("PGLOGICAL_ABORT_PREPARED commit: gid=%s" , gid );
637
637
if (MtmExchangeGlobalTransactionStatus (gid , TRANSACTION_STATUS_ABORTED ) == TRANSACTION_STATUS_UNKNOWN ) {
638
- MTM_LOG1 ("PGLOGICAL_ABORT_PREPARED commit: gid=%s #2" , gid );
638
+ MTM_LOG2 ("PGLOGICAL_ABORT_PREPARED commit: gid=%s #2" , gid );
639
639
StartTransactionCommand ();
640
640
MtmBeginSession ();
641
641
MtmSetCurrentTransactionGID (gid );
@@ -978,7 +978,7 @@ void MtmExecutor(int id, void* work, size_t size)
978
978
{
979
979
while (true) {
980
980
char action = pq_getmsgbyte (& s );
981
- MTM_LOG1 ("%d: REMOTE process action %c" , MyProcPid , action );
981
+ MTM_LOG3 ("%d: REMOTE process action %c" , MyProcPid , action );
982
982
#if 0
983
983
if (Mtm -> status == MTM_RECOVERY ) {
984
984
MTM_LOG1 ("Replay action %c[%x]" , action , s .data [s .cursor ]);
0 commit comments