Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 9148acb

Browse files
committed
dismiss several asserts in receiver
1 parent 4d77153 commit 9148acb

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

contrib/mmts/pglogical_apply.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -791,7 +791,7 @@ process_remote_commit(StringInfo in)
791791
{
792792
case PGLOGICAL_PRECOMMIT_PREPARED:
793793
{
794-
Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));
794+
// Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));
795795
strncpy(gid, pq_getmsgstring(in), sizeof gid);
796796
MTM_LOG2("%d: PGLOGICAL_PRECOMMIT_PREPARED %s, (%llx,%llx,%llx)", MyProcPid, gid, commit_lsn, end_lsn, origin_lsn);
797797
MtmBeginSession(origin_node);
@@ -874,7 +874,7 @@ process_remote_commit(StringInfo in)
874874
}
875875
case PGLOGICAL_ABORT_PREPARED:
876876
{
877-
Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));
877+
// Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));
878878
strncpy(gid, pq_getmsgstring(in), sizeof gid);
879879
/* MtmRollbackPreparedTransaction will set origin session itself */
880880
MTM_LOG1("Receive ABORT_PREPARED logical message for transaction %s from node %d", gid, origin_node);

0 commit comments

Comments
 (0)