summaryrefslogtreecommitdiff
path: root/cpp/src
Commit message (Collapse)AuthorAgeFilesLines
...
* Delay deleting the Rdma::AsynchIO associated with a Connection to just beforeAndrew Stitcher2010-10-121-69/+55
| | | | | | | | | | | | the callback to the ConnectionImpl shutdown function so that we make the possibility of race between a write coming down and deleting it as small as possible. Rearranged scope of polling boolean to indicate that the data channel is connected (or not) and changed name to better describe its function git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021821 13f79535-47bb-0310-9956-ffa450edef68
* Account for seemingly getting reject messages after already getting establishedAndrew Stitcher2010-10-121-1/+7
| | | | | | | event. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021820 13f79535-47bb-0310-9956-ffa450edef68
* Serialise close into the data callbacks:Andrew Stitcher2010-10-123-38/+72
| | | | | | | | | Rejig Rdma::ConnectionManager to have a stop function with a callback and use this to ensure that the Rdma::Connector used by qpid::sys::RdmaConnector is correctly deleted only after it has been actually stopped git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021819 13f79535-47bb-0310-9956-ffa450edef68
* Make sure that Rdma::Listener can generate no more callbacks after it receivesAndrew Stitcher2010-10-121-0/+12
| | | | | | | a disconnected event for a connection id. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021818 13f79535-47bb-0310-9956-ffa450edef68
* If we have already stopped an Rdma connection, but we still get a data eventAndrew Stitcher2010-10-121-0/+3
| | | | | | | ignore it git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021817 13f79535-47bb-0310-9956-ffa450edef68
* Handle Rdma Flush events - instead of reporting to the application justAndrew Stitcher2010-10-121-0/+16
| | | | | | | | return write buffers to the pool and do nothing for recv buffers as the connection must be in an error state now. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021816 13f79535-47bb-0310-9956-ffa450edef68
* Fix Rdma test server so that you can interrupt it again (since makingAndrew Stitcher2010-10-121-3/+9
| | | | | | | Poller run loop impervious to signals) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021815 13f79535-47bb-0310-9956-ffa450edef68
* Catch uncaught exceptions thrown by DispatchHandle callbacks instead of lettingAndrew Stitcher2010-10-121-0/+7
| | | | | | | then destroy the Poller thread. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021814 13f79535-47bb-0310-9956-ffa450edef68
* Converted four files from DOS format to Unix format to match all of the otherTed Ross2010-10-114-1335/+1335
| | | | | | | | | files in their respective directories. This is a non-substantive change, only end-of-line formatting was modified. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021423 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2863 Propagate WinSDK Build Version numbers to the Messaging .NET BindingCharles E. Rolke2010-10-111-1/+10
| | | | | | | | | | Rooted at qpid/, this patch propagates the Windows version numbers to the .NET Binding DLLs. The changes can be summarized: 1. The files that hold the version numbers are renamed to templates and are edited to hold the version number CMake variable names. 2. CMake calls configure_file twice to put the version numbers into the generated files. 3. The projects that use these files are steered to use the generated source. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1021361 13f79535-47bb-0310-9956-ffa450edef68
* Registers the amq.failover exchange in the management exchange.Jonathan Robie2010-10-085-14/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1005908 13f79535-47bb-0310-9956-ffa450edef68
* Fix session-shutdown-after-failure so it does not cause a segfault.Ted Ross2010-10-071-2/+2
| | | | | | | | Fixed the method-call wrapper for Python in the qpid messaging wrapper to properly handle and translate C++ exceptions. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1005654 13f79535-47bb-0310-9956-ffa450edef68
* Add explicit node-type declaration for receivers.Ted Ross2010-10-071-4/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1005643 13f79535-47bb-0310-9956-ffa450edef68
* Update new cluster design: no longer planning to use MessageStore interface.Alan Conway2010-10-071-36/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1005472 13f79535-47bb-0310-9956-ffa450edef68
* Cluster benchmark test script. Improvements to qpid-cpp-bencmhark.Alan Conway2010-10-043-14/+68
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1004420 13f79535-47bb-0310-9956-ffa450edef68
* Allows browsing of exclusive queues held by another session. Jonathan Robie2010-10-042-1/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1004357 13f79535-47bb-0310-9956-ffa450edef68
* Fixes two bugs for ring queue policies that involve size. Jonathan Robie2010-10-013-22/+125
| | | | | | | | | | | | - When messages vary in size, now correctly displaces enough smaller messages to make room for the new message. - When a message is larger than maximum queue size, now correctly rejects the message. Resolves JIRA QPID-2338 (https://issues.apache.org/jira/browse/QPID-2338). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003531 13f79535-47bb-0310-9956-ffa450edef68
* Improvements to output & message distribution for qpid-cpp-benchmark.Alan Conway2010-09-304-6/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003231 13f79535-47bb-0310-9956-ffa450edef68
* Add missing files to EXTRA_DIST.Alan Conway2010-09-301-2/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003230 13f79535-47bb-0310-9956-ffa450edef68
* qpid-test-cluster: script to start a multi-host test cluster.Alan Conway2010-09-303-1/+97
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003229 13f79535-47bb-0310-9956-ffa450edef68
* Extending qpid-cpp-benchmark for cluster testingAlan Conway2010-09-302-42/+74
| | | | | | | | - multiple --broker args have senders/receivers connect to different cluster nodes. - multiple --client-host args start clients on different hosts via ssh. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003228 13f79535-47bb-0310-9956-ffa450edef68
* Add missing cluster test scripts to EXTRA_DIST.Alan Conway2010-09-301-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003226 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2888: qmf v2 agent will republish all data on broker reconnect.Kenneth Anthony Giusti2010-09-302-6/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003052 13f79535-47bb-0310-9956-ffa450edef68
* new-cluster-design.txt: added note on async replication.Alan Conway2010-09-281-6/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1002171 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that a rejected message is also dequeued.Jonathan Robie2010-09-281-0/+2
| | | | | | | Without this fix, rejected messages were dropped, but not dequeued. This meant that durable messages would 're-appear' after a restart. This also meant that the queue message count was incorrect if messages had been rejected. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1002147 13f79535-47bb-0310-9956-ffa450edef68
* Scripts using rsync and ssh to assist cluster testing:Alan Conway2010-09-275-0/+188
| | | | | | | | | | - run a command on all hosts in a cluster. - copy files to all hosts in a cluster. - "make install" locally and copy install tree to cluster. - copy source tree to cluster and "make install" on each host. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001888 13f79535-47bb-0310-9956-ffa450edef68
* Added install_env.sh to set environment variables to use an install prefix.Alan Conway2010-09-273-7/+34
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001887 13f79535-47bb-0310-9956-ffa450edef68
* Update new-cluster-design.txt, clarifications & notes.Alan Conway2010-09-241-13/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001052 13f79535-47bb-0310-9956-ffa450edef68
* Update new-cluster-design.txt: improvements to new members joining cluster.Alan Conway2010-09-241-3/+82
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001022 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2885: clean up memory leaks on C++ qmf console shutdown.Kenneth Anthony Giusti2010-09-242-0/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1000907 13f79535-47bb-0310-9956-ffa450edef68
* Design note on proposed new cluster design.Alan Conway2010-09-221-0/+277
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1000234 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2880: allow boolean values in method call map/list arguments.Kenneth Anthony Giusti2010-09-221-2/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999919 13f79535-47bb-0310-9956-ffa450edef68
* Added type casts to literal numbers in cpp/src/tests/Qmf2.cpp.Ted Ross2010-09-221-7/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999897 13f79535-47bb-0310-9956-ffa450edef68
* QMFv2 Additions:Ted Ross2010-09-2122-278/+1693
| | | | | | | | | | | | - QMFv2 schema encoding completed - Schema queries handled by the agent and initiated by the console by user request - Full query support with predicates evaluated on the agent (regex not yet implemented) - Agent filtering in the console - Agent aging in the console - Unit tests git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999662 13f79535-47bb-0310-9956-ffa450edef68
* Renamed the MessageStore interface truncateInit parameter to a more generic ↵Kim van der Riet2010-09-211-7/+9
| | | | | | name. Changed the language of the description to match. This is a tidy-up only, there should be no code implications. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999473 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2875: wait for federation configuration to settle before testing route ↵Kenneth Anthony Giusti2010-09-211-21/+78
| | | | | | propagation. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999433 13f79535-47bb-0310-9956-ffa450edef68
* Adding cast to list and map size comparisons to avoid signed/unsigned ↵Jonathan Robie2010-09-161-2/+2
| | | | | | | | | comparison: BOOST_CHECK_EQUAL(list.size(), (size_t) 0); git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@997846 13f79535-47bb-0310-9956-ffa450edef68
* Fixes parsing problem with empty lists ('[]') in addresses, which previously ↵Jonathan Robie2010-09-163-2/+26
| | | | | | raised an exception and leaked the memory associated with the AddressImpl. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@997771 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2859: Save the agent's name to the configuration file.Kenneth Anthony Giusti2010-09-152-20/+61
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@997453 13f79535-47bb-0310-9956-ffa450edef68
* Removed spurious commentTed Ross2010-09-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@997370 13f79535-47bb-0310-9956-ffa450edef68
* Fixed a thread safety issue in which the managementObjects map was used in ↵Ted Ross2010-09-142-55/+66
| | | | | | | | | | | an unsafe way (i.e. without the lock held). Replaced a raw pointer with a boost::shared_ptr to protect objects during method calls. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@997089 13f79535-47bb-0310-9956-ffa450edef68
* Break deadlock caused when ClusterTimer::drop is called concurrently with ↵Alan Conway2010-09-092-6/+8
| | | | | | Timer::add. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995426 13f79535-47bb-0310-9956-ffa450edef68
* Fix to allow compilation with libibverbs 1.1.2Andrew Stitcher2010-09-082-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995165 13f79535-47bb-0310-9956-ffa450edef68
* Stop the client side Rdma code from receiving connection events before the ↵Andrew Stitcher2010-09-083-0/+6
| | | | | | | | data events are stopped to avoid any events after the Rdma::Connector is deleted git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995145 13f79535-47bb-0310-9956-ffa450edef68
* Delay client side Rdma connection disconnect() so that it happens serialisedAndrew Stitcher2010-09-081-3/+8
| | | | | | to the data channel for the connection. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995144 13f79535-47bb-0310-9956-ffa450edef68
* Delay daemon side Rdma connection disconnect() so that it happens serialisedAndrew Stitcher2010-09-083-1/+23
| | | | | | to the data channel for the connection. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995143 13f79535-47bb-0310-9956-ffa450edef68
* Avoid Rdma::AsynchIO leaking when stopped without being drained andAndrew Stitcher2010-09-081-1/+3
| | | | | | | add in asserts to be sure that you call stopped and drained callbacks in the correct state git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995142 13f79535-47bb-0310-9956-ffa450edef68
* Only delete Rdma server side connections when the client disconnects -Andrew Stitcher2010-09-082-12/+16
| | | | | | | this avoids a race between the disconnect event and deleting the connection upon closing. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995141 13f79535-47bb-0310-9956-ffa450edef68
* Reordered members of RdmaIOHandler to ensure correct destruction orderAndrew Stitcher2010-09-081-4/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995140 13f79535-47bb-0310-9956-ffa450edef68
* Improve daemon handling of unexpected RDMA disconnects from clientAndrew Stitcher2010-09-081-21/+48
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995139 13f79535-47bb-0310-9956-ffa450edef68