lib: added {big,page}_alloc_zero routines

[libucw.git] / lib / asio.h

diff --git a/lib/asio.h b/lib/asio.h
index 31c1f5ac490f69100032d9df24960979de6edb32..d17ee7ff5eef7bc62da3eb1aaba3ab2da7e233c6 100644 (file)
--- a/lib/asio.h
+++ b/lib/asio.h
@@ -19,18 +19,19 @@ struct asio_queue {
   uns buffer_size;                     // How large buffers do we use [user-settable]
   uns max_writebacks;                  // Maximum number of writeback requests active [user-settable]
   uns allocated_requests;
-  uns allocated_writebacks;
-  uns running_requests;
+  uns running_requests;                        // Total number of running requests
+  uns running_writebacks;              // How many of them are writebacks
   clist idle_list;                     // Recycled requests waiting for get
   clist done_list;                     // Finished requests
   struct work_queue queue;
+  uns use_count;                       // For use by the caller
 };
 
 enum asio_op {
   ASIO_FREE,
   ASIO_READ,
   ASIO_WRITE,
-  ASIO_WRITE_BACK,                     // Write with no success notification
+  ASIO_WRITE_BACK,                     // Background write with no success notification
 };
 
 struct asio_request {
@@ -42,14 +43,14 @@ struct asio_request {
   uns len;
   int status;
   int returned_errno;
+  int submitted;
+  void *user_data;                     // For use by the caller
 };
 
 void asio_init_queue(struct asio_queue *q);                    // Initialize a new queue
 void asio_cleanup_queue(struct asio_queue *q);
-struct asio_request *asio_get(struct asio_queue *q);           // Get an empty request (not for writeback)
-struct asio_request *asio_get_writeback(struct asio_queue *q); // Get an empty writeback request
-void asio_turn_to_writeback(struct asio_request *r);           // Convert a request allocated as non-writeback to writeback
-void asio_submit(struct asio_request *r);                      // Submit the request
+struct asio_request *asio_get(struct asio_queue *q);           // Get an empty request
+void asio_submit(struct asio_request *r);                      // Submit the request (can block if too many writebacks)
 struct asio_request *asio_wait(struct asio_queue *q);          // Wait for the first finished request, NULL if no more
 void asio_put(struct asio_request *r);                         // Return a finished request for recycling
 void asio_sync(struct asio_queue *q);                          // Wait until all requests are finished