Skip to content

Commit 70249af

Browse files
committed
prevent "file already closed" errors
1 parent 2d26f89 commit 70249af

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

filereceiver.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,12 @@ func saveFile(path string, offset int64, length int64, r io.Reader, log log.Logg
152152
if err != nil {
153153
return 0, nil, err
154154
}
155-
defer logCloseFile(log, f)
155+
closed := false
156+
defer func() {
157+
if !closed {
158+
logCloseFile(log, f)
159+
}
160+
}()
156161
_, err = f.Seek(offset, io.SeekStart)
157162
if err != nil {
158163
return 0, nil, err
@@ -164,6 +169,7 @@ func saveFile(path string, offset int64, length int64, r io.Reader, log log.Logg
164169
return 0, nil, err
165170
}
166171
err = f.Close()
172+
closed = true
167173
if err != nil {
168174
return 0, nil, err
169175
}

0 commit comments

Comments
 (0)