summaryrefslogtreecommitdiff
path: root/qpid/cpp
Commit message (Collapse)AuthorAgeFilesLines
* constants.rb: generate type code constants for AMQP types. Useful with Array.Alan Conway2008-11-0414-87/+267
| | | | | | | | | framing/Array: - added some std:::vector like functions & typedefs. - use TypeCode enums, human readable ostream << operator. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711365 13f79535-47bb-0310-9956-ffa450edef68
* Added unit test for replay utility class.Gordon Sim2008-11-042-1/+81
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711328 13f79535-47bb-0310-9956-ffa450edef68
* Allow local broker to be run in any position in a ClusterFixture.Alan Conway2008-11-041-84/+77
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711283 13f79535-47bb-0310-9956-ffa450edef68
* Adding a couple of utilities (don't alter any existing functionality) that ↵Gordon Sim2008-11-048-6/+554
| | | | | | | | | | are useful in applications handling failover. Added example of their use that I've been using in testing. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711256 13f79535-47bb-0310-9956-ffa450edef68
* Correct signature of usleep() methodStephen D. Huston2008-11-031-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710216 13f79535-47bb-0310-9956-ffa450edef68
* Add missing source filesStephen D. Huston2008-11-031-0/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710188 13f79535-47bb-0310-9956-ffa450edef68
* correction for Active-Active clustering, allowing late joining nodes in the ↵Carl C. Trieloff2008-11-033-40/+61
| | | | | | cluster to sync counter values for sequenced messages git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710157 13f79535-47bb-0310-9956-ffa450edef68
* This line seems not to be as redundant as I thought! Its removal seems to ↵Gordon Sim2008-11-031-0/+1
| | | | | | trigger some leaks for some platforms/cases. Adding it back for now. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710124 13f79535-47bb-0310-9956-ffa450edef68
* Various fixes arising from testing client failover:Gordon Sim2008-11-0310-24/+52
| | | | | | | | | | | | | | | | | | | | * introduced new exception type for signalling connection failure (as distinct from any logical connection errors) * ConnectionImpl::closeInternal(): take copy of session map to prevent concurrent modification (by the same thread) as sessions are deleted and erase themselves. * ConnectionImpl::shutdown: hold lock before calling closeInternal(); mark handler failed before informing sessions of failure * SessionImpl::connectionBroker(): remove code as its rather meaningless * Don't swallow exceptions in Dispatcher * Handle exceptions in FailoverListener * Take weak_ptr to ConnectionImpl on constructor of Connector, then convert to shared_ptr when 'receiver' thread is started. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710106 13f79535-47bb-0310-9956-ffa450edef68
* Get initial Windows options in; event log doesn't yet workStephen D. Huston2008-10-312-9/+43
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709544 13f79535-47bb-0310-9956-ffa450edef68
* Federation enhancements and bug fixes:Ted Ross2008-10-311-1/+4
| | | | | | | | | | qmfconsole.py - minor fixes, make sure object-dereference only queries one broker Bridge.cpp - Added channel-id to queue name to avoid collisions qpid-route - Added link-map feature for viewing the entire federated topology git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709532 13f79535-47bb-0310-9956-ffa450edef68
* Cluster returns connection exception for un-supported AMQP features.Alan Conway2008-10-313-4/+40
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709474 13f79535-47bb-0310-9956-ffa450edef68
* Added return Message overload of SubscriptionManager get().Alan Conway2008-10-315-10/+24
| | | | | | | Fixed compile error in broker/Vhost.cpp git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709440 13f79535-47bb-0310-9956-ffa450edef68
* Fix intermittent hanging where two threads are waiting for completions on ↵Gordon Sim2008-10-311-1/+1
| | | | | | the same session. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709429 13f79535-47bb-0310-9956-ffa450edef68
* Federation bug-fixes:Ted Ross2008-10-314-12/+22
| | | | | | | | | | | | | | 1) Locking was added to protect the exchange's vector of bridges. 2) Bridges are now properly torn down when a link is lost. 3) Auto-tracing was improperly assigning tags to federation queues. Also, the federation queue name now uses the broker-id for the destination broker. This makes it easier to determine which queues go to which brokers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709342 13f79535-47bb-0310-9956-ffa450edef68
* Fix Acl references related to QPID-1368Stephen D. Huston2008-10-302-5/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709293 13f79535-47bb-0310-9956-ffa450edef68
* Fix namespace reference usage to work on WindowsStephen D. Huston2008-10-301-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709286 13f79535-47bb-0310-9956-ffa450edef68
* Resolve Time diffs for Windows; add Windows version of asynch I/O layer. ↵Stephen D. Huston2008-10-307-20/+173
| | | | | | Resolves QPID-1209 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709285 13f79535-47bb-0310-9956-ffa450edef68
* Adjust ACL-related enums to avoid Windows macro clashes; fixes QPID-1368Stephen D. Huston2008-10-303-98/+100
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709283 13f79535-47bb-0310-9956-ffa450edef68
* Resolved unused argument warnings from MSVCStephen D. Huston2008-10-304-41/+41
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709282 13f79535-47bb-0310-9956-ffa450edef68
* Adjust namespace references to work with MSVCStephen D. Huston2008-10-309-28/+41
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709281 13f79535-47bb-0310-9956-ffa450edef68
* Consistently refer to struct as struct, not classStephen D. Huston2008-10-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709280 13f79535-47bb-0310-9956-ffa450edef68
* Removed unneeded forward refStephen D. Huston2008-10-301-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709278 13f79535-47bb-0310-9956-ffa450edef68
* Add missing include fileStephen D. Huston2008-10-301-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709277 13f79535-47bb-0310-9956-ffa450edef68
* Add missing include new - needed on WindowsStephen D. Huston2008-10-301-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709276 13f79535-47bb-0310-9956-ffa450edef68
* Removed unneeded and nonportable include config.hStephen D. Huston2008-10-301-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709274 13f79535-47bb-0310-9956-ffa450edef68
* Add Windows pieces for building the broker; resolves QPID-1338Stephen D. Huston2008-10-302-1/+90
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709271 13f79535-47bb-0310-9956-ffa450edef68
* Add missing source filesStephen D. Huston2008-10-302-4/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709268 13f79535-47bb-0310-9956-ffa450edef68
* Replicate session state for un-acknowledged messages to new cluster members.Alan Conway2008-10-3012-75/+257
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709242 13f79535-47bb-0310-9956-ffa450edef68
* Include qpidd.h file in listed sourcesGordon Sim2008-10-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709187 13f79535-47bb-0310-9956-ffa450edef68
* Allow AbsTime and Duration to be used cross-platform; add usleep() wrapper. ↵Stephen D. Huston2008-10-295-48/+125
| | | | | | Related to QPID-1209 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709028 13f79535-47bb-0310-9956-ffa450edef68
* Split platform-specific qpidd code out to posix/QpiddBroker.cpp; allows ↵Stephen D. Huston2008-10-294-188/+253
| | | | | | Windows port code to come in. Related to QPID-1338 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708991 13f79535-47bb-0310-9956-ffa450edef68
* * added flag to SubscriptionSettings to control automatic completion of messageGordon Sim2008-10-296-30/+50
| | | | | | | | | | * removed automatic acquiring under autoAck mode * added test for results from acquire requests * added short txtest to the set of system tests run under make check git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708919 13f79535-47bb-0310-9956-ffa450edef68
* Ensure required header files are installed (we may want to revise this, but ↵Gordon Sim2008-10-291-5/+5
| | | | | | as committed by r707808 applications no longer compile due to these headers being missing; if we do want to avoid them being installed any includes from other headers need to be revised also). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708872 13f79535-47bb-0310-9956-ffa450edef68
* Rename schema names OPTIONAL and INDEX to IS_OPTIONAL and IS_INDEX to avoid ↵Stephen D. Huston2008-10-282-4/+4
| | | | | | name clashes in Windows header files; fixes QPID-1408 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708704 13f79535-47bb-0310-9956-ffa450edef68
* Fix to build needed directory tree on Windows; fixes QPID-1407Stephen D. Huston2008-10-281-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708703 13f79535-47bb-0310-9956-ffa450edef68
* Make federation work over Rdma linksAndrew Stitcher2008-10-281-45/+53
| | | | | | | - Some refactoring of Rdma code for simplicity git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708696 13f79535-47bb-0310-9956-ffa450edef68
* Trivial comment changeAndrew Stitcher2008-10-281-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708695 13f79535-47bb-0310-9956-ffa450edef68
* Recent change from AckPolicy to Subscription means completions are not sent ↵Gordon Sim2008-10-281-0/+1
| | | | | | automatically which is required in window mode. Added manual send as temporary measure. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708540 13f79535-47bb-0310-9956-ffa450edef68
* Test for presence of python directoryGordon Sim2008-10-281-3/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708496 13f79535-47bb-0310-9956-ffa450edef68
* Add CONF_FILE and MODULE_DIR macros to allow building clientStephen D. Huston2008-10-271-8/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708389 13f79535-47bb-0310-9956-ffa450edef68
* Fix minor compile warnings noticed on WindowsStephen D. Huston2008-10-275-7/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708387 13f79535-47bb-0310-9956-ffa450edef68
* client::SubscriptionManager::findSubscription() throws if not found.Alan Conway2008-10-273-5/+7
| | | | | | | Added progress indicator to boost tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@708210 13f79535-47bb-0310-9956-ffa450edef68
* corrected compile errorCarl C. Trieloff2008-10-261-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707931 13f79535-47bb-0310-9956-ffa450edef68
* Adjust to removed AckPolicy.cpp and refactored Modules.h, .cppStephen D. Huston2008-10-262-7/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707929 13f79535-47bb-0310-9956-ffa450edef68
* Change 'at' to 'find' to build with older g++ and with MSVCStephen D. Huston2008-10-261-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707927 13f79535-47bb-0310-9956-ffa450edef68
* Refactor duplicated Module-handling from broker/client to commonStephen D. Huston2008-10-264-59/+132
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707924 13f79535-47bb-0310-9956-ffa450edef68
* Microsoft NMAKE file to generate C++ code from specsStephen D. Huston2008-10-261-0/+38
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707918 13f79535-47bb-0310-9956-ffa450edef68
* Client API change: Centralize access to subscription status, better control ↵Alan Conway2008-10-2529-496/+740
| | | | | | | | | | | | | | | | | | | of acquire/accept. client/AckPolicy: removed, functionality moved to Subscription and SubscriptionSettings client/SubscriptionSettings: struct aggregates flow control & accept-acquire parameters for subscribe. client/Subscription: represents active subscription. Query settings, unacked messages, manual accept/acquire client/SubscriptionManager: use AcceptMode, AcquireMode enums rather than confusing bools. Issues addressed by the change: - old use of bool for acceptMode was inverted wrt AMQP enum values, bools are confusing. - old AckPolicy was broken - not possible to access the instance associated with an active subscription - old AckPolicy did not provide a way to do manual acquire, only accept. - setting values on SubscriptionManager to apply to subsequent subscriptions is awkward & error-prone, now can use SubscriptionSettings to control on each subscribe individually. - a subscription is a central concept in AMQP, it deserves to be a class. Subscription and SubscriptionSettings provides a single point for future expansion of interactions with a a Subscription. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707808 13f79535-47bb-0310-9956-ffa450edef68
* Fix script to clean up data_dir.Alan Conway2008-10-251-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707806 13f79535-47bb-0310-9956-ffa450edef68