Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit77fdb2c

Browse files
committed
log levels and DDD
1 parent33db855 commit77fdb2c

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

‎multimaster.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3292,7 +3292,7 @@ MtmDetectGlobalDeadLock(PGPROC* proc)
32923292

32933293
ByteBufferAlloc(&buf);
32943294
EnumerateLocks(MtmSerializeLock,&buf);
3295-
RaftableSet(psprintf("lock-graph-%d",MtmNodeId),buf.data,buf.used,true);
3295+
RaftableSet(psprintf("lock-graph-%d",MtmNodeId),buf.data,buf.used,false);
32963296
MtmGraphInit(&graph);
32973297
MtmGraphAdd(&graph, (GlobalTransactionId*)buf.data,buf.used/sizeof(GlobalTransactionId));
32983298
ByteBufferFree(&buf);

‎pglogical_apply.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -525,7 +525,7 @@ process_remote_commit(StringInfo in)
525525
{
526526
casePGLOGICAL_COMMIT:
527527
{
528-
MTM_LOG1("%d: PGLOGICAL_COMMIT commit",MyProcPid);
528+
MTM_LOG2("%d: PGLOGICAL_COMMIT commit",MyProcPid);
529529
if (IsTransactionState()) {
530530
Assert(TransactionIdIsValid(MtmGetCurrentTransactionId()));
531531
MtmBeginSession();
@@ -542,7 +542,7 @@ process_remote_commit(StringInfo in)
542542
AbortCurrentTransaction();
543543
}else {
544544
/* prepare TBLOCK_INPROGRESS state for PrepareTransactionBlock() */
545-
MTM_LOG1("%ld: PGLOGICAL_PREPARE commit: gid=%s",MtmGetSystemTime(),gid);
545+
MTM_LOG2("%ld: PGLOGICAL_PREPARE commit: gid=%s",MtmGetSystemTime(),gid);
546546
BeginTransactionBlock();
547547
CommitTransactionCommand();
548548
StartTransactionCommand();
@@ -568,7 +568,7 @@ process_remote_commit(StringInfo in)
568568
Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));
569569
csn=pq_getmsgint64(in);
570570
gid=pq_getmsgstring(in);
571-
MTM_LOG1("%ld: PGLOGICAL_COMMIT_PREPARED commit: csn=%ld, gid=%s",MtmGetSystemTime(),csn,gid);
571+
MTM_LOG2("%ld: PGLOGICAL_COMMIT_PREPARED commit: csn=%ld, gid=%s",MtmGetSystemTime(),csn,gid);
572572
StartTransactionCommand();
573573
MtmBeginSession();
574574
MtmSetCurrentTransactionCSN(csn);
@@ -581,7 +581,7 @@ process_remote_commit(StringInfo in)
581581
{
582582
Assert(!TransactionIdIsValid(MtmGetCurrentTransactionId()));
583583
gid=pq_getmsgstring(in);
584-
MTM_LOG1("%ld: PGLOGICAL_ABORT_PREPARED commit: gid=%s",MtmGetSystemTime(),gid);
584+
MTM_LOG2("%ld: PGLOGICAL_ABORT_PREPARED commit: gid=%s",MtmGetSystemTime(),gid);
585585
if (MtmExchangeGlobalTransactionStatus(gid,TRANSACTION_STATUS_ABORTED)==TRANSACTION_STATUS_UNKNOWN) {
586586
MTM_LOG1("%ld: PGLOGICAL_ABORT_PREPARED commit: gid=%s #2",MtmGetSystemTime(),gid);
587587
StartTransactionCommand();

‎pglogical_proto.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ pglogical_write_commit(StringInfo out, PGLogicalOutputData *data,
161161
}
162162
pq_sendbyte(out,'C');/* sending COMMIT */
163163

164-
MTM_LOG1("%ld: PGLOGICAL_SEND commit: event=%d, gid=%s, commit_lsn=%lx, txn->end_lsn=%lx, xlog=%lx",MtmGetSystemTime(),flags,txn->gid,commit_lsn,txn->end_lsn,GetXLogInsertRecPtr());
164+
MTM_LOG2("%ld: PGLOGICAL_SEND commit: event=%d, gid=%s, commit_lsn=%lx, txn->end_lsn=%lx, xlog=%lx",MtmGetSystemTime(),flags,txn->gid,commit_lsn,txn->end_lsn,GetXLogInsertRecPtr());
165165

166166
/* send the flags field */
167167
pq_sendbyte(out,flags);

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp