summaryrefslogtreecommitdiff
path: root/cpp/src
Commit message (Collapse)AuthorAgeFilesLines
* Replicate connection decoder fragments to new members.Alan Conway2009-03-0223-396/+221
| | | | | | | | | | | | Refactoring: - Merge Decoder into ConnectionMap. - Process cluster controls in event queue thread. - Use counter not pointer for connection ID, avoid re-use. - Do all processing in event queue thread to avoid races (temporary pending performance measurements) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749473 13f79535-47bb-0310-9956-ffa450edef68
* Remove -Wno-missing-field-initializers which is not supported by gcc3.4Andrew Stitcher2009-03-022-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749432 13f79535-47bb-0310-9956-ffa450edef68
* - Reworked DispatchHandler state machine to eliminate race conditionsAndrew Stitcher2009-03-028-87/+246
| | | | | | | | | | | particularly when deleting a DispatchHandle - Reworked Poller interrupt mechanism eliminating locking problems and to support DispatchHandler changes - Beefed up the DispatchHandler test program so that it's a fair torture test of the DispatchHandler code git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749406 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1705: added unit test for heartbeat firing after connection has failed overGordon Sim2009-03-021-0/+85
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749313 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1705: cancel heartbeat timer task as part of cleanupGordon Sim2009-03-021-0/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749297 13f79535-47bb-0310-9956-ffa450edef68
* Add lock to cluster::ConnectionMap, make it thread safe.Alan Conway2009-02-273-12/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748723 13f79535-47bb-0310-9956-ffa450edef68
* Modified so that the content of the message is only parsed if it is used in ↵Jonathan Robie2009-02-272-55/+78
| | | | | | | | | | a binding query. Headers can be queried without parsing the message. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748689 13f79535-47bb-0310-9956-ffa450edef68
* cluster: apply membership updates while in CATCHUP mode.Alan Conway2009-02-272-10/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748651 13f79535-47bb-0310-9956-ffa450edef68
* Sorry, forgot a crucial line in my last 'fix'!Gordon Sim2009-02-271-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748640 13f79535-47bb-0310-9956-ffa450edef68
* Fix test to account for failure after last message has been delivered, but ↵Gordon Sim2009-02-271-4/+8
| | | | | | before the session and connection are closed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748624 13f79535-47bb-0310-9956-ffa450edef68
* Fix to avoid spinning if an exception is thrown in cluster::PollableQueue.Alan Conway2009-02-261-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748339 13f79535-47bb-0310-9956-ffa450edef68
* Send session.detached back to server in response to a detach.Gordon Sim2009-02-261-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748286 13f79535-47bb-0310-9956-ffa450edef68
* Add browse option, useful for ad-hoc testing.Gordon Sim2009-02-261-6/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748252 13f79535-47bb-0310-9956-ffa450edef68
* Added a couple of extra options that are useful in ad-hoc testing.Gordon Sim2009-02-261-7/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748222 13f79535-47bb-0310-9956-ffa450edef68
* Remove "flow enabled" log messages.Alan Conway2009-02-262-10/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748215 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1695: Make LVQ persist durable messagesGordon Sim2009-02-263-7/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748214 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1693: Improvements to failover soak test from mgoulish@redhat.comGordon Sim2009-02-261-40/+129
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748081 13f79535-47bb-0310-9956-ffa450edef68
* Add FrameDecoder unit test, update comments in Cluster.h/cpp.Alan Conway2009-02-254-5/+82
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747947 13f79535-47bb-0310-9956-ffa450edef68
* Bugfix: This fixes a bug in the management agent where an explicit get-requestTed Ross2009-02-252-0/+12
| | | | | | | | | on an object would cause the last-modified timestamp of the object to not get updated if the object had been modified since the last publish interval. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747946 13f79535-47bb-0310-9956-ffa450edef68
* Need to register finalizer so that we can release the shared pointer to the ↵Gordon Sim2009-02-252-0/+3
| | | | | | queue and have the queue deleted before the management agents deletes the underlying qmf object. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747861 13f79535-47bb-0310-9956-ffa450edef68
* Fix for bug in credit reallocation, along with test from rafaels@redhat.com ↵Gordon Sim2009-02-251-2/+4
| | | | | | that reproduces it. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747833 13f79535-47bb-0310-9956-ffa450edef68
* Added "uptime" to the management object for the broker.Ted Ross2009-02-252-1/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747809 13f79535-47bb-0310-9956-ffa450edef68
* Fix race condition: move all calls on Decoder into event delivery thread.Alan Conway2009-02-251-2/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747789 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1685: Fixed ring queue policyGordon Sim2009-02-253-14/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747744 13f79535-47bb-0310-9956-ffa450edef68
* Fix header name in sources.Gordon Sim2009-02-251-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747721 13f79535-47bb-0310-9956-ffa450edef68
* Replace struct name to avoid clashing with similarly named struct in ↵Gordon Sim2009-02-251-3/+3
| | | | | | ClientSessionTest. This was causing seg fault when -O0 was specified in CXXFLAGS. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747709 13f79535-47bb-0310-9956-ffa450edef68
* Changed the producer rate limit timer callbackAndrew Stitcher2009-02-244-11/+23
| | | | | | | | so that it generates a callback serialised with the connection git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747587 13f79535-47bb-0310-9956-ffa450edef68
* Implement process id and name methods for WindowsStephen D. Huston2009-02-241-8/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747577 13f79535-47bb-0310-9956-ffa450edef68
* Check that broker pointer is not null before invoking on it.Gordon Sim2009-02-241-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747540 13f79535-47bb-0310-9956-ffa450edef68
* Fixed issue with producer flow control in a cluster.Alan Conway2009-02-2420-31/+163
| | | | | | | | | | | | | | | | | | Producer flow control uses a Timer and other clock-based calculations to send flow control commands. These commands are not predictably ordered from the clusters point of view. Added getClusterOrderProxy() to SessionState. In a cluster it returns a proxy that defers sending a command to the client until it is multicast to the cluster. In a stand alone broker it is just the normal proxy. Updated producer flow control to use this proxy. Cluster flow control is turned off in shadow connections. Only the directly connected node does flow control calculations and multicasts the commands to send. All nodes sending of the commands thru SessionState to ensure consistent session state (e.g. command numbering.) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747528 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1678 Mick Goulish: failover_soak using UUIDs for cluster name to avoid ↵Alan Conway2009-02-242-8/+9
| | | | | | clashes. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747521 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1671: Set userid for client side of inter-broker links.Gordon Sim2009-02-242-1/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747507 13f79535-47bb-0310-9956-ffa450edef68
* Modify the null authenticator to handle PLAIN correctly, making acls easier ↵Gordon Sim2009-02-241-9/+19
| | | | | | to test. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747505 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1676 - Added client process name and pid to connection object for ↵Ted Ross2009-02-246-1/+74
| | | | | | | | | | management. Supported in C++, Python, and Ruby clients. Still needs to be added to the Java clients. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747389 13f79535-47bb-0310-9956-ffa450edef68
* Avoid hiding Bridge::idGordon Sim2009-02-241-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747366 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1674 Mick Goulish: Fixes an error caused by a string going out of scope ↵Alan Conway2009-02-233-21/+25
| | | | | | just before ForkedBroker startup. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747162 13f79535-47bb-0310-9956-ffa450edef68
* Commit accepts of control messages (else they are left on queue)Gordon Sim2009-02-201-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@746197 13f79535-47bb-0310-9956-ffa450edef68
* Merged win-pollable-condition branch changes 743545:746056 into trunkStephen D. Huston2009-02-208-697/+1401
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@746061 13f79535-47bb-0310-9956-ffa450edef68
* Ensure pythonpath is set correctlyGordon Sim2009-02-191-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745834 13f79535-47bb-0310-9956-ffa450edef68
* Fixed for cases where --subs > 1 and --iterations > 1Gordon Sim2009-02-181-1/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745590 13f79535-47bb-0310-9956-ffa450edef68
* Added tests for federated links to and from a clusterGordon Sim2009-02-183-3/+134
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745486 13f79535-47bb-0310-9956-ffa450edef68
* Minor fixes. Alan Conway2009-02-173-15/+11
| | | | | | | | | client/SubscriptionManager: made it thread safe, was causing latencytest to crash with --rate and --time-limit. cluster/Cluster.cpp: don't call cpg_leave during shutdown. Not required and a problem if shutdown was caused by a cpg error. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745226 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1667: Test case (fix was submitted in previous rev)Gordon Sim2009-02-171-0/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745125 13f79535-47bb-0310-9956-ffa450edef68
* Fixed bug in setFlowControl - was recursively calling self.Alan Conway2009-02-172-6/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745115 13f79535-47bb-0310-9956-ffa450edef68
* Cluster start-up retries to handle slow cman start-up.Alan Conway2009-02-142-7/+11
| | | | | | | | - infinite retry if cpg_initialize returns TRY_AGAIN. - infinite retry for cman_is_quorate git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744321 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that the queue depth in bytes remains accurate for LVQ. This also ↵Gordon Sim2009-02-132-1/+25
| | | | | | ensures that there are no underflow exceptions from the policy that keeps this count. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744222 13f79535-47bb-0310-9956-ffa450edef68
* Add --no-module-dir to start_cluster script.Alan Conway2009-02-131-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744129 13f79535-47bb-0310-9956-ffa450edef68
* Test case for previous commit.Gordon Sim2009-02-131-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744052 13f79535-47bb-0310-9956-ffa450edef68
* Check session impl is valid on close to avoid segfault.Gordon Sim2009-02-131-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@744051 13f79535-47bb-0310-9956-ffa450edef68
* Enable --cluster-cman option if built with libcman support.Alan Conway2009-02-122-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743909 13f79535-47bb-0310-9956-ffa450edef68