LEFT | RIGHT |
1 #ifndef COMMUNICATION_H | 1 #ifndef COMMUNICATION_H |
2 #define COMMUNICATION_H | 2 #define COMMUNICATION_H |
3 | 3 |
4 #include <memory> | 4 #include <memory> |
5 #include <sstream> | 5 #include <sstream> |
6 #include <stdexcept> | 6 #include <stdexcept> |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 #include <string> | 8 #include <string> |
9 #include <vector> | 9 #include <vector> |
10 #include <Windows.h> | 10 #include <Windows.h> |
(...skipping 19 matching lines...) Expand all Loading... |
30 enum ValueType : uint32_t { | 30 enum ValueType : uint32_t { |
31 TYPE_PROC, TYPE_STRING, TYPE_WSTRING, TYPE_INT64, TYPE_INT32, TYPE_BOOL | 31 TYPE_PROC, TYPE_STRING, TYPE_WSTRING, TYPE_INT64, TYPE_INT32, TYPE_BOOL |
32 }; | 32 }; |
33 typedef uint32_t SizeType; | 33 typedef uint32_t SizeType; |
34 | 34 |
35 class InputBuffer | 35 class InputBuffer |
36 { | 36 { |
37 public: | 37 public: |
38 InputBuffer() : buffer(), hasType(false) {} | 38 InputBuffer() : buffer(), hasType(false) {} |
39 InputBuffer(const std::string& data) : buffer(data), hasType(false) {} | 39 InputBuffer(const std::string& data) : buffer(data), hasType(false) {} |
40 InputBuffer(const InputBuffer& copy) { hasType = copy.hasType; buffer = std:
:istringstream(copy.buffer.str()); currentType = copy.currentType; } | 40 InputBuffer(const InputBuffer& copy) |
| 41 { |
| 42 hasType = copy.hasType; |
| 43 buffer = std::istringstream(copy.buffer.str()); |
| 44 currentType = copy.currentType; |
| 45 } |
41 InputBuffer& operator>>(ProcType& value) { return Read(value, TYPE_PROC); } | 46 InputBuffer& operator>>(ProcType& value) { return Read(value, TYPE_PROC); } |
42 InputBuffer& operator>>(std::string& value) { return ReadString(value, TYPE_
STRING); } | 47 InputBuffer& operator>>(std::string& value) { return ReadString(value, TYPE_
STRING); } |
43 InputBuffer& operator>>(std::wstring& value) { return ReadString(value, TYPE
_WSTRING); } | 48 InputBuffer& operator>>(std::wstring& value) { return ReadString(value, TYPE
_WSTRING); } |
44 InputBuffer& operator>>(int64_t& value) { return Read(value, TYPE_INT64); } | 49 InputBuffer& operator>>(int64_t& value) { return Read(value, TYPE_INT64); } |
45 InputBuffer& operator>>(int32_t& value) { return Read(value, TYPE_INT32); } | 50 InputBuffer& operator>>(int32_t& value) { return Read(value, TYPE_INT32); } |
46 InputBuffer& operator>>(bool& value) { return Read(value, TYPE_BOOL); } | 51 InputBuffer& operator>>(bool& value) { return Read(value, TYPE_BOOL); } |
47 InputBuffer& operator=(const InputBuffer& copy) { hasType = copy.hasType; bu
ffer = std::istringstream(copy.buffer.str()); | 52 InputBuffer& operator=(const InputBuffer& copy) |
48 currentType = copy.current
Type; return *this; } | 53 { |
| 54 hasType = copy.hasType; |
| 55 buffer = std::istringstream(copy.buffer.str()); |
| 56 currentType = copy.currentType; |
| 57 return *this; |
| 58 } |
49 ValueType GetType(); | 59 ValueType GetType(); |
50 private: | 60 private: |
51 std::istringstream buffer; | 61 std::istringstream buffer; |
52 ValueType currentType; | 62 ValueType currentType; |
53 bool hasType; | 63 bool hasType; |
54 | 64 |
55 void CheckType(ValueType expectedType); | 65 void CheckType(ValueType expectedType); |
56 | 66 |
57 template<class T> | 67 template<class T> |
58 InputBuffer& ReadString(T& value, ValueType expectedType) | 68 InputBuffer& ReadString(T& value, ValueType expectedType) |
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
167 | 177 |
168 InputBuffer ReadMessage(); | 178 InputBuffer ReadMessage(); |
169 void WriteMessage(OutputBuffer& message); | 179 void WriteMessage(OutputBuffer& message); |
170 | 180 |
171 protected: | 181 protected: |
172 HANDLE pipe; | 182 HANDLE pipe; |
173 }; | 183 }; |
174 } | 184 } |
175 | 185 |
176 #endif | 186 #endif |
LEFT | RIGHT |