Initial support for breaking the "do all queued I/Os" loop.

diff --git a/src/DiskIO/IpcIo/IpcIoFile.h b/src/DiskIO/IpcIo/IpcIoFile.h
index f116f98ff7fb8a1a26ee3df4a9f8112b4247028a..e5915c1fc7cca496f7fe8314cc2062a2ad0fb26b 100644 (file)
--- a/src/DiskIO/IpcIo/IpcIoFile.h
+++ b/src/DiskIO/IpcIo/IpcIoFile.h
@@ -93,6 +93,7 @@ private:
     static void HandleResponses(const char *const when);
     void handleResponse(IpcIoMsg &ipcIo);
 
+    static void DiskerHandleMoreRequests(void*);
     static void DiskerHandleRequests();
     static void DiskerHandleRequest(const int workerId, IpcIoMsg &ipcIo);
 
@@ -125,6 +126,9 @@ private:
     typedef Ipc::FewToFewBiQueue Queue;
     static std::auto_ptr<Queue> queue; ///< IPC queue
 
+    /// whether we are waiting for an event to handle still queued I/O requests
+    static bool DiskerHandleMoreRequestsScheduled;
+
     CBDATA_CLASS2(IpcIoFile);
 };