diff options
| author | Pulux <pulux@pf4sh.eu> | 2022-08-05 05:52:25 +0200 |
|---|---|---|
| committer | Leah Neukirchen <leah@vuxu.org> | 2022-09-25 19:05:37 +0200 |
| commit | 83029dff5de737fb4d6de9dbe64d39ce494eade7 (patch) | |
| tree | 90ba742cf0e04afb2010af929219dd3cfe2c562d /nq.c | |
| parent | 5bb7de35cac53bbc1b666e3cb38cb095fa7ef713 (diff) | |
| download | nq-83029dff5de737fb4d6de9dbe64d39ce494eade7.tar.gz nq-83029dff5de737fb4d6de9dbe64d39ce494eade7.tar.xz nq-83029dff5de737fb4d6de9dbe64d39ce494eade7.zip | |
nq: add support for a $NQFAILDIR
Diffstat (limited to 'nq.c')
| -rw-r--r-- | nq.c | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/nq.c b/nq.c index 564782d..1aff8f9 100644 --- a/nq.c +++ b/nq.c @@ -123,7 +123,7 @@ int main(int argc, char *argv[]) { int64_t ms; - int dirfd = -1, donedirfd = -1, lockfd = -1; + int dirfd = -1, donedirfd = -1, faildirfd = -1, lockfd = -1; int opt = 0, cflag = 0, qflag = 0, tflag = 0, wflag = 0; int pipefd[2]; char lockfile[64], newestlocked[64]; @@ -195,6 +195,22 @@ usage: } } + char *failpath = getenv("NQFAILDIR"); + if (failpath) { + if (mkdir(failpath, 0777) < 0) { + if (errno != EEXIST) { + perror("mkdir $NQFAILDIR"); + exit(111); + } + } + + faildirfd = open(failpath, O_RDONLY | O_DIRECTORY); + if (faildirfd < 0) { + perror("dir open"); + exit(111); + } + } + if (tflag || wflag) { snprintf(lockfile, sizeof lockfile, ".,%011" PRIx64 ".%d", ms, getpid()); @@ -263,6 +279,10 @@ usage: else if (donepath) renameat(dirfd, lockfile, donedirfd, lockfile); + } + if (WEXITSTATUS(status) != 0) { + if (failpath) + renameat(dirfd, lockfile, faildirfd, lockfile); /* errors above are ignored */ } } else { |