You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2007/03/21 15:28:18 UTC
svn commit: r520898 - /incubator/qpid/trunk/qpid/
Author: aconway
Date: Wed Mar 21 07:28:17 2007
New Revision: 520898
URL: http://svn.apache.org/viewvc?view=rev&rev=520898
Log:
The following revisions were merged wholesale by moving qpid.0-9/cpp to the
trunk. Recording them so they won't clutter "svnmerge.py avail" output.
Recorded merge of revisions 492713-492776,492778-493019,493021-493048,493050-493067,493069-493156,493158-494180,494182-494524,494526-494540,494543-494548,494550-494553,494555-494961,494963-494999,495001-495042,495044-495250,495252-495450,495452-495580,495582-495678,495680-496325,496327-496388,496390-496438,496440-496455,496457-496498,496500-496585,496587-496592,496594-496595,496597-496731,496733-496767,496769-496809,496811,496813-496872,496875-497061,497064-497077,497079-497092,497094-497137,497139-497160,497163-497168,497170-497178,497180-497194,497196-497276,497279-497444,497446-497449,497451-497482,497484-497488,497490-497514,497516-497584,497586-497615,497617-497632,497634-497819,497821-497905,497907-497948,497950-497973,497975-497990,497993-498630,498632-498663,498665-498796,498798-498803,498805-499029,499031-499045,499047-499120,499122,499124-499132,499135-499162,499164-499524,499526-499548,499552-499570,499572-499611,499613-499879,499881-499924,499926,499930-499967,499
969-500262,500264-500281,500283-500302,500304,500306-501020,501023-501024,501026-501080,501083-501098,501100-501142,501146-501169,501171-501455,501457-501469,501471-501549,501552-501558,501560-501576,501578-501585,501587-501849,501851-501863,501865-501889,501891-501917,501919-502175,502177-503694,503696-503730,503732-503735,503737-503856,503859-504589,504591-504600,504602-504609,504611-504699,504701-504848,504850-505286,505288-505299,505301-505303,505305-505387,505389-506476,506478-506544,506546-506564,506567-507490,507492-507671,507673-507959,507961-507992,507994-508097,508099-508149,508151-508232,508234-508376,508378-508390,508392-508395,508397-508459,508461-509610,509612-509615,509618-509737,509739-509753,509756-510095,510097-510106,510108-510113,510115-510127,510129-510911,510914-511003,511005-515362,515364-515720,515722-516458,516461-516484,516486-516488,516490-517823,517825,517827,517829,517831-517832,517834-517848,517850,517852-517854,517856-517858,517860-517877,51787
9-517886,517888-517891,517893-517903,517905,517907-517930,517932-518197,518201-518206,518208-518230,518232,518235,518237,518239-518240,518243-518245,518247-518255,518257-518260,518262,518264,518266-518292,518294-518706,518708-519146 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9
........
r492713 | aconway | 2007-01-04 15:14:20 -0500 (Thu, 04 Jan 2007) | 4 lines
Fixed some compile errors:
- Fix error in code generator for decoding timestamps.
- Add dummy op<< for framing::Content
........
r492774 | aconway | 2007-01-04 17:05:53 -0500 (Thu, 04 Jan 2007) | 4 lines
Fixed compile errors, not all fixed yet:
- Fix error in code generator for decoding timestamps.
- Add dummy op<< for framing::Content
........
r492781 | aconway | 2007-01-04 17:31:05 -0500 (Thu, 04 Jan 2007) | 4 lines
Unsupress generation of 0-8 classes. Re-suppress when new
Messaging classes are ready to replace them.
........
r492787 | aconway | 2007-01-04 17:42:56 -0500 (Thu, 04 Jan 2007) | 2 lines
Compile fixes, still not complete: #def class in FramingContent.h
........
r492840 | aconway | 2007-01-04 19:52:33 -0500 (Thu, 04 Jan 2007) | 12 lines
0-9 branch now compiles but is not yet functional.
Areas needing attention are marked FIXME.
It includes both 0-8 Basic etc. classes 0-9 Message claasses,
0-8 classes cannot be removed till 0-9 Message is ready to replace them.
Summary of fixes:
- added 0-9 methods to SessionHandlerImpl.h, no implementation yet.
- added missing framing::Content methods
- unimplemented methods do { assert(0); // FIXME
........
r494308 | aconway | 2007-01-08 21:57:26 -0500 (Mon, 08 Jan 2007) | 2 lines
Disabled python tests, added system tests to build: client_test, topictest.
........
r494427 | cctrieloff | 2007-01-09 10:04:57 -0500 (Tue, 09 Jan 2007) | 5 lines
Patch from Andrew, I will merge the solution that I am working on shortly, but
this patch should enable the branch to work till then
........
r494483 | aconway | 2007-01-09 11:55:27 -0500 (Tue, 09 Jan 2007) | 3 lines
Automated C++ client_test and topictest.
Andrew Stitcher: patch to change hardcoded 8-0 version numbers to 0-9.
........
r494518 | cctrieloff | 2007-01-09 13:48:57 -0500 (Tue, 09 Jan 2007) | 4 lines
merged in code form Andrew, to clean up version map construction.
........
r494559 | cctrieloff | 2007-01-09 15:29:06 -0500 (Tue, 09 Jan 2007) | 4 lines
version back merge from trunk rev 494553.
........
r495018 | aconway | 2007-01-10 17:44:12 -0500 (Wed, 10 Jan 2007) | 2 lines
Encoding and decoding of AMQP 0-9 request and response frames.
........
r495254 | aconway | 2007-01-11 10:25:54 -0500 (Thu, 11 Jan 2007) | 4 lines
* Build order - src before tests.
* docs/api/developer.doxygen: Generate for all classes, private members etc.
........
r495345 | aconway | 2007-01-11 14:32:46 -0500 (Thu, 11 Jan 2007) | 3 lines
Include *.cpp in developer doxygen to get calls/called-by links.
........
r495681 | aconway | 2007-01-12 13:39:26 -0500 (Fri, 12 Jan 2007) | 4 lines
Andrew Stitcher <as...@redhat.com>
* Add empty implementation of handler class for protocol Message class.
........
r496110 | aconway | 2007-01-14 13:30:25 -0500 (Sun, 14 Jan 2007) | 4 lines
* Added Requester/Responder classes to manage request-ids, response-ids,
and response-mark. Response batches not yet supported.
........
r496114 | aconway | 2007-01-14 13:48:47 -0500 (Sun, 14 Jan 2007) | 5 lines
* Combined README.txt and READE-dist into README. Fixes cwiki link,
and provides more useful chunk of info.
* Fixed rpm target to create build directories.
........
r496425 | aconway | 2007-01-15 13:28:29 -0500 (Mon, 15 Jan 2007) | 4 lines
* Refactor: Moved major broker components (exchanges, queues etc.) from
class SessionHandlerImplFactory to more logical class Broker.
........
r496511 | aconway | 2007-01-15 16:56:23 -0500 (Mon, 15 Jan 2007) | 3 lines
* Client & broker using Requester/Responder to manage request/response IDs.
........
r496848 | aconway | 2007-01-16 15:17:50 -0500 (Tue, 16 Jan 2007) | 6 lines
* Renamed Session* classes to Connection* to align with AMQP spec
- broker::SessionHandlerImpl -> broker::Connection
- broker::SessionHandlerImplFactory -> broker::ConnectionFactory
- sys::SessionHandler -> ConnectionInputHandler
- sys::SessionHandlerFactory -> ConnectionInputHandlerFactory
........
r496926 | aconway | 2007-01-16 22:49:35 -0500 (Tue, 16 Jan 2007) | 8 lines
Separated adapter code from Connection class: Extracted all
HandlerImpl classes to BrokerAdapter. The Connection is now part of the
version-invariant core, all version-dependent code is in BrokerAdapter.
The extraction exposes some ugly dependencies between adapter, Connection
and parts of the Broker. More refactoring to follow to improve encapsulation.
........
r497319 | aconway | 2007-01-18 01:27:50 -0500 (Thu, 18 Jan 2007) | 17 lines
There are a ton of FIXMES and request/response IDs are not yet working fully
but all tests are passing.
* broker::Broker: Removed requester/responder from broker.
* framing::BodyHandler: added Requester/Responder to BodyHandler, becomes
the base class for channel adapters in broker and client.
* broker::BrokerAdapter: Inherit BodyHandler, wraps a broker::Channel.
Hide private *HandlerImpl detail classes in BodyHandler.cpp.
* broker::Connection: Requester/Responder/Adapter now per-channel.
Connection channel map replaced with adapter map of BrokerAdapters.
handle* functions moved to BrokerAdapter.
All methods now handled by a BrokerAdapter for the relevant channel.
ChannelHandlerImpl is repsonsible for checking that
- No method on a non-0 channel is processed before open()
- Channel 0 methods only happen on channel 0 and similar for non-zero methods
Checks are not yet complete (see FIXMES)
* client::ResponseHandler: fix for client hang if broker crashs.
........
r497336 | aconway | 2007-01-18 02:54:09 -0500 (Thu, 18 Jan 2007) | 20 lines
From: Andrew Stitcher <as...@redhat.com>
r723@fuschia: andrew | 2007-01-12 00:35:16 +0000
Branch for my work on Qpid.0-9
r724@fuschia: andrew | 2007-01-12 00:59:28 +0000
Added in empty implementation of handler class for protocol Message class
r768@fuschia: andrew | 2007-01-17 01:25:16 +0000
* Added Test for new MessageHandlerImpl (but no actual tests yet)
* Filled in lots of the blanks in the MessageHandlerImpl with code
stolen from the BasicHandlerImpl
r800@fuschia: andrew | 2007-01-17 17:34:13 +0000
Updated to latest upstream changes
Alan Conway <ac...@redhat.com>
* Took the changes from Andrew's patch and separated the
MessageHandlerImpl into its own .cpp/.h file. Other handlers
should be separated also.
* BrokerAdapter inner classes ignore channel arg and use
channel member instead.
........
r497473 | gsim | 2007-01-18 11:02:21 -0500 (Thu, 18 Jan 2007) | 3 lines
In case any channel is waiting for a response on termination of the connection, notify the response handler. (Fix to QPID-303).
........
r497511 | aconway | 2007-01-18 12:45:23 -0500 (Thu, 18 Jan 2007) | 5 lines
* MethodContext: added invocation context for methods. Can carry RequestId
as well as ChannelId.
* gentools: AMQP_Clinet|ServerOperations and *Body::invoke(): pass MethodContex instead of channel ID.
* All *HandlerImpl classe: use MethodContext instead of channel ID.
........
r497542 | gsim | 2007-01-18 14:22:40 -0500 (Thu, 18 Jan 2007) | 3 lines
Initial implementation of AMQP content data type.
........
r497755 | gsim | 2007-01-19 04:37:56 -0500 (Fri, 19 Jan 2007) | 5 lines
* tests/FramingTest.cpp - added test for validation of content data type
* lib/broker/BrokerAdapter.cpp - initial unbind implementation
* lib/common/framing/FramingContent.cpp - minor code cleanup
........
r497963 | aconway | 2007-01-19 16:33:27 -0500 (Fri, 19 Jan 2007) | 12 lines
Last big refactoring for 0-9 framing. Still need additional tests &
debugging but the overall structure is all in place.
* configure.ac: Added -Wno_virtual_overload warning
* ChannelTest.cpp, MessageBuilderTest.cpp: Fixed virtual overload warnings.
* ChannelAdapter.cpp: Common base for client/broker adapters.
Creates invocation context, handles request/resposne IDs.
* CppGenerator.java:
- Proxies send methods using MethodContext.
* Various .h files: removed unnecessary #includes, added to requred .cpp files.
* ConnectionContext: renamed from SessionContext.
........
r498646 | aconway | 2007-01-22 10:20:54 -0500 (Mon, 22 Jan 2007) | 4 lines
* AMQRequestBody.cpp: encode/decode bug - added missing reserved 4 byte word.
* BrokerSingleton: allow broker to run in-process.
* RequestResponseTest: skeleton test for request-response round-trip.
........
r498662 | gsim | 2007-01-22 10:53:15 -0500 (Mon, 22 Jan 2007) | 3 lines
Updated size calculation of request frame.
........
r498706 | aconway | 2007-01-22 12:10:25 -0500 (Mon, 22 Jan 2007) | 2 lines
* Fixed request-response correlation on the broker.
........
r499332 | gsim | 2007-01-24 05:04:31 -0500 (Wed, 24 Jan 2007) | 3 lines
Don't close channel on connection (resulting in BrokerAdapter being deleted) until close request has been successfully sent.
........
r499353 | gsim | 2007-01-24 05:54:43 -0500 (Wed, 24 Jan 2007) | 3 lines
use same name for pid file as start_broker
........
r501087 | aconway | 2007-01-29 11:13:24 -0500 (Mon, 29 Jan 2007) | 12 lines
* Added ClientAdapter - client side ChannelAdapter. Updated client side.
* Moved ChannelAdapter initialization from ctor to init(), updated broker side.
* Improved various exception messages with boost::format messages.
* Removed unnecssary virtual inheritance.
* Widespread: fixed incorrect non-const ProtocolVersion& parameters.
* Client API: pass channels by reference, not pointer.
* codegen:
- MethodBodyClass.h.templ: Added CLASS_ID, METHOD_ID and isA() template.
- Various: fixed non-const ProtocolVersion& parameters.
* cpp/bootstrap: Allow config arguments with -build.
* cpp/gen/Makefile.am: Merged codegen fixes from trunk.
........
r501502 | aconway | 2007-01-30 13:20:00 -0500 (Tue, 30 Jan 2007) | 11 lines
* client/* framing/*: fixed client-side request ID processing.
* cpp/tests/InProcessBroker.h: For tests: connect to an in-process
broker directly, bypass the network. Keeps log of client/broker
conversation for verification in test code.
* cpp/tests/FramingTest.cpp (testRequestResponseRoundtrip):
Client/broker round-trip test for request/reponse IDs and response mark.
* APRAcceptor.cpp (APRAcceptor): fixed valgrind uninitialized error.
........
r501534 | aconway | 2007-01-30 15:07:41 -0500 (Tue, 30 Jan 2007) | 22 lines
Andrew Stitcher <as...@redhat.com>
r723@fuschia: andrew | 2007-01-12 00:35:16 +0000
Branch for my work on Qpid.0-9
r724@fuschia: andrew | 2007-01-12 00:59:28 +0000
Added in empty implementation of handler class for protocol Message class
r768@fuschia: andrew | 2007-01-17 01:25:16 +0000
* Added Test for new MessageHandlerImpl (but no actual tests yet)
* Filled in lots of the blanks in the MessageHandlerImpl with code
stolen from the BasicHandlerImpl
r800@fuschia: andrew | 2007-01-17 17:34:13 +0000
Updated to latest upstream changes
r840@fuschia: andrew | 2007-01-19 00:31:59 +0000
Fixed merge errors
r841@fuschia: andrew | 2007-01-19 00:47:29 +0000
Another merge problem fixed
r878@fuschia: andrew | 2007-01-24 11:27:48 +0000
Started work on the Message class handler implementation
r976@fuschia: andrew | 2007-01-30 17:05:05 +0000
Working again after broker Message refactor
r980@fuschia: andrew | 2007-01-30 18:39:18 +0000
Fix for extra parameter to transfer
........
r501638 | aconway | 2007-01-30 18:25:56 -0500 (Tue, 30 Jan 2007) | 7 lines
* cpp/lib/broker/Broker.cpp: Defer creation of acceptor till needed so
InProcessBroker will not listen on any port.
* cpp/lib/broker/BrokerAdapter,Connection.cpp,.h: Encapsulate public data
members.
........
r501895 | aconway | 2007-01-31 11:51:42 -0500 (Wed, 31 Jan 2007) | 4 lines
* broker/Broker.cpp: Don't create Acceptor in shutdown() - required so
InProcessBroker does not attempt to bind.
........
r501948 | aconway | 2007-01-31 14:07:04 -0500 (Wed, 31 Jan 2007) | 13 lines
* framing/ChannelAdapter.cpp: Enable channel state assertions.
* common/Exception & others: Exception template constructors that
accept any object that supports ostream operator<< as messages.
E.g. can pass a boost::format object directly, no need to call str().
* Fixed up various exception messges to use boost::format.
* framing/Requester.cpp: Exception on invalid response id.
* client/Connection.h: Remove extra getVersion() function.
........
r501973 | aconway | 2007-01-31 15:17:14 -0500 (Wed, 31 Jan 2007) | 3 lines
Trivial FIXMEs.
........
r502038 | aconway | 2007-01-31 18:28:38 -0500 (Wed, 31 Jan 2007) | 27 lines
From Andrew Stitcher <as...@redhat.com>
r723@fuschia: andrew | 2007-01-12 00:35:16 +0000
Branch for my work on Qpid.0-9
r724@fuschia: andrew | 2007-01-12 00:59:28 +0000
Added in empty implementation of handler class for protocol Message class
r768@fuschia: andrew | 2007-01-17 01:25:16 +0000
* Added Test for new MessageHandlerImpl (but no actual tests yet)
* Filled in lots of the blanks in the MessageHandlerImpl with code
stolen from the BasicHandlerImpl
r800@fuschia: andrew | 2007-01-17 17:34:13 +0000
Updated to latest upstream changes
r840@fuschia: andrew | 2007-01-19 00:31:59 +0000
Fixed merge errors
r841@fuschia: andrew | 2007-01-19 00:47:29 +0000
Another merge problem fixed
r878@fuschia: andrew | 2007-01-24 11:27:48 +0000
Started work on the Message class handler implementation
r976@fuschia: andrew | 2007-01-30 17:05:05 +0000
Working again after broker Message refactor
r980@fuschia: andrew | 2007-01-30 18:39:18 +0000
Fix for extra parameter to transfer
r992@fuschia: andrew | 2007-01-31 18:29:57 +0000
Checkpoint of work on broker MessageMessage
r1001@fuschia: andrew | 2007-01-31 22:02:27 +0000
MessageMessage work now compiles
........
r502209 | astitcher | 2007-02-01 08:27:03 -0500 (Thu, 01 Feb 2007) | 2 lines
Changed methodBody in Methodcontext to be a shared_ptr
........
r502767 | aconway | 2007-02-02 17:03:10 -0500 (Fri, 02 Feb 2007) | 25 lines
* cpp/lib/common/framing/MethodContext.h: Reduced MethodContext to
ChannelAdapter and Method Body. Request ID comes from body,
ChannelAdapter is used to send frames, not OutputHandler.
* cpp/lib/common/framing/ChannelAdapter.h,.cpp: Removed context member.
Context is per-method not per-channel.
* cpp/lib/broker/*: Replace direct use of OutputHandler and ChannelId
with MethodContext (for responses) or ChannelAdapter (for requests.)
Use context request-ID to construct responses, send all bodies via
ChannelAdapter.
* cpp/lib/broker/BrokerAdapter.cpp: Link broker::Channel to BrokerAdapter.
* cpp/lib/broker/*: Remove unnecessary ProtocolVersion parameters.
Fix bogus signatures: ProtocolVersion* -> const ProtocolVersion&
* Cosmetic changes, many files:
- fixed indentation, broke long lines.
- removed unnecessary qpid:: prefixes.
* broker/BrokerAdapter,BrokerChannel: Merged BrokerAdapter into
broker::channel.
........
r503672 | aconway | 2007-02-05 08:20:42 -0500 (Mon, 05 Feb 2007) | 2 lines
File missed in last commit.
........
r504145 | astitcher | 2007-02-06 09:18:32 -0500 (Tue, 06 Feb 2007) | 5 lines
r768@fuschia: andrew | 2007-01-17 01:25:16 +0000
* Added Test for new MessageHandlerImpl (but no actual tests yet)
* Filled in lots of the blanks in the MessageHandlerImpl with code
stolen from the BasicHandlerImpl
........
r504146 | astitcher | 2007-02-06 09:18:46 -0500 (Tue, 06 Feb 2007) | 1 line
........
r504148 | astitcher | 2007-02-06 09:19:50 -0500 (Tue, 06 Feb 2007) | 3 lines
r800@fuschia: andrew | 2007-01-17 17:34:13 +0000
Updated to latest upstream changes
........
r504149 | astitcher | 2007-02-06 09:20:06 -0500 (Tue, 06 Feb 2007) | 1 line
........
r504150 | astitcher | 2007-02-06 09:20:21 -0500 (Tue, 06 Feb 2007) | 1 line
........
r504151 | astitcher | 2007-02-06 09:20:42 -0500 (Tue, 06 Feb 2007) | 1 line
........
r504152 | astitcher | 2007-02-06 09:21:02 -0500 (Tue, 06 Feb 2007) | 1 line
........
r504172 | aconway | 2007-02-06 10:01:45 -0500 (Tue, 06 Feb 2007) | 13 lines
* broker/Reference, tests/ReferenceTest: class representing a reference.
* broker/BrokerChannel.cpp (complete): get destination exchange from Message,
don't assume only one message in progress (could have multiple
references open.)
* broker/BrokerMessageMessage.cpp,.h: Contains transfer body and
vector of append bodies. Construct from Reference.
* broker/CompletionHandler.h: Extracted from BrokerMessage, used for
MessageMessage also.
* broker/ExchangeRegistry.cpp: Moved throw for missing exchanges to
registry.
* cpp/tests/start_broker: Increased wait time to 5 secs.
* cpp/tests/*: renamed DummyChannel as MockChannel.
........
r504182 | astitcher | 2007-02-06 10:53:33 -0500 (Tue, 06 Feb 2007) | 2 lines
Inline transferred messages delivered
........
r504305 | aconway | 2007-02-06 16:38:30 -0500 (Tue, 06 Feb 2007) | 19 lines
* cpp/lib/broker/BrokerQueue.cpp (): Centralized exceptions.
* cpp/lib/broker/BrokerAdapter.cpp (consume): Moved exceptions to Queue
* cpp/lib/broker/BrokerChannel.cpp (consume): Moved exceptions to Queue
* cpp/lib/broker/BrokerMessageBase.cpp:
- Added getApplicationHeaders.
* cpp/lib/broker/BrokerMessageMessage.cpp:
- Fixed exchangeName/destination mix up.
- Removed redundant constructor.
- Added getApplicationHeaders
* cpp/lib/broker/MessageHandlerImpl.cpp:
- Added missing acknowledgements
- Replaced assert(0) with throw "unimplemented".
- Moved exchange existence exceptions to ExchangeRegistry
- Handle transfers with references.
* cpp/tests/Makefile.am (check): Don't run tests unless all libs built OK.
* cpp/tests/python_tests: Re-enabled python tests. Not all passing.
* python/tests/message.py (MessageTests.test_get): Replace get-ok with ok.
........
r504485 | aconway | 2007-02-07 05:13:41 -0500 (Wed, 07 Feb 2007) | 10 lines
* broker/BrokerMessage.cpp: Added ConnectionToken publisher.
* cpp/lib/broker/BrokerMessageMessage.cpp:
- Added ConnectionToken publisher.
- Implemented getDeliveryMode, getApplicationHeaders
* cpp/lib/broker/Reference.cpp: Holds MessageMessage instead of just
MessageTransferBody.
........
r504603 | astitcher | 2007-02-07 11:15:58 -0500 (Wed, 07 Feb 2007) | 25 lines
r840@fuschia: andrew | 2007-01-19 00:31:59 +0000
Fixed merge errors
r841@fuschia: andrew | 2007-01-19 00:47:29 +0000
Another merge problem fixed
r878@fuschia: andrew | 2007-01-24 11:27:48 +0000
Started work on the Message class handler implementation
r976@fuschia: andrew | 2007-01-30 17:05:05 +0000
Working again after broker Message refactor
r980@fuschia: andrew | 2007-01-30 18:39:18 +0000
Fix for extra parameter to transfer
r992@fuschia: andrew | 2007-01-31 18:29:57 +0000
Checkpoint of work on broker MessageMessage
r1001@fuschia: andrew | 2007-01-31 22:02:27 +0000
MessageMessage work now compiles
r1071@fuschia: andrew | 2007-02-06 14:14:30 +0000
Implemented outgoing Message.Transfer so that messages are now delivered
- Still to do: correctly process the Message.Ok acknowledgements;
Message.Get etc.
r1081@fuschia: andrew | 2007-02-06 14:53:22 +0000
Fixed broken push
r1084@fuschia: andrew | 2007-02-06 15:48:20 +0000
Merge fixes
r1091@fuschia: andrew | 2007-02-07 16:15:27 +0000
Implement contentSize for inline content
........
r504703 | aconway | 2007-02-07 16:31:51 -0500 (Wed, 07 Feb 2007) | 2 lines
Removed out of date FIXME.
........
r504708 | aconway | 2007-02-07 16:59:22 -0500 (Wed, 07 Feb 2007) | 6 lines
* cpp/lib/broker/Content.h: removed destroy. Destructor cleans up.
* cpp/lib/broker/BrokerMessage.cpp: Removed Content::destroy call,
* cpp/lib/broker/InMemoryContent.cpp/.h: Remove empty destroy() and destructor.
* cpp/lib/broker/LazyLoadedContent.cpp/.h: Moved destroy() to destructor
........
r505108 | astitcher | 2007-02-08 19:52:46 -0500 (Thu, 08 Feb 2007) | 4 lines
r1102@fuschia: andrew | 2007-02-09 00:52:04 +0000
Got ack working for the non batched case
Small tidy up in broker Channel
........
r505139 | astitcher | 2007-02-08 21:16:03 -0500 (Thu, 08 Feb 2007) | 3 lines
r1104@fuschia: andrew | 2007-02-09 02:14:00 +0000
Initial implementation of Message.get delivery
........
r505291 | gsim | 2007-02-09 08:52:00 -0500 (Fri, 09 Feb 2007) | 3 lines
Fix to close connection when issuing a connection exception (ideally would wait a short while before doing so, but this is better than nothing for now).
........
r505298 | gsim | 2007-02-09 09:03:16 -0500 (Fri, 09 Feb 2007) | 3 lines
'Corrected' error code (507 no longer exists in the spec so using what java has i.e. 530).
........
r505360 | gsim | 2007-02-09 11:46:16 -0500 (Fri, 09 Feb 2007) | 3 lines
Handle invalid channels.
........
r506409 | gsim | 2007-02-12 05:52:55 -0500 (Mon, 12 Feb 2007) | 2 lines
Changed default virtual host to "" (was "/").
........
r506459 | gsim | 2007-02-12 09:26:01 -0500 (Mon, 12 Feb 2007) | 3 lines
Corrected calculation of inline content size.
........
r506823 | aconway | 2007-02-12 21:41:14 -0500 (Mon, 12 Feb 2007) | 25 lines
* gentools/templ.cpp/*Proxy*, CppGenerator.java: Changes to Proxy
classes to make them directly usable as an API for low-level AMQP access.
- Proxies hold reference to a ChannelAdapter not just an output handler.
- Removed MethodContext parameter, makes no sense on requester end.
- Return RequestId from request methods so caller can correlate
incoming responses.
- Add RequestId parameter to response methods so caller can provide
correlation for outgoing responses.
- No longer inherit from *Operations classes as the signatures no
longer match. Proxy is for caller (client/requester) and Operations
is for callee (server/responder)
* cpp/lib/client/ClientChannel.h: Channel provides a raw proxy to the broker.
Normal users will still use the Channel API to deal with the broker, but
advanced users (incl ourselves!) can use the raw API to directly send
and receive any AMQP message.
* cpp/lib/broker/BrokerChannel,BrokerAdapter: Refactor for new proxies.
broker::Channel is also a ClientProxy
* Sundry files:
- Pass ProtcolVersion by value, it is only two bytes.
- Misc. const correctness fixes.
........
r507249 | astitcher | 2007-02-13 16:52:30 -0500 (Tue, 13 Feb 2007) | 6 lines
r1111@fuschia: andrew | 2007-02-09 15:51:10 +0000
Removed currently unused request tracking logic
r1125@fuschia: andrew | 2007-02-13 21:51:30 +0000
Implemented receiveing batched Message.ok in c++ broker
Implemented batched response frames in python client code
........
r507560 | aconway | 2007-02-14 10:02:10 -0500 (Wed, 14 Feb 2007) | 13 lines
* cpp/lib/common/sys/ProducerConsumer.h:
General-purpose producer-consumer synchronization. Anywhere we have
producer/consumer threads in qpid we should re-use this sync object
rather than re-inventing the synchronization each time.
* cpp/lib/common/sys/AtomicCount.h: Separated ScopedIncrement/ScopedDecrement
into ScopedIncrement.h
* cpp/tests/InProcessBroker.h: Added class InProcessBrokerClient, a
self contained in-process client + broker convenience for tests.
........
r507602 | astitcher | 2007-02-14 11:22:38 -0500 (Wed, 14 Feb 2007) | 3 lines
r1127@fuschia: andrew | 2007-02-14 16:15:34 +0000
Fixed tests, and fixed an exposed bug
........
r507622 | gsim | 2007-02-14 11:58:52 -0500 (Wed, 14 Feb 2007) | 5 lines
Added durability property to queues and pass this to broker on declare. (This change also applied on trunk)
Minor update of accumulated ack and test.
........
r508156 | aconway | 2007-02-15 16:20:52 -0500 (Thu, 15 Feb 2007) | 2 lines
Constructor version argument defaults to highestProtocolVersion.
........
r508379 | gsim | 2007-02-16 07:26:11 -0500 (Fri, 16 Feb 2007) | 3 lines
Altered exception thrown for unopened and reopened references.
........
r508705 | aconway | 2007-02-16 22:46:44 -0500 (Fri, 16 Feb 2007) | 13 lines
* cpp/lib/client/ClientMessage.h/.cpp: Added Message constructor taking data.
* cpp/lib/client/IncomingMessage.cpp: Simplified message aggregation.
* cpp/lib/common/framing/AMQ*Body.h: remove unnecessary virtual inheritance.
* cpp/lib/common/framing/AMQMethodBody.h: add bool isRequest, isResponse
* cpp/lib/common/sys/Mutex.h (class ScopedUnlock): Added ScopedUnlock
* cpp/lib/common/sys/ThreadSafeQueue.h: Thread-safe queue template.
* cpp/tests/BrokerChannelTest.cpp: Renamed from ChannelTest.
* cpp/tests/ClientChannelTest.cpp: Test client API.
* cpp/tests/RequestResponseTest.cpp: Removed empty test.
* cpp/lib/client/Connection.h,.cpp:
- non-static channelIdCounter
- No close() in dtor.
........
r508706 | aconway | 2007-02-16 22:54:15 -0500 (Fri, 16 Feb 2007) | 2 lines
ClientChannel: removed server proxy, not used.
........
r509834 | astitcher | 2007-02-20 19:23:25 -0500 (Tue, 20 Feb 2007) | 5 lines
r1152@fuschia: andrew | 2007-02-17 21:14:42 +0000
More support for references (and transfers of reference content)
r1220@fuschia: andrew | 2007-02-21 00:22:53 +0000
Working version of delivering Message Transfers by reference
........
r510161 | aconway | 2007-02-21 14:25:45 -0500 (Wed, 21 Feb 2007) | 30 lines
Thread safety fixes for race conditions on incoming messages.
* cpp/lib/client/MessageListener.h: const correctness.
* cpp/tests/*: MessageListener const change.
* cpp/lib/broker/Content.h: Removed out-of-date FIXME comments.
* cpp/lib/client/ClientChannel.h/ .cpp():
- added locking for consumers map and other member access.
- refactored implementations of Basic get, deliver, return:
most logic now encapsulted in IncomingMessage class.
- fix channel close problems.
* cpp/lib/client/ClientMessage.h/.cpp:
- const correctness & API convenience fixes.
- getMethod/setMethod/getHeader: for new IncomingMessage
* cpp/lib/client/Connection.h/.cpp:
- Fixes to channel closure.
* cpp/lib/client/IncomingMessage.h/.cpp:
- Encapsulate *all* incoming message handling for client.
- Moved handling of BasicGetOk to IncomingMessage to fix race.
- Thread safety fixes.
* cpp/lib/client/ResponseHandler.h/.cpp:
- added getResponse for ClientChannel.
* cpp/lib/common/Exception.h:
- added missing throwSelf implementations.
- added ShutdownException as general purpose shut-down indicator.
- added EmptyException as general purpose "empty" indicator.
* cpp/lib/common/sys/Condition|Monitor|Mutex.h|.cpp:
- Condition variable abstraction extracted from Monitor for situations
where a single lock is associated with multiple conditions.
* cpp/tests/ClientChannelTest.cpp:
- Test incoming message transfer, get, consume etc.
........
r510180 | aconway | 2007-02-21 15:09:23 -0500 (Wed, 21 Feb 2007) | 2 lines
Fix spurious error message printed by client when broker closes connection.
........
r510553 | aconway | 2007-02-22 10:39:58 -0500 (Thu, 22 Feb 2007) | 2 lines
Added some more logging.
........
r510705 | aconway | 2007-02-22 18:23:52 -0500 (Thu, 22 Feb 2007) | 4 lines
* cpp/lib/client/Basic.*, ClientChannel.*: Extracted Basic functionality
from Channel into separate Basic class.
* cpp/lib/client/*, cpp/test/*: Adjusted for new Channel::getBasic() API.
........
r510986 | astitcher | 2007-02-23 10:41:28 -0500 (Fri, 23 Feb 2007) | 3 lines
r1237@fuschia: andrew | 2007-02-23 15:40:44 +0000
Bug in acks - Small typo fixed
........
r514751 | astitcher | 2007-03-05 13:01:22 -0500 (Mon, 05 Mar 2007) | 5 lines
r1239@fuschia: andrew | 2007-02-26 10:58:52 +0000
Refactored message transfer to extract commmonality from deliver/get
r1242@fuschia: andrew | 2007-03-05 17:54:44 +0000
Turn oversize inline transfers into reference transfers
........
r516157 | astitcher | 2007-03-08 14:43:09 -0500 (Thu, 08 Mar 2007) | 4 lines
r1278@fuschia: andrew | 2007-03-08 19:42:43 +0000
Correctly split reference messages into chunks shorter than
the framesize
........
r517929 | aconway | 2007-03-13 19:01:36 -0400 (Tue, 13 Mar 2007) | 1 line
Restore qpidc.spec.in, accidentally deleted during merge
........
r518258 | aconway | 2007-03-14 14:29:24 -0400 (Wed, 14 Mar 2007) | 1 line
cpp/tests/FramingTest.cpp: Updated for new default virtual host "/"
........
r518733 | aconway | 2007-03-15 15:22:02 -0400 (Thu, 15 Mar 2007) | 1 line
Changed u_int<n>_t to uint<n>_t for posix compliance.
........
r519146 | aconway | 2007-03-16 17:18:26 -0400 (Fri, 16 Mar 2007) | 1 line
Make --enable-valgrind the default, suppress all current leaks so we can see new ones. Fixing suppressed leaks is QPID-424.
........
Modified:
incubator/qpid/trunk/qpid/ (props changed)
Propchange: incubator/qpid/trunk/qpid/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.