Lines Matching defs:cleanup
84 /* cleanup(8), message canonicalization
185 /* cleanup_service_error_reason - handle error writing to cleanup service. */
192 * XXX If the cleanup server gave a reason, then it was already logged.
211 static int copy_segment(VSTREAM *qfile, VSTREAM *cleanup, PICKUP_INFO *info,
244 rec_fprintf(cleanup, REC_TYPE_TIME, "%ld",
292 rec_put(cleanup, REC_TYPE_NORM, "", 0);
294 if ((REC_PUT_BUF(cleanup, type, buf)) < 0)
300 /* pickup_copy - copy message to cleanup service */
302 static int pickup_copy(VSTREAM *qfile, VSTREAM *cleanup,
331 rec_fprintf(cleanup, REC_TYPE_FILT, "%s", var_filter_xport);
338 if ((status = copy_segment(qfile, cleanup, info, buf, REC_TYPE_ENVELOPE)) != 0)
368 rec_fputs(cleanup, REC_TYPE_MESG, "");
369 rec_fprintf(cleanup, REC_TYPE_NORM, "Received: by %s (%s, from userid %ld)",
371 rec_fprintf(cleanup, REC_TYPE_NORM, "\tid %s; %s", info->id,
378 if ((status = copy_segment(qfile, cleanup, info, buf, REC_TYPE_CONTENT)) != 0)
387 rec_fputs(cleanup, REC_TYPE_XTRA, "");
388 if ((status = copy_segment(qfile, cleanup, info, buf, REC_TYPE_EXTRACT)) != 0)
392 * There are no errors. Send the end-of-data marker, and get the cleanup
394 * bounce, the cleanup service can report only soft errors here.
396 rec_fputs(cleanup, REC_TYPE_END, "");
397 if (attr_scan(cleanup, ATTR_FLAG_MISSING,
404 * Depending on the cleanup service completion status, delete the message
405 * file, or try again later. Bounces are dealt with by the cleanup
406 * service itself. The master process wakes up the cleanup service every
416 /* pickup_file - initialize for file copy and cleanup */
423 VSTREAM *cleanup;
446 * Contact the cleanup service and read the queue ID that it has
447 * allocated. In case of trouble, request that the cleanup service
469 cleanup = mail_connect_wait(MAIL_CLASS_PUBLIC, var_cleanup_service);
470 if (attr_scan(cleanup, ATTR_FLAG_STRICT,
473 || attr_print(cleanup, ATTR_FLAG_NONE,
479 status = pickup_copy(qfile, cleanup, info, buf);
482 vstream_fclose(cleanup);
598 * cleanup server watchdog timeout is $daemon_timeout (i.e. several