package nbd

  1. Overview
  2. Docs

Parameters

module R : RPC

Signature

exception Unexpected_id of R.id
exception Shutdown
type client = {
  1. transport : R.transport;
  2. outgoing_mutex : Lwt_mutex.t;
  3. id_to_wakeup : (R.id, R.request_hdr * (R.response_hdr * R.response_body) Lwt.u) Hashtbl.t;
  4. mutable dispatcher_thread : unit Lwt.t;
  5. mutable dispatcher_shutting_down : bool;
}
val dispatcher : client -> unit Lwt.t
val create : R.transport -> client Lwt.t