// Copyright (c) 2012 The Chromium Authors. All rights reserved. // Use of this source code is governed by a BSD-style license that can be // found in the LICENSE file. #include "ipc/ipc_message_utils.h" #include "base/file_path.h" #include "base/json/json_writer.h" #include "base/memory/scoped_ptr.h" #include "base/nullable_string16.h" #include "base/string_number_conversions.h" #include "base/time.h" #include "base/utf_string_conversions.h" #include "base/values.h" #include "ipc/ipc_channel_handle.h" #if defined(OS_POSIX) #include "ipc/file_descriptor_set_posix.h" #endif namespace IPC { namespace { const int kMaxRecursionDepth = 100; template void LogBytes(const std::vector& data, std::string* out) { #if defined(OS_WIN) // Windows has a GUI for logging, which can handle arbitrary binary data. for (size_t i = 0; i < data.size(); ++i) out->push_back(data[i]); #else // On POSIX, we log to stdout, which we assume can display ASCII. static const size_t kMaxBytesToLog = 100; for (size_t i = 0; i < std::min(data.size(), kMaxBytesToLog); ++i) { if (isprint(data[i])) out->push_back(data[i]); else out->append(StringPrintf("[%02X]", static_cast(data[i]))); } if (data.size() > kMaxBytesToLog) { out->append( StringPrintf(" and %u more bytes", static_cast(data.size() - kMaxBytesToLog))); } #endif } bool ReadValue(const Message* m, PickleIterator* iter, Value** value, int recursion); void WriteValue(Message* m, const Value* value, int recursion) { bool result; if (recursion > kMaxRecursionDepth) { LOG(WARNING) << "Max recursion depth hit in WriteValue."; return; } m->WriteInt(value->GetType()); switch (value->GetType()) { case Value::TYPE_NULL: break; case Value::TYPE_BOOLEAN: { bool val; result = value->GetAsBoolean(&val); DCHECK(result); WriteParam(m, val); break; } case Value::TYPE_INTEGER: { int val; result = value->GetAsInteger(&val); DCHECK(result); WriteParam(m, val); break; } case Value::TYPE_DOUBLE: { double val; result = value->GetAsDouble(&val); DCHECK(result); WriteParam(m, val); break; } case Value::TYPE_STRING: { std::string val; result = value->GetAsString(&val); DCHECK(result); WriteParam(m, val); break; } case Value::TYPE_BINARY: { const base::BinaryValue* binary = static_cast(value); m->WriteData(binary->GetBuffer(), static_cast(binary->GetSize())); break; } case Value::TYPE_DICTIONARY: { const DictionaryValue* dict = static_cast(value); WriteParam(m, static_cast(dict->size())); for (DictionaryValue::key_iterator it = dict->begin_keys(); it != dict->end_keys(); ++it) { const Value* subval; if (dict->GetWithoutPathExpansion(*it, &subval)) { WriteParam(m, *it); WriteValue(m, subval, recursion + 1); } else { NOTREACHED() << "DictionaryValue iterators are filthy liars."; } } break; } case Value::TYPE_LIST: { const ListValue* list = static_cast(value); WriteParam(m, static_cast(list->GetSize())); for (size_t i = 0; i < list->GetSize(); ++i) { const Value* subval; if (list->Get(i, &subval)) { WriteValue(m, subval, recursion + 1); } else { NOTREACHED() << "ListValue::GetSize is a filthy liar."; } } break; } } } // Helper for ReadValue that reads a DictionaryValue into a pre-allocated // object. bool ReadDictionaryValue(const Message* m, PickleIterator* iter, DictionaryValue* value, int recursion) { int size; if (!ReadParam(m, iter, &size)) return false; for (int i = 0; i < size; ++i) { std::string key; Value* subval; if (!ReadParam(m, iter, &key) || !ReadValue(m, iter, &subval, recursion + 1)) return false; value->SetWithoutPathExpansion(key, subval); } return true; } // Helper for ReadValue that reads a ReadListValue into a pre-allocated // object. bool ReadListValue(const Message* m, PickleIterator* iter, ListValue* value, int recursion) { int size; if (!ReadParam(m, iter, &size)) return false; for (int i = 0; i < size; ++i) { Value* subval; if (!ReadValue(m, iter, &subval, recursion + 1)) return false; value->Set(i, subval); } return true; } bool ReadValue(const Message* m, PickleIterator* iter, Value** value, int recursion) { if (recursion > kMaxRecursionDepth) { LOG(WARNING) << "Max recursion depth hit in ReadValue."; return false; } int type; if (!ReadParam(m, iter, &type)) return false; switch (type) { case Value::TYPE_NULL: *value = Value::CreateNullValue(); break; case Value::TYPE_BOOLEAN: { bool val; if (!ReadParam(m, iter, &val)) return false; *value = Value::CreateBooleanValue(val); break; } case Value::TYPE_INTEGER: { int val; if (!ReadParam(m, iter, &val)) return false; *value = Value::CreateIntegerValue(val); break; } case Value::TYPE_DOUBLE: { double val; if (!ReadParam(m, iter, &val)) return false; *value = Value::CreateDoubleValue(val); break; } case Value::TYPE_STRING: { std::string val; if (!ReadParam(m, iter, &val)) return false; *value = Value::CreateStringValue(val); break; } case Value::TYPE_BINARY: { const char* data; int length; if (!m->ReadData(iter, &data, &length)) return false; *value = base::BinaryValue::CreateWithCopiedBuffer(data, length); break; } case Value::TYPE_DICTIONARY: { scoped_ptr val(new DictionaryValue()); if (!ReadDictionaryValue(m, iter, val.get(), recursion)) return false; *value = val.release(); break; } case Value::TYPE_LIST: { scoped_ptr val(new ListValue()); if (!ReadListValue(m, iter, val.get(), recursion)) return false; *value = val.release(); break; } default: return false; } return true; } } // namespace // ----------------------------------------------------------------------------- LogData::LogData() : routing_id(0), type(0), sent(0), receive(0), dispatch(0) { } LogData::~LogData() { } MessageIterator::MessageIterator(const Message& m) : iter_(m) { } int MessageIterator::NextInt() const { int val = -1; if (!iter_.ReadInt(&val)) NOTREACHED(); return val; } const std::string MessageIterator::NextString() const { std::string val; if (!iter_.ReadString(&val)) NOTREACHED(); return val; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(p ? "true" : "false"); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(base::IntToString(p)); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(base::UintToString(p)); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(base::Int64ToString(static_cast(p))); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(base::Uint64ToString(static_cast(p))); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(base::Int64ToString(static_cast(p))); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(base::Uint64ToString(p)); } void ParamTraits::Write(Message* m, const param_type& p) { m->WriteBytes(&p, sizeof(param_type)); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { const char* data; if (!m->ReadBytes(iter, &data, sizeof(param_type))) return false; memcpy(r, data, sizeof(param_type)); return true; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(base::UintToString(p)); } void ParamTraits::Write(Message* m, const param_type& p) { m->WriteData(reinterpret_cast(&p), sizeof(param_type)); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { const char *data; int data_size; if (!m->ReadData(iter, &data, &data_size) || data_size != sizeof(param_type)) { NOTREACHED(); return false; } memcpy(r, data, sizeof(param_type)); return true; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(StringPrintf("%e", p)); } void ParamTraits::Write(Message* m, const param_type& p) { m->WriteData(reinterpret_cast(&p), sizeof(param_type)); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { const char *data; int data_size; if (!m->ReadData(iter, &data, &data_size) || data_size != sizeof(param_type)) { NOTREACHED(); return false; } memcpy(r, data, sizeof(param_type)); return true; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(StringPrintf("%e", p)); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(p); } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(WideToUTF8(p)); } #if !defined(WCHAR_T_IS_UTF16) void ParamTraits::Log(const param_type& p, std::string* l) { l->append(UTF16ToUTF8(p)); } #endif void ParamTraits >::Write(Message* m, const param_type& p) { if (p.empty()) { m->WriteData(NULL, 0); } else { m->WriteData(&p.front(), static_cast(p.size())); } } bool ParamTraits >::Read(const Message* m, PickleIterator* iter, param_type* r) { const char *data; int data_size = 0; if (!m->ReadData(iter, &data, &data_size) || data_size < 0) return false; r->resize(data_size); if (data_size) memcpy(&r->front(), data, data_size); return true; } void ParamTraits >::Log(const param_type& p, std::string* l) { LogBytes(p, l); } void ParamTraits >::Write(Message* m, const param_type& p) { if (p.empty()) { m->WriteData(NULL, 0); } else { m->WriteData(reinterpret_cast(&p.front()), static_cast(p.size())); } } bool ParamTraits >::Read(const Message* m, PickleIterator* iter, param_type* r) { const char *data; int data_size = 0; if (!m->ReadData(iter, &data, &data_size) || data_size < 0) return false; r->resize(data_size); if (data_size) memcpy(&r->front(), data, data_size); return true; } void ParamTraits >::Log(const param_type& p, std::string* l) { LogBytes(p, l); } void ParamTraits >::Write(Message* m, const param_type& p) { WriteParam(m, static_cast(p.size())); for (size_t i = 0; i < p.size(); i++) WriteParam(m, p[i]); } bool ParamTraits >::Read(const Message* m, PickleIterator* iter, param_type* r) { int size; // ReadLength() checks for < 0 itself. if (!m->ReadLength(iter, &size)) return false; r->resize(size); for (int i = 0; i < size; i++) { bool value; if (!ReadParam(m, iter, &value)) return false; (*r)[i] = value; } return true; } void ParamTraits >::Log(const param_type& p, std::string* l) { for (size_t i = 0; i < p.size(); ++i) { if (i != 0) l->push_back(' '); LogParam((p[i]), l); } } void ParamTraits::Write(Message* m, const param_type& p) { WriteValue(m, &p, 0); } bool ParamTraits::Read( const Message* m, PickleIterator* iter, param_type* r) { int type; if (!ReadParam(m, iter, &type) || type != Value::TYPE_DICTIONARY) return false; return ReadDictionaryValue(m, iter, r, 0); } void ParamTraits::Log(const param_type& p, std::string* l) { std::string json; base::JSONWriter::Write(&p, &json); l->append(json); } #if defined(OS_POSIX) void ParamTraits::Write(Message* m, const param_type& p) { const bool valid = p.fd >= 0; WriteParam(m, valid); if (valid) { if (!m->WriteFileDescriptor(p)) NOTREACHED(); } } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { bool valid; if (!ReadParam(m, iter, &valid)) return false; if (!valid) { r->fd = -1; r->auto_close = false; return true; } return m->ReadFileDescriptor(iter, r); } void ParamTraits::Log(const param_type& p, std::string* l) { if (p.auto_close) { l->append(StringPrintf("FD(%d auto-close)", p.fd)); } else { l->append(StringPrintf("FD(%d)", p.fd)); } } #endif // defined(OS_POSIX) void ParamTraits::Write(Message* m, const param_type& p) { ParamTraits::Write(m, p.value()); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { FilePath::StringType value; if (!ParamTraits::Read(m, iter, &value)) return false; *r = FilePath(value); return true; } void ParamTraits::Log(const param_type& p, std::string* l) { ParamTraits::Log(p.value(), l); } void ParamTraits::Write(Message* m, const param_type& p) { WriteValue(m, &p, 0); } bool ParamTraits::Read( const Message* m, PickleIterator* iter, param_type* r) { int type; if (!ReadParam(m, iter, &type) || type != Value::TYPE_LIST) return false; return ReadListValue(m, iter, r, 0); } void ParamTraits::Log(const param_type& p, std::string* l) { std::string json; base::JSONWriter::Write(&p, &json); l->append(json); } void ParamTraits::Write(Message* m, const param_type& p) { WriteParam(m, p.string()); WriteParam(m, p.is_null()); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { string16 string; if (!ReadParam(m, iter, &string)) return false; bool is_null; if (!ReadParam(m, iter, &is_null)) return false; *r = NullableString16(string, is_null); return true; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append("("); LogParam(p.string(), l); l->append(", "); LogParam(p.is_null(), l); l->append(")"); } void ParamTraits::Write(Message* m, const param_type& p) { WriteParam(m, p.size); WriteParam(m, p.is_directory); WriteParam(m, p.last_modified.ToDoubleT()); WriteParam(m, p.last_accessed.ToDoubleT()); WriteParam(m, p.creation_time.ToDoubleT()); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* p) { double last_modified; double last_accessed; double creation_time; bool result = ReadParam(m, iter, &p->size) && ReadParam(m, iter, &p->is_directory) && ReadParam(m, iter, &last_modified) && ReadParam(m, iter, &last_accessed) && ReadParam(m, iter, &creation_time); if (result) { p->last_modified = base::Time::FromDoubleT(last_modified); p->last_accessed = base::Time::FromDoubleT(last_accessed); p->creation_time = base::Time::FromDoubleT(creation_time); } return result; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append("("); LogParam(p.size, l); l->append(","); LogParam(p.is_directory, l); l->append(","); LogParam(p.last_modified.ToDoubleT(), l); l->append(","); LogParam(p.last_accessed.ToDoubleT(), l); l->append(","); LogParam(p.creation_time.ToDoubleT(), l); l->append(")"); } void ParamTraits::Write(Message* m, const param_type& p) { ParamTraits::Write(m, p.ToInternalValue()); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { int64 value; if (!ParamTraits::Read(m, iter, &value)) return false; *r = base::Time::FromInternalValue(value); return true; } void ParamTraits::Log(const param_type& p, std::string* l) { ParamTraits::Log(p.ToInternalValue(), l); } void ParamTraits::Write(Message* m, const param_type& p) { ParamTraits::Write(m, p.ToInternalValue()); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { int64 value; bool ret = ParamTraits::Read(m, iter, &value); if (ret) *r = base::TimeDelta::FromInternalValue(value); return ret; } void ParamTraits::Log(const param_type& p, std::string* l) { ParamTraits::Log(p.ToInternalValue(), l); } void ParamTraits::Write(Message* m, const param_type& p) { ParamTraits::Write(m, p.ToInternalValue()); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { int64 value; bool ret = ParamTraits::Read(m, iter, &value); if (ret) *r = base::TimeTicks::FromInternalValue(value); return ret; } void ParamTraits::Log(const param_type& p, std::string* l) { ParamTraits::Log(p.ToInternalValue(), l); } void ParamTraits::Write(Message* m, const param_type& p) { #if defined(OS_WIN) // On Windows marshalling pipe handle is not supported. DCHECK(p.pipe.handle == NULL); #endif // defined (OS_WIN) WriteParam(m, p.name); #if defined(OS_POSIX) WriteParam(m, p.socket); #endif } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { return ReadParam(m, iter, &r->name) #if defined(OS_POSIX) && ReadParam(m, iter, &r->socket) #endif ; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(StringPrintf("ChannelHandle(%s", p.name.c_str())); #if defined(OS_POSIX) l->append(", "); ParamTraits::Log(p.socket, l); #endif l->append(")"); } void ParamTraits::Write(Message* m, const param_type& p) { WriteParam(m, p.channel); WriteParam(m, p.routing_id); WriteParam(m, p.type); WriteParam(m, p.flags); WriteParam(m, p.sent); WriteParam(m, p.receive); WriteParam(m, p.dispatch); WriteParam(m, p.params); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { return ReadParam(m, iter, &r->channel) && ReadParam(m, iter, &r->routing_id) && ReadParam(m, iter, &r->type) && ReadParam(m, iter, &r->flags) && ReadParam(m, iter, &r->sent) && ReadParam(m, iter, &r->receive) && ReadParam(m, iter, &r->dispatch) && ReadParam(m, iter, &r->params); } void ParamTraits::Log(const param_type& p, std::string* l) { // Doesn't make sense to implement this! } void ParamTraits::Write(Message* m, const Message& p) { #if defined(OS_POSIX) // We don't serialize the file descriptors in the nested message, so there // better not be any. DCHECK(!p.HasFileDescriptors()); #endif // Don't just write out the message. This is used to send messages between // NaCl (Posix environment) and the browser (could be on Windows). The message // header formats differ between these systems (so does handle sharing, but // we already asserted we don't have any handles). So just write out the // parts of the header we use. // // Be careful also to use only explicitly-sized types. The NaCl environment // could be 64-bit and the host browser could be 32-bits. The nested message // may or may not be safe to send between 32-bit and 64-bit systems, but we // leave that up to the code sending the message to ensure. m->WriteUInt32(static_cast(p.routing_id())); m->WriteUInt32(p.type()); m->WriteUInt32(p.flags()); m->WriteData(p.payload(), static_cast(p.payload_size())); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, Message* r) { uint32 routing_id, type, flags; if (!m->ReadUInt32(iter, &routing_id) || !m->ReadUInt32(iter, &type) || !m->ReadUInt32(iter, &flags)) return false; int payload_size; const char* payload; if (!m->ReadData(iter, &payload, &payload_size)) return false; r->SetHeaderValues(static_cast(routing_id), type, flags); return r->WriteBytes(payload, payload_size); } void ParamTraits::Log(const Message& p, std::string* l) { l->append(""); } #if defined(OS_WIN) // Note that HWNDs/HANDLE/HCURSOR/HACCEL etc are always 32 bits, even on 64 // bit systems. void ParamTraits::Write(Message* m, const param_type& p) { m->WriteUInt32(reinterpret_cast(p)); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { uint32 temp; if (!m->ReadUInt32(iter, &temp)) return false; *r = reinterpret_cast(temp); return true; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(StringPrintf("0x%X", p)); } void ParamTraits::Write(Message* m, const param_type& p) { m->WriteData(reinterpret_cast(&p), sizeof(LOGFONT)); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { const char *data; int data_size = 0; bool result = m->ReadData(iter, &data, &data_size); if (result && data_size == sizeof(LOGFONT)) { memcpy(r, data, sizeof(LOGFONT)); } else { result = false; NOTREACHED(); } return result; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(StringPrintf("")); } void ParamTraits::Write(Message* m, const param_type& p) { m->WriteData(reinterpret_cast(&p), sizeof(MSG)); } bool ParamTraits::Read(const Message* m, PickleIterator* iter, param_type* r) { const char *data; int data_size = 0; bool result = m->ReadData(iter, &data, &data_size); if (result && data_size == sizeof(MSG)) { memcpy(r, data, sizeof(MSG)); } else { result = false; NOTREACHED(); } return result; } void ParamTraits::Log(const param_type& p, std::string* l) { l->append(""); } #endif // OS_WIN } // namespace IPC