-func (ctx *Ctx) LockDir(nodeId *NodeId, xx TRxTx) (*os.File, error) {
- ctx.ensureRxDir(nodeId)
- lockPath := filepath.Join(ctx.Spool, nodeId.String(), string(xx)) + ".lock"
+func (ctx *Ctx) LockDir(nodeId *NodeId, lockCtx string) (*os.File, error) {
+ if err := ctx.ensureRxDir(nodeId); err != nil {
+ return nil, err
+ }
+ lockPath := filepath.Join(ctx.Spool, nodeId.String(), lockCtx) + ".lock"