(__pselect): No need to enable async cancellation here. This is done in select.
[glibc.git] / libio / fileops.c
blobcf7fd65421cc1779912d2592660e8381295ebc55
1 /* Copyright (C) 1993, 1995, 1997-2005, 2006 Free Software Foundation, Inc.
2 This file is part of the GNU C Library.
3 Written by Per Bothner <bothner@cygnus.com>.
5 The GNU C Library is free software; you can redistribute it and/or
6 modify it under the terms of the GNU Lesser General Public
7 License as published by the Free Software Foundation; either
8 version 2.1 of the License, or (at your option) any later version.
10 The GNU C Library is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Lesser General Public License for more details.
15 You should have received a copy of the GNU Lesser General Public
16 License along with the GNU C Library; if not, write to the Free
17 Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
18 02111-1307 USA.
20 As a special exception, if you link the code in this file with
21 files compiled with a GNU compiler to produce an executable,
22 that does not cause the resulting executable to be covered by
23 the GNU Lesser General Public License. This exception does not
24 however invalidate any other reasons why the executable file
25 might be covered by the GNU Lesser General Public License.
26 This exception applies to code released by its copyright holders
27 in files containing the exception. */
30 #ifndef _POSIX_SOURCE
31 # define _POSIX_SOURCE
32 #endif
33 #include "libioP.h"
34 #include <assert.h>
35 #include <fcntl.h>
36 #include <sys/param.h>
37 #include <sys/types.h>
38 #include <sys/stat.h>
39 #include <string.h>
40 #include <errno.h>
41 #include <unistd.h>
42 #ifdef __STDC__
43 #include <stdlib.h>
44 #endif
45 #if _LIBC
46 # include "../wcsmbs/wcsmbsload.h"
47 # include "../iconv/gconv_charset.h"
48 # include "../iconv/gconv_int.h"
49 # include <shlib-compat.h>
50 # include <not-cancel.h>
51 #endif
52 #ifndef errno
53 extern int errno;
54 #endif
55 #ifndef __set_errno
56 # define __set_errno(Val) errno = (Val)
57 #endif
60 #ifdef _LIBC
61 # define open(Name, Flags, Prot) __open (Name, Flags, Prot)
62 # define lseek(FD, Offset, Whence) __lseek (FD, Offset, Whence)
63 # define read(FD, Buf, NBytes) __read (FD, Buf, NBytes)
64 # define write(FD, Buf, NBytes) __write (FD, Buf, NBytes)
65 # define _IO_do_write _IO_new_do_write /* For macro uses. */
66 # define _IO_file_close_it _IO_new_file_close_it
67 #else
68 # define _IO_new_do_write _IO_do_write
69 # define _IO_new_file_attach _IO_file_attach
70 # define _IO_new_file_close_it _IO_file_close_it
71 # define _IO_new_file_finish _IO_file_finish
72 # define _IO_new_file_fopen _IO_file_fopen
73 # define _IO_new_file_init _IO_file_init
74 # define _IO_new_file_setbuf _IO_file_setbuf
75 # define _IO_new_file_sync _IO_file_sync
76 # define _IO_new_file_overflow _IO_file_overflow
77 # define _IO_new_file_seekoff _IO_file_seekoff
78 # define _IO_new_file_underflow _IO_file_underflow
79 # define _IO_new_file_write _IO_file_write
80 # define _IO_new_file_xsputn _IO_file_xsputn
81 #endif
84 #ifdef _LIBC
85 extern struct __gconv_trans_data __libio_translit attribute_hidden;
86 #endif
89 /* An fstream can be in at most one of put mode, get mode, or putback mode.
90 Putback mode is a variant of get mode.
92 In a filebuf, there is only one current position, instead of two
93 separate get and put pointers. In get mode, the current position
94 is that of gptr(); in put mode that of pptr().
96 The position in the buffer that corresponds to the position
97 in external file system is normally _IO_read_end, except in putback
98 mode, when it is _IO_save_end.
99 If the field _fb._offset is >= 0, it gives the offset in
100 the file as a whole corresponding to eGptr(). (?)
102 PUT MODE:
103 If a filebuf is in put mode, then all of _IO_read_ptr, _IO_read_end,
104 and _IO_read_base are equal to each other. These are usually equal
105 to _IO_buf_base, though not necessarily if we have switched from
106 get mode to put mode. (The reason is to maintain the invariant
107 that _IO_read_end corresponds to the external file position.)
108 _IO_write_base is non-NULL and usually equal to _IO_base_base.
109 We also have _IO_write_end == _IO_buf_end, but only in fully buffered mode.
110 The un-flushed character are those between _IO_write_base and _IO_write_ptr.
112 GET MODE:
113 If a filebuf is in get or putback mode, eback() != egptr().
114 In get mode, the unread characters are between gptr() and egptr().
115 The OS file position corresponds to that of egptr().
117 PUTBACK MODE:
118 Putback mode is used to remember "excess" characters that have
119 been sputbackc'd in a separate putback buffer.
120 In putback mode, the get buffer points to the special putback buffer.
121 The unread characters are the characters between gptr() and egptr()
122 in the putback buffer, as well as the area between save_gptr()
123 and save_egptr(), which point into the original reserve buffer.
124 (The pointers save_gptr() and save_egptr() are the values
125 of gptr() and egptr() at the time putback mode was entered.)
126 The OS position corresponds to that of save_egptr().
128 LINE BUFFERED OUTPUT:
129 During line buffered output, _IO_write_base==base() && epptr()==base().
130 However, ptr() may be anywhere between base() and ebuf().
131 This forces a call to filebuf::overflow(int C) on every put.
132 If there is more space in the buffer, and C is not a '\n',
133 then C is inserted, and pptr() incremented.
135 UNBUFFERED STREAMS:
136 If a filebuf is unbuffered(), the _shortbuf[1] is used as the buffer.
139 #define CLOSED_FILEBUF_FLAGS \
140 (_IO_IS_FILEBUF+_IO_NO_READS+_IO_NO_WRITES+_IO_TIED_PUT_GET)
143 void
144 _IO_new_file_init (fp)
145 struct _IO_FILE_plus *fp;
147 /* POSIX.1 allows another file handle to be used to change the position
148 of our file descriptor. Hence we actually don't know the actual
149 position before we do the first fseek (and until a following fflush). */
150 fp->file._offset = _IO_pos_BAD;
151 fp->file._IO_file_flags |= CLOSED_FILEBUF_FLAGS;
153 INTUSE(_IO_link_in) (fp);
154 fp->file._fileno = -1;
156 INTDEF2(_IO_new_file_init, _IO_file_init)
159 _IO_new_file_close_it (fp)
160 _IO_FILE *fp;
162 int write_status, close_status;
163 if (!_IO_file_is_open (fp))
164 return EOF;
166 if ((fp->_flags & _IO_NO_WRITES) == 0
167 && (fp->_flags & _IO_CURRENTLY_PUTTING) != 0)
168 write_status = _IO_do_flush (fp);
169 else
170 write_status = 0;
172 INTUSE(_IO_unsave_markers) (fp);
174 close_status = _IO_SYSCLOSE (fp);
176 /* Free buffer. */
177 if (fp->_mode <= 0)
179 INTUSE(_IO_setb) (fp, NULL, NULL, 0);
180 _IO_setg (fp, NULL, NULL, NULL);
181 _IO_setp (fp, NULL, NULL);
183 #if defined _LIBC || defined _GLIBCPP_USE_WCHAR_T
184 else
186 if (_IO_have_wbackup (fp))
187 INTUSE(_IO_free_wbackup_area) (fp);
188 INTUSE(_IO_wsetb) (fp, NULL, NULL, 0);
189 _IO_wsetg (fp, NULL, NULL, NULL);
190 _IO_wsetp (fp, NULL, NULL);
192 #endif
194 INTUSE(_IO_un_link) ((struct _IO_FILE_plus *) fp);
195 fp->_flags = _IO_MAGIC|CLOSED_FILEBUF_FLAGS;
196 fp->_fileno = -1;
197 fp->_offset = _IO_pos_BAD;
199 return close_status ? close_status : write_status;
201 INTDEF2(_IO_new_file_close_it, _IO_file_close_it)
203 void
204 _IO_new_file_finish (fp, dummy)
205 _IO_FILE *fp;
206 int dummy;
208 if (_IO_file_is_open (fp))
210 _IO_do_flush (fp);
211 if (!(fp->_flags & _IO_DELETE_DONT_CLOSE))
212 _IO_SYSCLOSE (fp);
214 INTUSE(_IO_default_finish) (fp, 0);
216 INTDEF2(_IO_new_file_finish, _IO_file_finish)
218 _IO_FILE *
219 _IO_file_open (fp, filename, posix_mode, prot, read_write, is32not64)
220 _IO_FILE *fp;
221 const char *filename;
222 int posix_mode;
223 int prot;
224 int read_write;
225 int is32not64;
227 int fdesc;
228 #ifdef _LIBC
229 if (__builtin_expect (fp->_flags2 & _IO_FLAGS2_NOTCANCEL, 0))
230 fdesc = open_not_cancel (filename,
231 posix_mode | (is32not64 ? 0 : O_LARGEFILE), prot);
232 else
233 fdesc = open (filename, posix_mode | (is32not64 ? 0 : O_LARGEFILE), prot);
234 #else
235 fdesc = open (filename, posix_mode, prot);
236 #endif
237 if (fdesc < 0)
238 return NULL;
239 fp->_fileno = fdesc;
240 _IO_mask_flags (fp, read_write,_IO_NO_READS+_IO_NO_WRITES+_IO_IS_APPENDING);
241 if ((read_write & _IO_IS_APPENDING) && (read_write & _IO_NO_READS))
242 if (_IO_SEEKOFF (fp, (_IO_off64_t)0, _IO_seek_end, _IOS_INPUT|_IOS_OUTPUT)
243 == _IO_pos_BAD && errno != ESPIPE)
245 close_not_cancel (fdesc);
246 return NULL;
248 INTUSE(_IO_link_in) ((struct _IO_FILE_plus *) fp);
249 return fp;
251 libc_hidden_def (_IO_file_open)
253 _IO_FILE *
254 _IO_new_file_fopen (fp, filename, mode, is32not64)
255 _IO_FILE *fp;
256 const char *filename;
257 const char *mode;
258 int is32not64;
260 int oflags = 0, omode;
261 int read_write;
262 int oprot = 0666;
263 int i;
264 _IO_FILE *result;
265 #ifdef _LIBC
266 const char *cs;
267 const char *last_recognized;
268 #endif
270 if (_IO_file_is_open (fp))
271 return 0;
272 switch (*mode)
274 case 'r':
275 omode = O_RDONLY;
276 read_write = _IO_NO_WRITES;
277 break;
278 case 'w':
279 omode = O_WRONLY;
280 oflags = O_CREAT|O_TRUNC;
281 read_write = _IO_NO_READS;
282 break;
283 case 'a':
284 omode = O_WRONLY;
285 oflags = O_CREAT|O_APPEND;
286 read_write = _IO_NO_READS|_IO_IS_APPENDING;
287 break;
288 default:
289 __set_errno (EINVAL);
290 return NULL;
292 #ifdef _LIBC
293 last_recognized = mode;
294 #endif
295 for (i = 1; i < 6; ++i)
297 switch (*++mode)
299 case '\0':
300 break;
301 case '+':
302 omode = O_RDWR;
303 read_write &= _IO_IS_APPENDING;
304 #ifdef _LIBC
305 last_recognized = mode;
306 #endif
307 continue;
308 case 'x':
309 oflags |= O_EXCL;
310 #ifdef _LIBC
311 last_recognized = mode;
312 #endif
313 continue;
314 case 'b':
315 #ifdef _LIBC
316 last_recognized = mode;
317 #endif
318 continue;
319 case 'm':
320 fp->_flags2 |= _IO_FLAGS2_MMAP;
321 continue;
322 case 'c':
323 fp->_flags2 |= _IO_FLAGS2_NOTCANCEL;
324 break;
325 default:
326 /* Ignore. */
327 continue;
329 break;
332 result = _IO_file_open (fp, filename, omode|oflags, oprot, read_write,
333 is32not64);
336 #ifdef _LIBC
337 if (result != NULL)
339 /* Test whether the mode string specifies the conversion. */
340 cs = strstr (last_recognized + 1, ",ccs=");
341 if (cs != NULL)
343 /* Yep. Load the appropriate conversions and set the orientation
344 to wide. */
345 struct gconv_fcts fcts;
346 struct _IO_codecvt *cc;
347 char *endp = __strchrnul (cs + 5, ',');
348 char ccs[endp - (cs + 5) + 3];
350 *((char *) __mempcpy (ccs, cs + 5, endp - (cs + 5))) = '\0';
351 strip (ccs, ccs);
353 if (__wcsmbs_named_conv (&fcts, ccs[2] == '\0'
354 ? upstr (ccs, cs + 5) : ccs) != 0)
356 /* Something went wrong, we cannot load the conversion modules.
357 This means we cannot proceed since the user explicitly asked
358 for these. */
359 (void) INTUSE(_IO_file_close_it) (fp);
360 __set_errno (EINVAL);
361 return NULL;
364 assert (fcts.towc_nsteps == 1);
365 assert (fcts.tomb_nsteps == 1);
367 fp->_wide_data->_IO_read_ptr = fp->_wide_data->_IO_read_end;
368 fp->_wide_data->_IO_write_ptr = fp->_wide_data->_IO_write_base;
370 /* Clear the state. We start all over again. */
371 memset (&fp->_wide_data->_IO_state, '\0', sizeof (__mbstate_t));
372 memset (&fp->_wide_data->_IO_last_state, '\0', sizeof (__mbstate_t));
374 cc = fp->_codecvt = &fp->_wide_data->_codecvt;
376 /* The functions are always the same. */
377 *cc = __libio_codecvt;
379 cc->__cd_in.__cd.__nsteps = fcts.towc_nsteps;
380 cc->__cd_in.__cd.__steps = fcts.towc;
382 cc->__cd_in.__cd.__data[0].__invocation_counter = 0;
383 cc->__cd_in.__cd.__data[0].__internal_use = 1;
384 cc->__cd_in.__cd.__data[0].__flags = __GCONV_IS_LAST;
385 cc->__cd_in.__cd.__data[0].__statep = &result->_wide_data->_IO_state;
387 /* XXX For now no transliteration. */
388 cc->__cd_in.__cd.__data[0].__trans = NULL;
390 cc->__cd_out.__cd.__nsteps = fcts.tomb_nsteps;
391 cc->__cd_out.__cd.__steps = fcts.tomb;
393 cc->__cd_out.__cd.__data[0].__invocation_counter = 0;
394 cc->__cd_out.__cd.__data[0].__internal_use = 1;
395 cc->__cd_out.__cd.__data[0].__flags = __GCONV_IS_LAST;
396 cc->__cd_out.__cd.__data[0].__statep =
397 &result->_wide_data->_IO_state;
399 /* And now the transliteration. */
400 cc->__cd_out.__cd.__data[0].__trans = &__libio_translit;
402 /* From now on use the wide character callback functions. */
403 ((struct _IO_FILE_plus *) fp)->vtable = fp->_wide_data->_wide_vtable;
405 /* Set the mode now. */
406 result->_mode = 1;
409 #endif /* GNU libc */
411 return result;
413 INTDEF2(_IO_new_file_fopen, _IO_file_fopen)
415 _IO_FILE *
416 _IO_new_file_attach (fp, fd)
417 _IO_FILE *fp;
418 int fd;
420 if (_IO_file_is_open (fp))
421 return NULL;
422 fp->_fileno = fd;
423 fp->_flags &= ~(_IO_NO_READS+_IO_NO_WRITES);
424 fp->_flags |= _IO_DELETE_DONT_CLOSE;
425 /* Get the current position of the file. */
426 /* We have to do that since that may be junk. */
427 fp->_offset = _IO_pos_BAD;
428 if (_IO_SEEKOFF (fp, (_IO_off64_t)0, _IO_seek_cur, _IOS_INPUT|_IOS_OUTPUT)
429 == _IO_pos_BAD && errno != ESPIPE)
430 return NULL;
431 return fp;
433 INTDEF2(_IO_new_file_attach, _IO_file_attach)
435 _IO_FILE *
436 _IO_new_file_setbuf (fp, p, len)
437 _IO_FILE *fp;
438 char *p;
439 _IO_ssize_t len;
441 if (_IO_default_setbuf (fp, p, len) == NULL)
442 return NULL;
444 fp->_IO_write_base = fp->_IO_write_ptr = fp->_IO_write_end
445 = fp->_IO_buf_base;
446 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_base, fp->_IO_buf_base);
448 return fp;
450 INTDEF2(_IO_new_file_setbuf, _IO_file_setbuf)
453 _IO_FILE *
454 _IO_file_setbuf_mmap (fp, p, len)
455 _IO_FILE *fp;
456 char *p;
457 _IO_ssize_t len;
459 _IO_FILE *result;
461 /* Change the function table. */
462 _IO_JUMPS ((struct _IO_FILE_plus *) fp) = &_IO_file_jumps;
463 fp->_wide_data->_wide_vtable = &_IO_wfile_jumps;
465 /* And perform the normal operation. */
466 result = _IO_new_file_setbuf (fp, p, len);
468 /* If the call failed, restore to using mmap. */
469 if (result == NULL)
471 _IO_JUMPS ((struct _IO_FILE_plus *) fp) = &_IO_file_jumps_mmap;
472 fp->_wide_data->_wide_vtable = &_IO_wfile_jumps_mmap;
475 return result;
478 static _IO_size_t new_do_write (_IO_FILE *, const char *, _IO_size_t) __THROW;
480 /* Write TO_DO bytes from DATA to FP.
481 Then mark FP as having empty buffers. */
484 _IO_new_do_write (fp, data, to_do)
485 _IO_FILE *fp;
486 const char *data;
487 _IO_size_t to_do;
489 return (to_do == 0
490 || (_IO_size_t) new_do_write (fp, data, to_do) == to_do) ? 0 : EOF;
492 INTDEF2(_IO_new_do_write, _IO_do_write)
494 static
495 _IO_size_t
496 new_do_write (fp, data, to_do)
497 _IO_FILE *fp;
498 const char *data;
499 _IO_size_t to_do;
501 _IO_size_t count;
502 if (fp->_flags & _IO_IS_APPENDING)
503 /* On a system without a proper O_APPEND implementation,
504 you would need to sys_seek(0, SEEK_END) here, but is
505 is not needed nor desirable for Unix- or Posix-like systems.
506 Instead, just indicate that offset (before and after) is
507 unpredictable. */
508 fp->_offset = _IO_pos_BAD;
509 else if (fp->_IO_read_end != fp->_IO_write_base)
511 _IO_off64_t new_pos
512 = _IO_SYSSEEK (fp, fp->_IO_write_base - fp->_IO_read_end, 1);
513 if (new_pos == _IO_pos_BAD)
514 return 0;
515 fp->_offset = new_pos;
517 count = _IO_SYSWRITE (fp, data, to_do);
518 if (fp->_cur_column && count)
519 fp->_cur_column = INTUSE(_IO_adjust_column) (fp->_cur_column - 1, data,
520 count) + 1;
521 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_base, fp->_IO_buf_base);
522 fp->_IO_write_base = fp->_IO_write_ptr = fp->_IO_buf_base;
523 fp->_IO_write_end = (fp->_mode <= 0
524 && (fp->_flags & (_IO_LINE_BUF+_IO_UNBUFFERED))
525 ? fp->_IO_buf_base : fp->_IO_buf_end);
526 return count;
530 _IO_new_file_underflow (fp)
531 _IO_FILE *fp;
533 _IO_ssize_t count;
534 #if 0
535 /* SysV does not make this test; take it out for compatibility */
536 if (fp->_flags & _IO_EOF_SEEN)
537 return (EOF);
538 #endif
540 if (fp->_flags & _IO_NO_READS)
542 fp->_flags |= _IO_ERR_SEEN;
543 __set_errno (EBADF);
544 return EOF;
546 if (fp->_IO_read_ptr < fp->_IO_read_end)
547 return *(unsigned char *) fp->_IO_read_ptr;
549 if (fp->_IO_buf_base == NULL)
551 /* Maybe we already have a push back pointer. */
552 if (fp->_IO_save_base != NULL)
554 free (fp->_IO_save_base);
555 fp->_flags &= ~_IO_IN_BACKUP;
557 INTUSE(_IO_doallocbuf) (fp);
560 /* Flush all line buffered files before reading. */
561 /* FIXME This can/should be moved to genops ?? */
562 if (fp->_flags & (_IO_LINE_BUF|_IO_UNBUFFERED))
564 #if 0
565 INTUSE(_IO_flush_all_linebuffered) ();
566 #else
567 /* We used to flush all line-buffered stream. This really isn't
568 required by any standard. My recollection is that
569 traditional Unix systems did this for stdout. stderr better
570 not be line buffered. So we do just that here
571 explicitly. --drepper */
572 _IO_acquire_lock (_IO_stdout);
574 if ((_IO_stdout->_flags & (_IO_LINKED | _IO_NO_WRITES | _IO_LINE_BUF))
575 == (_IO_LINKED | _IO_LINE_BUF))
576 _IO_OVERFLOW (_IO_stdout, EOF);
578 _IO_release_lock (_IO_stdout);
579 #endif
582 INTUSE(_IO_switch_to_get_mode) (fp);
584 /* This is very tricky. We have to adjust those
585 pointers before we call _IO_SYSREAD () since
586 we may longjump () out while waiting for
587 input. Those pointers may be screwed up. H.J. */
588 fp->_IO_read_base = fp->_IO_read_ptr = fp->_IO_buf_base;
589 fp->_IO_read_end = fp->_IO_buf_base;
590 fp->_IO_write_base = fp->_IO_write_ptr = fp->_IO_write_end
591 = fp->_IO_buf_base;
593 count = _IO_SYSREAD (fp, fp->_IO_buf_base,
594 fp->_IO_buf_end - fp->_IO_buf_base);
595 if (count <= 0)
597 if (count == 0)
598 fp->_flags |= _IO_EOF_SEEN;
599 else
600 fp->_flags |= _IO_ERR_SEEN, count = 0;
602 fp->_IO_read_end += count;
603 if (count == 0)
604 return EOF;
605 if (fp->_offset != _IO_pos_BAD)
606 _IO_pos_adjust (fp->_offset, count);
607 return *(unsigned char *) fp->_IO_read_ptr;
609 INTDEF2(_IO_new_file_underflow, _IO_file_underflow)
611 /* Guts of underflow callback if we mmap the file. This stats the file and
612 updates the stream state to match. In the normal case we return zero.
613 If the file is no longer eligible for mmap, its jump tables are reset to
614 the vanilla ones and we return nonzero. */
615 static int
616 mmap_remap_check (_IO_FILE *fp)
618 struct _G_stat64 st;
620 if (_IO_SYSSTAT (fp, &st) == 0
621 && S_ISREG (st.st_mode) && st.st_size != 0
622 /* Limit the file size to 1MB for 32-bit machines. */
623 && (sizeof (ptrdiff_t) > 4 || st.st_size < 1*1024*1024))
625 const size_t pagesize = __getpagesize ();
626 # define ROUNDED(x) (((x) + pagesize - 1) & ~(pagesize - 1))
627 if (ROUNDED (st.st_size) < ROUNDED (fp->_IO_buf_end
628 - fp->_IO_buf_base))
630 /* We can trim off some pages past the end of the file. */
631 (void) __munmap (fp->_IO_buf_base + ROUNDED (st.st_size),
632 ROUNDED (fp->_IO_buf_end - fp->_IO_buf_base)
633 - ROUNDED (st.st_size));
634 fp->_IO_buf_end = fp->_IO_buf_base + st.st_size;
636 else if (ROUNDED (st.st_size) > ROUNDED (fp->_IO_buf_end
637 - fp->_IO_buf_base))
639 /* The file added some pages. We need to remap it. */
640 void *p;
641 #ifdef _G_HAVE_MREMAP
642 p = __mremap (fp->_IO_buf_base, ROUNDED (fp->_IO_buf_end
643 - fp->_IO_buf_base),
644 ROUNDED (st.st_size), MREMAP_MAYMOVE);
645 if (p == MAP_FAILED)
647 (void) __munmap (fp->_IO_buf_base,
648 fp->_IO_buf_end - fp->_IO_buf_base);
649 goto punt;
651 #else
652 (void) __munmap (fp->_IO_buf_base,
653 fp->_IO_buf_end - fp->_IO_buf_base);
654 # ifdef _G_MMAP64
655 p = _G_MMAP64 (NULL, st.st_size, PROT_READ, MAP_SHARED,
656 fp->_fileno, 0);
657 # else
658 p = __mmap (NULL, st.st_size, PROT_READ, MAP_SHARED,
659 fp->_fileno, 0);
660 # endif
661 if (p == MAP_FAILED)
662 goto punt;
663 #endif
664 fp->_IO_buf_base = p;
665 fp->_IO_buf_end = fp->_IO_buf_base + st.st_size;
667 else
669 /* The number of pages didn't change. */
670 fp->_IO_buf_end = fp->_IO_buf_base + st.st_size;
672 # undef ROUNDED
674 fp->_offset -= fp->_IO_read_end - fp->_IO_read_ptr;
675 _IO_setg (fp, fp->_IO_buf_base,
676 fp->_offset < fp->_IO_buf_end - fp->_IO_buf_base
677 ? fp->_IO_buf_base + fp->_offset : fp->_IO_buf_end,
678 fp->_IO_buf_end);
680 /* If we are already positioned at or past the end of the file, don't
681 change the current offset. If not, seek past what we have mapped,
682 mimicking the position left by a normal underflow reading into its
683 buffer until EOF. */
685 if (fp->_offset < fp->_IO_buf_end - fp->_IO_buf_base)
687 if (
688 # ifdef _G_LSEEK64
689 _G_LSEEK64
690 # else
691 __lseek
692 # endif
693 (fp->_fileno, fp->_IO_buf_end - fp->_IO_buf_base, SEEK_SET)
694 != fp->_IO_buf_end - fp->_IO_buf_base)
695 fp->_flags |= _IO_ERR_SEEN;
696 else
697 fp->_offset = fp->_IO_buf_end - fp->_IO_buf_base;
700 return 0;
702 else
704 /* Life is no longer good for mmap. Punt it. */
705 (void) __munmap (fp->_IO_buf_base,
706 fp->_IO_buf_end - fp->_IO_buf_base);
707 punt:
708 fp->_IO_buf_base = fp->_IO_buf_end = NULL;
709 _IO_setg (fp, NULL, NULL, NULL);
710 if (fp->_mode <= 0)
711 _IO_JUMPS ((struct _IO_FILE_plus *) fp) = &_IO_file_jumps;
712 else
713 _IO_JUMPS ((struct _IO_FILE_plus *) fp) = &_IO_wfile_jumps;
714 fp->_wide_data->_wide_vtable = &_IO_wfile_jumps;
716 return 1;
720 /* Special callback replacing the underflow callbacks if we mmap the file. */
722 _IO_file_underflow_mmap (_IO_FILE *fp)
724 if (fp->_IO_read_ptr < fp->_IO_read_end)
725 return *(unsigned char *) fp->_IO_read_ptr;
727 if (__builtin_expect (mmap_remap_check (fp), 0))
728 /* We punted to the regular file functions. */
729 return _IO_UNDERFLOW (fp);
731 if (fp->_IO_read_ptr < fp->_IO_read_end)
732 return *(unsigned char *) fp->_IO_read_ptr;
734 fp->_flags |= _IO_EOF_SEEN;
735 return EOF;
738 static void
739 decide_maybe_mmap (_IO_FILE *fp)
741 /* We use the file in read-only mode. This could mean we can
742 mmap the file and use it without any copying. But not all
743 file descriptors are for mmap-able objects and on 32-bit
744 machines we don't want to map files which are too large since
745 this would require too much virtual memory. */
746 struct _G_stat64 st;
748 if (_IO_SYSSTAT (fp, &st) == 0
749 && S_ISREG (st.st_mode) && st.st_size != 0
750 /* Limit the file size to 1MB for 32-bit machines. */
751 && (sizeof (ptrdiff_t) > 4 || st.st_size < 1*1024*1024)
752 /* Sanity check. */
753 && (fp->_offset == _IO_pos_BAD || fp->_offset <= st.st_size))
755 /* Try to map the file. */
756 void *p;
758 # ifdef _G_MMAP64
759 p = _G_MMAP64 (NULL, st.st_size, PROT_READ, MAP_SHARED, fp->_fileno, 0);
760 # else
761 p = __mmap (NULL, st.st_size, PROT_READ, MAP_SHARED, fp->_fileno, 0);
762 # endif
763 if (p != MAP_FAILED)
765 /* OK, we managed to map the file. Set the buffer up and use a
766 special jump table with simplified underflow functions which
767 never tries to read anything from the file. */
769 if (
770 # ifdef _G_LSEEK64
771 _G_LSEEK64
772 # else
773 __lseek
774 # endif
775 (fp->_fileno, st.st_size, SEEK_SET) != st.st_size)
777 (void) __munmap (p, st.st_size);
778 fp->_offset = _IO_pos_BAD;
780 else
782 INTUSE(_IO_setb) (fp, p, (char *) p + st.st_size, 0);
784 if (fp->_offset == _IO_pos_BAD)
785 fp->_offset = 0;
787 _IO_setg (fp, p, p + fp->_offset, p + st.st_size);
788 fp->_offset = st.st_size;
790 if (fp->_mode <= 0)
791 _IO_JUMPS ((struct _IO_FILE_plus *)fp) = &_IO_file_jumps_mmap;
792 else
793 _IO_JUMPS ((struct _IO_FILE_plus *)fp) = &_IO_wfile_jumps_mmap;
794 fp->_wide_data->_wide_vtable = &_IO_wfile_jumps_mmap;
796 return;
801 /* We couldn't use mmap, so revert to the vanilla file operations. */
803 if (fp->_mode <= 0)
804 _IO_JUMPS ((struct _IO_FILE_plus *) fp) = &_IO_file_jumps;
805 else
806 _IO_JUMPS ((struct _IO_FILE_plus *) fp) = &_IO_wfile_jumps;
807 fp->_wide_data->_wide_vtable = &_IO_wfile_jumps;
811 _IO_file_underflow_maybe_mmap (_IO_FILE *fp)
813 /* This is the first read attempt. Choose mmap or vanilla operations
814 and then punt to the chosen underflow routine. */
815 decide_maybe_mmap (fp);
816 return _IO_UNDERFLOW (fp);
821 _IO_new_file_overflow (f, ch)
822 _IO_FILE *f;
823 int ch;
825 if (f->_flags & _IO_NO_WRITES) /* SET ERROR */
827 f->_flags |= _IO_ERR_SEEN;
828 __set_errno (EBADF);
829 return EOF;
831 /* If currently reading or no buffer allocated. */
832 if ((f->_flags & _IO_CURRENTLY_PUTTING) == 0 || f->_IO_write_base == NULL)
834 /* Allocate a buffer if needed. */
835 if (f->_IO_write_base == NULL)
837 INTUSE(_IO_doallocbuf) (f);
838 _IO_setg (f, f->_IO_buf_base, f->_IO_buf_base, f->_IO_buf_base);
840 /* Otherwise must be currently reading.
841 If _IO_read_ptr (and hence also _IO_read_end) is at the buffer end,
842 logically slide the buffer forwards one block (by setting the
843 read pointers to all point at the beginning of the block). This
844 makes room for subsequent output.
845 Otherwise, set the read pointers to _IO_read_end (leaving that
846 alone, so it can continue to correspond to the external position). */
847 if (__builtin_expect (_IO_in_backup (f), 0))
849 size_t nbackup = f->_IO_read_end - f->_IO_read_ptr;
850 INTUSE(_IO_free_backup_area) (f);
851 f->_IO_read_base -= MIN (nbackup,
852 f->_IO_read_base - f->_IO_buf_base);
853 f->_IO_read_ptr = f->_IO_read_base;
856 if (f->_IO_read_ptr == f->_IO_buf_end)
857 f->_IO_read_end = f->_IO_read_ptr = f->_IO_buf_base;
858 f->_IO_write_ptr = f->_IO_read_ptr;
859 f->_IO_write_base = f->_IO_write_ptr;
860 f->_IO_write_end = f->_IO_buf_end;
861 f->_IO_read_base = f->_IO_read_ptr = f->_IO_read_end;
863 f->_flags |= _IO_CURRENTLY_PUTTING;
864 if (f->_mode <= 0 && f->_flags & (_IO_LINE_BUF+_IO_UNBUFFERED))
865 f->_IO_write_end = f->_IO_write_ptr;
867 if (ch == EOF)
868 return INTUSE(_IO_do_write) (f, f->_IO_write_base,
869 f->_IO_write_ptr - f->_IO_write_base);
870 if (f->_IO_write_ptr == f->_IO_buf_end ) /* Buffer is really full */
871 if (_IO_do_flush (f) == EOF)
872 return EOF;
873 *f->_IO_write_ptr++ = ch;
874 if ((f->_flags & _IO_UNBUFFERED)
875 || ((f->_flags & _IO_LINE_BUF) && ch == '\n'))
876 if (INTUSE(_IO_do_write) (f, f->_IO_write_base,
877 f->_IO_write_ptr - f->_IO_write_base) == EOF)
878 return EOF;
879 return (unsigned char) ch;
881 INTDEF2(_IO_new_file_overflow, _IO_file_overflow)
884 _IO_new_file_sync (fp)
885 _IO_FILE *fp;
887 _IO_ssize_t delta;
888 int retval = 0;
890 /* char* ptr = cur_ptr(); */
891 if (fp->_IO_write_ptr > fp->_IO_write_base)
892 if (_IO_do_flush(fp)) return EOF;
893 delta = fp->_IO_read_ptr - fp->_IO_read_end;
894 if (delta != 0)
896 #ifdef TODO
897 if (_IO_in_backup (fp))
898 delta -= eGptr () - Gbase ();
899 #endif
900 _IO_off64_t new_pos = _IO_SYSSEEK (fp, delta, 1);
901 if (new_pos != (_IO_off64_t) EOF)
902 fp->_IO_read_end = fp->_IO_read_ptr;
903 #ifdef ESPIPE
904 else if (errno == ESPIPE)
905 ; /* Ignore error from unseekable devices. */
906 #endif
907 else
908 retval = EOF;
910 if (retval != EOF)
911 fp->_offset = _IO_pos_BAD;
912 /* FIXME: Cleanup - can this be shared? */
913 /* setg(base(), ptr, ptr); */
914 return retval;
916 INTDEF2(_IO_new_file_sync, _IO_file_sync)
918 static int
919 _IO_file_sync_mmap (_IO_FILE *fp)
921 if (fp->_IO_read_ptr != fp->_IO_read_end)
923 #ifdef TODO
924 if (_IO_in_backup (fp))
925 delta -= eGptr () - Gbase ();
926 #endif
927 if (
928 # ifdef _G_LSEEK64
929 _G_LSEEK64
930 # else
931 __lseek
932 # endif
933 (fp->_fileno, fp->_IO_read_ptr - fp->_IO_buf_base, SEEK_SET)
934 != fp->_IO_read_ptr - fp->_IO_buf_base)
936 fp->_flags |= _IO_ERR_SEEN;
937 return EOF;
940 fp->_offset = fp->_IO_read_ptr - fp->_IO_buf_base;
941 fp->_IO_read_end = fp->_IO_read_ptr = fp->_IO_read_base;
942 return 0;
946 _IO_off64_t
947 _IO_new_file_seekoff (fp, offset, dir, mode)
948 _IO_FILE *fp;
949 _IO_off64_t offset;
950 int dir;
951 int mode;
953 _IO_off64_t result;
954 _IO_off64_t delta, new_offset;
955 long count;
956 /* POSIX.1 8.2.3.7 says that after a call the fflush() the file
957 offset of the underlying file must be exact. */
958 int must_be_exact = (fp->_IO_read_base == fp->_IO_read_end
959 && fp->_IO_write_base == fp->_IO_write_ptr);
961 if (mode == 0)
962 dir = _IO_seek_cur, offset = 0; /* Don't move any pointers. */
964 /* Flush unwritten characters.
965 (This may do an unneeded write if we seek within the buffer.
966 But to be able to switch to reading, we would need to set
967 egptr to ptr. That can't be done in the current design,
968 which assumes file_ptr() is eGptr. Anyway, since we probably
969 end up flushing when we close(), it doesn't make much difference.)
970 FIXME: simulate mem-papped files. */
972 if (fp->_IO_write_ptr > fp->_IO_write_base || _IO_in_put_mode (fp))
973 if (INTUSE(_IO_switch_to_get_mode) (fp))
974 return EOF;
976 if (fp->_IO_buf_base == NULL)
978 /* It could be that we already have a pushback buffer. */
979 if (fp->_IO_read_base != NULL)
981 free (fp->_IO_read_base);
982 fp->_flags &= ~_IO_IN_BACKUP;
984 INTUSE(_IO_doallocbuf) (fp);
985 _IO_setp (fp, fp->_IO_buf_base, fp->_IO_buf_base);
986 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_base, fp->_IO_buf_base);
989 switch (dir)
991 case _IO_seek_cur:
992 /* Adjust for read-ahead (bytes is buffer). */
993 offset -= fp->_IO_read_end - fp->_IO_read_ptr;
994 if (fp->_offset == _IO_pos_BAD)
996 if (mode != 0)
997 goto dumb;
998 else
1000 result = _IO_SYSSEEK (fp, 0, dir);
1001 if (result == EOF)
1002 return result;
1004 fp->_offset = result;
1007 /* Make offset absolute, assuming current pointer is file_ptr(). */
1008 offset += fp->_offset;
1009 if (offset < 0)
1011 __set_errno (EINVAL);
1012 return EOF;
1015 dir = _IO_seek_set;
1016 break;
1017 case _IO_seek_set:
1018 break;
1019 case _IO_seek_end:
1021 struct _G_stat64 st;
1022 if (_IO_SYSSTAT (fp, &st) == 0 && S_ISREG (st.st_mode))
1024 offset += st.st_size;
1025 dir = _IO_seek_set;
1027 else
1028 goto dumb;
1031 /* At this point, dir==_IO_seek_set. */
1033 /* If we are only interested in the current position we've found it now. */
1034 if (mode == 0)
1035 return offset;
1037 /* If destination is within current buffer, optimize: */
1038 if (fp->_offset != _IO_pos_BAD && fp->_IO_read_base != NULL
1039 && !_IO_in_backup (fp))
1041 _IO_off64_t start_offset = (fp->_offset
1042 - (fp->_IO_read_end - fp->_IO_buf_base));
1043 if (offset >= start_offset && offset < fp->_offset)
1045 _IO_setg (fp, fp->_IO_buf_base,
1046 fp->_IO_buf_base + (offset - start_offset),
1047 fp->_IO_read_end);
1048 _IO_setp (fp, fp->_IO_buf_base, fp->_IO_buf_base);
1050 _IO_mask_flags (fp, 0, _IO_EOF_SEEN);
1051 goto resync;
1055 if (fp->_flags & _IO_NO_READS)
1056 goto dumb;
1058 /* Try to seek to a block boundary, to improve kernel page management. */
1059 new_offset = offset & ~(fp->_IO_buf_end - fp->_IO_buf_base - 1);
1060 delta = offset - new_offset;
1061 if (delta > fp->_IO_buf_end - fp->_IO_buf_base)
1063 new_offset = offset;
1064 delta = 0;
1066 result = _IO_SYSSEEK (fp, new_offset, 0);
1067 if (result < 0)
1068 return EOF;
1069 if (delta == 0)
1070 count = 0;
1071 else
1073 count = _IO_SYSREAD (fp, fp->_IO_buf_base,
1074 (must_be_exact
1075 ? delta : fp->_IO_buf_end - fp->_IO_buf_base));
1076 if (count < delta)
1078 /* We weren't allowed to read, but try to seek the remainder. */
1079 offset = count == EOF ? delta : delta-count;
1080 dir = _IO_seek_cur;
1081 goto dumb;
1084 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_base + delta,
1085 fp->_IO_buf_base + count);
1086 _IO_setp (fp, fp->_IO_buf_base, fp->_IO_buf_base);
1087 fp->_offset = result + count;
1088 _IO_mask_flags (fp, 0, _IO_EOF_SEEN);
1089 return offset;
1090 dumb:
1092 INTUSE(_IO_unsave_markers) (fp);
1093 result = _IO_SYSSEEK (fp, offset, dir);
1094 if (result != EOF)
1096 _IO_mask_flags (fp, 0, _IO_EOF_SEEN);
1097 fp->_offset = result;
1098 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_base, fp->_IO_buf_base);
1099 _IO_setp (fp, fp->_IO_buf_base, fp->_IO_buf_base);
1101 return result;
1103 resync:
1104 /* We need to do it since it is possible that the file offset in
1105 the kernel may be changed behind our back. It may happen when
1106 we fopen a file and then do a fork. One process may access the
1107 the file and the kernel file offset will be changed. */
1108 if (fp->_offset >= 0)
1109 _IO_SYSSEEK (fp, fp->_offset, 0);
1111 return offset;
1113 INTDEF2(_IO_new_file_seekoff, _IO_file_seekoff)
1115 _IO_off64_t
1116 _IO_file_seekoff_mmap (fp, offset, dir, mode)
1117 _IO_FILE *fp;
1118 _IO_off64_t offset;
1119 int dir;
1120 int mode;
1122 _IO_off64_t result;
1124 /* If we are only interested in the current position, calculate it and
1125 return right now. This calculation does the right thing when we are
1126 using a pushback buffer, but in the usual case has the same value as
1127 (fp->_IO_read_ptr - fp->_IO_buf_base). */
1128 if (mode == 0)
1129 return fp->_offset - (fp->_IO_read_end - fp->_IO_read_ptr);
1131 switch (dir)
1133 case _IO_seek_cur:
1134 /* Adjust for read-ahead (bytes is buffer). */
1135 offset += fp->_IO_read_ptr - fp->_IO_read_base;
1136 break;
1137 case _IO_seek_set:
1138 break;
1139 case _IO_seek_end:
1140 offset += fp->_IO_buf_end - fp->_IO_buf_base;
1141 break;
1143 /* At this point, dir==_IO_seek_set. */
1145 if (offset < 0)
1147 /* No negative offsets are valid. */
1148 __set_errno (EINVAL);
1149 return EOF;
1152 result = _IO_SYSSEEK (fp, offset, 0);
1153 if (result < 0)
1154 return EOF;
1156 if (offset > fp->_IO_buf_end - fp->_IO_buf_base)
1157 /* One can fseek arbitrarily past the end of the file
1158 and it is meaningless until one attempts to read.
1159 Leave the buffer pointers in EOF state until underflow. */
1160 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_end, fp->_IO_buf_end);
1161 else
1162 /* Adjust the read pointers to match the file position,
1163 but so the next read attempt will call underflow. */
1164 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_base + offset,
1165 fp->_IO_buf_base + offset);
1167 fp->_offset = result;
1169 _IO_mask_flags (fp, 0, _IO_EOF_SEEN);
1171 return offset;
1174 static _IO_off64_t
1175 _IO_file_seekoff_maybe_mmap (_IO_FILE *fp, _IO_off64_t offset, int dir,
1176 int mode)
1178 /* We only get here when we haven't tried to read anything yet.
1179 So there is nothing more useful for us to do here than just
1180 the underlying lseek call. */
1182 _IO_off64_t result = _IO_SYSSEEK (fp, offset, dir);
1183 if (result < 0)
1184 return EOF;
1186 fp->_offset = result;
1187 return result;
1190 _IO_ssize_t
1191 _IO_file_read (fp, buf, size)
1192 _IO_FILE *fp;
1193 void *buf;
1194 _IO_ssize_t size;
1196 return (__builtin_expect (fp->_flags2 & _IO_FLAGS2_NOTCANCEL, 0)
1197 ? read_not_cancel (fp->_fileno, buf, size)
1198 : read (fp->_fileno, buf, size));
1200 INTDEF(_IO_file_read)
1202 _IO_off64_t
1203 _IO_file_seek (fp, offset, dir)
1204 _IO_FILE *fp;
1205 _IO_off64_t offset;
1206 int dir;
1208 #ifdef _G_LSEEK64
1209 return _G_LSEEK64 (fp->_fileno, offset, dir);
1210 #else
1211 return lseek (fp->_fileno, offset, dir);
1212 #endif
1214 INTDEF(_IO_file_seek)
1217 _IO_file_stat (fp, st)
1218 _IO_FILE *fp;
1219 void *st;
1221 #ifdef _G_FSTAT64
1222 return _G_FSTAT64 (fp->_fileno, (struct _G_stat64 *) st);
1223 #else
1224 return fstat (fp->_fileno, (struct stat *) st);
1225 #endif
1227 INTDEF(_IO_file_stat)
1230 _IO_file_close_mmap (fp)
1231 _IO_FILE *fp;
1233 /* In addition to closing the file descriptor we have to unmap the file. */
1234 (void) __munmap (fp->_IO_buf_base, fp->_IO_buf_end - fp->_IO_buf_base);
1235 fp->_IO_buf_base = fp->_IO_buf_end = NULL;
1236 /* Cancelling close should be avoided if possible since it leaves an
1237 unrecoverable state behind. */
1238 return close_not_cancel (fp->_fileno);
1242 _IO_file_close (fp)
1243 _IO_FILE *fp;
1245 /* Cancelling close should be avoided if possible since it leaves an
1246 unrecoverable state behind. */
1247 return close_not_cancel (fp->_fileno);
1249 INTDEF(_IO_file_close)
1251 _IO_ssize_t
1252 _IO_new_file_write (f, data, n)
1253 _IO_FILE *f;
1254 const void *data;
1255 _IO_ssize_t n;
1257 _IO_ssize_t to_do = n;
1258 while (to_do > 0)
1260 _IO_ssize_t count = (__builtin_expect (f->_flags2
1261 & _IO_FLAGS2_NOTCANCEL, 0)
1262 ? write_not_cancel (f->_fileno, data, to_do)
1263 : write (f->_fileno, data, to_do));
1264 if (count < 0)
1266 f->_flags |= _IO_ERR_SEEN;
1267 break;
1269 to_do -= count;
1270 data = (void *) ((char *) data + count);
1272 n -= to_do;
1273 if (f->_offset >= 0)
1274 f->_offset += n;
1275 return n;
1278 _IO_size_t
1279 _IO_new_file_xsputn (f, data, n)
1280 _IO_FILE *f;
1281 const void *data;
1282 _IO_size_t n;
1284 register const char *s = (const char *) data;
1285 _IO_size_t to_do = n;
1286 int must_flush = 0;
1287 _IO_size_t count = 0;
1289 if (n <= 0)
1290 return 0;
1291 /* This is an optimized implementation.
1292 If the amount to be written straddles a block boundary
1293 (or the filebuf is unbuffered), use sys_write directly. */
1295 /* First figure out how much space is available in the buffer. */
1296 if ((f->_flags & _IO_LINE_BUF) && (f->_flags & _IO_CURRENTLY_PUTTING))
1298 count = f->_IO_buf_end - f->_IO_write_ptr;
1299 if (count >= n)
1301 register const char *p;
1302 for (p = s + n; p > s; )
1304 if (*--p == '\n')
1306 count = p - s + 1;
1307 must_flush = 1;
1308 break;
1313 else if (f->_IO_write_end > f->_IO_write_ptr)
1314 count = f->_IO_write_end - f->_IO_write_ptr; /* Space available. */
1316 /* Then fill the buffer. */
1317 if (count > 0)
1319 if (count > to_do)
1320 count = to_do;
1321 if (count > 20)
1323 #ifdef _LIBC
1324 f->_IO_write_ptr = __mempcpy (f->_IO_write_ptr, s, count);
1325 #else
1326 memcpy (f->_IO_write_ptr, s, count);
1327 f->_IO_write_ptr += count;
1328 #endif
1329 s += count;
1331 else
1333 register char *p = f->_IO_write_ptr;
1334 register int i = (int) count;
1335 while (--i >= 0)
1336 *p++ = *s++;
1337 f->_IO_write_ptr = p;
1339 to_do -= count;
1341 if (to_do + must_flush > 0)
1343 _IO_size_t block_size, do_write;
1344 /* Next flush the (full) buffer. */
1345 if (_IO_OVERFLOW (f, EOF) == EOF)
1346 /* If nothing else has to be written we must not signal the
1347 caller that everything has been written. */
1348 return to_do == 0 ? EOF : n - to_do;
1350 /* Try to maintain alignment: write a whole number of blocks.
1351 dont_write is what gets left over. */
1352 block_size = f->_IO_buf_end - f->_IO_buf_base;
1353 do_write = to_do - (block_size >= 128 ? to_do % block_size : 0);
1355 if (do_write)
1357 count = new_do_write (f, s, do_write);
1358 to_do -= count;
1359 if (count < do_write)
1360 return n - to_do;
1363 /* Now write out the remainder. Normally, this will fit in the
1364 buffer, but it's somewhat messier for line-buffered files,
1365 so we let _IO_default_xsputn handle the general case. */
1366 if (to_do)
1367 to_do -= INTUSE(_IO_default_xsputn) (f, s+do_write, to_do);
1369 return n - to_do;
1371 INTDEF2(_IO_new_file_xsputn, _IO_file_xsputn)
1373 _IO_size_t
1374 _IO_file_xsgetn (fp, data, n)
1375 _IO_FILE *fp;
1376 void *data;
1377 _IO_size_t n;
1379 register _IO_size_t want, have;
1380 register _IO_ssize_t count;
1381 register char *s = data;
1383 want = n;
1385 if (fp->_IO_buf_base == NULL)
1387 /* Maybe we already have a push back pointer. */
1388 if (fp->_IO_save_base != NULL)
1390 free (fp->_IO_save_base);
1391 fp->_flags &= ~_IO_IN_BACKUP;
1393 INTUSE(_IO_doallocbuf) (fp);
1396 while (want > 0)
1398 have = fp->_IO_read_end - fp->_IO_read_ptr;
1399 if (want <= have)
1401 memcpy (s, fp->_IO_read_ptr, want);
1402 fp->_IO_read_ptr += want;
1403 want = 0;
1405 else
1407 if (have > 0)
1409 #ifdef _LIBC
1410 s = __mempcpy (s, fp->_IO_read_ptr, have);
1411 #else
1412 memcpy (s, fp->_IO_read_ptr, have);
1413 s += have;
1414 #endif
1415 want -= have;
1416 fp->_IO_read_ptr += have;
1419 /* Check for backup and repeat */
1420 if (_IO_in_backup (fp))
1422 _IO_switch_to_main_get_area (fp);
1423 continue;
1426 /* If we now want less than a buffer, underflow and repeat
1427 the copy. Otherwise, _IO_SYSREAD directly to
1428 the user buffer. */
1429 if (fp->_IO_buf_base
1430 && want < (size_t) (fp->_IO_buf_end - fp->_IO_buf_base))
1432 if (__underflow (fp) == EOF)
1433 break;
1435 continue;
1438 /* These must be set before the sysread as we might longjmp out
1439 waiting for input. */
1440 _IO_setg (fp, fp->_IO_buf_base, fp->_IO_buf_base, fp->_IO_buf_base);
1441 _IO_setp (fp, fp->_IO_buf_base, fp->_IO_buf_base);
1443 /* Try to maintain alignment: read a whole number of blocks. */
1444 count = want;
1445 if (fp->_IO_buf_base)
1447 _IO_size_t block_size = fp->_IO_buf_end - fp->_IO_buf_base;
1448 if (block_size >= 128)
1449 count -= want % block_size;
1452 count = _IO_SYSREAD (fp, s, count);
1453 if (count <= 0)
1455 if (count == 0)
1456 fp->_flags |= _IO_EOF_SEEN;
1457 else
1458 fp->_flags |= _IO_ERR_SEEN;
1460 break;
1463 s += count;
1464 want -= count;
1465 if (fp->_offset != _IO_pos_BAD)
1466 _IO_pos_adjust (fp->_offset, count);
1470 return n - want;
1472 INTDEF(_IO_file_xsgetn)
1474 static _IO_size_t _IO_file_xsgetn_mmap (_IO_FILE *, void *, _IO_size_t)
1475 __THROW;
1476 static _IO_size_t
1477 _IO_file_xsgetn_mmap (fp, data, n)
1478 _IO_FILE *fp;
1479 void *data;
1480 _IO_size_t n;
1482 register _IO_size_t have;
1483 char *read_ptr = fp->_IO_read_ptr;
1484 register char *s = (char *) data;
1486 have = fp->_IO_read_end - fp->_IO_read_ptr;
1488 if (have < n)
1490 if (__builtin_expect (_IO_in_backup (fp), 0))
1492 #ifdef _LIBC
1493 s = __mempcpy (s, read_ptr, have);
1494 #else
1495 memcpy (s, read_ptr, have);
1496 s += have;
1497 #endif
1498 n -= have;
1499 _IO_switch_to_main_get_area (fp);
1500 read_ptr = fp->_IO_read_ptr;
1501 have = fp->_IO_read_end - fp->_IO_read_ptr;
1504 if (have < n)
1506 /* Check that we are mapping all of the file, in case it grew. */
1507 if (__builtin_expect (mmap_remap_check (fp), 0))
1508 /* We punted mmap, so complete with the vanilla code. */
1509 return s - (char *) data + _IO_XSGETN (fp, data, n);
1511 read_ptr = fp->_IO_read_ptr;
1512 have = fp->_IO_read_end - read_ptr;
1516 if (have < n)
1517 fp->_flags |= _IO_EOF_SEEN;
1519 if (have != 0)
1521 have = MIN (have, n);
1522 #ifdef _LIBC
1523 s = __mempcpy (s, read_ptr, have);
1524 #else
1525 memcpy (s, read_ptr, have);
1526 s += have;
1527 #endif
1528 fp->_IO_read_ptr = read_ptr + have;
1531 return s - (char *) data;
1534 static _IO_size_t _IO_file_xsgetn_maybe_mmap (_IO_FILE *, void *, _IO_size_t)
1535 __THROW;
1536 static _IO_size_t
1537 _IO_file_xsgetn_maybe_mmap (fp, data, n)
1538 _IO_FILE *fp;
1539 void *data;
1540 _IO_size_t n;
1542 /* We only get here if this is the first attempt to read something.
1543 Decide which operations to use and then punt to the chosen one. */
1545 decide_maybe_mmap (fp);
1546 return _IO_XSGETN (fp, data, n);
1549 #ifdef _LIBC
1550 # undef _IO_do_write
1551 # undef _IO_file_close_it
1552 versioned_symbol (libc, _IO_new_do_write, _IO_do_write, GLIBC_2_1);
1553 versioned_symbol (libc, _IO_new_file_attach, _IO_file_attach, GLIBC_2_1);
1554 versioned_symbol (libc, _IO_new_file_close_it, _IO_file_close_it, GLIBC_2_1);
1555 versioned_symbol (libc, _IO_new_file_finish, _IO_file_finish, GLIBC_2_1);
1556 versioned_symbol (libc, _IO_new_file_fopen, _IO_file_fopen, GLIBC_2_1);
1557 versioned_symbol (libc, _IO_new_file_init, _IO_file_init, GLIBC_2_1);
1558 versioned_symbol (libc, _IO_new_file_setbuf, _IO_file_setbuf, GLIBC_2_1);
1559 versioned_symbol (libc, _IO_new_file_sync, _IO_file_sync, GLIBC_2_1);
1560 versioned_symbol (libc, _IO_new_file_overflow, _IO_file_overflow, GLIBC_2_1);
1561 versioned_symbol (libc, _IO_new_file_seekoff, _IO_file_seekoff, GLIBC_2_1);
1562 versioned_symbol (libc, _IO_new_file_underflow, _IO_file_underflow, GLIBC_2_1);
1563 versioned_symbol (libc, _IO_new_file_write, _IO_file_write, GLIBC_2_1);
1564 versioned_symbol (libc, _IO_new_file_xsputn, _IO_file_xsputn, GLIBC_2_1);
1565 #endif
1567 const struct _IO_jump_t _IO_file_jumps =
1569 JUMP_INIT_DUMMY,
1570 JUMP_INIT(finish, INTUSE(_IO_file_finish)),
1571 JUMP_INIT(overflow, INTUSE(_IO_file_overflow)),
1572 JUMP_INIT(underflow, INTUSE(_IO_file_underflow)),
1573 JUMP_INIT(uflow, INTUSE(_IO_default_uflow)),
1574 JUMP_INIT(pbackfail, INTUSE(_IO_default_pbackfail)),
1575 JUMP_INIT(xsputn, INTUSE(_IO_file_xsputn)),
1576 JUMP_INIT(xsgetn, INTUSE(_IO_file_xsgetn)),
1577 JUMP_INIT(seekoff, _IO_new_file_seekoff),
1578 JUMP_INIT(seekpos, _IO_default_seekpos),
1579 JUMP_INIT(setbuf, _IO_new_file_setbuf),
1580 JUMP_INIT(sync, _IO_new_file_sync),
1581 JUMP_INIT(doallocate, INTUSE(_IO_file_doallocate)),
1582 JUMP_INIT(read, INTUSE(_IO_file_read)),
1583 JUMP_INIT(write, _IO_new_file_write),
1584 JUMP_INIT(seek, INTUSE(_IO_file_seek)),
1585 JUMP_INIT(close, INTUSE(_IO_file_close)),
1586 JUMP_INIT(stat, INTUSE(_IO_file_stat)),
1587 JUMP_INIT(showmanyc, _IO_default_showmanyc),
1588 JUMP_INIT(imbue, _IO_default_imbue)
1590 libc_hidden_data_def (_IO_file_jumps)
1592 const struct _IO_jump_t _IO_file_jumps_mmap =
1594 JUMP_INIT_DUMMY,
1595 JUMP_INIT(finish, INTUSE(_IO_file_finish)),
1596 JUMP_INIT(overflow, INTUSE(_IO_file_overflow)),
1597 JUMP_INIT(underflow, _IO_file_underflow_mmap),
1598 JUMP_INIT(uflow, INTUSE(_IO_default_uflow)),
1599 JUMP_INIT(pbackfail, INTUSE(_IO_default_pbackfail)),
1600 JUMP_INIT(xsputn, _IO_new_file_xsputn),
1601 JUMP_INIT(xsgetn, _IO_file_xsgetn_mmap),
1602 JUMP_INIT(seekoff, _IO_file_seekoff_mmap),
1603 JUMP_INIT(seekpos, _IO_default_seekpos),
1604 JUMP_INIT(setbuf, (_IO_setbuf_t) _IO_file_setbuf_mmap),
1605 JUMP_INIT(sync, _IO_file_sync_mmap),
1606 JUMP_INIT(doallocate, INTUSE(_IO_file_doallocate)),
1607 JUMP_INIT(read, INTUSE(_IO_file_read)),
1608 JUMP_INIT(write, _IO_new_file_write),
1609 JUMP_INIT(seek, INTUSE(_IO_file_seek)),
1610 JUMP_INIT(close, _IO_file_close_mmap),
1611 JUMP_INIT(stat, INTUSE(_IO_file_stat)),
1612 JUMP_INIT(showmanyc, _IO_default_showmanyc),
1613 JUMP_INIT(imbue, _IO_default_imbue)
1616 const struct _IO_jump_t _IO_file_jumps_maybe_mmap =
1618 JUMP_INIT_DUMMY,
1619 JUMP_INIT(finish, INTUSE(_IO_file_finish)),
1620 JUMP_INIT(overflow, INTUSE(_IO_file_overflow)),
1621 JUMP_INIT(underflow, _IO_file_underflow_maybe_mmap),
1622 JUMP_INIT(uflow, INTUSE(_IO_default_uflow)),
1623 JUMP_INIT(pbackfail, INTUSE(_IO_default_pbackfail)),
1624 JUMP_INIT(xsputn, _IO_new_file_xsputn),
1625 JUMP_INIT(xsgetn, _IO_file_xsgetn_maybe_mmap),
1626 JUMP_INIT(seekoff, _IO_file_seekoff_maybe_mmap),
1627 JUMP_INIT(seekpos, _IO_default_seekpos),
1628 JUMP_INIT(setbuf, (_IO_setbuf_t) _IO_file_setbuf_mmap),
1629 JUMP_INIT(sync, _IO_new_file_sync),
1630 JUMP_INIT(doallocate, INTUSE(_IO_file_doallocate)),
1631 JUMP_INIT(read, INTUSE(_IO_file_read)),
1632 JUMP_INIT(write, _IO_new_file_write),
1633 JUMP_INIT(seek, INTUSE(_IO_file_seek)),
1634 JUMP_INIT(close, _IO_file_close),
1635 JUMP_INIT(stat, INTUSE(_IO_file_stat)),
1636 JUMP_INIT(showmanyc, _IO_default_showmanyc),
1637 JUMP_INIT(imbue, _IO_default_imbue)