storage/sqlite/sqlite-storage.go | 4 ++-- storage/sqlite/sqlite-storage_test.go | 3 ++- diff --git a/storage/sqlite/sqlite-storage.go b/storage/sqlite/sqlite-storage.go index 38f734fe5096f4d54a04d475620279dbf004800c..9eb97e85abceac600b67a41f251c8737be19e78f 100644 --- a/storage/sqlite/sqlite-storage.go +++ b/storage/sqlite/sqlite-storage.go @@ -252,7 +252,7 @@ } if opts.SetJournalMode == "" && !opts.Memory { opts.SetJournalMode = "wal" } - err = initPoolConns(nil, conns, opts.InitConnOpts) + err = initPoolConns(context.TODO(), conns, opts.InitConnOpts) if err != nil { conns.Close() return @@ -494,7 +494,7 @@ NumConns() int } func withPoolConn(pool ConnPool, with func(conn)) { - c := pool.Get(nil) + c := pool.Get(context.TODO()) defer pool.Put(c) with(c) } diff --git a/storage/sqlite/sqlite-storage_test.go b/storage/sqlite/sqlite-storage_test.go index 2494ce6d1a7602e925afa41cc95b2752a5a49c43..1fe1314ea3e1cc442f5045801864d2dfb2463701 100644 --- a/storage/sqlite/sqlite-storage_test.go +++ b/storage/sqlite/sqlite-storage_test.go @@ -5,6 +5,7 @@ package sqliteStorage import ( "bytes" + "context" "errors" "fmt" "io" @@ -34,7 +35,7 @@ qt.Assert(t, initPoolDatabase(pool, InitDbOpts{}), qt.IsNil) if !opts.Memory && opts.SetJournalMode == "" { opts.SetJournalMode = "wal" } - qt.Assert(t, initPoolConns(nil, pool, opts.InitConnOpts), qt.IsNil) + qt.Assert(t, initPoolConns(context.TODO(), pool, opts.InitConnOpts), qt.IsNil) prov, err := NewProvider(pool, ProviderOpts{BatchWrites: pool.NumConns() > 1}) require.NoError(t, err) t.Cleanup(func() { prov.Close() })