From 9a60bc13645c074d635bf2b591b792fccd2f2247 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Wed, 5 Aug 2015 06:39:11 -0700 Subject: [PATCH] Properly set pending --- server/monitor.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/monitor.go b/server/monitor.go index 58447860..b6fbd6d7 100644 --- a/server/monitor.go +++ b/server/monitor.go @@ -36,7 +36,7 @@ type ConnInfo struct { Cid uint64 `json:"cid"` IP string `json:"ip"` Port int `json:"port"` - Pending int `json:"pending_size"` + Pending int `json:"pending_bytes"` InMsgs int64 `json:"in_msgs"` OutMsgs int64 `json:"out_msgs"` InBytes int64 `json:"in_bytes"` @@ -117,6 +117,7 @@ func (s *Server) HandleConnz(w http.ResponseWriter, r *http.Request) { InBytes: client.inBytes, OutBytes: client.outBytes, NumSubs: client.subs.Count(), + Pending: client.bw.Buffered(), Lang: client.opts.Lang, Version: client.opts.Version, }