diff options
| author | Adelyn Breedlove <[email protected]> | 2019-01-29 17:18:49 -0700 |
|---|---|---|
| committer | Adelyn Breedlove <[email protected]> | 2019-01-29 17:18:49 -0700 |
| commit | 2e76d2a6763260401c4ad168f3eb4f8416573fce (patch) | |
| tree | 5061bf3c65f11dfb8e6b55772f10f99ee0dbd2bf /lib/sharder.ml | |
| parent | Remove some silly internals (diff) | |
| download | disml-2e76d2a6763260401c4ad168f3eb4f8416573fce.tar.xz disml-2e76d2a6763260401c4ad168f3eb4f8416573fce.zip | |
Better shard shutdown and HTTP error logging
Diffstat (limited to 'lib/sharder.ml')
| -rw-r--r-- | lib/sharder.ml | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/sharder.ml b/lib/sharder.ml index 157967d..d4e6bd1 100644 --- a/lib/sharder.ml +++ b/lib/sharder.ml @@ -279,6 +279,8 @@ module Shard = struct let shutdown_clean shard =
let (_,w) = shard._internal in
+ Pipe.write (snd shard.pipe) (Frame.create ~opcode:(Frame.Opcode.Close) ~final:true ())
+ >>= fun _ ->
Ivar.fill shard.hb_stopper ();
Writer.close w
|