From dbd8b4a1d88ee4e3f1269db8022beaaf7be8e44e Mon Sep 17 00:00:00 2001 From: ngaut Date: Fri, 18 Dec 2015 10:00:17 +0800 Subject: [PATCH] Address comments --- store/localstore/kv.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/store/localstore/kv.go b/store/localstore/kv.go index f40cbac2ef..ac684932f8 100644 --- a/store/localstore/kv.go +++ b/store/localstore/kv.go @@ -35,6 +35,10 @@ const ( opCommit ) +const ( + maxSeekWorkers = 3 +) + type command struct { op op txn *dbTxn @@ -128,7 +132,7 @@ func (s *dbStore) seekWorker(seekCh chan *command) { func (s *dbStore) scheduler() { closed := false seekCh := make(chan *command, 1000) - for i := 0; i < 3; i++ { + for i := 0; i < maxSeekWorkers; i++ { go s.seekWorker(seekCh) } @@ -361,7 +365,6 @@ func (s *dbStore) Begin() (kv.Transaction, error) { return nil, errors.Trace(err) } - // todo: send to chan txn := &dbTxn{ tid: beginVer.Ver, valid: true,