From 2e76d2a6763260401c4ad168f3eb4f8416573fce Mon Sep 17 00:00:00 2001 From: Adelyn Breedlove Date: Tue, 29 Jan 2019 17:18:49 -0700 Subject: Better shard shutdown and HTTP error logging --- lib/sharder.ml | 2 ++ 1 file changed, 2 insertions(+) (limited to 'lib/sharder.ml') 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 -- cgit v1.2.3