diff options
author | Gilles Chehade <gilles@cvs.openbsd.org> | 2011-04-17 11:39:24 +0000 |
---|---|---|
committer | Gilles Chehade <gilles@cvs.openbsd.org> | 2011-04-17 11:39:24 +0000 |
commit | c47b42a036abf532822fdf80ce52298ad8b2d9ce (patch) | |
tree | 25233bd6efe03645b35829cd05f1ca81f5a98906 /usr.sbin | |
parent | 1541cc4dd793cb295324ed5c8a8d25cd859ca1cc (diff) |
a structure describing an envelope should be called struct envelope, not
struct message ...
Diffstat (limited to 'usr.sbin')
-rw-r--r-- | usr.sbin/smtpd/bounce.c | 20 | ||||
-rw-r--r-- | usr.sbin/smtpd/lka.c | 4 | ||||
-rw-r--r-- | usr.sbin/smtpd/mda.c | 4 | ||||
-rw-r--r-- | usr.sbin/smtpd/mfa.c | 10 | ||||
-rw-r--r-- | usr.sbin/smtpd/mta.c | 24 | ||||
-rw-r--r-- | usr.sbin/smtpd/queue.c | 12 | ||||
-rw-r--r-- | usr.sbin/smtpd/queue_backend.c | 22 | ||||
-rw-r--r-- | usr.sbin/smtpd/queue_fsqueue.c | 78 | ||||
-rw-r--r-- | usr.sbin/smtpd/queue_shared.c | 100 | ||||
-rw-r--r-- | usr.sbin/smtpd/ramqueue.c | 22 | ||||
-rw-r--r-- | usr.sbin/smtpd/runner.c | 20 | ||||
-rw-r--r-- | usr.sbin/smtpd/smtp.c | 4 | ||||
-rw-r--r-- | usr.sbin/smtpd/smtpd.h | 48 | ||||
-rw-r--r-- | usr.sbin/smtpd/util.c | 12 |
14 files changed, 190 insertions, 190 deletions
diff --git a/usr.sbin/smtpd/bounce.c b/usr.sbin/smtpd/bounce.c index 6130e7d3c95..f48c3d22256 100644 --- a/usr.sbin/smtpd/bounce.c +++ b/usr.sbin/smtpd/bounce.c @@ -1,4 +1,4 @@ -/* $OpenBSD: bounce.c,v 1.29 2011/04/15 17:01:05 gilles Exp $ */ +/* $OpenBSD: bounce.c,v 1.30 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2009 Gilles Chehade <gilles@openbsd.org> @@ -40,14 +40,14 @@ struct client_ctx { struct event ev; - struct message m; + struct envelope m; struct smtp_client *pcb; struct smtpd *env; FILE *msgfp; }; int -bounce_session(struct smtpd *env, int fd, struct message *messagep) +bounce_session(struct smtpd *env, int fd, struct envelope *m) { struct client_ctx *cc = NULL; int msgfd = -1; @@ -55,7 +55,7 @@ bounce_session(struct smtpd *env, int fd, struct message *messagep) FILE *msgfp = NULL; u_int32_t msgid; - msgid = evpid_to_msgid(messagep->evpid); + msgid = evpid_to_msgid(m->evpid); /* get message content */ if ((msgfd = queue_message_fd_r(env, Q_QUEUE, msgid)) == -1) @@ -69,16 +69,16 @@ bounce_session(struct smtpd *env, int fd, struct message *messagep) goto fail; cc->pcb = client_init(fd, msgfp, env->sc_hostname, 1); cc->env = env; - cc->m = *messagep; + cc->m = *m; cc->msgfp = msgfp; client_ssl_optional(cc->pcb); client_sender(cc->pcb, ""); - client_rcpt(cc->pcb, NULL, "%s@%s", messagep->sender.user, - messagep->sender.domain); + client_rcpt(cc->pcb, NULL, "%s@%s", m->sender.user, + m->sender.domain); /* Construct an appropriate reason line. */ - reason = messagep->session_errorline; + reason = m->session_errorline; if (strlen(reason) > 4 && (*reason == '1' || *reason == '6')) reason += 4; @@ -102,9 +102,9 @@ bounce_session(struct smtpd *env, int fd, struct message *messagep) "Below is a copy of the original message:\n" "\n", env->sc_hostname, - messagep->sender.user, messagep->sender.domain, + m->sender.user, m->sender.domain, time_to_text(time(NULL)), - messagep->recipient.user, messagep->recipient.domain, + m->recipient.user, m->recipient.domain, reason); /* setup event */ diff --git a/usr.sbin/smtpd/lka.c b/usr.sbin/smtpd/lka.c index 3e8aa3ded91..7ee4bace72d 100644 --- a/usr.sbin/smtpd/lka.c +++ b/usr.sbin/smtpd/lka.c @@ -1,4 +1,4 @@ -/* $OpenBSD: lka.c,v 1.123 2010/11/29 15:25:55 gilles Exp $ */ +/* $OpenBSD: lka.c,v 1.124 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2008 Pierre-Yves Ritschard <pyr@openbsd.org> @@ -614,7 +614,7 @@ lka_expand_resume(struct smtpd *env, struct lkasession *lkasession) void lka_expansion_done(struct smtpd *env, struct lkasession *lkasession) { - struct message message; + struct envelope message; struct path *path; /* delivery list is empty OR expansion led to an error, reject */ diff --git a/usr.sbin/smtpd/mda.c b/usr.sbin/smtpd/mda.c index 5ac6326286d..c507aea44e1 100644 --- a/usr.sbin/smtpd/mda.c +++ b/usr.sbin/smtpd/mda.c @@ -1,4 +1,4 @@ -/* $OpenBSD: mda.c,v 1.52 2011/04/15 17:01:05 gilles Exp $ */ +/* $OpenBSD: mda.c,v 1.53 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2008 Gilles Chehade <gilles@openbsd.org> @@ -61,7 +61,7 @@ mda_imsg(struct smtpd *env, struct imsgev *iev, struct imsg *imsg) if (s == NULL) fatal(NULL); msgbuf_init(&s->w); - s->msg = *(struct message *)imsg->data; + s->msg = *(struct envelope *)imsg->data; s->msg.status = S_MESSAGE_TEMPFAILURE; s->id = mda_id++; s->datafp = fdopen(imsg->fd, "r"); diff --git a/usr.sbin/smtpd/mfa.c b/usr.sbin/smtpd/mfa.c index 72dac373691..9a376ed16f2 100644 --- a/usr.sbin/smtpd/mfa.c +++ b/usr.sbin/smtpd/mfa.c @@ -1,4 +1,4 @@ -/* $OpenBSD: mfa.c,v 1.55 2011/04/15 17:01:05 gilles Exp $ */ +/* $OpenBSD: mfa.c,v 1.56 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2008 Gilles Chehade <gilles@openbsd.org> @@ -37,8 +37,8 @@ void mfa_imsg(struct smtpd *, struct imsgev *, struct imsg *); __dead void mfa_shutdown(void); void mfa_sig_handler(int, short, void *); -void mfa_test_mail(struct smtpd *, struct message *); -void mfa_test_rcpt(struct smtpd *, struct message *); +void mfa_test_mail(struct smtpd *, struct envelope *); +void mfa_test_rcpt(struct smtpd *, struct envelope *); void mfa_test_rcpt_resume(struct smtpd *, struct submit_status *); int mfa_strip_source_route(char *, size_t); @@ -167,7 +167,7 @@ mfa(struct smtpd *env) } void -mfa_test_mail(struct smtpd *env, struct message *m) +mfa_test_mail(struct smtpd *env, struct envelope *m) { struct submit_status ss; @@ -202,7 +202,7 @@ accept: } void -mfa_test_rcpt(struct smtpd *env, struct message *m) +mfa_test_rcpt(struct smtpd *env, struct envelope *m) { struct submit_status ss; diff --git a/usr.sbin/smtpd/mta.c b/usr.sbin/smtpd/mta.c index 24d20942a6a..b6fa2aa3742 100644 --- a/usr.sbin/smtpd/mta.c +++ b/usr.sbin/smtpd/mta.c @@ -1,4 +1,4 @@ -/* $OpenBSD: mta.c,v 1.102 2011/04/15 17:01:05 gilles Exp $ */ +/* $OpenBSD: mta.c,v 1.103 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2008 Pierre-Yves Ritschard <pyr@openbsd.org> @@ -49,9 +49,9 @@ void mta_pickup(struct mta_session *, void *); void mta_event(int, short, void *); void mta_status(struct mta_session *, const char *, ...); -void mta_message_status(struct message *, char *); -void mta_message_log(struct mta_session *, struct message *); -void mta_message_done(struct mta_session *, struct message *); +void mta_message_status(struct envelope *, char *); +void mta_message_log(struct mta_session *, struct envelope *); +void mta_message_done(struct mta_session *, struct envelope *); void mta_connect_done(int, short, void *); void mta_request_datafd(struct mta_session *); @@ -61,7 +61,7 @@ mta_imsg(struct smtpd *env, struct imsgev *iev, struct imsg *imsg) struct ramqueue_batch *rq_batch; struct mta_session *s; struct mta_relay *relay; - struct message *m; + struct envelope *m; struct secret *secret; struct dns *dns; struct ssl *ssl; @@ -135,7 +135,7 @@ mta_imsg(struct smtpd *env, struct imsgev *iev, struct imsg *imsg) m = malloc(sizeof *m); if (m == NULL) fatal(NULL); - *m = *(struct message *)imsg->data; + *m = *(struct envelope *)imsg->data; strlcpy(m->session_errorline, "000 init", sizeof(m->session_errorline)); @@ -347,7 +347,7 @@ mta_enter_state(struct mta_session *s, int newstate, void *p) struct secret secret; struct mta_relay *relay; struct sockaddr *sa; - struct message *m; + struct envelope *m; struct smtp_client *pcb; int max_reuse; @@ -658,7 +658,7 @@ void mta_status(struct mta_session *s, const char *fmt, ...) { char *status; - struct message *m, *next; + struct envelope *m, *next; va_list ap; va_start(ap, fmt); @@ -683,7 +683,7 @@ mta_status(struct mta_session *s, const char *fmt, ...) } void -mta_message_status(struct message *m, char *status) +mta_message_status(struct envelope *m, char *status) { /* * Previous delivery attempts might have assigned an errorline of @@ -700,7 +700,7 @@ mta_message_status(struct message *m, char *status) } void -mta_message_log(struct mta_session *s, struct message *m) +mta_message_log(struct mta_session *s, struct envelope *m) { struct mta_relay *relay = TAILQ_FIRST(&s->relays); char *status = m->session_errorline; @@ -717,7 +717,7 @@ mta_message_log(struct mta_session *s, struct message *m) } void -mta_message_done(struct mta_session *s, struct message *m) +mta_message_done(struct mta_session *s, struct envelope *m) { switch (m->session_errorline[0]) { case '6': @@ -747,7 +747,7 @@ void mta_request_datafd(struct mta_session *s) { struct ramqueue_batch rq_batch; - struct message *m; + struct envelope *m; m = TAILQ_FIRST(&s->recipients); diff --git a/usr.sbin/smtpd/queue.c b/usr.sbin/smtpd/queue.c index 22b57be98f5..e0ffc834296 100644 --- a/usr.sbin/smtpd/queue.c +++ b/usr.sbin/smtpd/queue.c @@ -1,4 +1,4 @@ -/* $OpenBSD: queue.c,v 1.100 2011/04/17 11:16:57 gilles Exp $ */ +/* $OpenBSD: queue.c,v 1.101 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2008 Gilles Chehade <gilles@openbsd.org> @@ -47,7 +47,7 @@ void queue_imsg(struct smtpd *env, struct imsgev *iev, struct imsg *imsg) { struct submit_status ss; - struct message *m; + struct envelope *m; struct ramqueue_batch *rq_batch; int fd, ret; @@ -341,17 +341,17 @@ queue_purge(struct smtpd *env, enum queue_kind qkind, char *queuepath) } void -queue_submit_envelope(struct smtpd *env, struct message *message) +queue_submit_envelope(struct smtpd *env, struct envelope *m) { imsg_compose_event(env->sc_ievs[PROC_QUEUE], IMSG_QUEUE_SUBMIT_ENVELOPE, 0, 0, -1, - message, sizeof(struct message)); + m, sizeof(*m)); } void -queue_commit_envelopes(struct smtpd *env, struct message *message) +queue_commit_envelopes(struct smtpd *env, struct envelope *m) { imsg_compose_event(env->sc_ievs[PROC_QUEUE], IMSG_QUEUE_COMMIT_ENVELOPES, 0, 0, -1, - message, sizeof(struct message)); + m, sizeof(*m)); } diff --git a/usr.sbin/smtpd/queue_backend.c b/usr.sbin/smtpd/queue_backend.c index 555a9d08d08..4d14f47881b 100644 --- a/usr.sbin/smtpd/queue_backend.c +++ b/usr.sbin/smtpd/queue_backend.c @@ -1,4 +1,4 @@ -/* $OpenBSD: queue_backend.c,v 1.8 2011/04/15 17:01:05 gilles Exp $ */ +/* $OpenBSD: queue_backend.c,v 1.9 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2011 Gilles Chehade <gilles@openbsd.org> @@ -40,7 +40,7 @@ int fsqueue_init(struct smtpd *); int fsqueue_message(struct smtpd *, enum queue_kind, enum queue_op, u_int32_t *); int fsqueue_envelope(struct smtpd *, enum queue_kind, - enum queue_op , struct message *); + enum queue_op , struct envelope *); struct queue_backend queue_backends[] = { @@ -103,29 +103,29 @@ queue_message_fd_rw(struct smtpd *env, enum queue_kind qkind, u_int32_t msgid) int queue_envelope_create(struct smtpd *env, enum queue_kind qkind, - struct message *envelope) + struct envelope *m) { - return env->sc_queue->envelope(env, qkind, QOP_CREATE, envelope); + return env->sc_queue->envelope(env, qkind, QOP_CREATE, m); } int queue_envelope_delete(struct smtpd *env, enum queue_kind qkind, - struct message *envelope) + struct envelope *m) { - return env->sc_queue->envelope(env, qkind, QOP_DELETE, envelope); + return env->sc_queue->envelope(env, qkind, QOP_DELETE, m); } int queue_envelope_load(struct smtpd *env, enum queue_kind qkind, - u_int64_t evpid, struct message *envelope) + u_int64_t evpid, struct envelope *m) { - envelope->evpid = evpid; - return env->sc_queue->envelope(env, qkind, QOP_LOAD, envelope); + m->evpid = evpid; + return env->sc_queue->envelope(env, qkind, QOP_LOAD, m); } int queue_envelope_update(struct smtpd *env, enum queue_kind qkind, - struct message *envelope) + struct envelope *m) { - return env->sc_queue->envelope(env, qkind, QOP_UPDATE, envelope); + return env->sc_queue->envelope(env, qkind, QOP_UPDATE, m); } diff --git a/usr.sbin/smtpd/queue_fsqueue.c b/usr.sbin/smtpd/queue_fsqueue.c index 76c3f747f10..4b4f80c44a8 100644 --- a/usr.sbin/smtpd/queue_fsqueue.c +++ b/usr.sbin/smtpd/queue_fsqueue.c @@ -1,4 +1,4 @@ -/* $OpenBSD: queue_fsqueue.c,v 1.9 2011/04/16 09:13:38 gilles Exp $ */ +/* $OpenBSD: queue_fsqueue.c,v 1.10 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2011 Gilles Chehade <gilles@openbsd.org> @@ -41,9 +41,9 @@ static char *fsqueue_getpath(enum queue_kind); /*static*/ u_int16_t fsqueue_hash(u_int32_t); -static int fsqueue_envelope_load(struct smtpd *, enum queue_kind, struct message *); -static int fsqueue_envelope_update(struct smtpd *, enum queue_kind, struct message *); -static int fsqueue_envelope_delete(struct smtpd *, enum queue_kind, struct message *); +static int fsqueue_envelope_load(struct smtpd *, enum queue_kind, struct envelope *); +static int fsqueue_envelope_update(struct smtpd *, enum queue_kind, struct envelope *); +static int fsqueue_envelope_delete(struct smtpd *, enum queue_kind, struct envelope *); static int fsqueue_message_create(struct smtpd *, enum queue_kind, u_int32_t *); static int fsqueue_message_commit(struct smtpd *, enum queue_kind, u_int32_t); @@ -56,7 +56,7 @@ int fsqueue_init(struct smtpd *); int fsqueue_message(struct smtpd *, enum queue_kind, enum queue_op, u_int32_t *); int fsqueue_envelope(struct smtpd *, enum queue_kind, - enum queue_op , struct message *); + enum queue_op , struct envelope *); static char * fsqueue_getpath(enum queue_kind kind) @@ -94,7 +94,7 @@ fsqueue_hash(u_int32_t h) static int fsqueue_envelope_create(struct smtpd *env, enum queue_kind qkind, - struct message *envelope) + struct envelope *m) { char evpname[MAXPATHLEN]; FILE *fp; @@ -108,7 +108,7 @@ again: rnd = (u_int32_t)arc4random(); if (rnd == 0) goto again; - evpid = envelope->evpid | rnd; + evpid = m->evpid | rnd; if (! bsnprintf(evpname, sizeof(evpname), "%s/%08x%s/%016llx", fsqueue_getpath(qkind), @@ -129,15 +129,15 @@ again: if (fp == NULL) fatal("fsqueue_envelope_create: fdopen"); - envelope->creation = time(NULL); - envelope->evpid = evpid; + m->creation = time(NULL); + m->evpid = evpid; if (qkind == Q_BOUNCE) { - envelope->lasttry = 0; - envelope->retry = 0; + m->lasttry = 0; + m->retry = 0; } - if (fwrite(envelope, sizeof (struct message), 1, fp) != 1) { + if (fwrite(m, sizeof (*m), 1, fp) != 1) { if (errno == ENOSPC) goto tempfail; fatal("fsqueue_envelope_create: write"); @@ -157,24 +157,24 @@ tempfail: fclose(fp); else if (fd != -1) close(fd); - envelope->creation = 0; - envelope->evpid = 0; + m->creation = 0; + m->evpid = 0; return 0; } static int fsqueue_envelope_load(struct smtpd *env, enum queue_kind qkind, - struct message *envelope) + struct envelope *m) { char pathname[MAXPATHLEN]; FILE *fp; if (! bsnprintf(pathname, sizeof(pathname), "%s/%04x/%08x%s/%016llx", fsqueue_getpath(qkind), - fsqueue_hash(evpid_to_msgid(envelope->evpid)), - evpid_to_msgid(envelope->evpid), - PATH_ENVELOPES, envelope->evpid)) + fsqueue_hash(evpid_to_msgid(m->evpid)), + evpid_to_msgid(m->evpid), + PATH_ENVELOPES, m->evpid)) fatalx("fsqueue_envelope_load: snprintf"); fp = fopen(pathname, "r"); @@ -183,7 +183,7 @@ fsqueue_envelope_load(struct smtpd *env, enum queue_kind qkind, return 0; fatal("fsqueue_envelope_load: fopen"); } - if (fread(envelope, sizeof(struct message), 1, fp) != 1) + if (fread(m, sizeof(*m), 1, fp) != 1) fatal("fsqueue_envelope_load: fread"); fclose(fp); return 1; @@ -191,24 +191,24 @@ fsqueue_envelope_load(struct smtpd *env, enum queue_kind qkind, static int fsqueue_envelope_update(struct smtpd *env, enum queue_kind qkind, - struct message *envelope) + struct envelope *m) { char temp[MAXPATHLEN]; char dest[MAXPATHLEN]; FILE *fp; u_int64_t batch_id; - batch_id = envelope->batch_id; - envelope->batch_id = 0; + batch_id = m->batch_id; + m->batch_id = 0; if (! bsnprintf(temp, sizeof(temp), "%s/envelope.tmp", PATH_QUEUE)) fatalx("fsqueue_envelope_update"); if (! bsnprintf(dest, sizeof(dest), "%s/%04x/%08x%s/%016llx", fsqueue_getpath(qkind), - fsqueue_hash(evpid_to_msgid(envelope->evpid)), - evpid_to_msgid(envelope->evpid), - PATH_ENVELOPES, envelope->evpid)) + fsqueue_hash(evpid_to_msgid(m->evpid)), + evpid_to_msgid(m->evpid), + PATH_ENVELOPES, m->evpid)) fatal("fsqueue_envelope_update: snprintf"); fp = fopen(temp, "w"); @@ -217,7 +217,7 @@ fsqueue_envelope_update(struct smtpd *env, enum queue_kind qkind, goto tempfail; fatal("fsqueue_envelope_update: open"); } - if (fwrite(envelope, sizeof(struct message), 1, fp) != 1) { + if (fwrite(m, sizeof(*m), 1, fp) != 1) { if (errno == ENOSPC) goto tempfail; fatal("fsqueue_envelope_update: fwrite"); @@ -231,7 +231,7 @@ fsqueue_envelope_update(struct smtpd *env, enum queue_kind qkind, fatal("fsqueue_envelope_update: rename"); } - envelope->batch_id = batch_id; + m->batch_id = batch_id; return 1; tempfail: @@ -240,36 +240,36 @@ tempfail: if (fp) fclose(fp); - envelope->batch_id = batch_id; + m->batch_id = batch_id; return 0; } static int fsqueue_envelope_delete(struct smtpd *env, enum queue_kind qkind, - struct message *envelope) + struct envelope *m) { char pathname[MAXPATHLEN]; u_int16_t hval; - hval = fsqueue_hash(evpid_to_msgid(envelope->evpid)); + hval = fsqueue_hash(evpid_to_msgid(m->evpid)); if (! bsnprintf(pathname, sizeof(pathname), "%s/%04x/%08x%s/%016llx", fsqueue_getpath(qkind), hval, - evpid_to_msgid(envelope->evpid), + evpid_to_msgid(m->evpid), PATH_ENVELOPES, - envelope->evpid)) + m->evpid)) fatal("fsqueue_envelope_delete: snprintf"); if (unlink(pathname) == -1) fatal("fsqueue_envelope_delete: unlink"); if (! bsnprintf(pathname, sizeof(pathname), "%s/%04x/%08x%s", PATH_QUEUE, - hval, evpid_to_msgid(envelope->evpid), PATH_ENVELOPES)) + hval, evpid_to_msgid(m->evpid), PATH_ENVELOPES)) fatal("fsqueue_envelope_delete: snprintf"); if (rmdir(pathname) != -1) - fsqueue_message_delete(env, qkind, evpid_to_msgid(envelope->evpid)); + fsqueue_message_delete(env, qkind, evpid_to_msgid(m->evpid)); return 1; } @@ -632,20 +632,20 @@ fsqueue_message(struct smtpd *env, enum queue_kind qkind, int fsqueue_envelope(struct smtpd *env, enum queue_kind qkind, - enum queue_op qop, struct message *envelope) + enum queue_op qop, struct envelope *m) { switch (qop) { case QOP_CREATE: - return fsqueue_envelope_create(env, qkind, envelope); + return fsqueue_envelope_create(env, qkind, m); case QOP_DELETE: - return fsqueue_envelope_delete(env, qkind, envelope); + return fsqueue_envelope_delete(env, qkind, m); case QOP_LOAD: - return fsqueue_envelope_load(env, qkind, envelope); + return fsqueue_envelope_load(env, qkind, m); case QOP_UPDATE: - return fsqueue_envelope_update(env, qkind, envelope); + return fsqueue_envelope_update(env, qkind, m); default: fatalx("queue_fsqueue_envelope: unsupported operation."); diff --git a/usr.sbin/smtpd/queue_shared.c b/usr.sbin/smtpd/queue_shared.c index 12f17bfd2c3..494c76c5ecf 100644 --- a/usr.sbin/smtpd/queue_shared.c +++ b/usr.sbin/smtpd/queue_shared.c @@ -1,4 +1,4 @@ -/* $OpenBSD: queue_shared.c,v 1.45 2011/04/15 17:30:23 gilles Exp $ */ +/* $OpenBSD: queue_shared.c,v 1.46 2011/04/17 11:39:22 gilles Exp $ */ /* * Copyright (c) 2008 Gilles Chehade <gilles@openbsd.org> @@ -55,61 +55,61 @@ struct qwalk { int walk_simple(struct qwalk *, char *); int walk_queue(struct qwalk *, char *); -void display_envelope(struct message *, int); +void display_envelope(struct envelope *, int); void getflag(u_int *, int, char *, char *, size_t); int -bounce_record_message(struct smtpd *env, struct message *messagep, struct message *mbounce) +bounce_record_message(struct smtpd *env, struct envelope *m, struct envelope *bounce) { u_int32_t msgid; - if (messagep->type == T_BOUNCE_MESSAGE) { + if (m->type == T_BOUNCE_MESSAGE) { log_debug("mailer daemons loop detected !"); return 0; } - *mbounce = *messagep; - mbounce->type = T_BOUNCE_MESSAGE; - mbounce->status &= ~S_MESSAGE_PERMFAILURE; + *bounce = *m; + bounce->type = T_BOUNCE_MESSAGE; + bounce->status &= ~S_MESSAGE_PERMFAILURE; - msgid = evpid_to_msgid(messagep->evpid); + msgid = evpid_to_msgid(m->evpid); if (! queue_message_create(env, Q_BOUNCE, &msgid)) return 0; - mbounce->evpid = msgid_to_evpid(msgid); - if (! queue_envelope_create(env, Q_BOUNCE, mbounce)) + bounce->evpid = msgid_to_evpid(msgid); + if (! queue_envelope_create(env, Q_BOUNCE, bounce)) return 0; return queue_message_commit(env, Q_BOUNCE, msgid); } void -queue_message_update(struct smtpd *env, struct message *messagep) +queue_message_update(struct smtpd *env, struct envelope *m) { - messagep->flags &= ~F_MESSAGE_PROCESSING; - messagep->status &= ~(S_MESSAGE_ACCEPTED|S_MESSAGE_REJECTED); - messagep->batch_id = 0; - messagep->retry++; + m->flags &= ~F_MESSAGE_PROCESSING; + m->status &= ~(S_MESSAGE_ACCEPTED|S_MESSAGE_REJECTED); + m->batch_id = 0; + m->retry++; - if (messagep->status & S_MESSAGE_PERMFAILURE) { - if (messagep->type != T_BOUNCE_MESSAGE && - messagep->sender.user[0] != '\0') { - struct message bounce; + if (m->status & S_MESSAGE_PERMFAILURE) { + if (m->type != T_BOUNCE_MESSAGE && + m->sender.user[0] != '\0') { + struct envelope bounce; - bounce_record_message(env, messagep, &bounce); + bounce_record_message(env, m, &bounce); } - queue_envelope_delete(env, Q_QUEUE, messagep); + queue_envelope_delete(env, Q_QUEUE, m); return; } - if (messagep->status & S_MESSAGE_TEMPFAILURE) { - messagep->status &= ~S_MESSAGE_TEMPFAILURE; - queue_envelope_update(env, Q_QUEUE, messagep); + if (m->status & S_MESSAGE_TEMPFAILURE) { + m->status &= ~S_MESSAGE_TEMPFAILURE; + queue_envelope_update(env, Q_QUEUE, m); return; } /* no error, remove envelope */ - queue_envelope_delete(env, Q_QUEUE, messagep); + queue_envelope_delete(env, Q_QUEUE, m); } struct qwalk * @@ -247,7 +247,7 @@ void show_queue(char *queuepath, int flags) { char path[MAXPATHLEN]; - struct message message; + struct envelope message; struct qwalk *q; FILE *fp; @@ -267,7 +267,7 @@ show_queue(char *queuepath, int flags) } errno = 0; - if (fread(&message, sizeof(struct message), 1, fp) != 1) + if (fread(&message, sizeof(message), 1, fp) != 1) err(1, "%s", path); fclose(fp); @@ -278,42 +278,42 @@ show_queue(char *queuepath, int flags) } void -display_envelope(struct message *envelope, int flags) +display_envelope(struct envelope *m, int flags) { char status[128]; status[0] = '\0'; - getflag(&envelope->status, S_MESSAGE_TEMPFAILURE, "TEMPFAIL", + getflag(&m->status, S_MESSAGE_TEMPFAILURE, "TEMPFAIL", status, sizeof(status)); - if (envelope->status) - errx(1, "%016llx: unexpected status 0x%04x", envelope->evpid, - envelope->status); + if (m->status) + errx(1, "%016llx: unexpected status 0x%04x", m->evpid, + m->status); - getflag(&envelope->flags, F_MESSAGE_BOUNCE, "BOUNCE", + getflag(&m->flags, F_MESSAGE_BOUNCE, "BOUNCE", status, sizeof(status)); - getflag(&envelope->flags, F_MESSAGE_AUTHENTICATED, "AUTH", + getflag(&m->flags, F_MESSAGE_AUTHENTICATED, "AUTH", status, sizeof(status)); - getflag(&envelope->flags, F_MESSAGE_PROCESSING, "PROCESSING", + getflag(&m->flags, F_MESSAGE_PROCESSING, "PROCESSING", status, sizeof(status)); - getflag(&envelope->flags, F_MESSAGE_SCHEDULED, "SCHEDULED", + getflag(&m->flags, F_MESSAGE_SCHEDULED, "SCHEDULED", status, sizeof(status)); - getflag(&envelope->flags, F_MESSAGE_ENQUEUED, "ENQUEUED", + getflag(&m->flags, F_MESSAGE_ENQUEUED, "ENQUEUED", status, sizeof(status)); - getflag(&envelope->flags, F_MESSAGE_FORCESCHEDULE, "SCHEDULED_MANUAL", + getflag(&m->flags, F_MESSAGE_FORCESCHEDULE, "SCHEDULED_MANUAL", status, sizeof(status)); - if (envelope->flags) - errx(1, "%016llx: unexpected flags 0x%04x", envelope->evpid, - envelope->flags); + if (m->flags) + errx(1, "%016llx: unexpected flags 0x%04x", m->evpid, + m->flags); if (status[0]) status[strlen(status) - 1] = '\0'; else strlcpy(status, "-", sizeof(status)); - switch (envelope->type) { + switch (m->type) { case T_MDA_MESSAGE: printf("MDA"); break; @@ -328,16 +328,16 @@ display_envelope(struct message *envelope, int flags) } printf("|%016llx|%s|%s@%s|%s@%s|%d|%d|%u", - envelope->evpid, + m->evpid, status, - envelope->sender.user, envelope->sender.domain, - envelope->recipient.user, envelope->recipient.domain, - envelope->lasttry, - envelope->expire, - envelope->retry); + m->sender.user, m->sender.domain, + m->recipient.user, m->recipient.domain, + m->lasttry, + m->expire, + m->retry); - if (envelope->session_errorline[0] != '\0') - printf("|%s", envelope->session_errorline); + if (m->session_errorline[0] != '\0') + printf("|%s", m->session_errorline); printf("\n"); } diff --git a/usr.sbin/smtpd/ramqueue.c b/usr.sbin/smtpd/ramqueue.c index 9045956d6e1..5beb2076561 100644 --- a/usr.sbin/smtpd/ramqueue.c +++ b/usr.sbin/smtpd/ramqueue.c @@ -1,4 +1,4 @@ -/* $OpenBSD: ramqueue.c,v 1.4 2011/04/15 17:01:05 gilles Exp $ */ +/* $OpenBSD: ramqueue.c,v 1.5 2011/04/17 11:39:23 gilles Exp $ */ /* * Copyright (c) 2011 Gilles Chehade <gilles@openbsd.org> @@ -38,13 +38,13 @@ #include "smtpd.h" #include "log.h" -int ramqueue_expire(struct smtpd *, struct message *, time_t); -void ramqueue_insert(struct ramqueue *, struct message *, time_t); -time_t ramqueue_next_schedule(struct message *, time_t); +int ramqueue_expire(struct smtpd *, struct envelope *, time_t); +void ramqueue_insert(struct ramqueue *, struct envelope *, time_t); +time_t ramqueue_next_schedule(struct envelope *, time_t); int ramqueue_host_cmp(struct ramqueue_host *, struct ramqueue_host *); struct ramqueue_host *ramqueue_get_host(struct ramqueue *, char *); struct ramqueue_batch *ramqueue_get_batch(struct ramqueue *, - struct ramqueue_host *, struct message *); + struct ramqueue_host *, struct envelope *); void ramqueue_put_host(struct ramqueue *, struct ramqueue_host *); void ramqueue_put_batch(struct ramqueue *, struct ramqueue_batch *); int ramqueue_load_offline(struct ramqueue *); @@ -129,7 +129,7 @@ ramqueue_load(struct ramqueue *rqueue, time_t *nsched) { char path[MAXPATHLEN]; time_t curtm; - struct message envelope; + struct envelope envelope; static struct qwalk *q = NULL; struct ramqueue_envelope *rq_evp; @@ -169,7 +169,7 @@ ramqueue_load(struct ramqueue *rqueue, time_t *nsched) } void -ramqueue_insert(struct ramqueue *rqueue, struct message *envelope, time_t curtm) +ramqueue_insert(struct ramqueue *rqueue, struct envelope *envelope, time_t curtm) { struct ramqueue_envelope *rq_evp; struct ramqueue_envelope *evp; @@ -214,9 +214,9 @@ ramqueue_remove(struct ramqueue *rqueue, struct ramqueue_envelope *rq_evp) } int -ramqueue_expire(struct smtpd *env, struct message *envelope, time_t curtm) +ramqueue_expire(struct smtpd *env, struct envelope *envelope, time_t curtm) { - struct message bounce; + struct envelope bounce; if (curtm - envelope->creation >= envelope->expire) { message_set_errormsg(envelope, @@ -231,7 +231,7 @@ ramqueue_expire(struct smtpd *env, struct message *envelope, time_t curtm) } time_t -ramqueue_next_schedule(struct message *envelope, time_t curtm) +ramqueue_next_schedule(struct envelope *envelope, time_t curtm) { time_t delay; @@ -297,7 +297,7 @@ ramqueue_put_host(struct ramqueue *rqueue, struct ramqueue_host *host) struct ramqueue_batch * ramqueue_get_batch(struct ramqueue *rqueue, struct ramqueue_host *host, - struct message *envelope) + struct envelope *envelope) { struct ramqueue_batch *rq_batch; diff --git a/usr.sbin/smtpd/runner.c b/usr.sbin/smtpd/runner.c index cf4844bb384..28eb88fe33f 100644 --- a/usr.sbin/smtpd/runner.c +++ b/usr.sbin/smtpd/runner.c @@ -1,4 +1,4 @@ -/* $OpenBSD: runner.c,v 1.103 2011/04/15 19:03:28 gilles Exp $ */ +/* $OpenBSD: runner.c,v 1.104 2011/04/17 11:39:23 gilles Exp $ */ /* * Copyright (c) 2008 Gilles Chehade <gilles@openbsd.org> @@ -57,11 +57,11 @@ void runner_process_batch(struct smtpd *, struct ramqueue_envelope *, time_t); void runner_purge_run(void); void runner_purge_message(u_int32_t); -int runner_check_loop(struct smtpd *, struct message *); +int runner_check_loop(struct smtpd *, struct envelope *); int runner_force_message_to_ramqueue(struct ramqueue *, u_int32_t); -void ramqueue_insert(struct ramqueue *, struct message *, time_t); +void ramqueue_insert(struct ramqueue *, struct envelope *, time_t); /*temporary*/ u_int16_t fsqueue_hash(u_int32_t); @@ -71,7 +71,7 @@ u_int32_t filename_to_msgid(char *); void runner_imsg(struct smtpd *env, struct imsgev *iev, struct imsg *imsg) { - struct message *m; + struct envelope *m; switch (imsg->hdr.type) { case IMSG_QUEUE_COMMIT_MESSAGE: @@ -100,7 +100,7 @@ runner_imsg(struct smtpd *env, struct imsgev *iev, struct imsg *imsg) * bounce (and insert bounce in ramqueue). */ if (m->status & S_MESSAGE_PERMFAILURE) { - struct message bounce; + struct envelope bounce; if (m->type != T_BOUNCE_MESSAGE && m->sender.user[0] != '\0') { @@ -349,7 +349,7 @@ int runner_process_envelope(struct smtpd *env, struct ramqueue_envelope *rq_evp, time_t curtm) { size_t mta_av, mda_av, bnc_av; - struct message envelope; + struct envelope envelope; mta_av = env->sc_maxconn - env->stats->mta.sessions_active; mda_av = env->sc_maxconn - env->stats->mda.sessions_active; @@ -380,7 +380,7 @@ runner_process_envelope(struct smtpd *env, struct ramqueue_envelope *rq_evp, tim } if (runner_check_loop(env, &envelope)) { - struct message bounce; + struct envelope bounce; message_set_errormsg(&envelope, "loop has been detected"); bounce_record_message(env, &envelope, &bounce); @@ -405,7 +405,7 @@ runner_process_batch(struct smtpd *env, struct ramqueue_envelope *rq_evp, time_t { struct ramqueue_host *host = rq_evp->host; struct ramqueue_batch *batch = rq_evp->batch; - struct message envelope; + struct envelope envelope; int fd; switch (batch->type) { @@ -506,7 +506,7 @@ runner_force_message_to_ramqueue(struct ramqueue *rqueue, u_int32_t msgid) char path[MAXPATHLEN]; DIR *dirp; struct dirent *dp; - struct message envelope; + struct envelope envelope; time_t curtm; if (! bsnprintf(path, MAXPATHLEN, "%s/%04x/%08x/envelopes", @@ -620,7 +620,7 @@ delroot: } int -runner_check_loop(struct smtpd *env, struct message *messagep) +runner_check_loop(struct smtpd *env, struct envelope *messagep) { int fd; FILE *fp; diff --git a/usr.sbin/smtpd/smtp.c b/usr.sbin/smtpd/smtp.c index 1908db95caa..2164f8bc6c3 100644 --- a/usr.sbin/smtpd/smtp.c +++ b/usr.sbin/smtpd/smtp.c @@ -1,4 +1,4 @@ -/* $OpenBSD: smtp.c,v 1.82 2011/04/15 17:01:05 gilles Exp $ */ +/* $OpenBSD: smtp.c,v 1.83 2011/04/17 11:39:23 gilles Exp $ */ /* * Copyright (c) 2008 Gilles Chehade <gilles@openbsd.org> @@ -152,7 +152,7 @@ smtp_imsg(struct smtpd *env, struct imsgev *iev, struct imsg *imsg) case IMSG_SMTP_ENQUEUE: imsg_compose_event(iev, IMSG_SMTP_ENQUEUE, 0, 0, smtp_enqueue(env, NULL), imsg->data, - sizeof(struct message)); + sizeof(struct envelope)); return; } } diff --git a/usr.sbin/smtpd/smtpd.h b/usr.sbin/smtpd/smtpd.h index cf9aa129b2f..a6a207b74a6 100644 --- a/usr.sbin/smtpd/smtpd.h +++ b/usr.sbin/smtpd/smtpd.h @@ -1,4 +1,4 @@ -/* $OpenBSD: smtpd.h,v 1.216 2011/04/17 11:16:57 gilles Exp $ */ +/* $OpenBSD: smtpd.h,v 1.217 2011/04/17 11:39:23 gilles Exp $ */ /* * Copyright (c) 2008 Gilles Chehade <gilles@openbsd.org> @@ -430,8 +430,8 @@ enum message_flags { F_MESSAGE_BOUNCE = 0x40 }; -struct message { - TAILQ_ENTRY(message) entry; +struct envelope { + TAILQ_ENTRY(envelope) entry; enum message_type type; @@ -560,7 +560,7 @@ struct session { u_char *s_buf; int s_buflen; struct timeval s_tv; - struct message s_msg; + struct envelope s_msg; short s_nresp[STATE_COUNT]; size_t rcptcount; long s_datalen; @@ -638,7 +638,7 @@ struct smtpd { TAILQ_HEAD(maplist, map) *sc_maps, *sc_maps_reload; TAILQ_HEAD(rulelist, rule) *sc_rules, *sc_rules_reload; SPLAY_HEAD(sessiontree, session) sc_sessions; - SPLAY_HEAD(msgtree, message) sc_messages; + SPLAY_HEAD(msgtree, envelope) sc_messages; SPLAY_HEAD(ssltree, ssl) *sc_ssl; SPLAY_HEAD(childtree, child) children; SPLAY_HEAD(lkatree, lkasession) lka_sessions; @@ -752,7 +752,7 @@ struct submit_status { } u; enum message_flags flags; struct sockaddr_storage ss; - struct message msg; + struct envelope msg; }; struct forward_req { @@ -782,7 +782,7 @@ struct secret { struct mda_session { LIST_ENTRY(mda_session) entry; - struct message msg; + struct envelope msg; struct msgbuf w; struct event ev; u_int32_t id; @@ -816,7 +816,7 @@ struct lkasession { u_int8_t iterations; u_int32_t pending; enum lkasession_flags flags; - struct message message; + struct envelope message; struct submit_status ss; }; @@ -871,7 +871,7 @@ struct mta_session { char *host; int port; int flags; - TAILQ_HEAD(,message) recipients; + TAILQ_HEAD(,envelope) recipients; TAILQ_HEAD(,mta_relay) relays; objid_t secmapid; char *secret; @@ -934,7 +934,7 @@ struct queue_backend { int (*init)(struct smtpd *); int (*message)(struct smtpd *, enum queue_kind, enum queue_op, u_int32_t *); int (*envelope)(struct smtpd *, enum queue_kind, enum queue_op, - struct message *); + struct envelope *); }; extern void (*imsg_callback)(struct smtpd *, struct imsgev *, struct imsg *); @@ -955,9 +955,9 @@ int authenticate_user(char *, char *); /* bounce.c */ -int bounce_session(struct smtpd *, int, struct message *); +int bounce_session(struct smtpd *, int, struct envelope *); int bounce_session_switch(struct smtpd *, FILE *, enum session_state *, char *, - struct message *); + struct envelope *); void bounce_event(int, short, void *); @@ -1045,8 +1045,8 @@ int cmdline_symset(char *); /* queue.c */ pid_t queue(struct smtpd *); -void queue_submit_envelope(struct smtpd *, struct message *); -void queue_commit_envelopes(struct smtpd *, struct message *); +void queue_submit_envelope(struct smtpd *, struct envelope *); +void queue_commit_envelopes(struct smtpd *, struct envelope *); /* queue_backend.c */ @@ -1058,21 +1058,21 @@ int queue_message_fd_r(struct smtpd *, enum queue_kind, u_int32_t); int queue_message_fd_rw(struct smtpd *, enum queue_kind, u_int32_t); int queue_message_purge(struct smtpd *, enum queue_kind, u_int32_t); int queue_envelope_create(struct smtpd *, enum queue_kind, - struct message *); + struct envelope *); int queue_envelope_delete(struct smtpd *, enum queue_kind, - struct message *); + struct envelope *); int queue_envelope_load(struct smtpd *, enum queue_kind, - u_int64_t, struct message *); + u_int64_t, struct envelope *); int queue_envelope_update(struct smtpd *, enum queue_kind, - struct message *); + struct envelope *); /* queue_shared.c */ -void queue_message_update(struct smtpd *, struct message *); +void queue_message_update(struct smtpd *, struct envelope *); struct qwalk *qwalk_new(char *); int qwalk(struct qwalk *, char *); void qwalk_close(struct qwalk *); -int bounce_record_message(struct smtpd *, struct message *, struct message *); +int bounce_record_message(struct smtpd *, struct envelope *, struct envelope *); void show_queue(char *, int); @@ -1096,7 +1096,7 @@ RB_PROTOTYPE(hosttree, ramqueue_host, host_entry, ramqueue_host_cmp); /* runner.c */ pid_t runner(struct smtpd *); -void message_reset_flags(struct message *); +void message_reset_flags(struct envelope *); /* smtp.c */ @@ -1164,8 +1164,8 @@ int valid_message_uid(char *); char *time_to_text(time_t); int secure_file(int, char *, struct passwd *, int); void lowercase(char *, char *, size_t); -void message_set_errormsg(struct message *, char *, ...); -char *message_get_errormsg(struct message *); +void message_set_errormsg(struct envelope *, char *, ...); +char *message_get_errormsg(struct envelope *); void sa_set_port(struct sockaddr *, int); struct path *path_dup(struct path *); u_int64_t generate_uid(void); @@ -1173,5 +1173,5 @@ void fdlimit(double); int availdesc(void); u_int32_t evpid_to_msgid(u_int64_t); u_int64_t msgid_to_evpid(u_int32_t); -u_int32_t filename_to_msgpid(char *); +u_int32_t filename_to_msgid(char *); u_int64_t filename_to_evpid(char *); diff --git a/usr.sbin/smtpd/util.c b/usr.sbin/smtpd/util.c index 2adb910efda..34072fab662 100644 --- a/usr.sbin/smtpd/util.c +++ b/usr.sbin/smtpd/util.c @@ -1,4 +1,4 @@ -/* $OpenBSD: util.c,v 1.42 2011/04/15 17:21:24 gilles Exp $ */ +/* $OpenBSD: util.c,v 1.43 2011/04/17 11:39:23 gilles Exp $ */ /* * Copyright (c) 2000,2001 Markus Friedl. All rights reserved. @@ -351,16 +351,16 @@ lowercase(char *buf, char *s, size_t len) } void -message_set_errormsg(struct message *messagep, char *fmt, ...) +message_set_errormsg(struct envelope *m, char *fmt, ...) { int ret; va_list ap; va_start(ap, fmt); - ret = vsnprintf(messagep->session_errorline, MAX_LINE_SIZE, fmt, ap); + ret = vsnprintf(m->session_errorline, MAX_LINE_SIZE, fmt, ap); if (ret >= MAX_LINE_SIZE) - strlcpy(messagep->session_errorline + (MAX_LINE_SIZE - 4), "...", 4); + strlcpy(m->session_errorline + (MAX_LINE_SIZE - 4), "...", 4); /* this should not happen */ if (ret == -1) @@ -370,9 +370,9 @@ message_set_errormsg(struct message *messagep, char *fmt, ...) } char * -message_get_errormsg(struct message *messagep) +message_get_errormsg(struct envelope *m) { - return messagep->session_errorline; + return m->session_errorline; } void |