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
|
#ifndef OFDNSTREAMBUF_H_
#define OFDNSTREAMBUF_H_
#include <unistd.h>
#include <streambuf>
//CLASS
class OFdnStreambuf: public std::streambuf
{
int d_fd = -1;
size_t d_bufsize = 0;
char *d_buffer = 0;
public:
OFdnStreambuf() = default;
OFdnStreambuf(int fd, size_t bufsize = 1);
~OFdnStreambuf() override;
void open(int fd, size_t bufsize = 1);
private:
int sync() override;
int overflow(int c) override;
};
//=
//CONS
inline OFdnStreambuf::OFdnStreambuf(int fd, size_t bufsize)
{
open(fd, bufsize);
}
//=
//DESTR
inline OFdnStreambuf::~OFdnStreambuf()
{
if (d_buffer)
{
sync();
delete[] d_buffer;
}
}
//=
//OPEN
inline void OFdnStreambuf::open(int fd, size_t bufsize)
{
d_fd = fd;
d_bufsize = bufsize == 0 ? 1 : bufsize;
delete[] d_buffer;
d_buffer = new char[d_bufsize];
setp(d_buffer, d_buffer + d_bufsize);
}
//=
//SYNC
inline int OFdnStreambuf::sync()
{
if (pptr() > pbase())
{
write(d_fd, d_buffer, pptr() - pbase());
setp(d_buffer, d_buffer + d_bufsize);
}
return 0;
}
//=
//OVERFLOW
inline int OFdnStreambuf::overflow(int c)
{
sync();
if (c != EOF)
{
*pptr() = c;
pbump(1);
}
return c;
}
//=
#endif
|
