Installed a modified version of Nikos Mavrogiannopoulos' patch that
[exim.git] / src / src / spool_in.c
CommitLineData
8e669ac1 1/* $Cambridge: exim/src/src/spool_in.c,v 1.8 2005/02/17 11:58:26 ph10 Exp $ */
059ec3d9
PH
2
3/*************************************************
4* Exim - an Internet mail transport agent *
5*************************************************/
6
c988f1f4 7/* Copyright (c) University of Cambridge 1995 - 2005 */
059ec3d9
PH
8/* See the file NOTICE for conditions of use and distribution. */
9
10/* Functions for reading spool files. When compiling for a utility (eximon),
11not all are needed, and some functionality can be cut out. */
12
13
14#include "exim.h"
15
16
17
18#ifndef COMPILE_UTILITY
19/*************************************************
20* Open and lock data file *
21*************************************************/
22
23/* The data file is the one that is used for locking, because the header file
24can get replaced during delivery because of header rewriting. The file has
25to opened with write access so that we can get an exclusive lock, but in
26fact it won't be written to. Just in case there's a major disaster (e.g.
27overwriting some other file descriptor with the value of this one), open it
28with append.
29
30Argument: the id of the message
31Returns: TRUE if file successfully opened and locked
32
33Side effect: deliver_datafile is set to the fd of the open file.
34*/
35
36BOOL
37spool_open_datafile(uschar *id)
38{
39int i;
40struct stat statbuf;
41flock_t lock_data;
42uschar spoolname[256];
43
44/* If split_spool_directory is set, first look for the file in the appropriate
45sub-directory of the input directory. If it is not found there, try the input
46directory itself, to pick up leftovers from before the splitting. If split_
47spool_directory is not set, first look in the main input directory. If it is
48not found there, try the split sub-directory, in case it is left over from a
49splitting state. */
50
51for (i = 0; i < 2; i++)
52 {
53 int save_errno;
54 message_subdir[0] = (split_spool_directory == (i == 0))? id[5] : 0;
55 sprintf(CS spoolname, "%s/input/%s/%s-D", spool_directory, message_subdir, id);
56 deliver_datafile = Uopen(spoolname, O_RDWR | O_APPEND, 0);
57 if (deliver_datafile >= 0) break;
58 save_errno = errno;
59 if (errno == ENOENT)
60 {
61 if (i == 0) continue;
62 if (!queue_running)
63 log_write(0, LOG_MAIN, "Spool file %s-D not found", id);
64 }
65 else log_write(0, LOG_MAIN, "Spool error for %s: %s", spoolname,
66 strerror(errno));
67 errno = save_errno;
68 return FALSE;
69 }
70
71/* File is open and message_subdir is set. Set the close-on-exec flag, and lock
72the file. We lock only the first line of the file (containing the message ID)
73because this apparently is needed for running Exim under Cygwin. If the entire
74file is locked in one process, a sub-process cannot access it, even when passed
75an open file descriptor (at least, I think that's the Cygwin story). On real
76Unix systems it doesn't make any difference as long as Exim is consistent in
77what it locks. */
78
79fcntl(deliver_datafile, F_SETFD, fcntl(deliver_datafile, F_GETFD) |
80 FD_CLOEXEC);
81
82lock_data.l_type = F_WRLCK;
83lock_data.l_whence = SEEK_SET;
84lock_data.l_start = 0;
85lock_data.l_len = SPOOL_DATA_START_OFFSET;
86
87if (fcntl(deliver_datafile, F_SETLK, &lock_data) < 0)
88 {
89 log_write(L_skip_delivery,
90 LOG_MAIN,
91 "Spool file is locked (another process is handling this message)");
92 close(deliver_datafile);
93 deliver_datafile = -1;
94 errno = 0;
95 return FALSE;
96 }
97
98/* Get the size of the data; don't include the leading filename line
99in the count, but add one for the newline before the data. */
100
101if (fstat(deliver_datafile, &statbuf) == 0)
102 {
103 message_body_size = statbuf.st_size - SPOOL_DATA_START_OFFSET;
104 message_size = message_body_size + 1;
105 }
106
107return TRUE;
108}
109#endif /* COMPILE_UTILITY */
110
111
112
113/*************************************************
114* Read non-recipients tree from spool file *
115*************************************************/
116
117/* The tree of non-recipients is written to the spool file in a form that
118makes it easy to read back into a tree. The format is as follows:
119
120 . Each node is preceded by two letter(Y/N) indicating whether it has left
121 or right children. There's one space after the two flags, before the name.
122
123 . The left subtree (if any) then follows, then the right subtree (if any).
124
125This function is entered with the next input line in the buffer. Note we must
126save the right flag before recursing with the same buffer.
127
128Once the tree is read, we re-construct the balance fields by scanning the tree.
129I forgot to write them out originally, and the compatible fix is to do it this
130way. This initial local recursing function does the necessary.
131
132Arguments:
133 node tree node
134
135Returns: maximum depth below the node, including the node itself
136*/
137
138static int
139count_below(tree_node *node)
140{
141int nleft, nright;
142if (node == NULL) return 0;
143nleft = count_below(node->left);
144nright = count_below(node->right);
145node->balance = (nleft > nright)? 1 : ((nright > nleft)? 2 : 0);
146return 1 + ((nleft > nright)? nleft : nright);
147}
148
149/* This is the real function...
150
151Arguments:
152 connect pointer to the root of the tree
153 f FILE to read data from
154 buffer contains next input line; further lines read into it
155 buffer_size size of the buffer
156
157Returns: FALSE on format error
158*/
159
160static BOOL
161read_nonrecipients_tree(tree_node **connect, FILE *f, uschar *buffer,
162 int buffer_size)
163{
164tree_node *node;
165int n = Ustrlen(buffer);
166BOOL right = buffer[1] == 'Y';
167
168if (n < 5) return FALSE; /* malformed line */
169buffer[n-1] = 0; /* Remove \n */
170node = store_get(sizeof(tree_node) + n - 3);
171*connect = node;
172Ustrcpy(node->name, buffer + 3);
173node->data.ptr = NULL;
174
175if (buffer[0] == 'Y')
176 {
177 if (Ufgets(buffer, buffer_size, f) == NULL ||
178 !read_nonrecipients_tree(&node->left, f, buffer, buffer_size))
179 return FALSE;
180 }
181else node->left = NULL;
182
183if (right)
184 {
185 if (Ufgets(buffer, buffer_size, f) == NULL ||
186 !read_nonrecipients_tree(&node->right, f, buffer, buffer_size))
187 return FALSE;
188 }
189else node->right = NULL;
190
191(void) count_below(*connect);
192return TRUE;
193}
194
195
196
197
198/*************************************************
199* Read spool header file *
200*************************************************/
201
202/* This function reads a spool header file and places the data into the
203appropriate global variables. The header portion is always read, but header
204structures are built only if read_headers is set true. It isn't, for example,
205while generating -bp output.
206
207It may be possible for blocks of nulls (binary zeroes) to get written on the
208end of a file if there is a system crash during writing. It was observed on an
209earlier version of Exim that omitted to fsync() the files - this is thought to
210have been the cause of that incident, but in any case, this code must be robust
211against such an event, and if such a file is encountered, it must be treated as
212malformed.
213
214Arguments:
215 name name of the header file, including the -H
216 read_headers TRUE if in-store header structures are to be built
217 subdir_set TRUE is message_subdir is already set
218
219Returns: spool_read_OK success
220 spool_read_notopen open failed
221 spool_read_enverror error in the envelope portion
222 spool_read_hdrdrror error in the header portion
223*/
224
225int
226spool_read_header(uschar *name, BOOL read_headers, BOOL subdir_set)
227{
228FILE *f = NULL;
229int n;
230int rcount = 0;
231long int uid, gid;
232BOOL inheader = FALSE;
1e70f85b 233uschar *p;
059ec3d9
PH
234
235/* Reset all the global variables to their default values. However, there is
236one exception. DO NOT change the default value of dont_deliver, because it may
237be forced by an external setting. */
238
239for (n = 0; n < ACL_C_MAX + ACL_M_MAX; n++) acl_var[n] = NULL;
240
241authenticated_id = NULL;
242authenticated_sender = NULL;
243allow_unqualified_recipient = FALSE;
244allow_unqualified_sender = FALSE;
245body_linecount = 0;
246body_zerocount = 0;
247deliver_firsttime = FALSE;
248deliver_freeze = FALSE;
249deliver_frozen_at = 0;
250deliver_manual_thaw = FALSE;
251/* dont_deliver must NOT be reset */
252header_list = header_last = NULL;
b08b24c8 253host_lookup_deferred = FALSE;
059ec3d9
PH
254host_lookup_failed = FALSE;
255interface_address = NULL;
256interface_port = 0;
257local_error_message = FALSE;
258local_scan_data = NULL;
259message_linecount = 0;
260received_protocol = NULL;
261received_count = 0;
262recipients_list = NULL;
263sender_address = NULL;
264sender_fullhost = NULL;
265sender_helo_name = NULL;
266sender_host_address = NULL;
267sender_host_name = NULL;
268sender_host_port = 0;
269sender_host_authenticated = NULL;
270sender_ident = NULL;
271sender_local = FALSE;
272sender_set_untrusted = FALSE;
1f5b4c3d 273smtp_active_hostname = primary_hostname;
059ec3d9
PH
274tree_nonrecipients = NULL;
275
8523533c
TK
276#ifdef EXPERIMENTAL_BRIGHTMAIL
277bmi_run = 0;
278bmi_verdicts = NULL;
279#endif
280
059ec3d9
PH
281#ifdef SUPPORT_TLS
282tls_certificate_verified = FALSE;
283tls_cipher = NULL;
284tls_peerdn = NULL;
285#endif
286
8523533c 287#ifdef WITH_CONTENT_SCAN
8523533c
TK
288spam_score_int = NULL;
289#endif
290
059ec3d9
PH
291/* Generate the full name and open the file. If message_subdir is already
292set, just look in the given directory. Otherwise, look in both the split
293and unsplit directories, as for the data file above. */
294
295for (n = 0; n < 2; n++)
296 {
297 if (!subdir_set)
298 message_subdir[0] = (split_spool_directory == (n == 0))? name[5] : 0;
299 sprintf(CS big_buffer, "%s/input/%s/%s", spool_directory, message_subdir,
300 name);
301 f = Ufopen(big_buffer, "rb");
302 if (f != NULL) break;
303 if (n != 0 || subdir_set || errno != ENOENT) return spool_read_notopen;
304 }
305
306errno = 0;
307
308#ifndef COMPILE_UTILITY
309DEBUG(D_deliver) debug_printf("reading spool file %s\n", name);
310#endif /* COMPILE_UTILITY */
311
312/* The first line of a spool file contains the message id followed by -H (i.e.
313the file name), in order to make the file self-identifying. */
314
315if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
316if (Ustrlen(big_buffer) != MESSAGE_ID_LENGTH + 3 ||
317 Ustrncmp(big_buffer, name, MESSAGE_ID_LENGTH + 2) != 0)
318 goto SPOOL_FORMAT_ERROR;
319
320/* The next three lines in the header file are in a fixed format. The first
321contains the login, uid, and gid of the user who caused the file to be written.
322The second contains the mail address of the message's sender, enclosed in <>.
323The third contains the time the message was received, and the number of warning
324messages for delivery delays that have been sent. */
325
326if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
327
1e70f85b
PH
328p = big_buffer + Ustrlen(big_buffer);
329while (p > big_buffer && isspace(p[-1])) p--;
330*p = 0;
331if (!isdigit(p[-1])) goto SPOOL_FORMAT_ERROR;
332while (p > big_buffer && isdigit(p[-1])) p--;
333gid = Uatoi(p);
334if (p <= big_buffer || *(--p) != ' ') goto SPOOL_FORMAT_ERROR;
335*p = 0;
336if (!isdigit(p[-1])) goto SPOOL_FORMAT_ERROR;
337while (p > big_buffer && isdigit(p[-1])) p--;
338uid = Uatoi(p);
339if (p <= big_buffer || *(--p) != ' ') goto SPOOL_FORMAT_ERROR;
340*p = 0;
8e669ac1 341
1e70f85b 342originator_login = string_copy(big_buffer);
059ec3d9
PH
343originator_uid = (uid_t)uid;
344originator_gid = (gid_t)gid;
345
346if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
347n = Ustrlen(big_buffer);
348if (n < 3 || big_buffer[0] != '<' || big_buffer[n-2] != '>')
349 goto SPOOL_FORMAT_ERROR;
350
351sender_address = store_get(n-2);
352Ustrncpy(sender_address, big_buffer+1, n-3);
353sender_address[n-3] = 0;
354
355if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
356if (sscanf(CS big_buffer, "%d %d", &received_time, &warning_count) != 2)
357 goto SPOOL_FORMAT_ERROR;
358
359message_age = time(NULL) - received_time;
360
361#ifndef COMPILE_UTILITY
362DEBUG(D_deliver) debug_printf("user=%s uid=%ld gid=%ld sender=%s\n",
363 originator_login, (long int)originator_uid, (long int)originator_gid,
364 sender_address);
365#endif /* COMPILE_UTILITY */
366
367/* Now there may be a number of optional lines, each starting with "-".
368If you add a new setting here, make sure you set the default above. */
369
370for (;;)
371 {
372 if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
373 if (big_buffer[0] != '-') break;
374
375 big_buffer[Ustrlen(big_buffer) - 1] = 0;
376 if (Ustrncmp(big_buffer, "-acl ", 5) == 0)
377 {
378 int index, count;
379 if (sscanf(CS big_buffer + 5, "%d %d", &index, &count) != 2)
380 goto SPOOL_FORMAT_ERROR;
381 /* Ignore if index too big - might be if a later release with more
382 variables built this spool file. */
383 if (index < ACL_C_MAX + ACL_M_MAX)
384 {
385 acl_var[index] = store_get(count + 1);
386 if (fread(acl_var[index], 1, count+1, f) < count) goto SPOOL_READ_ERROR;
387 acl_var[index][count] = 0;
388 }
389 }
390 else if (Ustrcmp(big_buffer, "-local") == 0) sender_local = TRUE;
391 else if (Ustrcmp(big_buffer, "-localerror") == 0)
392 local_error_message = TRUE;
393 else if (Ustrncmp(big_buffer, "-local_scan ", 12) == 0)
394 local_scan_data = string_copy(big_buffer + 12);
8e669ac1 395#ifdef WITH_CONTENT_SCAN
8523533c 396 else if (Ustrncmp(big_buffer, "-spam_score_int ", 16) == 0)
8e669ac1 397 spam_score_int = string_copy(big_buffer + 16);
8523533c
TK
398#endif
399#ifdef EXPERIMENTAL_BRIGHTMAIL
400 else if (Ustrncmp(big_buffer, "-bmi_verdicts ", 14) == 0)
401 bmi_verdicts = string_copy(big_buffer + 14);
402#endif
b08b24c8
PH
403 else if (Ustrcmp(big_buffer, "-host_lookup_deferred") == 0)
404 host_lookup_deferred = TRUE;
059ec3d9
PH
405 else if (Ustrcmp(big_buffer, "-host_lookup_failed") == 0)
406 host_lookup_failed = TRUE;
407 else if (Ustrncmp(big_buffer, "-body_linecount", 15) == 0)
408 body_linecount = Uatoi(big_buffer + 15);
409 else if (Ustrncmp(big_buffer, "-body_zerocount", 15) == 0)
410 body_zerocount = Uatoi(big_buffer + 15);
411 else if (Ustrncmp(big_buffer, "-frozen", 7) == 0)
412 {
413 deliver_freeze = TRUE;
414 deliver_frozen_at = Uatoi(big_buffer + 7);
415 }
416 else if (Ustrcmp(big_buffer, "-allow_unqualified_recipient") == 0)
417 allow_unqualified_recipient = TRUE;
418 else if (Ustrcmp(big_buffer, "-allow_unqualified_sender") == 0)
419 allow_unqualified_sender = TRUE;
420 else if (Ustrcmp(big_buffer, "-deliver_firsttime") == 0)
421 deliver_firsttime = TRUE;
422 else if (Ustrcmp(big_buffer, "-manual_thaw") == 0)
423 deliver_manual_thaw = TRUE;
424 else if (Ustrncmp(big_buffer, "-auth_id", 8) == 0)
425 authenticated_id = string_copy(big_buffer + 9);
426 else if (Ustrncmp(big_buffer, "-auth_sender", 12) == 0)
427 authenticated_sender = string_copy(big_buffer + 13);
428 else if (Ustrncmp(big_buffer, "-sender_set_untrusted", 21) == 0)
429 sender_set_untrusted = TRUE;
430
431 #ifdef SUPPORT_TLS
432 else if (Ustrncmp(big_buffer, "-tls_certificate_verified", 25) == 0)
433 tls_certificate_verified = TRUE;
434 else if (Ustrncmp(big_buffer, "-tls_cipher", 11) == 0)
435 tls_cipher = string_copy(big_buffer + 12);
436 else if (Ustrncmp(big_buffer, "-tls_peerdn", 11) == 0)
437 tls_peerdn = string_copy(big_buffer + 12);
438 #endif
439
440 /* We now record the port number after the address, separated by a
441 dot. For compatibility during upgrading, do nothing if there
442 isn't a value (it gets left at zero). */
443
444 else if (Ustrncmp(big_buffer, "-host_address", 13) == 0)
445 {
446 sender_host_port = host_extract_port(big_buffer + 14);
447 sender_host_address = string_copy(big_buffer + 14);
448 }
449
450 else if (Ustrncmp(big_buffer, "-interface_address", 18) == 0)
451 {
452 interface_port = host_extract_port(big_buffer + 19);
453 interface_address = string_copy(big_buffer + 19);
454 }
455
1f5b4c3d 456 else if (Ustrncmp(big_buffer, "-active_hostname", 16) == 0)
8e669ac1 457 smtp_active_hostname = string_copy(big_buffer + 17);
059ec3d9
PH
458 else if (Ustrncmp(big_buffer, "-host_auth", 10) == 0)
459 sender_host_authenticated = string_copy(big_buffer + 11);
460 else if (Ustrncmp(big_buffer, "-host_name", 10) == 0)
461 sender_host_name = string_copy(big_buffer + 11);
462 else if (Ustrncmp(big_buffer, "-helo_name", 10) == 0)
463 sender_helo_name = string_copy(big_buffer + 11);
464 else if (Ustrncmp(big_buffer, "-ident", 6) == 0)
465 sender_ident = string_copy(big_buffer + 7);
466 else if (Ustrncmp(big_buffer, "-received_protocol", 18) == 0)
467 received_protocol = string_copy(big_buffer + 19);
468 else if (Ustrncmp(big_buffer, "-N", 2) == 0)
469 dont_deliver = TRUE;
470
471 /* To allow new versions of Exim that add additional flags to interwork
472 with older versions that do not understand them, just ignore any flagged
473 lines that we don't recognize. Otherwise it wouldn't be possible to back
474 off a new version that left new-style flags written on the spool. That's
475 why the following line is commented out. */
476
477 /* else goto SPOOL_FORMAT_ERROR; */
478 }
479
480/* Build sender_fullhost if required */
481
482#ifndef COMPILE_UTILITY
483host_build_sender_fullhost();
484#endif /* COMPILE_UTILITY */
485
486#ifndef COMPILE_UTILITY
487DEBUG(D_deliver)
488 debug_printf("sender_local=%d ident=%s\n", sender_local,
489 (sender_ident == NULL)? US"unset" : sender_ident);
490#endif /* COMPILE_UTILITY */
491
492/* We now have the tree of addresses NOT to deliver to, or a line
493containing "XX", indicating no tree. */
494
495if (Ustrncmp(big_buffer, "XX\n", 3) != 0 &&
496 !read_nonrecipients_tree(&tree_nonrecipients, f, big_buffer, big_buffer_size))
497 goto SPOOL_FORMAT_ERROR;
498
499#ifndef COMPILE_UTILITY
500DEBUG(D_deliver)
501 {
502 debug_printf("Non-recipients:\n");
503 debug_print_tree(tree_nonrecipients);
504 }
505#endif /* COMPILE_UTILITY */
506
507/* After reading the tree, the next line has not yet been read into the
508buffer. It contains the count of recipients which follow on separate lines. */
509
510if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
511if (sscanf(CS big_buffer, "%d", &rcount) != 1) goto SPOOL_FORMAT_ERROR;
512
513#ifndef COMPILE_UTILITY
514DEBUG(D_deliver) debug_printf("recipients_count=%d\n", rcount);
515#endif /* COMPILE_UTILITY */
516
517recipients_list_max = rcount;
518recipients_list = store_get(rcount * sizeof(recipient_item));
519
520for (recipients_count = 0; recipients_count < rcount; recipients_count++)
521 {
522 int nn;
523 int pno = -1;
524 uschar *errors_to = NULL;
525 uschar *p;
526
527 if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
528 nn = Ustrlen(big_buffer);
529 if (nn < 2) goto SPOOL_FORMAT_ERROR;
530
531 /* Remove the newline; this terminates the address if there is no additional
532 data on the line. */
533
534 p = big_buffer + nn - 1;
535 *p-- = 0;
536
537 /* Look back from the end of the line for digits and special terminators.
538 Since an address must end with a domain, we can tell that extra data is
539 present by the presence of the terminator, which is always some character
540 that cannot exist in a domain. (If I'd thought of the need for additional
541 data early on, I'd have put it at the start, with the address at the end. As
542 it is, we have to operate backwards. Addresses are permitted to contain
543 spaces, you see.)
544
545 This code has to cope with various versions of this data that have evolved
546 over time. In all cases, the line might just contain an address, with no
547 additional data. Otherwise, the possibilities are as follows:
548
549 Exim 3 type: <address><space><digits>,<digits>,<digits>
550
551 The second set of digits is the parent number for one_time addresses. The
552 other values were remnants of earlier experiments that were abandoned.
553
554 Exim 4 first type: <address><space><digits>
555
556 The digits are the parent number for one_time addresses.
557
558 Exim 4 new type: <address><space><data>#<type bits>
559
560 The type bits indicate what the contents of the data are.
561
562 Bit 01 indicates that, reading from right to left, the data
563 ends with <errors_to address><space><len>,<pno> where pno is
564 the parent number for one_time addresses, and len is the length
565 of the errors_to address (zero meaning none).
566 */
567
568 while (isdigit(*p)) p--;
569
570 /* Handle Exim 3 spool files */
571
572 if (*p == ',')
573 {
574 int dummy;
575 while (isdigit(*(--p)) || *p == ',');
576 if (*p == ' ')
577 {
578 *p++ = 0;
579 sscanf(CS p, "%d,%d", &dummy, &pno);
580 }
581 }
582
583 /* Handle early Exim 4 spool files */
584
585 else if (*p == ' ')
586 {
587 *p++ = 0;
588 sscanf(CS p, "%d", &pno);
589 }
590
591 /* Handle current format Exim 4 spool files */
592
593 else if (*p == '#')
594 {
595 int flags;
596 sscanf(CS p+1, "%d", &flags);
597
598 if ((flags & 0x01) != 0) /* one_time data exists */
599 {
600 int len;
601 while (isdigit(*(--p)) || *p == ',' || *p == '-');
602 sscanf(CS p+1, "%d,%d", &len, &pno);
603 *p = 0;
604 if (len > 0)
605 {
606 p -= len;
607 errors_to = string_copy(p);
608 }
609 }
610
611 *(--p) = 0; /* Terminate address */
612 }
613
614 recipients_list[recipients_count].address = string_copy(big_buffer);
615 recipients_list[recipients_count].pno = pno;
616 recipients_list[recipients_count].errors_to = errors_to;
617 }
618
619/* The remainder of the spool header file contains the headers for the message,
620separated off from the previous data by a blank line. Each header is preceded
621by a count of its length and either a certain letter (for various identified
622headers), space (for a miscellaneous live header) or an asterisk (for a header
623that has been rewritten). Count the Received: headers. We read the headers
624always, in order to check on the format of the file, but only create a header
625list if requested to do so. */
626
627inheader = TRUE;
628if (Ufgets(big_buffer, big_buffer_size, f) == NULL) goto SPOOL_READ_ERROR;
629if (big_buffer[0] != '\n') goto SPOOL_FORMAT_ERROR;
630
631while ((n = fgetc(f)) != EOF)
632 {
633 header_line *h;
634 uschar flag[4];
635 int i;
636
637 if (!isdigit(n)) goto SPOOL_FORMAT_ERROR;
638 ungetc(n, f);
639 fscanf(f, "%d%c ", &n, flag);
640 if (flag[0] != '*') message_size += n; /* Omit non-transmitted headers */
641
642 if (read_headers)
643 {
644 h = store_get(sizeof(header_line));
645 h->next = NULL;
646 h->type = flag[0];
647 h->slen = n;
648 h->text = store_get(n+1);
649
650 if (h->type == htype_received) received_count++;
651
652 if (header_list == NULL) header_list = h;
653 else header_last->next = h;
654 header_last = h;
655
656 for (i = 0; i < n; i++)
657 {
658 int c = fgetc(f);
659 if (c == 0 || c == EOF) goto SPOOL_FORMAT_ERROR;
660 if (c == '\n' && h->type != htype_old) message_linecount++;
661 h->text[i] = c;
662 }
663 h->text[i] = 0;
664 }
665
666 /* Not requiring header data, just skip through the bytes */
667
668 else for (i = 0; i < n; i++)
669 {
670 int c = fgetc(f);
671 if (c == 0 || c == EOF) goto SPOOL_FORMAT_ERROR;
672 }
673 }
674
675/* We have successfully read the data in the header file. Update the message
676line count by adding the body linecount to the header linecount. Close the file
677and give a positive response. */
678
679#ifndef COMPILE_UTILITY
680DEBUG(D_deliver) debug_printf("body_linecount=%d message_linecount=%d\n",
681 body_linecount, message_linecount);
682#endif /* COMPILE_UTILITY */
683
684message_linecount += body_linecount;
685
686fclose(f);
687return spool_read_OK;
688
689
690/* There was an error reading the spool or there was missing data,
691or there was a format error. A "read error" with no errno means an
692unexpected EOF, which we treat as a format error. */
693
694SPOOL_READ_ERROR:
695if (errno != 0)
696 {
697 n = errno;
698
699 #ifndef COMPILE_UTILITY
700 DEBUG(D_any) debug_printf("Error while reading spool file %s\n", name);
701 #endif /* COMPILE_UTILITY */
702
703 fclose(f);
704 errno = n;
705 return inheader? spool_read_hdrerror : spool_read_enverror;
706 }
707
708SPOOL_FORMAT_ERROR:
709
710#ifndef COMPILE_UTILITY
711DEBUG(D_any) debug_printf("Format error in spool file %s\n", name);
712#endif /* COMPILE_UTILITY */
713
714fclose(f);
715errno = ERRNO_SPOOLFORMAT;
716return inheader? spool_read_hdrerror : spool_read_enverror;
717}
718
719/* End of spool_in.c */