Skip to content

Commit ea100b2

Browse files
Merge pull request #2 from segmentio/fix-race
Ensure that SqliteStmt.closed property is guarded.
2 parents be424d2 + c1afc64 commit ea100b2

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sqlite3.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1912,11 +1912,11 @@ func (rc *SQLiteRows) DeclTypes() []string {
19121912

19131913
// Next move cursor to next.
19141914
func (rc *SQLiteRows) Next(dest []driver.Value) error {
1915+
rc.s.mu.Lock()
1916+
defer rc.s.mu.Unlock()
19151917
if rc.s.closed {
19161918
return io.EOF
19171919
}
1918-
rc.s.mu.Lock()
1919-
defer rc.s.mu.Unlock()
19201920
rv := C.sqlite3_step(rc.s.s)
19211921
if rv == C.SQLITE_DONE {
19221922
return io.EOF

0 commit comments

Comments
 (0)