Changeset 8dcb832


Ignore:
Timestamp:
Oct 6, 2021, 8:37:21 PM (4 years ago)
Author:
Peter A. Buhr <pabuhr@…>
Branches:
ADT, ast-experimental, enum, forall-pointer-decay, master, pthread-emulation, qualifiedEnum
Children:
237df76
Parents:
e16eb460
Message:

remove mutual-exclusion acquire for streams, add EINTR restarts for C stream functions

Location:
libcfa/src
Files:
4 edited

Legend:

Unmodified
Added
Removed

  • libcfa/src/fstream.cfa

    re16eb460 r8dcb832  
    1010// Created On       : Wed May 27 17:56:53 2015
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Fri Oct  1 08:10:21 2021
    13 // Update Count     : 473
     12// Last Modified On : Wed Oct  6 18:39:13 2021
     13// Update Count     : 508
    1414//
    1515
    … …  
    3636        prt$ = false;
    3737        sawNL$ = false;
    38         acquired$ = false;
    3938        sepSetCur$( os, sepGet( os ) );
    4039        sepSet( os, " " );
    … …  
    101100        if ( &os == &exit ) exit( EXIT_FAILURE );
    102101        if ( &os == &abort ) abort();
    103         if ( os.acquired$ ) { os.acquired$ = false; unlock( os ); }
    104102} // ends
    105103
    … …  
    109107
    110108void open( ofstream & os, const char name[], const char mode[] ) {
    111         FILE * file = fopen( name, mode );
     109        FILE * file;
     110    for ( cnt; 10 ) {
     111                errno = 0;
     112                file = fopen( name, mode );
     113          if ( file != 0p || errno != EINTR ) break;            // timer interrupt ?
     114          if ( cnt == 9 ) abort( "ofstream open EINTR spinning exceeded" );
     115    } // for
    112116        if ( file == 0p ) {
    113117                throw (Open_Failure){ os };
    … …  
    123127  if ( (FILE *)(file$) == (FILE *)stdout || (FILE *)(file$) == (FILE *)stderr ) return;
    124128
    125         if ( fclose( (FILE *)(file$) ) == EOF ) {
     129        int ret;
     130    for ( cnt; 10 ) {
     131                errno = 0;
     132                ret = fclose( (FILE *)(file$) );
     133          if ( ret != EOF || errno != EINTR ) break;            // timer interrupt ?
     134          if ( cnt == 9 ) abort( "ofstream open EINTR spinning exceeded" );
     135    } // for
     136        if ( ret == EOF ) {
    126137                throw (Close_Failure){ os };
    127138                // abort | IO_MSG "close output" | nl | strerror( errno );
    … …  
    146157        va_list args;
    147158        va_start( args, format );
    148         int len = vfprintf( (FILE *)(os.file$), format, args );
     159               
     160        int len;
     161    for ( cnt; 10 ) {
     162                errno = 0;
     163                len = vfprintf( (FILE *)(os.file$), format, args );
     164          if ( len != EOF || errno != EINTR ) break;            // timer interrupt ?
     165          if ( cnt == 9 ) abort( "ofstream fmt EINTR spinning exceeded" );
     166    } // for
    149167        if ( len == EOF ) {
    150168                if ( ferror( (FILE *)(os.file$) ) ) {
    … …  
    158176        return len;
    159177} // fmt
    160 
    161 void acquire( ofstream & os ) with( os ) {
    162         lock( os );                                                                                     // may increase recursive lock
    163         if ( ! acquired$ ) acquired$ = true;                            // not locked ?
    164         else unlock( os );                                                                      // unwind recursive lock at start
    165 } // acquire
    166 
    167 void ?{}( osacquire & acq, ofstream & os ) { &acq.os = &os; lock( os ); }
    168 void ^?{}( osacquire & acq ) { unlock( acq.os ); }
    169178
    170179static ofstream soutFile = { (FILE *)stdout };
    … …  
    195204        file$ = file;
    196205        nlOnOff$ = false;
    197         acquired$ = false;
    198206} // ?{}
    199207
    … …  
    215223
    216224void ends( ifstream & is ) {
    217         if ( is.acquired$ ) { is.acquired$ = false; unlock( is ); }
    218225} // ends
    219226
    … …  
    221228
    222229void open( ifstream & is, const char name[], const char mode[] ) {
    223         FILE * file = fopen( name, mode );
     230        FILE * file;
     231    for ( cnt; 10 ) {
     232                errno = 0;
     233                file = fopen( name, mode );
     234          if ( file != 0p || errno != EINTR ) break;            // timer interrupt ?
     235          if ( cnt == 9 ) abort( "ifstream open EINTR spinning exceeded" );
     236    } // for
    224237        if ( file == 0p ) {
    225238                throw (Open_Failure){ is };
    … …  
    235248  if ( (FILE *)(file$) == (FILE *)stdin ) return;
    236249
    237         if ( fclose( (FILE *)(file$) ) == EOF ) {
     250        int ret;
     251    for ( cnt; 10 ) {
     252                errno = 0;
     253                ret = fclose( (FILE *)(file$) );
     254          if ( ret != EOF || errno != EINTR ) break;            // timer interrupt ?
     255          if ( cnt == 9 ) abort( "ifstream close EINTR spinning exceeded" );
     256    } // for
     257        if ( ret == EOF ) {
    238258                throw (Close_Failure){ is };
    239259                // abort | IO_MSG "close input" | nl | strerror( errno );
    240260        } // if
    241         file$ = 0p;
     261        file$ = 0p;                                                                                     // safety after close
    242262} // close
    243263
    … …  
    268288int fmt( ifstream & is, const char format[], ... ) {
    269289        va_list args;
    270 
    271290        va_start( args, format );
    272         int len = vfscanf( (FILE *)(is.file$), format, args );
     291
     292        int len;
     293    for () {                                                                                    // no check for EINTR limit waiting for keyboard input
     294                errno = 0;
     295                len = vfscanf( (FILE *)(is.file$), format, args );
     296          if ( len != EOF || errno != EINTR ) break;            // timer interrupt ?
     297    } // for
    273298        if ( len == EOF ) {
    274299                if ( ferror( (FILE *)(is.file$) ) ) {
    … …  
    279304        return len;
    280305} // fmt
    281 
    282 void acquire( ifstream & is ) with( is ) {
    283         lock( is );                                                                                     // may increase recursive lock
    284         if ( ! acquired$ ) acquired$ = true;                            // not locked ?
    285         else unlock( is );                                                                      // unwind recursive lock at start
    286 } // acquire
    287 
    288 void ?{}( isacquire & acq, ifstream & is ) { &acq.is = &is; lock( is ); }
    289 void ^?{}( isacquire & acq ) { unlock( acq.is ); }
    290306
    291307static ifstream sinFile = { (FILE *)stdin };

  • libcfa/src/fstream.hfa

    re16eb460 r8dcb832  
    1010// Created On       : Wed May 27 17:56:53 2015
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Fri Oct  1 07:40:37 2021
    13 // Update Count     : 238
     12// Last Modified On : Wed Oct  6 18:45:49 2021
     13// Update Count     : 240
    1414//
    1515
    … …  
    3636        char tupleSeparator$[ofstream_sepSize];
    3737        multiple_acquisition_lock lock$;
    38         bool acquired$;
    3938}; // ofstream
    4039
    … …  
    8079ofstream & write( ofstream &, const char data[], size_t size );
    8180
    82 void acquire( ofstream & );
    83 
    84 struct osacquire {
    85         ofstream & os;
    86 };
    87 void ?{}( osacquire & acq, ofstream & );
    88 void ^?{}( osacquire & acq );
    89 
    9081void ?{}( ofstream & );
    9182void ?{}( ofstream &, const char name[], const char mode[] ); // FIX ME: use default = "w"
    … …  
    109100        bool nlOnOff$;
    110101        multiple_acquisition_lock lock$;
    111         bool acquired$;
    112102}; // ifstream
    113103
    … …  
    133123ifstream & read( ifstream & is, char data[], size_t size );
    134124ifstream & ungetc( ifstream & is, char c );
    135 
    136 void acquire( ifstream & is );
    137 
    138 struct isacquire {
    139         ifstream & is;
    140 };
    141 void ?{}( isacquire & acq, ifstream & is );
    142 void ^?{}( isacquire & acq );
    143125
    144126void ?{}( ifstream & is );

  • libcfa/src/iostream.cfa

    re16eb460 r8dcb832  
    1010// Created On       : Wed May 27 17:56:53 2015
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Sat May 15 09:39:21 2021
    13 // Update Count     : 1342
     12// Last Modified On : Wed Oct  6 18:55:03 2021
     13// Update Count     : 1344
    1414//
    1515
    … …  
    398398                return os;
    399399        } // nlOff
    400 } // distribution
    401 
    402 forall( ostype & | ostream( ostype ) ) {
    403         ostype & acquire( ostype & os ) {
    404                 acquire( os );                                                                  // call void returning
    405                 return os;
    406         } // acquire
    407400} // distribution
    408401
    … …  
    10371030} // distribution
    10381031
    1039 forall( istype & | istream( istype ) ) {
    1040         istype & acquire( istype & is ) {
    1041                 acquire( is );                                                                  // call void returning
    1042                 return is;
    1043         } // acquire
    1044 } // distribution
    1045 
    10461032// *********************************** manipulators ***********************************
    10471033

  • libcfa/src/iostream.hfa

    re16eb460 r8dcb832  
    1010// Created On       : Wed May 27 17:56:53 2015
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Wed Apr 28 20:37:56 2021
    13 // Update Count     : 401
     12// Last Modified On : Wed Oct  6 18:54:59 2021
     13// Update Count     : 404
    1414//
    1515
    … …  
    5858        void close( ostype & );
    5959        ostype & write( ostype &, const char [], size_t );
    60         void acquire( ostype & );                                                       // concurrent access
    6160}; // ostream
    6261
    … …  
    142141        ostype & nlOn( ostype & );
    143142        ostype & nlOff( ostype & );
    144 } // distribution
    145 
    146 forall( ostype & | ostream( ostype ) ) {
    147         ostype & acquire( ostype & );
    148143} // distribution
    149144
    … …  
    312307        void close( istype & is );
    313308        istype & read( istype &, char [], size_t );
    314         void acquire( istype & );                                                       // concurrent access
    315309}; // istream
    316310
    … …  
    379373} // distribution
    380374
    381 forall( istype & | istream( istype ) ) {
    382         istype & acquire( istype & );
    383 } // distribution
    384 
    385375// *********************************** manipulators ***********************************
    386376
Note: See TracChangeset for help on using the changeset viewer.