OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 // P2PSocketDispatcher is a per-renderer object that dispatchers all | 5 // P2PSocketDispatcher is a per-renderer object that dispatchers all |
6 // P2P messages received from the browser and relays all P2P messages | 6 // P2P messages received from the browser and relays all P2P messages |
7 // sent to the browser. P2PSocketClient instances register themselves | 7 // sent to the browser. P2PSocketClient instances register themselves |
8 // with the dispatcher using RegisterClient() and UnregisterClient(). | 8 // with the dispatcher using RegisterClient() and UnregisterClient(). |
9 // | 9 // |
10 // Relationship of classes. | 10 // Relationship of classes. |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
67 | 67 |
68 private: | 68 private: |
69 friend class P2PAsyncAddressResolver; | 69 friend class P2PAsyncAddressResolver; |
70 friend class P2PSocketClientImpl; | 70 friend class P2PSocketClientImpl; |
71 | 71 |
72 // Send a message asynchronously. | 72 // Send a message asynchronously. |
73 virtual void Send(IPC::Message* message); | 73 virtual void Send(IPC::Message* message); |
74 | 74 |
75 // IPC::MessageFilter override. Called on IO thread. | 75 // IPC::MessageFilter override. Called on IO thread. |
76 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; | 76 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; |
77 virtual void OnFilterAdded(IPC::Channel* channel) OVERRIDE; | 77 virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE; |
78 virtual void OnFilterRemoved() OVERRIDE; | 78 virtual void OnFilterRemoved() OVERRIDE; |
79 virtual void OnChannelClosing() OVERRIDE; | 79 virtual void OnSenderClosing() OVERRIDE; |
80 | 80 |
81 // Returns the IO message loop. | 81 // Returns the IO message loop. |
82 base::MessageLoopProxy* message_loop(); | 82 base::MessageLoopProxy* message_loop(); |
83 | 83 |
84 // Called by P2PSocketClient. | 84 // Called by P2PSocketClient. |
85 int RegisterClient(P2PSocketClientImpl* client); | 85 int RegisterClient(P2PSocketClientImpl* client); |
86 void UnregisterClient(int id); | 86 void UnregisterClient(int id); |
87 void SendP2PMessage(IPC::Message* msg); | 87 void SendP2PMessage(IPC::Message* msg); |
88 | 88 |
89 // Called by DnsRequest. | 89 // Called by DnsRequest. |
(...skipping 16 matching lines...) Expand all Loading... |
106 | 106 |
107 scoped_refptr<base::MessageLoopProxy> message_loop_; | 107 scoped_refptr<base::MessageLoopProxy> message_loop_; |
108 IDMap<P2PSocketClientImpl> clients_; | 108 IDMap<P2PSocketClientImpl> clients_; |
109 | 109 |
110 IDMap<P2PAsyncAddressResolver> host_address_requests_; | 110 IDMap<P2PAsyncAddressResolver> host_address_requests_; |
111 | 111 |
112 bool network_notifications_started_; | 112 bool network_notifications_started_; |
113 scoped_refptr<ObserverListThreadSafe<NetworkListObserver> > | 113 scoped_refptr<ObserverListThreadSafe<NetworkListObserver> > |
114 network_list_observers_; | 114 network_list_observers_; |
115 | 115 |
116 IPC::Channel* channel_; | 116 IPC::Sender* sender_; |
117 | 117 |
118 DISALLOW_COPY_AND_ASSIGN(P2PSocketDispatcher); | 118 DISALLOW_COPY_AND_ASSIGN(P2PSocketDispatcher); |
119 }; | 119 }; |
120 | 120 |
121 } // namespace content | 121 } // namespace content |
122 | 122 |
123 #endif // CONTENT_RENDERER_P2P_SOCKET_DISPATCHER_H_ | 123 #endif // CONTENT_RENDERER_P2P_SOCKET_DISPATCHER_H_ |
OLD | NEW |