From a6a7d6ce079cabdaf2fa502b2e2cf15e5428ac6f Mon Sep 17 00:00:00 2001 From: Jannis Hoffmann Date: Wed, 3 Jul 2024 15:52:39 +0200 Subject: format files --- src/qmail-queue.c | 280 ++++++++++++++++++++++++++++++++++-------------------- 1 file changed, 176 insertions(+), 104 deletions(-) (limited to 'src/qmail-queue.c') diff --git a/src/qmail-queue.c b/src/qmail-queue.c index b1289dc..ee9a3df 100644 --- a/src/qmail-queue.c +++ b/src/qmail-queue.c @@ -1,28 +1,30 @@ -#include -#include -#include #include -#include "sig.h" +#include +#include +#include + +#include "alloc.h" +#include "buffer.h" +#include "env.h" #include "exit.h" +#include "fmt.h" #include "open.h" +#include "scan.h" #include "seek.h" -#include "fmt.h" -#include "alloc.h" -#include "buffer.h" -#include "datetime.h" -#include "now.h" -#include "triggerpull.h" -#include "extra.h" +#include "sig.h" +#include "wait.h" + #include "auto_qmail.h" #include "auto_uids.h" #include "date822fmt.h" +#include "datetime.h" +#include "extra.h" #include "fmtqfn.h" -#include "env.h" -#include "wait.h" -#include "scan.h" +#include "now.h" +#include "triggerpull.h" #define DEATH 86400 /* 24 hours; _must_ be below q-s's OSSIFIED (36 hours) */ -#define ADDR 1003 +#define ADDR 1003 char inbuf[2048]; struct buffer bi; @@ -47,21 +49,42 @@ int flagmadeintd = 0; void cleanup() { if (flagmadeintd) { - seek_trunc(intdfd,0); - if (unlink(intdfn) == -1) return; + seek_trunc(intdfd, 0); + if (unlink(intdfn) == -1) return; } if (flagmademess) { - seek_trunc(messfd,0); + seek_trunc(messfd, 0); if (unlink(messfn) == -1) return; } } -void die(int e) { _exit(e); } -void die_qhpsi() { cleanup(); die(71); } -void die_write() { cleanup(); die(53); } -void die_read() { cleanup(); die(54); } -void sigalrm() { /* thou shalt not clean up here */ die(52); } -void sigbug() { die(81); } +void die(int e) +{ + _exit(e); +} +void die_qhpsi() +{ + cleanup(); + die(71); +} +void die_write() +{ + cleanup(); + die(53); +} +void die_read() +{ + cleanup(); + die(54); +} +void sigalrm() +{ /* thou shalt not clean up here */ + die(52); +} +void sigbug() +{ + die(81); +} unsigned int receivedlen; char *received; @@ -73,56 +96,89 @@ static unsigned int receivedfmt(char *s) unsigned int len; len = 0; - i = fmt_str(s,"Received: (qmail "); len += i; if (s) s += i; - i = fmt_ulong(s,mypid); len += i; if (s) s += i; - i = fmt_str(s," invoked "); len += i; if (s) s += i; - if (uid == auto_uida) { - i = fmt_str(s,"by alias"); len += i; if (s) s += i; - } else if (uid == auto_uidd) { - i = fmt_str(s,"from network"); len += i; if (s) s += i; - } else if (uid == auto_uids) { - i = fmt_str(s,"for bounce"); len += i; if (s) s += i; + i = fmt_str(s, "Received: (qmail "); + len += i; + if (s) s += i; + i = fmt_ulong(s, mypid); + len += i; + if (s) s += i; + i = fmt_str(s, " invoked "); + len += i; + if (s) s += i; + if (uid == auto_uida) { + i = fmt_str(s, "by alias"); + len += i; + if (s) s += i; + } else if (uid == auto_uidd) { + i = fmt_str(s, "from network"); + len += i; + if (s) s += i; + } else if (uid == auto_uids) { + i = fmt_str(s, "for bounce"); + len += i; + if (s) s += i; } else { - i = fmt_str(s,"by uid "); len += i; if (s) s += i; - i = fmt_ulong(s,uid); len += i; if (s) s += i; + i = fmt_str(s, "by uid "); + len += i; + if (s) s += i; + i = fmt_ulong(s, uid); + len += i; + if (s) s += i; } - i = fmt_str(s,"); "); len += i; if (s) s += i; - i = date822fmt(s,&dt); len += i; if (s) s += i; + i = fmt_str(s, "); "); + len += i; + if (s) s += i; + i = date822fmt(s, &dt); + len += i; + if (s) s += i; return len; } void received_setup() { - receivedlen = receivedfmt((char *) 0); + receivedlen = receivedfmt((char *)0); received = alloc(receivedlen + 1); if (!received) die(51); receivedfmt(received); } -unsigned int pidfmt(char *s,unsigned long seq) +unsigned int pidfmt(char *s, unsigned long seq) { unsigned int i; unsigned int len; len = 0; - i = fmt_str(s,"pid/"); len += i; if (s) s += i; - i = fmt_ulong(s,mypid); len += i; if (s) s += i; - i = fmt_str(s,"."); len += i; if (s) s += i; - i = fmt_ulong(s,starttime); len += i; if (s) s += i; - i = fmt_str(s,"."); len += i; if (s) s += i; - i = fmt_ulong(s,seq); len += i; if (s) s += i; - ++len; if (s) *s++ = 0; + i = fmt_str(s, "pid/"); + len += i; + if (s) s += i; + i = fmt_ulong(s, mypid); + len += i; + if (s) s += i; + i = fmt_str(s, "."); + len += i; + if (s) s += i; + i = fmt_ulong(s, starttime); + len += i; + if (s) s += i; + i = fmt_str(s, "."); + len += i; + if (s) s += i; + i = fmt_ulong(s, seq); + len += i; + if (s) s += i; + ++len; + if (s) *s++ = 0; return len; } -char *fnnum(char *dirslash,int flagsplit) +char *fnnum(char *dirslash, int flagsplit) { char *s; - s = alloc(fmtqfn((char *) 0,dirslash,messnum,flagsplit)); + s = alloc(fmtqfn((char *)0, dirslash, messnum, flagsplit)); if (!s) die(51); - fmtqfn(s,dirslash,messnum,flagsplit); + fmtqfn(s, dirslash, messnum, flagsplit); return s; } @@ -132,18 +188,18 @@ void pidopen(void) unsigned long seq; seq = 1; - len = pidfmt((char *) 0,seq); + len = pidfmt((char *)0, seq); pidfn = alloc(len); if (!pidfn) die(51); for (seq = 1; seq < 10; ++seq) { - if (pidfmt((char *) 0,seq) > len) die(81); /* paranoia */ - pidfmt(pidfn,seq); + if (pidfmt((char *)0, seq) > len) die(81); /* paranoia */ + pidfmt(pidfn, seq); messfd = open_excl(pidfn); if (messfd != -1) return; } - die(63); + die(63); } char *qhpsi; @@ -152,10 +208,10 @@ void qhpsiprog(char *arg) { int wstat; int child; - char *qhpsiargs[6] = { 0, 0, 0, 0, 0, 0 }; + char *qhpsiargs[6] = {0, 0, 0, 0, 0, 0}; char *x; - unsigned long u; - int childrc; + unsigned long u; + int childrc; int qhpsirc = 1; unsigned int size; unsigned int qhpsiminsize = 0; @@ -163,39 +219,52 @@ void qhpsiprog(char *arg) struct stat st; - if (stat(messfn,&st) == -1) die(63); - size = (unsigned int) st.st_size; + if (stat(messfn, &st) == -1) die(63); + size = (unsigned int)st.st_size; x = env_get("QHPSIMINSIZE"); - if (x) { scan_ulong(x,&u); qhpsiminsize = (int) u; } - if (qhpsiminsize) if (size < qhpsiminsize) return; + if (x) { + scan_ulong(x, &u); + qhpsiminsize = (int)u; + } + if (qhpsiminsize) + if (size < qhpsiminsize) return; x = env_get("QHPSIMAXSIZE"); - if (x) { scan_ulong(x,&u); qhpsimaxsize = (int) u; } - if (qhpsimaxsize) if (size > qhpsimaxsize) return; + if (x) { + scan_ulong(x, &u); + qhpsimaxsize = (int)u; + } + if (qhpsimaxsize) + if (size > qhpsimaxsize) return; if (*arg) { switch (child = fork()) { - case -1: - die_qhpsi(); + case -1: die_qhpsi(); case 0: - qhpsiargs[0] = arg; + qhpsiargs[0] = arg; qhpsiargs[1] = messfn; qhpsiargs[2] = env_get("QHPSIARG1"); - if (!qhpsiargs[2]) qhpsiargs[2] = 0; + if (!qhpsiargs[2]) qhpsiargs[2] = 0; qhpsiargs[3] = env_get("QHPSIARG2"); - if (!qhpsiargs[3]) qhpsiargs[3] = 0; + if (!qhpsiargs[3]) qhpsiargs[3] = 0; qhpsiargs[4] = env_get("QHPSIARG3"); - if (!qhpsiargs[4]) qhpsiargs[4] = 0; + if (!qhpsiargs[4]) qhpsiargs[4] = 0; x = env_get("QHPSIRC"); - if (x) { scan_ulong(x,&u); qhpsirc = (int) u; } - execvp(*qhpsiargs,qhpsiargs); + if (x) { + scan_ulong(x, &u); + qhpsirc = (int)u; + } + execvp(*qhpsiargs, qhpsiargs); die_qhpsi(); } - if (wait_pid(&wstat,child) == -1) die_qhpsi(); + if (wait_pid(&wstat, child) == -1) die_qhpsi(); if (wait_crashed(wstat)) die_qhpsi(); - childrc = wait_exitcode(wstat); - if (childrc == qhpsirc) { cleanup(); die(32); } - else if (childrc != 0) die_qhpsi(); + childrc = wait_exitcode(wstat); + if (childrc == qhpsirc) { + cleanup(); + die(32); + } else if (childrc != 0) + die_qhpsi(); } } @@ -215,7 +284,7 @@ int main() mypid = getpid(); uid = getuid(); starttime = now(); - datetime_tai(&dt,starttime); + datetime_tai(&dt, starttime); qhpsi = env_get("QHPSI"); received_setup(); @@ -228,23 +297,23 @@ int main() alarm(DEATH); pidopen(); - if (fstat(messfd,&pidst) == -1) die(63); + if (fstat(messfd, &pidst) == -1) die(63); messnum = pidst.st_ino; - messfn = fnnum("mess/",1); - todofn = fnnum("todo/",1); - intdfn = fnnum("intd/",1); + messfn = fnnum("mess/", 1); + todofn = fnnum("todo/", 1); + intdfn = fnnum("intd/", 1); - if (link(pidfn,messfn) == -1) die(64); + if (link(pidfn, messfn) == -1) die(64); if (unlink(pidfn) == -1) die(63); flagmademess = 1; - buffer_init(&bo,write,messfd,outbuf,sizeof(outbuf)); - buffer_init(&bi,read,0,inbuf,sizeof(inbuf)); + buffer_init(&bo, write, messfd, outbuf, sizeof(outbuf)); + buffer_init(&bi, read, 0, inbuf, sizeof(inbuf)); - if (buffer_put(&bo,received,receivedlen) == -1) die_write(); + if (buffer_put(&bo, received, receivedlen) == -1) die_write(); - switch (buffer_copy(&bo,&bi)) { + switch (buffer_copy(&bo, &bi)) { case -2: die_read(); case -3: die_write(); } @@ -255,38 +324,41 @@ int main() if (intdfd == -1) die(65); flagmadeintd = 1; - buffer_init(&bo,write,intdfd,outbuf,sizeof(outbuf)); - buffer_init(&bi,read,1,inbuf,sizeof(inbuf)); + buffer_init(&bo, write, intdfd, outbuf, sizeof(outbuf)); + buffer_init(&bi, read, 1, inbuf, sizeof(inbuf)); - if (buffer_put(&bo,"u",1) == -1) die_write(); - if (buffer_put(&bo,tmp,fmt_ulong(tmp,uid)) == -1) die_write(); - if (buffer_put(&bo,"",1) == -1) die_write(); + if (buffer_put(&bo, "u", 1) == -1) die_write(); + if (buffer_put(&bo, tmp, fmt_ulong(tmp, uid)) == -1) die_write(); + if (buffer_put(&bo, "", 1) == -1) die_write(); - if (buffer_put(&bo,"p",1) == -1) die_write(); - if (buffer_put(&bo,tmp,fmt_ulong(tmp,mypid)) == -1) die_write(); - if (buffer_put(&bo,"",1) == -1) die_write(); + if (buffer_put(&bo, "p", 1) == -1) die_write(); + if (buffer_put(&bo, tmp, fmt_ulong(tmp, mypid)) == -1) die_write(); + if (buffer_put(&bo, "", 1) == -1) die_write(); - if (buffer_get(&bi,&ch,1) < 1) die_read(); + if (buffer_get(&bi, &ch, 1) < 1) die_read(); if (ch != 'F') die(91); - if (buffer_put(&bo,&ch,1) == -1) die_write(); + if (buffer_put(&bo, &ch, 1) == -1) die_write(); for (len = 0; len < ADDR; ++len) { - if (buffer_get(&bi,&ch,1) < 1) die_read(); - if (buffer_put(&bo,&ch,1) == -1) die_write(); + if (buffer_get(&bi, &ch, 1) < 1) die_read(); + if (buffer_put(&bo, &ch, 1) == -1) die_write(); if (!ch) break; } if (len >= ADDR) die(11); - if (buffer_put(&bo,QUEUE_EXTRA,QUEUE_EXTRALEN) == -1) die_write(); + if (buffer_put(&bo, QUEUE_EXTRA, QUEUE_EXTRALEN) == -1) die_write(); for (;;) { - if (buffer_get(&bi,&ch,1) < 1) die_read(); + if (buffer_get(&bi, &ch, 1) < 1) die_read(); if (!ch) break; - if (ch == 'Q') { qhpsi = 0; break; } + if (ch == 'Q') { + qhpsi = 0; + break; + } if (ch != 'T') die(91); - if (buffer_put(&bo,&ch,1) == -1) die_write(); + if (buffer_put(&bo, &ch, 1) == -1) die_write(); for (len = 0; len < ADDR; ++len) { - if (buffer_get(&bi,&ch,1) < 1) die_read(); - if (buffer_put(&bo,&ch,1) == -1) die_write(); + if (buffer_get(&bi, &ch, 1) < 1) die_read(); + if (buffer_put(&bo, &ch, 1) == -1) die_write(); if (!ch) break; } if (len >= ADDR) die(11); @@ -297,8 +369,8 @@ int main() if (buffer_flush(&bo) == -1) die_write(); if (fsync(intdfd) == -1) die_write(); - if (link(intdfn,todofn) == -1) die(66); - if ((fd = open(todofn,O_RDONLY)) < 0 || fsync(fd) < 0 || close(fd)) die(66); + if (link(intdfn, todofn) == -1) die(66); + if ((fd = open(todofn, O_RDONLY)) < 0 || fsync(fd) < 0 || close(fd)) die(66); triggerpull(); die(0); -- cgit v1.2.3