]> Cypherpunks.ru repositories - nncp.git/blobdiff - src/ctx.go
go fmt
[nncp.git] / src / ctx.go
index 58dba44df6156381216ee90e5043587d9b538039..9f18563bbb8c65f7cd051861f079267ec5139910 100644 (file)
@@ -74,14 +74,20 @@ func (ctx *Ctx) ensureRxDir(nodeId *NodeId) error {
        logMsg := func(les LEs) string {
                return fmt.Sprintf("Ensuring directory %s existence", dirPath)
        }
-       if err := os.MkdirAll(dirPath, os.FileMode(0777)); err != nil {
-               ctx.LogE("dir-ensure-mkdir", LEs{{"Dir", dirPath}}, err, logMsg)
-               return err
-       }
        fd, err := os.Open(dirPath)
        if err != nil {
-               ctx.LogE("dir-ensure-open", LEs{{"Dir", dirPath}}, err, logMsg)
-               return err
+               if !os.IsNotExist(err) {
+                       return err
+               }
+               if err := os.MkdirAll(dirPath, os.FileMode(0777)); err != nil {
+                       ctx.LogE("dir-ensure-mkdir", LEs{{"Dir", dirPath}}, err, logMsg)
+                       return err
+               }
+               fd, err = os.Open(dirPath)
+               if err != nil {
+                       ctx.LogE("dir-ensure-open", LEs{{"Dir", dirPath}}, err, logMsg)
+                       return err
+               }
        }
        return fd.Close()
 }