aboutsummaryrefslogtreecommitdiff
path: root/lib/gateway
diff options
context:
space:
mode:
authorAdelyn Breelove <[email protected]>2019-02-14 14:23:09 -0700
committerAdelyn Breelove <[email protected]>2019-02-14 14:23:09 -0700
commit4661400e174d54cb9383dc0066cb6c1063811115 (patch)
treea805b03a07e7bee6297366fd5caefbaa4ea837bd /lib/gateway
parentChange api of the set_status methods (diff)
downloaddisml-4661400e174d54cb9383dc0066cb6c1063811115.tar.xz
disml-4661400e174d54cb9383dc0066cb6c1063811115.zip
Fix shard close code log
Diffstat (limited to 'lib/gateway')
-rw-r--r--lib/gateway/sharder.ml4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/gateway/sharder.ml b/lib/gateway/sharder.ml
index 4317f80..4c5d23c 100644
--- a/lib/gateway/sharder.ml
+++ b/lib/gateway/sharder.ml
@@ -62,7 +62,7 @@ module Shard = struct
| Binary ->
if compress then `Ok (decompress s.content |> Yojson.Safe.from_string)
else `Error "Failed to decompress"
- | Close -> `Close s.extension
+ | Close -> `Close s.content
| op ->
let op = Frame.Opcode.to_string op in
`Error ("Unexpected opcode " ^ op)
@@ -312,7 +312,7 @@ let start ?count ?compress ?large_threshold () =
Shard.handle_frame ~f t.state >>| fun s ->
t.state <- s
| `Close c ->
- Logs.warn (fun m -> m "Close frame received. Code: %d" c);
+ Logs.warn (fun m -> m "Close frame received. Code: %s" c);
Shard.shutdown t
| `Error e ->
Logs.warn (fun m -> m "Websocket soft error: %s" e);