mirror of
https://github.com/drakkan/sftpgo.git
synced 2024-11-22 07:30:25 +00:00
sftpd transfer: close the file before executing any action ...
... that could potentially move or delete it
This commit is contained in:
parent
6a6e31cceb
commit
25f7043fb3
1 changed files with 2 additions and 1 deletions
|
@ -47,6 +47,7 @@ func (t *Transfer) WriteAt(p []byte, off int64) (n int, err error) {
|
||||||
|
|
||||||
// Close method called when the transfer is completed, we log the transfer info
|
// Close method called when the transfer is completed, we log the transfer info
|
||||||
func (t *Transfer) Close() error {
|
func (t *Transfer) Close() error {
|
||||||
|
err := t.file.Close()
|
||||||
elapsed := time.Since(t.start).Nanoseconds() / 1000000
|
elapsed := time.Since(t.start).Nanoseconds() / 1000000
|
||||||
if t.transferType == transferDownload {
|
if t.transferType == transferDownload {
|
||||||
logger.TransferLog(sftpdDownloadLogSender, t.path, elapsed, t.bytesSent, t.user.Username, t.connectionID)
|
logger.TransferLog(sftpdDownloadLogSender, t.path, elapsed, t.bytesSent, t.user.Username, t.connectionID)
|
||||||
|
@ -61,7 +62,7 @@ func (t *Transfer) Close() error {
|
||||||
numFiles++
|
numFiles++
|
||||||
dataprovider.UpdateUserQuota(dataProvider, t.user.Username, numFiles, t.bytesReceived, false)
|
dataprovider.UpdateUserQuota(dataProvider, t.user.Username, numFiles, t.bytesReceived, false)
|
||||||
}
|
}
|
||||||
return t.file.Close()
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *Transfer) handleThrottle() {
|
func (t *Transfer) handleThrottle() {
|
||||||
|
|
Loading…
Reference in a new issue