summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Increased release number.Alan Conway2007-12-061-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601819 13f79535-47bb-0310-9956-ffa450edef68
* File omitted from previous checkin.Alan Conway2007-12-061-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601811 13f79535-47bb-0310-9956-ffa450edef68
* From Ted Ross <tross@redhat.com>Alan Conway2007-12-0626-140/+535
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Queue statistics fixed. Additional objects added (exchange, binding). Changes: M cpp/src/qpid/broker/ExchangeRegistry.h M cpp/src/qpid/broker/ExchangeRegistry.cpp ExchangeRegistry was modified to pass a parent pointer to created exchanges. This parent reference is not stored but is used to link management objects in a hierarchy of ownership. M cpp/src/qpid/broker/Exchange.h M cpp/src/qpid/broker/Exchange.cpp Exchange now inherits Manageable to make it visible via the management interface. The Exchange parent class handles most of the management boilerplate. A Binding struct was introduced to track bindings for management. This is separate from QueueBindings which track bindings for queues. M cpp/src/qpid/broker/HeadersExchange.h M cpp/src/qpid/broker/FanOutExchange.h M cpp/src/qpid/broker/DirectExchange.h M cpp/src/qpid/broker/TopicExchange.h M cpp/src/qpid/broker/HeadersExchange.cpp M cpp/src/qpid/broker/FanOutExchange.cpp M cpp/src/qpid/broker/DirectExchange.cpp M cpp/src/qpid/broker/TopicExchange.cpp M cpp/src/qpid/management/ManagementExchange.cpp M cpp/src/qpid/management/ManagementExchange.h Each exchange type handles management stats in its own specific way. Additionally, the constructors pass the management parent pointer to the constructor or Exchange. An extra layer was added to contain bindings. Instead of directly storing bound queues, the exchanges store "bindings" which are managable constructs. M cpp/src/qpid/broker/Broker.cpp Broker now explicitly enables the management agent. Also sets the management parent (vhost) in the exchange registry. M cpp/src/qpid/broker/Vhost.cpp Updated constructor to be more defensive in case the management agent has not been enabled. M cpp/src/qpid/broker/Queue.cpp Same constructor update as vhost. Moved accounting of dequeues into "pop". Implemented management method handler (purge). M cpp/src/qpid/broker/Deliverable.h A new method was added to extract the content size of the deliverable content (if appropriate). The method is not pure virtual and returns zero if not overridden. M cpp/src/qpid/broker/DeliverableMessage.h M cpp/src/qpid/broker/TxPublish.cpp M cpp/src/qpid/broker/DeliverableMessage.cpp M cpp/src/qpid/broker/TxPublish.h These derivatives of Deliverable were updated with overrides for contenSize. M cpp/src/qpid/management/ManagementAgent.h M cpp/src/qpid/management/ManagementAgent.cpp An "enable" method was added to prevent inadvertent creation of a management agent when not desired. Adding and deleting management objects is now protected by a mutex. Make sure that deleted objects get reported even if neither their configuration nor instrumentation is changed. M specs/management-schema.xml Minor cosmetic updates. Additional parent linkage. M cpp/managementgen/schema.py M cpp/managementgen/templates/Class.cpp Added generated code to publish schema details for methods. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601807 13f79535-47bb-0310-9956-ffa450edef68
* Removed redundant TimerA, use intrusive_ptr for Timer.Alan Conway2007-12-067-166/+41
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601803 13f79535-47bb-0310-9956-ffa450edef68
* Changed output path to .Arnaud Simon2007-12-061-8/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601802 13f79535-47bb-0310-9956-ffa450edef68
* run script for compiling and running the samplesArnaud Simon2007-12-061-0/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601800 13f79535-47bb-0310-9956-ffa450edef68
* Remove reference to deleted fileGordon Sim2007-12-061-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601723 13f79535-47bb-0310-9956-ffa450edef68
* Fixed minor problems with example Makefiles.Alan Conway2007-12-055-120/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601538 13f79535-47bb-0310-9956-ffa450edef68
* Removed deleted programGordon Sim2007-12-051-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601468 13f79535-47bb-0310-9956-ffa450edef68
* Reversed renamingGordon Sim2007-12-058-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601467 13f79535-47bb-0310-9956-ffa450edef68
* Extra exception info.Alan Conway2007-12-051-3/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601457 13f79535-47bb-0310-9956-ffa450edef68
* Removed line for deleted file.Gordon Sim2007-12-051-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601407 13f79535-47bb-0310-9956-ffa450edef68
* Renamed for consistency with c++Gordon Sim2007-12-058-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601394 13f79535-47bb-0310-9956-ffa450edef68
* Remove unnecessary file.Gordon Sim2007-12-052-131/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601392 13f79535-47bb-0310-9956-ffa450edef68
* Avoid holding lock while making the flush calls (can cause deadlocking)Gordon Sim2007-12-051-5/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601391 13f79535-47bb-0310-9956-ffa450edef68
* moved base example into the common packageArnaud Simon2007-12-0510-10/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601388 13f79535-47bb-0310-9956-ffa450edef68
* Fixed problems with setting pub/sub hosts.Alan Conway2007-12-051-19/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601381 13f79535-47bb-0310-9956-ffa450edef68
* Updates to examples from jonathan.robie@redhat.comGordon Sim2007-12-058-29/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601358 13f79535-47bb-0310-9956-ffa450edef68
* Fixed errors in usage text.Alan Conway2007-12-051-6/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601352 13f79535-47bb-0310-9956-ffa450edef68
* bumped the rpm release numberRafael H. Schloming2007-12-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601143 13f79535-47bb-0310-9956-ffa450edef68
* examples/Makefile.am:Alan Conway2007-12-044-11/+13
| | | | | | | | | | - installcheck target builds installed examples. - Automatically run by rpmbuild and distcheck targets. rubygen/generate: fixed packaging error in rubygen.mk src/Makefile.am: fixed packaging error. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601125 13f79535-47bb-0310-9956-ffa450edef68
* removed warnings on duplicate constants, the issue will go away with 0-10 finalRafael H. Schloming2007-12-041-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601112 13f79535-47bb-0310-9956-ffa450edef68
* Added options to broker for journal file size. Also brought back exception ↵Kim van der Riet2007-12-047-30/+44
| | | | | | copying in MessageStoreModue to prevent exceptions thrown in the store lib causing cores when handled in qpidd.cpp. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601099 13f79535-47bb-0310-9956-ffa450edef68
* Patch from Ted Ross <tross@redhat.com>Alan Conway2007-12-041-1/+2
| | | | | | | | | | I've been doing some work in TopicExchange and noticed an opportunity for optimization of the route method. The current code does a heap allocation per binding, per message. The optimization removes the per-binding allocation. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@601051 13f79535-47bb-0310-9956-ffa450edef68
* Log exception when prepare fails.Gordon Sim2007-12-041-0/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600985 13f79535-47bb-0310-9956-ffa450edef68
* Remove start(); not yet safe to send commands while dispatcher is running ↵Gordon Sim2007-12-042-8/+0
| | | | | | concurrently. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600984 13f79535-47bb-0310-9956-ffa450edef68
* Updates to topic testGordon Sim2007-12-042-43/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600962 13f79535-47bb-0310-9956-ffa450edef68
* changed MINA threading modelArnaud Simon2007-12-041-7/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600861 13f79535-47bb-0310-9956-ffa450edef68
* removed useless lockArnaud Simon2007-12-041-14/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600860 13f79535-47bb-0310-9956-ffa450edef68
* Add option for durability to topic testGordon Sim2007-12-032-11/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600655 13f79535-47bb-0310-9956-ffa450edef68
* incremented release numberGordon Sim2007-12-031-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600640 13f79535-47bb-0310-9956-ffa450edef68
* fixed the error in receivingRajith Muditha Attapattu2007-12-031-3/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600599 13f79535-47bb-0310-9956-ffa450edef68
* Updated ofr converting request text in upercase textArnaud Simon2007-12-033-67/+47
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600561 13f79535-47bb-0310-9956-ffa450edef68
* merged the three writes in a single oneArnaud Simon2007-12-031-10/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600501 13f79535-47bb-0310-9956-ffa450edef68
* Added Session.h to list of distributed headers.Gordon Sim2007-12-031-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600442 13f79535-47bb-0310-9956-ffa450edef68
* Fix problem where client does notice disconnection from Broker. Alan Conway2007-12-016-65/+115
| | | | | | | | | src/qpid/client/SessionCore.cpp: close/open Demux on suspend/resume. src/tests/exception_test.cpp: convert to Session API, boost test. - Temporarily disabled due issues noted in TODO comments git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600046 13f79535-47bb-0310-9956-ffa450edef68
* Default --worker-threads is max(2, cores), performs better on 1 core boxes.Alan Conway2007-11-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599887 13f79535-47bb-0310-9956-ffa450edef68
* Python examplesAlan Conway2007-11-3010-0/+782
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599876 13f79535-47bb-0310-9956-ffa450edef68
* added latency testsArnaud Simon2007-11-301-8/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599868 13f79535-47bb-0310-9956-ffa450edef68
* Added a very basic plain nio transport. You could flip between the ↵Rajith Muditha Attapattu2007-11-306-5/+246
| | | | | | | | | transports using -Dtransport="nio". By default it's the MINA transport. You can also turn on batching for the nio transport by using -Dbatch="true". This option has no effect on MINA. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599856 13f79535-47bb-0310-9956-ffa450edef68
* Altered topic test to use the new session api.Gordon Sim2007-11-305-70/+95
| | | | | | | | Exposed start() through the subscription manager in addition to run(). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599832 13f79535-47bb-0310-9956-ffa450edef68
* added latency testsArnaud Simon2007-11-302-0/+231
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599810 13f79535-47bb-0310-9956-ffa450edef68
* added interval rateArnaud Simon2007-11-303-32/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599725 13f79535-47bb-0310-9956-ffa450edef68
* Printing summary before closing session, as this sometimes results in an errorRajith Muditha Attapattu2007-11-291-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599637 13f79535-47bb-0310-9956-ffa450edef68
* Modified the scriptsRajith Muditha Attapattu2007-11-293-3/+5
| | | | | | | And made the default log frequency to every 1000 msgs git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599624 13f79535-47bb-0310-9956-ffa450edef68
* Removed all the fancy threading with the test cases as these interfer with ↵Rajith Muditha Attapattu2007-11-297-559/+154
| | | | | | the test cases git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599611 13f79535-47bb-0310-9956-ffa450edef68
* Rolled back changes from rev 598440, the _real_ cause of the St9exception ↵Kim van der Riet2007-11-291-25/+22
| | | | | | error has been solved (elsewhere) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599592 13f79535-47bb-0310-9956-ffa450edef68
* Cleaned up the calculations and added an option to disable interval stat ↵Rajith Muditha Attapattu2007-11-292-102/+164
| | | | | | collection git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599528 13f79535-47bb-0310-9956-ffa450edef68
* Temp hack to fix as yet unclear issue with concurrent flush() and ↵Gordon Sim2007-11-291-1/+1
| | | | | | enqueueComplete() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599495 13f79535-47bb-0310-9956-ffa450edef68
* added flushArnaud Simon2007-11-291-0/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599452 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status