summaryrefslogtreecommitdiff
path: root/qpid
Commit message (Collapse)AuthorAgeFilesLines
* error checking for field table decode, actually close sessions on session ↵Rafael H. Schloming2007-10-013-4/+41
| | | | | | 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
* Changed to set topic namesArnaud Simon2007-10-011-31/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581052 13f79535-47bb-0310-9956-ffa450edef68
* fixed buildRafael H. Schloming2007-10-011-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581050 13f79535-47bb-0310-9956-ffa450edef68
* Changed to use QpidTestCaseArnaud Simon2007-10-016-55/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581009 13f79535-47bb-0310-9956-ffa450edef68
* Changed to use QpidTestCaseArnaud Simon2007-10-011-5/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581008 13f79535-47bb-0310-9956-ffa450edef68
* * src/qpid/framing/ResumeHandler.cpp: Handle ack and resume logicAlan Conway2007-10-015-0/+218
| | | | | | | for broker and client. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580984 13f79535-47bb-0310-9956-ffa450edef68
* Changed to use UUID for unique name generationArnaud Simon2007-10-011-7/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580974 13f79535-47bb-0310-9956-ffa450edef68
* Changed for setting new name to destinationsArnaud Simon2007-10-011-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580944 13f79535-47bb-0310-9956-ffa450edef68
* Changed for setting message flow to already started message listenersArnaud Simon2007-10-013-5/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580929 13f79535-47bb-0310-9956-ffa450edef68
* Changed to use QpidTestCaseArnaud Simon2007-10-011-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580928 13f79535-47bb-0310-9956-ffa450edef68
* Changed onMessage to copy the incoming byteBufferArnaud Simon2007-10-011-5/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580922 13f79535-47bb-0310-9956-ffa450edef68
* Make ExecutionHandler threadsafe for calls that can be made by application ↵Gordon Sim2007-10-015-14/+40
| | | | | | | | | | 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
* changed kill broker methodArnaud Simon2007-10-011-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580891 13f79535-47bb-0310-9956-ffa450edef68
* Added missing headers to makefile.Alan Conway2007-09-281-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580471 13f79535-47bb-0310-9956-ffa450edef68
* added messageID to sent messagesArnaud Simon2007-09-281-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580470 13f79535-47bb-0310-9956-ffa450edef68
* changed delcareQueue to be protected so that to used 0_10 specific impArnaud Simon2007-09-281-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580460 13f79535-47bb-0310-9956-ffa450edef68
* Ensure no danbling pointers in client API:Alan Conway2007-09-289-22/+29
| | | | | | | | | - 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
* Fixed compile error.Alan Conway2007-09-281-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580417 13f79535-47bb-0310-9956-ffa450edef68
* Missed commit for last checkin.Alan Conway2007-09-281-2/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580413 13f79535-47bb-0310-9956-ffa450edef68
* * src/qpid/log/Helpers.h: Format complex types for log messagesAlan Conway2007-09-281-0/+79
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580404 13f79535-47bb-0310-9956-ffa450edef68
* * src/tests/ClientSessionTest.cpp: Suspend/resume tests.Alan Conway2007-09-2822-283/+356
| | | | | | | | | | | | | | | * 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
* fixed several 0_10 issuesArnaud Simon2007-09-284-7/+48
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580394 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580389 ↵Arnaud Simon2007-09-285-237/+276
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* Minor refactoring of execution layerGordon Sim2007-09-2811-26/+72
| | | | | | | | 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
* Honour sync bit when processing L4 methodGordon Sim2007-09-283-3/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580266 13f79535-47bb-0310-9956-ffa450edef68
* issue execution_sync rather than execution_flush prior to waiting for completionRafael H. Schloming2007-09-271-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580123 13f79535-47bb-0310-9956-ffa450edef68
* added support for 0-10 field table encodingRafael H. Schloming2007-09-273-23/+87
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580122 13f79535-47bb-0310-9956-ffa450edef68
* Some revisions to rubygen for packed structs and execution header (changes ↵Gordon Sim2007-09-275-28/+194
| | | | | | not yet enabled) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580094 13f79535-47bb-0310-9956-ffa450edef68
* Added generic TestCase for connecting to remote broker Arnaud Simon2007-09-273-11/+249
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580051 13f79535-47bb-0310-9956-ffa450edef68
* fixed codec of UUIDsRafael H. Schloming2007-09-272-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579863 13f79535-47bb-0310-9956-ffa450edef68
* Detect that connection is already closed on attempt to close()Gordon Sim2007-09-263-1/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579582 13f79535-47bb-0310-9956-ffa450edef68
* Change to start execution mark at -1Gordon Sim2007-09-261-8/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579559 13f79535-47bb-0310-9956-ffa450edef68
* Start execution mark from -1 (0xFFFFFFFF)Gordon Sim2007-09-267-12/+16
| | | | | | | | Rename ackFrequency as ackBatchSize in Dispatcher git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579553 13f79535-47bb-0310-9956-ffa450edef68
* Renamed the following files for consistency:Alan Conway2007-09-2553-120/+120
| | | | | | | | | | | | | | | | | | 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
* Added a conveter to convert between FieldTable and Map<String,Object> for 0-10Rajith Muditha Attapattu2007-09-254-8/+60
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579043 13f79535-47bb-0310-9956-ffa450edef68
* improved close handling, made session.sync() return on session closeRafael H. Schloming2007-09-253-1/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@579040 13f79535-47bb-0310-9956-ffa450edef68
* Changed the ExceptionListener to ClosedListerner that notifies a close event.Rajith Muditha Attapattu2007-09-2510-70/+80
| | | | | | | | 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
* 2007-09-24 Alan Conway <aconway@redhat.com>Alan Conway2007-09-2417-214/+246
| | | | | | | | | | | | | | | * 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
* Client.java: workaround for NPE + close underling connection. ↵Rafael H. Schloming2007-09-242-9/+29
| | | | | | 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
* switched to one byte for class/method idsRafael H. Schloming2007-09-242-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578891 13f79535-47bb-0310-9956-ffa450edef68
* added a mapping for byte[]sRafael H. Schloming2007-09-242-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578864 13f79535-47bb-0310-9956-ffa450edef68
* Packaging fixes to spec and Makefile from nsantos@redhat.com.Alan Conway2007-09-242-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578854 13f79535-47bb-0310-9956-ffa450edef68
* Added TestClient program for running distributed tests with.Rupert Smith2007-09-244-0/+158
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578847 13f79535-47bb-0310-9956-ffa450edef68
* added field table encoding/decodingRafael H. Schloming2007-09-2417-113/+742
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578827 13f79535-47bb-0310-9956-ffa450edef68
* rerun generate script when it is modifiedRafael H. Schloming2007-09-242-15/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578826 13f79535-47bb-0310-9956-ffa450edef68
* Added missing makefiles to include_HEADERS for installation.Alan Conway2007-09-211-61/+62
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578269 13f79535-47bb-0310-9956-ffa450edef68
* Supression for bogus i386 valgrind error.Alan Conway2007-09-211-23/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578244 13f79535-47bb-0310-9956-ffa450edef68
* - dequeue fix for AIOCarl C. Trieloff2007-09-213-5/+16
| | | | | | | | - added access functions needed for AIO in Recoverable classes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578232 13f79535-47bb-0310-9956-ffa450edef68
* Split broker::Session into:Alan Conway2007-09-2122-281/+331
| | | | | | | | broker::SessionState: session info (uuid etc.) + handler chains. broker::SemanticState: session state for the SemanticHandler. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578219 13f79535-47bb-0310-9956-ffa450edef68
* Moved c++ over to using the same preview file for 0-10 work as java.Gordon Sim2007-09-2114-7485/+43
| | | | | | | | | | Removed all channel class related code from broker as a result. Did the same for some python tests I missed earlier. Renamed ChannelAdapter to ChannelHandler. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@578167 13f79535-47bb-0310-9956-ffa450edef68