| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165889 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165888 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165887 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
- handler/context/replica convention (see overview.h doc notes)
- rename BrokerHandler to BrokerContext
- notify Cluster (BrokerContext) on queue stopped or empty (need empty?)
- Implementing Stoppable & stoppable scopes in Queue.cpp
- Move queue ownership logic from dequeue to acquire
Releasing on message count will not work, switch to timer based release.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165886 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165884 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165883 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
to work.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165882 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Stop consumers from dispatching and wait for already dispatching consumers to exit.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165881 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added a 1ms sleep when CPG is flow controlled. Huge thruput
improvement for qpid-cluster-benchmarks multi-host case.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165880 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- fixed error message.
- add necessary waiting to deal with async wiring in the new cluster.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165879 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165878 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Re-arranged queue creation/deletion to avoid wiring races.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165877 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165876 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Send multiple multicast events in a single call to CPG using iovec.
Encoding in the sending thread using reference counted buffers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165875 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Experimental code to investigate & measure performance of new cluster design ideas.
Experimental classes are in src/qpid/cluster/exp.
New broker::Cluster interface provides call points for cluster. Similar to
store but has more operations, may be merged at a future point.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165874 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Applied partial patch from Darryl Pierce
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1165794 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1165391 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1164249 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1164247 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
- Update suspended & ended transactions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1164246 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Clock events are much too frequent to log, doing so makes trace
logging useless for clustered brokers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163766 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Add a dialog to select version of Visual Studio as cmake generator.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163754 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
(0013)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163537 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
object (0012)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163536 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
(0011)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163534 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
receivers (0010)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163529 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163526 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163347 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163290 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The change did not compile on windows due to EXTERN declaration issues.
Changes has been backed out as it is not critical and can be addressed elsewhere.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163275 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Previous fix was incomplete. The class Msg is used by Variant.cpp in the types library.
Moved the Msg class from common to types library.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1162273 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
See qpid/cpp/design_docs/hot-standby-design.txt
This is in competition with the previous active-active cluster design
in qpid/cpp/design_docs/new-cluster-design.txt
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1162272 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- Added the QPID_COMMON_EXTERN declaration to Msg.h
- Removed a spurious #include "Msg.h" from qpid/types/Variant.cpp
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1162233 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1162219 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1162104 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1162092 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Prevent infinite loop when unable to decode frame in SASL security layer.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1162060 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
XP. Addresses note I left in QPID-3406.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1161783 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
- Replicate DTX state to new members joining.
- Use cluster timer for DTX timeouts.
- Incidental: quote nulls in qpid::Msg messages (XIDs often have null characters)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1161742 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1161152 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
handling for message decode. Patch from Paul Colby.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1161119 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
lack of exported method
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1160612 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
violations to match that specified for 'exchange-name-required'
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1160607 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- Previously we weren't correctly handling synchronous errors when we
attempted to connect.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1160458 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
The initial fix for this bug was incomplete.
The original bug was triggered by a faulty client sending
session.attach before connection.open. The special case is when the
session.attach is on channel 0. This commit fixes the broker for all
cases where a faulty client sends frames before completly opening the
connection.
Older versions of the Java client are known to send this faulty sequence sporadically,
see https://issues.apache.org/jira/browse/QPID-3042.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1159329 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1159324 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
possible infinite loop
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1159293 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Was causing problems with changes to introduce IPv6.
In most cases this was being used unnecessarilly due to cut-and-paste of tests.
In the 2 cases it was useful, replaced by simply shutting down the broker
to simulate network failure.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1159268 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
- Move (almost) all knowledge of difference in address types to SocketAddress
- Make the Windows and Posix sockets code more similar with the aim of
eliminating differences in the future
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1158934 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
1. Delete Microsoft name in some projects.
2. Get rid of ascii codes >= 0x80. The copyright symbol is the main culprit.
3. Change 2010 to 2011.
4. Minor tab and trailing whitespace removal.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1158873 13f79535-47bb-0310-9956-ffa450edef68
|