Home | History | Annotate | Line # | Download | only in stdio
setvbuf.c revision 1.19
      1  1.19  christos /*	$NetBSD: setvbuf.c,v 1.19 2012/03/15 18:22:30 christos Exp $	*/
      2   1.7       jtc 
      3   1.1       cgd /*-
      4   1.7       jtc  * Copyright (c) 1990, 1993
      5   1.7       jtc  *	The Regents of the University of California.  All rights reserved.
      6   1.1       cgd  *
      7   1.1       cgd  * This code is derived from software contributed to Berkeley by
      8   1.1       cgd  * Chris Torek.
      9   1.1       cgd  *
     10   1.1       cgd  * Redistribution and use in source and binary forms, with or without
     11   1.1       cgd  * modification, are permitted provided that the following conditions
     12   1.1       cgd  * are met:
     13   1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     14   1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     15   1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     16   1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     17   1.1       cgd  *    documentation and/or other materials provided with the distribution.
     18  1.17       agc  * 3. Neither the name of the University nor the names of its contributors
     19   1.1       cgd  *    may be used to endorse or promote products derived from this software
     20   1.1       cgd  *    without specific prior written permission.
     21   1.1       cgd  *
     22   1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     23   1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     24   1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     25   1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     26   1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     27   1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     28   1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     29   1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     30   1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     31   1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     32   1.1       cgd  * SUCH DAMAGE.
     33   1.1       cgd  */
     34   1.1       cgd 
     35   1.9  christos #include <sys/cdefs.h>
     36   1.1       cgd #if defined(LIBC_SCCS) && !defined(lint)
     37   1.7       jtc #if 0
     38   1.7       jtc static char sccsid[] = "@(#)setvbuf.c	8.2 (Berkeley) 11/16/93";
     39   1.9  christos #else
     40  1.19  christos __RCSID("$NetBSD: setvbuf.c,v 1.19 2012/03/15 18:22:30 christos Exp $");
     41   1.7       jtc #endif
     42   1.1       cgd #endif /* LIBC_SCCS and not lint */
     43   1.1       cgd 
     44  1.13     lukem #include <assert.h>
     45  1.13     lukem #include <errno.h>
     46   1.1       cgd #include <stdio.h>
     47   1.1       cgd #include <stdlib.h>
     48  1.15      yamt #include <wchar.h>
     49  1.16   thorpej #include "reentrant.h"
     50   1.1       cgd #include "local.h"
     51   1.1       cgd 
     52   1.1       cgd /*
     53   1.1       cgd  * Set one of the three kinds of buffering, optionally including
     54   1.1       cgd  * a buffer.
     55   1.1       cgd  */
     56   1.8       jtc int
     57  1.19  christos setvbuf(FILE *fp, char *buf, int mode, size_t size)
     58   1.1       cgd {
     59  1.12     perry 	int ret, flags;
     60   1.2       cgd 	size_t iosize;
     61   1.2       cgd 	int ttyflag;
     62  1.13     lukem 
     63  1.13     lukem 	_DIAGASSERT(fp != NULL);
     64  1.13     lukem 	/* buf may be NULL */
     65   1.1       cgd 
     66   1.1       cgd 	/*
     67   1.1       cgd 	 * Verify arguments.  The `int' limit on `size' is due to this
     68   1.2       cgd 	 * particular implementation.  Note, buf and size are ignored
     69   1.2       cgd 	 * when setting _IONBF.
     70   1.1       cgd 	 */
     71   1.2       cgd 	if (mode != _IONBF)
     72   1.2       cgd 		if ((mode != _IOFBF && mode != _IOLBF) || (int)size < 0)
     73  1.19  christos 			return -1;
     74   1.1       cgd 
     75  1.11       jtc 	FLOCKFILE(fp);
     76   1.1       cgd 	/*
     77   1.6       cgd 	 * Write current buffer, if any.  Discard unread input (including
     78   1.6       cgd 	 * ungetc data), cancel line buffering, and free old buffer if
     79   1.6       cgd 	 * malloc()ed.  We also clear any eof condition, as if this were
     80   1.6       cgd 	 * a seek.
     81   1.1       cgd 	 */
     82   1.2       cgd 	ret = 0;
     83   1.2       cgd 	(void)__sflush(fp);
     84   1.6       cgd 	if (HASUB(fp))
     85   1.6       cgd 		FREEUB(fp);
     86  1.15      yamt 	WCIO_FREE(fp);
     87   1.2       cgd 	fp->_r = fp->_lbfsize = 0;
     88   1.2       cgd 	flags = fp->_flags;
     89   1.2       cgd 	if (flags & __SMBF)
     90   1.1       cgd 		free((void *)fp->_bf._base);
     91   1.6       cgd 	flags &= ~(__SLBF | __SNBF | __SMBF | __SOPT | __SNPT | __SEOF);
     92   1.1       cgd 
     93   1.2       cgd 	/* If setting unbuffered mode, skip all the hard work. */
     94   1.2       cgd 	if (mode == _IONBF)
     95   1.2       cgd 		goto nbf;
     96   1.2       cgd 
     97   1.1       cgd 	/*
     98   1.2       cgd 	 * Find optimal I/O size for seek optimization.  This also returns
     99   1.2       cgd 	 * a `tty flag' to suggest that we check isatty(fd), but we do not
    100   1.2       cgd 	 * care since our caller told us how to buffer.
    101   1.1       cgd 	 */
    102   1.2       cgd 	flags |= __swhatbuf(fp, &iosize, &ttyflag);
    103   1.2       cgd 	if (size == 0) {
    104   1.2       cgd 		buf = NULL;	/* force local allocation */
    105   1.2       cgd 		size = iosize;
    106   1.2       cgd 	}
    107   1.1       cgd 
    108   1.2       cgd 	/* Allocate buffer if needed. */
    109   1.2       cgd 	if (buf == NULL) {
    110   1.2       cgd 		if ((buf = malloc(size)) == NULL) {
    111   1.2       cgd 			/*
    112   1.2       cgd 			 * Unable to honor user's request.  We will return
    113   1.2       cgd 			 * failure, but try again with file system size.
    114   1.2       cgd 			 */
    115  1.10    kleink 			ret = -1;
    116   1.2       cgd 			if (size != iosize) {
    117   1.2       cgd 				size = iosize;
    118   1.2       cgd 				buf = malloc(size);
    119   1.2       cgd 			}
    120   1.2       cgd 		}
    121   1.2       cgd 		if (buf == NULL) {
    122   1.2       cgd 			/* No luck; switch to unbuffered I/O. */
    123   1.2       cgd nbf:
    124   1.2       cgd 			fp->_flags = flags | __SNBF;
    125   1.2       cgd 			fp->_w = 0;
    126   1.2       cgd 			fp->_bf._base = fp->_p = fp->_nbuf;
    127   1.2       cgd 			fp->_bf._size = 1;
    128  1.11       jtc 			FUNLOCKFILE(fp);
    129  1.19  christos 			return ret;
    130   1.2       cgd 		}
    131   1.2       cgd 		flags |= __SMBF;
    132   1.2       cgd 	}
    133   1.1       cgd 
    134   1.2       cgd 	/*
    135   1.2       cgd 	 * Kill any seek optimization if the buffer is not the
    136   1.2       cgd 	 * right size.
    137   1.2       cgd 	 *
    138   1.2       cgd 	 * SHOULD WE ALLOW MULTIPLES HERE (i.e., ok iff (size % iosize) == 0)?
    139   1.2       cgd 	 */
    140   1.2       cgd 	if (size != iosize)
    141   1.2       cgd 		flags |= __SNPT;
    142   1.1       cgd 
    143   1.1       cgd 	/*
    144   1.2       cgd 	 * Fix up the FILE fields, and set __cleanup for output flush on
    145   1.6       cgd 	 * exit (since we are buffered in some way).
    146   1.1       cgd 	 */
    147   1.3       cgd 	if (mode == _IOLBF)
    148   1.2       cgd 		flags |= __SLBF;
    149   1.2       cgd 	fp->_flags = flags;
    150   1.2       cgd 	fp->_bf._base = fp->_p = (unsigned char *)buf;
    151  1.18  christos 	_DIAGASSERT(__type_fit(int, size));
    152  1.18  christos 	fp->_bf._size = (int)size;
    153   1.6       cgd 	/* fp->_lbfsize is still 0 */
    154   1.6       cgd 	if (flags & __SWR) {
    155   1.6       cgd 		/*
    156   1.6       cgd 		 * Begin or continue writing: see __swsetup().  Note
    157   1.6       cgd 		 * that __SNBF is impossible (it was handled earlier).
    158   1.6       cgd 		 */
    159   1.6       cgd 		if (flags & __SLBF) {
    160   1.6       cgd 			fp->_w = 0;
    161   1.6       cgd 			fp->_lbfsize = -fp->_bf._size;
    162  1.18  christos 		} else {
    163  1.18  christos 			_DIAGASSERT(__type_fit(int, size));
    164  1.18  christos 			fp->_w = (int)size;
    165  1.18  christos 		}
    166   1.6       cgd 	} else {
    167   1.6       cgd 		/* begin/continue reading, or stay in intermediate state */
    168   1.6       cgd 		fp->_w = 0;
    169   1.6       cgd 	}
    170   1.2       cgd 	__cleanup = _cleanup;
    171   1.1       cgd 
    172  1.11       jtc 	FUNLOCKFILE(fp);
    173  1.19  christos 	return ret;
    174   1.1       cgd }
    175