We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 20a51a3 commit 8b3129cCopy full SHA for 8b3129c
vfs/memdb/memdb.go
@@ -223,7 +223,7 @@ func (m *memFile) Lock(lock vfs.LockLevel) error {
223
m.reserved = true
224
225
case vfs.LOCK_EXCLUSIVE:
226
- if m.lock < vfs.LOCK_PENDING {
+ if m.lock == vfs.LOCK_RESERVED {
227
m.lock = vfs.LOCK_PENDING
228
m.pending = true
229
}
vfs/mvcc/mvcc.go
@@ -287,7 +287,9 @@ func (m *mvccFile) Unlock(lock vfs.LockLevel) error {
287
// Relase ownership, commit changes.
288
if m.owner == m {
289
m.owner = nil
290
- m.mvccDB.data = m.data
+ if m.lock == vfs.LOCK_EXCLUSIVE {
291
+ m.mvccDB.data = m.data
292
+ }
293
if m.waiter != nil {
294
m.waiter.Broadcast()
295
0 commit comments