diff options
| author | Adelyn Breelove <[email protected]> | 2019-01-30 12:45:13 -0700 |
|---|---|---|
| committer | Adelyn Breelove <[email protected]> | 2019-01-30 12:45:13 -0700 |
| commit | 170f83e80c1382aa24b0d76181657ec899b66a25 (patch) | |
| tree | 42f708e35f1797f43bb3f7ecbb5d89438c43e855 | |
| parent | Add a dummy job that will be used later (diff) | |
| download | disml-170f83e80c1382aa24b0d76181657ec899b66a25.tar.xz disml-170f83e80c1382aa24b0d76181657ec899b66a25.zip | |
hotfix to writing on a closed pipe
| -rw-r--r-- | lib/sharder.ml | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/sharder.ml b/lib/sharder.ml index e14b55b..0edb707 100644 --- a/lib/sharder.ml +++ b/lib/sharder.ml @@ -279,7 +279,7 @@ module Shard = struct let shutdown_clean shard =
Logs.debug (fun m -> m "Performing clean shutdown. Shard [%d, %d]" (fst shard.id) (snd shard.id));
- Pipe.write (snd shard.pipe) (Frame.create ~opcode:Frame.Opcode.Close ~final:true ())
+ Pipe.write_if_open (snd shard.pipe) (Frame.create ~opcode:Frame.Opcode.Close ~final:true ())
>>= fun _ ->
Ivar.fill shard.hb_stopper ();
Writer.close (snd shard._internal)
|