diff options
Diffstat (limited to 'lib')
| -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)
|