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 17 matching lines...) Expand all Loading... |
28 PROC_GET_PREF | 28 PROC_GET_PREF |
29 }; | 29 }; |
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(const std::string& data) : buffer(data), hasType(false) {} | 39 InputBuffer(const std::string& data) : buffer(data), hasType(false) {} |
| 40 InputBuffer(const InputBuffer& copy) |
| 41 { |
| 42 hasType = copy.hasType; |
| 43 buffer = std::istringstream(copy.buffer.str()); |
| 44 currentType = copy.currentType; |
| 45 } |
39 InputBuffer& operator>>(ProcType& value) { return Read(value, TYPE_PROC); } | 46 InputBuffer& operator>>(ProcType& value) { return Read(value, TYPE_PROC); } |
40 InputBuffer& operator>>(std::string& value) { return ReadString(value, TYPE_
STRING); } | 47 InputBuffer& operator>>(std::string& value) { return ReadString(value, TYPE_
STRING); } |
41 InputBuffer& operator>>(std::wstring& value) { return ReadString(value, TYPE
_WSTRING); } | 48 InputBuffer& operator>>(std::wstring& value) { return ReadString(value, TYPE
_WSTRING); } |
42 InputBuffer& operator>>(int64_t& value) { return Read(value, TYPE_INT64); } | 49 InputBuffer& operator>>(int64_t& value) { return Read(value, TYPE_INT64); } |
43 InputBuffer& operator>>(int32_t& value) { return Read(value, TYPE_INT32); } | 50 InputBuffer& operator>>(int32_t& value) { return Read(value, TYPE_INT32); } |
44 InputBuffer& operator>>(bool& value) { return Read(value, TYPE_BOOL); } | 51 InputBuffer& operator>>(bool& value) { return Read(value, TYPE_BOOL); } |
| 52 InputBuffer& operator=(const InputBuffer& copy) |
| 53 { |
| 54 hasType = copy.hasType; |
| 55 buffer = std::istringstream(copy.buffer.str()); |
| 56 currentType = copy.currentType; |
| 57 return *this; |
| 58 } |
45 ValueType GetType(); | 59 ValueType GetType(); |
46 private: | 60 private: |
47 std::istringstream buffer; | 61 std::istringstream buffer; |
48 ValueType currentType; | 62 ValueType currentType; |
49 bool hasType; | 63 bool hasType; |
50 | 64 |
51 void CheckType(ValueType expectedType); | 65 void CheckType(ValueType expectedType); |
52 | 66 |
53 template<class T> | 67 template<class T> |
54 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... |
163 | 177 |
164 InputBuffer ReadMessage(); | 178 InputBuffer ReadMessage(); |
165 void WriteMessage(OutputBuffer& message); | 179 void WriteMessage(OutputBuffer& message); |
166 | 180 |
167 protected: | 181 protected: |
168 HANDLE pipe; | 182 HANDLE pipe; |
169 }; | 183 }; |
170 } | 184 } |
171 | 185 |
172 #endif | 186 #endif |
LEFT | RIGHT |