source: libcfa/src/strstream.cfa @ ae1d151

ADTast-experimentalpthread-emulation
Last change on this file since ae1d151 was cce4648, checked in by Thierry Delisle <tdelisle@…>, 2 years ago

Visibility for streams

  • Property mode set to 100644
File size: 5.4 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2021 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// strstream.cfa --
8//
9// Author           : Peter A. Buhr
10// Created On       : Thu Apr 22 22:24:35 2021
11// Last Modified By : Peter A. Buhr
12// Last Modified On : Sun Oct 10 16:13:20 2021
13// Update Count     : 101
14//
15
16#include "strstream.hfa"
17#include "fstream.hfa"                                                                  // abort
18
19#include <stdio.h>                                                                              // vsnprintf
20#include <stdarg.h>                                                                             // varargs
21#include <string.h>                                                                             // strncpy, strerror
22#include <assert.h>
23#include <errno.h>                                                                              // errno
24#include <unistd.h>                                                                             // sbrk, sysconf
25
26#pragma GCC visibility push(default)
27
28// *********************************** strstream ***********************************
29
30
31#define IO_MSG "I/O error: "
32
33// private
34inline bool sepPrt$( ostrstream & os ) { setNL$( os, false ); return os.sepOnOff$; }
35inline void sepReset$( ostrstream & os ) { os.sepOnOff$ = os.sepDefault$; }
36inline void sepReset$( ostrstream & os, bool reset ) { os.sepDefault$ = reset; os.sepOnOff$ = os.sepDefault$; }
37inline const char * sepGetCur$( ostrstream & os ) { return os.sepCur$; }
38inline void sepSetCur$( ostrstream & os, const char sepCur[] ) { os.sepCur$ = sepCur; }
39inline bool getNL$( ostrstream & os ) { return os.sawNL$; }
40inline void setNL$( ostrstream & os, bool state ) { os.sawNL$ = state; }
41inline bool getANL$( ostrstream & os ) { return os.nlOnOff$; }
42inline bool getPrt$( ostrstream & os ) { return os.prt$; }
43inline void setPrt$( ostrstream & os, bool state ) { os.prt$ = state; }
44
45// public
46void ?{}( ostrstream & os, char buf[], size_t size ) {
47        os.buf$ = buf;
48        os.size$ = size;
49        os.cursor$ = 0;
50        os.sepDefault$ = true;
51        os.sepOnOff$ = false;
52        os.nlOnOff$ = true;
53        os.prt$ = false;
54        os.sawNL$ = false;
55        sepSetCur$( os, sepGet( os ) );
56        sepSet( os, " " );
57        sepSetTuple( os, ", " );
58} // ?{}
59
60void sepOn( ostrstream & os ) { os.sepOnOff$ = ! getNL$( os ); }
61void sepOff( ostrstream & os ) { os.sepOnOff$ = false; }
62
63bool sepDisable( ostrstream & os ) {
64        bool temp = os.sepDefault$;
65        os.sepDefault$ = false;
66        sepReset$( os );
67        return temp;
68} // sepDisable
69
70bool sepEnable( ostrstream & os ) {
71        bool temp = os.sepDefault$;
72        os.sepDefault$ = true;
73        if ( os.sepOnOff$ ) sepReset$( os );                            // start of line ?
74        return temp;
75} // sepEnable
76
77void nlOn( ostrstream & os ) { os.nlOnOff$ = true; }
78void nlOff( ostrstream & os ) { os.nlOnOff$ = false; }
79
80const char * sepGet( ostrstream & os ) { return os.separator$; }
81void sepSet( ostrstream & os, const char s[] ) {
82        assert( s );
83        strncpy( os.separator$, s, ostrstream_sepSize - 1 );
84        os.separator$[ostrstream_sepSize - 1] = '\0';
85} // sepSet
86
87const char * sepGetTuple( ostrstream & os ) { return os.tupleSeparator$; }
88void sepSetTuple( ostrstream & os, const char s[] ) {
89        assert( s );
90        strncpy( os.tupleSeparator$, s, ostrstream_sepSize - 1 );
91        os.tupleSeparator$[ostrstream_sepSize - 1] = '\0';
92} // sepSet
93
94void ends( ostrstream & os ) {
95        if ( getANL$( os ) ) nl( os );
96        else setPrt$( os, false );                                                      // turn off
97} // ends
98
99int fmt( ostrstream & os, const char format[], ... ) {
100        va_list args;
101        va_start( args, format );
102        int len = vsnprintf( os.buf$ + os.cursor$, os.size$ - os.cursor$, format, args );
103        va_end( args );
104        os.cursor$ += len;
105        if ( os.cursor$ >= os.size$ ) {                                         // cursor exceeded buffer size?
106                #define fmtmsg IO_MSG "ostrstream truncated write, buffer too small.\n"
107                write( STDERR_FILENO, fmtmsg, sizeof(fmtmsg) - 1 );
108                abort();
109        } // if
110
111        setPrt$( os, true );                                                            // called in output cascade
112        sepReset$( os );                                                                        // reset separator
113        return len;
114} // fmt
115
116ostrstream & write( ostrstream & os, FILE * stream ) {
117        if ( fwrite( os.buf$, 1, os.cursor$, stream ) != os.cursor$ ) {
118                #define ostrwritemsg IO_MSG "ostrstream write error.\n"
119                write( STDERR_FILENO, ostrwritemsg, sizeof(ostrwritemsg) - 1 );
120                abort();
121        } // if
122        return os;
123} // write
124
125ostrstream & write( ostrstream & os ) {
126        return write( os, stdout );
127} // write
128
129
130// *********************************** istrstream ***********************************
131
132// private
133bool getANL$( istrstream & is ) { return is.nlOnOff$; }
134
135// public
136void ?{}( istrstream & is, char buf[] ) {
137        is.buf$ = buf;
138        is.cursor$ = 0;
139        is.nlOnOff$ = false;
140} // ?{}
141
142void nlOn( istrstream & is ) { is.nlOnOff$ = true; }
143void nlOff( istrstream & is ) { is.nlOnOff$ = false; }
144
145void ends( istrstream & is ) {}
146bool eof( istrstream & is ) { return false; }
147
148int fmt( istrstream & is, const char format[], ... ) with(is) {
149        va_list args;
150        va_start( args, format );
151        // THIS DOES NOT WORK BECAUSE VSSCANF RETURNS NUMBER OF VALUES READ VERSUS BUFFER POSITION SCANNED.
152        int len = vsscanf( buf$ + cursor$, format, args );
153        va_end( args );
154        if ( len == EOF ) {
155                abort | IO_MSG "invalid read";
156        } // if
157        // SKULLDUGGERY: This hack skips over characters read by vsscanf by moving to the next whitespace but it does not
158        // handle C reads with wdi manipulators that leave the cursor at a non-whitespace character.
159        for ( ; buf$[cursor$] != ' ' && buf$[cursor$] != '\t' && buf$[cursor$] != '\0'; cursor$ += 1 ) {
160                //printf( "X \'%c\'\n", buf$[cursor$] );
161        } // for
162        if ( buf$[cursor$] != '\0' ) cursor$ += 1;      // advance to whitespace
163        return len;
164} // fmt
165
166istrstream &ungetc( istrstream & is, char c ) {
167        // if ( ungetc( c, (FILE *)(is.file$) ) == EOF ) {
168        //      abort | IO_MSG "ungetc" | nl | strerror( errno );
169        // } // if
170        return is;
171} // ungetc
172
173// Local Variables: //
174// tab-width: 4 //
175// End: //
Note: See TracBrowser for help on using the repository browser.