diff --git a/ocaml/TaskServer.mli b/ocaml/TaskServer.mli index c492756d..e3801423 100644 --- a/ocaml/TaskServer.mli +++ b/ocaml/TaskServer.mli @@ -19,14 +19,14 @@ val debug_env : bool (** Print a debug message *) val debug : string -> unit -(** {1} ZMQ *) +(** {1} Zmq *) (** ZeroMQ context *) -val zmq_context : ZMQ.Context.t +val zmq_context : Zmq.Context.t -(** Bind a ZMQ socket to a TCP port and to an IPC file /tmp/qp_run. *) +(** Bind a Zmq socket to a TCP port and to an IPC file /tmp/qp_run. *) val bind_socket : - socket_type:string -> socket:'a ZMQ.Socket.t -> port:int -> unit + socket_type:string -> socket:'a Zmq.Socket.t -> port:int -> unit (** Name of the host on which the server runs *) val hostname : string lazy_t @@ -35,8 +35,8 @@ val hostname : string lazy_t val ip_address : string lazy_t (** Standard messages *) -val reply_ok : [> `Req ] ZMQ.Socket.t -> unit -val reply_wrong_state : [> `Req ] ZMQ.Socket.t -> unit +val reply_ok : [> `Req ] Zmq.Socket.t -> unit +val reply_wrong_state : [> `Req ] Zmq.Socket.t -> unit (** Stop server *) val stop : port:int -> unit @@ -44,34 +44,34 @@ val stop : port:int -> unit (** {1} Server functions *) (** Create a new job *) -val new_job : Message.Newjob_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> [> `Pair] ZMQ.Socket.t -> t +val new_job : Message.Newjob_msg.t -> t -> [> `Req ] Zmq.Socket.t -> [> `Pair] Zmq.Socket.t -> t (** Finish a running job *) -val end_job : Message.Endjob_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> [> `Pair] ZMQ.Socket.t -> t +val end_job : Message.Endjob_msg.t -> t -> [> `Req ] Zmq.Socket.t -> [> `Pair] Zmq.Socket.t -> t (** Connect a client *) -val connect: Message.Connect_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> t +val connect: Message.Connect_msg.t -> t -> [> `Req ] Zmq.Socket.t -> t (** Disconnect a client *) -val disconnect: Message.Disconnect_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> t +val disconnect: Message.Disconnect_msg.t -> t -> [> `Req ] Zmq.Socket.t -> t (** Add a task to the pool *) -val add_task: Message.AddTask_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> t +val add_task: Message.AddTask_msg.t -> t -> [> `Req ] Zmq.Socket.t -> t (** Mark the task as done by the client *) -val task_done: Message.TaskDone_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> t +val task_done: Message.TaskDone_msg.t -> t -> [> `Req ] Zmq.Socket.t -> t (** Delete a task when it has been pulled by the collector *) -val del_task: Message.DelTask_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> t +val del_task: Message.DelTask_msg.t -> t -> [> `Req ] Zmq.Socket.t -> t (** The client get a new task to execute *) -val get_task: Message.GetTask_msg.t -> t -> [> `Req ] ZMQ.Socket.t -> [> `Pair] ZMQ.Socket.t -> t +val get_task: Message.GetTask_msg.t -> t -> [> `Req ] Zmq.Socket.t -> [> `Pair] Zmq.Socket.t -> t (** Terminate server *) -val terminate : t -> [> `Req ] ZMQ.Socket.t -> t +val terminate : t -> [> `Req ] Zmq.Socket.t -> t (** Reply an Error message *) -val error : string -> t -> [> `Req ] ZMQ.Socket.t -> t +val error : string -> t -> [> `Req ] Zmq.Socket.t -> t (** Run server *) val run : port:int -> unit