sqlite storage: Buffer write requests

diff --git a/storage/sqlite/sqlite-storage.go b/storage/sqlite/sqlite-storage.go
index 66d73a28dec23b13450df0059a2129caeb93a8e0..9933290e3a5dc98c5e02aaba53a90a5aa08ea4fb 100644 (file)
--- a/storage/sqlite/sqlite-storage.go
+++ b/storage/sqlite/sqlite-storage.go
@@ -4,6 +4,7 @@ import (
        "bytes"
        "context"
        "errors"
+       "expvar"
        "fmt"
        "io"
        "log"
@@ -258,7 +259,7 @@ func NewProvider(pool ConnPool, opts ProviderOpts) (_ *provider, err error) {
        if err != nil {
                return
        }
-       writes := make(chan writeRequest)
+       writes := make(chan writeRequest, 1<<(20-14))
        prov := &provider{pool: pool, writes: writes, opts: opts}
        runtime.SetFinalizer(prov, func(p *provider) {
                // This is done in a finalizer, as it's easier than trying to synchronize on whether the