From 170f83e80c1382aa24b0d76181657ec899b66a25 Mon Sep 17 00:00:00 2001
From: Adelyn Breelove <tenseiken595@gmail.com>
Date: Wed, 30 Jan 2019 12:45:13 -0700
Subject: hotfix to writing on a closed pipe

---
 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 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)
-- 
cgit v1.2.3