gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Only increment server stats if available

Browse Source
This commit is contained in:
Derek Collison
2013-01-02 18:15:55 -06:00
parent 3977043780
commit 0a45c0bc5a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/client.go
View File

@@ -417,8 +417,10 @@ func (c *client) processMsg(msg []byte) {
c.inMsgs++
c.inBytes += int64(len(msg))
atomic.AddInt64(&c.srv.inMsgs, 1)
atomic.AddInt64(&c.srv.inBytes, int64(len(msg)))
if c.srv != nil {
atomic.AddInt64(&c.srv.inMsgs, 1)
atomic.AddInt64(&c.srv.inBytes, int64(len(msg)))
}
if trace {
c.traceMsg(msg)