Sync directories for rename assurance

[nncp.git] / src / toss.go

diff --git a/src/toss.go b/src/toss.go
index 586f378076746fb689338dd14f0df44b75fc7860..5bc8b7960b79b8d2e904405b1e1aacd7282672d8 100644 (file)
--- a/src/toss.go
+++ b/src/toss.go
@@ -261,6 +261,10 @@ func (ctx *Ctx) Toss(
                                        ctx.LogE("rx", SdsAdd(sds, SDS{"err": err}), "rename")
                                        isBad = true
                                }
+                               if err = DirSync(*incoming); err != nil {
+                                       ctx.LogE("rx", SdsAdd(sds, SDS{"err": err}), "sync")
+                                       isBad = true
+                               }
                                delete(sds, "tmp")
                        }
                        ctx.LogI("rx", sds, "")