| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
Added to TCP (without specific port capability)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1410364 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Added broker interface option to specify network interfaces for listening
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1410363 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Added functions to find machines network interface names and addresses
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1410362 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1410360 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409869 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
a binding key) by receivers and used as default value for senders
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409813 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409812 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- Don't initialize HaBroker if management is disabled.
- Fix use of constants from another compilation unit in QueueReplicator.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409327 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
This reverts r1403946: There was a problem with this, for example if I bind a
queue Q to receive broker events. On the backup, Q will receive double events:
from the replicating subscription to the primary and events generated locally in
the backup broker. That can cause the backup to generate "invalid position"
errors and shut down.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409243 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409242 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Imagine a cluster with primary A and backups B and C. A queue Q is created on A
and replicated to B, C. Now A dies and B takes over as primary. Before C can
connect to B, a client destroys Q and creates a new queue with the same name.
When B connects it sees Q and incorrectly assumes it is the same Q that it has
already replicated. Now C has an inconsistent replica of Q.
The fix is to tag queues/exchanges with a UUID so a backup can tell if a queue
is not the same as the one it has already replicated, even if the names are the
same. This all also applies to exchanges.
- Minor imrovements to printing UUIDs in a FieldTable.
- Fix comparison of void Variants, added operator !=
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409241 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409225 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409161 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1409004 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
- In the case of retrying a connection failure the epoll code mistakenly
thinks the connection has just been disconnected and therefore should
never be seen again.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1408983 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
The backup broker was running ExchangeRegistry::for_each to clean up
connections, but this holds the ExchangeRegistry lock and hence the deadlock.
Now we copy a list of exchanges with for_each and work on it without the lock.
The issue showed up for 0 timeouts only because the queue schedules non-0
timeouts to a separate timer thread.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1407661 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
Dillaman)
In a stress tests QMF events were not being propagated to backups. Discovered
that the inter-broker link had hundreds of thousands of enqueued OutputTasks --
representing only a few unique consumers. There should only be only a single
output task for a given consumer. This appears to have stalled the delivery of
QMF messages to the backup broker
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1407543 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Named queues are assumed to exist and should not be declared during bridge creation.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1406809 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1406354 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1406353 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Cycle through the entire pool of (32K) channel Id numbers to defer problem of references which are held for a little too long.
This problem was exposed by QPID-4392 where a channel number wrap problem was repaired.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1405946 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
Demote TimerWarning messages to debug level.
Print them only once per minute.
To enable only these messages when broker is otherwise at INFO log level:
--log-enable debug+:Timer
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1405316 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1405106 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
This reverts commit 750b661d428e76ab7b4a006beb799a03e2e9cbb5.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1405012 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
PACKAGE_NAME is a common name for #define macros in legacy code.
Replaced public PACKAGE_NAME, EVENT_NAME with private camelCase members
and added static getFullName()
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1404665 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
QMF create/delete events for auto-delete queues can be generated out-of-order
because they are not regulated by any lock. This creates problems for HA
replication. This commit does 2 things:
1. Dispatch QMF events via a pollable queue. Events are encoded in the thread
calling raiseEvent then put on a PollableQueue to be dispatched in a separate thread.
This allows us to move the raiseEvent calls inside registry locks to ensure
they are ordered.
2. Move queue create and delete raiseEvent calls inside the queue registry
lock so they are executed in order.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1404590 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1404350 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1403946 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Peeking at the conf sets the error flag and prevents the hang.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1403797 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Using a private class typedef in a free function.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1402191 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Maintain a pool of available channel numbers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1402158 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401831 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401721 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
Related issue discovered while fixing this bug:
The BrokerReplicater pulls management events and query responses from different
queues, there is no co-ordination between them. If a response is processed late,
after create and delete events, it will incorrectly re-create the deleted queue.
This patch ignores responses if we have already seen an event for the queue or
exchange.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401711 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
exchange->bind
In BrokerReplicator, there are a few places that it calls
exchange->bind(). We're seeing some incorrect behavior during failover testing
(e.g. an exchange shows that it has 5 bindings when there is really only 1) and
we think we've narrowed it down to this. Instead of calling exchange->bind(), it
should call queue->bind(). If you look at qpid::broker::Broker::createObject(),
you'll see that this method calls queue->bind() to bind a queue to an exchange.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401710 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
queues
When an auto-delete queue is replicated, the replicating subscription attempts
to auto-delete the queue after it has already been auto-deleted by the closing
of the last non-HA consumer. An issue occurs if a new auto-delete queue with
the same name is created shortly after the deletion of the previously queue.
This can occur when a client subscribes to an auto-delete queue and is
temporarily disconnected from the broker. It is possible for the cancelled HA
subscription to remove the newly created queue from the queue registry since the
old and new queues use the same names. The HA replicating subscription should
not execute the auto-delete logic when the subscription is cancelled.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401709 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
transports
Refactor SslMux support simplifying it and remove need for separate
SslHandler and SslIo code.
Refactored SSL client code to use the same connect and broker SSL to use the same
accept sequences as the TCP code. This also solves QPID-3565: IPv6 support for SSL
transport on Unix C++ client/broker
Remove now unneeded ssl files.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401561 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
transports
Add the security related functions to the Socket/Asynch interfaces
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401560 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
transports
Lift Socket into an interface with concrete implementations
- BSDSocket, WinSocket and SslSocket
- As a side effect completely change the approach we use for platform
specific handles: IOHandle now directly carries the platform handle
but its real type is only exposed to platform specific code.
- Modified RDMA code for the new IOHandle approach
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401559 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
transports
Refactor to unify the various SSL and TCP interfaces:
- Make ssl listen have the same signature as regular sockets
- Give ssl connect same interface as tcp
- Unify the SSL and TCP IO interfaces some more
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401558 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
- Also squash a struct/class warning
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401072 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Variables used in arguments for set_target_properties need to be wrapped
in double quotes. Otherwise when they are undefined Cmake thinks there
are too few arguments present.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400965 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
work and the recent cmake work
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400948 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400880 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Now install most of the test executables
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400783 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
- Make the installed pkgconfig files have the correct paths embedded.
- Use install variables that should be compatible with the variables
set by rpmbuild's %cmake macro
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400780 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400759 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
that is present when links are fine and bridge is unbound.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400736 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400296 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1400295 13f79535-47bb-0310-9956-ffa450edef68
|