diff options
| author | Adelyn Breelove <[email protected]> | 2019-02-01 14:10:40 -0700 |
|---|---|---|
| committer | Adelyn Breelove <[email protected]> | 2019-02-01 14:10:40 -0700 |
| commit | 241de26b21eee31141839fc7a9705ffa1942c91f (patch) | |
| tree | dfd1b2c43b51755c9d96ba3cfdf4e801d1336e12 /lib | |
| parent | Minor updates (diff) | |
| download | disml-241de26b21eee31141839fc7a9705ffa1942c91f.tar.xz disml-241de26b21eee31141839fc7a9705ffa1942c91f.zip | |
Opt to never force close unix fd before writer is flushed
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 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 () ->
|