diff options
| author | Alan Conway <aconway@apache.org> | 2009-06-16 21:21:09 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-06-16 21:21:09 +0000 |
| commit | 80d65b38008d9b7f31c825508819f9600d63b63c (patch) | |
| tree | 316862bff35f1cae6f0d1152dcf4a6e3b0f967ed /cpp/src/qpid/cluster/Connection.h | |
| parent | f5e98a6dfb8c4defe22755340f440e6f16c2559a (diff) | |
| download | qpid-python-80d65b38008d9b7f31c825508819f9600d63b63c.tar.gz | |
Performance improvements in AggregateOutput and SemanticState.
Replaced AggregateOutput hierarchy with a flat list per connection
holding only the OutputTasks that are potentially active. Tasks are
droped from the list as soon as they return false, and added back when
they may have output.
Inlined frequently-used SequenceNumber functions.
Replace std::list in QueueListeners with std::vector.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@785408 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.h')
| -rw-r--r-- | cpp/src/qpid/cluster/Connection.h | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/Connection.h b/cpp/src/qpid/cluster/Connection.h index 8e3b0ad337..51aab92bfc 100644 --- a/cpp/src/qpid/cluster/Connection.h +++ b/cpp/src/qpid/cluster/Connection.h @@ -103,7 +103,7 @@ class Connection : // Called for data delivered from the cluster. void deliveredFrame(const EventFrame&); - void consumerState(const std::string& name, bool blocked, bool notifyEnabled); + void consumerState(const std::string& name, bool blocked, bool notifyEnabled, bool isInListener); // ==== Used in catch-up mode to build initial state. // @@ -115,6 +115,8 @@ class Connection : const framing::SequenceNumber& received, const framing::SequenceSet& unknownCompleted, const SequenceSet& receivedIncomplete); + void outputTask(uint16_t channel, const std::string& name); + void shadowReady(uint64_t memberId, uint64_t connectionId, const std::string& username, const std::string& fragment, uint32_t sendMax); void membership(const framing::FieldTable&, const framing::FieldTable&, uint64_t frameSeq); |