Skip to content

Commit

Permalink
make code more readable.
Browse files Browse the repository at this point in the history
  • Loading branch information
horizonzy committed Jan 19, 2022
1 parent 97d1f93 commit 282e4e6
Showing 1 changed file with 7 additions and 8 deletions.
15 changes: 7 additions & 8 deletions server/storage/schema/cindex.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ func ReadConsistentIndex(tx backend.ReadTx) (uint64, uint64) {

func UnsafeUpdateConsistentIndex(tx backend.BatchTx, index uint64, term uint64, onlyGrow bool) {
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
}

Expand All @@ -67,14 +67,13 @@ func UnsafeUpdateConsistentIndex(tx backend.BatchTx, index uint64, term uint64,
if term < oldTerm {
return
}
if term == oldTerm && index <= oldi {
return
if index > oldi {
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 {
bs2 := make([]byte, 8)
binary.BigEndian.PutUint64(bs2, term)
Expand Down

0 comments on commit 282e4e6

Please sign in to comment.