commit
487639b2d8
11
wal/wal.go
11
wal/wal.go
|
@ -449,9 +449,14 @@ func (w *WAL) Close() error {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
for _, l := range w.locks {
|
for _, l := range w.locks {
|
||||||
// TODO: log the error
|
err := l.Unlock()
|
||||||
l.Unlock()
|
if err != nil {
|
||||||
l.Destroy()
|
plog.Errorf("failed to unlock during closing wal: %s", err)
|
||||||
|
}
|
||||||
|
err = l.Destroy()
|
||||||
|
if err != nil {
|
||||||
|
plog.Errorf("failed to destroy lock during closing wal: %s", err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue