source: libcfa/src/fstream.cfa @ 74330e7

ADTarm-ehast-experimentalenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprpthread-emulationqualifiedEnum
Last change on this file since 74330e7 was d1a9ff5, checked in by Peter A. Buhr <pabuhr@…>, 5 years ago

change private names to start with $, change NULL to 0p
  • Property mode set to 100644
File size: 7.3 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2015 University of Waterloo
3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
7// fstream.c --
8//
9// Author           : Peter A. Buhr
10// Created On       : Wed May 27 17:56:53 2015
11// Last Modified By : Peter A. Buhr
12// Last Modified On : Fri Feb  7 19:01:01 2020
13// Update Count     : 363
14//
15
16#include "fstream.hfa"
17
18#include <stdio.h>                                                                              // vfprintf, vfscanf
19#include <stdlib.h>                                                                             // exit
20#include <stdarg.h>                                                                             // varargs
21#include <string.h>                                                                             // strlen
22#include <float.h>                                                                              // DBL_DIG, LDBL_DIG
23#include <complex.h>                                                                    // creal, cimag
24#include <assert.h>
25#include <errno.h>                                                                              // errno
26
27
28//*********************************** ofstream ***********************************
29
30
31#define IO_MSG "I/O error: "
32
33void ?{}( ofstream & os, void * file ) {
34        os.$file = file;
35        os.$sepDefault = true;
36        os.$sepOnOff = false;
37        os.$nlOnOff = true;
38        os.$prt = false;
39        os.$sawNL = false;
40        $sepSetCur( os, sepGet( os ) );
41        sepSet( os, " " );
42        sepSetTuple( os, ", " );
43} // ?{}
44
45// private
46bool $sepPrt( ofstream & os ) { $setNL( os, false ); return os.$sepOnOff; }
47void $sepReset( ofstream & os ) { os.$sepOnOff = os.$sepDefault; }
48void $sepReset( ofstream & os, bool reset ) { os.$sepDefault = reset; os.$sepOnOff = os.$sepDefault; }
49const char * $sepGetCur( ofstream & os ) { return os.$sepCur; }
50void $sepSetCur( ofstream & os, const char sepCur[] ) { os.$sepCur = sepCur; }
51bool $getNL( ofstream & os ) { return os.$sawNL; }
52void $setNL( ofstream & os, bool state ) { os.$sawNL = state; }
53bool $getANL( ofstream & os ) { return os.$nlOnOff; }
54bool $getPrt( ofstream & os ) { return os.$prt; }
55void $setPrt( ofstream & os, bool state ) { os.$prt = state; }
56
57// public
58void ?{}( ofstream & os ) { os.$file = 0p; }
59
60void ?{}( ofstream & os, const char name[], const char mode[] ) {
61        open( os, name, mode );
62} // ?{}
63
64void ?{}( ofstream & os, const char name[] ) {
65        open( os, name, "w" );
66} // ?{}
67
68void ^?{}( ofstream & os ) {
69        close( os );
70} // ^?{}
71
72void sepOn( ofstream & os ) { os.$sepOnOff = ! $getNL( os ); }
73void sepOff( ofstream & os ) { os.$sepOnOff = false; }
74
75bool sepDisable( ofstream & os ) {
76        bool temp = os.$sepDefault;
77        os.$sepDefault = false;
78        $sepReset( os );
79        return temp;
80} // sepDisable
81
82bool sepEnable( ofstream & os ) {
83        bool temp = os.$sepDefault;
84        os.$sepDefault = true;
85        if ( os.$sepOnOff ) $sepReset( os );                            // start of line ?
86        return temp;
87} // sepEnable
88
89void nlOn( ofstream & os ) { os.$nlOnOff = true; }
90void nlOff( ofstream & os ) { os.$nlOnOff = false; }
91
92const char * sepGet( ofstream & os ) { return os.$separator; }
93void sepSet( ofstream & os, const char s[] ) {
94        assert( s );
95        strncpy( os.$separator, s, sepSize - 1 );
96        os.$separator[sepSize - 1] = '\0';
97} // sepSet
98
99const char * sepGetTuple( ofstream & os ) { return os.$tupleSeparator; }
100void sepSetTuple( ofstream & os, const char s[] ) {
101        assert( s );
102        strncpy( os.$tupleSeparator, s, sepSize - 1 );
103        os.$tupleSeparator[sepSize - 1] = '\0';
104} // sepSet
105
106void ends( ofstream & os ) {
107        if ( $getANL( os ) ) nl( os );
108        else $setPrt( os, false );                                                      // turn off
109        if ( &os == &exit ) exit( EXIT_FAILURE );
110        if ( &os == &abort ) abort();
111} // ends
112
113int fail( ofstream & os ) {
114        return os.$file == 0 || ferror( (FILE *)(os.$file) );
115} // fail
116
117int flush( ofstream & os ) {
118        return fflush( (FILE *)(os.$file) );
119} // flush
120
121void open( ofstream & os, const char name[], const char mode[] ) {
122        FILE * file = fopen( name, mode );
123        #ifdef __CFA_DEBUG__
124        if ( file == 0p ) {
125                abort | IO_MSG "open output file \"" | name | "\"" | nl | strerror( errno );
126        } // if
127        #endif // __CFA_DEBUG__
128        (os){ file };
129} // open
130
131void open( ofstream & os, const char name[] ) {
132        open( os, name, "w" );
133} // open
134
135void close( ofstream & os ) {
136        if ( (FILE *)(os.$file) == stdout || (FILE *)(os.$file) == stderr ) return;
137
138        if ( fclose( (FILE *)(os.$file) ) == EOF ) {
139                abort | IO_MSG "close output" | nl | strerror( errno );
140        } // if
141} // close
142
143ofstream & write( ofstream & os, const char data[], size_t size ) {
144        if ( fail( os ) ) {
145                abort | IO_MSG "attempt write I/O on failed stream";
146        } // if
147
148        if ( fwrite( data, 1, size, (FILE *)(os.$file) ) != size ) {
149                abort | IO_MSG "write" | nl | strerror( errno );
150        } // if
151        return os;
152} // write
153
154int fmt( ofstream & os, const char format[], ... ) {
155        va_list args;
156        va_start( args, format );
157        int len = vfprintf( (FILE *)(os.$file), format, args );
158        if ( len == EOF ) {
159                if ( ferror( (FILE *)(os.$file) ) ) {
160                        abort | IO_MSG "invalid write";
161                } // if
162        } // if
163        va_end( args );
164
165        $setPrt( os, true );                                                            // called in output cascade
166        $sepReset( os );                                                                        // reset separator
167        return len;
168} // fmt
169
170static ofstream soutFile = { (FILE *)stdout };
171ofstream & sout = soutFile, & stdout = soutFile;
172static ofstream serrFile = { (FILE *)stderr };
173ofstream & serr = serrFile, & stderr = serrFile;
174
175static ofstream exitFile = { (FILE *)stdout };
176ofstream & exit = exitFile;
177static ofstream abortFile = { (FILE *)stderr };
178ofstream & abort = abortFile;
179
180
181//*********************************** ifstream ***********************************
182
183
184// private
185void ?{}( ifstream & is, void * file ) {
186        is.$file = file;
187        is.$nlOnOff = false;
188} // ?{}
189
190// public
191void ?{}( ifstream & is ) { is.$file = 0p; }
192
193void ?{}( ifstream & is, const char name[], const char mode[] ) {
194        open( is, name, mode );
195} // ?{}
196
197void ?{}( ifstream & is, const char name[] ) {
198        open( is, name, "r" );
199} // ?{}
200
201void ^?{}( ifstream & is ) {
202        close( is );
203} // ^?{}
204
205void nlOn( ifstream & os ) { os.$nlOnOff = true; }
206void nlOff( ifstream & os ) { os.$nlOnOff = false; }
207bool getANL( ifstream & os ) { return os.$nlOnOff; }
208
209int fail( ifstream & is ) {
210        return is.$file == 0p || ferror( (FILE *)(is.$file) );
211} // fail
212
213int eof( ifstream & is ) {
214        return feof( (FILE *)(is.$file) );
215} // eof
216
217void open( ifstream & is, const char name[], const char mode[] ) {
218        FILE * file = fopen( name, mode );
219        #ifdef __CFA_DEBUG__
220        if ( file == 0p ) {
221                abort | IO_MSG "open input file \"" | name | "\"" | nl | strerror( errno );
222        } // if
223        #endif // __CFA_DEBUG__
224        is.$file = file;
225} // open
226
227void open( ifstream & is, const char name[] ) {
228        open( is, name, "r" );
229} // open
230
231void close( ifstream & is ) {
232        if ( (FILE *)(is.$file) == stdin ) return;
233
234        if ( fclose( (FILE *)(is.$file) ) == EOF ) {
235                abort | IO_MSG "close input" | nl | strerror( errno );
236        } // if
237} // close
238
239ifstream & read( ifstream & is, char * data, size_t size ) {
240        if ( fail( is ) ) {
241                abort | IO_MSG "attempt read I/O on failed stream";
242        } // if
243
244        if ( fread( data, size, 1, (FILE *)(is.$file) ) == 0 ) {
245                abort | IO_MSG "read" | nl | strerror( errno );
246        } // if
247        return is;
248} // read
249
250ifstream &ungetc( ifstream & is, char c ) {
251        if ( fail( is ) ) {
252                abort | IO_MSG "attempt ungetc I/O on failed stream";
253        } // if
254
255        if ( ungetc( c, (FILE *)(is.$file) ) == EOF ) {
256                abort | IO_MSG "ungetc" | nl | strerror( errno );
257        } // if
258        return is;
259} // ungetc
260
261int fmt( ifstream & is, const char format[], ... ) {
262        va_list args;
263
264        va_start( args, format );
265        int len = vfscanf( (FILE *)(is.$file), format, args );
266        if ( len == EOF ) {
267                if ( ferror( (FILE *)(is.$file) ) ) {
268                        abort | IO_MSG "invalid read";
269                } // if
270        } // if
271        va_end( args );
272        return len;
273} // fmt
274
275static ifstream sinFile = { (FILE *)stdin };
276ifstream & sin = sinFile, & stdin = sinFile;
277
278// Local Variables: //
279// tab-width: 4 //
280// End: //
Note: See TracBrowser for help on using the repository browser.