Merge pull request #10815 from jingyih/fix_RLock

mvcc/backend: use RLock in test
This commit is contained in:
Xiang Li 2019-06-11 23:10:12 -07:00 committed by GitHub
commit 0de9b8abf5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -241,9 +241,9 @@ func TestBackendWriteback(t *testing.T) {
} }
rtx := b.ReadTx() rtx := b.ReadTx()
for i, tt := range keys { for i, tt := range keys {
rtx.Lock() rtx.RLock()
k, v := rtx.UnsafeRange([]byte("key"), tt.key, tt.end, tt.limit) k, v := rtx.UnsafeRange([]byte("key"), tt.key, tt.end, tt.limit)
rtx.Unlock() rtx.RUnlock()
if !reflect.DeepEqual(tt.wkey, k) || !reflect.DeepEqual(tt.wval, v) { if !reflect.DeepEqual(tt.wkey, k) || !reflect.DeepEqual(tt.wval, v) {
t.Errorf("#%d: want k=%+v, v=%+v; got k=%+v, v=%+v", i, tt.wkey, tt.wval, k, v) t.Errorf("#%d: want k=%+v, v=%+v; got k=%+v, v=%+v", i, tt.wkey, tt.wval, k, v)
} }
@ -282,9 +282,9 @@ func TestBackendWritebackForEach(t *testing.T) {
return nil return nil
} }
rtx := b.ReadTx() rtx := b.ReadTx()
rtx.Lock() rtx.RLock()
rtx.UnsafeForEach([]byte("key"), getSeq) rtx.UnsafeForEach([]byte("key"), getSeq)
rtx.Unlock() rtx.RUnlock()
partialSeq := seq partialSeq := seq