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

make code more readable.

Browse Source
This commit is contained in:
horizonzy 2022-01-19 22:24:49 +08:00
parent 97d1f935f6
commit 282e4e6e88
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server/storage/schema/cindex.go
View File

@ -58,7 +58,7 @@ func ReadConsistentIndex(tx backend.ReadTx) (uint64, uint64) {
func UnsafeUpdateConsistentIndex(tx backend.BatchTx, index uint64, term uint64, onlyGrow bool) { func UnsafeUpdateConsistentIndex(tx backend.BatchTx, index uint64, term uint64, onlyGrow bool) {
if index == 0 { if index == 0 {
// Never save 0 as it means that we didn't loaded the real index yet. // Never save 0 as it means that we didn't load the real index yet.
return return
} }
@ -67,14 +67,13 @@ func UnsafeUpdateConsistentIndex(tx backend.BatchTx, index uint64, term uint64,
if term < oldTerm { if term < oldTerm {
return return
} }
if term == oldTerm && index <= oldi { if index > oldi {
return bs1 := make([]byte, 8)
binary.BigEndian.PutUint64(bs1, index)
// put the index into the underlying backend
// tx has been locked in TxnBegin, so there is no need to lock it again
tx.UnsafePut(Meta, MetaConsistentIndexKeyName, bs1)
} }
bs1 := make([]byte, 8)
binary.BigEndian.PutUint64(bs1, index)
// put the index into the underlying backend
// tx has been locked in TxnBegin, so there is no need to lock it again
tx.UnsafePut(Meta, MetaConsistentIndexKeyName, bs1)
if term > 0 && term > oldTerm { if term > 0 && term > oldTerm {
bs2 := make([]byte, 8) bs2 := make([]byte, 8)
binary.BigEndian.PutUint64(bs2, term) binary.BigEndian.PutUint64(bs2, term)