delta/python-packages/qpid-python.git/cpp/lib/common, branch client_restructure

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 497439 via svnmerge from

2007-03-13T21:23:20+00:00

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

........
  r497439 | gsim | 2007-01-18 09:14:54 -0500 (Thu, 18 Jan 2007) | 3 lines
  
  Added the non-standard 'binary' type to the field table implementation to support the java client.
........


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

Merged revisions 497341 via svnmerge from

2007-03-13T20:39:05+00:00

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

........
  r497341 | gsim | 2007-01-18 03:11:12 -0500 (Thu, 18 Jan 2007) | 3 lines
  
  Close connection when connection.close is sent to client.
........


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

Merged revisions 496678 via svnmerge from

2007-03-13T20:28:37+00:00

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

........
  r496678 | kpvdr | 2007-01-16 08:09:50 -0500 (Tue, 16 Jan 2007) | 1 line
  
  Fixed QPID-296 Header guards may not be compliant with C++ standard
........


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

Merged revisions 496665 via svnmerge from

2007-03-13T20:16:58+00:00

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

........
  r496665 | gsim | 2007-01-16 07:00:22 -0500 (Tue, 16 Jan 2007) | 3 lines
  
  Some basic additional error logging of framing errors. 
........


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

Merged revisions 492756 via svnmerge from

2007-03-09T17:57:40+00:00

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

........
  r492756 | kpvdr | 2007-01-04 16:30:39 -0500 (Thu, 04 Jan 2007) | 1 line
  
  Fixed C++ client sending protocol version 0-0 over the wire. Minor fixes and tidy-up in related code.
........


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

* cpp/lib/client/Basic., ClientChannel.: Extracted Basic functionality

2007-02-22T23:23:52+00:00

  from Channel into separate Basic class.
* cpp/lib/client/*, cpp/test/*: Adjusted for new Channel::getBasic() API.


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

Fix spurious error message printed by client when broker closes connection.

2007-02-21T20:09:23+00:00

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

Thread safety fixes for race conditions on incoming messages.

2007-02-21T19:25:45+00:00

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


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

* cpp/lib/client/ClientMessage.h/.cpp: Added Message constructor taking data.

2007-02-17T03:46:44+00:00

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


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