]> Cypherpunks.ru repositories - nncp.git/blobdiff - src/tmp.go
More errors checking
[nncp.git] / src / tmp.go
index 32c3fdba1aed68b16a39477c9f810a73646a7a5e..62ec5bbc9cbdd4d253858666c850168595ab3ba9 100644 (file)
@@ -74,9 +74,9 @@ func (ctx *Ctx) NewTmpFileWHash() (*TmpFileWHash, error) {
 }
 
 func (tmp *TmpFileWHash) Cancel() {
-       tmp.Fd.Truncate(0)
-       tmp.Fd.Close()
-       os.Remove(tmp.Fd.Name())
+       tmp.Fd.Truncate(0) // #nosec G104
+       tmp.Fd.Close() // #nosec G104
+       os.Remove(tmp.Fd.Name()) // #nosec G104
 }
 
 func DirSync(dirPath string) error {
@@ -86,7 +86,7 @@ func DirSync(dirPath string) error {
        }
        err = fd.Sync()
        if err != nil {
-               fd.Close()
+               fd.Close() // #nosec G104
                return err
        }
        return fd.Close()
@@ -98,15 +98,17 @@ func (tmp *TmpFileWHash) Commit(dir string) error {
                return err
        }
        if err = tmp.W.Flush(); err != nil {
-               tmp.Fd.Close()
+               tmp.Fd.Close() // #nosec G104
                return err
        }
        if err = tmp.Fd.Sync(); err != nil {
-               tmp.Fd.Close()
+               tmp.Fd.Close() // #nosec G104
                return err
        }
-       tmp.Fd.Close()
-       checksum := ToBase32(tmp.Hsh.Sum(nil))
+       if err = tmp.Fd.Close(); err != nil {
+               return err
+       }
+       checksum := Base32Codec.EncodeToString(tmp.Hsh.Sum(nil))
        tmp.ctx.LogD("tmp", SDS{"src": tmp.Fd.Name(), "dst": checksum}, "commit")
        if err = os.Rename(tmp.Fd.Name(), filepath.Join(dir, checksum)); err != nil {
                return err