We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dbaf3df commit 3d72685Copy full SHA for 3d72685
pkg/lockservice/lock_table_allocator.go
@@ -154,8 +154,8 @@ func (l *lockTableAllocator) Valid(
154
binds []pb.LockTable,
155
) ([]uint64, error) {
156
var invalid []uint64
157
- l.mu.RLock()
158
- defer l.mu.RUnlock()
+ l.mu.Lock()
+ defer l.mu.Unlock()
159
160
for _, b := range binds {
161
if !b.Valid {
@@ -210,8 +210,8 @@ func (l *lockTableAllocator) Close() error {
210
}
211
212
func (l *lockTableAllocator) GetLatest(groupID uint32, tableID uint64) pb.LockTable {
213
214
215
216
m := l.getLockTablesLocked(groupID)
217
if old, ok := m[tableID]; ok {
0 commit comments