summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client
Commit message (Collapse)AuthorAgeFilesLines
* Stop the client side Rdma code from receiving connection events before the ↵Andrew Stitcher2010-09-081-0/+1
| | | | | | | | 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
* Trivial comment fixAndrew Stitcher2010-09-081-5/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995138 13f79535-47bb-0310-9956-ffa450edef68
* Remove write after frees in Rdma::AsynchIO and qpid::client::RdmaConnectorAndrew Stitcher2010-09-081-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995134 13f79535-47bb-0310-9956-ffa450edef68
* Remove use of dubious auto_ptrAndrew Stitcher2010-09-081-5/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995129 13f79535-47bb-0310-9956-ffa450edef68
* Make sure that we fail connection correctly if connect fails.Andrew Stitcher2010-09-081-11/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995128 13f79535-47bb-0310-9956-ffa450edef68
* Stop using references to intrusive_ptr in Rdma codeAndrew Stitcher2010-09-081-8/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995127 13f79535-47bb-0310-9956-ffa450edef68
* Give timer tasks a name for logging purposes.Alan Conway2010-08-261-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@989925 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2807: Allow per message acknowledgementGordon Sim2010-08-206-1/+56
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@987459 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2817: on close, wait for at most the heartbeat interval (if specified) ↵Gordon Sim2010-08-203-1/+30
| | | | | | for close-ok response from broker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@987429 13f79535-47bb-0310-9956-ffa450edef68
* Fix locking in receiver impl; protect session member against concurrent ↵Gordon Sim2010-08-161-2/+7
| | | | | | fetch and init. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985838 13f79535-47bb-0310-9956-ffa450edef68
* Fix read-credit bug causing cluster brokers to disconnect clients sporadically.Alan Conway2010-07-142-8/+21
| | | | | | | Also added connection identifier in connection log messages. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964213 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Don't hold lock while waiting for incoming message in ↵Gordon Sim2010-07-061-1/+1
| | | | | | nextReceiver() call. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@960951 13f79535-47bb-0310-9956-ffa450edef68
* Fix spordic failure in cluster_test testConnectionKnownHosts.Alan Conway2010-07-011-2/+10
| | | | | | | | | | Very occasional failure of the form: cluster_test.cpp(547): error in "testConnectionKnownHosts": check kb0 == kb2 failed [42179 57640 != 44199 57640 ] ]) Fix is to avoid using possibly out-of-date initial-brokers data from the connection. Only rely on updates received from the amq.failover exchange. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@959751 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Translate exceptions to correct type when occuring on creating new ↵Gordon Sim2010-07-011-0/+4
| | | | | | session. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@959721 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: expose authenticated username for connectionGordon Sim2010-06-302-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@959461 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: corrected option name for setting subscribe options on a queueGordon Sim2010-06-301-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@959451 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2698: recognise special property names for amqp 0-10 specific message- ↵Gordon Sim2010-06-252-3/+48
| | | | | | and delivery- properties git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@958044 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that we can't shutdown in the middle of writing a bufferAndrew Stitcher2010-06-141-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@954497 13f79535-47bb-0310-9956-ffa450edef68
* Combine Rdma::Buffer and ibv_sge needed to send itAndrew Stitcher2010-06-141-6/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@954496 13f79535-47bb-0310-9956-ffa450edef68
* In Rdma::AsynchIO::stop():Andrew Stitcher2010-06-141-4/+15
| | | | | | | | | | | | - make sure we stop the underlying handle immediately whether or not we do the stopped callback now or have to defer it. In qpid::client::RdmaConnector: - make sure that the shutdown handler is called under all circumstances. - make sure that the destructor doesn't delete the aio if it is already deleted git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@954492 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that AsynchConnector is disassociated from Poller when aborting ↵Gordon Sim2010-06-112-4/+9
| | | | | | connection attempt due to a heartbeat timeout git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@953610 13f79535-47bb-0310-9956-ffa450edef68
* Refer to struct Url as that, not a class - fixes compile warnings on Windows.Stephen D. Huston2010-06-111-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@953526 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Correct the name of the subject string used for incoming messages.Gordon Sim2010-06-101-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@953321 13f79535-47bb-0310-9956-ffa450edef68
* Ensure heartbeat task is cancelled before ConnectionImpl it refers to is deletedGordon Sim2010-06-091-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@953032 13f79535-47bb-0310-9956-ffa450edef68
* Don't set USER callback, AUTHNAME is sufficientGordon Sim2010-06-071-4/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@952390 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Changed default for reconnect to false as that is more intuitive ↵Gordon Sim2010-06-021-1/+1
| | | | | | (e.g. when you specify the wrong broker address to start with) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@950480 13f79535-47bb-0310-9956-ffa450edef68
* Fix compilation error on windowsGordon Sim2010-05-281-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@949182 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2598: Prevent exit hang on windows (at the expense of intermittent leak ↵Gordon Sim2010-05-281-10/+8
| | | | | | on exit under linux) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@949176 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2631: For blocking Bounds::expand() calls, only increase the current ↵Gordon Sim2010-05-275-10/+21
| | | | | | count when there is space. In SessionImpl::send() expand bounds before queueing frame. Expand bounds for all frames sent (including connection frames and cluster specific frames). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@948936 13f79535-47bb-0310-9956-ffa450edef68
* Prevent race between shutdown() and release() resulting in attempt to close ↵Gordon Sim2010-05-191-3/+12
| | | | | | deleted connector. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@946106 13f79535-47bb-0310-9956-ffa450edef68
* Fix RDMA for upstream changes which now require notification on shutdownAndrew Stitcher2010-05-181-29/+66
| | | | | | differently from before git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@945904 13f79535-47bb-0310-9956-ffa450edef68
* Added locking to make amqp_0_10::SenderImpl thread safe.Alan Conway2010-05-182-11/+38
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@945813 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2612: Fix to windows build from Chuck RolkeGordon Sim2010-05-181-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@945778 13f79535-47bb-0310-9956-ffa450edef68
* Fix retry logic in ConnectionImpl::newSession.Alan Conway2010-05-171-8/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@945387 13f79535-47bb-0310-9956-ffa450edef68
* Fix errors when new API Receiver is closed while in use.Alan Conway2010-05-142-23/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@944461 13f79535-47bb-0310-9956-ffa450edef68
* Initial multi-thread unit test for messaging API.Alan Conway2010-05-142-0/+9
| | | | | | | - added Receiver::isClosed() to test for local close. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@944261 13f79535-47bb-0310-9956-ffa450edef68
* Moved FailoverUpdates to qpid::messaging namespace.Alan Conway2010-05-131-86/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943975 13f79535-47bb-0310-9956-ffa450edef68
* New API clients failover in a cluster with SSL connections.Alan Conway2010-05-132-19/+42
| | | | | | | | - Fix setting of reconnect URLs on messaging::Connection. - Added SSL failover test. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943974 13f79535-47bb-0310-9956-ffa450edef68
* Fix deadlocks & thread safety in new API classes.Alan Conway2010-05-139-61/+112
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943973 13f79535-47bb-0310-9956-ffa450edef68
* Transfer TCP code changes to RDMA codeAndrew Stitcher2010-05-131-6/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943772 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to new API impl to support failover.Alan Conway2010-05-123-16/+20
| | | | | | | | | - client/SslConnector.cpp: throw ConnectionException for errors during connection. - client/amqp0_10/ConnectionImpl.cpp: translate unknown exceptions to ConnectionError. - client/amqp0_10/FailoverUpdates.cpp: interrupt receiver by closing session in dtor. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943489 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Fix failover updates to set correct option name; clear list valued ↵Gordon Sim2010-05-112-1/+3
| | | | | | option on setting it rather than merely appending to it. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943160 13f79535-47bb-0310-9956-ffa450edef68
* Support for multiple protocols in qpid::Url.Alan Conway2010-05-114-20/+19
| | | | | | | | | | - simplified qpid::Address to hold (protocol,host,port) triples. - protocol plugins call Url:addProtocol to add tags to Url parser. - use Address::protocol when establishing connections. - ssl_test: tests using URL to connect. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943130 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Add default constructor for Connection; add option to set url on ↵Gordon Sim2010-05-111-5/+10
| | | | | | existing connection. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943071 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Fix bug preventing re-establishment of credit on reconnectGordon Sim2010-05-111-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@943036 13f79535-47bb-0310-9956-ffa450edef68
* Allow empty subject for direct- and xml- exchangesGordon Sim2010-05-051-3/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@941306 13f79535-47bb-0310-9956-ffa450edef68
* Load client side plugins just before creating the first Connection.Andrew Stitcher2010-04-273-4/+54
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@938701 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: allow safe closing of session as part of handling a session exceptionGordon Sim2010-04-274-13/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@938460 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2548: applied patch from francesco emmiGordon Sim2010-04-261-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@937990 13f79535-47bb-0310-9956-ffa450edef68