13 "crawshaw.io/sqlite/sqlitex"
14 _ "github.com/anacrolix/envpprof"
15 "github.com/stretchr/testify/assert"
16 "github.com/stretchr/testify/require"
19 func TestSimultaneousIncrementalBlob(t *testing.T) {
21 pool, err := sqlitex.Open(
22 // We don't do this in memory, because it seems to have some locking issues with updating
24 fmt.Sprintf("file:%s", filepath.Join(t.TempDir(), "sqlite3.db")),
25 // We can't disable WAL in this test because then we can't open 2 blobs simultaneously for read.
26 sqlite.OpenFlagsDefault, /* &^sqlite.SQLITE_OPEN_WAL */
28 require.NoError(t, err)
30 p, err := NewProviderPool(pool, poolSize, true)
31 require.NoError(t, err)
32 a, err := p.NewInstance("a")
33 require.NoError(t, err)
34 const contents = "hello, world"
35 require.NoError(t, a.Put(bytes.NewReader([]byte("hello, world"))))
37 require.NoError(t, err)
39 require.NoError(t, err)
43 doRead := func(b *[]byte, e *error, rc io.ReadCloser, n int) {
46 *b, *e = ioutil.ReadAll(rc)
47 require.NoError(t, *e, n)
48 assert.EqualValues(t, contents, *b)
51 go doRead(&b2, &e2, rc2, 2)
52 go doRead(&b1, &e1, rc1, 1)