X-Git-Url: https://pd.if.org/git/?a=blobdiff_plain;f=functions%2Fstdio%2Ffputs.c;h=3565a1181e73d4978b895b9d5b9a668819109e87;hb=HEAD;hp=716fef838b5ebddaba629c760c52e777f268eadb;hpb=a6dd99e5c0b3af81082d24751218c21f7f3e7443;p=pdclib.old diff --git a/functions/stdio/fputs.c b/functions/stdio/fputs.c index 716fef8..3565a11 100644 --- a/functions/stdio/fputs.c +++ b/functions/stdio/fputs.c @@ -9,40 +9,70 @@ #include #ifndef REGTEST +#include <_PDCLIB_io.h> -int fputs( const char * _PDCLIB_restrict s, struct _PDCLIB_file_t * _PDCLIB_restrict stream ) +int _PDCLIB_fputs_unlocked( const char * _PDCLIB_restrict s, + FILE * _PDCLIB_restrict stream ) { - /* FIXME: This is devoid of any error checking (file writeable? r/w - constraints honored?) - */ - /* FIXME: Proper buffering handling. */ - while ( stream->bufidx < stream->bufsize ) + if ( _PDCLIB_prepwrite( stream ) == EOF ) { - if ( ( stream->buffer[stream->bufidx++] = *(s++) ) == '\0' ) - { - break; - } + return EOF; } - fflush( stream ); - if ( *(s-1) != '\0' ) + while ( *s != '\0' ) { - return fputs( s, stream ); + /* Unbuffered and line buffered streams get flushed when fputs() does + write the terminating end-of-line. All streams get flushed if the + buffer runs full. + */ + stream->buffer[ stream->bufidx++ ] = *s; + if ( ( stream->bufidx == stream->bufsize ) || + ( ( stream->status & _IOLBF ) && *s == '\n' ) + ) + { + if ( _PDCLIB_flushbuffer( stream ) == EOF ) + { + return EOF; + } + } + ++s; } - else + if ( stream->status & _IONBF ) { - return 1; + if ( _PDCLIB_flushbuffer( stream ) == EOF ) + { + return EOF; + } } + return 0; } -#endif +int fputs( const char * _PDCLIB_restrict s, + FILE * _PDCLIB_restrict stream ) +{ + _PDCLIB_flockfile( stream ); + int r = _PDCLIB_fputs_unlocked( s, stream ); + _PDCLIB_funlockfile( stream ); + return r; +} +#endif #ifdef TEST #include <_PDCLIB_test.h> int main( void ) { - TESTCASE( NO_TESTDRIVER ); + char const * const message = "SUCCESS testing fputs()"; + FILE * fh; + TESTCASE( ( fh = tmpfile() ) != NULL ); + TESTCASE( fputs( message, fh ) >= 0 ); + rewind( fh ); + for ( size_t i = 0; i < 23; ++i ) + { + TESTCASE( fgetc( fh ) == message[i] ); + } + TESTCASE( fclose( fh ) == 0 ); return TEST_RESULTS; } #endif +