diff options
author | Gilles Chehade <gilles@poolp.org> | 2020-05-22 14:35:02 +0200 |
---|---|---|
committer | Gilles Chehade <gilles@poolp.org> | 2020-05-22 14:35:02 +0200 |
commit | 90087f07a7cfffe10b4958e13558a0052f85691d (patch) | |
tree | bf0aac44374cfd5cd0da91cc67a6744decd74665 /smtpd/scheduler_backend.c | |
parent | moving smtpd to usr.sbin/smtpd to ease cherry-picking of upstream (diff) | |
download | OpenSMTPD-90087f07a7cfffe10b4958e13558a0052f85691d.tar.xz OpenSMTPD-90087f07a7cfffe10b4958e13558a0052f85691d.zip |
Revert "moving smtpd to usr.sbin/smtpd to ease cherry-picking of upstream"
This reverts commit 90620a574d8824e5b2aa18709f2d5b5b6bb3cb38.
Diffstat (limited to 'smtpd/scheduler_backend.c')
-rw-r--r-- | smtpd/scheduler_backend.c | 82 |
1 files changed, 82 insertions, 0 deletions
diff --git a/smtpd/scheduler_backend.c b/smtpd/scheduler_backend.c new file mode 100644 index 00000000..ad2b4cab --- /dev/null +++ b/smtpd/scheduler_backend.c @@ -0,0 +1,82 @@ +/* $OpenBSD: scheduler_backend.c,v 1.16 2018/05/24 11:38:24 gilles Exp $ */ + +/* + * Copyright (c) 2012 Gilles Chehade <gilles@poolp.org> + * + * Permission to use, copy, modify, and distribute this software for any + * purpose with or without fee is hereby granted, provided that the above + * copyright notice and this permission notice appear in all copies. + * + * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES + * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR + * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES + * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN + * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF + * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. + */ + +#include "includes.h" + +#include <sys/types.h> +#include <sys/queue.h> +#include <sys/tree.h> +#include <sys/socket.h> + +#include <ctype.h> +#include <err.h> +#include <event.h> +#include <fcntl.h> +#include <imsg.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <limits.h> + +#include "smtpd.h" +#include "log.h" + +extern struct scheduler_backend scheduler_backend_null; +extern struct scheduler_backend scheduler_backend_proc; +extern struct scheduler_backend scheduler_backend_ramqueue; + +struct scheduler_backend * +scheduler_backend_lookup(const char *name) +{ + if (!strcmp(name, "null")) + return &scheduler_backend_null; + if (!strcmp(name, "ramqueue")) + return &scheduler_backend_ramqueue; + + return &scheduler_backend_proc; +} + +void +scheduler_info(struct scheduler_info *sched, struct envelope *evp) +{ + struct dispatcher *disp; + + disp = evp->type == D_BOUNCE ? + env->sc_dispatcher_bounce : + dict_xget(env->sc_dispatchers, evp->dispatcher); + + switch (disp->type) { + case DISPATCHER_LOCAL: + sched->type = D_MDA; + break; + case DISPATCHER_REMOTE: + sched->type = D_MTA; + break; + case DISPATCHER_BOUNCE: + sched->type = D_BOUNCE; + break; + } + sched->ttl = disp->ttl ? disp->ttl : env->sc_ttl; + + sched->evpid = evp->id; + sched->creation = evp->creation; + sched->retry = evp->retry; + sched->lasttry = evp->lasttry; + sched->lastbounce = evp->lastbounce; + sched->nexttry = 0; +} |