1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
/*
* Copyright (c) 2000-2001, 2005, 2006 Proofpoint, Inc. and its suppliers.
* All rights reserved.
* Copyright (c) 1990, 1993
* The Regents of the University of California. All rights reserved.
*
* This code is derived from software contributed to Berkeley by
* Chris Torek.
*
* By using this file, you agree to the terms and conditions set
* forth in the LICENSE file which can be found at the top level of
* the sendmail distribution.
*/
#include <sm/gen.h>
SM_RCSID("@(#)$Id: fflush.c,v 1.46 2013-11-22 20:51:42 ca Exp $")
#include <unistd.h>
#include <errno.h>
#include <sm/time.h>
#include <signal.h>
#include <fcntl.h>
#include <string.h>
#include <sm/io.h>
#include <sm/assert.h>
#include <sm/setjmp.h>
#include "local.h"
#include <sm/conf.h>
/*
** SM_IO_FLUSH -- flush the buffer for a 'fp' to the "file"
**
** Flush a single file. We don't allow this function to flush
** all open files when fp==NULL any longer.
**
** Parameters:
** fp -- the file pointer buffer to flush
** timeout -- time to complete the flush
**
** Results:
** Failure: SM_IO_EOF and sets errno
** Success: 0 (zero)
*/
int
sm_io_flush(fp, timeout)
register SM_FILE_T *fp;
int SM_NONVOLATILE timeout;
{
int fd;
struct timeval to;
SM_REQUIRE_ISA(fp, SmFileMagic);
if ((fp->f_flags & (SMWR | SMRW)) == 0)
{
/*
** The file is not opened for writing, so it cannot be flushed
** (writable means SMWR [write] or SMRW [read/write].
*/
errno = EBADF;
return SM_IO_EOF;
}
SM_CONVERT_TIME(fp, fd, timeout, &to);
/* Now do the flush */
return sm_flush(fp, (int *) &timeout);
}
/*
** SM_FLUSH -- perform the actual flush
**
** Assumes that 'fp' has been validated before this function called.
**
** Parameters:
** fp -- file pointer to be flushed
** timeout -- max time allowed for flush (milliseconds)
**
** Results:
** Success: 0 (zero)
** Failure: SM_IO_EOF and errno set
**
** Side Effects:
** timeout will get updated with the time remaining (if any)
*/
int
sm_flush(fp, timeout)
register SM_FILE_T *fp;
int *timeout;
{
register unsigned char *p;
register int n, t;
int fd;
SM_REQUIRE_ISA(fp, SmFileMagic);
t = fp->f_flags;
if ((t & SMWR) == 0)
return 0;
if (t & SMSTR)
{
*fp->f_p = '\0';
return 0;
}
if ((p = fp->f_bf.smb_base) == NULL)
return 0;
n = fp->f_p - p; /* write this much */
if ((fd = sm_io_getinfo(fp, SM_IO_WHAT_FD, NULL)) == -1)
{
/* can't get an fd, likely internal 'fake' fp */
errno = 0;
fd = -1;
}
/*
** Set these immediately to avoid problems with longjmp and to allow
** exchange buffering (via setvbuf) in user write function.
*/
fp->f_p = p;
fp->f_w = t & (SMLBF|SMNBF) ? 0 : fp->f_bf.smb_size; /* implies SMFBF */
for (; n > 0; n -= t, p += t)
{
errno = 0; /* needed to ensure EOF correctly found */
/* Call the file type's write function */
t = (*fp->f_write)(fp, (char *)p, n);
if (t <= 0)
{
if (t == 0 && errno == 0)
break; /* EOF found */
if (IS_IO_ERROR(fd, t, *timeout))
{
fp->f_flags |= SMERR;
/* errno set by fp->f_write */
return SM_IO_EOF;
}
SM_IO_WR_TIMEOUT(fp, fd, *timeout);
t = 0;
}
}
return 0;
}
|
