Corrected Recordset Lock Sequence

aerospike · Jun 11, 2015 · 6ab37ae · 6ab37ae
1 parent d3842f2
commit 6ab37ae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/recordset.go b/recordset.go
@@ -132,9 +132,9 @@ func (rcs *Recordset) signalEnd() {
 }
 
 func (rcs *Recordset) sendError(err error) {
+	rcs.chanLock.Lock()
+	defer rcs.chanLock.Unlock()
 	if rcs.IsActive() {
-		rcs.chanLock.Lock()
-		defer rcs.chanLock.Unlock()
 		rcs.Errors <- err
 	}
 }