Remove IPC::Endpoint.

ipc/ipc_channel_proxy.h

 // Copyright (c) 2012 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.
 
 #ifndef IPC_IPC_CHANNEL_PROXY_H_
 #define IPC_IPC_CHANNEL_PROXY_H_
 
 #include <stdint.h>
 
 #include <map>
 #include <memory>
 #include <string>
 #include <vector>
 
 #include "base/callback.h"
 #include "base/memory/ref_counted.h"
 #include "base/synchronization/lock.h"
 #include "base/threading/non_thread_safe.h"
 #include "build/build_config.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/ipc_channel_handle.h"
-#include "ipc/ipc_endpoint.h"
 #include "ipc/ipc_listener.h"
 #include "ipc/ipc_sender.h"
 #include "mojo/public/cpp/bindings/associated_group.h"
 #include "mojo/public/cpp/bindings/associated_interface_request.h"
 #include "mojo/public/cpp/bindings/scoped_interface_endpoint_handle.h"
 
 namespace base {
 class SingleThreadTaskRunner;
 }
 
@@ skipping 33 matching lines @@
 // instance where the IPC::Channel will be created and operated.
 //
 // Thread-safe send
 //
 // If a particular |Channel| implementation has a thread-safe |Send()| operation
 // then ChannelProxy skips the inter-thread hop and calls |Send()| directly. In
 // this case the |channel_| variable is touched by multiple threads so
 // |channel_lifetime_lock_| is used to protect it. The locking overhead is only
 // paid if the underlying channel supports thread-safe |Send|.
 //
-class IPC_EXPORT ChannelProxy : public Endpoint, public base::NonThreadSafe {
+class IPC_EXPORT ChannelProxy : public Sender, public base::NonThreadSafe {
  public:
 #if defined(ENABLE_IPC_FUZZER)
   // Interface for a filter to be imposed on outgoing messages which can
   // re-write the message. Used for testing.
   class OutgoingMessageFilter {
    public:
     virtual Message* Rewrite(Message* message) = 0;
   };
 #endif
 
@@ skipping 140 matching lines @@
 
 #if defined(ENABLE_IPC_FUZZER)
   void set_outgoing_message_filter(OutgoingMessageFilter* filter) {
     outgoing_message_filter_ = filter;
   }
 #endif
 
   // Called to clear the pointer to the IPC task runner when it's going away.
   void ClearIPCTaskRunner();
 
-  // Endpoint overrides.
-  base::ProcessId GetPeerPID() const override;
-  void OnSetAttachmentBrokerEndpoint() override;
-
  protected:
   class Context;
   // A subclass uses this constructor if it needs to add more information
   // to the internal state.
   explicit ChannelProxy(Context* context);
 
 
   // Used internally to hold state that is referenced on the IPC thread.
   class Context : public base::RefCountedThreadSafe<Context>,
                   public Listener {
@@ skipping 49 matching lines @@
     // more messages, so we honor that wish by forgetting them!
     virtual void Clear();
 
    private:
     friend class ChannelProxy;
     friend class IpcSecurityTestUtil;
 
     // Create the Channel
     void CreateChannel(std::unique_ptr<ChannelFactory> factory);
 
-    void set_attachment_broker_endpoint(bool is_endpoint) {
-      attachment_broker_endpoint_ = is_endpoint;
-      if (channel_)
-        channel_->SetAttachmentBrokerEndpoint(is_endpoint);
-    }
-
     // Methods called on the IO thread.
     void OnSendMessage(std::unique_ptr<Message> message_ptr);
     void OnAddFilter();
     void OnRemoveFilter(MessageFilter* filter);
 
     // Methods called on the listener thread.
     void AddFilter(MessageFilter* filter);
     void OnDispatchConnected();
     void OnDispatchError();
     void OnDispatchBadMessage(const Message& message);
@@ skipping 39 matching lines @@
     // IPC thread when they're added to filters_.
     std::vector<scoped_refptr<MessageFilter> > pending_filters_;
     // Lock for pending_filters_.
     base::Lock pending_filters_lock_;
 
     // Cached copy of the peer process ID. Set on IPC but read on both IPC and
     // listener threads.
     base::ProcessId peer_pid_;
     base::Lock peer_pid_lock_;
 
-    // Whether this channel is used as an endpoint for sending and receiving
-    // brokerable attachment messages to/from the broker process.
-    bool attachment_broker_endpoint_;
-
     mojo::AssociatedGroup associated_group_;
 
     // Holds associated interface binders added by AddGenericAssociatedInterface
     // or AddGenericAssociatedInterfaceForIOThread until the underlying channel
     // has been initialized.
     base::Lock pending_interfaces_lock_;
     std::vector<std::pair<std::string, GenericAssociatedInterfaceFactory>>
         pending_interfaces_;
   };
 
@@ skipping 32 matching lines @@
   bool did_init_;
 
 #if defined(ENABLE_IPC_FUZZER)
   OutgoingMessageFilter* outgoing_message_filter_;
 #endif
 };
 
 }  // namespace IPC
 
 #endif  // IPC_IPC_CHANNEL_PROXY_H_