Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

update variable declaration location

Browse Source
This commit is contained in:
Wilson Wang
2021-05-03 10:19:33 -07:00
parent 8d8d0377a2
commit 56154216b7
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/mvcc/kvstore_txn.go
View File

@@ -35,11 +35,13 @@ type storeTxnRead struct {
} }
func (s *store) Read(mode ReadTxMode, trace *traceutil.Trace) TxnRead { func (s *store) Read(mode ReadTxMode, trace *traceutil.Trace) TxnRead {
var tx backend.ReadTx
s.mu.RLock() s.mu.RLock()
s.revMu.RLock() s.revMu.RLock()
// backend holds b.readTx.RLock() only when creating the concurrentReadTx. After // For read-only workloads, we use shared buffer by copying transaction read buffer
// ConcurrentReadTx is created, it will not block write transaction. // for higher concurrency with ongoing blocking writes.
// For write/write-read transactions, we use the shared buffer
// rather than duplicating transaction read buffer to avoid transaction overhead.
var tx backend.ReadTx
if mode == ConcurrentReadTxMode { if mode == ConcurrentReadTxMode {
tx = s.b.ConcurrentReadTx() tx = s.b.ConcurrentReadTx()
} else { } else {