| Index: third_party/mojo/src/mojo/edk/system/dispatcher.cc
|
| diff --git a/third_party/mojo/src/mojo/edk/system/dispatcher.cc b/third_party/mojo/src/mojo/edk/system/dispatcher.cc
|
| index e2f2b8784f4684c9d1c074e1a7aae65e8c6ccd66..e8695e8eff1a71f567253986a74fb707cb714768 100644
|
| --- a/third_party/mojo/src/mojo/edk/system/dispatcher.cc
|
| +++ b/third_party/mojo/src/mojo/edk/system/dispatcher.cc
|
| @@ -6,6 +6,8 @@
|
|
|
| #include "base/logging.h"
|
| #include "mojo/edk/system/configuration.h"
|
| +#include "mojo/edk/system/data_pipe_consumer_dispatcher.h"
|
| +#include "mojo/edk/system/data_pipe_producer_dispatcher.h"
|
| #include "mojo/edk/system/message_pipe_dispatcher.h"
|
| #include "mojo/edk/system/platform_handle_dispatcher.h"
|
| #include "mojo/edk/system/shared_buffer_dispatcher.h"
|
| @@ -77,11 +79,11 @@ scoped_refptr<Dispatcher> Dispatcher::TransportDataAccess::Deserialize(
|
| return scoped_refptr<Dispatcher>(
|
| MessagePipeDispatcher::Deserialize(channel, source, size));
|
| case kTypeDataPipeProducer:
|
| + return scoped_refptr<Dispatcher>(
|
| + DataPipeProducerDispatcher::Deserialize(channel, source, size));
|
| case kTypeDataPipeConsumer:
|
| - // TODO(vtl): Implement.
|
| - LOG(WARNING) << "Deserialization of dispatcher type " << type
|
| - << " not supported";
|
| - return nullptr;
|
| + return scoped_refptr<Dispatcher>(
|
| + DataPipeConsumerDispatcher::Deserialize(channel, source, size));
|
| case kTypeSharedBuffer:
|
| return scoped_refptr<Dispatcher>(SharedBufferDispatcher::Deserialize(
|
| channel, source, size, platform_handles));
|
|
|