source: libcfa/src/fstream.cfa@ 678c540

ADT ast-experimental
Last change on this file since 678c540 was cce4648, checked in by Thierry Delisle <tdelisle@…>, 3 years ago

Visibility for streams

  • Property mode set to 100644
File size: 11.2 KB
RevLine 
[86bd7c1f]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//
[356189a]7// fstream.c --
[86bd7c1f]8//
[90c3b1c]9// Author : Peter A. Buhr
[86bd7c1f]10// Created On : Wed May 27 17:56:53 2015
[5d125e4]11// Last Modified By : Peter A. Buhr
[7a1b7e6]12// Last Modified On : Sat Apr 9 14:55:54 2022
13// Update Count : 515
[86bd7c1f]14//
15
[f451177]16#include "fstream.hfa" // also includes iostream.hfa
[51b73452]17
[90c3b1c]18#include <stdio.h> // vfprintf, vfscanf
19#include <stdlib.h> // exit
20#include <stdarg.h> // varargs
[b431515]21#include <string.h> // strncpy, strerror
[91c389a]22#include <assert.h>
[8a25be9]23#include <errno.h> // errno
[51b73452]24
[cce4648]25#pragma GCC visibility push(default)
26
[8d321f9]27// *********************************** ofstream ***********************************
[65240bb]28
29
[53ba273]30#define IO_MSG "I/O error: "
[6ba0659]31
[7ce2483]32// private
33void ?{}( ofstream & os, void * file ) with( os ) {
[3bf3b6b]34 file$ = file;
35 sepDefault$ = true;
36 sepOnOff$ = false;
37 nlOnOff$ = true;
38 prt$ = false;
39 sawNL$ = false;
[6c5d92f]40 sepSetCur$( os, sepGet( os ) );
[5cb2b8c]41 sepSet( os, " " );
42 sepSetTuple( os, ", " );
[65240bb]43} // ?{}
[0583064b]44
[7ce2483]45inline bool sepPrt$( ofstream & os ) { setNL$( os, false ); return os.sepOnOff$; }
46inline void sepReset$( ofstream & os ) { os.sepOnOff$ = os.sepDefault$; }
47inline void sepReset$( ofstream & os, bool reset ) { os.sepDefault$ = reset; os.sepOnOff$ = os.sepDefault$; }
48inline const char * sepGetCur$( ofstream & os ) { return os.sepCur$; }
49inline void sepSetCur$( ofstream & os, const char sepCur[] ) { os.sepCur$ = sepCur; }
50inline bool getNL$( ofstream & os ) { return os.sawNL$; }
51inline void setNL$( ofstream & os, bool state ) { os.sawNL$ = state; }
52inline bool getANL$( ofstream & os ) { return os.nlOnOff$; }
53inline bool getPrt$( ofstream & os ) { return os.prt$; }
54inline void setPrt$( ofstream & os, bool state ) { os.prt$ = state; }
55
[c52f033]56inline void lock( ofstream & os ) with( os ) { lock( os.lock$ ); }
[7ce2483]57inline void unlock( ofstream & os ) { unlock( os.lock$ ); }
[829c907]58
[9ebd778]59// public
[6c5d92f]60void ?{}( ofstream & os ) { os.file$ = 0p; }
[7ce2483]61void ?{}( ofstream & os, const char name[], const char mode[] ) { open( os, name, mode ); }
62void ?{}( ofstream & os, const char name[] ) { open( os, name, "w" ); }
63void ^?{}( ofstream & os ) { close( os ); }
[4cae032]64
[6c5d92f]65void sepOn( ofstream & os ) { os.sepOnOff$ = ! getNL$( os ); }
66void sepOff( ofstream & os ) { os.sepOnOff$ = false; }
[09687aa]67
[93c2e0a]68bool sepDisable( ofstream & os ) {
[6c5d92f]69 bool temp = os.sepDefault$;
70 os.sepDefault$ = false;
71 sepReset$( os );
[53ba273]72 return temp;
73} // sepDisable
[6152c81]74
[93c2e0a]75bool sepEnable( ofstream & os ) {
[6c5d92f]76 bool temp = os.sepDefault$;
77 os.sepDefault$ = true;
78 if ( os.sepOnOff$ ) sepReset$( os ); // start of line ?
[53ba273]79 return temp;
80} // sepEnable
[90c3b1c]81
[6c5d92f]82void nlOn( ofstream & os ) { os.nlOnOff$ = true; }
83void nlOff( ofstream & os ) { os.nlOnOff$ = false; }
[200fcb3]84
[6c5d92f]85const char * sepGet( ofstream & os ) { return os.separator$; }
[e3fea42]86void sepSet( ofstream & os, const char s[] ) {
[9ebd778]87 assert( s );
[b431515]88 strncpy( os.separator$, s, ofstream_sepSize - 1 );
89 os.separator$[ofstream_sepSize - 1] = '\0';
[9ebd778]90} // sepSet
91
[6c5d92f]92const char * sepGetTuple( ofstream & os ) { return os.tupleSeparator$; }
[e3fea42]93void sepSetTuple( ofstream & os, const char s[] ) {
[9ebd778]94 assert( s );
[b431515]95 strncpy( os.tupleSeparator$, s, ofstream_sepSize - 1 );
96 os.tupleSeparator$[ofstream_sepSize - 1] = '\0';
[9ebd778]97} // sepSet
98
[65240bb]99void ends( ofstream & os ) {
[6c5d92f]100 if ( getANL$( os ) ) nl( os );
101 else setPrt$( os, false ); // turn off
[65240bb]102 if ( &os == &exit ) exit( EXIT_FAILURE );
103 if ( &os == &abort ) abort();
104} // ends
105
[7ce2483]106bool fail( ofstream & os ) { return os.file$ == 0 || ferror( (FILE *)(os.file$) ); }
107void clear( ofstream & os ) { clearerr( (FILE *)(os.file$) ); }
108int flush( ofstream & os ) { return fflush( (FILE *)(os.file$) ); }
[6ba0659]109
[e3fea42]110void open( ofstream & os, const char name[], const char mode[] ) {
[8dcb832]111 FILE * file;
112 for ( cnt; 10 ) {
113 errno = 0;
114 file = fopen( name, mode );
115 if ( file != 0p || errno != EINTR ) break; // timer interrupt ?
116 if ( cnt == 9 ) abort( "ofstream open EINTR spinning exceeded" );
117 } // for
[d1a9ff5]118 if ( file == 0p ) {
[8d321f9]119 throw (Open_Failure){ os };
120 // abort | IO_MSG "open output file \"" | name | "\"" | nl | strerror( errno );
[93c2e0a]121 } // if
[cce4648]122 (os){ file }; // initialize
[6ba0659]123} // open
124
[7ce2483]125void open( ofstream & os, const char name[] ) { open( os, name, "w" ); }
[8da74119]126
[7ce2483]127void close( ofstream & os ) with( os ) {
[3bf3b6b]128 if ( (FILE *)(file$) == 0p ) return;
129 if ( (FILE *)(file$) == (FILE *)stdout || (FILE *)(file$) == (FILE *)stderr ) return;
[6ba0659]130
[8dcb832]131 int ret;
132 for ( cnt; 10 ) {
133 errno = 0;
134 ret = fclose( (FILE *)(file$) );
135 if ( ret != EOF || errno != EINTR ) break; // timer interrupt ?
136 if ( cnt == 9 ) abort( "ofstream open EINTR spinning exceeded" );
137 } // for
138 if ( ret == EOF ) {
[ba0d2ea]139 throw (Close_Failure){ os };
140 // abort | IO_MSG "close output" | nl | strerror( errno );
[356189a]141 } // if
[7ce2483]142 file$ = 0p; // safety after close
[6ba0659]143} // close
144
[e3fea42]145ofstream & write( ofstream & os, const char data[], size_t size ) {
[6ba0659]146 if ( fail( os ) ) {
[ba0d2ea]147 throw (Write_Failure){ os };
148 // abort | IO_MSG "attempt write I/O on failed stream";
[6ba0659]149 } // if
150
[6c5d92f]151 if ( fwrite( data, 1, size, (FILE *)(os.file$) ) != size ) {
[ba0d2ea]152 throw (Write_Failure){ os };
153 // abort | IO_MSG "write" | nl | strerror( errno );
[839ccbb]154 } // if
[86bd7c1f]155 return os;
[839ccbb]156} // write
[51b73452]157
[09687aa]158int fmt( ofstream & os, const char format[], ... ) {
[5d125e4]159 va_list args;
[829c907]160 va_start( args, format );
[cce4648]161
[8dcb832]162 int len;
163 for ( cnt; 10 ) {
164 errno = 0;
[7a1b7e6]165 disable_interrupts();
[8dcb832]166 len = vfprintf( (FILE *)(os.file$), format, args );
[7a1b7e6]167 enable_interrupts();
[8dcb832]168 if ( len != EOF || errno != EINTR ) break; // timer interrupt ?
169 if ( cnt == 9 ) abort( "ofstream fmt EINTR spinning exceeded" );
170 } // for
[90c3b1c]171 if ( len == EOF ) {
[6c5d92f]172 if ( ferror( (FILE *)(os.file$) ) ) {
[ff2a33e]173 abort | IO_MSG "invalid write";
[90c3b1c]174 } // if
175 } // if
[5d125e4]176 va_end( args );
[b72bad4f]177
[6c5d92f]178 setPrt$( os, true ); // called in output cascade
179 sepReset$( os ); // reset separator
[90c3b1c]180 return len;
[829c907]181} // fmt
182
[fd8f88f]183static ofstream soutFile = { (FILE *)stdout };
[a87d40b]184ofstream & sout = soutFile, & stdout = soutFile;
[fd8f88f]185static ofstream serrFile = { (FILE *)stderr };
[a87d40b]186ofstream & serr = serrFile, & stderr = serrFile;
[51b73452]187
[e474cf09]188static ofstream lsoutFile = { (FILE *)stdout };
189ofstream & lsout = lsoutFile;
190
[fd8f88f]191static ofstream exitFile = { (FILE *)stdout };
[65240bb]192ofstream & exit = exitFile;
[fd8f88f]193static ofstream abortFile = { (FILE *)stderr };
[65240bb]194ofstream & abort = abortFile;
[5cb2b8c]195
[f451177]196ofstream & nl( ofstream & os ) {
197 nl$( os ); // call basic_ostream nl
198 flush( os );
199 return os;
200} // nl
[90c3b1c]201
[00e9be9]202
[8d321f9]203// *********************************** ifstream ***********************************
[65240bb]204
[51b73452]205
[09687aa]206// private
[7ce2483]207void ?{}( ifstream & is, void * file ) with( is ) {
[3bf3b6b]208 file$ = file;
209 nlOnOff$ = false;
[65240bb]210} // ?{}
[09687aa]211
[c8371b5]212bool getANL$( ifstream & os ) { return os.nlOnOff$; }
213
[7ce2483]214inline void lock( ifstream & os ) with( os ) { lock( os.lock$ ); }
215inline void unlock( ifstream & os ) { unlock( os.lock$ ); }
216
[09687aa]217// public
[6c5d92f]218void ?{}( ifstream & is ) { is.file$ = 0p; }
[7ce2483]219void ?{}( ifstream & is, const char name[], const char mode[] ) { open( is, name, mode ); }
220void ?{}( ifstream & is, const char name[] ) { open( is, name, "r" ); }
221void ^?{}( ifstream & is ) { close( is ); }
[4cae032]222
[7ce2483]223bool fail( ifstream & is ) { return is.file$ == 0p || ferror( (FILE *)(is.file$) ); }
224void clear( ifstream & is ) { clearerr( (FILE *)(is.file$) ); }
[00e9be9]225
[c8371b5]226void nlOn( ifstream & os ) { os.nlOnOff$ = true; }
227void nlOff( ifstream & os ) { os.nlOnOff$ = false; }
228
229void ends( ifstream & is ) {}
[e474cf09]230
[c8371b5]231bool eof( ifstream & is ) { return feof( (FILE *)(is.file$) ) != 0; }
[6ba0659]232
[e3fea42]233void open( ifstream & is, const char name[], const char mode[] ) {
[8dcb832]234 FILE * file;
235 for ( cnt; 10 ) {
236 errno = 0;
237 file = fopen( name, mode );
238 if ( file != 0p || errno != EINTR ) break; // timer interrupt ?
239 if ( cnt == 9 ) abort( "ifstream open EINTR spinning exceeded" );
240 } // for
[d1a9ff5]241 if ( file == 0p ) {
[8d321f9]242 throw (Open_Failure){ is };
243 // abort | IO_MSG "open input file \"" | name | "\"" | nl | strerror( errno );
[93c2e0a]244 } // if
[cce4648]245 (is){ file }; // initialize
[90c3b1c]246} // open
[6ba0659]247
[7ce2483]248void open( ifstream & is, const char name[] ) { open( is, name, "r" ); }
[8da74119]249
[7ce2483]250void close( ifstream & is ) with( is ) {
[3bf3b6b]251 if ( (FILE *)(file$) == 0p ) return;
252 if ( (FILE *)(file$) == (FILE *)stdin ) return;
[90c3b1c]253
[8dcb832]254 int ret;
255 for ( cnt; 10 ) {
256 errno = 0;
257 ret = fclose( (FILE *)(file$) );
258 if ( ret != EOF || errno != EINTR ) break; // timer interrupt ?
259 if ( cnt == 9 ) abort( "ifstream close EINTR spinning exceeded" );
260 } // for
261 if ( ret == EOF ) {
[ba0d2ea]262 throw (Close_Failure){ is };
263 // abort | IO_MSG "close input" | nl | strerror( errno );
[356189a]264 } // if
[8dcb832]265 file$ = 0p; // safety after close
[90c3b1c]266} // close
267
[00e9be9]268ifstream & read( ifstream & is, char data[], size_t size ) {
[6ba0659]269 if ( fail( is ) ) {
[ba0d2ea]270 throw (Read_Failure){ is };
271 // abort | IO_MSG "attempt read I/O on failed stream";
[6ba0659]272 } // if
273
[6c5d92f]274 if ( fread( data, size, 1, (FILE *)(is.file$) ) == 0 ) {
[ba0d2ea]275 throw (Read_Failure){ is };
276 // abort | IO_MSG "read" | nl | strerror( errno );
[6ba0659]277 } // if
[86bd7c1f]278 return is;
[6ba0659]279} // read
[356189a]280
[09687aa]281ifstream &ungetc( ifstream & is, char c ) {
[6ba0659]282 if ( fail( is ) ) {
[ff2a33e]283 abort | IO_MSG "attempt ungetc I/O on failed stream";
[6ba0659]284 } // if
[51b73452]285
[6c5d92f]286 if ( ungetc( c, (FILE *)(is.file$) ) == EOF ) {
[ff2a33e]287 abort | IO_MSG "ungetc" | nl | strerror( errno );
[6ba0659]288 } // if
289 return is;
290} // ungetc
[51b73452]291
[09687aa]292int fmt( ifstream & is, const char format[], ... ) {
[5d125e4]293 va_list args;
[829c907]294 va_start( args, format );
[8dcb832]295
296 int len;
297 for () { // no check for EINTR limit waiting for keyboard input
298 errno = 0;
[7a1b7e6]299 disable_interrupts();
[8dcb832]300 len = vfscanf( (FILE *)(is.file$), format, args );
[7a1b7e6]301 enable_interrupts();
[8dcb832]302 if ( len != EOF || errno != EINTR ) break; // timer interrupt ?
303 } // for
[90c3b1c]304 if ( len == EOF ) {
[6c5d92f]305 if ( ferror( (FILE *)(is.file$) ) ) {
[ff2a33e]306 abort | IO_MSG "invalid read";
[90c3b1c]307 } // if
308 } // if
[5d125e4]309 va_end( args );
[90c3b1c]310 return len;
[829c907]311} // fmt
[51b73452]312
[fd8f88f]313static ifstream sinFile = { (FILE *)stdin };
[a87d40b]314ifstream & sin = sinFile, & stdin = sinFile;
[86bd7c1f]315
[91e52be]316
[8d321f9]317// *********************************** exceptions ***********************************
[91e52be]318
319
[ba0d2ea]320static vtable(Open_Failure) Open_Failure_vt;
[a5a6a1a8]321
322// exception I/O constructors
[3bf3b6b]323void ?{}( Open_Failure & ex, ofstream & ostream ) with(ex) {
324 virtual_table = &Open_Failure_vt;
325 ostream = &ostream;
326 tag = 1;
[a5a6a1a8]327} // ?{}
328
[3bf3b6b]329void ?{}( Open_Failure & ex, ifstream & istream ) with(ex) {
330 virtual_table = &Open_Failure_vt;
331 istream = &istream;
332 tag = 0;
[a5a6a1a8]333} // ?{}
334
335
[ba0d2ea]336static vtable(Close_Failure) Close_Failure_vt;
337
338// exception I/O constructors
[3bf3b6b]339void ?{}( Close_Failure & ex, ofstream & ostream ) with(ex) {
340 virtual_table = &Close_Failure_vt;
341 ostream = &ostream;
342 tag = 1;
[ba0d2ea]343} // ?{}
344
[3bf3b6b]345void ?{}( Close_Failure & ex, ifstream & istream ) with(ex) {
346 virtual_table = &Close_Failure_vt;
347 istream = &istream;
348 tag = 0;
[ba0d2ea]349} // ?{}
350
351
352static vtable(Write_Failure) Write_Failure_vt;
353
354// exception I/O constructors
[3bf3b6b]355void ?{}( Write_Failure & ex, ofstream & ostream ) with(ex) {
356 virtual_table = &Write_Failure_vt;
357 ostream = &ostream;
358 tag = 1;
[ba0d2ea]359} // ?{}
360
[3bf3b6b]361void ?{}( Write_Failure & ex, ifstream & istream ) with(ex) {
362 virtual_table = &Write_Failure_vt;
363 istream = &istream;
364 tag = 0;
[ba0d2ea]365} // ?{}
366
367
368static vtable(Read_Failure) Read_Failure_vt;
369
370// exception I/O constructors
[3bf3b6b]371void ?{}( Read_Failure & ex, ofstream & ostream ) with(ex) {
372 virtual_table = &Read_Failure_vt;
373 ostream = &ostream;
374 tag = 1;
[ba0d2ea]375} // ?{}
376
[3bf3b6b]377void ?{}( Read_Failure & ex, ifstream & istream ) with(ex) {
378 virtual_table = &Read_Failure_vt;
379 istream = &istream;
380 tag = 0;
[ba0d2ea]381} // ?{}
382
383// void throwOpen_Failure( ofstream & ostream ) {
384// Open_Failure exc = { ostream };
385// }
386
387// void throwOpen_Failure( ifstream & istream ) {
388// Open_Failure exc = { istream };
389// }
[91e52be]390
[86bd7c1f]391// Local Variables: //
392// tab-width: 4 //
393// End: //
Note: See TracBrowser for help on using the repository browser.