NNCPNOSYNC environment variable

[nncp.git] / src / sp.go

diff --git a/src/sp.go b/src/sp.go
index e8e477cff9da8b5aa83b5ef75697142bd5c28cb8..772d92c4d729bb4fbec8ba066ae67a3438e45807 100644 (file)
--- 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)