| 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
|
| |
|
|
| |
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
|
| |
|
|
| |
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
|
| |
|
|
|
|
|
| |
- 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@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
|
| |
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1158370 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1157907 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
- short perftest run which connects to ::1 (old client API)
- qpid-send/qpid-receive sending messages between them (new messaging API)
- Simple 2 broker federation over IPv6 test
- Simple cluster failover via IPv6 test
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1157279 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
connection URLs
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1157275 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1157274 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
- If we fail to reset the epoll settings of a file handle when going
round the poll loop and it's because the handle is not in the epoll
set then just try to add it into the epoll set.
This gets round the case where connect closes a socket fd (implicitly
taking out of all epoll sets) and then tries to connect again.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1157273 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
- On the Listen side we create separate listening sockets for IPv4 and IPv6
making sure to not allow the IPv6 socket to run dual stack. This makes the
reported IPv4 addresses look "normal" and would allow us to turn control
IPv4/IPv6 listening separately.
- On the connect side we make sure to try all the addresses returned by
getaddrinfo() in order until we either find one that connects or have
tried all of them.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1157272 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the ssf (security strength factor). also a change to logging level of one message, so that when we see the list of mechanisms, we will always also see which one was chosen.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1156604 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
for explicitly named links
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1156586 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1156560 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1156327 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1156266 13f79535-47bb-0310-9956-ffa450edef68
|