| Index: ppapi/proxy/dispatcher.cc
|
| ===================================================================
|
| --- ppapi/proxy/dispatcher.cc (revision 72517)
|
| +++ ppapi/proxy/dispatcher.cc (working copy)
|
| @@ -12,6 +12,7 @@
|
| #include "base/logging.h"
|
| #include "ipc/ipc_message.h"
|
| #include "ipc/ipc_sync_channel.h"
|
| +#include "ipc/ipc_test_sink.h"
|
| #include "ppapi/c/dev/ppb_buffer_dev.h"
|
| #include "ppapi/c/dev/ppb_char_set_dev.h"
|
| #include "ppapi/c/dev/ppb_cursor_control_dev.h"
|
| @@ -65,6 +66,7 @@
|
| GetInterfaceFunc local_get_interface)
|
| : pp_module_(0),
|
| remote_process_handle_(remote_process_handle),
|
| + test_sink_(NULL),
|
| disallow_trusted_interfaces_(false), // TODO(brettw) make this settable.
|
| local_get_interface_(local_get_interface),
|
| declared_supported_remote_interfaces_(false),
|
| @@ -87,6 +89,11 @@
|
| return true;
|
| }
|
|
|
| +void Dispatcher::InitWithTestSink(IPC::TestSink* test_sink) {
|
| + DCHECK(!test_sink_);
|
| + test_sink_ = test_sink;
|
| +}
|
| +
|
| bool Dispatcher::OnMessageReceived(const IPC::Message& msg) {
|
| // Control messages.
|
| if (msg.routing_id() == MSG_ROUTING_CONTROL) {
|
| @@ -157,6 +164,8 @@
|
| }
|
|
|
| bool Dispatcher::Send(IPC::Message* msg) {
|
| + if (test_sink_)
|
| + return test_sink_->Send(msg);
|
| return channel_->Send(msg);
|
| }
|
|
|
|
|