delta/python-packages/qpid-python.git/cpp/src/qpid/sys/Dispatcher.cpp, branch qpid.0-10

QPID-1040: Patch from Ted Ross: Asynchronous Connector

2008-05-09T02:00:04+00:00

Code to allow non-blocking connection of new sockets


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@654666 13f79535-47bb-0310-9956-ffa450edef68

- Eliminated a race condition on deletion of PollerHandles

2007-11-29T11:34:15+00:00

* Added DeletionManager class to delete handles
* Used to stop PollerHandles being deleted whilst still in use


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599390 13f79535-47bb-0310-9956-ffa450edef68

Removed obsolete comment

2007-11-28T10:23:07+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@598939 13f79535-47bb-0310-9956-ffa450edef68

Improved Fix for the race condition where you've got a competing read and write

2007-11-08T17:45:54+00:00

for the same handle. This can happen if we've just got a read event then before 
handling it we watch for write events and get one immediately.


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593237 13f79535-47bb-0310-9956-ffa450edef68

Temporary fix to issue that results in an assertion from Dispatcher.cpp. Where an interest in write is signalled just as a readable event is triggered it is possible for a writeable (or read-writeable) event to be triggered before the earlier event is processed. This change ensures they are processed serially by queueing them up for the first thread to handle.

2007-11-06T16:45:30+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592485 13f79535-47bb-0310-9956-ffa450edef68

Fix client side core dump when disconneced unexpectedly:

2007-10-31T14:50:58+00:00

 void qpid::client::SessionCore::invariant() const: Assertion

Minor items:
src/qpid/broker/Queue.cpp: info log for each message dispatched.  
src/qpid/broker/SessionHandler.cpp: check attached in handleOut()
src/qpid/sys/Dispatcher.cpp: use polymorphic_downcast to catch cast errors in debug builds.
src/qpid/client/SessionCore.cpp: fix incorrect asserts
src/qpid/client/Message.h: convenience constructor parameters


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@590688 13f79535-47bb-0310-9956-ffa450edef68

* Asynchronous network IO subsystem

2007-07-27T17:19:30+00:00

- This is now implemented such that it very nearly only depends on the platform
  code (Socker & Poller), this is not 100% true at present, but should be simple
  to finish.
- This is still not the default (use "./configure --disable-apr-netio" to get it)
- Interrupting the broker gives a known error
- Default for number of broker io threads is not correct (needs to be number of CPUs -
  it will run slower with too many io threads)

* EventChannel code
- Deleted all EventChannel code as it's entirely superceded by this new shiny code ;-)

* Rearranged the platform Socket implementations a bit for better abstraction


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@560323 13f79535-47bb-0310-9956-ffa450edef68

* Add libuuid to libcommon link (for when apr goes away)

2007-07-12T01:48:13+00:00

* Latest version of AsynchIO code



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@555455 13f79535-47bb-0310-9956-ffa450edef68

* More work on asychronous network IO

2007-06-29T18:56:11+00:00

* Fix of current EventQueue code to carry on compiling


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@552001 13f79535-47bb-0310-9956-ffa450edef68

Intermediate checkin with preliminary work on epoll based net IO

2007-06-18T12:11:32+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@548337 13f79535-47bb-0310-9956-ffa450edef68