Attachment 857827 Details for Bug 1060202 – Patch for qpid-txtest to create orphaned DTX transactions

[patch] Patch for qpid-txtest to create orphaned DTX transactions

qpid-txtest_modified.patch (text/plain), 2.45 KB, created by Pavel Moravec on 2014-01-31 12:51:22 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2014-01-31 12:51:22 UTC

Size: 2.45 KB

patch

obsolete

>Index: ../src/tests/qpid-txtest.cpp
>===================================================================
>--- ../src/tests/qpid-txtest.cpp	(revision 1562753)
>+++ ../src/tests/qpid-txtest.cpp	(working copy)
>@@ -57,12 +57,13 @@
>     uint txCount;
>     uint totalMsgCount;
>     bool dtx;
>+    bool dtxCommit;
>     bool quiet;
> 
>     Args() : init(true), transfer(true), check(true),
>              size(256), durable(true), queues(2),
>              base("tx-test"), msgsPerTx(1), txCount(1), totalMsgCount(10),
>-             dtx(false), quiet(false)
>+             dtx(false), dtxCommit(true), quiet(false)
>     {
>         addOptions()
> 
>@@ -77,6 +78,7 @@
>             ("tx-count", optValue(txCount, "N"), "number of transactions per 'agent'")
>             ("total-messages", optValue(totalMsgCount, "N"), "total number of messages in 'circulation'")
>             ("dtx", optValue(dtx, "yes|no"), "use distributed transactions")
>+            ("dtx-commit", optValue(dtxCommit, "yes|no"), "commit distributed transactions")
>             ("quiet", optValue(quiet), "reduce output from test");
>     }
> };
>@@ -157,6 +159,7 @@
>                 if (opts.dtx) {
>                     setNewXid(xid);
>                     session.dtxStart(arg::xid=xid);
>+                    std::cout << xid << std::endl;
>                 }
>                 for (uint m = 0; m < opts.msgsPerTx; m++) {
>                     in = lq.pop();
>@@ -175,7 +178,8 @@
>                 if (opts.dtx) {
>                     session.dtxEnd(arg::xid=xid);
>                     session.dtxPrepare(arg::xid=xid);
>-                    session.dtxCommit(arg::xid=xid);
>+                    if (opts.dtxCommit)
>+                      session.dtxCommit(arg::xid=xid);
>                 } else {
>                     session.txCommit();
>                 }
>@@ -261,10 +265,12 @@
>                     if (!opts.quiet) std::cout << (i%2 ? " * aborting " : " * committing ");
>                     xid.print(std::cout);
>                     std::cout << std::endl;
>-                    if (i%2) {
>-                        session.dtxRollback(arg::xid=xid);
>-                    } else {
>-                        session.dtxCommit(arg::xid=xid);
>+                    if (opts.dtxCommit) {
>+                        if (i%2) {
>+                            session.dtxRollback(arg::xid=xid);
>+                        } else {
>+                            session.dtxCommit(arg::xid=xid);
>+                        }
>                     }
>                 }
>             }

Actions: View | Diff

Attachments on bug 1060202: 857827 | 857888