summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Fix cluster TTL: replicte expiry information to newcomers.Alan Conway2009-03-0914-70/+98
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751760 13f79535-47bb-0310-9956-ffa450edef68
* Close a potential race between closing a connection and sending dataAndrew Stitcher2009-03-091-18/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751751 13f79535-47bb-0310-9956-ffa450edef68
* QPID-949 : Removed the deleteOnExit calls on all flowed entries, as this ↵Martin Ritchie2009-03-095-14/+24
| | | | | | will increase our memory usage. Instead add a close method on the BackingStore that is called when the queue closes and clean up the backing then. Also moved the QueueHousekeeping thread stop to before we do any queue closing in the VHost. This will ensure that we are not causing any operations that might inadvertadly load a message, and so prevent the backing file from being deleted. This should of course now not occur as all getMessage() calls have been removed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751722 13f79535-47bb-0310-9956-ffa450edef68
* Removed false positive return from FU.delete(). Delete mirrors functionality ↵Martin Ritchie2009-03-092-8/+16
| | | | | | provided by java.io. Attempting to delete an non-existent file returns false. The caller must handle this correctly. If client provides a null value then the call will throw a NPE which is a valid java response. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751720 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1721: Fixes for replication between clusters when new members are addedGordon Sim2009-03-0919-24/+204
| | | | | | | | | | * suppress event generation during node catch up * ensure sequence counters used for duplicate detection are synchronised in both primary and dr clusters when new members join * connect queue with the event manager within queue registry rather than adapter as the latter path is not used for catchup git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751719 13f79535-47bb-0310-9956-ffa450edef68
* QPID-949 : Removed all getMessage() calls as this will cause a flowed ↵Martin Ritchie2009-03-0915-64/+77
| | | | | | message to be read in to memory from disk. In all instances the reason was to perform methods that exist on the the QueueEntry. Added accessor to MessageID on QueueEntry. Outstanding getMessage() calls have been left in to perform NO_LOCAL work. Moving Publisher and PublisherClient identifer to the QEI would remove this need. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751718 13f79535-47bb-0310-9956-ffa450edef68
* Added test to ensure ThreadPool is references are correctly removed for ↵Martin Ritchie2009-03-092-10/+45
| | | | | | Priority queues. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751714 13f79535-47bb-0310-9956-ffa450edef68
* Ack outstanding messages before closingGordon Sim2009-03-091-0/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751713 13f79535-47bb-0310-9956-ffa450edef68
* FileUtils would report a failure to delete a non-existent fileMartin Ritchie2009-03-092-2/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751636 13f79535-47bb-0310-9956-ffa450edef68
* Fixed race conditions in cluster.Alan Conway2009-03-0818-353/+362
| | | | | | | | Execute all cluster logic in frameDeliverQueue thread, decoding only in eventDeliverQueue thread. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751557 13f79535-47bb-0310-9956-ffa450edef68
* Correct needed include file for strlen()Stephen D. Huston2009-03-061-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751131 13f79535-47bb-0310-9956-ffa450edef68
* fixed uuid decoding errors due to read_uuid semantics changeRafael H. Schloming2009-03-062-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751064 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1720Rajith Muditha Attapattu2009-03-062-7/+29
| | | | | | | The fix is a bit of a hack, but I don't see another way to handle it. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751061 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1719: extra test for federated cluster (includes node failure which ↵Gordon Sim2009-03-062-2/+27
| | | | | | requires a wait so only run on make check-long) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750989 13f79535-47bb-0310-9956-ffa450edef68
* added support for encoding buffersRafael H. Schloming2009-03-063-0/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750960 13f79535-47bb-0310-9956-ffa450edef68
* FileUtils : Was not correctly handling the case where a File object became ↵Martin Ritchie2009-03-061-7/+8
| | | | | | null, it would previously have thrown a NPE which was erroneously caught this and declared the delete to have failed. If there is nothing to delete (signified by the Null File object) then the delete should pass. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750946 13f79535-47bb-0310-9956-ffa450edef68
* codec and unicode tests and fixesRafael H. Schloming2009-03-064-22/+56
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750934 13f79535-47bb-0310-9956-ffa450edef68
* Moved a variable inside an assertion to avoid unused variable error when the ↵Jonathan Robie2009-03-061-2/+1
| | | | | | assertion is undefined. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750930 13f79535-47bb-0310-9956-ffa450edef68
* AclPlugin: Use --acl-file unmodified if --no-data-dir.Alan Conway2009-03-062-10/+5
| | | | | | | SessionId: print as userid.sessionid rather than sessionid@userid. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750913 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1719: Ensure management object id remain in sync across cluster.Gordon Sim2009-03-063-7/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750910 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1634 : FileQueueBackingStore had two issues. Delete wasn't using the ↵Martin Ritchie2009-03-061-7/+9
| | | | | | getFileHandle() method so it was attempting to delete a bin rather than the message data. Our Broker Unit tests don't create the right type of ByteBuffer so whilst they passed the buffer.getData().array() failed as array() is not supported in the ByteBuffer types we actually use at runtime. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750876 13f79535-47bb-0310-9956-ffa450edef68
* QPID-949, QPID-1633 : Set default Maximum Memory Usage for a queue to ↵Martin Ritchie2009-03-064-14/+100
| | | | | | | | 100Meg. Future work would be to have the broker split Xmx between VirtualHost and for the Vhost then to use its housekeeping thread to spread the memory between the current queues. It could of course be clever and give more memory to queues in high use. Mistype in AMQQueueFactory resulted in it setting the Max Queue Size alert rather than the Max Memory value git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750875 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1635 : Feed back from review, ensure that getMessage() never returns ↵Martin Ritchie2009-03-062-15/+10
| | | | | | null. Used setDeliveredToConsumers() on QEI to know when it is safe to unload message so SAMQQueue does not need to have anything to do with message un/loading. So the FtD work is fully encapuslated by the QEI which delegates memory accounting to its list. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750874 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1628 : Ensured all getSize() calls are done on the QueueEntry to ↵Martin Ritchie2009-03-069-25/+26
| | | | | | prevent the inadvertent loading of a flowed message with a call to getMessage() git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750873 13f79535-47bb-0310-9956-ffa450edef68
* Style ChangesMartin Ritchie2009-03-062-69/+61
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750871 13f79535-47bb-0310-9956-ffa450edef68
* QPID-949 : Extend the basic QueueBrowser_Test to run on a queue that has ↵Martin Ritchie2009-03-061-0/+69
| | | | | | been flowed to disk git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750869 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1451 : Added the ability to log first message recevied in Queue Browser.Martin Ritchie2009-03-062-38/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750868 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1639 : Added test to ensure that properties passed on QueueDeclare are ↵Martin Ritchie2009-03-063-5/+243
| | | | | | applied to queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750867 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1718: Ensure that cancellation caused by e.g. ↵Gordon Sim2009-03-052-2/+19
| | | | | | SubscriptionManager::get() doesn't close dispatch queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750622 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1717: Check that target queue for replication events exists before ↵Gordon Sim2009-03-052-13/+26
| | | | | | attempting to process it. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750586 13f79535-47bb-0310-9956-ffa450edef68
* Cluster: restore separate event/frame threads.Alan Conway2009-03-054-89/+70
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750574 13f79535-47bb-0310-9956-ffa450edef68
* qpid/broker/QueuePolicy.cppManuel Teira Paz2009-03-052-3/+3
| | | | | | | | | - Add a missing std namespace qpid/broker/TxAccept.cpp - Add a missing std namespace git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750497 13f79535-47bb-0310-9956-ffa450edef68
* qpid/log/posix/SinkOptions.cppManuel Teira Paz2009-03-051-1/+5
| | | | | | | | | - Conditionally use LOG_FTP and LOG_AUTHPRIV - Add a missing std namespace git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750496 13f79535-47bb-0310-9956-ffa450edef68
* configure.ac:Manuel Teira Paz2009-03-051-1/+26
| | | | | | | | | | | | - Check for existence of LOG_FTP and LOG_AUTHPRIV to create proper defines - Define SUNOS properly - Reverse SUNCC detection to make it work properly - Check if libacl is actually needed (in Solaris this functionality is part of libc) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750494 13f79535-47bb-0310-9956-ffa450edef68
* qpid::log::Selector: Include strings.h for ::strlen Manuel Teira Paz2009-03-051-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750491 13f79535-47bb-0310-9956-ffa450edef68
* Replace PF_LOCAL with PF_UNIX, since it seems to be equivalent, and the Manuel Teira Paz2009-03-051-1/+1
| | | | | | | former doesn't exist on Solaris (for instance) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750489 13f79535-47bb-0310-9956-ffa450edef68
* In qpid::client::SessionImplManuel Teira Paz2009-03-051-1/+2
| | | | | | | | | | Force the construction of a sys::ExceptionHolder to avoid the Sun Compiler to throw an ambiguity error, since it things that sys::ExceptionHolder and ClosedException are convertible one to the other. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750488 13f79535-47bb-0310-9956-ffa450edef68
* Add a pair of missing std:: namespacesManuel Teira Paz2009-03-052-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750487 13f79535-47bb-0310-9956-ffa450edef68
* Implement a solaris qpid::sys::SystemInfoManuel Teira Paz2009-03-052-2/+111
| | | | | | | Choose implementation based on SUNOS definition git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750486 13f79535-47bb-0310-9956-ffa450edef68
* Remove the argument type in the boost::function template sinceManuel Teira Paz2009-03-051-1/+1
| | | | | | | it's no needed and hurts the Sun compiler git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750485 13f79535-47bb-0310-9956-ffa450edef68
* Define the QPID_TSS macro for the Sun Studio CompilersManuel Teira Paz2009-03-051-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750483 13f79535-47bb-0310-9956-ffa450edef68
* Prepend std namespace to atoi since we are including cstdlibManuel Teira Paz2009-03-051-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750482 13f79535-47bb-0310-9956-ffa450edef68
* cluster: fix delivery-property.exchange-name set on updated messages.Alan Conway2009-03-0522-89/+144
| | | | | | | | | Logging improvements, useful for debugging: - qpid/SessionState.cpp: show frame bodies with command IDs. - assign cluster-wide id number to each Event. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750456 13f79535-47bb-0310-9956-ffa450edef68
* Remove socklen_t for Windows; related to QPID-1710Stephen D. Huston2009-03-052-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750253 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1713Rajith Muditha Attapattu2009-03-041-14/+144
| | | | | | | | The automated test case for this is still being worked out. However this feature has been tested manually. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750205 13f79535-47bb-0310-9956-ffa450edef68
* Corrected a spelling mistakeRajith Muditha Attapattu2009-03-041-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750204 13f79535-47bb-0310-9956-ffa450edef68
* This is related QPID-1640Rajith Muditha Attapattu2009-03-042-29/+80
| | | | | | | This includes a the failover test run in a loop. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750203 13f79535-47bb-0310-9956-ffa450edef68
* Issue a useful message if not generating code from specs; fixes QPID-1709Stephen D. Huston2009-03-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750155 13f79535-47bb-0310-9956-ffa450edef68
* Issue a useful message if not generating code from specs' fixes QPID-1709Stephen D. Huston2009-03-041-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750154 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1712: changed default value for _cycleRetries to 1Arnaud Simon2009-03-041-4/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750025 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status