From: Matt Joiner Date: Sat, 14 Nov 2020 11:57:19 +0000 (+1100) Subject: sqlite storage: Buffer write requests X-Git-Tag: v1.19.0~19 X-Git-Url: http://www.git.stargrave.org/?a=commitdiff_plain;h=258585fd8b911957bea2adfeeadb0c641324ddf6;p=btrtrc.git sqlite storage: Buffer write requests --- diff --git a/storage/sqlite/sqlite-storage.go b/storage/sqlite/sqlite-storage.go index 66d73a28..9933290e 100644 --- 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