file no longer exists

1 files changed, 0 insertions, 192 deletions

diff --git a/usr.sbin/smtpd/lka_proc.c b/usr.sbin/smtpd/lka_proc.c
deleted file mode 100644
index b01cd433926..00000000000
--- a/usr.sbin/smtpd/lka_proc.c
+++ /dev/null
@@ -1,192 +0,0 @@
-/*	$OpenBSD: lka_proc.c,v 1.13 2019/12/12 22:10:47 gilles Exp $	*/
-
-/*
- * Copyright (c) 2018 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 <sys/types.h>
-#include <sys/queue.h>
-#include <sys/tree.h>
-#include <sys/socket.h>
-
-#include <netinet/in.h>
-
-#include <errno.h>
-#include <event.h>
-#include <imsg.h>
-#include <inttypes.h>
-#include <limits.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include "smtpd.h"
-#include "log.h"
-
-static int			inited = 0;
-static struct dict		processors;
-
-struct processor_instance {
-	char			*name;
-	struct io		*io;
-	struct io		*errfd;
-	int			 ready;
-	uint32_t		 subsystems;
-};
-
-static void	processor_io(struct io *, int, void *);
-static void	processor_errfd(struct io *, int, void *);
-void		lka_filter_process_response(const char *, const char *);
-
-int
-lka_proc_ready(void)
-{
-	void	*iter;
-	struct processor_instance	*pi;
-
-	iter = NULL;
-	while (dict_iter(&processors, &iter, NULL, (void **)&pi))
-		if (!pi->ready)
-			return 0;
-	return 1;
-}
-
-static void
-lka_proc_config(struct processor_instance *pi)
-{
-	io_printf(pi->io, "config|smtpd-version|%s\n", SMTPD_VERSION);
-	io_printf(pi->io, "config|smtp-session-timeout|%d\n", SMTPD_SESSION_TIMEOUT);
-	if (pi->subsystems & FILTER_SUBSYSTEM_SMTP_IN)
-		io_printf(pi->io, "config|subsystem|smtp-in\n");
-	io_printf(pi->io, "config|ready\n");
-}
-
-void
-lka_proc_forked(const char *name, uint32_t subsystems, int fd)
-{
-	struct processor_instance	*processor;
-
-	if (!inited) {
-		dict_init(&processors);
-		inited = 1;
-	}
-
-	processor = xcalloc(1, sizeof *processor);
-	processor->name = xstrdup(name);
-	processor->io = io_new();
-	processor->subsystems = subsystems;
-
-	io_set_nonblocking(fd);
-
-	io_set_fd(processor->io, fd);
-	io_set_callback(processor->io, processor_io, processor->name);
-	dict_xset(&processors, name, processor);
-}
-
-void
-lka_proc_errfd(const char *name, int fd)
-{
-	struct processor_instance	*processor;
-
-	processor = dict_xget(&processors, name);
-
-	io_set_nonblocking(fd);
-
-	processor->errfd = io_new();
-	io_set_fd(processor->errfd, fd);
-	io_set_callback(processor->errfd, processor_errfd, processor->name);
-
-	lka_proc_config(processor);
-}
-
-struct io *
-lka_proc_get_io(const char *name)
-{
-	struct processor_instance *processor;
-
-	processor = dict_xget(&processors, name);
-
-	return processor->io;
-}
-
-static void
-processor_register(const char *name, const char *line)
-{
-	struct processor_instance *processor;
-
-	processor = dict_xget(&processors, name);
-
-	if (strcmp(line, "register|ready") == 0) {
-		processor->ready = 1;
-		return;
-	}
-
-	if (strncmp(line, "register|report|", 16) == 0) {
-		lka_report_register_hook(name, line+16);
-		return;
-	}
-
-	if (strncmp(line, "register|filter|", 16) == 0) {
-		lka_filter_register_hook(name, line+16);
-		return;
-	}
-
-	fatalx("Invalid register line received: %s", line);
-}
-
-static void
-processor_io(struct io *io, int evt, void *arg)
-{
-	struct processor_instance *processor;
-	const char		*name = arg;
-	char			*line = NULL;
-	ssize_t			 len;
-
-	switch (evt) {
-	case IO_DATAIN:
-		while ((line = io_getline(io, &len)) != NULL) {
-			if (strncmp("register|", line, 9) == 0) {
-				processor_register(name, line);
-				continue;
-			}
-			
-			processor = dict_xget(&processors, name);
-			if (!processor->ready)
-				fatalx("Non-register message before register|"
-				    "ready: %s", line);
-			else if (strncmp(line, "filter-result|", 14) == 0 ||
-			    strncmp(line, "filter-dataline|", 16) == 0)
-				lka_filter_process_response(name, line);
-			else if (strncmp(line, "report|", 7) == 0)
-				lka_report_proc(name, line);
-			else
-				fatalx("Invalid filter message type: %s", line);
-		}
-	}
-}
-
-static void
-processor_errfd(struct io *io, int evt, void *arg)
-{
-	const char	*name = arg;
-	char		*line = NULL;
-	ssize_t		 len;
-
-	switch (evt) {
-	case IO_DATAIN:
-		while ((line = io_getline(io, &len)) != NULL)
-			log_warnx("%s: %s", name, line);
-	}
-}