summaryrefslogtreecommitdiff
path: root/cpp
Commit message (Collapse)AuthorAgeFilesLines
* Stopped frameset from assembling messages piecewise.Alan Conway2007-11-134-42/+35
| | | | | | | Roughly halves allocations on the broker, not much effect on client. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594647 13f79535-47bb-0310-9956-ffa450edef68
* Moved Serializer notifyWorker inside the mutex.Alan Conway2007-11-132-34/+20
| | | | | | | | Removed user-definable notify function, we want to get rid of Serializer, not reuse it. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594537 13f79535-47bb-0310-9956-ffa450edef68
* - removed dirCarl C. Trieloff2007-11-1312-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594525 13f79535-47bb-0310-9956-ffa450edef68
* Increase severity of log message when frames are dropped on session detachingGordon Sim2007-11-131-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594455 13f79535-47bb-0310-9956-ffa450edef68
* Add management directory (as advised on qpid list by nsantos)Gordon Sim2007-11-131-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594454 13f79535-47bb-0310-9956-ffa450edef68
* Patch QPID-680 from trossCarl C. Trieloff2007-11-1339-1377/+1793
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594364 13f79535-47bb-0310-9956-ffa450edef68
* - call correct delete []Carl C. Trieloff2007-11-131-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594361 13f79535-47bb-0310-9956-ffa450edef68
* - removed debugCarl C. Trieloff2007-11-121-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594271 13f79535-47bb-0310-9956-ffa450edef68
* Change to avoid assertion when delivery is concurrent with session detachment:Gordon Sim2007-11-123-11/+16
| | | | | | | | | | | | * in SessionState::getHandler() doesn't assert and just return pointer * do assertion internally in SessionState where getHandler was relied for this before * in SemanticHandler::deliver() get handler and check it; if null then dump the message and print an error git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594233 13f79535-47bb-0310-9956-ffa450edef68
* On rollback requeue (rather than resend).Gordon Sim2007-11-121-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594220 13f79535-47bb-0310-9956-ffa450edef68
* - fix for msg creation, content no longer overwritesCarl C. Trieloff2007-11-121-5/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594205 13f79535-47bb-0310-9956-ffa450edef68
* Minimal bounds checkingGordon Sim2007-11-122-0/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594198 13f79535-47bb-0310-9956-ffa450edef68
* - notify the queue when a async IO completes for a message.Carl C. Trieloff2007-11-123-7/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594186 13f79535-47bb-0310-9956-ffa450edef68
* - fix for dequeue window mode, no ack. (needs to record and dequeue)Carl C. Trieloff2007-11-121-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594155 13f79535-47bb-0310-9956-ffa450edef68
* -- added sync requestCarl C. Trieloff2007-11-121-4/+24
| | | | | | | | -- make queue durable if -- durable yes specified git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594151 13f79535-47bb-0310-9956-ffa450edef68
* Add DeliveryMode enum to AMQHeaderBody.h, remove from tests.Alan Conway2007-11-105-9/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593726 13f79535-47bb-0310-9956-ffa450edef68
* Replace vector in AMQHeaderBody with boost::optional.Alan Conway2007-11-102-91/+61
| | | | | | | Eliminates 40% of allocs. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593721 13f79535-47bb-0310-9956-ffa450edef68
* Get rid of BasicHeaderProperties, dead code from 0-8 protocol.Alan Conway2007-11-0916-411/+74
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593692 13f79535-47bb-0310-9956-ffa450edef68
* Package examples in rpm %doc directory.Alan Conway2007-11-0924-101/+47
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593638 13f79535-47bb-0310-9956-ffa450edef68
* On Linux, broker defaults --worker-threads to the number of available CPU coresAlan Conway2007-11-095-2/+85
| | | | | | | reported by sysconf(_SC_NPROCESSORS_ONLN) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593632 13f79535-47bb-0310-9956-ffa450edef68
* Fix race in destruction of serializer.Gordon Sim2007-11-092-4/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593569 13f79535-47bb-0310-9956-ffa450edef68
* Functions for scripts that verify examples.Alan Conway2007-11-091-0/+50
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593531 13f79535-47bb-0310-9956-ffa450edef68
* Makefile to build/distribute examples.Alan Conway2007-11-091-9/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593415 13f79535-47bb-0310-9956-ffa450edef68
* QPID-676: Jonathan Robie's C++ examples.Alan Conway2007-11-0920-110/+1651
| | | | | | | | | | | | | | | Made the following alterations for recent C++ API changes: - use arg:: namespace for Session keyword arguments. - removed trailing _ on session method names. cpp/examples/Makefile.am calls make in each example directory with flags to build examples from headers/libraries SVN checkout. Examples themselves have a plain Makefile (not automake) which will work as is if qpid is installed in standard places. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593402 13f79535-47bb-0310-9956-ffa450edef68
* src/tests/perfdist: Use ssh to run distributed perftest.Alan Conway2007-11-082-36/+91
| | | | | | | | | | | ./perfdist for usage. src/tests/perftest.cpp: --summary gives one-line report, can cut/paste into spreadsheet for multiple runs. --purge as initial clean-up step for distributed tests (see perfdist) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593321 13f79535-47bb-0310-9956-ffa450edef68
* Added persistence to queue declaration when --durable option is defined on ↵Kim van der Riet2007-11-081-1/+1
| | | | | | the command line. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593289 13f79535-47bb-0310-9956-ffa450edef68
* - enable the ability to lazy load from async storeCarl C. Trieloff2007-11-0821-36/+56
| | | | | | | | | | - the ci has a raw ptr for Queue in QueuedMessage, if any has any concerns, ping me and I will convert it to an auto_ptr Carl. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593251 13f79535-47bb-0310-9956-ffa450edef68
* Improved Fix for the race condition where you've got a competing read and writeAndrew Stitcher2007-11-082-74/+15
| | | | | | | | for the same handle. This can happen if we've just got a read event then before handling it we watch for write events and get one immediately. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593237 13f79535-47bb-0310-9956-ffa450edef68
* Exception handling for dispatch functorGordon Sim2007-11-083-10/+17
| | | | | | | | Don't dequeue no-ack messages unless they have been acquired git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593212 13f79535-47bb-0310-9956-ffa450edef68
* Make standard exchanges durableGordon Sim2007-11-088-27/+50
| | | | | | | | Ensure flags are set correctly for recovered messages with no content git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593159 13f79535-47bb-0310-9956-ffa450edef68
* Ensure browsers are always serviced on the serializers dispatch thread to ↵Gordon Sim2007-11-082-2/+10
| | | | | | avoid concurrent servicing threads interfering with each other. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593112 13f79535-47bb-0310-9956-ffa450edef68
* Change options --log.foo to --log-foo for consistency.Alan Conway2007-11-075-36/+36
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592956 13f79535-47bb-0310-9956-ffa450edef68
* Revert r592946Alan Conway2007-11-071-5/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592948 13f79535-47bb-0310-9956-ffa450edef68
* Fix race condition in perftest.Alan Conway2007-11-071-3/+5
| | | | | | | | NOTE: in multi-process mode you must run the publisher first and wait for it to show "waiting for consumers" before starting consumers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592946 13f79535-47bb-0310-9956-ffa450edef68
* Fix race condition in perftest.Alan Conway2007-11-071-18/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592941 13f79535-47bb-0310-9956-ffa450edef68
* auto-ack support for perftest.Alan Conway2007-11-073-7/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592897 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-639: c++ now includes sizes for all structs (enabled the same ↵Gordon Sim2007-11-074-13/+73
| | | | | | in python & java) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592895 13f79535-47bb-0310-9956-ffa450edef68
* client::SubscriptionManager:Alan Conway2007-11-0714-346/+402
| | | | | | | | | | | | | | | | | - Added autoStop support. - Added LocalQueue subscriptions. - Expose AckPolicy settings to user. client::Message: - incoming Messages carry their session for acknowledge perftest: (see perftest --help for details...) - allow multiple consumers. - 3 queue modes: shared, fanout, topic. - set size of messages git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592869 13f79535-47bb-0310-9956-ffa450edef68
* Added LocalQueue subscriptions. LocalQueue::pop() provides a "pull"Alan Conway2007-11-0710-31/+90
| | | | | | | alternative to the MessageListener::received() "push" API. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592803 13f79535-47bb-0310-9956-ffa450edef68
* Fix to QPID-640. The fields actually set/encoded are now tracked explicitly.Gordon Sim2007-11-071-43/+105
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592753 13f79535-47bb-0310-9956-ffa450edef68
* added # yum install e2fsprogs-develArnaud Simon2007-11-071-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592653 13f79535-47bb-0310-9956-ffa450edef68
* - clean up between base & subclassesCarl C. Trieloff2007-11-064-6/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592530 13f79535-47bb-0310-9956-ffa450edef68
* Add support for array type to c++ (and python, decode only for now)Gordon Sim2007-11-0610-19/+287
| | | | | | | | Change the type of the in-doubt field in dtx-coordination.recover to an array (to bring in line with amqp spec) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592494 13f79535-47bb-0310-9956-ffa450edef68
* Temporary fix to issue that results in an assertion from Dispatcher.cpp. ↵Gordon Sim2007-11-062-4/+79
| | | | | | Where an interest in write is signalled just as a readable event is triggered it is possible for a writeable (or read-writeable) event to be triggered before the earlier event is processed. This change ensures they are processed serially by queueing them up for the first thread to handle. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592485 13f79535-47bb-0310-9956-ffa450edef68
* Added reset function to class AbsTime, thus allowing same instance of ↵Kim van der Riet2007-11-053-3/+15
| | | | | | TimerTask to be reset and used again for the same duration as initially set git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592170 13f79535-47bb-0310-9956-ffa450edef68
* Suspension of one xid on a channel should allow for work on other xids to be ↵Gordon Sim2007-11-052-0/+15
| | | | | | done prior to resuming the initial xid. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591986 13f79535-47bb-0310-9956-ffa450edef68
* Modified comment for last change to explain the reasoningGordon Sim2007-11-051-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591951 13f79535-47bb-0310-9956-ffa450edef68
* Push buffer back on front when read fails (esp. important when result was ↵Gordon Sim2007-11-051-1/+1
| | | | | | EAGAIN as the buffer may contain unread data) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591950 13f79535-47bb-0310-9956-ffa450edef68
* AMQP 670 This patch contains the following:Carl C. Trieloff2007-11-0414-90/+133
| | | | | | | | | | 1) "using" clauses were removed from one header file. This required changes in other header and body files that were relying on that clause. 2) The object indexing scheme has been improved in the management schema. Objects now properly reference their parent/containing objects. 3) The framework for parsing management commands has been added. 4) The python management API has been improved and now includes an object-method call. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591715 13f79535-47bb-0310-9956-ffa450edef68
* - support for store to abort init / forceCarl C. Trieloff2007-11-037-9/+19
| | | | | | | | - there is an issue exiting via exception not related to this fix, but uncovered by this fix - JIRA 671 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591526 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status