queue_null.c revision 1.2
1/* $OpenBSD: queue_null.c,v 1.2 2013/05/24 17:03:14 eric Exp $ */ 2 3/* 4 * Copyright (c) 2012 Eric Faurot <eric@openbsd.org> 5 * 6 * Permission to use, copy, modify, and distribute this software for any 7 * purpose with or without fee is hereby granted, provided that the above 8 * copyright notice and this permission notice appear in all copies. 9 * 10 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES 11 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF 12 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR 13 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES 14 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN 15 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF 16 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. 17 */ 18 19#include <sys/types.h> 20#include <sys/queue.h> 21#include <sys/tree.h> 22#include <sys/socket.h> 23#include <sys/stat.h> 24 25#include <ctype.h> 26#include <err.h> 27#include <errno.h> 28#include <event.h> 29#include <fcntl.h> 30#include <imsg.h> 31#include <inttypes.h> 32#include <libgen.h> 33#include <pwd.h> 34#include <stdio.h> 35#include <stdlib.h> 36#include <string.h> 37#include <time.h> 38#include <unistd.h> 39 40#include "smtpd.h" 41#include "log.h" 42 43static int queue_null_init(int); 44static int queue_null_message(enum queue_op, uint32_t *); 45static int queue_null_envelope(enum queue_op , uint64_t *, char *, size_t); 46 47struct queue_backend queue_backend_null = { 48 queue_null_init, 49 queue_null_message, 50 queue_null_envelope, 51}; 52 53static int devnull; 54 55static int 56queue_null_init(int server) 57{ 58 59 devnull = open("/dev/null", O_WRONLY, 0777); 60 if (devnull == -1) { 61 log_warn("open"); 62 return (0); 63 } 64 65 return (1); 66} 67 68static int 69queue_null_message(enum queue_op qop, uint32_t *msgid) 70{ 71 switch (qop) { 72 case QOP_CREATE: 73 *msgid = queue_generate_msgid(); 74 return (1); 75 case QOP_DELETE: 76 case QOP_COMMIT: 77 return (1); 78 case QOP_FD_R: 79 return (-1); 80 case QOP_FD_RW: 81 return dup(devnull); 82 case QOP_CORRUPT: 83 return (0); 84 default: 85 fatalx("queue_null_message: unsupported operation."); 86 } 87 88 return (0); 89} 90 91static int 92queue_null_envelope(enum queue_op qop, uint64_t *evpid, char *buf, size_t len) 93{ 94 uint32_t msgid; 95 96 if (qop == QOP_WALK) 97 return (-1); 98 99 switch (qop) { 100 case QOP_CREATE: 101 msgid = evpid_to_msgid(*evpid); 102 *evpid = queue_generate_evpid(msgid); 103 return (1); 104 case QOP_DELETE: 105 return (1); 106 case QOP_LOAD: 107 return (0); 108 case QOP_UPDATE: 109 return (1); 110 default: 111 fatalx("queue_null_envelope: unsupported operation."); 112 } 113 114 return (0); 115} 116