summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionState.cpp
Commit message (Collapse)AuthorAgeFilesLines
* QPID-4712: authorisation for AMQP 1.0 connectionsGordon Sim2013-06-251-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1496466 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4905: Stopped broker::Broker needing to refer to broker::ConnectionAndrew Stitcher2013-06-191-2/+2
| | | | | | - Also removed ConnectionToken which didn't add anything over OwnershipToken git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1494640 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4905: Tidy up broker::ConnectionAndrew Stitcher2013-06-191-2/+1
| | | | | | | - Clean up code for accounting for sent frames - merged Connection and ConnectionState into Connection git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1494639 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4905: Tidy upAndrew Stitcher2013-06-041-10/+0
| | | | | | | | - Remove unused function getBuffered() of ConnectionOutputHandler - Stop SessionContext and AggregateOutput from needlessly implementing the OutputControl interface git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1489457 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4514: Remove IO readCredit throttling only used by removed cluster codeAndrew Stitcher2013-01-301-5/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1440616 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4514: Remove obsolete cluster code: Queue, Semanticstate, SessionHandlerAlan Conway2012-12-191-2/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1424133 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4514: Remove obsolete cluster code: Broker, Connection, Link.Alan Conway2012-12-191-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1424125 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4514: Remove obsolete cluster code, clusterOrderProxyAlan Conway2012-12-191-5/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1424121 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4449 - Reverted much of the original change and re-implemented the fix ↵Ted Ross2012-11-301-3/+3
| | | | | | | | | | in a simpler way. The build-define _IN_QPID_BROKER is now used for modules built in the broker. The shared-pointer changes are conditionally compiled only for in-broker cases. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1415796 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4449 - Fixed the API in qpid::management::Manageable to remain backward ↵Ted Ross2012-11-201-3/+3
| | | | | | compatible. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1411761 13f79535-47bb-0310-9956-ffa450edef68
* MQPID-4286: QMF queries for HA replication take too long to process (Jason ↵Alan Conway2012-10-151-5/+4
| | | | | | | | | | Dillaman) Rework ManagementAgent locks, get rid of shared buffers that were points of contention. Minor log message improvements in ha code. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1398530 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Removed now unused cluster specific ClusterSafe code.Andrew Stitcher2012-09-131-6/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1384555 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4178: broker refactoringGordon Sim2012-08-101-14/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1371676 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4005: Eliminate "using" especially "using namespace" from header fileAndrew Stitcher2012-05-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1339403 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3630: remove additional code in client.Ken Giusti2012-01-131-2/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1231222 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3630: remove deprecated rate limiting featureKen Giusti2012-01-131-87/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1231221 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3417: C++ broker - support adding arrival timestamp to received messages.Ken Giusti2011-10-121-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1182490 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3502: Ensure accepts are sent when required for asynchronously ↵Gordon Sim2011-09-231-3/+1
| | | | | | completed messages git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1174800 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3394: move object copy after changing object state, not before.Ken Giusti2011-08-041-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1153966 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3121: Cluster management inconsistency when using persistent store.Alan Conway2011-06-231-0/+6
| | | | | | | | | | | | | | | | | With the recent changes to asynchronous completion, completeRcvMsg can be called immediately by the thread that enqueues the message or deferred as an IO Callback till after journal threads are done with the message. The choice between these two options is unpredicatable, so the ordering of management events generated during completeRcvMsg unpredictalbe and can cause an inconsistency error when completeRcvMsg updates connection stats. The fix is to mark completeRcvMsg as a cluster-unsafe scope so no management messages will be generated regardless of how it is called. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1138874 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3252Charles E. Rolke2011-05-261-1/+3
| | | | | | | | Touch up a compile failure when assert() compiles to nothing, leaving an "unused" variable. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1127947 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3252: flush msgs when sync requested.Ken Giusti2011-05-111-5/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1101864 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3197: prevent async command completer from accessing session's ↵Ken Giusti2011-04-111-1/+21
| | | | | | connection when session is detached git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1091167 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3073: fix to allow older versions of boost to compile.Ken Giusti2011-03-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1079590 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3073: refactor to eliminate locks, malloc, and map insert/remove in ↵Ken Giusti2011-03-081-91/+55
| | | | | | receive path. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1079385 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2935: merge producer flow control (C++ broker).Ken Giusti2011-02-191-23/+185
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1072356 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3045 - sporadic failure of cluster_tests.ShortTests.test_route_updateAlan Conway2011-02-081-3/+10
| | | | | | | | | | | Sporadically the test was failing because the session associated with an inter-broker bridge was created out of order with other objects. This is unlikely to cause a fatal cluster inconsistency in practice but it has been corrected in any case. The fix was to delay creation of the management object for a bridge session till a point which is consistent on all cluster members. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1068554 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
* Disable non-0 session timeouts.Alan Conway2010-08-031-0/+5
| | | | | | | | | | Since session resume is not fully implemented, non-0 session timeouts are of no use. Moreover the partial implementation causes problems in a cluster as stale sessions kept alive by a timeout can interfere with failover and updates. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981933 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2688: ensure that unacked messages are requeued before autodeletion ↵Gordon Sim2010-06-221-0/+1
| | | | | | occurs when session closes git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@956988 13f79535-47bb-0310-9956-ffa450edef68
* Code cleanup Ted Ross2010-04-231-1/+1
| | | | | | | | | | - Removed IdAllocator (it's no longer needed) - Cleaned up the calls to ManagementAgent::addObject to handle durable objects - Removed the deferred call to addObject for durable objects - Removed unneeded calls to self._checkClosed() in qmf.console.Agent git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@937516 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of QPID-2509 (Remove message staging from C++ broker)Kim van der Riet2010-04-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@934463 13f79535-47bb-0310-9956-ffa450edef68
* Optimized handling of accepts and completions.Alan Conway2009-08-121-2/+1
| | | | | | | | | | SemanticState::accept/completed now make a single pass through the SequenceSet of commands and the unacked DeliveryRecord list in parallel, rather than doing a pass through unacked for every range in the SequenceSet. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@803655 13f79535-47bb-0310-9956-ffa450edef68
* Change all broker users of broker::Timer to use sys::TimerAndrew Stitcher2009-07-301-9/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@799273 13f79535-47bb-0310-9956-ffa450edef68
* Add directory to #includeAlan Conway2009-07-141-8/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793909 13f79535-47bb-0310-9956-ffa450edef68
* Reverted checkins 793119, 793120, 793121, 793122 because of problems with ↵Kim van der Riet2009-07-131-8/+9
| | | | | | heartbeats and the store tests. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793602 13f79535-47bb-0310-9956-ffa450edef68
* Change all broker users of broker::Timer to use sys::TimerAndrew Stitcher2009-07-101-9/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793121 13f79535-47bb-0310-9956-ffa450edef68
* Performance improvements in AggregateOutput and SemanticState.Alan Conway2009-06-161-6/+6
| | | | | | | | | | | | | | Replaced AggregateOutput hierarchy with a flat list per connection holding only the OutputTasks that are potentially active. Tasks are droped from the list as soon as they return false, and added back when they may have output. Inlined frequently-used SequenceNumber functions. Replace std::list in QueueListeners with std::vector. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@785408 13f79535-47bb-0310-9956-ffa450edef68
* Plumbed in an a connection abort operation to the OutputHandlerAndrew Stitcher2009-06-081-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@782649 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1843 - Cleaned up the interface to the broker's internal management agent.Ted Ross2009-05-111-5/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@773570 13f79535-47bb-0310-9956-ffa450edef68
* Changed the producer rate limit timer callbackAndrew Stitcher2009-02-241-5/+9
| | | | | | | | 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
* Fixed issue with producer flow control in a cluster.Alan Conway2009-02-241-6/+11
| | | | | | | | | | | | | | | | | | 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-1674 Mick Goulish: Fixes an error caused by a string going out of scope ↵Alan Conway2009-02-231-0/+1
| | | | | | just before ForkedBroker startup. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747162 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to producer flow control to reduce the numberAndrew Stitcher2009-02-041-22/+22
| | | | | | | | | of flow messages sent to the client and to eliminate a concurrency issue updating the broker flow control state. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@740933 13f79535-47bb-0310-9956-ffa450edef68
* Add in management statistics for client flow control.Andrew Stitcher2009-02-031-27/+33
| | | | | | | Really fixed Client library to count credit the same way the broker does. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@740433 13f79535-47bb-0310-9956-ffa450edef68
* Send client property indicating that client supportsAndrew Stitcher2009-02-021-2/+6
| | | | | | | | | producer throttling in the Connection.OpenOK message. Broker only tries to apply flow control to client if it has received the property in the Connection.OpenOK message. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@740135 13f79535-47bb-0310-9956-ffa450edef68
* Producer side rate throttling:Andrew Stitcher2009-01-271-17/+93
| | | | | | | | | This uses the Message.Flow command to send credit from broker to client to ensure that the client doesn't exceed a rate configured on the broker per session. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@738247 13f79535-47bb-0310-9956-ffa450edef68
* Use special management ids for objects used in state transfer to new ↵Gordon Sim2009-01-231-1/+4
| | | | | | | | | members. This prevents the ids getting out of sync across the cluster and allows management methods to be used reliably. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737203 13f79535-47bb-0310-9956-ffa450edef68
* Removed BodyHolder: minor performance improvement, opens the way for more ↵Alan Conway2009-01-221-2/+1
| | | | | | efficient memory management. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736783 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: added 'exactly-once' guarantee to asynchronous replication of ↵Gordon Sim2009-01-201-6/+22
| | | | | | | | | | | | queue state * altered replication protocol to detect and eliminate duplicates * added support for acknowledged transfer over inter-broker bridges * added option to qpid-route to control this git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736018 13f79535-47bb-0310-9956-ffa450edef68