1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
|
/***
*streamb.h - definitions/declarations for the streambuf class
*
* Copyright (c) 1990-1993, Microsoft Corporation. All rights reserved.
*
*Purpose:
* This file defines the classes, values, macros, and functions
* used by the streambuf class.
* [AT&T C++]
*
****/
#ifndef _INC_STREAMB
#define _INC_STREAMB
#include <ios.h> // need ios::seek_dir definition
#ifdef _MT // defined in ios.h
extern "C" {
void _mtlockinit(PRTL_CRITICAL_SECTION);
void _mtlock(PRTL_CRITICAL_SECTION);
void _mtunlock(PRTL_CRITICAL_SECTION);
}
#endif
#ifndef NULL
#define NULL 0
#endif
#ifndef EOF
#define EOF (-1)
#endif
// C4505: "unreferenced local function has been removed"
#pragma warning(disable:4505) // disable C4505 warning
// #pragma warning(default:4505) // use this to reenable, if desired
// C4103 : "used #pragma pack to change alignment"
#pragma warning(disable:4103) // disable C4103 warning
// #pragma warning(default:4103) // use this to reenable, if desired
// Force word packing to avoid possible -Zp override
#pragma pack(4)
typedef long streampos, streamoff;
class ios;
class streambuf {
public:
virtual ~streambuf();
inline int in_avail() const;
inline int out_waiting() const;
int sgetc();
int snextc();
int sbumpc();
void stossc();
inline int sputbackc(char);
inline int sputc(int);
inline int sputn(const char *,int);
inline int sgetn(char *,int);
virtual int sync();
// enum seek_dir { beg=0, cur=1, end=2 }; // CONSIDER: needed ???
virtual streambuf* setbuf(char *, int);
virtual streampos seekoff(streamoff,ios::seek_dir,int =ios::in|ios::out);
virtual streampos seekpos(streampos,int =ios::in|ios::out);
virtual int xsputn(const char *,int);
virtual int xsgetn(char *,int);
virtual int overflow(int =EOF) = 0; // pure virtual function
virtual int underflow() = 0; // pure virtual function
virtual int pbackfail(int);
void dbp();
#ifdef _MT
void setlock() { LockFlg--; } // <0 indicates lock required;
void clrlock() { if (LockFlg <= 0) LockFlg++; }
void lock() { if (LockFlg<0) _mtlock(lockptr()); };
void unlock() { if (LockFlg<0) _mtunlock(lockptr()); }
#else
void lock() { }
void unlock() { }
#endif
protected:
streambuf();
streambuf(char *,int);
inline char * base() const;
inline char * ebuf() const;
inline char * pbase() const;
inline char * pptr() const;
inline char * epptr() const;
inline char * eback() const;
inline char * gptr() const;
inline char * egptr() const;
inline int blen() const;
inline void setp(char *,char *);
inline void setg(char *,char *,char *);
inline void pbump(int);
inline void gbump(int);
void setb(char *,char *,int =0);
inline int unbuffered() const;
inline void unbuffered(int);
int allocate();
virtual int doallocate();
#ifdef _MT
PRTL_CRITICAL_SECTION lockptr() { return & x_lock; }
#endif
private:
int _fAlloc;
int _fUnbuf;
int x_lastc;
char * _base;
char * _ebuf;
char * _pbase;
char * _pptr;
char * _epptr;
char * _eback;
char * _gptr;
char * _egptr;
#ifdef _MT
int LockFlg; // <0 indicates locking required
RTL_CRITICAL_SECTION x_lock; // lock needed only for multi-thread operation
#endif
};
inline int streambuf::in_avail() const { return (gptr()<_egptr) ? (_egptr-gptr()) : 0; }
inline int streambuf::out_waiting() const { return (_pptr>=_pbase) ? (_pptr-_pbase) : 0; }
inline int streambuf::sputbackc(char _c){ return (_eback<gptr()) ? *(--_gptr)=_c : pbackfail(_c); }
inline int streambuf::sputc(int _i){ return (_pptr<_epptr) ? (unsigned char)(*(_pptr++)=(char)_i) : overflow(_i); }
inline int streambuf::sputn(const char * _str,int _n) { return xsputn(_str, _n); }
inline int streambuf::sgetn(char * _str,int _n) { return xsgetn(_str, _n); }
inline char * streambuf::base() const { return _base; }
inline char * streambuf::ebuf() const { return _ebuf; }
inline int streambuf::blen() const {return ((_ebuf > _base) ? (_ebuf-_base) : 0); }
inline char * streambuf::pbase() const { return _pbase; }
inline char * streambuf::pptr() const { return _pptr; }
inline char * streambuf::epptr() const { return _epptr; }
inline char * streambuf::eback() const { return _eback; }
inline char * streambuf::gptr() const { return _gptr; }
inline char * streambuf::egptr() const { return _egptr; }
inline void streambuf::gbump(int n) { if (_egptr) _gptr += n; }
inline void streambuf::pbump(int n) { if (_epptr) _pptr += n; }
inline void streambuf::setg(char * eb, char * g, char * eg) {_eback=eb; _gptr=g; _egptr=eg; x_lastc=EOF; }
inline void streambuf::setp(char * p, char * ep) {_pptr=_pbase=p; _epptr=ep; }
inline int streambuf::unbuffered() const { return _fUnbuf; }
inline void streambuf::unbuffered(int fUnbuf) { _fUnbuf = fUnbuf; }
// Restore default packing
#pragma pack()
#endif /* !_INC_STREAMB */
|
