DirSync after .seen creation

diff --git a/src/toss.go b/src/toss.go
index f23b5836fe6374f53aefebdfdf6f95c5684519f4..6f91b43d799cf87100c96dc69deaf219cdd3aa8e 100644 (file)
--- a/src/toss.go
+++ b/src/toss.go
@@ -199,7 +199,18 @@ func jobProcess(
                if !dryRun && jobPath != "" {
                        if doSeen {
                                if fd, err := os.Create(jobPath + SeenSuffix); err == nil {
-                                       fd.Close() // #nosec G104
+                                       fd.Close()
+                                       if err = DirSync(filepath.Base(jobPath)); err != nil {
+                                               ctx.LogE("rx-dirsync", les, err, func(les LEs) string {
+                                                       return fmt.Sprintf(
+                                                               "Tossing file %s/%s (%s): %s: dirsyncing",
+                                                               sender.Name, pktName,
+                                                               humanize.IBytes(pktSize),
+                                                               filepath.Base(jobPath),
+                                                       )
+                                               })
+                                               return err
+                                       }
                                }
                        }
                        if err = os.Remove(jobPath); err != nil {
@@ -381,7 +392,18 @@ func jobProcess(
                        if jobPath != "" {
                                if doSeen {
                                        if fd, err := os.Create(jobPath + SeenSuffix); err == nil {
-                                               fd.Close() // #nosec G104
+                                               fd.Close()
+                                               if err = DirSync(filepath.Base(jobPath)); err != nil {
+                                                       ctx.LogE("rx-dirsync", les, err, func(les LEs) string {
+                                                               return fmt.Sprintf(
+                                                                       "Tossing file %s/%s (%s): %s: dirsyncing",
+                                                                       sender.Name, pktName,
+                                                                       humanize.IBytes(pktSize),
+                                                                       filepath.Base(jobPath),
+                                                               )
+                                                       })
+                                                       return err
+                                               }
                                        }
                                }
                                if err = os.Remove(jobPath); err != nil {
@@ -495,7 +517,18 @@ func jobProcess(
                        if jobPath != "" {
                                if doSeen {
                                        if fd, err := os.Create(jobPath + SeenSuffix); err == nil {
-                                               fd.Close() // #nosec G104
+                                               fd.Close()
+                                               if err = DirSync(filepath.Base(jobPath)); err != nil {
+                                                       ctx.LogE("rx-dirsync", les, err, func(les LEs) string {
+                                                               return fmt.Sprintf(
+                                                                       "Tossing file %s/%s (%s): %s: dirsyncing",
+                                                                       sender.Name, pktName,
+                                                                       humanize.IBytes(pktSize),
+                                                                       filepath.Base(jobPath),
+                                                               )
+                                                       })
+                                                       return err
+                                               }
                                        }
                                }
                                if err = os.Remove(jobPath); err != nil {
@@ -573,7 +606,18 @@ func jobProcess(
                if !dryRun && jobPath != "" {
                        if doSeen {
                                if fd, err := os.Create(jobPath + SeenSuffix); err == nil {
-                                       fd.Close() // #nosec G104
+                                       fd.Close()
+                                       if err = DirSync(filepath.Base(jobPath)); err != nil {
+                                               ctx.LogE("rx-dirsync", les, err, func(les LEs) string {
+                                                       return fmt.Sprintf(
+                                                               "Tossing file %s/%s (%s): %s: dirsyncing",
+                                                               sender.Name, pktName,
+                                                               humanize.IBytes(pktSize),
+                                                               filepath.Base(jobPath),
+                                                       )
+                                               })
+                                               return err
+                                       }
                                }
                        }
                        if err = os.Remove(jobPath); err != nil {