blob: 435e6357245f49f747e7d771d33a9a79eeb34109 (
plain) (
blame)
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
|
#pragma once
#ifdef __GNUC__
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Warray-bounds" //need because of bug in gcc4.9.2
#endif
#include "defaults.h"
#include "file.h"
#include <util/generic/ptr.h>
#include <util/network/pair.h>
#include <util/generic/noncopyable.h>
using PIPEHANDLE = SOCKET;
#define INVALID_PIPEHANDLE INVALID_SOCKET
/// Pipe-like object: pipe on POSIX and socket on windows
class TPipeHandle: public TNonCopyable {
public:
inline TPipeHandle() noexcept
: Fd_(INVALID_PIPEHANDLE)
{
}
inline TPipeHandle(PIPEHANDLE fd) noexcept
: Fd_(fd)
{
}
inline ~TPipeHandle() {
Close();
}
bool Close() noexcept;
inline PIPEHANDLE Release() noexcept {
PIPEHANDLE ret = Fd_;
Fd_ = INVALID_PIPEHANDLE;
return ret;
}
inline void Swap(TPipeHandle& r) noexcept {
DoSwap(Fd_, r.Fd_);
}
inline operator PIPEHANDLE() const noexcept {
return Fd_;
}
inline bool IsOpen() const noexcept {
return Fd_ != INVALID_PIPEHANDLE;
}
ssize_t Read(void* buffer, size_t byteCount) const noexcept;
ssize_t Write(const void* buffer, size_t byteCount) const noexcept;
// Only CloseOnExec is supported
static void Pipe(TPipeHandle& reader, TPipeHandle& writer, EOpenMode mode = 0);
private:
PIPEHANDLE Fd_;
};
class TPipe {
public:
TPipe();
/// Takes ownership of handle, so closes it when the last holder of descriptor dies.
explicit TPipe(PIPEHANDLE fd);
~TPipe();
void Close();
bool IsOpen() const noexcept;
PIPEHANDLE GetHandle() const noexcept;
size_t Read(void* buf, size_t len) const;
size_t Write(const void* buf, size_t len) const;
// Only CloseOnExec is supported
static void Pipe(TPipe& reader, TPipe& writer, EOpenMode mode = 0);
private:
class TImpl;
using TImplRef = TSimpleIntrusivePtr<TImpl>;
TImplRef Impl_;
};
#ifdef __GNUC__
#pragma GCC diagnostic pop
#endif
|
