| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
exchange is deleted/recreated
SemanticState::route() uses a simple cache variable to avoid looking
up the exchange for every message. However if the exchange in question
is deleted, even if then recreated, this can cause inconsistencies in
a cluster.
Even in a stand-alone broker messages can be routed by a deleted
exchange because of the cache.
Fix is to mark the exchange deleted and check the status when using
the cached exchange.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1095144 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Previously if multiple queues were bound to the same routing key,
then a failure to deliver to one of the queues (e.g. policy limit
error) could prevent delivery on some of the other queues.
With this commit the exchange delivers to every queue that did not
have an error before raising an error.
Note: this was originally committed as r1092765, but it caused test
failures was reverted as r1092804. The original commit did not create
exceptions of the correct type.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1094734 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
an error."
This reverts commit r1092765 which introduced test failures in make check.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1092804 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
Previously if multiple queues were bound to the same routing key,
then a failure to deliver to one of the queues (e.g. policy limit
error) could prevent delivery on some of the other queues.
With this commit the exchange delivers to every queue that did not
have an error before raising an error.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1092765 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1092306 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
to unsigned values
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1092219 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1090266 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1088738 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Fix is a race condition in posix/Socket.cpp Socket::connect.
When connecting to a port on the same host which no longer has a
process associated with it the OS occasionally chooses the remote
port (which is unoccupied) as the port to bind the local end of the
socket, resulting in a "circular" connection.
This seems like something the OS should prevent but I have confirmed
that the sporadic hangs in cluster_tests.LongTests.test_failover on
RHEL5 are caused by such a circular connection.
The fix is to detect circular connections and raise an error.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087052 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
added check for ais_exec running -- or don't run these clustered tests
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1082812 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The non-clustered versions of the sasl_fed_ex tests should probably not attempt to load cluster.so.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1082804 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
This is a test-only fix.
Tell the client explicitly to use DIGEST-MD5, rather than possibly defaulting to a mech that the test has not prepared for.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1082685 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
indefinitely.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1082668 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
qpid-cpp-benchmark
- qpid-cluster-benchmark: added command line options.
- qpid-cpp-benchmark: clean up error handling, fixed a race condition.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1081396 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
test_dr_no_message was using unreliable sleeps to try to determine expiry of messages.
There's no obvious way to implement the test correctly.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1080945 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- simplified brokertest.py using subprocess.Popen file redirection instead of threads.
- fixed the hang in test_failover
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1080786 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079808 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
clustered versions of the 4 federated sasl external tests.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079539 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
receive path.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079385 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
With the store doing async completions, completion IO callbacks could
be queued differently on different nodes. This led to inconsistent
management changes in a cluster when a connection was modified in an
IO callback.
Fix was to mark IO callback processing as not cluster safe, so
connections don't record management stats during an IO callback.
Test changes:
- enable durable tests in test_management.
- add substitutions to mask known issue of inconsistent "stats changed" messages.
- add transactional client to test_management.
- ignore heartbeat connection close logs in cluster_test_logs.py
- make brokertest.retry more accurate
- fix minor bug in brokertest.log_ready.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1078947 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
The core script sasl_fed_ex ( used by sasl_fed_ex_* ) is modified to
encapsulate broker creation, and handle clustering -- toggled by a new
argument.
This is an intermediate checkin. There are not yet any scripts that
actually invoke the new clustering capability.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1078745 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1077902 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
and the host system timing base yields and elapsed time of zero.
The change is to throw a meaningful error message rather than throwing
an obscure DIV0 error.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076652 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
in a cluster.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076375 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076329 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
removing qrsh -- was never used.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075874 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075471 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075470 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
4 tests with a common core. They are:
sasl_fed_ex_dynamic
sasl_fed_ex_link
sasl_fed_ex_queue
sasl_fed_ex_route
( and the common core is sasl_fed_ex )
These tests correspond to the 4 different ways that the
qpid-route command has of making links, or links+routes.
All those pathways have to be modified so that the new
"mechanism" argument information can be passed down and
used -- so that you can specify a SASL mechnism to be
used on the interbroker link that you create.
( So -- the qpid-route command also had to be modified
to propagate the mechanism info with all 4 subcommands. )
Since the SASL mechanism is owned by the link, these
tests check that the link comes up and becomes operational.
Finally, I modified the sasl-mechanism flag in qpid-route
to call it "client-sasl-mechanism" to better distinguish
between the SASL mechanism used in the created route -- and
the SASL mechanism (if any) that is used when the qpid-route
client itself connects to the broker that it is talking to.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075452 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
* don't create queue on recovery
* ensure laternate exchange is set before creating store record for queue
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075331 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
arguments
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1074698 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1074611 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
assert
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073945 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
[Also modified acl unit test module to allow the policy file used to be configurable, making it easier to run standalone. Reset policy to allow all on tear down to allow repeated runs.]
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073726 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073490 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073139 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073134 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
rejected messages.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073085 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073033 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1072928 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1072925 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1072356 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1072179 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071252 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071018 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1070634 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The qpid-send test client with argument --durable only sends the first
message as durable. Subsequent messages are not durable.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069916 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
QPID-2104: LVQ enhancement
These both required some refactoring of the Queue class to allow cleaner implementation of different types of behaviour. The in-memory storage of messages is now abstracted out behind an interface specified by qpid::broker::Messages which qpid::broker::Queue uses. Different implementations of that are available for the standard FIFO queue, priority queues and LVQ (I have also separated out the 'legacy' implementation of LVQ from the new version driven by QPID-2104).
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069322 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
when a Receiver is closed.
This only releases messages in the client's cache that have not been read. It does not release messages that have been read by the client application, but not acknowledged.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069030 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
Sporadically the test was failing because the session associated with
an inter-broker bridge was created out of order with other
objects. This is unlikely to cause a fatal cluster inconsistency in
practice but it has been corrected in any case. The fix was to delay
creation of the management object for a bridge session till a point
which is consistent on all cluster members.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068554 13f79535-47bb-0310-9956-ffa450edef68
|