X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=src%2Fsrc%2Fspool_mbox.c;h=4f3c4d25bb26de9a6db786685927843131cb05d7;hb=2a53e2464bfa1a831f544ed44d3690e5c22259a5;hp=05f90a819c57fbd520f312706bf7236ec5f08885;hpb=1bd642c265dae5643f16d023879043b7576f66a9;p=user%2Fhenk%2Fcode%2Fexim.git diff --git a/src/src/spool_mbox.c b/src/src/spool_mbox.c index 05f90a819..4f3c4d25b 100644 --- a/src/src/spool_mbox.c +++ b/src/src/spool_mbox.c @@ -4,7 +4,7 @@ /* Copyright (c) Tom Kistner 2003 - 2015 * License: GPL - * Copyright (c) The Exim Maintainers 2016 - 2018 + * Copyright (c) The Exim Maintainers 2016 - 2020 */ /* Code for setting up a MBOX style spool file inside a /scan/ @@ -36,16 +36,15 @@ uschar buffer[16384]; uschar *temp_string; uschar *mbox_path; FILE *mbox_file = NULL, *l_data_file = NULL, *yield = NULL; -header_line *my_headerlist; struct stat statbuf; -int i, j; -void *reset_point; +int j; +rmark reset_point; mbox_path = string_sprintf("%s/scan/%s/%s.eml", spool_directory, message_id, message_id); if (mbox_fname) *mbox_fname = mbox_path; -reset_point = store_get(0); +reset_point = store_mark(); /* Skip creation if already spooled out as mbox file */ if (!spool_mbox_ok) @@ -88,7 +87,7 @@ if (!spool_mbox_ok) /* write all non-deleted header lines to mbox file */ - for (my_headerlist = header_list; my_headerlist; + for (header_line * my_headerlist = header_list; my_headerlist; my_headerlist = my_headerlist->next) if (my_headerlist->type != '*') if (fwrite(my_headerlist->text, my_headerlist->slen, 1, mbox_file) != 1) @@ -116,9 +115,9 @@ if (!spool_mbox_ok) else { message_subdir[1] = '\0'; - for (i = 0; i < 2; i++) + for (int i = 0; i < 2; i++) { - message_subdir[0] = split_spool_directory == (i == 0) ? message_id[5] : 0; + set_subdir_str(message_subdir, message_id, i); temp_string = spool_fname(US"input", message_subdir, message_id, US"-D"); if ((l_data_file = Ufopen(temp_string, "rb"))) break; } @@ -147,7 +146,7 @@ if (!spool_mbox_ok) { uschar * s; - if (!spool_file_wireformat || source_file_override) + if (!f.spool_file_wireformat || source_file_override) j = fread(buffer, 1, sizeof(buffer), l_data_file); else /* needs CRLF -> NL */ if ((s = US fgets(CS buffer, sizeof(buffer), l_data_file))) @@ -209,16 +208,14 @@ unspool_mbox(void) spam_ok = 0; malware_ok = 0; -if (spool_mbox_ok && !no_mbox_unspool) +if (spool_mbox_ok && !f.no_mbox_unspool) { - uschar *mbox_path; uschar *file_path; - struct dirent *entry; DIR *tempdir; + rmark reset_point = store_mark(); + uschar * mbox_path = string_sprintf("%s/scan/%s", spool_directory, spooled_message_id); - mbox_path = string_sprintf("%s/scan/%s", spool_directory, spooled_message_id); - - if (!(tempdir = opendir(CS mbox_path))) + if (!(tempdir = exim_opendir(mbox_path))) { debug_printf("Unable to opendir(%s): %s\n", mbox_path, strerror(errno)); /* Just in case we still can: */ @@ -226,7 +223,7 @@ if (spool_mbox_ok && !no_mbox_unspool) return; } /* loop thru dir & delete entries */ - while((entry = readdir(tempdir))) + for (struct dirent *entry; entry = readdir(tempdir); ) { uschar *name = US entry->d_name; int dummy; @@ -241,7 +238,7 @@ if (spool_mbox_ok && !no_mbox_unspool) /* remove directory */ rmdir(CS mbox_path); - store_reset(mbox_path); + store_reset(reset_point); } spool_mbox_ok = 0; }