delta/python-packages/qpid-python.git/cpp/src/qpid/broker/TxAccept.cpp, branch QPID-6125-ProtocolRefactoring

QPID-5139: HA transactions block a thread, can deadlock the broker

2013-10-29T15:23:49+00:00

PrimaryTxObserver::prepare used to block pending responses from each backup. With
concurrent transactions this can deadlock the broker: once all worker threads
are blocked in prepare, responses from backups cannot be received.

This commit generalizes the async completion mechanism for messages to allow
async completion of arbitrary commands. It leaves the special-case code for
messages undisturbed but adds a second path (starting from
SessionState::handleCommand) for async completion of other commands.
In particular it implements tx.commit to allow async completion.

TxBuffer is now an AsyncCompletion and commitLocal() is split into
- startCommit() called by SemanticState::commit()
- endCommit() called when the commit command completes

TxAccept no longer holds pre-computed ranges, compute fresh each time.
- Avoid range iterators going out of date during a delayed commit.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1536754 13f79535-47bb-0310-9956-ffa450edef68

QPID-4327: HA TX transactions: basic replication.

2013-08-01T20:27:26+00:00

On primary a PrimaryTxObserver observes a transaction's TxBuffer and generates
transaction events on a tx-replication-queue. On the backup a TxReplicator
receives the events and constructs a TxBuffer equivalent to the one in the
primary.

Unfinished:
- Primary does not wait for backups to prepare() before committing.
- All connected backups are assumed to be in the transaction, there are race
  conditions around brokers joining/leavinv where this assumption is invalid.
- Need more tests.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1509423 13f79535-47bb-0310-9956-ffa450edef68

QPID-4327: Added TransactionObserver interface.

2013-08-01T20:26:58+00:00

Added TransactionObserver interface, called at each point in a transaction's
lifecycle. Currently only a single observer can be associated with a
transaction.

Added startTx, startDtx to BrokerObserver so plugins can observe transactions
starting and set a TransactionObserver.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1509421 13f79535-47bb-0310-9956-ffa450edef68

QPID-4327: Refactor to simplify TxAccept.

2013-08-01T20:26:34+00:00

Removed un-necessary RangeOps layers.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1509419 13f79535-47bb-0310-9956-ffa450edef68

Joint checkin from gsim, kpvdr, cctrieloff. See QPID-2102: Exceeding reject queue policy under a transaction causes broker crash

2009-09-22T17:36:01+00:00

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@817742 13f79535-47bb-0310-9956-ffa450edef68

Add directory to #include

2009-07-14T14:32:39+00:00

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793909 13f79535-47bb-0310-9956-ffa450edef68

DeliveryRecord optimizations.

2009-05-06T17:58:50+00:00

Replace linear search with binary search.
Collapse multi-pass mark-then-erase to a signle pass.


git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@772384 13f79535-47bb-0310-9956-ffa450edef68

Replace std::list with std::deque for SemanticState::unacked - more efficient, improves latency.

2009-05-01T19:59:57+00:00

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@770802 13f79535-47bb-0310-9956-ffa450edef68

qpid/broker/QueuePolicy.cpp

2009-03-05T16:29:22+00:00

 - Add a missing std namespace
qpid/broker/TxAccept.cpp
 - Add a missing std namespace


git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@750497 13f79535-47bb-0310-9956-ffa450edef68

QPID-1497: Ensure policy count and size reflect transactionality of dequeues

2008-12-01T19:49:23+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722200 13f79535-47bb-0310-9956-ffa450edef68