]> Cypherpunks.ru repositories - nncp.git/blobdiff - src/lockdir.go
More errors checking
[nncp.git] / src / lockdir.go
index 38144eea6f5b8d73164dfc05388dd8841390446b..875a5bbde49979fb9121d2d185d5f04213d73d16 100644 (file)
@@ -25,7 +25,10 @@ import (
 )
 
 func (ctx *Ctx) LockDir(nodeId *NodeId, lockCtx string) (*os.File, error) {
-       ctx.ensureRxDir(nodeId)
+       if err := ctx.ensureRxDir(nodeId); err != nil {
+               ctx.LogE("lockdir", SDS{}, err, "")
+               return nil, err
+       }
        lockPath := filepath.Join(ctx.Spool, nodeId.String(), lockCtx) + ".lock"
        dirLock, err := os.OpenFile(
                lockPath,