summaryrefslogtreecommitdiff
path: root/cpp/src/qpid
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-664: change format of connection options string to match address ↵Gordon Sim2010-01-287-213/+355
| | | | | | options; make open() a non-static method. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904000 13f79535-47bb-0310-9956-ffa450edef68
* QPID_2634 Management updates in timer create inconsistencies in a cluster.Alan Conway2010-01-277-17/+142
| | | | | | | | | Cluster plugin provides a PeriodicTimer implementation to the broker which executes tasks in the cluster dispatch thread simultaneously across the cluster. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903869 13f79535-47bb-0310-9956-ffa450edef68
* Cluster implementation of PeriodicTimer.Alan Conway2010-01-274-6/+171
| | | | | | | | | The cluster implementation multicast periodic-timer controls and executes the task when those controls are delivered, which is in the cluster delivery thread context and so consistent across the cluster. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903867 13f79535-47bb-0310-9956-ffa450edef68
* Added PeriodicTimer interface for periodic tasks that need cluster ↵Alan Conway2010-01-278-24/+169
| | | | | | | | | | | synchronization. The ManagementAgent's periodic prociessing uses PeriodicTimer. PeriodicTimerImpl is the default implementation for stand-alone brokers, simple wrapper for sys::Timer. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903866 13f79535-47bb-0310-9956-ffa450edef68
* In clustered broker: move construction of broker::Connections to the cluster ↵Alan Conway2010-01-273-57/+101
| | | | | | | | | | dispatch thread. Constructing a connection can involve sending management information so needs to be in the cluster dispatch context. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903864 13f79535-47bb-0310-9956-ffa450edef68
* Fix cluster elder calculation to ensure unique elder.Alan Conway2010-01-277-13/+46
| | | | | | | | Race condition in the previous algorithm allowed several cluster members to consider themselves the elder. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903826 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: change cancel() to close() for consistencyGordon Sim2010-01-279-23/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903599 13f79535-47bb-0310-9956-ffa450edef68
* Make TCP more like RDMAAndrew Stitcher2010-01-261-3/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903503 13f79535-47bb-0310-9956-ffa450edef68
* Fix memory error in previous SocketAddress refactoringAndrew Stitcher2010-01-267-37/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903407 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2288: add support for bindings in address optionsGordon Sim2010-01-261-13/+55
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903171 13f79535-47bb-0310-9956-ffa450edef68
* Add SSL support for Windows client and broker per QPID-1403. Adds new ↵Stephen D. Huston2010-01-239-20/+1359
| | | | | | | | | | | | | AsynchIO::BufferBase::squish() method that does what used to be done by in-place memmove() calls so it can be reused easily. SSL support for Windows is in: - Client: qpid/client/windows/SslConnector.cpp qpid/client/TCPConnector.{h cpp} rearranged a bit to make pieces available to SslConnector - Broker: qpid/broker/windows/SslProtocolFactory.cpp - Common: qpid/sys/windows/SslAsynchIO contains all the Schannel stuff to negotiate a session, encrypt, and decrypt data. The SslAsynchIO acts as a shim between the layer above and the "regular" AsynchIO that actually handles read/write and completions. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@902318 13f79535-47bb-0310-9956-ffa450edef68
* If we've already closed Connection don't attempt to write to itAndrew Stitcher2010-01-221-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@902278 13f79535-47bb-0310-9956-ffa450edef68
* #include SecurityLayer.h needs to go back in; MSVC needs to see the class ↵Stephen D. Huston2010-01-221-0/+1
| | | | | | def for auto_ptr use in activateSecurityLayer. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@902176 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2347: Signal deletion of queue to active subscribers via a ↵Gordon Sim2010-01-2211-2/+117
| | | | | | resource-deleted exception. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@902055 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to make Win32 port build again (and remove some warnings)Andrew Stitcher2010-01-212-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901816 13f79535-47bb-0310-9956-ffa450edef68
* Small comment fixAndrew Stitcher2010-01-211-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901556 13f79535-47bb-0310-9956-ffa450edef68
* Throw sync connect failures straight out of AsynchConnector constructorAndrew Stitcher2010-01-211-19/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901555 13f79535-47bb-0310-9956-ffa450edef68
* Allow Connection to be closed whilst still connecting without error.Andrew Stitcher2010-01-211-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901554 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that shutting down an unsuccessful connect can't race with connection ↵Andrew Stitcher2010-01-211-3/+9
| | | | | | deletion git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901553 13f79535-47bb-0310-9956-ffa450edef68
* Remove possible double closing of connection on connect failureAndrew Stitcher2010-01-211-7/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901552 13f79535-47bb-0310-9956-ffa450edef68
* Fix a potential RDMA connect failure raceAndrew Stitcher2010-01-211-3/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901551 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1879 Don't use a thread for every new client ConnectionAndrew Stitcher2010-01-217-220/+196
| | | | | | | | | | | - By default the max number of threads now used for network io is the number of cpus available. - This can be overridden with the QPID_MAX_IOTHREADS environment variable or the config file - The client threads are initialised (via a singleton) when first used in a Connection::open() git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901550 13f79535-47bb-0310-9956-ffa450edef68
* Small refactor of AsynchConnector to have a more regular structureAndrew Stitcher2010-01-211-9/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901548 13f79535-47bb-0310-9956-ffa450edef68
* Split out AsynchConnecter::start from constructor (like other AsynchIO classes)Andrew Stitcher2010-01-215-24/+36
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901547 13f79535-47bb-0310-9956-ffa450edef68
* Made the getSSF() member functions of Connectors private as they can't be ↵Andrew Stitcher2010-01-213-3/+3
| | | | | | | | used from outside the connector anyway except via the virtual in the parent class. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901546 13f79535-47bb-0310-9956-ffa450edef68
* Log detailed error if unexpected socket write error (don't throw anymore)Andrew Stitcher2010-01-211-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901545 13f79535-47bb-0310-9956-ffa450edef68
* Cluster-safe assertions.Alan Conway2010-01-206-4/+145
| | | | | | | | | Assert that replicated data structures are modified in a cluster-safe context - in cluster delivery thread or during update. Assertions added to Queue.cpp and SemanticState.cpp. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901282 13f79535-47bb-0310-9956-ffa450edef68
* Provide access to a sessions connection.Gordon Sim2010-01-202-0/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901247 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: added support for testing transactions to qpid-send and qpid-recv, ↵Gordon Sim2010-01-201-1/+1
| | | | | | fixed bug in rollback. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901153 13f79535-47bb-0310-9956-ffa450edef68
* Removed dead code - cluster::Connection::left()Alan Conway2010-01-192-9/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900860 13f79535-47bb-0310-9956-ffa450edef68
* Correct new uuid methods for Windows, add QPID_CLIENT_EXTERN where needed.Stephen D. Huston2010-01-182-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900592 13f79535-47bb-0310-9956-ffa450edef68
* Deleting vestigial header file.Jonathan Robie2010-01-181-37/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900506 13f79535-47bb-0310-9956-ffa450edef68
* Applied John Dunning's patch from ↵Jonathan Robie2010-01-182-4/+8
| | | | | | | | | | https://issues.apache.org/jira/browse/QPID-2335. Allows management tools to report the query for a binding. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900475 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2295: Clustered + persistent broker crashes with inconsistency error.Alan Conway2010-01-184-30/+1
| | | | | | | | | | Code running in the store's timer thread was causing inconsistent changes in message allocation. This code is out-of-date, we no longer need to notify the Queue when persistent storage completes as the message is already available on the queue. Removed the out-dated code. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900448 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2323: add a Uuid type and allow it as the value of a Variant.Gordon Sim2010-01-156-15/+198
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@899657 13f79535-47bb-0310-9956-ffa450edef68
* Removed dead code: OutputTask::hasOutput and Queue::checkForMessages.Alan Conway2010-01-1411-56/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@899356 13f79535-47bb-0310-9956-ffa450edef68
* Explicitly name qpid::framing::Buffer instead of framing::Buffer; resolves ↵Stephen D. Huston2010-01-121-5/+5
| | | | | | compile errors on Windows. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@898519 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: Added some of the missing standard message headers. Added two new ↵Gordon Sim2010-01-125-8/+57
| | | | | | test utilities for sending and receiving with the new API (both still works in progress). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@898296 13f79535-47bb-0310-9956-ffa450edef68
* This further improves the fix made at rev 19819 in Qpid trunk for QPID-2175Rajith Muditha Attapattu2010-01-112-4/+6
| | | | | | | The check is now done without creating any new strings to avoid extra allocations. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@898021 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2297Rajith Muditha Attapattu2010-01-111-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@898016 13f79535-47bb-0310-9956-ffa450edef68
* Fix broker crash "confirmed N but only sent M" with managed agents running.Alan Conway2010-01-116-21/+121
| | | | | | | | | | | | | | The broker's ManagementAgent caches schemas from managed agents. This cache was not being replicated to new cluster members. If an agent such as sesame was running and connected to a newly-joined broker, that broker could send schema request messages which were not sent by other brokers that had the schema in cache. This resulted in the other brokers exiting with a "confirmed N but only sent M" message. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@897955 13f79535-47bb-0310-9956-ffa450edef68
* Add cluster watchdog plugin to cmake build.Alan Conway2010-01-071-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896959 13f79535-47bb-0310-9956-ffa450edef68
* fix & test QPID-2320Carl C. Trieloff2010-01-061-6/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896687 13f79535-47bb-0310-9956-ffa450edef68
* Make cluster::StoreStatus::load/save no-ops if broker has no data-dir.Alan Conway2010-01-061-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896662 13f79535-47bb-0310-9956-ffa450edef68
* Fix uninitialized read error in cluster::StoreStatus.Alan Conway2010-01-061-7/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896617 13f79535-47bb-0310-9956-ffa450edef68
* Revert "Make cluster update work out of the box without special ↵Alan Conway2010-01-062-4/+4
| | | | | | | | | authentication options." This reverts revision 885870 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896541 13f79535-47bb-0310-9956-ffa450edef68
* Added config-seq counter to track config changes since cluster init.Alan Conway2010-01-069-54/+108
| | | | | | | | Config-seq is recorded persitently to help identify best store when recovering from total failure. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896538 13f79535-47bb-0310-9956-ffa450edef68
* Exception handling for URL parsing in cluster.Alan Conway2010-01-062-8/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896537 13f79535-47bb-0310-9956-ffa450edef68
* Don't hold up broker initialization for cluster initialization.Alan Conway2010-01-063-42/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896536 13f79535-47bb-0310-9956-ffa450edef68
* BodyHolder.cpp, .h removed. 0 bytes and no references to either one. ↵Stephen D. Huston2010-01-052-0/+0
| | | | | | Resolves QPID-2213. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896256 13f79535-47bb-0310-9956-ffa450edef68