diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2013-01-30 19:48:00 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2013-01-30 19:48:00 +0000 |
| commit | e23bf66c0d0ba9a322ab99e363d11fb7a302bb96 (patch) | |
| tree | 33e15c8da82d8bf459df9502417bf0f1c4bcb395 /cpp/src/qpid/sys/windows/AsynchIO.cpp | |
| parent | 686d2cd2454c6f8c718731824613e43fd690bb0d (diff) | |
| download | qpid-python-e23bf66c0d0ba9a322ab99e363d11fb7a302bb96.tar.gz | |
QPID-4514: Remove IO start/stop reading primitives used by removed cluster
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1440617 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/sys/windows/AsynchIO.cpp')
| -rw-r--r-- | cpp/src/qpid/sys/windows/AsynchIO.cpp | 17 |
1 files changed, 6 insertions, 11 deletions
diff --git a/cpp/src/qpid/sys/windows/AsynchIO.cpp b/cpp/src/qpid/sys/windows/AsynchIO.cpp index d8aa6efda7..b36ee9f941 100644 --- a/cpp/src/qpid/sys/windows/AsynchIO.cpp +++ b/cpp/src/qpid/sys/windows/AsynchIO.cpp @@ -286,8 +286,6 @@ public: virtual void notifyPendingWrite(); virtual void queueWriteClose(); virtual bool writeQueueEmpty(); - virtual void startReading(); - virtual void stopReading(); virtual void requestCallback(RequestCallback); /** @@ -347,6 +345,12 @@ private: void close(void); /** + * startReading initiates reading, readComplete() is + * called when the read completes. + */ + void startReading(); + + /** * readComplete is called when a read request is complete. * * @param result Results of the operation. @@ -565,15 +569,6 @@ void AsynchIO::startReading() { return; } -// stopReading was added to prevent a race condition with read-credit on Linux. -// It may or may not be required on windows. -// -// AsynchIOHandler::readbuff() calls stopReading() inside the same -// critical section that protects startReading() in -// AsynchIOHandler::giveReadCredit(). -// -void AsynchIO::stopReading() {} - // Queue the specified callback for invocation from an I/O thread. void AsynchIO::requestCallback(RequestCallback callback) { // This method is generally called from a processing thread; transfer |
