LCPQ/quantum_package
10
0
Fork 0
mirror of https://github.com/LCPQ/quantum_package synced 2024-12-25 13:53:49 +01:00
Code Issues Releases Wiki Activity

Merge branch 'LCPQ-master'

Browse Source
This commit is contained in:
Anthony Scemama 2018-05-09 12:23:08 +02:00
commit 29ce56067d
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
ocaml/TaskServer.mli
View File

@ -19,14 +19,14 @@ val debug_env : bool
(** Print a debug message *) (** Print a debug message *)
val debug : string -> unit val debug : string -> unit
(** {1} ZMQ *) (** {1} Zmq *)
(** ZeroMQ context *) (** 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.<port> *) (** Bind a Zmq socket to a TCP port and to an IPC file /tmp/qp_run.<port> *)
val bind_socket : 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 *) (** Name of the host on which the server runs *)
val hostname : string lazy_t val hostname : string lazy_t
@ -35,8 +35,8 @@ val hostname : string lazy_t
val ip_address : string lazy_t val ip_address : string lazy_t
(** Standard messages *) (** Standard messages *)
val reply_ok : [> `Req ] ZMQ.Socket.t -> unit val reply_ok : [> `Req ] Zmq.Socket.t -> unit
val reply_wrong_state : [> `Req ] ZMQ.Socket.t -> unit val reply_wrong_state : [> `Req ] Zmq.Socket.t -> unit
(** Stop server *) (** Stop server *)
val stop : port:int -> unit val stop : port:int -> unit
@ -44,34 +44,34 @@ val stop : port:int -> unit
(** {1} Server functions *) (** {1} Server functions *)
(** Create a new job *) (** 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 *) (** 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 *) (** 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 *) (** 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 *) (** 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 *) (** 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 *) (** 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 *) (** 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 *) (** Terminate server *)
val terminate : t -> [> `Req ] ZMQ.Socket.t -> t val terminate : t -> [> `Req ] Zmq.Socket.t -> t
(** Reply an Error message *) (** Reply an Error message *)
val error : string -> t -> [> `Req ] ZMQ.Socket.t -> t val error : string -> t -> [> `Req ] Zmq.Socket.t -> t
(** Run server *) (** Run server *)
val run : port:int -> unit val run : port:int -> unit