source: libcfa/src/fstream.cfa@ 9795142

//
// Cforall Version 1.0.0 Copyright (C) 2015 University of Waterloo
//
// The contents of this file are covered under the licence agreement in the
// file "LICENCE" distributed with Cforall.
//
// fstream.c --
//
// Author           : Peter A. Buhr
// Created On       : Wed May 27 17:56:53 2015
// Last Modified By : Peter A. Buhr
// Last Modified On : Sat Apr 20 12:03:43 2019
// Update Count     : 311
//

#include "fstream.hfa"

#include <stdio.h>                                                                              // vfprintf, vfscanf
#include <stdlib.h>                                                                             // exit
#include <stdarg.h>                                                                             // varargs
#include <string.h>                                                                             // strlen
#include <float.h>                                                                              // DBL_DIG, LDBL_DIG
#include <complex.h>                                                                    // creal, cimag
#include <assert.h>
#include <errno.h>                                                                              // errno

#define IO_MSG "I/O error: "

void ?{}( ofstream & os, void * file, bool sepDefault, bool sepOnOff, bool nlOnOff, bool prt, const char * separator, const char * tupleSeparator ) {
        os.file = file;
        os.sepDefault = sepDefault;
        os.sepOnOff = sepOnOff;
        os.nlOnOff = nlOnOff;
        os.prt = prt;
        os.sawNL = false;
        sepSet( os, separator );
        sepSetCur( os, sepGet( os ) );
        sepSetTuple( os, tupleSeparator );
}

// private
bool sepPrt( ofstream & os ) { setNL( os, false ); return os.sepOnOff; }
void sepReset( ofstream & os ) { os.sepOnOff = os.sepDefault; }
void sepReset( ofstream & os, bool reset ) { os.sepDefault = reset; os.sepOnOff = os.sepDefault; }
const char * sepGetCur( ofstream & os ) { return os.sepCur; }
void sepSetCur( ofstream & os, const char * sepCur ) { os.sepCur = sepCur; }
bool getNL( ofstream & os ) { return os.sawNL; }
void setNL( ofstream & os, bool state ) { os.sawNL = state; }
bool getANL( ofstream & os ) { return os.nlOnOff; }
bool getPrt( ofstream & os ) { return os.prt; }
void setPrt( ofstream & os, bool state ) { os.prt = state; }

// public
void ?{}( ofstream & os ) { os.file = 0; }

void ?{}( ofstream & os, const char * name, const char * mode ) {
        open( os, name, mode );
}
void ?{}( ofstream & os, const char * name ) {
        open( os, name, "w" );
}

void sepOn( ofstream & os ) { os.sepOnOff = ! getNL( os ); }
void sepOff( ofstream & os ) { os.sepOnOff = false; }

bool sepDisable( ofstream & os ) {
        bool temp = os.sepDefault;
        os.sepDefault = false;
        sepReset( os );
        return temp;
} // sepDisable

bool sepEnable( ofstream & os ) {
        bool temp = os.sepDefault;
        os.sepDefault = true;
        if ( os.sepOnOff ) sepReset( os );                                      // start of line ?
        return temp;
} // sepEnable

void nlOn( ofstream & os ) { os.nlOnOff = true; }
void nlOff( ofstream & os ) { os.nlOnOff = false; }

const char * sepGet( ofstream & os ) { return os.separator; }
void sepSet( ofstream & os, const char * s ) {
        assert( s );
        strncpy( os.separator, s, sepSize - 1 );
        os.separator[sepSize - 1] = '\0';
} // sepSet

const char * sepGetTuple( ofstream & os ) { return os.tupleSeparator; }
void sepSetTuple( ofstream & os, const char * s ) {
        assert( s );
        strncpy( os.tupleSeparator, s, sepSize - 1 );
        os.tupleSeparator[sepSize - 1] = '\0';
} // sepSet

int fail( ofstream & os ) {
        return os.file == 0 || ferror( (FILE *)(os.file) );
} // fail

int flush( ofstream & os ) {
        return fflush( (FILE *)(os.file) );
} // flush

void open( ofstream & os, const char * name, const char * mode ) {
        FILE *file = fopen( name, mode );
        #ifdef __CFA_DEBUG__
        if ( file == 0 ) {
                abort( IO_MSG "open output file \"%s\", %s", name, strerror( errno ) );
        } // if
        #endif // __CFA_DEBUG__
        (os){ file, true, false, true, false, " ", ", " };
} // open

void open( ofstream & os, const char * name ) {
        open( os, name, "w" );
} // open

void close( ofstream & os ) {
        if ( (FILE *)(os.file) == stdout || (FILE *)(os.file) == stderr ) return;

        if ( fclose( (FILE *)(os.file) ) == EOF ) {
                abort( IO_MSG "close output %s", strerror( errno ) );
        } // if
} // close

ofstream & write( ofstream & os, const char * data, size_t size ) {
        if ( fail( os ) ) {
                abort( "attempt write I/O on failed stream\n" );
        } // if

        if ( fwrite( data, 1, size, (FILE *)(os.file) ) != size ) {
                abort( IO_MSG "write %s", strerror( errno ) );
        } // if
        return os;
} // write

int fmt( ofstream & os, const char format[], ... ) {
        va_list args;
        va_start( args, format );
        int len = vfprintf( (FILE *)(os.file), format, args );
        if ( len == EOF ) {
                if ( ferror( (FILE *)(os.file) ) ) {
                        abort( "invalid write\n" );
                } // if
        } // if
        va_end( args );

        setPrt( os, true );                                                                     // called in output cascade
        sepReset( os );                                                                         // reset separator
        return len;
} // fmt

static ofstream soutFile = { (FILE *)(&_IO_2_1_stdout_), true, false, true, false, " ", ", " };
ofstream & sout = soutFile;
static ofstream serrFile = { (FILE *)(&_IO_2_1_stderr_), true, false, true, false, " ", ", " };
ofstream & serr = serrFile;


//---------------------------------------

// private
void ?{}( ifstream & is, void * file ) {
        is.file = file;
        is.nlOnOff = false;
}

// public
void ?{}( ifstream & is ) {     is.file = 0; }

void ?{}( ifstream & is, const char * name, const char * mode ) {
        open( is, name, mode );
}
void ?{}( ifstream & is, const char * name ) {
        open( is, name, "r" );
}

void nlOn( ifstream & os ) { os.nlOnOff = true; }
void nlOff( ifstream & os ) { os.nlOnOff = false; }
bool getANL( ifstream & os ) { return os.nlOnOff; }

int fail( ifstream & is ) {
        return is.file == 0 || ferror( (FILE *)(is.file) );
} // fail

int eof( ifstream & is ) {
        return feof( (FILE *)(is.file) );
} // eof

void open( ifstream & is, const char * name, const char * mode ) {
        FILE * file = fopen( name, mode );
        #ifdef __CFA_DEBUG__
        if ( file == 0 ) {
                abort( IO_MSG "open input file \"%s\", %s\n", name, strerror( errno ) );
        } // if
        #endif // __CFA_DEBUG__
        is.file = file;
} // open

void open( ifstream & is, const char * name ) {
        open( is, name, "r" );
} // open

void close( ifstream & is ) {
        if ( (FILE *)(is.file) == stdin ) return;

        if ( fclose( (FILE *)(is.file) ) == EOF ) {
                abort( IO_MSG "close input %s", strerror( errno ) );
        } // if
} // close

ifstream & read( ifstream & is, char * data, size_t size ) {
        if ( fail( is ) ) {
                abort( "attempt read I/O on failed stream\n" );
        } // if

        if ( fread( data, size, 1, (FILE *)(is.file) ) == 0 ) {
                abort( IO_MSG "read %s", strerror( errno ) );
        } // if
        return is;
} // read

ifstream &ungetc( ifstream & is, char c ) {
        if ( fail( is ) ) {
                abort( "attempt ungetc I/O on failed stream\n" );
        } // if

        if ( ungetc( c, (FILE *)(is.file) ) == EOF ) {
                abort( IO_MSG "ungetc %s", strerror( errno ) );
        } // if
        return is;
} // ungetc

int fmt( ifstream & is, const char format[], ... ) {
        va_list args;

        va_start( args, format );
        int len = vfscanf( (FILE *)(is.file), format, args );
        if ( len == EOF ) {
                if ( ferror( (FILE *)(is.file) ) ) {
                        abort( "invalid read\n" );
                } // if
        } // if
        va_end( args );
        return len;
} // fmt


static ifstream sinFile = { (FILE *)(&_IO_2_1_stdin_) };
ifstream & sin = sinFile;

// Local Variables: //
// tab-width: 4 //
// End: //