From 258585fd8b911957bea2adfeeadb0c641324ddf6 Mon Sep 17 00:00:00 2001
From: Matt Joiner <anacrolix@gmail.com>
Date: Sat, 14 Nov 2020 22:57:19 +1100
Subject: [PATCH] sqlite storage: Buffer write requests
---
storage/sqlite/sqlite-storage.go | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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
--
2.51.0