diff options
author | Yasuhiro Matsumoto <mattn.jp@gmail.com> | 2017-01-03 22:25:02 +0900 |
---|---|---|
committer | Yasuhiro Matsumoto <mattn.jp@gmail.com> | 2017-01-03 22:25:02 +0900 |
commit | 6f2749a3ca9b233ffb8749ef9684f7f4d88cee7a (patch) | |
tree | 99f07d970ea8184870d4cd167c7a27b505049621 | |
parent | temporary fix BeginTx (diff) | |
download | golite-6f2749a3ca9b233ffb8749ef9684f7f4d88cee7a.tar.gz golite-6f2749a3ca9b233ffb8749ef9684f7f4d88cee7a.tar.xz |
fix race condition
-rw-r--r-- | sqlite3.go | 6 |
1 files changed, 3 insertions, 3 deletions
@@ -808,13 +808,13 @@ func (s *SQLiteStmt) exec(ctx context.Context, args []namedValue) (driver.Result done := make(chan struct{}) defer close(done) - go func() { + go func(db *C.sqlite3) { select { case <-ctx.Done(): - C.sqlite3_interrupt(s.c.db) + C.sqlite3_interrupt(db) case <-done: } - }() + }(s.c.db) var rowid, changes C.longlong rv := C._sqlite3_step(s.s, &rowid, &changes) |