added channel close

This commit is contained in:
ston1th 2022-10-08 10:40:28 +02:00
commit f0af1fb04d

View file

@ -377,7 +377,10 @@ func (md *Metadata) Close() (err error) {
func (md *Metadata) close() (err error) { func (md *Metadata) close() (err error) {
md.cancel() md.cancel()
md.wc = nil if md.wc != nil {
close(md.wc)
md.wc = nil
}
if md.f != nil { if md.f != nil {
md.f.Sync() md.f.Sync()
err = md.f.Close() err = md.f.Close()