luxfi/zapdb
1
0
Fork 0
mirror of https://github.com/luxfi/zapdb.git synced 2026-07-26 22:46:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

added changes

Browse Source
This commit is contained in:
Harshil Goel
2025-07-03 22:06:04 +05:30
parent 20de0e80c0
commit 0f85160ac4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
db.go
+3 -3
View File
@@ -923,7 +923,7 @@ func (db *DB) doWrites(lc *z.Closer) {
reqLen := new(expvar.Int)
y.PendingWritesSet(db.opt.MetricsEnabled, db.opt.Dir, reqLen)
reqs := make([]*request, 0, 10)
reqs := make([]*request, 0, 5)
for {
var r *request
select {
@@ -936,7 +936,7 @@ func (db *DB) doWrites(lc *z.Closer) {
reqs = append(reqs, r)
reqLen.Set(int64(len(reqs)))
if len(reqs) >= 3*kvWriteChCapacity {
if len(reqs) >= 5 {
pendingCh <- struct{}{} // blocking.
goto writeCase
}
@@ -967,7 +967,7 @@ func (db *DB) doWrites(lc *z.Closer) {
writeCase:
go writeRequests(reqs)
reqs = make([]*request, 0, 10)
reqs = make([]*request, 0, 5)
reqLen.Set(0)
}
}