| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
close, and maintain cummulative mark in session
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581056 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581052 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581050 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581009 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581008 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
for broker and client.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580984 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580974 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580944 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580929 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580928 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580922 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
threads.
Added generic listener for completion changes.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580915 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580891 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580471 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580470 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580460 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
- Session -shared_ptr-> SessionCore -shared_ptr-> ConnectionImpl
- Connection -shared_ptr-> ConnectionImpl
- ConnectionImpl -weak_ptr-> SessionCore
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580440 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580417 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580413 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580404 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* broker/SessionManager.cpp, broker/SessionHandler.cpp:
Implement suspend/resume
* client/ScopedAssociation.h, SessionCore.h, SessionHandler.h:
Simplified relationships.
- Removed ScopedAssociation.
- SessionHandler: is now a member of SessionCore.
- SessionCore: shared_ptr ownership by Session(s) and ConnectionImpl.
- Using framing::FrameHandler interfaces.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580403 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580394 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Set sync bit when session is in sync mode
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580380 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580266 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580123 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580122 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
not yet enabled)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580094 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580051 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579863 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579582 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579559 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Rename ackFrequency as ackBatchSize in Dispatcher
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579553 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
broker/BrokerExchange.cpp -> Exchange.cpp
broker/BrokerExchange.h -> Exchange.h
broker/BrokerQueue.cpp -> Queue.cpp
broker/BrokerQueue.h -> Queue.h
client/ClientChannel.cpp -> Channel.cpp
client/ClientChannel.h -> Channel.h
client/ClientConnection.cpp -> Connection.cpp
client/ClientExchange.cpp -> Exchange.cpp
client/ClientExchange.h -> Exchange.h
client/ClientMessage.h -> Message.h
client/ClientQueue.cpp -> Queue.cpp
client/ClientQueue.h -> Queue.h
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579340 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
................
r578850 | rgodfrey | 2007-09-24 16:25:51 +0100 (Mon, 24 Sep 2007) | 9 lines
Merged revisions 578845 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1
........
r578845 | rgodfrey | 2007-09-24 15:57:05 +0100 (Mon, 24 Sep 2007) | 1 line
QPID-612 : Use same scheme for every creation of temporary queue names
........
................
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579154 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579043 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579040 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Rafi and I decided against throwing an exception as the close (connection or session) can be called by a peer even when there is no error.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579033 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* cpp/src/qpid/broker/SessionManager.cpp: Manage suspended sessions.
Replaces SuspendedSessions.
* cpp/src/qpid/broker/SessionState.cpp: Work with SessionManager.
* cpp/src/qpid/broker/SessionHandler.cpp: Owns SessionState.
* cpp/src/qpid/broker/Connection.h, .cpp: Owns session handlers.
* cpp/src/qpid/broker/Broker.h: Added SessionManager member.
* cpp/src/Makefile.am: Added broker/SessionManager.cpp
* amqp.0-10-preview.xml: Added session-busy and channel-busy constants.
* cpp/src/tests/.valgrind.supp-default: Added suppresssions for F7.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578975 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
BasicInteropTest.java: added a connection close and a flush so that the message will definitely be received prior to the JVM exiting.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578936 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578891 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578864 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578854 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
................
r575688 | rhs | 2007-09-14 15:04:38 +0100 (Fri, 14 Sep 2007) | 1 line
Merged revision 572751 from the trunk, this fixes QPID-573.
................
r577316 | rupertlssmith | 2007-09-19 15:40:41 +0100 (Wed, 19 Sep 2007) | 3 lines
Initialized merge tracking via "svnmerge" with revisions "400000-567005,568919,568924,573502,573516,574902,575738,575788,575811" from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1
................
r577660 | rupertlssmith | 2007-09-20 10:51:18 +0100 (Thu, 20 Sep 2007) | 9 lines
Recorded merge of revisions 574874 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1
........
r574874 | gsim | 2007-09-12 10:59:56 +0100 (Wed, 12 Sep 2007) | 3 lines
Applied fix (submitted as patch to qpid-dev by Nuno Santos): include headers used in posix wrappers.
........
................
r578048 | rupertlssmith | 2007-09-21 11:12:59 +0100 (Fri, 21 Sep 2007) | 9 lines
Recorded merge of revisions 577941 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1
........
r577941 | rgreig | 2007-09-20 22:52:44 +0100 (Thu, 20 Sep 2007) | 2 lines
Attempt to fix hanging builds due to client tests
........
................
r578061 | rupertlssmith | 2007-09-21 12:10:10 +0100 (Fri, 21 Sep 2007) | 10 lines
Merged revisions 578058 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1
........
r578058 | rgreig | 2007-09-21 12:06:40 +0100 (Fri, 21 Sep 2007) | 3 lines
QPID-606: synchronize retrieval of application registry to avoid race conditions. This was
particularly affecting systests which use the in-VM broker.
........
................
r578765 | rupertlssmith | 2007-09-24 12:25:46 +0100 (Mon, 24 Sep 2007) | 45 lines
Blocked revisions 578733,578735,578745 via svnmerge
................
r578733 | rupertlssmith | 2007-09-24 10:47:30 +0100 (Mon, 24 Sep 2007) | 1 line
Removed change tracking, to re-init.
................
r578735 | rupertlssmith | 2007-09-24 10:54:24 +0100 (Mon, 24 Sep 2007) | 3 lines
Initialized merge tracking via "svnmerge" with revisions "1-568187,574873,574876,575253,575688,576861,577193,577316,577660,578048,578061" from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2
................
r578745 | rupertlssmith | 2007-09-24 11:22:32 +0100 (Mon, 24 Sep 2007) | 30 lines
Merged revisions 575663-575687,575689-576860,576862-577192,577194-577315,577317-577659,577661-578047,578049-578060,578062-578604 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2
........
r575663 | rgodfrey | 2007-09-14 13:43:13 +0100 (Fri, 14 Sep 2007) | 1 line
QPID-600 : Deadlock on connection.close
........
r577931 | rgreig | 2007-09-20 22:26:37 +0100 (Thu, 20 Sep 2007) | 1 line
Adding timeouts to two wait() calls to prevent hanging
........
r578258 | rgreig | 2007-09-21 21:31:18 +0100 (Fri, 21 Sep 2007) | 1 line
QPID-607: dispatcher threads now poll so that the can die when the connection is closed.
........
r578475 | rgreig | 2007-09-22 20:01:59 +0100 (Sat, 22 Sep 2007) | 1 line
QPID-608 Fix the test by adding in creation of the VM broker
........
r578509 | rgreig | 2007-09-22 23:05:30 +0100 (Sat, 22 Sep 2007) | 1 line
QPID-609 : dispatcher thread was being restarted by the code that closed the consumer due to the receipt of a basic.cancel frame. Move the dispatcher shutdown to the end of the consumer close process. Also rename the dispatcher _closed field since it clashes with a field in the container class.
........
r578604 | rgreig | 2007-09-23 22:29:33 +0100 (Sun, 23 Sep 2007) | 4 lines
QPID-589: avoid the deadlock between the session close and the BasicCancelOkHandler by
not sending a BasicCancel when the session is being closed.
........
................
................
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578852 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578847 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578827 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578826 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578463 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578269 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578244 13f79535-47bb-0310-9956-ffa450edef68
|