fast path (Avoid defer) in normal msg.Fin case

nsqio · Mar 26, 2015 · a44589f · a44589f
1 parent 7fbbc6f
commit a44589f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/consumer.go b/consumer.go
@@ -756,10 +756,11 @@ func (r *Consumer) startStopContinueBackoff(conn *Conn, signal backoffSignal) {
 	// max backoff/normal rate (by ensuring that we dont continually incr/decr
 	// the counter during a backoff period)
 	r.backoffMtx.Lock()
-	defer r.backoffMtx.Unlock()
 	if r.inBackoffTimeout() {
+		r.backoffMtx.Unlock()
 		return
 	}
+	defer r.backoffMtx.Unlock()
 
 	// update backoff state
 	backoffUpdated := false