summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
Commit message (Collapse)AuthorAgeFilesLines
* Session resume support in client & broker: Client can resume a sessionAlan Conway2007-10-26110-1480/+1790
| | | | | | | | | | | | | | | | | | | | | | | | | after voluntary suspend() or network failure. Frames lost in network failure are automatically re-transmitted for transparent re-connection. client::Session improvements: - Locking to avoid races between network & user threads. - Replaced client::StateManager with sys::StateMonitor - avoid heap allocation. qpid::Exception clean up: - use QPID_MSG consistently to format exception messages. - throw typed exceptions (in reply_exceptions.h) for AMQP exceptions. - re-throw correct typed exception on client for exceptions from broker. - Removed QpidError.h rubygen/templates/constants.rb: - constants.h: Added FOO_CLASS_ID and FOO_BAR_METHOD_ID constants. - reply_constants.h: Added throwReplyException(code, text) log::Logger: - Fixed shutdown race in Statement::~Initializer() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@588761 13f79535-47bb-0310-9956-ffa450edef68
* - added patch from TeddCarl C. Trieloff2007-10-2613-202/+413
| | | | | | | | - QPID-660 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@588478 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to handling of non-acquired subscribersGordon Sim2007-10-251-4/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@588286 13f79535-47bb-0310-9956-ffa450edef68
* Don't requeue released messages.Gordon Sim2007-10-251-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@588203 13f79535-47bb-0310-9956-ffa450edef68
* Hack for no-local when used with jms topicsGordon Sim2007-10-236-28/+102
| | | | | | | | Fix for releasing of exclusive ownership of queues second time around git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@587525 13f79535-47bb-0310-9956-ffa450edef68
* - removed debug coutCarl C. Trieloff2007-10-231-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@587485 13f79535-47bb-0310-9956-ffa450edef68
* More tidying up of field table APIAndrew Stitcher2007-10-236-26/+56
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@587480 13f79535-47bb-0310-9956-ffa450edef68
* -added missing file from checkinCarl C. Trieloff2007-10-231-0/+40
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@587467 13f79535-47bb-0310-9956-ffa450edef68
* - flush async IO if present on sync for 0-10Carl C. Trieloff2007-10-235-7/+46
| | | | | | | | | - notify, for ack from sync for 0-10 - use of raw pointer, to avoid recursive fre git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@587332 13f79535-47bb-0310-9956-ffa450edef68
* Record peer address (for logging purposes) on initiation rather than on ↵Gordon Sim2007-10-221-11/+14
| | | | | | every logged message. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@587054 13f79535-47bb-0310-9956-ffa450edef68
* QPID-651 applied patch from TedCarl C. Trieloff2007-10-1915-10/+857
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586578 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586520 ↵Andrew Stitcher2007-10-199-511/+194
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* Fix to allocation algorithm in queue: prevents infinite loop when first ↵Gordon Sim2007-10-193-9/+12
| | | | | | | | | | consumer for allocation is cancelled after starting to dispatch a particular method. Removed alarming(!) log statement. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586519 13f79535-47bb-0310-9956-ffa450edef68
* Fixed typo in messageCarl C. Trieloff2007-10-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586427 13f79535-47bb-0310-9956-ffa450edef68
* Fix for leak on receiving eof on networkAndrew Stitcher2007-10-191-7/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586345 13f79535-47bb-0310-9956-ffa450edef68
* - added init for dir and async options for storeCarl C. Trieloff2007-10-196-2/+46
| | | | | | | | - added flush for queue for async processing git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586207 13f79535-47bb-0310-9956-ffa450edef68
* More rearranging of template specialisation to avoid gccisms and conform ↵Andrew Stitcher2007-10-182-24/+12
| | | | | | correctly to the standard git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586054 13f79535-47bb-0310-9956-ffa450edef68
* - added options for aysnc store & store dir locationCarl C. Trieloff2007-10-182-2/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586005 13f79535-47bb-0310-9956-ffa450edef68
* Lock active session id map when removing id for closed session.Gordon Sim2007-10-183-1/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585968 13f79535-47bb-0310-9956-ffa450edef68
* Recast int to FixedWidthValue conversions to avoid tamplate specialisation ↵Andrew Stitcher2007-10-182-130/+18
| | | | | | and be more general git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585966 13f79535-47bb-0310-9956-ffa450edef68
* Fixed return of acquired message ranges (and added tests)Gordon Sim2007-10-183-6/+60
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585952 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-644Gordon Sim2007-10-184-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585899 13f79535-47bb-0310-9956-ffa450edef68
* Fix to headers exchanges bind: need to check the match value is present ↵Gordon Sim2007-10-172-1/+17
| | | | | | | | | | before dereferencing Added tests for this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585503 13f79535-47bb-0310-9956-ffa450edef68
* Use shared pointers for consumers (held by queues and sessions) to prevent ↵Gordon Sim2007-10-178-101/+120
| | | | | | | | | | having to hold lock across deliver() while avoiding invocation on stale pointers. Ensure auto-deleted queues are properly cleaned up (i.e. are unbound from exchanges) to avoid leaking memory as messages are accumulated in inaccessible queues. (some cleanup to follow on this) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585417 13f79535-47bb-0310-9956-ffa450edef68
* * Summary: generalized Invoker visitor to all *Operations andAlan Conway2007-10-1612-54/+110
| | | | | | | | | | | | | | | | | | | | | | | | | | | *Handler classes, client and broker. Single template free function invoke(Invocable, const AMQBody&); works for all invocable handlers. * rubygen/templates/OperationsInvoker.rb: Generates invoker visitors for all Operations classes, client and server. * src/qpid/framing/Invoker.h: Invoker base class and template invoke() function. * rubygen/templates/structs.rb: add generic invoke method template to invoke an arbitrary object with the correct memeber function. * src/qpid/framing/AMQMethodBody.cpp, .h: Removed invoke(), replaced by qpid::framing::invoke() * src/qpid/broker/SemanticHandler.cpp, ConnectionHandler.cpp: Replace AMQMethodBody::invoke with invoke() free function. * src/qpid/framing/StructHelper.h: Avoid un-necessary alloc and copy in encode/decode. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585223 13f79535-47bb-0310-9956-ffa450edef68
* Include declarations of the specialisations we define to make sure they are ↵Andrew Stitcher2007-10-161-0/+16
| | | | | | picked up correctly by everything git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585190 13f79535-47bb-0310-9956-ffa450edef68
* Restored missing TestOptions.hAlan Conway2007-10-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585181 13f79535-47bb-0310-9956-ffa450edef68
* Edits to --help message and man page to improve readabiliity.Alan Conway2007-10-166-25/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585137 13f79535-47bb-0310-9956-ffa450edef68
* Log a warning if we close a connection with unsent dataAndrew Stitcher2007-10-162-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585127 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of 0-10 field tablesAndrew Stitcher2007-10-1619-168/+661
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585097 13f79535-47bb-0310-9956-ffa450edef68
* * Revised allocation algorithm to ensure all consumers are given the ↵Gordon Sim2007-10-163-14/+22
| | | | | | | | | | | opportunity to consume a message * If already have infinit credit, don't try to add to it * If get disconnected while processing close, just finish off the close and don't signal the disconnection git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585085 13f79535-47bb-0310-9956-ffa450edef68
* Locking for updates to subscriber credit. Revised log statements to reduce ↵Gordon Sim2007-10-151-8/+18
| | | | | | noise. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584841 13f79535-47bb-0310-9956-ffa450edef68
* Fix compilation errorGordon Sim2007-10-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584792 13f79535-47bb-0310-9956-ffa450edef68
* Added missing framing:: qualifier.Alan Conway2007-10-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584776 13f79535-47bb-0310-9956-ffa450edef68
* Added assert.cpp to makefile.Alan Conway2007-10-151-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584770 13f79535-47bb-0310-9956-ffa450edef68
* QPID_ASSERT: assert a condition. In a debug build abort if condition is false,Alan Conway2007-10-152-0/+82
| | | | | | | in NDEBUG build throws an exception. Note this will leave the test in production code. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584769 13f79535-47bb-0310-9956-ffa450edef68
* Include information on the client connection in io traces.Gordon Sim2007-10-153-17/+61
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584755 13f79535-47bb-0310-9956-ffa450edef68
* Remove default queue concept which is no longer applicable in 0-10.Gordon Sim2007-10-153-11/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584719 13f79535-47bb-0310-9956-ffa450edef68
* Enabled packed struct encoding in python, cpp, and java. Also fixed ↵Rafael H. Schloming2007-10-141-1/+1
| | | | | | computation of required byte credit in Message.cpp. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584474 13f79535-47bb-0310-9956-ffa450edef68
* Further fixes to locking between queue and semantic state to avoid deadlocking.Gordon Sim2007-10-124-53/+102
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584172 13f79535-47bb-0310-9956-ffa450edef68
* Some fixes to locking within the queue (preventing locks being held during ↵Gordon Sim2007-10-122-36/+33
| | | | | | delivery to a consumer) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584144 13f79535-47bb-0310-9956-ffa450edef68
* Close connection when a framing error is encountered during decoding.Gordon Sim2007-10-122-29/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@584143 13f79535-47bb-0310-9956-ffa450edef68
* Exclusive no longer implies auto-delete on queue.declare.Gordon Sim2007-10-115-8/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583821 13f79535-47bb-0310-9956-ffa450edef68
* Requeue messages for cancelled subscriptions on reciver (rather than ↵Gordon Sim2007-10-111-2/+6
| | | | | | redelivering) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583750 13f79535-47bb-0310-9956-ffa450edef68
* Fix: recovered messages must be marked redeliveredGordon Sim2007-10-111-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583739 13f79535-47bb-0310-9956-ffa450edef68
* Fixed compile error.Alan Conway2007-10-091-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583298 13f79535-47bb-0310-9956-ffa450edef68
* Added some debug logs to indicate credit levels and verify if a message is ↵Rajith Muditha Attapattu2007-10-092-0/+6
| | | | | | | | | enqueued. I found it useful during testing git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@583253 13f79535-47bb-0310-9956-ffa450edef68
* Don't recover messages for cancelled subscriptions.Gordon Sim2007-10-054-8/+30
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@582353 13f79535-47bb-0310-9956-ffa450edef68
* Additional tests and fixesGordon Sim2007-10-048-16/+66
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581957 13f79535-47bb-0310-9956-ffa450edef68
* * docs/man/qpidd.x: Explain configuration options.Alan Conway2007-10-043-7/+15
| | | | | | | | | | * etc/qpidd.conf: Placeholder configuration file. * qpidc.spec.in: Install qpidd.conf * Makefile.am: Install qpidd.conf * src/qpid/Options.cpp, h, src/qpidd.cpp: Option formatting fixes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@581951 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status