summaryrefslogtreecommitdiff
path: root/src/qmail-lspawn.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/qmail-lspawn.c')
-rw-r--r--src/qmail-lspawn.c171
1 files changed, 84 insertions, 87 deletions
diff --git a/src/qmail-lspawn.c b/src/qmail-lspawn.c
index fed5c4c..29c1b7a 100644
--- a/src/qmail-lspawn.c
+++ b/src/qmail-lspawn.c
@@ -1,24 +1,26 @@
#include <unistd.h>
-#include "fd.h"
-#include "wait.h"
-#include "prot.h"
+
#include "buffer.h"
-#include "stralloc.h"
-#include "scan.h"
-#include "exit.h"
-#include "cdbread.h"
+#include "byte.h"
#include "case.h"
+#include "cdbread.h"
+#include "error.h"
+#include "exit.h"
+#include "fd.h"
+#include "open.h"
+#include "prot.h"
#include "readclose.h"
+#include "scan.h"
+#include "stralloc.h"
+#include "wait.h"
+
#include "auto_qmail.h"
#include "auto_uids.h"
#include "qlx.h"
-#include "error.h"
-#include "open.h"
-#include "byte.h"
char *aliasempty;
-void initialize(int argc,char **argv)
+void initialize(int argc, char **argv)
{
aliasempty = argv[1];
if (!aliasempty) _exit(100);
@@ -26,45 +28,40 @@ void initialize(int argc,char **argv)
int truncreport = 3000;
-void report(buffer *log,int wstat,char *s,int len)
+void report(buffer *log, int wstat, char *s, int len)
{
int i;
- if (wait_crashed(wstat)) { buffer_putsflush(log,"Zqmail-lspawn: qmail-local crashed.\n"); return; }
+ if (wait_crashed(wstat)) {
+ buffer_putsflush(log, "Zqmail-lspawn: qmail-local crashed.\n");
+ return;
+ }
switch (wait_exitcode(wstat)) {
- case QLX_CDB:
- buffer_putsflush(log,"Zqmail-lspawn: Trouble reading users/assign.cdb.\n"); return;
- case QLX_NOMEM:
- buffer_putsflush(log,"Zqmail-lspawn: Out of memory.\n"); return;
- case QLX_SYS:
- buffer_putsflush(log,"Zqmail-lspawn: Temporary failure.\n"); return;
- case QLX_NOALIAS:
- buffer_putsflush(log,"Zqmail-lspawn: Unable to find alias user!\n"); return;
+ case QLX_CDB: buffer_putsflush(log, "Zqmail-lspawn: Trouble reading users/assign.cdb.\n"); return;
+ case QLX_NOMEM: buffer_putsflush(log, "Zqmail-lspawn: Out of memory.\n"); return;
+ case QLX_SYS: buffer_putsflush(log, "Zqmail-lspawn: Temporary failure.\n"); return;
+ case QLX_NOALIAS: buffer_putsflush(log, "Zqmail-lspawn: Unable to find alias user!\n"); return;
case QLX_ROOT:
- buffer_putsflush(log,"Zqmail-spawn: Not allowed to perform deliveries as root.\n"); return;
- case QLX_USAGE:
- buffer_putsflush(log,"Zqmail-spawn: Internal bug.\n"); return;
- case QLX_NFS:
- buffer_putsflush(log,"Zqmail-spawn: NFS failure in qmail-local.\n"); return;
- case QLX_EXECHARD:
- buffer_putsflush(log,"Dqmail-spawn: Unable to run qmail-local.\n"); return;
- case QLX_EXECSOFT:
- buffer_putsflush(log,"Zqmail-spawn: Unable to run qmail-local.\n"); return;
- case QLX_EXECPW:
- buffer_putsflush(log,"Zqmail-spawn: Unable to run qmail-getpw.\n"); return;
- case 111: case 71: case 74: case 75:
- buffer_put(log,"Z",1); break;
- case 0:
- buffer_put(log,"K",1); break;
+ buffer_putsflush(log, "Zqmail-spawn: Not allowed to perform deliveries as root.\n");
+ return;
+ case QLX_USAGE: buffer_putsflush(log, "Zqmail-spawn: Internal bug.\n"); return;
+ case QLX_NFS: buffer_putsflush(log, "Zqmail-spawn: NFS failure in qmail-local.\n"); return;
+ case QLX_EXECHARD: buffer_putsflush(log, "Dqmail-spawn: Unable to run qmail-local.\n"); return;
+ case QLX_EXECSOFT: buffer_putsflush(log, "Zqmail-spawn: Unable to run qmail-local.\n"); return;
+ case QLX_EXECPW: buffer_putsflush(log, "Zqmail-spawn: Unable to run qmail-getpw.\n"); return;
+ case 111:
+ case 71:
+ case 74:
+ case 75: buffer_put(log, "Z", 1); break;
+ case 0: buffer_put(log, "K", 1); break;
case 100:
- default:
- buffer_put(log,"D",1); break;
+ default: buffer_put(log, "D", 1); break;
}
- for (i = 0; i < len; ++i)
+ for (i = 0; i < len; ++i)
if (!s[i]) break;
- buffer_put(log,s,i);
+ buffer_put(log, s, i);
}
stralloc lower = {0};
@@ -83,42 +80,43 @@ void nughde_get(char *local)
int fd;
int flagwild;
- if (!stralloc_copys(&lower,"!")) _exit(QLX_NOMEM);
- if (!stralloc_cats(&lower,local)) _exit(QLX_NOMEM);
+ if (!stralloc_copys(&lower, "!")) _exit(QLX_NOMEM);
+ if (!stralloc_cats(&lower, local)) _exit(QLX_NOMEM);
if (!stralloc_0(&lower)) _exit(QLX_NOMEM);
- case_lowerb(lower.s,lower.len);
+ case_lowerb(lower.s, lower.len);
- if (!stralloc_copys(&nughde,"")) _exit(QLX_NOMEM);
+ if (!stralloc_copys(&nughde, "")) _exit(QLX_NOMEM);
fd = open_read("users/assign.cdb");
if (fd == -1)
- if (errno != ENOENT)
- _exit(QLX_CDB);
+ if (errno != ENOENT) _exit(QLX_CDB);
if (fd != -1) {
unsigned int i;
- cdb_init(&c,fd);
- r = cdb_find(&c,"",0);
+ cdb_init(&c, fd);
+ r = cdb_find(&c, "", 0);
if (r != 1) _exit(QLX_CDB);
- if (!stralloc_ready(&wildchars,cdb_datalen(&c))) _exit(QLX_NOMEM);
+ if (!stralloc_ready(&wildchars, cdb_datalen(&c))) _exit(QLX_NOMEM);
wildchars.len = cdb_datalen(&c);
- if (cdb_read(&c,wildchars.s,wildchars.len,cdb_datapos(&c)) == -1) _exit(QLX_CDB);
+ if (cdb_read(&c, wildchars.s, wildchars.len, cdb_datapos(&c)) == -1) _exit(QLX_CDB);
i = lower.len;
flagwild = 0;
do {
/* i > 0 */
- if (!flagwild || (i == 1) || (byte_chr(wildchars.s,wildchars.len,lower.s[i - 1]) < wildchars.len)) {
- r = cdb_find(&c,lower.s,i);
+ if (!flagwild || (i == 1)
+ || (byte_chr(wildchars.s, wildchars.len, lower.s[i - 1]) < wildchars.len))
+ {
+ r = cdb_find(&c, lower.s, i);
if (r == -1) _exit(QLX_CDB);
if (r == 1) {
- if (!stralloc_ready(&nughde,cdb_datalen(&c))) _exit(QLX_NOMEM);
+ if (!stralloc_ready(&nughde, cdb_datalen(&c))) _exit(QLX_NOMEM);
nughde.len = cdb_datalen(&c);
- if (cdb_read(&c,nughde.s,nughde.len,cdb_datapos(&c)) == -1) _exit(QLX_CDB);
+ if (cdb_read(&c, nughde.s, nughde.len, cdb_datapos(&c)) == -1) _exit(QLX_CDB);
if (flagwild)
- if (!stralloc_cats(&nughde,local + i - 1)) _exit(QLX_NOMEM);
+ if (!stralloc_cats(&nughde, local + i - 1)) _exit(QLX_NOMEM);
if (!stralloc_0(&nughde)) _exit(QLX_NOMEM);
close(fd);
return;
@@ -137,27 +135,26 @@ void nughde_get(char *local)
args[1] = local;
args[2] = 0;
switch (gpwpid = fork()) {
- case -1:
- _exit(QLX_SYS);
+ case -1: _exit(QLX_SYS);
case 0:
if (prot_gid(auto_gidn) == -1) _exit(QLX_USAGE);
if (prot_uid(auto_uidp) == -1) _exit(QLX_USAGE);
close(pi[0]);
- if (fd_move(1,pi[1]) == -1) _exit(QLX_SYS);
- execv(*args,args);
+ if (fd_move(1, pi[1]) == -1) _exit(QLX_SYS);
+ execv(*args, args);
_exit(QLX_EXECPW);
}
close(pi[1]);
- if (readclose_append(pi[0],&nughde,128) == -1) _exit(QLX_SYS);
+ if (readclose_append(pi[0], &nughde, 128) == -1) _exit(QLX_SYS);
- if (wait_pid(&gpwstat,gpwpid) != -1) {
+ if (wait_pid(&gpwstat, gpwpid) != -1) {
if (wait_crashed(gpwstat)) _exit(QLX_SYS);
if (wait_exitcode(gpwstat) != 0) _exit(wait_exitcode(gpwstat));
}
}
-int spawn(int fdmess,int fdout,const char *s,char *r,const int at)
+int spawn(int fdmess, int fdout, const char *s, char *r, const int at)
{
int f;
@@ -169,7 +166,7 @@ int spawn(int fdmess,int fdout,const char *s,char *r,const int at)
int gid;
char *x;
unsigned int xlen;
-
+
r[at] = 0;
if (!r[0]) _exit(0); /* <> */
@@ -183,42 +180,42 @@ int spawn(int fdmess,int fdout,const char *s,char *r,const int at)
args[0] = "bin/qmail-local";
args[1] = "--";
args[2] = x;
- n = byte_chr(x,xlen,0);
- if (n++ == xlen) _exit(QLX_USAGE);
- x += n;
+ n = byte_chr(x, xlen, 0);
+ if (n++ == xlen) _exit(QLX_USAGE);
+ x += n;
xlen -= n;
- scan_ulong(x,&u);
+ scan_ulong(x, &u);
uid = u;
- n = byte_chr(x,xlen,0);
- if (n++ == xlen) _exit(QLX_USAGE);
- x += n;
+ n = byte_chr(x, xlen, 0);
+ if (n++ == xlen) _exit(QLX_USAGE);
+ x += n;
xlen -= n;
- scan_ulong(x,&u);
+ scan_ulong(x, &u);
gid = u;
- n = byte_chr(x,xlen,0);
- if (n++ == xlen) _exit(QLX_USAGE);
- x += n;
+ n = byte_chr(x, xlen, 0);
+ if (n++ == xlen) _exit(QLX_USAGE);
+ x += n;
xlen -= n;
args[3] = x;
- n = byte_chr(x,xlen,0);
- if (n++ == xlen) _exit(QLX_USAGE);
- x += n;
+ n = byte_chr(x, xlen, 0);
+ if (n++ == xlen) _exit(QLX_USAGE);
+ x += n;
xlen -= n;
args[4] = r;
args[5] = x;
- n = byte_chr(x,xlen,0);
- if (n++ == xlen) _exit(QLX_USAGE);
- x += n;
+ n = byte_chr(x, xlen, 0);
+ if (n++ == xlen) _exit(QLX_USAGE);
+ x += n;
xlen -= n;
args[6] = x;
- n = byte_chr(x,xlen,0);
- if (n++ == xlen) _exit(QLX_USAGE);
- x += n;
+ n = byte_chr(x, xlen, 0);
+ if (n++ == xlen) _exit(QLX_USAGE);
+ x += n;
xlen -= n;
args[7] = r + at + 1;
@@ -226,14 +223,14 @@ int spawn(int fdmess,int fdout,const char *s,char *r,const int at)
args[9] = aliasempty;
args[10] = 0;
- if (fd_move(0,fdmess) == -1) _exit(QLX_SYS);
- if (fd_move(1,fdout) == -1) _exit(QLX_SYS);
- if (fd_copy(2,1) == -1) _exit(QLX_SYS);
+ if (fd_move(0, fdmess) == -1) _exit(QLX_SYS);
+ if (fd_move(1, fdout) == -1) _exit(QLX_SYS);
+ if (fd_copy(2, 1) == -1) _exit(QLX_SYS);
if (prot_gid(gid) == -1) _exit(QLX_USAGE);
if (prot_uid(uid) == -1) _exit(QLX_USAGE);
if (!getuid()) _exit(QLX_ROOT);
- execv(*args,args);
+ execv(*args, args);
if (errno) _exit(QLX_EXECSOFT);
_exit(QLX_EXECHARD);
}
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-23 02:41:51 +0000