From 6ed2a6924517cc502396ddce51c010c137084276 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Tue, 20 Nov 2012 15:03:03 -0800 Subject: [PATCH] Added fixme for queue sub perf --- server/client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/client.go b/server/client.go index b1ba2a54..87c09476 100644 --- a/server/client.go +++ b/server/client.go @@ -10,7 +10,6 @@ import ( "net" "sync" "time" -// "unsafe" "github.com/apcera/gnatsd/hashmap" ) @@ -344,6 +343,7 @@ func (c *client) processMsg(msg []byte) { for _, v := range r { sub := v.(*subscription) if sub.queue != nil { + // FIXME, this can be more efficient if qmap == nil { qmap = make(map[string][]*subscription) }