X-Git-Url: http://www.git.cypherpunks.ru/?p=nncp.git;a=blobdiff_plain;f=src%2Ftoss.go;h=e383257db77c43e31ddd8127160276526376983e;hp=bdfcb31aad6d4ec44b0cc18dd17df32ce0ad4dde;hb=891cee4997bb0a269d4b2f35311bab104bdc3283;hpb=53b736c0d8998982b232e8f25d27753ea3a1e309 diff --git a/src/toss.go b/src/toss.go index bdfcb31..e383257 100644 --- a/src/toss.go +++ b/src/toss.go @@ -329,16 +329,18 @@ func jobProcess( }) return err } - if err = tmp.Sync(); err != nil { - tmp.Close() - ctx.LogE("rx-sync", les, err, func(les LEs) string { - return fmt.Sprintf( - "Tossing file %s/%s (%s): %s: syncing", - sender.Name, pktName, - humanize.IBytes(pktSize), dst, - ) - }) - return err + if !NoSync { + if err = tmp.Sync(); err != nil { + tmp.Close() + ctx.LogE("rx-sync", les, err, func(les LEs) string { + return fmt.Sprintf( + "Tossing file %s/%s (%s): %s: syncing", + sender.Name, pktName, + humanize.IBytes(pktSize), dst, + ) + }) + return err + } } if err = tmp.Close(); err != nil { ctx.LogE("rx-close", les, err, func(les LEs) string {