diff options
| author | Christian Neukirchen <chneukirchen@gmail.com> | 2016-07-24 18:50:17 +0200 |
|---|---|---|
| committer | Christian Neukirchen <chneukirchen@gmail.com> | 2016-07-24 18:50:17 +0200 |
| commit | 381576322800ee3afe3246fadaf74d61377951ba (patch) | |
| tree | 6775633d42783e6b709ff61d20648c599b6dbef2 /fq.c | |
| parent | 531dd7ab05c7aee56ed2cbbaee92fbbe3ae4e6eb (diff) | |
| download | nq-381576322800ee3afe3246fadaf74d61377951ba.tar.gz nq-381576322800ee3afe3246fadaf74d61377951ba.tar.xz nq-381576322800ee3afe3246fadaf74d61377951ba.zip | |
fq: add -n to not wait
Diffstat (limited to 'fq.c')
| -rw-r--r-- | fq.c | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/fq.c b/fq.c index b92aa56..38a9088 100644 --- a/fq.c +++ b/fq.c @@ -56,7 +56,7 @@ main(int argc, char *argv[]) off_t off, loff; ssize_t rd; int didsth = 0, seen_nl = 0; - int opt = 0, aflag = 0, qflag = 0; + int opt = 0, aflag = 0, nflag = 0, qflag = 1; char *path; #ifdef USE_INOTIFY @@ -65,16 +65,19 @@ main(int argc, char *argv[]) close(0); - while ((opt = getopt(argc, argv, "+aq")) != -1) { + while ((opt = getopt(argc, argv, "+anq")) != -1) { switch (opt) { case 'a': aflag = 1; break; + case 'n': + nflag = 1; + break; case 'q': qflag = 1; break; default: - fputs("usage: fq [-qa] [JOBID...]\n", stderr); + fputs("usage: fq [-anq] [JOBID...]\n", stderr); exit(1); } } @@ -162,6 +165,9 @@ main(int argc, char *argv[]) loff = off; /* file truncated */ if (off == loff) { + if (nflag && islocked(fd)) + break; + if (flock(fd, LOCK_EX | LOCK_NB) == -1 && errno == EWOULDBLOCK) { #ifdef USE_INOTIFY |