delta/python-packages/qpid-python.git/cpp/lib/broker/BrokerChannel.cpp, branch qpid.0-9

Changed u_int_t to uint_t for posix compliance.

2007-03-15T19:22:02+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@518733 13f79535-47bb-0310-9956-ffa450edef68

Merged revisions 496317 via svnmerge from

2007-03-13T20:14:31+00:00

https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid

........
  r496317 | aconway | 2007-01-15 08:58:07 -0500 (Mon, 15 Jan 2007) | 12 lines
  
  2006-12-08  Jim Meyering  
  
          Ensure that AccumulatedAck.range is not used uninitialized.
          * lib/broker/AccumulatedAck.h (AccumulatedAck): Make this a class,
          rather than a struct.
          (AccumulatedAck::AccumulatedAck): Add a constructor to require
          initialization of the "range" member.
          * lib/broker/BrokerChannel.cpp (Channel) [accumulatedAck]: Initialize.
          * tests/TxAckTest.cpp (TxAckTest) [acked]: Likewise.
          * tests/AccumulatedAckTest.cpp (testCovers): Initialize local.
          (testUpdateAndConsolidate): Likewise.
........


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@517849 13f79535-47bb-0310-9956-ffa450edef68

r1237@fuschia: andrew | 2007-02-23 15:40:44 +0000

2007-02-23T15:41:28+00:00

 Bug in acks - Small typo fixed


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510986 13f79535-47bb-0310-9956-ffa450edef68

* cpp/lib/common/sys/ProducerConsumer.h:

2007-02-14T15:02:10+00:00

  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.


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507560 13f79535-47bb-0310-9956-ffa450edef68

r1111@fuschia: andrew | 2007-02-09 15:51:10 +0000

2007-02-13T21:52:30+00:00

 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


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507249 13f79535-47bb-0310-9956-ffa450edef68

* gentools/templ.cpp/Proxy, CppGenerator.java: Changes to Proxy

2007-02-13T02:41:14+00:00

  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.


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@506823 13f79535-47bb-0310-9956-ffa450edef68

Handle invalid channels.

2007-02-09T16:46:16+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@505360 13f79535-47bb-0310-9956-ffa450edef68

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).

2007-02-09T13:52:00+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@505291 13f79535-47bb-0310-9956-ffa450edef68

r1104@fuschia: andrew | 2007-02-09 02:14:00 +0000

2007-02-09T02:16:03+00:00

 Initial implementation of Message.get delivery


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@505139 13f79535-47bb-0310-9956-ffa450edef68

r1102@fuschia: andrew | 2007-02-09 00:52:04 +0000

2007-02-09T00:52:46+00:00

 Got ack working for the non batched case
 Small tidy up in broker Channel


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@505108 13f79535-47bb-0310-9956-ffa450edef68