masqmail

annotate src/queue.c @ 394:c8e3d1a79313

find changesets by author, revision, files, or words in the commit message
Refactoring in conf.c: read_rval().
author markus schnalke <meillo@marmaro.de>
date Sat, 18 Feb 2012 19:32:40 +0100
parents 41958685480d
children bdbedce60247
rev   line source
meillo@367 1 /*
meillo@367 2 ** MasqMail
meillo@367 3 ** Copyright (C) 1999-2001 Oliver Kurth
meillo@367 4 ** Copyright (C) 2010 markus schnalke <meillo@marmaro.de>
meillo@367 5 **
meillo@367 6 ** This program is free software; you can redistribute it and/or modify
meillo@367 7 ** it under the terms of the GNU General Public License as published by
meillo@367 8 ** the Free Software Foundation; either version 2 of the License, or
meillo@367 9 ** (at your option) any later version.
meillo@367 10 **
meillo@367 11 ** This program is distributed in the hope that it will be useful,
meillo@367 12 ** but WITHOUT ANY WARRANTY; without even the implied warranty of
meillo@367 13 ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
meillo@367 14 ** GNU General Public License for more details.
meillo@367 15 **
meillo@367 16 ** You should have received a copy of the GNU General Public License
meillo@367 17 ** along with this program; if not, write to the Free Software
meillo@367 18 ** Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
meillo@0 19 */
meillo@0 20
meillo@0 21 #include <sys/stat.h>
meillo@0 22 #include <glob.h>
meillo@0 23
meillo@15 24 #include "masqmail.h"
meillo@15 25
meillo@10 26 static void
meillo@10 27 mix_arr(int *buf, int len)
meillo@0 28 {
meillo@10 29 int i;
meillo@0 30
meillo@10 31 for (i = 0; i < len; i++)
meillo@10 32 buf[i] = i;
meillo@10 33 for (i = 0; i < len - 1; i++) {
meillo@10 34 int j = (int) ((float) (len - i) * ((float) rand()) / (RAND_MAX + 1.0));
meillo@10 35 int tmp;
meillo@0 36
meillo@10 37 if (i != j) {
meillo@10 38 tmp = buf[i];
meillo@10 39 buf[i] = buf[j];
meillo@10 40 buf[j] = tmp;
meillo@10 41 }
meillo@10 42 }
meillo@0 43 }
meillo@0 44
meillo@10 45 GList*
meillo@348 46 read_queue(void)
meillo@0 47 {
meillo@10 48 GList *msg_list = NULL;
meillo@10 49 glob_t gl;
meillo@10 50 gchar *pattern;
meillo@10 51 int i, *idx_arr;
meillo@0 52
meillo@367 53 /*
meillo@367 54 ** Escaping the question marks prevents them from being
meillo@367 55 ** interpreted as trigraphs
meillo@367 56 */
meillo@38 57 pattern = g_strdup_printf("%s/input/?????\?-??\?-?\?-H", conf.spool_dir);
meillo@10 58 gl.gl_offs = 0;
meillo@10 59 glob(pattern, 0, NULL, &gl);
meillo@0 60
meillo@10 61 g_free(pattern);
meillo@0 62
meillo@10 63 DEBUG(4) {
meillo@10 64 int i;
meillo@10 65 for (i = 0; i < gl.gl_pathc; i++) {
meillo@10 66 debugf("spoolfile: %s\n", gl.gl_pathv[i]);
meillo@10 67 }
meillo@10 68 }
meillo@0 69
meillo@10 70 idx_arr = g_malloc(sizeof(int) * gl.gl_pathc);
meillo@10 71 mix_arr(idx_arr, gl.gl_pathc);
meillo@0 72
meillo@10 73 for (i = 0; i < gl.gl_pathc; i++) {
meillo@10 74 gchar *uid;
meillo@0 75
meillo@10 76 /* copy 13 chars, offset spooldir path + 7 chars for /input/ */
meillo@10 77 /* uid length = 6 chars + '-' + 3 chars + '-' + 2 = 13 chars */
meillo@10 78 uid = g_strndup(&(gl.gl_pathv[idx_arr[i]][strlen(conf.spool_dir) + 7]), 13);
meillo@0 79
meillo@10 80 DEBUG(5) debugf("uid: %s\n", uid);
meillo@0 81
meillo@349 82 msg_list = g_list_append(msg_list, msg_spool_read(uid));
meillo@0 83
meillo@10 84 DEBUG(5) debugf("after read spool file for %s\n", uid);
meillo@0 85
meillo@10 86 g_free(uid);
meillo@10 87 }
meillo@10 88 return msg_list;
meillo@0 89 }
meillo@0 90
meillo@10 91 gboolean
meillo@10 92 queue_run()
meillo@0 93 {
meillo@10 94 GList *msg_list;
meillo@10 95 gboolean ok = TRUE;
meillo@0 96
meillo@10 97 logwrite(LOG_NOTICE, "Starting queue run.\n");
meillo@348 98 msg_list = read_queue();
meillo@277 99 if (msg_list) {
meillo@10 100 ok = deliver_msg_list(msg_list, DLVR_ALL);
meillo@277 101 DEBUG(5) debugf(" deliver_msg_list() returned: %d\n", ok);
meillo@10 102 destroy_msg_list(msg_list);
meillo@10 103 }
meillo@10 104 logwrite(LOG_NOTICE, "Finished queue run.\n");
meillo@0 105
meillo@10 106 return ok;
meillo@0 107 }
meillo@0 108
meillo@10 109 gboolean
meillo@10 110 queue_run_online()
meillo@0 111 {
meillo@277 112 GList *msg_list;
meillo@10 113 gboolean ok = TRUE;
meillo@0 114
meillo@10 115 logwrite(LOG_NOTICE, "Starting online queue run.\n");
meillo@348 116 msg_list = read_queue();
meillo@277 117 if (msg_list) {
meillo@10 118 ok = deliver_msg_list(msg_list, DLVR_ONLINE);
meillo@277 119 DEBUG(5) debugf(" deliver_msg_list() returned: %d\n", ok);
meillo@10 120 destroy_msg_list(msg_list);
meillo@10 121 }
meillo@10 122 logwrite(LOG_NOTICE, "Finished online queue run.\n");
meillo@0 123
meillo@10 124 return ok;
meillo@0 125 }
meillo@0 126
meillo@10 127 static gchar*
meillo@10 128 format_difftime(double secs)
meillo@0 129 {
meillo@10 130 if (secs > 86400)
meillo@10 131 return g_strdup_printf("%.1fd", secs / 86400);
meillo@10 132 else if (secs > 3600)
meillo@10 133 return g_strdup_printf("%.1fh", secs / 3600);
meillo@10 134 else if (secs > 60)
meillo@10 135 return g_strdup_printf("%.1fm", secs / 60);
meillo@10 136 else
meillo@10 137 return g_strdup_printf("%.0fs", secs);
meillo@10 138 }
meillo@0 139
meillo@10 140 void
meillo@10 141 queue_list()
meillo@0 142 {
meillo@10 143 GList *msg_list;
meillo@10 144 GList *msg_node;
meillo@0 145
meillo@348 146 msg_list = read_queue();
meillo@0 147
meillo@82 148 if (msg_list == NULL) {
meillo@82 149 printf("mail queue is empty.\n");
meillo@82 150 return;
meillo@82 151 }
meillo@0 152
meillo@82 153 foreach(msg_list, msg_node) {
meillo@82 154 message *msg = (message *) (msg_node->data);
meillo@82 155 GList *rcpt_node;
meillo@82 156 gchar *size_str = NULL;
meillo@82 157 gchar *time_str = NULL;
meillo@82 158 gchar *host_str = NULL;
meillo@82 159 gchar *ident_str = NULL;
meillo@0 160
meillo@82 161 if (msg->data_size >= 0)
meillo@82 162 size_str = g_strdup_printf(" size=%d", msg->data_size);
meillo@82 163 if (msg->received_time > 0) {
meillo@82 164 gchar *tmp_str;
meillo@82 165 time_str = g_strdup_printf(" age=%s", tmp_str = format_difftime(difftime(time(NULL), msg->received_time)));
meillo@82 166 g_free(tmp_str);
meillo@82 167 }
meillo@82 168 if (msg->received_host != NULL)
meillo@82 169 host_str = g_strdup_printf(" host=%s", msg->received_host);
meillo@82 170 if (msg->ident != NULL)
meillo@82 171 ident_str = g_strdup_printf(" ident=%s", msg->ident);
meillo@0 172
meillo@82 173 printf("%s <= %s%s%s%s%s\n", msg->uid, addr_string(msg->return_path), size_str ? size_str : "",
meillo@82 174 time_str ? time_str : "", host_str ? host_str : "", ident_str ? ident_str : "");
meillo@0 175
meillo@82 176 if (size_str)
meillo@82 177 g_free(size_str);
meillo@82 178 if (time_str)
meillo@82 179 g_free(time_str);
meillo@82 180 if (host_str)
meillo@82 181 g_free(host_str);
meillo@82 182 if (ident_str)
meillo@82 183 g_free(ident_str);
meillo@10 184
meillo@82 185 foreach(msg->rcpt_list, rcpt_node) {
meillo@82 186 address *rcpt = (address *) (rcpt_node->data);
meillo@82 187
meillo@82 188 printf(" %s %s\n", addr_is_delivered(rcpt) ? "=>" : (addr_is_failed(rcpt) ? "!=" : "=="), addr_string(rcpt));
meillo@10 189 }
meillo@82 190 g_free(msg);
meillo@82 191 }
meillo@10 192 }
meillo@10 193
meillo@10 194 gboolean
meillo@366 195 queue_delete(gchar *uid)
meillo@0 196 {
meillo@10 197 gboolean hdr_ok = TRUE;
meillo@10 198 gboolean dat_ok = TRUE;
meillo@10 199 gchar *hdr_name = g_strdup_printf("%s/input/%s-H", conf.spool_dir, uid);
meillo@10 200 gchar *dat_name = g_strdup_printf("%s/input/%s-D", conf.spool_dir, uid);
meillo@10 201 struct stat stat_buf;
meillo@0 202
meillo@82 203 if (!spool_lock(uid)) {
meillo@10 204 fprintf(stderr, "message %s is locked.\n", uid);
meillo@10 205 return FALSE;
meillo@10 206 }
meillo@0 207
meillo@82 208 if (stat(hdr_name, &stat_buf) == 0) {
meillo@82 209 if (unlink(hdr_name) != 0) {
meillo@82 210 fprintf(stderr, "could not unlink %s: %s\n", hdr_name, strerror(errno));
meillo@82 211 hdr_ok = FALSE;
meillo@82 212 }
meillo@82 213 } else {
meillo@82 214 fprintf(stderr, "could not stat file %s: %s\n", hdr_name, strerror(errno));
meillo@82 215 hdr_ok = FALSE;
meillo@82 216 }
meillo@82 217 if (stat(dat_name, &stat_buf) == 0) {
meillo@82 218 if (unlink(dat_name) != 0) {
meillo@82 219 fprintf(stderr, "could not unlink %s: %s\n", dat_name, strerror(errno));
meillo@82 220 dat_ok = FALSE;
meillo@82 221 }
meillo@82 222 } else {
meillo@82 223 fprintf(stderr, "could not stat file %s: %s\n", dat_name, strerror(errno));
meillo@82 224 dat_ok = FALSE;
meillo@82 225 }
meillo@82 226 printf("message %s deleted\n", uid);
meillo@82 227
meillo@82 228 spool_unlock(uid);
meillo@82 229
meillo@10 230 return (dat_ok && hdr_ok);
meillo@0 231 }