projects
/
btrtrc.git
/ commitdiff
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
b0ebc85
)
sqlite storage: Buffer write requests
author
Matt Joiner <anacrolix@gmail.com>
Sat, 14 Nov 2020 11:57:19 +0000 (22:57 +1100)
committer
Matt Joiner <anacrolix@gmail.com>
Mon, 16 Nov 2020 05:37:11 +0000 (16:37 +1100)
storage/sqlite/sqlite-storage.go
patch
|
blob
|
history
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