summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client
Commit message (Collapse)AuthorAgeFilesLines
* cluster:]Alan Conway2008-09-261-50/+0
| | | | | | | | | - call updateMemberStats() exactly once for each change in cluster membership. - fix spurious replication of catch-up connection close events. Removed unused client/MessageQueue.h git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@699456 13f79535-47bb-0310-9956-ffa450edef68
* Cluster replicates session command sequence state and consumers to newcomers.Alan Conway2008-09-242-2/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@698666 13f79535-47bb-0310-9956-ffa450edef68
* DumpClient send connections & session IDs to new members.Alan Conway2008-09-211-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@697446 13f79535-47bb-0310-9956-ffa450edef68
* RDMA bugfixes:Andrew Stitcher2008-09-191-1/+2
| | | | | | | | | | | | - Changed Rdma connection creation to allocate all necessary buffer memory immediately. This has the effect that no later buffer allocations happen which can fail so that once accepted connections won't fail because of lack of locked memory. - Fixed connection logic so we reject a new connection if we can't create the necessary handlers rather than kill the entire broker (this includes not enough locked memory) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@697101 13f79535-47bb-0310-9956-ffa450edef68
* Dump shared state to new cluster members.Alan Conway2008-09-181-0/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@696788 13f79535-47bb-0310-9956-ffa450edef68
* Moved PollableCondition, PollableQueue and to sys. Fixed cluster shutdown ↵Alan Conway2008-09-111-1/+1
| | | | | | | | | | | | | | issues. sys/PollableCondition: is a generic mechansim to poll for non-IO events in the Poller. sys/PollableQueue: is a thread-safe queue template that can be dispatched from the Poller when there are items on the queue. It uses PollableCondition. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@694243 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of AMQP over RDMA protocols (Infiniband)Andrew Stitcher2008-09-112-2/+430
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@694143 13f79535-47bb-0310-9956-ffa450edef68
* Refactored c++ client library to allow multiple protocols to beAndrew Stitcher2008-09-118-140/+301
| | | | | | | | | | | | | | | used simultaneously: - Added in capability for client library plugins: Client library will load in plugin modules from the client library module directory on library load. - Add protocol option into the standard client command line options - Split plugin module load area into daemon and client; default daemon module directory is now <libdir>/qpid/daemon, default client module directory is <libdir>/qpid/client. - Changed names of plugins to leave out libqpid prefix git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@694113 13f79535-47bb-0310-9956-ffa450edef68
* Cluster support for copying shared broker state to new members.Alan Conway2008-09-106-9/+107
| | | | | | | | | | | | cluster/DumpClient: Copies broker shared state to a new broker via AMQP. broker/*Registry, Queue, QueueBindings: Added iteration functions for DumpClient broker/SemanticState.cpp: Allow DumpClient to sidestep setting of delivery-properties.exchange. client/Connection.h: Added Connection::open(Url) overload. client/SessionImpl: Added send(AMQBody, FrameSet) overload for forwarding broker messages. tests/cluster_test.cpp: Added test for DumpClient copying shared state between brokers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@693918 13f79535-47bb-0310-9956-ffa450edef68
* Generate c++ enum types for AMQP enums in framing/enum.h.Alan Conway2008-09-092-8/+9
| | | | | | | Modified enum scheme to avoid name clashes: namespace amqp_class { EnumName { ENUM_NAME_X=1, ENUM_NAME_X=2 ...}}; git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@693465 13f79535-47bb-0310-9956-ffa450edef68
* src/qpid/client/SubscriptionManager.cpp: added start().Alan Conway2008-09-052-2/+17
| | | | | | | src/tests* improvements to multi-host test scripts. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@692478 13f79535-47bb-0310-9956-ffa450edef68
* Add ASL to everywhere, to everything.Aidan Skinner2008-08-281-0/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@689937 13f79535-47bb-0310-9956-ffa450edef68
* Fix Cluster::send encode race.Alan Conway2008-08-051-4/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682885 13f79535-47bb-0310-9956-ffa450edef68
* * revised approach for setting tcp-nodelay on client to avoid breaking ↵Gordon Sim2008-08-053-13/+14
| | | | | | | | | | | | platform abstractions * added ability to set tcp-nodelay on server side of the socket also Merged from r682785. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682791 13f79535-47bb-0310-9956-ffa450edef68
* Removed unused functionsAndrew Stitcher2008-07-293-56/+0
| | | | | | | | | Removed unused Thread and Socket functions - These functions also cause problems with Solaris compilations Remove unused client connector functionality git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680833 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1198 (Partial): replace all uses of u_intX_t with uintX_tAndrew Stitcher2008-07-291-5/+5
| | | | | | | | | Patches from Manuel Teira. The u_int* versions are not available in the Sun header files. In any case using only uint* is more consistent git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680828 13f79535-47bb-0310-9956-ffa450edef68
* Fixed bug in SubscriptionManager::get() where flush was issued before ↵Gordon Sim2008-07-251-1/+4
| | | | | | waiting and if message showed up after flush completed but before wait was finished there was no credit (due to flush) to deliver it to the waiting client. Added test for thise case. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@679739 13f79535-47bb-0310-9956-ffa450edef68
* Refactor to change client connector state machine to be held in ↵Andrew Stitcher2008-07-244-18/+20
| | | | | | ConnectionHandler git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@679268 13f79535-47bb-0310-9956-ffa450edef68
* Some small changes which clean up header file inclusionsAndrew Stitcher2008-07-094-17/+23
| | | | | | | | and generally start to tidy up the network layer so that it's a bit easier to implement new network transports git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@675338 13f79535-47bb-0310-9956-ffa450edef68
* Improved text and rasied severity of log entry when client sessions are ↵Gordon Sim2008-07-021-1/+1
| | | | | | deleted without first being closed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@673359 13f79535-47bb-0310-9956-ffa450edef68
* Added timeout to SubscriptionManager::get(), LocalQueue::get() and ↵Alan Conway2008-07-014-17/+54
| | | | | | BlockingQueue::get() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@673158 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1137: don't treat connection as opened if the open never succeedsGordon Sim2008-06-262-3/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@671877 13f79535-47bb-0310-9956-ffa450edef68
* Additions to the client API:Alan Conway2008-06-254-15/+157
| | | | | | | | - SubscriptionManager::get(queue) to get a single message from a queue. - Set FlowControl per-subscription. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@671655 13f79535-47bb-0310-9956-ffa450edef68
* Propagate error messages across the Demux between network & user threads.Alan Conway2008-06-123-6/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667205 13f79535-47bb-0310-9956-ffa450edef68
* Updated doxygen comments in qpid/client/*.hAlan Conway2008-06-0925-380/+155
| | | | | | | Changed request-response example to use SubscriptionManager like the others. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@665891 13f79535-47bb-0310-9956-ffa450edef68
* Moved from AccumulatedAck to SequenceSet in managing transactional acceptsGordon Sim2008-06-092-2/+0
| | | | | | | | | Added transactional option to perftest Removed clientid from ConnectionSettings as it appears not to be used git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@665890 13f79535-47bb-0310-9956-ffa450edef68
* Added exceptions to sys::Waitable.Alan Conway2008-06-066-64/+52
| | | | | | | | Fixed client side deadlock involving client::Bounds. Fixed incorrect exception messages during connection shutdown. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@664114 13f79535-47bb-0310-9956-ffa450edef68
* Reverted move of ConnectionOptions (without the parse functionality they ↵Gordon Sim2008-06-031-57/+0
| | | | | | | | | | aren't off much use). Corrected include in ConnectionOptions.h git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@662681 13f79535-47bb-0310-9956-ffa450edef68
* Move ConnectionOptions into qpid::client.Gordon Sim2008-06-031-0/+57
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@662675 13f79535-47bb-0310-9956-ffa450edef68
* Separate option parsing from qpid::client::ClientSettings.Alan Conway2008-06-023-45/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@662581 13f79535-47bb-0310-9956-ffa450edef68
* Improve performance of synchronous publication by not requesting ↵Gordon Sim2008-06-021-1/+1
| | | | | | | | | | known-completed response for every completed sent. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@662561 13f79535-47bb-0310-9956-ffa450edef68
* Added --syslog-name, --syslog-facility options.Alan Conway2008-06-023-7/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@662558 13f79535-47bb-0310-9956-ffa450edef68
* Removed redundant flush request.Gordon Sim2008-05-301-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@661730 13f79535-47bb-0310-9956-ffa450edef68
* Move AckPolicy impl from header to .cpp; ensure that completion is marked ↵Gordon Sim2008-05-292-23/+56
| | | | | | even when auto-acking is turned off. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@661309 13f79535-47bb-0310-9956-ffa450edef68
* Removed obsolete src/qpid/client/SessionImpl.h .cppAlan Conway2008-05-271-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660715 13f79535-47bb-0310-9956-ffa450edef68
* Tighten up sync-correctness in SubscriptionManager & Dispatcher.Alan Conway2008-05-275-10/+12
| | | | | | | Add a flush to SessionBase_0_10::sync() so it syncs in both directions. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660643 13f79535-47bb-0310-9956-ffa450edef68
* Use symbolic constants for message flow values.Alan Conway2008-05-271-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660625 13f79535-47bb-0310-9956-ffa450edef68
* Additional API documentation around sync vs. async sessions.Alan Conway2008-05-273-1/+45
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660562 13f79535-47bb-0310-9956-ffa450edef68
* Added some comments to the various connection settings.Gordon Sim2008-05-271-1/+48
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660546 13f79535-47bb-0310-9956-ffa450edef68
* Fixed intermittent leak of client::Connector thread.Alan Conway2008-05-265-11/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660320 13f79535-47bb-0310-9956-ffa450edef68
* Changes to Session API:Alan Conway2008-05-2616-315/+306
| | | | | | | | | | | - Session is synchronous, no futures. - AsyncSession is async, returns futures. - Conversion functions sync(s) async(s) return a sync/async view of session s. - Connection::newSession - takes name, no timeout - SessionBase::getId - returns SessionId not UUID. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660258 13f79535-47bb-0310-9956-ffa450edef68
* Fix compile error in examples.Alan Conway2008-05-261-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660173 13f79535-47bb-0310-9956-ffa450edef68
* Delete obsolete Channel class.Alan Conway2008-05-234-626/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@659663 13f79535-47bb-0310-9956-ffa450edef68
* qpid::SessionState: Added error checking for invalid frame sequences.Alan Conway2008-05-235-14/+29
| | | | | | | client: Fix client crash on error during connection shutdown. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@659538 13f79535-47bb-0310-9956-ffa450edef68
* Fix for large messages.Gordon Sim2008-05-141-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@656331 13f79535-47bb-0310-9956-ffa450edef68
* From Jonathan Robie:Alan Conway2008-05-131-3/+5
| | | | | | | | | | | | | | | https://issues.apache.org/jira/browse/QPID-1056: Python examples for the xml exchange. https://issues.apache.org/jira/browse/QPID-1057 Fixes to the XmlExchange.cpp that prevent it from crashing the broker when used with python clients that don't send application header properties git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@656005 13f79535-47bb-0310-9956-ffa450edef68
* Added sync() to ensure all acks are receivd before exiting the Dispatcher loop.Alan Conway2008-05-131-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655983 13f79535-47bb-0310-9956-ffa450edef68
* Added enum CreditUnit { MESSAGE=0, BYTE=1 };Alan Conway2008-05-131-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655935 13f79535-47bb-0310-9956-ffa450edef68
* Reverted change to use ANONYMOUS as default (I had a change of heart on that)Gordon Sim2008-05-091-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@654761 13f79535-47bb-0310-9956-ffa450edef68
* Make ANONYMOUS the default authentication mechanism. Gordon Sim2008-05-092-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@654710 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status