X-Git-Url: http://www.git.cypherpunks.ru/?p=nncp.git;a=blobdiff_plain;f=src%2Fsp.go;h=772d92c4d729bb4fbec8ba066ae67a3438e45807;hp=e8e477cff9da8b5aa83b5ef75697142bd5c28cb8;hb=891cee4997bb0a269d4b2f35311bab104bdc3283;hpb=53b736c0d8998982b232e8f25d27753ea3a1e309 diff --git a/src/sp.go b/src/sp.go index e8e477c..772d92c 100644 --- a/src/sp.go +++ b/src/sp.go @@ -1461,13 +1461,15 @@ func (state *SPState) ProcessSP(payload []byte) ([][]byte, error) { humanize.IBytes(uint64(fullsize)), ) } - err = fd.Sync() - if err != nil { - state.Ctx.LogE("sp-file-sync", lesp, err, func(les LEs) string { - return logMsg(les) + ": syncing" - }) - state.closeFd(filePathPart) - continue + if !NoSync { + err = fd.Sync() + if err != nil { + state.Ctx.LogE("sp-file-sync", lesp, err, func(les LEs) string { + return logMsg(les) + ": syncing" + }) + state.closeFd(filePathPart) + continue + } } if hasherAndOffset != nil { delete(state.fileHashers, filePath)