Edwin Smith
136 linhas
4.6 KiB
C++
136 linhas
4.6 KiB
C++
/*
|
|
+----------------------------------------------------------------------+
|
|
| HipHop for PHP |
|
|
+----------------------------------------------------------------------+
|
|
| Copyright (c) 2010-2013 Facebook, Inc. (http://www.facebook.com) |
|
|
+----------------------------------------------------------------------+
|
|
| This source file is subject to version 3.01 of the PHP license, |
|
|
| that is bundled with this package in the file LICENSE, and is |
|
|
| available through the world-wide-web at the following url: |
|
|
| http://www.php.net/license/3_01.txt |
|
|
| If you did not receive a copy of the PHP license and are unable to |
|
|
| obtain it through the world-wide-web, please send a note to |
|
|
| license@php.net so we can mail you a copy immediately. |
|
|
+----------------------------------------------------------------------+
|
|
*/
|
|
|
|
#include "hphp/runtime/debugger/debugger_thrift_buffer.h"
|
|
#include "hphp/runtime/base/variable_serializer.h"
|
|
#include "hphp/runtime/base/variable_unserializer.h"
|
|
|
|
namespace HPHP {
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
TRACE_SET_MOD(debugger);
|
|
|
|
String DebuggerThriftBuffer::readImpl() {
|
|
TRACE(2, "DebuggerThriftBuffer::readImpl\n");
|
|
assert(m_size <= BUFFER_SIZE);
|
|
int nread = m_socket->readImpl(m_buffer, m_size);
|
|
m_buffer[nread] = '\0';
|
|
return String(m_buffer, nread, CopyString);
|
|
}
|
|
|
|
void DebuggerThriftBuffer::flushImpl(CStrRef data) {
|
|
TRACE(2, "DebuggerThriftBuffer::flushImpl\n");
|
|
m_socket->write(data);
|
|
}
|
|
|
|
void DebuggerThriftBuffer::throwError(const char *msg, int code) {
|
|
TRACE(2, "DebuggerThriftBuffer::throwError\n");
|
|
throw Exception("Protocol Error (%d): %s", code, msg);
|
|
}
|
|
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
|
|
static StaticString s_hit_limit(LITSTR_INIT("Hit serialization limit"));
|
|
static StaticString s_unknown_exp(LITSTR_INIT("Hit unknown exception"));
|
|
static StaticString s_type_mismatch(LITSTR_INIT("Type mismatch"));
|
|
|
|
template<typename T>
|
|
static inline int serializeImpl(T data, String& sdata) {
|
|
TRACE(2, "DebuggerWireHelpers::serializeImpl\n");
|
|
VariableSerializer vs(VariableSerializer::Type::DebuggerSerialize);
|
|
try {
|
|
sdata = vs.serialize(data, true);
|
|
} catch (StringBufferLimitException &e) {
|
|
sdata = s_hit_limit;
|
|
return DebuggerWireHelpers::HitLimit;
|
|
} catch (...) {
|
|
sdata = s_unknown_exp;
|
|
return DebuggerWireHelpers::UnknownError;
|
|
}
|
|
return DebuggerWireHelpers::NoError;
|
|
}
|
|
|
|
static inline int unserializeImpl(CStrRef sdata, Variant& data) {
|
|
TRACE(2, "DebuggerWireHelpers::unserializeImpl(CStrRef sdata,\n");
|
|
if (sdata.same(s_hit_limit)) {
|
|
return DebuggerWireHelpers::HitLimit;
|
|
}
|
|
if (sdata.same(s_unknown_exp)) {
|
|
return DebuggerWireHelpers::UnknownError;
|
|
}
|
|
VariableUnserializer vu(sdata.data(), sdata.size(),
|
|
VariableUnserializer::Type::Serialize, true);
|
|
try {
|
|
data = vu.unserialize();
|
|
} catch (Exception &e) {
|
|
data = null_variant;
|
|
return DebuggerWireHelpers::UnknownError;
|
|
}
|
|
return DebuggerWireHelpers::NoError;
|
|
}
|
|
|
|
int DebuggerWireHelpers::WireSerialize(CArrRef data, String& sdata) {
|
|
TRACE(2, "DebuggerWireHelpers::WireSerialize(CArrRef data,\n");
|
|
return serializeImpl(data, sdata);
|
|
}
|
|
|
|
int DebuggerWireHelpers::WireSerialize(CObjRef data, String& sdata) {
|
|
TRACE(2, "DebuggerWireHelpers::WireSerialize(CObjRef data,\n");
|
|
return serializeImpl(data, sdata);
|
|
}
|
|
|
|
int DebuggerWireHelpers::WireSerialize(CVarRef data, String& sdata) {
|
|
TRACE(2, "DebuggerWireHelpers::WireSerialize(CVarRef data,\n");
|
|
return serializeImpl(data, sdata);
|
|
}
|
|
|
|
int DebuggerWireHelpers::WireUnserialize(String& sdata, Array& data) {
|
|
TRACE(2, "DebuggerWireHelpers::WireUnserialize, Array& data)\n");
|
|
Variant v;
|
|
int ret = unserializeImpl(sdata, v);
|
|
if (ret != NoError) {
|
|
return ret;
|
|
}
|
|
if (!v.isArray() && !v.isNull()) {
|
|
sdata = s_type_mismatch;
|
|
return TypeMismatch;
|
|
}
|
|
data = v;
|
|
return NoError;
|
|
}
|
|
|
|
int DebuggerWireHelpers::WireUnserialize(String& sdata, Object& data) {
|
|
TRACE(2, "DebuggerWireHelpers::WireUnserialize, Object& data\n");
|
|
Variant v;
|
|
int ret = unserializeImpl(sdata, v);
|
|
if (ret != NoError) {
|
|
return ret;
|
|
}
|
|
if (!v.isObject() && !v.isNull()) {
|
|
sdata = s_type_mismatch;
|
|
return TypeMismatch;
|
|
}
|
|
data = v.toObject();
|
|
return NoError;
|
|
}
|
|
|
|
int DebuggerWireHelpers::WireUnserialize(String& sdata, Variant& data) {
|
|
TRACE(2, "DebuggerWireHelpers::WireUnserialize\n");
|
|
return unserializeImpl(sdata, data);
|
|
}
|
|
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
}
|