Skip to content

Commit

Permalink
nsqd/nsqdmin: introspection of producer connections
Browse files Browse the repository at this point in the history
  • Loading branch information
sparklxb committed Apr 16, 2017
1 parent a3df076 commit f4e36a9
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions nsqd/nsqd.go
Original file line number Diff line number Diff line change
Expand Up @@ -216,15 +216,13 @@ func (n *NSQD) GetStartTime() time.Time {
// AddClient adds a client to the producers map
func (n *NSQD) AddClient(clientID int64, client Client) {
n.Lock()

n.clients[clientID] = client
n.Unlock()
}

// RemoveClient removes a client from the producers map
func (n *NSQD) RemoveClient(clientID int64) {
n.Lock()

_, ok := n.clients[clientID]
if !ok {
n.Unlock()
Expand Down

0 comments on commit f4e36a9

Please sign in to comment.