Skip to content

Commit 1c70845

Browse files
committed
Fixed deadlock
1 parent 63542b1 commit 1c70845

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

cursor.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ func (c *Cursor) Next(dest interface{}) bool {
156156
}
157157

158158
hasMore, err := c.loadNextLocked(dest)
159-
if c.handleError(err) != nil {
159+
if c.handleErrorLocked(err) != nil {
160160
c.mu.Unlock()
161161
c.Close()
162162
return false
@@ -404,7 +404,6 @@ func (c *Cursor) fetchMore() error {
404404
}
405405

406406
_, _, err = c.conn.Query(q)
407-
c.handleError(err)
408407
} else {
409408
c.mu.Unlock()
410409
}

0 commit comments

Comments
 (0)