svn commit: r727455 - in /qpid/trunk/qpid/cpp/src/qpid/amqp_0_10: Connection.cpp Connection.h

2008-12-17 Thread aconway
Author: aconway Date: Wed Dec 17 10:05:30 2008 New Revision: 727455 URL: http://svn.apache.org/viewvc?rev=727455view=rev Log: src/qpid/amqp_0_10/Connection.cpp: allow encoding to be concurrent with adding new frames. Modified: qpid/trunk/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp qpid

svn commit: r727583 - in /qpid/trunk/qpid/cpp: INSTALL configure.ac src/qpid/cluster/Cpg.cpp src/qpid/cluster/Cpg.h src/qpid/cluster/types.h src/tests/ais_check

2008-12-17 Thread aconway
Author: aconway Date: Wed Dec 17 15:44:04 2008 New Revision: 727583 URL: http://svn.apache.org/viewvc?rev=727583view=rev Log: Handle package name changes in Fedora10: openais-corosync cman-cmanlib Modified: qpid/trunk/qpid/cpp/INSTALL qpid/trunk/qpid/cpp/configure.ac qpid/trunk/qpid

svn commit: r728072 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp Cluster.h ClusterPlugin.cpp OutputInterceptor.cpp OutputInterceptor.h WriteEstimate.cpp WriteEstimate.h

2008-12-19 Thread aconway
Author: aconway Date: Fri Dec 19 09:22:52 2008 New Revision: 728072 URL: http://svn.apache.org/viewvc?rev=728072view=rev Log: cluster: Increase initial estimate controlling writes. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.h

svn commit: r731739 - in /qpid/trunk/qpid/cpp/src: qpid/broker/Daemon.cpp tests/BrokerFixture.h

2009-01-05 Thread aconway
Author: aconway Date: Mon Jan 5 14:01:15 2009 New Revision: 731739 URL: http://svn.apache.org/viewvc?rev=731739view=rev Log: Minor logging fixes. cpp/src/tests/BrokerFixture.h: make tests quiet, log with error+ qpid/broker/Daemon.cpp: print to stderr in parent process if child fails. Modified

svn commit: r732354 - /qpid/trunk/qpid/cpp/src/qpid/cluster/types.h

2009-01-07 Thread aconway
Author: aconway Date: Wed Jan 7 07:00:55 2009 New Revision: 732354 URL: http://svn.apache.org/viewvc?rev=732354view=rev Log: Consistent #if defined for header selectino. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/types.h Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/types.h URL: http

svn commit: r733051 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp ClusterPlugin.cpp Connection.h FailoverExchange.cpp Multicaster.cpp Multicaster.h Quorum_cman.cpp

2009-01-09 Thread aconway
Author: aconway Date: Fri Jan 9 06:47:21 2009 New Revision: 733051 URL: http://svn.apache.org/viewvc?rev=733051view=rev Log: Fix --cluster-mast-max: errors in last commit. Work around problems with CPG flow control. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk

svn commit: r734452 - /qpid/trunk/qpid/cpp/src/tests/latencytest.cpp

2009-01-14 Thread aconway
Author: aconway Date: Wed Jan 14 09:32:43 2009 New Revision: 734452 URL: http://svn.apache.org/viewvc?rev=734452view=rev Log: Fix logic to generate messages at a specified rate. Previous logic was sending messages well below the specified rate. Modified: qpid/trunk/qpid/cpp/src/tests

svn commit: r735059 - in /qpid/trunk/qpid/cpp/src: qpid/cluster/Cluster.cpp qpid/cluster/Event.cpp qpid/cluster/Event.h tests/cluster_test.cpp

2009-01-16 Thread aconway
Author: aconway Date: Fri Jan 16 09:25:18 2009 New Revision: 735059 URL: http://svn.apache.org/viewvc?rev=735059view=rev Log: Separate cluster::EventHeader to allow non-copy events. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Event.cpp

svn commit: r735150 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: PollerDispatch.cpp PollerDispatch.h ThreadDispatch.cpp ThreadDispatch.h

2009-01-16 Thread aconway
Author: aconway Date: Fri Jan 16 13:34:01 2009 New Revision: 735150 URL: http://svn.apache.org/viewvc?rev=735150view=rev Log: cluster refactor: separate out dispatch strategy, implement poller and thread dispatch. Added: qpid/trunk/qpid/cpp/src/qpid/cluster/PollerDispatch.cpp (with props

svn commit: r735151 - in /qpid/trunk/qpid/cpp/src: cluster.mk qpid/cluster/Cluster.cpp qpid/cluster/Cluster.h qpid/cluster/Event.cpp qpid/cluster/Event.h

2009-01-16 Thread aconway
Author: aconway Date: Fri Jan 16 13:34:46 2009 New Revision: 735151 URL: http://svn.apache.org/viewvc?rev=735151view=rev Log: cluster refactor: separate out dispatch strategy, implement poller and thread dispatch. Modified: qpid/trunk/qpid/cpp/src/cluster.mk qpid/trunk/qpid/cpp/src/qpid

svn commit: r736135 - in /qpid/trunk/qpid/cpp/src: Makefile.am qpid/cluster/Cluster.cpp qpid/cluster/Event.cpp qpid/cluster/Event.h qpid/cluster/Multicaster.cpp qpid/cluster/Multicaster.h qpid/sys/Lat

2009-01-20 Thread aconway
Author: aconway Date: Tue Jan 20 14:11:37 2009 New Revision: 736135 URL: http://svn.apache.org/viewvc?rev=736135view=rev Log: Latency measurements, compiled out of production code. Added: qpid/trunk/qpid/cpp/src/qpid/sys/LatencyMetric.cpp (with props) qpid/trunk/qpid/cpp/src/qpid/sys

svn commit: r736326 - in /qpid/trunk/qpid/cpp/src: qpid/cluster/ qpid/framing/ qpid/sys/ tests/

2009-01-21 Thread aconway
Author: aconway Date: Wed Jan 21 07:44:42 2009 New Revision: 736326 URL: http://svn.apache.org/viewvc?rev=736326view=rev Log: Additional latency measurement points. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp qpid

svn commit: r736409 - in /qpid/trunk/qpid/cpp/src: cluster.mk qpid/cluster/Cluster.cpp qpid/cluster/Cluster.h qpid/cluster/Connection.cpp qpid/cluster/Connection.h qpid/cluster/Event.h qpid/cluster/Ev

2009-01-21 Thread aconway
Author: aconway Date: Wed Jan 21 12:40:38 2009 New Revision: 736409 URL: http://svn.apache.org/viewvc?rev=736409view=rev Log: cluster: Pipeline decoding. About 10% improvement in latency and throughput. Added: qpid/trunk/qpid/cpp/src/qpid/cluster/EventFrame.h (with props) Modified

svn commit: r736810 - in /qpid/trunk/qpid/cpp/src/qpid/framing: AMQFrame.cpp AMQFrame.h

2009-01-22 Thread aconway
Author: aconway Date: Thu Jan 22 13:48:47 2009 New Revision: 736810 URL: http://svn.apache.org/viewvc?rev=736810view=rev Log: Optimization: cache results of AMQFrame::encodedSize(). Modified: qpid/trunk/qpid/cpp/src/qpid/framing/AMQFrame.cpp qpid/trunk/qpid/cpp/src/qpid/framing

svn commit: r737067 - /qpid/trunk/qpid/cpp/src/qpid/framing/FrameDecoder.cpp

2009-01-23 Thread aconway
Author: aconway Date: Fri Jan 23 08:07:39 2009 New Revision: 737067 URL: http://svn.apache.org/viewvc?rev=737067view=rev Log: Replace assertion with exception. Modified: qpid/trunk/qpid/cpp/src/qpid/framing/FrameDecoder.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/framing/FrameDecoder.cpp URL

svn commit: r737968 - in /qpid/trunk/qpid/cpp/src: ./ qpid/cluster/ qpid/sys/

2009-01-26 Thread aconway
Author: aconway Date: Tue Jan 27 01:44:02 2009 New Revision: 737968 URL: http://svn.apache.org/viewvc?rev=737968view=rev Log: cluster: Add sequence number to events frames Added: qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterQueueHandler.h (with props) Removed: qpid/trunk/qpid/cpp/src

svn commit: r738107 - in /qpid/trunk/qpid/cpp/src: cluster.mk qpid/cluster/Cluster.cpp qpid/cluster/Connection.cpp qpid/cluster/Event.cpp qpid/cluster/EventFrame.cpp qpid/cluster/EventFrame.h

2009-01-27 Thread aconway
Author: aconway Date: Tue Jan 27 14:58:47 2009 New Revision: 738107 URL: http://svn.apache.org/viewvc?rev=738107view=rev Log: cluster/EventFrame.cpp: Add operator for EventFrame Added: qpid/trunk/qpid/cpp/src/qpid/cluster/EventFrame.cpp (with props) Modified: qpid/trunk/qpid/cpp/src

svn commit: r738200 - /qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterPlugin.cpp

2009-01-27 Thread aconway
Author: aconway Date: Tue Jan 27 19:36:35 2009 New Revision: 738200 URL: http://svn.apache.org/viewvc?rev=738200view=rev Log: Change --cluster-mcast-max default to 0. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterPlugin.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r738618 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp Cluster.h ClusterPlugin.cpp Multicaster.cpp Multicaster.h

2009-01-28 Thread aconway
Author: aconway Date: Wed Jan 28 20:48:23 2009 New Revision: 738618 URL: http://svn.apache.org/viewvc?rev=738618view=rev Log: (empty) Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.h qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r739031 - in /qpid/trunk/qpid/cpp/src/qpid: amqp_0_10/SessionHandler.cpp amqp_0_10/SessionHandler.h broker/SessionHandler.cpp cluster/Cluster.cpp cluster/Cluster.h cluster/UpdateClient.cpp

2009-01-29 Thread aconway
Author: aconway Date: Thu Jan 29 21:47:21 2009 New Revision: 739031 URL: http://svn.apache.org/viewvc?rev=739031view=rev Log: Better error messages for not-attached exceptions. Modified: qpid/trunk/qpid/cpp/src/qpid/amqp_0_10/SessionHandler.cpp qpid/trunk/qpid/cpp/src/qpid/amqp_0_10

svn commit: r739051 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp

2009-01-29 Thread aconway
Author: aconway Date: Thu Jan 29 22:24:22 2009 New Revision: 739051 URL: http://svn.apache.org/viewvc?rev=739051view=rev Log: Fix cluster race condition for new members joining. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r739295 - /qpid/trunk/qpid/cpp/src/tests/python_tests

2009-01-30 Thread aconway
Author: aconway Date: Fri Jan 30 14:34:48 2009 New Revision: 739295 URL: http://svn.apache.org/viewvc?rev=739295view=rev Log: Correct mistake from previous commit where missing python dir causes an error rather than a warning. Modified: qpid/trunk/qpid/cpp/src/tests/python_tests Modified

svn commit: r740872 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Connection.cpp OutputInterceptor.cpp OutputInterceptor.h

2009-02-04 Thread aconway
Author: aconway Date: Wed Feb 4 20:47:14 2009 New Revision: 740872 URL: http://svn.apache.org/viewvc?rev=740872view=rev Log: Fix assertion due to doOutput control being sent after local connection closed. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp qpid/trunk/qpid/cpp

svn commit: r740900 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp ConnectionMap.cpp ConnectionMap.h

2009-02-04 Thread aconway
Author: aconway Date: Wed Feb 4 21:31:23 2009 New Revision: 740900 URL: http://svn.apache.org/viewvc?rev=740900view=rev Log: Fix race condition with deleted local connections. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r741135 - /qpid/trunk/qpid/cpp/src/cluster.mk

2009-02-05 Thread aconway
Author: aconway Date: Thu Feb 5 15:27:34 2009 New Revision: 741135 URL: http://svn.apache.org/viewvc?rev=741135view=rev Log: Remove non-existent qpid/cluster/Updatee.h from cluster.mk. Modified: qpid/trunk/qpid/cpp/src/cluster.mk Modified: qpid/trunk/qpid/cpp/src/cluster.mk URL: http

svn commit: r741568 - in /qpid/trunk/qpid/cpp/src/tests: ClusterFixture.cpp ClusterFixture.h ForkedBroker.h cluster.mk cluster_test.cpp

2009-02-06 Thread aconway
Author: aconway Date: Fri Feb 6 14:09:10 2009 New Revision: 741568 URL: http://svn.apache.org/viewvc?rev=741568view=rev Log: QPID-1650 Mick Goulish: separte ClusterFixture from cluster_test.cpp for use by other tests. Added: qpid/trunk/qpid/cpp/src/tests/ClusterFixture.cpp (with props

svn commit: r741588 - /qpid/trunk/qpid/cpp/src/tests/run_acl_tests

2009-02-06 Thread aconway
Author: aconway Date: Fri Feb 6 15:12:07 2009 New Revision: 741588 URL: http://svn.apache.org/viewvc?rev=741588view=rev Log: Fix error in run_acl_tests. Modified: qpid/trunk/qpid/cpp/src/tests/run_acl_tests Modified: qpid/trunk/qpid/cpp/src/tests/run_acl_tests URL: http://svn.apache.org

svn commit: r741624 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp

2009-02-06 Thread aconway
Author: aconway Date: Fri Feb 6 16:39:17 2009 New Revision: 741624 URL: http://svn.apache.org/viewvc?rev=741624view=rev Log: Fix seg fault if cluster and management are enabled. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r742520 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp

2009-02-09 Thread aconway
Author: aconway Date: Mon Feb 9 14:27:22 2009 New Revision: 742520 URL: http://svn.apache.org/viewvc?rev=742520view=rev Log: Demote CPG flow control warning message to debug. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp URL

svn commit: r742563 - /qpid/trunk/qpid/cpp/examples/tradedemo/topic_publisher.cpp

2009-02-09 Thread aconway
Author: aconway Date: Mon Feb 9 15:27:19 2009 New Revision: 742563 URL: http://svn.apache.org/viewvc?rev=742563view=rev Log: Fix no virtual destructor warning. Modified: qpid/trunk/qpid/cpp/examples/tradedemo/topic_publisher.cpp Modified: qpid/trunk/qpid/cpp/examples/tradedemo

svn commit: r742602 - in /qpid/trunk/qpid/cpp/src/tests: ClusterFixture.cpp cluster_test.cpp

2009-02-09 Thread aconway
Author: aconway Date: Mon Feb 9 16:33:48 2009 New Revision: 742602 URL: http://svn.apache.org/viewvc?rev=742602view=rev Log: Fix doubly-defined function. Modified: qpid/trunk/qpid/cpp/src/tests/ClusterFixture.cpp qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp Modified: qpid/trunk/qpid

svn commit: r742774 - in /qpid/trunk/qpid/cpp: examples/tradedemo/ src/ src/qpid/broker/ src/qpid/cluster/ src/qpid/framing/ src/tests/ xml/

2009-02-09 Thread aconway
Author: aconway Date: Mon Feb 9 22:25:26 2009 New Revision: 742774 URL: http://svn.apache.org/viewvc?rev=742774view=rev Log: Cluster support for message time-to-live. Added: qpid/trunk/qpid/cpp/src/qpid/broker/ExpiryPolicy.cpp (with props) qpid/trunk/qpid/cpp/src/qpid/broker

svn commit: r743131 - in /qpid/trunk/qpid/cpp/src: cluster.mk qpid/cluster/ConnectionDecoder.cpp qpid/cluster/ConnectionMap.cpp qpid/cluster/Decoder.cpp qpid/cluster/ThreadDispatch.cpp qpid/cluster/Th

2009-02-10 Thread aconway
Author: aconway Date: Tue Feb 10 22:16:05 2009 New Revision: 743131 URL: http://svn.apache.org/viewvc?rev=743131view=rev Log: Remove unused class and clean up some FIXME comments. Removed: qpid/trunk/qpid/cpp/src/qpid/cluster/ThreadDispatch.cpp qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r743346 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Connection.cpp Connection.h Decoder.cpp

2009-02-11 Thread aconway
Author: aconway Date: Wed Feb 11 14:34:07 2009 New Revision: 743346 URL: http://svn.apache.org/viewvc?rev=743346view=rev Log: Fix memory leak in cluster code. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.h qpid/trunk

svn commit: r743416 - in /qpid/trunk/qpid/cpp/src/qpid: cluster/Connection.cpp cluster/ConnectionMap.cpp sys/AsynchIO.h sys/AsynchIOHandler.cpp sys/posix/AsynchIO.cpp sys/windows/AsynchIO.cpp

2009-02-11 Thread aconway
Author: aconway Date: Wed Feb 11 17:29:42 2009 New Revision: 743416 URL: http://svn.apache.org/viewvc?rev=743416view=rev Log: Fix race condition with read-credit. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/ConnectionMap.cpp qpid

svn commit: r743839 - in /qpid/trunk/qpid/cpp: src/ src/qpid/broker/ src/qpid/client/ src/qpid/cluster/ src/tests/ xml/

2009-02-12 Thread aconway
Author: aconway Date: Thu Feb 12 19:01:51 2009 New Revision: 743839 URL: http://svn.apache.org/viewvc?rev=743839view=rev Log: Cluster security support: - Set correct user ID on update connections. - Allow configuration of user, pass and mechanism used for update connections. Added: qpid

svn commit: r743909 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: ClusterPlugin.cpp Quorum.h

2009-02-12 Thread aconway
Author: aconway Date: Thu Feb 12 22:28:33 2009 New Revision: 743909 URL: http://svn.apache.org/viewvc?rev=743909view=rev Log: Enable --cluster-cman option if built with libcman support. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterPlugin.cpp qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r744129 - /qpid/trunk/qpid/cpp/src/tests/start_cluster

2009-02-13 Thread aconway
Author: aconway Date: Fri Feb 13 14:43:46 2009 New Revision: 744129 URL: http://svn.apache.org/viewvc?rev=744129view=rev Log: Add --no-module-dir to start_cluster script. Modified: qpid/trunk/qpid/cpp/src/tests/start_cluster Modified: qpid/trunk/qpid/cpp/src/tests/start_cluster URL: http

svn commit: r744321 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cpg.cpp Quorum_cman.cpp

2009-02-13 Thread aconway
Author: aconway Date: Sat Feb 14 00:47:05 2009 New Revision: 744321 URL: http://svn.apache.org/viewvc?rev=744321view=rev Log: Cluster start-up retries to handle slow cman start-up. - infinite retry if cpg_initialize returns TRY_AGAIN. - infinite retry for cman_is_quorate Modified: qpid

svn commit: r745115 - in /qpid/trunk/qpid/cpp/src/qpid/client: SubscriptionManager.cpp SubscriptionManager.h

2009-02-17 Thread aconway
Author: aconway Date: Tue Feb 17 15:19:39 2009 New Revision: 745115 URL: http://svn.apache.org/viewvc?rev=745115view=rev Log: Fixed bug in setFlowControl - was recursively calling self. Modified: qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.cpp qpid/trunk/qpid/cpp/src/qpid

svn commit: r745226 - in /qpid/trunk/qpid/cpp/src/qpid: client/SubscriptionManager.cpp client/SubscriptionManager.h cluster/Cluster.cpp

2009-02-17 Thread aconway
Author: aconway Date: Tue Feb 17 20:18:38 2009 New Revision: 745226 URL: http://svn.apache.org/viewvc?rev=745226view=rev Log: Minor fixes. client/SubscriptionManager: made it thread safe, was causing latencytest to crash with --rate and --time-limit. cluster/Cluster.cpp: don't call cpg_leave

svn commit: r747528 - in /qpid/trunk/qpid/cpp/src: ./ qpid/broker/ qpid/cluster/ qpid/sys/ tests/

2009-02-24 Thread aconway
Author: aconway Date: Tue Feb 24 19:48:54 2009 New Revision: 747528 URL: http://svn.apache.org/viewvc?rev=747528view=rev Log: Fixed issue with producer flow control in a cluster. Producer flow control uses a Timer and other clock-based calculations to send flow control commands. These commands

svn commit: r748339 - /qpid/trunk/qpid/cpp/src/qpid/cluster/PollableQueue.h

2009-02-26 Thread aconway
Author: aconway Date: Thu Feb 26 22:33:40 2009 New Revision: 748339 URL: http://svn.apache.org/viewvc?rev=748339view=rev Log: Fix to avoid spinning if an exception is thrown in cluster::PollableQueue. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/PollableQueue.h Modified: qpid/trunk/qpid

svn commit: r748651 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp Cluster.h

2009-02-27 Thread aconway
Author: aconway Date: Fri Feb 27 19:34:47 2009 New Revision: 748651 URL: http://svn.apache.org/viewvc?rev=748651view=rev Log: cluster: apply membership updates while in CATCHUP mode. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.h

svn commit: r748723 - in /qpid/trunk/qpid/cpp/src/qpid: assert.cpp cluster/ConnectionMap.cpp cluster/ConnectionMap.h

2009-02-27 Thread aconway
Author: aconway Date: Fri Feb 27 22:27:11 2009 New Revision: 748723 URL: http://svn.apache.org/viewvc?rev=748723view=rev Log: Add lock to cluster::ConnectionMap, make it thread safe. Modified: qpid/trunk/qpid/cpp/src/qpid/assert.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/ConnectionMap.cpp

svn commit: r749473 - in /qpid/trunk/qpid/cpp: src/ src/qpid/cluster/ src/qpid/framing/ src/tests/ xml/

2009-03-02 Thread aconway
Author: aconway Date: Mon Mar 2 23:30:08 2009 New Revision: 749473 URL: http://svn.apache.org/viewvc?rev=749473view=rev Log: Replicate connection decoder fragments to new members. Refactoring: - Merge Decoder into ConnectionMap. - Process cluster controls in event queue thread. - Use

svn commit: r749621 - /qpid/trunk/qpid/cpp/src/qpid/framing/FrameDecoder.cpp

2009-03-03 Thread aconway
Author: aconway Date: Tue Mar 3 14:42:11 2009 New Revision: 749621 URL: http://svn.apache.org/viewvc?rev=749621view=rev Log: Avoid use of std::vector::data(), not available on some platforms. Modified: qpid/trunk/qpid/cpp/src/qpid/framing/FrameDecoder.cpp Modified: qpid/trunk/qpid/cpp/src

svn commit: r749730 - in /qpid/trunk/qpid/cpp/src: qpid/cluster/UpdateClient.cpp tests/failover_soak.cpp tests/replaying_sender.cpp tests/resuming_receiver.cpp tests/run_failover_soak

2009-03-03 Thread aconway
Author: aconway Date: Tue Mar 3 20:21:01 2009 New Revision: 749730 URL: http://svn.apache.org/viewvc?rev=749730view=rev Log: cluster::UpdateClient added missing error handling. Minor improvements to failover_soak tests. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/UpdateClient.cpp

svn commit: r749756 - in /qpid/trunk/qpid/cpp/src/tests: ForkedBroker.cpp failover_soak.cpp

2009-03-03 Thread aconway
Author: aconway Date: Tue Mar 3 21:07:49 2009 New Revision: 749756 URL: http://svn.apache.org/viewvc?rev=749756view=rev Log: cpp/src/tests/ForkedBroker.cpp: supress misleading exceptions with kill -9. Modified: qpid/trunk/qpid/cpp/src/tests/ForkedBroker.cpp qpid/trunk/qpid/cpp/src/tests

svn commit: r750456 - in /qpid/trunk/qpid/cpp: src/ src/qpid/ src/qpid/broker/ src/qpid/cluster/ src/tests/ xml/

2009-03-05 Thread aconway
Author: aconway Date: Thu Mar 5 13:28:14 2009 New Revision: 750456 URL: http://svn.apache.org/viewvc?rev=750456view=rev Log: cluster: fix delivery-property.exchange-name set on updated messages. Logging improvements, useful for debugging: - qpid/SessionState.cpp: show frame bodies with command

svn commit: r750574 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp Cluster.h ExpiryPolicy.cpp ExpiryPolicy.h

2009-03-05 Thread aconway
Author: aconway Date: Thu Mar 5 20:24:41 2009 New Revision: 750574 URL: http://svn.apache.org/viewvc?rev=750574view=rev Log: Cluster: restore separate event/frame threads. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.h qpid

svn commit: r751557 - in /qpid/trunk/qpid/cpp: src/ src/qpid/cluster/ src/qpid/framing/ xml/

2009-03-08 Thread aconway
Author: aconway Date: Sun Mar 8 23:52:35 2009 New Revision: 751557 URL: http://svn.apache.org/viewvc?rev=751557view=rev Log: Fixed race conditions in cluster. Execute all cluster logic in frameDeliverQueue thread, decoding only in eventDeliverQueue thread. Added: qpid/trunk/qpid/cpp/src

svn commit: r751760 - in /qpid/trunk/qpid/cpp: src/qpid/cluster/ src/qpid/framing/ src/tests/ xml/

2009-03-09 Thread aconway
Author: aconway Date: Mon Mar 9 17:03:40 2009 New Revision: 751760 URL: http://svn.apache.org/viewvc?rev=751760view=rev Log: Fix cluster TTL: replicte expiry information to newcomers. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r752092 - in /qpid/trunk/qpid/cpp/src/qpid: broker/Daemon.h console/ClassKey.cpp framing/Uuid.h

2009-03-10 Thread aconway
Author: aconway Date: Tue Mar 10 12:34:49 2009 New Revision: 752092 URL: http://svn.apache.org/viewvc?rev=752092view=rev Log: Add missing #includes to build with gcc 4.4. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Daemon.h qpid/trunk/qpid/cpp/src/qpid/console/ClassKey.cpp qpid

svn commit: r752146 - /qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterSettings.h

2009-03-10 Thread aconway
Author: aconway Date: Tue Mar 10 15:46:09 2009 New Revision: 752146 URL: http://svn.apache.org/viewvc?rev=752146view=rev Log: Cluster authentication settings default to empty. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterSettings.h Modified: qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r752154 - /qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp

2009-03-10 Thread aconway
Author: aconway Date: Tue Mar 10 16:20:39 2009 New Revision: 752154 URL: http://svn.apache.org/viewvc?rev=752154view=rev Log: Added cluster ACL test, disabled for now as it exposes a memory leak in the SASL client. Modified: qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp Modified: qpid

svn commit: r752600 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp

2009-03-11 Thread aconway
Author: aconway Date: Wed Mar 11 20:03:45 2009 New Revision: 752600 URL: http://svn.apache.org/viewvc?rev=752600view=rev Log: Fix problems buildling on gcc 4.4 and latest corosync. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp

svn commit: r760008 - /qpid/trunk/qpid/cpp/src/qpid/client/Handle.h

2009-03-30 Thread aconway
Author: aconway Date: Mon Mar 30 15:25:30 2009 New Revision: 760008 URL: http://svn.apache.org/viewvc?rev=760008view=rev Log: cpp/src/qpid/client/Handle.h: fix operator!() Modified: qpid/trunk/qpid/cpp/src/qpid/client/Handle.h Modified: qpid/trunk/qpid/cpp/src/qpid/client/Handle.h URL

svn commit: r760087 - in /qpid/trunk/qpid/cpp/src/qpid: broker/ExpiryPolicy.cpp broker/ExpiryPolicy.h broker/Message.cpp cluster/ExpiryPolicy.cpp cluster/ExpiryPolicy.h

2009-03-30 Thread aconway
Author: aconway Date: Mon Mar 30 18:22:09 2009 New Revision: 760087 URL: http://svn.apache.org/viewvc?rev=760087view=rev Log: Fix lifecycle issue in ExpiryPolicy - remove deleted messages from unexpired map. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/ExpiryPolicy.cpp qpid/trunk/qpid

svn commit: r760458 - in /qpid/trunk/qpid/cpp/src/tests: failover_soak.cpp run_failover_soak

2009-03-31 Thread aconway
Author: aconway Date: Tue Mar 31 14:20:05 2009 New Revision: 760458 URL: http://svn.apache.org/viewvc?rev=760458view=rev Log: cpp/src/tests/failover_soak.cpp: allow it to run with all modules loaded or only the cluster module. cpp/src/tests/run_failover_soak: run failover_soak with all modules

svn commit: r762370 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp Cpg.cpp UpdateClient.cpp

2009-04-06 Thread aconway
Author: aconway Date: Mon Apr 6 14:55:57 2009 New Revision: 762370 URL: http://svn.apache.org/viewvc?rev=762370view=rev Log: Cluster: fix exception handling if updater fails to connect to updatee. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid

svn commit: r763722 - in /qpid/trunk/qpid/cpp/src/tests: declare_queues.cpp failover_soak.cpp replaying_sender.cpp run_failover_soak

2009-04-09 Thread aconway
Author: aconway Date: Thu Apr 9 16:17:39 2009 New Revision: 763722 URL: http://svn.apache.org/viewvc?rev=763722view=rev Log: Add durability option to the cpp failover_soak test. From Mick Goulish: https://issues.apache.org/jira/browse/QPID-1796, Modified: qpid/trunk/qpid/cpp/src/tests

svn commit: r764783 - in /qpid/trunk/qpid/cpp/src: qpid/cluster/Cluster.cpp qpid/cluster/Connection.h tests/ClusterFailover.cpp tests/cluster.mk

2009-04-14 Thread aconway
Author: aconway Date: Tue Apr 14 14:19:12 2009 New Revision: 764783 URL: http://svn.apache.org/viewvc?rev=764783view=rev Log: Fix regression: close shadow connections belonging to brokers that have left the cluster. Added: qpid/trunk/qpid/cpp/src/tests/ClusterFailover.cpp (with props

svn commit: r764813 - /qpid/trunk/qpid/cpp/src/cluster.mk

2009-04-14 Thread aconway
Author: aconway Date: Tue Apr 14 15:03:07 2009 New Revision: 764813 URL: http://svn.apache.org/viewvc?rev=764813view=rev Log: src/cluster.mk: removed non-existent file. Modified: qpid/trunk/qpid/cpp/src/cluster.mk Modified: qpid/trunk/qpid/cpp/src/cluster.mk URL: http://svn.apache.org

svn commit: r765249 - /qpid/trunk/qpid/cpp/src/tests/client_test.cpp

2009-04-15 Thread aconway
Author: aconway Date: Wed Apr 15 15:54:08 2009 New Revision: 765249 URL: http://svn.apache.org/viewvc?rev=765249view=rev Log: Update client test to use SubscriptionManager. Modified: qpid/trunk/qpid/cpp/src/tests/client_test.cpp Modified: qpid/trunk/qpid/cpp/src/tests/client_test.cpp URL

svn commit: r765285 - in /qpid/trunk/qpid/cpp/src/qpid: client/ cluster/ framing/ sys/

2009-04-15 Thread aconway
Author: aconway Date: Wed Apr 15 17:45:45 2009 New Revision: 765285 URL: http://svn.apache.org/viewvc?rev=765285view=rev Log: Cleaned up some un-necessary #include dependencies. Removed un-used LatencyMetric hack. Removed: qpid/trunk/qpid/cpp/src/qpid/sys/LatencyMetric.cpp qpid/trunk

svn commit: r765286 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: EventFrame.cpp Multicaster.h OutputInterceptor.cpp

2009-04-15 Thread aconway
Author: aconway Date: Wed Apr 15 17:50:10 2009 New Revision: 765286 URL: http://svn.apache.org/viewvc?rev=765286view=rev Log: Removed un-used LatencyMetric hack: missed in lat commit. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/EventFrame.cpp qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r765338 - /qpid/trunk/qpid/cpp/src/tests/SocketProxy.h

2009-04-15 Thread aconway
Author: aconway Date: Wed Apr 15 20:18:45 2009 New Revision: 765338 URL: http://svn.apache.org/viewvc?rev=765338view=rev Log: Fix bug in SocketProxy causing occasional hangs in tests. Modified: qpid/trunk/qpid/cpp/src/tests/SocketProxy.h Modified: qpid/trunk/qpid/cpp/src/tests/SocketProxy.h

svn commit: r765365 - in /qpid/trunk/qpid/cpp/src/tests: ForkedBroker.cpp ForkedBroker.h PartialFailure.cpp failover_soak.cpp

2009-04-15 Thread aconway
Author: aconway Date: Wed Apr 15 21:21:47 2009 New Revision: 765365 URL: http://svn.apache.org/viewvc?rev=765365view=rev Log: Clean up temporary data directories in tests. ForkedBroker.cpp: create/delete tmp data directory if passed arg TMP_DATA_DIR. failover_soak.cpp, PartialFailure.cpp: use

svn commit: r765370 - in /qpid/trunk/qpid/cpp/src/tests: BasicP2PTest.cpp BasicP2PTest.h BasicPubSubTest.cpp BasicPubSubTest.h Makefile.am SimpleTestCaseBase.cpp SimpleTestCaseBase.h TestCase.h intero

2009-04-15 Thread aconway
Author: aconway Date: Wed Apr 15 21:34:01 2009 New Revision: 765370 URL: http://svn.apache.org/viewvc?rev=765370view=rev Log: Removed defunct interop_runner test, was never updated from 0-8 channel API. Removed: qpid/trunk/qpid/cpp/src/tests/BasicP2PTest.cpp qpid/trunk/qpid/cpp/src/tests

svn commit: r765615 - in /qpid/trunk/qpid/cpp: rubygen/framing.0-10/Session.rb src/Makefile.am

2009-04-16 Thread aconway
Author: aconway Date: Thu Apr 16 12:52:52 2009 New Revision: 765615 URL: http://svn.apache.org/viewvc?rev=765615view=rev Log: Changes missed in previous commit r765285. Modified: qpid/trunk/qpid/cpp/rubygen/framing.0-10/Session.rb qpid/trunk/qpid/cpp/src/Makefile.am Modified: qpid/trunk

svn commit: r765685 - in /qpid/trunk/qpid/cpp/src/tests: ForkedBroker.cpp run_failover_soak

2009-04-16 Thread aconway
Author: aconway Date: Thu Apr 16 16:53:22 2009 New Revision: 765685 URL: http://svn.apache.org/viewvc?rev=765685view=rev Log: Override the executable used by ForkedBroker by setting an env. var. Modified: qpid/trunk/qpid/cpp/src/tests/ForkedBroker.cpp qpid/trunk/qpid/cpp/src/tests

svn commit: r765699 - /qpid/trunk/qpid/cpp/src/qpid/cluster/ErrorCheck.cpp

2009-04-16 Thread aconway
Author: aconway Date: Thu Apr 16 17:40:14 2009 New Revision: 765699 URL: http://svn.apache.org/viewvc?rev=765699view=rev Log: Fix log message with incorrect level (critical should be debug). Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/ErrorCheck.cpp Modified: qpid/trunk/qpid/cpp/src/qpid

svn commit: r766899 - in /qpid/trunk/qpid/cpp/src: ./ qpid/client/ tests/

2009-04-20 Thread aconway
Author: aconway Date: Mon Apr 20 22:33:27 2009 New Revision: 766899 URL: http://svn.apache.org/viewvc?rev=766899view=rev Log: Apply PIMPL pattern to qpid::client::Message. Hide implementation of Message, move framing::MethodContent and framing::TransferContent out of public API. Added

svn commit: r767158 - /qpid/trunk/qpid/cpp/rubygen/framing.0-10/Session.rb

2009-04-21 Thread aconway
Author: aconway Date: Tue Apr 21 14:26:54 2009 New Revision: 767158 URL: http://svn.apache.org/viewvc?rev=767158view=rev Log: File missed in previous commit. Modified: qpid/trunk/qpid/cpp/rubygen/framing.0-10/Session.rb Modified: qpid/trunk/qpid/cpp/rubygen/framing.0-10/Session.rb URL

svn commit: r767663 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp

2009-04-22 Thread aconway
Author: aconway Date: Wed Apr 22 21:13:05 2009 New Revision: 767663 URL: http://svn.apache.org/viewvc?rev=767663view=rev Log: Better logging around cpg_init, 30 second retry limit. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp

svn commit: r767896 - in /qpid/trunk/qpid/cpp: rubygen/framing.0-10/ src/ src/qpid/client/ src/qpid/cluster/ src/tests/

2009-04-23 Thread aconway
Author: aconway Date: Thu Apr 23 11:48:32 2009 New Revision: 767896 URL: http://svn.apache.org/viewvc?rev=767896view=rev Log: Apply PIMPL pattern to client::Completion and client::Future. Added: qpid/trunk/qpid/cpp/src/qpid/client/Completion.cpp (with props) qpid/trunk/qpid/cpp/src

svn commit: r769914 - in /qpid/trunk/qpid/cpp/src: ./ qpid/cluster/

2009-04-29 Thread aconway
Author: aconway Date: Wed Apr 29 20:29:53 2009 New Revision: 769914 URL: http://svn.apache.org/viewvc?rev=769914view=rev Log: Improved simplified cluster output algorithm. Removed: qpid/trunk/qpid/cpp/src/qpid/cluster/WriteEstimate.cpp qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r770702 - in /qpid/trunk/qpid/cpp/src: ./ qpid/client/

2009-05-01 Thread aconway
Author: aconway Date: Fri May 1 14:53:05 2009 New Revision: 770702 URL: http://svn.apache.org/viewvc?rev=770702view=rev Log: Cleaned up PIMPL pattern for public API - Separated PrivateImplRef helper classs from Handler base class. - Consistent impl of ctor, dtor, copy, assign for all PIMPL

svn commit: r770723 - /qpid/trunk/qpid/cpp/rubygen/framing.0-10/Session.rb

2009-05-01 Thread aconway
Author: aconway Date: Fri May 1 15:45:28 2009 New Revision: 770723 URL: http://svn.apache.org/viewvc?rev=770723view=rev Log: Code generator changes missed on last commit. Modified: qpid/trunk/qpid/cpp/rubygen/framing.0-10/Session.rb Modified: qpid/trunk/qpid/cpp/rubygen/framing.0-10

svn commit: r770734 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp

2009-05-01 Thread aconway
Author: aconway Date: Fri May 1 16:00:43 2009 New Revision: 770734 URL: http://svn.apache.org/viewvc?rev=770734view=rev Log: Remove workaround for buggy corosync headers, no longer needed. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cpg.cpp Modified: qpid/trunk/qpid/cpp/src/qpid/cluster

svn commit: r771354 - in /qpid/trunk/qpid/cpp/src/qpid/broker: DeliveryRecord.h SemanticState.cpp

2009-05-04 Thread aconway
Author: aconway Date: Mon May 4 16:37:21 2009 New Revision: 771354 URL: http://svn.apache.org/viewvc?rev=771354view=rev Log: Undo buggy commit 770802. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/DeliveryRecord.h qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp Modified: qpid

svn commit: r771366 - in /qpid/trunk/qpid/cpp/src: ./ qpid/client/ tests/

2009-05-04 Thread aconway
Author: aconway Date: Mon May 4 17:22:33 2009 New Revision: 771366 URL: http://svn.apache.org/viewvc?rev=771366view=rev Log: Applied PIMPL pattern to SubscriptionManager. Cleaned up some sloppy #includes. Added: qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManagerImpl.cpp (with props

svn commit: r771386 - /qpid/trunk/qpid/cpp/src/Makefile.am

2009-05-04 Thread aconway
Author: aconway Date: Mon May 4 18:28:33 2009 New Revision: 771386 URL: http://svn.apache.org/viewvc?rev=771386view=rev Log: Fix error in Makefile.am. Modified: qpid/trunk/qpid/cpp/src/Makefile.am Modified: qpid/trunk/qpid/cpp/src/Makefile.am URL: http://svn.apache.org/viewvc/qpid/trunk

svn commit: r771392 - in /qpid/trunk/qpid/cpp/src: cluster.mk qpid/cluster/Cluster.cpp qpid/sys/LatencyTracker.h

2009-05-04 Thread aconway
Author: aconway Date: Mon May 4 18:38:18 2009 New Revision: 771392 URL: http://svn.apache.org/viewvc?rev=771392view=rev Log: LatenchTracker: a tool for measuring latencies. Added measurement points to cluster code. Added: qpid/trunk/qpid/cpp/src/qpid/sys/LatencyTracker.h (with props

svn commit: r771721 - /qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.h

2009-05-05 Thread aconway
Author: aconway Date: Tue May 5 13:36:31 2009 New Revision: 771721 URL: http://svn.apache.org/viewvc?rev=771721view=rev Log: Added #include Thread.h for backwards compatibility. Modified: qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.h Modified: qpid/trunk/qpid/cpp/src/qpid

svn commit: r772384 - in /qpid/trunk/qpid/cpp/src: qpid/broker/DeliveryRecord.cpp qpid/broker/DeliveryRecord.h qpid/broker/SemanticState.cpp qpid/broker/SemanticState.h qpid/broker/TxAccept.cpp tests/

2009-05-06 Thread aconway
Author: aconway Date: Wed May 6 17:58:50 2009 New Revision: 772384 URL: http://svn.apache.org/viewvc?rev=772384view=rev Log: DeliveryRecord optimizations. Replace linear search with binary search. Collapse multi-pass mark-then-erase to a signle pass. Modified: qpid/trunk/qpid/cpp/src/qpid

svn commit: r772752 - in /qpid/trunk/qpid/cpp/src/qpid/broker: QueueListeners.cpp QueueListeners.h

2009-05-07 Thread aconway
Author: aconway Date: Thu May 7 19:48:28 2009 New Revision: 772752 URL: http://svn.apache.org/viewvc?rev=772752view=rev Log: Use set for efficient insert/remove rather than list. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/QueueListeners.cpp qpid/trunk/qpid/cpp/src/qpid/broker

svn commit: r773552 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp Decoder.cpp Decoder.h

2009-05-11 Thread aconway
Author: aconway Date: Mon May 11 13:11:42 2009 New Revision: 773552 URL: http://svn.apache.org/viewvc?rev=773552view=rev Log: Fix leak of Decoder map entries. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Decoder.cpp qpid/trunk/qpid

svn commit: r774809 - in /qpid/trunk/qpid/cpp/src: ./ qpid/broker/ qpid/cluster/ qpid/management/

2009-05-14 Thread aconway
Author: aconway Date: Thu May 14 15:14:32 2009 New Revision: 774809 URL: http://svn.apache.org/viewvc?rev=774809view=rev Log: Fix for unpredictable enqueues by timer-triggered management code in a cluster. ManagementAgent uses Broker::getClusterMessageHandler() (if non-0) to enqueue timer

svn commit: r775182 - in /qpid/trunk/qpid/cpp/src: ./ qpid/broker/ qpid/cluster/ qpid/management/

2009-05-15 Thread aconway
Author: aconway Date: Fri May 15 15:12:05 2009 New Revision: 775182 URL: http://svn.apache.org/viewvc?rev=775182view=rev Log: Undo change from r774809. This fix is incorrect. The timer will go off in each member, and each one will send a response message which is replicated, resulting

svn commit: r778443 - in /qpid/trunk/qpid/cpp/src/qpid/broker: SemanticState.cpp SemanticState.h

2009-05-25 Thread aconway
Author: aconway Date: Mon May 25 15:51:52 2009 New Revision: 778443 URL: http://svn.apache.org/viewvc?rev=778443view=rev Log: ConsumerImpl optimization - only dispatch on queue if we were notified of messages. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp qpid/trunk

svn commit: r778452 - in /qpid/trunk/qpid/cpp/src/qpid/broker: SemanticState.cpp SemanticState.h

2009-05-25 Thread aconway
Author: aconway Date: Mon May 25 16:41:28 2009 New Revision: 778452 URL: http://svn.apache.org/viewvc?rev=778452view=rev Log: ConsumerImpl optimization - use atomic value for queueHasMessages. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp qpid/trunk/qpid/cpp/src/qpid

svn commit: r778464 - in /qpid/trunk/qpid/cpp/src/qpid: broker/QueueEvents.cpp broker/QueueEvents.h cluster/Connection.h cluster/Event.cpp cluster/Event.h cluster/Multicaster.cpp cluster/Multicaster.h

2009-05-25 Thread aconway
Author: aconway Date: Mon May 25 18:20:50 2009 New Revision: 778464 URL: http://svn.apache.org/viewvc?rev=778464view=rev Log: PollableQueue optimization - replace deque with vector. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/QueueEvents.cpp qpid/trunk/qpid/cpp/src/qpid/broker

svn commit: r778896 - in /qpid/trunk/qpid/cpp: src/qpid/cluster/ xml/

2009-05-26 Thread aconway
Author: aconway Date: Tue May 26 21:41:52 2009 New Revision: 778896 URL: http://svn.apache.org/viewvc?rev=778896view=rev Log: Improved doOutput algorithm. Simpler more robust algorithm based on message count rather than byte size. Self-tuning, removes 2 hard-to-explain cluster options. Similar

svn commit: r779235 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp Cluster.h Decoder.cpp Decoder.h

2009-05-27 Thread aconway
Author: aconway Date: Wed May 27 16:39:15 2009 New Revision: 779235 URL: http://svn.apache.org/viewvc?rev=779235view=rev Log: Added missing locks in cluster code. Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.h qpid/trunk/qpid

svn commit: r784267 - in /qpid/trunk/qpid/cpp/src/qpid/broker: QueueListeners.cpp QueueListeners.h

2009-06-12 Thread aconway
Author: aconway Date: Fri Jun 12 20:42:16 2009 New Revision: 784267 URL: http://svn.apache.org/viewvc?rev=784267view=rev Log: Revert bad optimization: unpredictable ordering of set caused cluster failures. Modified: qpid/trunk/qpid/cpp/src/qpid/broker/QueueListeners.cpp qpid/trunk/qpid

svn commit: r785408 - in /qpid/trunk/qpid/cpp: src/qpid/broker/ src/qpid/cluster/ src/qpid/framing/ src/qpid/sys/ xml/

2009-06-16 Thread aconway
Author: aconway Date: Tue Jun 16 21:21:09 2009 New Revision: 785408 URL: http://svn.apache.org/viewvc?rev=785408view=rev Log: Performance improvements in AggregateOutput and SemanticState. Replaced AggregateOutput hierarchy with a flat list per connection holding only the OutputTasks

svn commit: r785601 - in /qpid/trunk/qpid/cpp/src/tests: ClientSessionTest.cpp cluster_test.cpp unit_test.h

2009-06-17 Thread aconway
Author: aconway Date: Wed Jun 17 13:45:31 2009 New Revision: 785601 URL: http://svn.apache.org/viewvc?rev=785601view=rev Log: Drop _EXPECTED_FAILURES macro, doesn't work with all boost versions. Modified: qpid/trunk/qpid/cpp/src/tests/ClientSessionTest.cpp qpid/trunk/qpid/cpp/src/tests

svn commit: r785788 - in /qpid/trunk/qpid/cpp: src/qpid/cluster/Cluster.cpp src/qpid/cluster/Connection.cpp src/qpid/cluster/Connection.h src/tests/cluster_test.cpp xml/cluster.xml

2009-06-17 Thread aconway
Author: aconway Date: Wed Jun 17 20:45:52 2009 New Revision: 785788 URL: http://svn.apache.org/viewvc?rev=785788view=rev Log: Handle invalid AMPQ data to a cluster by closing the offending connection. Prior to this fix, invalid data shut down the whole cluster. Modified: qpid/trunk/qpid/cpp

  1   2   3   4   5   6   7   8   9   10   >