summaryrefslogtreecommitdiff
path: root/cpp
Commit message (Collapse)AuthorAgeFilesLines
* QPID-1613: Ensure that the rule registered with the demuxer for LocalQueue ↵Gordon Sim2009-01-235-4/+54
| | | | | | subscriptions is removed when they are cancelled. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737028 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: More changes to make clustering and federation work togetherGordon Sim2009-01-2214-16/+123
| | | | | | | | | | | * replicate outgoing link traffic to all nodes * coordinate amongst nodes so that only one node actually maintains active links with the others able to take over if that node fails git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736841 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1611: Patch from Mick Goulish to ensure queues are created in store in ↵Gordon Sim2009-01-221-0/+7
| | | | | | cluster configuration git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736814 13f79535-47bb-0310-9956-ffa450edef68
* Optimization: cache results of AMQFrame::encodedSize().Alan Conway2009-01-222-10/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736810 13f79535-47bb-0310-9956-ffa450edef68
* Removed BodyHolder: minor performance improvement, opens the way for more ↵Alan Conway2009-01-2242-724/+271
| | | | | | efficient memory management. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736783 13f79535-47bb-0310-9956-ffa450edef68
* More latency metrics.Alan Conway2009-01-225-3/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736752 13f79535-47bb-0310-9956-ffa450edef68
* cluster: Pipeline decoding. About 10% improvement in latency and throughput.Alan Conway2009-01-217-76/+165
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736409 13f79535-47bb-0310-9956-ffa450edef68
* correct lifecycle for pollablequeue dispatch handleCarl C. Trieloff2009-01-211-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736398 13f79535-47bb-0310-9956-ffa450edef68
* Re-issue 736381 with a literal.Ted Ross2009-01-211-4/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736394 13f79535-47bb-0310-9956-ffa450edef68
* Moved minimum frameMax constant into publicTed Ross2009-01-211-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736381 13f79535-47bb-0310-9956-ffa450edef68
* Include file in distributed headers.Gordon Sim2009-01-211-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736372 13f79535-47bb-0310-9956-ffa450edef68
* Enforce a minimum frame-max to avoid really bad things that can happenTed Ross2009-01-211-3/+4
| | | | | | | if frame-max is set to zero. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736370 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: Added ability for federation links to failover to other specified ↵Gordon Sim2009-01-2113-10/+337
| | | | | | known-hosts git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736354 13f79535-47bb-0310-9956-ffa450edef68
* Fix test to use exchange option correctly when specifiedGordon Sim2009-01-211-4/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736334 13f79535-47bb-0310-9956-ffa450edef68
* Additional latency measurement points.Alan Conway2009-01-219-9/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736326 13f79535-47bb-0310-9956-ffa450edef68
* Fix for race condition in test identified by Ted.Gordon Sim2009-01-211-3/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736317 13f79535-47bb-0310-9956-ffa450edef68
* Latency measurements, compiled out of production code.Alan Conway2009-01-208-16/+194
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736135 13f79535-47bb-0310-9956-ffa450edef68
* Use different file for storing port to avoid interfering with other ↵Gordon Sim2009-01-201-5/+5
| | | | | | check-long tests git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736097 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: added 'exactly-once' guarantee to asynchronous replication of ↵Gordon Sim2009-01-2027-133/+422
| | | | | | | | | | | | 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
* Fix tests broken by r735776: check payload pointer before use. Gordon Sim2009-01-201-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735988 13f79535-47bb-0310-9956-ffa450edef68
* Put messages into LVQ FIFO if no key is specified.Carl C. Trieloff2009-01-192-7/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735776 13f79535-47bb-0310-9956-ffa450edef68
* cluster refactor: separate out dispatch strategy, implement poller and ↵Alan Conway2009-01-165-74/+45
| | | | | | thread dispatch. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735151 13f79535-47bb-0310-9956-ffa450edef68
* cluster refactor: separate out dispatch strategy, implement poller and ↵Alan Conway2009-01-164-0/+222
| | | | | | thread dispatch. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735150 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1588 - Fixed bug in asynchronous API operations.Ted Ross2009-01-165-3/+175
| | | | | | | Added a new example to demonstrate async ops. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735115 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1589 - Added equality/inequality operators to qpid::console::ObjectId.Ted Ross2009-01-162-0/+45
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735114 13f79535-47bb-0310-9956-ffa450edef68
* Separate cluster::EventHeader to allow non-copy events.Alan Conway2009-01-164-38/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735059 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: clean shutdown of event queueGordon Sim2009-01-161-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735054 13f79535-47bb-0310-9956-ffa450edef68
* Added missing PYTHONPATH definition.Ted Ross2009-01-151-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734755 13f79535-47bb-0310-9956-ffa450edef68
* Added lvq-no-browse support to qpid-config.Ted Ross2009-01-151-0/+39
| | | | | | | Added tests for the qpid-specific queue parameters. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734689 13f79535-47bb-0310-9956-ffa450edef68
* Initial commit for QPID-1567 requires PollableQueue.h/PollableCondition.h to ↵Gordon Sim2009-01-151-2/+2
| | | | | | be available as includes for externally built plugins. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734688 13f79535-47bb-0310-9956-ffa450edef68
* Removed duplicate license textTed Ross2009-01-151-21/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734686 13f79535-47bb-0310-9956-ffa450edef68
* Minor typo fixesTed Ross2009-01-152-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734685 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: Initial support for asynchronous queue state replicationGordon Sim2009-01-1520-8/+1045
| | | | | | | | | | | | | | | * Added QueueEvents class with per broker instance * Modified qpid::broker::Queue to notify QueueEvents of enqueues and dequeues (based on configuration) * Added replication subdir containing two plugins: - an event listener that registers with QueueEvents and creates messages representing received events on a replication queue - a custom exchange type for processing messages of the format created by the listener plugin * Added new option for controlling event generation to qpid::client::QueueOptions * Added new queue option to qpid-config script for the same git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734674 13f79535-47bb-0310-9956-ffa450edef68
* Minor formatting correctionGordon Sim2009-01-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734670 13f79535-47bb-0310-9956-ffa450edef68
* Minor formatting fixes and typo correction.Gordon Sim2009-01-153-7/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734668 13f79535-47bb-0310-9956-ffa450edef68
* Fix to sender test: read in whole line as message body, not just next word.Gordon Sim2009-01-141-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734529 13f79535-47bb-0310-9956-ffa450edef68
* Include CPG error code in message.Alan Conway2009-01-141-16/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734479 13f79535-47bb-0310-9956-ffa450edef68
* Fix logic to generate messages at a specified rate. Alan Conway2009-01-141-21/+15
| | | | | | | Previous logic was sending messages well below the specified rate. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734452 13f79535-47bb-0310-9956-ffa450edef68
* Modified footer and header for Google baitJonathan Robie2009-01-142-2/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734451 13f79535-47bb-0310-9956-ffa450edef68
* Move dispatcher code from iocpDispatcher.cpp (no longer needed) to ↵Stephen D. Huston2009-01-134-61/+24
| | | | | | IocpPoller.cpp (run); mirrors migration introduced on Linux side git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734265 13f79535-47bb-0310-9956-ffa450edef68
* Revise allocator per patch in QPID-1458; Fixes QPID-1458Stephen D. Huston2009-01-131-2/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734251 13f79535-47bb-0310-9956-ffa450edef68
* Implement heartbeat timeout on client:Andrew Stitcher2009-01-139-20/+83
| | | | | | | | - The client shuts down a connection if it receives no traffic on it in 2 timeout periods git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734221 13f79535-47bb-0310-9956-ffa450edef68
* Send heartbeat from broker to clientAndrew Stitcher2009-01-139-9/+86
| | | | | | | | - Server sends possible heartbeat range and client replies with desired heartbeat as part of the tune-tuneOk exchange git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734220 13f79535-47bb-0310-9956-ffa450edef68
* Small tidy upAndrew Stitcher2009-01-131-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734218 13f79535-47bb-0310-9956-ffa450edef68
* Created new Timer code in qpid::sysAndrew Stitcher2009-01-133-1/+232
| | | | | | | | | - Necessary for a timer accessible to the client code - The interface is slightly different from the existing Timer code in an attempt to fix some issues with it git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734216 13f79535-47bb-0310-9956-ffa450edef68
* Start to fix Timer to improve encapsulation and then fixAndrew Stitcher2009-01-134-3/+12
| | | | | | | | its inbuilt race conditions (mostly due to the awkward interface of Timer and TimerTask) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734213 13f79535-47bb-0310-9956-ffa450edef68
* Adding missing includeStephen D. Huston2009-01-121-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733967 13f79535-47bb-0310-9956-ffa450edef68
* Add support for AsynchIO::RequestCallback processingStephen D. Huston2009-01-124-11/+65
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733966 13f79535-47bb-0310-9956-ffa450edef68
* Allow any remaining events in PollableQueue to be processed after Poller ↵Gordon Sim2009-01-121-4/+22
| | | | | | | | | threads return from poll loop. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733881 13f79535-47bb-0310-9956-ffa450edef68
* Added test coverage for the CLI utilitiesTed Ross2009-01-093-1/+207
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733108 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status