Index: third_party/mojo/src/mojo/edk/system/data_pipe_impl.cc |
diff --git a/third_party/mojo/src/mojo/edk/system/data_pipe_impl.cc b/third_party/mojo/src/mojo/edk/system/data_pipe_impl.cc |
index 6a4d070603268687193a15ecc1ea14239be892ea..74ba55abd02ee16d1bc1e786e8b1d1c238072313 100644 |
--- a/third_party/mojo/src/mojo/edk/system/data_pipe_impl.cc |
+++ b/third_party/mojo/src/mojo/edk/system/data_pipe_impl.cc |
@@ -35,7 +35,8 @@ void DataPipeImpl::ConvertDataToMessages(const char* buffer, |
// Note: |message_num_bytes| fits in a |uint32_t| since the capacity does. |
scoped_ptr<MessageInTransit> message(new MessageInTransit( |
- MessageInTransit::kTypeEndpoint, MessageInTransit::kSubtypeEndpointData, |
+ MessageInTransit::kTypeEndpointClient, |
+ MessageInTransit::kSubtypeEndpointClientData, |
static_cast<uint32_t>(message_num_bytes), buffer + *start_index)); |
message_queue->AddMessage(message.Pass()); |