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)); |