masqmail

annotate src/queue.c @ 93:b3673777f52a

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