summaryrefslogtreecommitdiff
path: root/src/kahn_pipe.ml
diff options
context:
space:
mode:
authorAlex AUVOLAT <alex.auvolat@ens.fr>2014-05-25 01:00:44 +0200
committerAlex AUVOLAT <alex.auvolat@ens.fr>2014-05-25 01:00:44 +0200
commit4a5ca97b0970e191332fb6fb4684a397b93390f5 (patch)
treeb833cd9bf8f21514f5c0ae2ece473ac398aff251 /src/kahn_pipe.ml
parent6e750a757ef6fb1f41cf4c2fe39edba834b76858 (diff)
downloadSystemeReseaux-Projet-4a5ca97b0970e191332fb6fb4684a397b93390f5.tar.gz
SystemeReseaux-Projet-4a5ca97b0970e191332fb6fb4684a397b93390f5.zip
./manager -pool-addr mypool -pool-count 16 -my-addr my_addr ./example.native
Diffstat (limited to 'src/kahn_pipe.ml')
-rw-r--r--src/kahn_pipe.ml3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/kahn_pipe.ml b/src/kahn_pipe.ml
index 9f3da0a..2df8bc5 100644
--- a/src/kahn_pipe.ml
+++ b/src/kahn_pipe.ml
@@ -18,6 +18,8 @@ module Pipe: S = struct
fun () ->
Marshal.to_channel c x [];
flush c
+
+ let output s = Format.printf "%s@?" s
let try_get block prt_list =
let fds = List.map fst prt_list in
@@ -52,7 +54,6 @@ module Pipe: S = struct
let bind e f =
fun () -> f (e ()) ()
- let bind_io = bind
let run p =
p()