Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code

Unified Diff: src/shared/Communication.h

Issue 4882650246414336: Issue 2005 - Refactor working with strings in InputBuffer and OutputBuffer
Patch Set: rebase Created April 2, 2015, 11:09 a.m.
Use n/p to move between diff chunks; N/P to move between comments.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: src/shared/Communication.h
diff --git a/src/shared/Communication.h b/src/shared/Communication.h
index 1b1bcaded69db28044bd6093c56dce629f8428c5..d7bc976c0d2af63c5c3e2220216046b5b86191b8 100644
--- a/src/shared/Communication.h
+++ b/src/shared/Communication.h
@@ -25,6 +25,7 @@
#include <string>
#include <vector>
#include <Windows.h>
+#include "Utils.h"
namespace Communication
{
@@ -55,7 +56,7 @@ namespace Communication
PROC_COMPARE_VERSIONS
};
enum ValueType : uint32_t {
- TYPE_PROC, TYPE_STRING, TYPE_WSTRING, TYPE_INT64, TYPE_INT32, TYPE_BOOL, TYPE_STRINGS
+ TYPE_PROC, TYPE_STRING, TYPE_INT64, TYPE_INT32, TYPE_BOOL, TYPE_STRINGS
};
typedef uint32_t SizeType;
@@ -71,12 +72,25 @@ namespace Communication
currentType = copy.currentType;
}
InputBuffer& operator>>(ProcType& value) { return Read(value, TYPE_PROC); }
- InputBuffer& operator>>(std::string& value) { return ReadString(value, TYPE_STRING); }
- InputBuffer& operator>>(std::wstring& value) { return ReadString(value, TYPE_WSTRING); }
+ InputBuffer& operator>>(std::string& value) { return ReadString(value); }
+ InputBuffer& operator>>(std::wstring& value)
+ {
+ std::string tmpString;
+ operator>>(tmpString);
+ value = ToUtf16String(tmpString);
+ return *this;
+ }
InputBuffer& operator>>(int64_t& value) { return Read(value, TYPE_INT64); }
InputBuffer& operator>>(int32_t& value) { return Read(value, TYPE_INT32); }
InputBuffer& operator>>(bool& value) { return Read(value, TYPE_BOOL); }
InputBuffer& operator>>(std::vector<std::string>& value) { return ReadStrings(value); }
+ InputBuffer& operator>>(std::vector<std::wstring>& value)
+ {
+ std::vector<std::string> tmpStrings;
+ operator>>(tmpStrings);
+ value = ToUtf16Strings(tmpStrings);
+ return *this;
+ }
InputBuffer& operator=(const InputBuffer& copy)
{
hasType = copy.hasType;
@@ -92,20 +106,19 @@ namespace Communication
void CheckType(ValueType expectedType);
- template<class T>
- InputBuffer& ReadString(T& value, ValueType expectedType)
+ InputBuffer& ReadString(std::string& value)
{
- CheckType(expectedType);
+ CheckType(TYPE_STRING);
SizeType length;
ReadBinary(length);
-
- std::auto_ptr<T::value_type> data(new T::value_type[length]);
- buffer.read(reinterpret_cast<char*>(data.get()), sizeof(T::value_type) * length);
- if (buffer.fail())
- throw new std::runtime_error("Unexpected end of input buffer");
-
- value.assign(data.get(), length);
+ value.resize(length);
+ if (length > 0)
+ {
+ buffer.read(&value[0], length);
+ if (buffer.fail())
+ throw new std::runtime_error("Unexpected end of input buffer");
+ }
return *this;
}
@@ -155,8 +168,11 @@ namespace Communication
return buffer.str();
}
OutputBuffer& operator<<(ProcType value) { return Write(value, TYPE_PROC); }
- OutputBuffer& operator<<(const std::string& value) { return WriteString(value, TYPE_STRING); }
- OutputBuffer& operator<<(const std::wstring& value) { return WriteString(value, TYPE_WSTRING); }
+ OutputBuffer& operator<<(const std::string& value) { return WriteString(value); }
+ OutputBuffer& operator<<(const std::wstring& value)
+ {
+ return operator<<(ToUtf8String(value));
+ }
OutputBuffer& operator<<(int64_t value) { return Write(value, TYPE_INT64); }
OutputBuffer& operator<<(int32_t value) { return Write(value, TYPE_INT32); }
OutputBuffer& operator<<(bool value) { return Write(value, TYPE_BOOL); }
@@ -167,15 +183,13 @@ namespace Communication
// Disallow copying
const OutputBuffer& operator=(const OutputBuffer&);
- template<class T>
- OutputBuffer& WriteString(const T& value, ValueType type)
+ OutputBuffer& WriteString(const std::string& value)
{
- WriteBinary(type);
+ WriteBinary(TYPE_STRING);
SizeType length = static_cast<SizeType>(value.size());
WriteBinary(length);
-
- buffer.write(reinterpret_cast<const char*>(value.c_str()), sizeof(T::value_type) * length);
+ buffer.write(value.c_str(), length);
if (buffer.fail())
throw new std::runtime_error("Unexpected error writing to output buffer");

Powered by Google App Engine
This is Rietveld