Remove IPC::Endpoint.

ipc/ipc_message_pipe_reader.cc

 // Copyright 2014 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_pipe_reader.h"
 
 #include <stdint.h>
 
 #include <utility>
 
@@ skipping 67 matching lines @@
     const std::string& name,
     mojo::ScopedInterfaceEndpointHandle handle) {
   if (!sender_.is_bound())
     return;
   mojom::GenericInterfaceAssociatedRequest request;
   request.Bind(std::move(handle));
   sender_->GetAssociatedInterface(name, std::move(request));
 }
 
 void MessagePipeReader::SetPeerPid(int32_t peer_pid) {
-  peer_pid_ = peer_pid;
-  delegate_->OnPeerPidReceived();
+  delegate_->OnPeerPidReceived(peer_pid);
 }
 
 void MessagePipeReader::Receive(
     const std::vector<uint8_t>& data,
     base::Optional<std::vector<mojom::SerializedHandlePtr>> handles) {
-  DCHECK_NE(peer_pid_, base::kNullProcessId);
   Message message(
       data.empty() ? "" : reinterpret_cast<const char*>(data.data()),
       static_cast<uint32_t>(data.size()));
-  message.set_sender_pid(peer_pid_);
 
   DVLOG(4) << "Receive " << message.type() << ": " << message.size();
   MojoResult write_result =
       ChannelMojo::WriteToMessageAttachmentSet(std::move(handles), &message);
   if (write_result != MOJO_RESULT_OK) {
     OnPipeError(write_result);
     return;
   }
 
   TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"),
@@ skipping 16 matching lines @@
 
   Close();
 
   // NOTE: The delegate call below may delete |this|.
   if (delegate_)
     delegate_->OnPipeError();
 }
 
 }  // namespace internal
 }  // namespace IPC