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 #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 <stddef.h> | 7 #include <stddef.h> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
11 #include "content/browser/renderer_host/p2p/socket_host.h" | 11 #include "content/browser/renderer_host/p2p/socket_host.h" |
12 #include "content/common/p2p_messages.h" | 12 #include "content/common/p2p_messages.h" |
13 #include "content/public/browser/browser_thread.h" | 13 #include "content/public/browser/browser_thread.h" |
14 #include "content/public/browser/resource_context.h" | 14 #include "content/public/browser/resource_context.h" |
15 #include "net/base/address_list.h" | 15 #include "net/base/address_list.h" |
16 #include "net/base/completion_callback.h" | 16 #include "net/base/completion_callback.h" |
17 #include "net/base/ip_address_number.h" | |
18 #include "net/base/net_errors.h" | 17 #include "net/base/net_errors.h" |
19 #include "net/base/network_interfaces.h" | 18 #include "net/base/network_interfaces.h" |
20 #include "net/base/sys_addrinfo.h" | 19 #include "net/base/sys_addrinfo.h" |
21 #include "net/dns/single_request_host_resolver.h" | 20 #include "net/dns/single_request_host_resolver.h" |
22 #include "net/log/net_log.h" | 21 #include "net/log/net_log.h" |
23 #include "net/socket/client_socket_factory.h" | 22 #include "net/socket/client_socket_factory.h" |
24 #include "net/udp/datagram_client_socket.h" | 23 #include "net/udp/datagram_client_socket.h" |
25 #include "net/url_request/url_request_context_getter.h" | 24 #include "net/url_request/url_request_context_getter.h" |
26 | 25 |
27 using content::BrowserMessageFilter; | 26 using content::BrowserMessageFilter; |
(...skipping 311 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
339 default_ipv4_local_address_ = GetDefaultLocalAddress(AF_INET); | 338 default_ipv4_local_address_ = GetDefaultLocalAddress(AF_INET); |
340 default_ipv6_local_address_ = GetDefaultLocalAddress(AF_INET6); | 339 default_ipv6_local_address_ = GetDefaultLocalAddress(AF_INET6); |
341 BrowserThread::PostTask( | 340 BrowserThread::PostTask( |
342 BrowserThread::IO, FROM_HERE, | 341 BrowserThread::IO, FROM_HERE, |
343 base::Bind(&P2PSocketDispatcherHost::SendNetworkList, this, list, | 342 base::Bind(&P2PSocketDispatcherHost::SendNetworkList, this, list, |
344 default_ipv4_local_address_, default_ipv6_local_address_)); | 343 default_ipv4_local_address_, default_ipv6_local_address_)); |
345 } | 344 } |
346 | 345 |
347 void P2PSocketDispatcherHost::SendNetworkList( | 346 void P2PSocketDispatcherHost::SendNetworkList( |
348 const net::NetworkInterfaceList& list, | 347 const net::NetworkInterfaceList& list, |
349 const net::IPAddressNumber& default_ipv4_local_address, | 348 const net::IPAddress& default_ipv4_local_address, |
350 const net::IPAddressNumber& default_ipv6_local_address) { | 349 const net::IPAddress& default_ipv6_local_address) { |
351 Send(new P2PMsg_NetworkListChanged(list, default_ipv4_local_address, | 350 Send(new P2PMsg_NetworkListChanged(list, default_ipv4_local_address, |
352 default_ipv6_local_address)); | 351 default_ipv6_local_address)); |
353 } | 352 } |
354 | 353 |
355 net::IPAddressNumber P2PSocketDispatcherHost::GetDefaultLocalAddress( | 354 net::IPAddress P2PSocketDispatcherHost::GetDefaultLocalAddress(int family) { |
356 int family) { | |
357 DCHECK(family == AF_INET || family == AF_INET6); | 355 DCHECK(family == AF_INET || family == AF_INET6); |
358 | 356 |
359 // Creation and connection of a UDP socket might be janky. | 357 // Creation and connection of a UDP socket might be janky. |
360 DCHECK_CURRENTLY_ON(BrowserThread::FILE); | 358 DCHECK_CURRENTLY_ON(BrowserThread::FILE); |
361 | 359 |
362 scoped_ptr<net::DatagramClientSocket> socket( | 360 scoped_ptr<net::DatagramClientSocket> socket( |
363 net::ClientSocketFactory::GetDefaultFactory()->CreateDatagramClientSocket( | 361 net::ClientSocketFactory::GetDefaultFactory()->CreateDatagramClientSocket( |
364 net::DatagramSocket::DEFAULT_BIND, net::RandIntCallback(), NULL, | 362 net::DatagramSocket::DEFAULT_BIND, net::RandIntCallback(), NULL, |
365 net::NetLog::Source())); | 363 net::NetLog::Source())); |
366 | 364 |
367 net::IPAddressNumber ip_address_number; | 365 net::IPAddress ip_address; |
368 if (family == AF_INET) { | 366 if (family == AF_INET) { |
369 ip_address_number.assign(kPublicIPv4Host, | 367 ip_address = net::IPAddress(kPublicIPv4Host); |
370 kPublicIPv4Host + net::kIPv4AddressSize); | |
371 } else { | 368 } else { |
372 ip_address_number.assign(kPublicIPv6Host, | 369 ip_address = net::IPAddress(kPublicIPv6Host); |
373 kPublicIPv6Host + net::kIPv6AddressSize); | |
374 } | 370 } |
375 | 371 |
376 if (socket->Connect(net::IPEndPoint(ip_address_number, kPublicPort)) != | 372 if (socket->Connect(net::IPEndPoint(ip_address, kPublicPort)) != net::OK) { |
377 net::OK) { | 373 return net::IPAddress(); |
378 return net::IPAddressNumber(); | |
379 } | 374 } |
380 | 375 |
381 net::IPEndPoint local_address; | 376 net::IPEndPoint local_address; |
382 if (socket->GetLocalAddress(&local_address) != net::OK) | 377 if (socket->GetLocalAddress(&local_address) != net::OK) |
383 return net::IPAddressNumber(); | 378 return net::IPAddress(); |
384 | 379 |
385 return local_address.address().bytes(); | 380 return local_address.address(); |
386 } | 381 } |
387 | 382 |
388 void P2PSocketDispatcherHost::OnAddressResolved( | 383 void P2PSocketDispatcherHost::OnAddressResolved( |
389 DnsRequest* request, | 384 DnsRequest* request, |
390 const net::IPAddressList& addresses) { | 385 const net::IPAddressList& addresses) { |
391 Send(new P2PMsg_GetHostAddressResult(request->request_id(), addresses)); | 386 Send(new P2PMsg_GetHostAddressResult(request->request_id(), addresses)); |
392 | 387 |
393 dns_requests_.erase(request); | 388 dns_requests_.erase(request); |
394 delete request; | 389 delete request; |
395 } | 390 } |
(...skipping 10 matching lines...) Expand all Loading... |
406 | 401 |
407 if (!dump_incoming_rtp_packet_ && !dump_outgoing_rtp_packet_) | 402 if (!dump_incoming_rtp_packet_ && !dump_outgoing_rtp_packet_) |
408 packet_callback_.Reset(); | 403 packet_callback_.Reset(); |
409 | 404 |
410 for (SocketsMap::iterator it = sockets_.begin(); it != sockets_.end(); ++it) | 405 for (SocketsMap::iterator it = sockets_.begin(); it != sockets_.end(); ++it) |
411 it->second->StopRtpDump(incoming, outgoing); | 406 it->second->StopRtpDump(incoming, outgoing); |
412 } | 407 } |
413 } | 408 } |
414 | 409 |
415 } // namespace content | 410 } // namespace content |
OLD | NEW |