blob: 4011b7180320ee8a4aef62d3c34b190f9cc24728 (
plain)
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
|
/* Copyright (C) 2004 Manuel Novoa III <mjn3@codepoet.org>
*
* GNU Library General Public License (LGPL) version 2 or later.
*
* Dedicated to Toni. See uClibc/DEDICATION.mjn3 for details.
*/
#include "_stdio.h"
/* Given a writing stream with no buffered output, write the
* data in 'buf' (which may be the stream's bufstart) of size
* 'bufsize' to the stream. If a write error occurs, set the
* stream's error indicator and (if buffering) buffer as much
* data as possible (FBF) or only up to '\n' (LBF) to implement
* "as if fputc()" clause in the standard.
*
* Returns the number of bytes written and/or buffered.
*
* Notes:
* Calling with bufsize == 0 is permitted, and buf is ignored in
* that case.
* We implement fflush() by setting bufpos to bufstart and passing
* bufstart as the buf arg. If there is a write error, the
* unwritten buffered data will simply be moved to the beginning
* of the buffer. Since the data obviously fits in the buffer
* and since there will be no '\n' chars in the buffer in the LBF
* case, no data will be lost.
* NOT THREADSAFE! Assumes stream already locked if necessary.
*/
size_t attribute_hidden __stdio_WRITE(register FILE *stream,
register const unsigned char *buf, size_t bufsize)
{
size_t todo;
ssize_t rv, stodo;
__STDIO_STREAM_VALIDATE(stream);
assert(stream->__filedes >= -1);
assert(__STDIO_STREAM_IS_WRITING(stream));
assert(!__STDIO_STREAM_BUFFER_WUSED(stream)); /* Buffer must be empty. */
todo = bufsize;
while (todo != 0) {
stodo = (todo <= SSIZE_MAX) ? todo : SSIZE_MAX;
rv = __WRITE(stream, (char *) buf, stodo);
if (rv >= 0) {
#ifdef __UCLIBC_MJN3_ONLY__
#warning TODO: Make custom stream write return check optional.
#endif
#ifdef __UCLIBC_HAS_GLIBC_CUSTOM_STREAMS__
assert(rv <= stodo);
if (rv > stodo) { /* Wrote more than stodo! */
/* abort(); */
}
#endif
todo -= rv;
buf += rv;
} else
#ifdef __UCLIBC_MJN3_ONLY__
#warning EINTR?
#endif
/* if (errno != EINTR) */
{
__STDIO_STREAM_SET_ERROR(stream);
#ifdef __STDIO_BUFFERS
stodo = __STDIO_STREAM_BUFFER_SIZE(stream);
if (stodo != 0) {
unsigned char *s;
if (stodo > todo) {
stodo = todo;
}
s = stream->__bufstart;
do {
*s = *buf;
if ((*s == '\n')
&& __STDIO_STREAM_IS_LBF(stream)
) {
break;
}
++s;
++buf;
} while (--stodo);
stream->__bufpos = s;
todo -= (s - stream->__bufstart);
}
#endif /* __STDIO_BUFFERS */
bufsize -= todo;
break;
}
}
__STDIO_STREAM_VALIDATE(stream);
return bufsize;
}
|
