X-Git-Url: https://diplodocus.org/git/nmh/blobdiff_plain/1d08c1e0c0de0d321883ece1c36bce851fe893c7..d711510305:/uip/rcvdist.c diff --git a/uip/rcvdist.c b/uip/rcvdist.c index 7e9ae010..1ad585d2 100644 --- a/uip/rcvdist.c +++ b/uip/rcvdist.c @@ -1,6 +1,4 @@ - -/* - * rcvdist.c -- asynchronously redistribute messages +/* rcvdist.c -- asynchronously redistribute messages * * This code is Copyright (c) 2002, by the authors of nmh. See the * COPYRIGHT file in the root directory of the nmh distribution for @@ -13,6 +11,7 @@ #include #include #include +#include "../sbr/m_mktemp.h" #define RCVDIST_SWITCHES \ X("form formfile", 4, FORMSW) \ @@ -48,7 +47,7 @@ main (int argc, char **argv) FILE *fp; char *tfile = NULL; - if (nmh_init(argv[0], 1)) { return 1; } + if (nmh_init(argv[0], 2)) { return 1; } done=unlink_done; @@ -89,7 +88,7 @@ main (int argc, char **argv) continue; } } - addrs = addrs ? add (cp, add (", ", addrs)) : getcpy (cp); + addrs = addrs ? add (cp, add (", ", addrs)) : mh_xstrdup(cp); } if (addrs == NULL) @@ -129,7 +128,8 @@ main (int argc, char **argv) sleep (5); switch (child_id) { case NOTOK: - admonish (NULL, "unable to fork");/* fall */ + inform("unable to fork, continuing..."); + /* FALLTHRU */ case OK: execvp (program, vec); fprintf (stderr, "unable to exec "); @@ -145,8 +145,6 @@ main (int argc, char **argv) /* very similar to routine in replsbr.c */ -#define SBUFSIZ 256 - static int outputlinelen = OUTPUTLINELEN; static struct format *fmt; @@ -173,11 +171,11 @@ static char *addrcomps[] = { static void rcvdistout (FILE *inb, char *form, char *addrs) { - register int char_read = 0, format_len, i, state; - register char **ap; - char *cp, name[NAMESZ], tmpbuf[SBUFSIZ]; + int char_read = 0, format_len, i, state; + char **ap; + char *cp, name[NAMESZ], tmpbuf[NMH_BUFSIZ]; charstring_t scanl; - register struct comp *cptr; + struct comp *cptr; FILE *out; m_getfld_state_t gstate = 0; @@ -200,7 +198,7 @@ rcvdistout (FILE *inb, char *form, char *addrs) cptr->c_text = addrs; for (;;) { - int msg_count = SBUFSIZ; + int msg_count = sizeof tmpbuf; switch (state = m_getfld (&gstate, name, tmpbuf, &msg_count, inb)) { case FLD: case FLDPLUS: @@ -208,7 +206,7 @@ rcvdistout (FILE *inb, char *form, char *addrs) if (i != -1) { char_read += msg_count; while (state == FLDPLUS) { - msg_count = SBUFSIZ; + msg_count = sizeof tmpbuf; state = m_getfld (&gstate, name, tmpbuf, &msg_count, inb); fmt_appendcomp(i, name, tmpbuf); char_read += msg_count; @@ -216,7 +214,7 @@ rcvdistout (FILE *inb, char *form, char *addrs) } while (state == FLDPLUS) { - msg_count = SBUFSIZ; + msg_count = sizeof tmpbuf; state = m_getfld (&gstate, name, tmpbuf, &msg_count, inb); } break; @@ -250,7 +248,7 @@ finished: ; } -static void +static void NORETURN unlink_done (int status) { if (backup[0])