![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to sendsbr.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDReno / contrib / mh / uip|
Return to sendsbr.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / mh / uip |
1.1 ! root 1: /* sendsbr.c - routines to help WhatNow/Send along */ ! 2: ! 3: #include "../h/mh.h" ! 4: #include <setjmp.h> ! 5: #include <stdio.h> ! 6: #include <signal.h> ! 7: #include <sys/types.h> ! 8: #include <sys/stat.h> ! 9: ! 10: /* */ ! 11: ! 12: int debugsw = 0; /* global */ ! 13: int forwsw = 1; ! 14: int inplace = 0; ! 15: int pushsw = 0; ! 16: int unique = 0; ! 17: ! 18: char *altmsg = NULL; /* .. */ ! 19: char *annotext = NULL; ! 20: char *distfile = NULL; ! 21: ! 22: ! 23: static int armed = 0; ! 24: static jmp_buf env; ! 25: ! 26: ! 27: char *getusr(); ! 28: long lseek(); ! 29: ! 30: static void alert(), anno(), annoaux(); ! 31: void senddone(); ! 32: static int tmp_fd(); ! 33: ! 34: /* */ ! 35: ! 36: sendsbr(vec, vecp, drft, st) ! 37: register char **vec, *drft; ! 38: int vecp; ! 39: register struct stat *st; ! 40: { ! 41: int status; ! 42: ! 43: armed++; ! 44: switch (setjmp (env)) { ! 45: case OK: ! 46: status = sendaux (vec, vecp, drft, st) ? NOTOK : OK; ! 47: break; ! 48: ! 49: default: ! 50: status = DONE; ! 51: break; ! 52: } ! 53: armed = 0; ! 54: if (distfile) ! 55: (void) unlink (distfile); ! 56: ! 57: return status; ! 58: } ! 59: ! 60: /* */ ! 61: ! 62: sendaux(vec, vecp, drft, st) ! 63: register char **vec, *drft; ! 64: int vecp; ! 65: register struct stat *st; ! 66: { ! 67: int child_id, ! 68: i, ! 69: status, ! 70: fd, ! 71: fd2; ! 72: char backup[BUFSIZ], ! 73: buf[BUFSIZ], ! 74: file[BUFSIZ]; ! 75: ! 76: fd = pushsw ? tmp_fd () : NOTOK; ! 77: fd2 = NOTOK; ! 78: ! 79: if (pushsw && unique) { ! 80: if (rename (drft, strcpy (file, m_scratch (drft, invo_name))) ! 81: == NOTOK) ! 82: adios (file, "unable to rename %s to", drft); ! 83: drft = file; ! 84: } ! 85: vec[vecp++] = drft; ! 86: if (annotext) ! 87: if ((fd2 = tmp_fd ()) != NOTOK) { ! 88: vec[vecp++] = "-idanno"; ! 89: (void) sprintf (buf, "%d", fd2); ! 90: vec[vecp++] = buf; ! 91: } ! 92: else ! 93: admonish (NULLCP, "unable to create file for annotation list"); ! 94: if (distfile && distout (drft, distfile, backup) == NOTOK) ! 95: senddone (1); ! 96: vec[vecp] = NULL; ! 97: ! 98: for (i = 0; (child_id = vfork ()) == NOTOK && i < 5; i++) ! 99: sleep (5); ! 100: switch (child_id) { ! 101: case NOTOK: /* oops */ ! 102: adios ("fork", "unable to"); ! 103: ! 104: case OK: /* send it */ ! 105: if (fd != NOTOK) { ! 106: (void) dup2 (fd, fileno (stdout)); ! 107: (void) dup2 (fd, fileno (stderr)); ! 108: (void) close (fd); ! 109: } ! 110: execvp (postproc, vec); ! 111: fprintf (stderr, "unable to exec "); ! 112: perror (postproc); ! 113: _exit (-1); ! 114: ! 115: default: /* wait for it */ ! 116: if ((status = pidwait (child_id, NOTOK)) == 0) { ! 117: if (annotext && fd2 != NOTOK) ! 118: anno (fd2, st); ! 119: if (rename (drft, strcpy (buf, m_backup (drft))) == NOTOK) ! 120: advise (buf, "unable to rename %s to", drft); ! 121: } ! 122: else { ! 123: if (fd != NOTOK) { ! 124: alert (drft, fd); ! 125: (void) close (fd); ! 126: } ! 127: else ! 128: advise (NULLCP, "message not delivered to anyone"); ! 129: if (fd2 != NOTOK) ! 130: (void) close (fd2); ! 131: if (distfile) { ! 132: (void) unlink (drft); ! 133: if (rename (backup, drft) == NOTOK) ! 134: advise (drft, "unable to rename %s to", backup); ! 135: } ! 136: } ! 137: break; ! 138: } ! 139: ! 140: return status; ! 141: } ! 142: ! 143: /* */ ! 144: ! 145: static void ! 146: alert(file, out) ! 147: register char *file; ! 148: int out; ! 149: { ! 150: int child_id, ! 151: i, ! 152: in; ! 153: char buf[BUFSIZ]; ! 154: ! 155: for (i = 0; (child_id = fork ()) == NOTOK && i < 5; i++) ! 156: sleep (5); ! 157: switch (child_id) { ! 158: case NOTOK: /* oops */ ! 159: advise ("fork", "unable to"); ! 160: ! 161: case OK: /* send it */ ! 162: (void) signal (SIGHUP, SIG_IGN); ! 163: (void) signal (SIGINT, SIG_IGN); ! 164: (void) signal (SIGQUIT, SIG_IGN); ! 165: (void) signal (SIGTERM, SIG_IGN); ! 166: if (forwsw) ! 167: if ((in = open (file, 0)) == NOTOK) ! 168: admonish (file, "unable to re-open"); ! 169: else { ! 170: (void) lseek (out, 0L, 2); ! 171: (void) strcpy (buf, "\nMessage not delivered to anyone.\n"); ! 172: (void) write (out, buf, strlen (buf)); ! 173: (void) strcpy (buf, "\n------- Unsent Draft\n\n"); ! 174: (void) write (out, buf, strlen (buf)); ! 175: cpydgst (in, out, file, "temporary file"); ! 176: (void) close (in); ! 177: (void) strcpy (buf, "\n------- End of Unsent Draft\n"); ! 178: (void) write (out, buf, strlen (buf)); ! 179: if (rename (file, strcpy (buf, m_backup (file))) == NOTOK) ! 180: admonish (buf, "unable to rename %s to", file); ! 181: } ! 182: (void) lseek (out, 0L, 0); ! 183: (void) dup2 (out, fileno (stdin)); ! 184: (void) close (out); ! 185: (void) sprintf (buf, "send failed on %s", ! 186: forwsw ? "enclosed draft" : file); ! 187: ! 188: execlp (mailproc, r1bindex (mailproc, '/'), getusr (), ! 189: "-subject", buf, NULLCP); ! 190: fprintf (stderr, "unable to exec "); ! 191: perror (mailproc); ! 192: _exit (-1); ! 193: ! 194: default: /* no waiting... */ ! 195: break; ! 196: } ! 197: } ! 198: ! 199: /* */ ! 200: ! 201: static int ! 202: tmp_fd() ! 203: { ! 204: int fd; ! 205: char tmpfil[BUFSIZ]; ! 206: ! 207: (void) strcpy (tmpfil, m_tmpfil (invo_name)); ! 208: if ((fd = creat (tmpfil, 0600)) == NOTOK) ! 209: return NOTOK; ! 210: (void) close (fd); ! 211: ! 212: if ((fd = open (tmpfil, 2)) == NOTOK) ! 213: return NOTOK; ! 214: if (debugsw) ! 215: advise (NULLCP, "temporary file %s selected", tmpfil); ! 216: else ! 217: if (unlink (tmpfil) == NOTOK) ! 218: advise (tmpfil, "unable to remove"); ! 219: ! 220: return fd; ! 221: } ! 222: ! 223: /* */ ! 224: ! 225: static void ! 226: anno(fd, st) ! 227: int fd; ! 228: register struct stat *st; ! 229: { ! 230: int child_id; ! 231: SIGDECL (*hstat)(), (*istat)(), (*qstat)(), (*tstat)(); ! 232: static char *cwd = NULL; ! 233: struct stat st2; ! 234: ! 235: if (altmsg && ! 236: (stat (altmsg, &st2) == NOTOK ! 237: || st -> st_mtime != st2.st_mtime ! 238: || st -> st_dev != st2.st_dev ! 239: || st -> st_ino != st2.st_ino)) { ! 240: if (debugsw) ! 241: admonish (NULLCP, "$mhaltmsg mismatch"); ! 242: return; ! 243: } ! 244: ! 245: child_id = debugsw ? NOTOK : fork (); ! 246: switch (child_id) { ! 247: case NOTOK: /* oops */ ! 248: if (!debugsw) ! 249: advise (NULLCP, ! 250: "unable to fork, so doing annotations by hand..."); ! 251: if (cwd == NULL) ! 252: cwd = getcpy (pwd ()); ! 253: ! 254: case OK: ! 255: hstat = signal (SIGHUP, SIG_IGN); ! 256: istat = signal (SIGINT, SIG_IGN); ! 257: qstat = signal (SIGQUIT, SIG_IGN); ! 258: tstat = signal (SIGTERM, SIG_IGN); ! 259: ! 260: annoaux (fd); ! 261: if (child_id == OK) ! 262: _exit (0); ! 263: ! 264: (void) signal (SIGHUP, hstat); ! 265: (void) signal (SIGINT, istat); ! 266: (void) signal (SIGQUIT, qstat); ! 267: (void) signal (SIGTERM, tstat); ! 268: ! 269: (void) chdir (cwd); ! 270: break; ! 271: ! 272: default: /* no waiting... */ ! 273: (void) close (fd); ! 274: break; ! 275: } ! 276: } ! 277: ! 278: /* */ ! 279: ! 280: static void ! 281: annoaux(fd) ! 282: int fd; ! 283: { ! 284: int fd2, ! 285: fd3, ! 286: msgnum; ! 287: char *cp, ! 288: *folder, ! 289: *maildir, ! 290: buffer[BUFSIZ], ! 291: **ap; ! 292: FILE *fp; ! 293: struct msgs *mp; ! 294: ! 295: if ((folder = getenv ("mhfolder")) == NULL || *folder == NULL) { ! 296: if (debugsw) ! 297: admonish (NULLCP, "$mhfolder not set"); ! 298: return; ! 299: } ! 300: maildir = m_maildir (folder); ! 301: if (chdir (maildir) == NOTOK) { ! 302: if (debugsw) ! 303: admonish (maildir, "unable to change directory to"); ! 304: return; ! 305: } ! 306: if (!(mp = m_gmsg (folder))) { ! 307: if (debugsw) ! 308: admonish (NULLCP, "unable to read folder %s"); ! 309: return; ! 310: } ! 311: if (mp -> hghmsg == 0) { ! 312: if (debugsw) ! 313: admonish (NULLCP, "no messages in %s", folder); ! 314: goto oops; ! 315: } ! 316: ! 317: if ((cp = getenv ("mhmessages")) == NULL || *cp == NULL) { ! 318: if (debugsw) ! 319: admonish (NULLCP, "$mhmessages not set"); ! 320: goto oops; ! 321: } ! 322: if (!debugsw /* MOBY HACK... */ ! 323: && pushsw ! 324: && (fd3 = open ("/dev/null", 2)) != NOTOK ! 325: && (fd2 = dup (fileno (stderr))) != NOTOK) { ! 326: (void) dup2 (fd3, fileno (stderr)); ! 327: (void) close (fd3); ! 328: } ! 329: else ! 330: fd2 = NOTOK; ! 331: for (ap = brkstring (cp = getcpy (cp), " ", NULLCP); *ap; ap++) ! 332: (void) m_convert (mp, *ap); ! 333: free (cp); ! 334: if (fd2 != NOTOK) ! 335: (void) dup2 (fd2, fileno (stderr)); ! 336: if (mp -> numsel == 0) { ! 337: if (debugsw) ! 338: admonish (NULLCP, "no messages to annotate"); ! 339: goto oops; ! 340: } ! 341: ! 342: (void) lseek (fd, 0L, 0); ! 343: if ((fp = fdopen (fd, "r")) == NULL) { ! 344: if (debugsw) ! 345: admonish (NULLCP, "unable to fdopen annotation list"); ! 346: goto oops; ! 347: } ! 348: cp = NULL; ! 349: while (fgets (buffer, sizeof buffer, fp) != NULL) ! 350: cp = add (buffer, cp); ! 351: (void) fclose (fp); ! 352: ! 353: if (debugsw) ! 354: advise (NULLCP, "annotate%s with %s: \"%s\"", ! 355: inplace ? " inplace" : "", annotext, cp); ! 356: for (msgnum = mp -> lowsel; msgnum <= mp -> hghsel; msgnum++) ! 357: if (mp -> msgstats[msgnum] & SELECTED) { ! 358: if (debugsw) ! 359: advise (NULLCP, "annotate message %d", msgnum); ! 360: (void) annotate (m_name (msgnum), annotext, cp, inplace); ! 361: } ! 362: ! 363: free (cp); ! 364: ! 365: oops: ; ! 366: m_fmsg (mp); ! 367: } ! 368: ! 369: /* */ ! 370: ! 371: void ! 372: senddone(status) ! 373: int status; ! 374: { ! 375: if (armed) ! 376: longjmp (env, status ? status : NOTOK); ! 377: ! 378: exit (status); ! 379: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.