From 241de26b21eee31141839fc7a9705ffa1942c91f Mon Sep 17 00:00:00 2001 From: Adelyn Breelove Date: Fri, 1 Feb 2019 14:10:40 -0700 Subject: Opt to never force close unix fd before writer is flushed --- lib/sharder.ml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'lib/sharder.ml') diff --git a/lib/sharder.ml b/lib/sharder.ml index 0edb707..4e6cc46 100644 --- a/lib/sharder.ml +++ b/lib/sharder.ml @@ -282,7 +282,7 @@ module Shard = struct 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) + Writer.close ~force_close:(Deferred.never ()) (snd shard._internal) let recreate shard = shutdown_clean shard >>= fun () -> -- cgit v1.2.3