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

Commitd9e27e3

Browse files
committed
Remove dump of snapshot
1 parent2c83897 commitd9e27e3

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

‎contrib/multimaster/multimaster.c‎

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,7 @@ static BackgroundWorker DtmWorker = {
158158

159159
staticvoidDumpSnapshot(Snapshots,char*name)
160160
{
161+
#ifdefDUMP_SNAPSHOT
161162
inti;
162163
charbuf[10000];
163164
char*cursor=buf;
@@ -175,6 +176,7 @@ static void DumpSnapshot(Snapshot s, char *name)
175176
}
176177
cursor+=sprintf(cursor,"]");
177178
XTM_INFO("%s\n",buf);
179+
#endif
178180
}
179181

180182
/* In snapshots provided by DTMD xip array is sorted, so we can use bsearch */
@@ -244,7 +246,9 @@ static void DtmMergeWithGlobalSnapshot(Snapshot dst)
244246
for (xid=dst->xmax;xid<src->xmax;xid++)
245247
if (TransactionIdIsInDoubt(xid))
246248
gotoGetLocalSnapshot;
247-
DumpSnapshot(dst,"local");
249+
250+
GetCurrentTransactionId();
251+
DumpSnapshot(dst,"local");
248252
DumpSnapshot(src,"DTM");
249253

250254
if (src->xmax<dst->xmax)dst->xmax=src->xmax;
@@ -764,6 +768,7 @@ DtmXactCallback(XactEvent event, void *arg)
764768
MMBeginTransaction();
765769
}
766770
break;
771+
#if0
767772
caseXACT_EVENT_PRE_COMMIT:
768773
caseXACT_EVENT_PARALLEL_PRE_COMMIT:
769774
{
@@ -774,6 +779,7 @@ DtmXactCallback(XactEvent event, void *arg)
774779
}
775780
break;
776781
}
782+
#endif
777783
caseXACT_EVENT_COMMIT:
778784
caseXACT_EVENT_ABORT:
779785
if (TransactionIdIsValid(DtmNextXid))

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp