OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 #include "content/browser/renderer_host/p2p/socket_dispatcher_host.h" | 5 #include "content/browser/renderer_host/p2p/socket_dispatcher_host.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
9 #include "content/browser/renderer_host/p2p/socket_host.h" | 9 #include "content/browser/renderer_host/p2p/socket_host.h" |
10 #include "content/public/browser/resource_context.h" | 10 #include "content/public/browser/resource_context.h" |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
99 | 99 |
100 DoneCallback done_callback_; | 100 DoneCallback done_callback_; |
101 }; | 101 }; |
102 | 102 |
103 P2PSocketDispatcherHost::P2PSocketDispatcherHost( | 103 P2PSocketDispatcherHost::P2PSocketDispatcherHost( |
104 content::ResourceContext* resource_context) | 104 content::ResourceContext* resource_context) |
105 : resource_context_(resource_context), | 105 : resource_context_(resource_context), |
106 monitoring_networks_(false) { | 106 monitoring_networks_(false) { |
107 } | 107 } |
108 | 108 |
109 P2PSocketDispatcherHost::~P2PSocketDispatcherHost() { | |
110 DCHECK(sockets_.empty()); | |
111 DCHECK(dns_requests_.empty()); | |
112 | |
113 if (monitoring_networks_) | |
114 net::NetworkChangeNotifier::RemoveIPAddressObserver(this); | |
115 } | |
116 | |
117 void P2PSocketDispatcherHost::OnChannelClosing() { | 109 void P2PSocketDispatcherHost::OnChannelClosing() { |
118 BrowserMessageFilter::OnChannelClosing(); | 110 BrowserMessageFilter::OnChannelClosing(); |
119 | 111 |
120 // Since the IPC channel is gone, close pending connections. | 112 // Since the IPC channel is gone, close pending connections. |
121 STLDeleteContainerPairSecondPointers(sockets_.begin(), sockets_.end()); | 113 STLDeleteContainerPairSecondPointers(sockets_.begin(), sockets_.end()); |
122 sockets_.clear(); | 114 sockets_.clear(); |
123 | 115 |
124 STLDeleteContainerPointers(dns_requests_.begin(), dns_requests_.end()); | 116 STLDeleteContainerPointers(dns_requests_.begin(), dns_requests_.end()); |
125 dns_requests_.clear(); | 117 dns_requests_.clear(); |
126 } | 118 } |
(...skipping 14 matching lines...) Expand all Loading... |
141 IPC_MESSAGE_HANDLER(P2PHostMsg_CreateSocket, OnCreateSocket) | 133 IPC_MESSAGE_HANDLER(P2PHostMsg_CreateSocket, OnCreateSocket) |
142 IPC_MESSAGE_HANDLER(P2PHostMsg_AcceptIncomingTcpConnection, | 134 IPC_MESSAGE_HANDLER(P2PHostMsg_AcceptIncomingTcpConnection, |
143 OnAcceptIncomingTcpConnection) | 135 OnAcceptIncomingTcpConnection) |
144 IPC_MESSAGE_HANDLER(P2PHostMsg_Send, OnSend) | 136 IPC_MESSAGE_HANDLER(P2PHostMsg_Send, OnSend) |
145 IPC_MESSAGE_HANDLER(P2PHostMsg_DestroySocket, OnDestroySocket) | 137 IPC_MESSAGE_HANDLER(P2PHostMsg_DestroySocket, OnDestroySocket) |
146 IPC_MESSAGE_UNHANDLED(handled = false) | 138 IPC_MESSAGE_UNHANDLED(handled = false) |
147 IPC_END_MESSAGE_MAP_EX() | 139 IPC_END_MESSAGE_MAP_EX() |
148 return handled; | 140 return handled; |
149 } | 141 } |
150 | 142 |
| 143 void P2PSocketDispatcherHost::OnIPAddressChanged() { |
| 144 // Notify the renderer about changes to list of network interfaces. |
| 145 BrowserThread::PostTask( |
| 146 BrowserThread::FILE, FROM_HERE, base::Bind( |
| 147 &P2PSocketDispatcherHost::DoGetNetworkList, this)); |
| 148 } |
| 149 |
| 150 P2PSocketDispatcherHost::~P2PSocketDispatcherHost() { |
| 151 DCHECK(sockets_.empty()); |
| 152 DCHECK(dns_requests_.empty()); |
| 153 |
| 154 if (monitoring_networks_) |
| 155 net::NetworkChangeNotifier::RemoveIPAddressObserver(this); |
| 156 } |
| 157 |
151 P2PSocketHost* P2PSocketDispatcherHost::LookupSocket( | 158 P2PSocketHost* P2PSocketDispatcherHost::LookupSocket( |
152 int32 routing_id, int socket_id) { | 159 int32 routing_id, int socket_id) { |
153 SocketsMap::iterator it = sockets_.find( | 160 SocketsMap::iterator it = sockets_.find( |
154 ExtendedSocketId(routing_id, socket_id)); | 161 ExtendedSocketId(routing_id, socket_id)); |
155 if (it == sockets_.end()) | 162 if (it == sockets_.end()) |
156 return NULL; | 163 return NULL; |
157 else | 164 else |
158 return it->second; | 165 return it->second; |
159 } | 166 } |
160 | 167 |
161 void P2PSocketDispatcherHost::OnStartNetworkNotifications( | 168 void P2PSocketDispatcherHost::OnStartNetworkNotifications( |
162 const IPC::Message& msg) { | 169 const IPC::Message& msg) { |
163 if (!monitoring_networks_) { | 170 if (!monitoring_networks_) { |
164 net::NetworkChangeNotifier::AddIPAddressObserver(this); | 171 net::NetworkChangeNotifier::AddIPAddressObserver(this); |
165 monitoring_networks_ = true; | 172 monitoring_networks_ = true; |
166 } | 173 } |
167 | 174 |
168 notifications_routing_ids_.insert(msg.routing_id()); | 175 notifications_routing_ids_.insert(msg.routing_id()); |
169 | 176 |
170 BrowserThread::PostTask( | 177 BrowserThread::PostTask( |
171 BrowserThread::FILE, FROM_HERE, base::Bind( | 178 BrowserThread::FILE, FROM_HERE, base::Bind( |
172 &P2PSocketDispatcherHost::DoGetNetworkList, this)); | 179 &P2PSocketDispatcherHost::DoGetNetworkList, this)); |
173 } | 180 } |
174 | 181 |
175 void P2PSocketDispatcherHost::OnStopNetworkNotifications( | 182 void P2PSocketDispatcherHost::OnStopNetworkNotifications( |
176 const IPC::Message& msg) { | 183 const IPC::Message& msg) { |
177 notifications_routing_ids_.erase(msg.routing_id()); | 184 notifications_routing_ids_.erase(msg.routing_id()); |
178 } | 185 } |
179 | 186 |
180 void P2PSocketDispatcherHost::OnIPAddressChanged() { | |
181 // Notify the renderer about changes to list of network interfaces. | |
182 BrowserThread::PostTask( | |
183 BrowserThread::FILE, FROM_HERE, base::Bind( | |
184 &P2PSocketDispatcherHost::DoGetNetworkList, this)); | |
185 } | |
186 | |
187 void P2PSocketDispatcherHost::DoGetNetworkList() { | |
188 net::NetworkInterfaceList list; | |
189 net::GetNetworkList(&list); | |
190 BrowserThread::PostTask( | |
191 BrowserThread::IO, FROM_HERE, base::Bind( | |
192 &P2PSocketDispatcherHost::SendNetworkList, this, list)); | |
193 } | |
194 | |
195 void P2PSocketDispatcherHost::SendNetworkList( | |
196 const net::NetworkInterfaceList& list) { | |
197 for (std::set<int>::iterator it = notifications_routing_ids_.begin(); | |
198 it != notifications_routing_ids_.end(); ++it) { | |
199 Send(new P2PMsg_NetworkListChanged(*it, list)); | |
200 } | |
201 } | |
202 | |
203 void P2PSocketDispatcherHost::OnGetHostAddress(const IPC::Message& msg, | 187 void P2PSocketDispatcherHost::OnGetHostAddress(const IPC::Message& msg, |
204 const std::string& host_name, | 188 const std::string& host_name, |
205 int32 request_id) { | 189 int32 request_id) { |
206 DnsRequest* request = new DnsRequest( | 190 DnsRequest* request = new DnsRequest( |
207 msg.routing_id(), request_id, resource_context_->GetHostResolver()); | 191 msg.routing_id(), request_id, resource_context_->GetHostResolver()); |
208 dns_requests_.insert(request); | 192 dns_requests_.insert(request); |
209 request->Resolve(host_name, base::Bind( | 193 request->Resolve(host_name, base::Bind( |
210 &P2PSocketDispatcherHost::OnAddressResolved, | 194 &P2PSocketDispatcherHost::OnAddressResolved, |
211 base::Unretained(this), request)); | 195 base::Unretained(this), request)); |
212 } | 196 } |
213 | 197 |
214 void P2PSocketDispatcherHost::OnAddressResolved( | |
215 DnsRequest* request, | |
216 const net::IPAddressNumber& result) { | |
217 Send(new P2PMsg_GetHostAddressResult( | |
218 request->routing_id(), request->request_id(), result)); | |
219 | |
220 dns_requests_.erase(request); | |
221 delete request; | |
222 } | |
223 | |
224 void P2PSocketDispatcherHost::OnCreateSocket( | 198 void P2PSocketDispatcherHost::OnCreateSocket( |
225 const IPC::Message& msg, P2PSocketType type, int socket_id, | 199 const IPC::Message& msg, P2PSocketType type, int socket_id, |
226 const net::IPEndPoint& local_address, | 200 const net::IPEndPoint& local_address, |
227 const net::IPEndPoint& remote_address) { | 201 const net::IPEndPoint& remote_address) { |
228 if (LookupSocket(msg.routing_id(), socket_id)) { | 202 if (LookupSocket(msg.routing_id(), socket_id)) { |
229 LOG(ERROR) << "Received P2PHostMsg_CreateSocket for socket " | 203 LOG(ERROR) << "Received P2PHostMsg_CreateSocket for socket " |
230 "that already exists."; | 204 "that already exists."; |
231 return; | 205 return; |
232 } | 206 } |
233 | 207 |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
279 SocketsMap::iterator it = sockets_.find( | 253 SocketsMap::iterator it = sockets_.find( |
280 ExtendedSocketId(msg.routing_id(), socket_id)); | 254 ExtendedSocketId(msg.routing_id(), socket_id)); |
281 if (it != sockets_.end()) { | 255 if (it != sockets_.end()) { |
282 delete it->second; | 256 delete it->second; |
283 sockets_.erase(it); | 257 sockets_.erase(it); |
284 } else { | 258 } else { |
285 LOG(ERROR) << "Received P2PHostMsg_DestroySocket for invalid socket_id."; | 259 LOG(ERROR) << "Received P2PHostMsg_DestroySocket for invalid socket_id."; |
286 } | 260 } |
287 } | 261 } |
288 | 262 |
| 263 void P2PSocketDispatcherHost::DoGetNetworkList() { |
| 264 net::NetworkInterfaceList list; |
| 265 net::GetNetworkList(&list); |
| 266 BrowserThread::PostTask( |
| 267 BrowserThread::IO, FROM_HERE, base::Bind( |
| 268 &P2PSocketDispatcherHost::SendNetworkList, this, list)); |
| 269 } |
| 270 |
| 271 void P2PSocketDispatcherHost::SendNetworkList( |
| 272 const net::NetworkInterfaceList& list) { |
| 273 for (std::set<int>::iterator it = notifications_routing_ids_.begin(); |
| 274 it != notifications_routing_ids_.end(); ++it) { |
| 275 Send(new P2PMsg_NetworkListChanged(*it, list)); |
| 276 } |
| 277 } |
| 278 |
| 279 void P2PSocketDispatcherHost::OnAddressResolved( |
| 280 DnsRequest* request, |
| 281 const net::IPAddressNumber& result) { |
| 282 Send(new P2PMsg_GetHostAddressResult( |
| 283 request->routing_id(), request->request_id(), result)); |
| 284 |
| 285 dns_requests_.erase(request); |
| 286 delete request; |
| 287 } |
| 288 |
289 } // namespace content | 289 } // namespace content |
OLD | NEW |