Chromium Code Reviews| Index: content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc |
| diff --git a/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc b/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc |
| index aa63ab16308c0460405505cc639b591e355ec426..e2690adb644dc1eb48ae63dbebe183f71c96fbfe 100644 |
| --- a/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc |
| +++ b/content/browser/renderer_host/pepper/pepper_tcp_socket_message_filter.cc |
| @@ -36,6 +36,10 @@ |
| #include "ppapi/proxy/tcp_socket_resource_base.h" |
| #include "ppapi/shared_impl/private/net_address_private_impl.h" |
| +#if defined(OS_CHROMEOS) |
| +#include "chromeos/network/firewall_hole.h" |
| +#endif // defined(OS_CHROMEOS) |
| + |
| using ppapi::NetAddressPrivateImpl; |
| using ppapi::host::NetErrorToPepperError; |
| using ppapi::proxy::TCPSocketResourceBase; |
| @@ -470,6 +474,10 @@ int32_t PepperTCPSocketMessageFilter::OnMsgClose( |
| return PP_OK; |
| state_.DoTransition(TCPSocketState::CLOSE, true); |
| +#if defined(OS_CHROMEOS) |
| + // Close the firewall hole, it is no longer needed. |
| + firewall_hole_.reset(nullptr); |
|
bbudge
2015/07/22 02:00:48
nit: can just reset() with no param.
avallee
2015/07/24 18:33:00
Done.
|
| +#endif // defined(OS_CHROMEOS) |
| // Make sure we get no further callbacks from |socket_| or |ssl_socket_|. |
| if (socket_) { |
| socket_->Close(); |
| @@ -713,8 +721,11 @@ void PepperTCPSocketMessageFilter::DoListen( |
| } |
| int32_t pp_result = NetErrorToPepperError(socket_->Listen(backlog)); |
| - SendListenReply(context, pp_result); |
| - state_.DoTransition(TCPSocketState::LISTEN, pp_result == PP_OK); |
| +#if defined(OS_CHROMEOS) |
| + OpenFirewallHole(context, pp_result); |
| +#else |
| + OnListenCompleted(context, pp_result); |
| +#endif |
| } |
| void PepperTCPSocketMessageFilter::OnResolveCompleted( |
| @@ -926,6 +937,47 @@ void PepperTCPSocketMessageFilter::OnWriteCompleted( |
| write_buffer_base_ = NULL; |
| } |
| +void PepperTCPSocketMessageFilter::OnListenCompleted( |
| + const ppapi::host::ReplyMessageContext& context, |
| + int32_t pp_result) { |
| + DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| + SendListenReply(context, pp_result); |
| + state_.DoTransition(TCPSocketState::LISTEN, pp_result == PP_OK); |
| +} |
| + |
| +#if defined(OS_CHROMEOS) |
| +void PepperTCPSocketMessageFilter::OpenFirewallHole( |
| + const ppapi::host::ReplyMessageContext& context, |
| + int32_t pp_result) { |
| + if (pp_result != PP_OK) { |
| + return; |
| + } |
| + |
| + net::IPEndPoint local_addr; |
| + // Has already been called successfully in DoBind(). |
| + socket_->GetLocalAddress(&local_addr); |
| + pepper_socket_utils::FirewallHoleOpenCallback callback = |
| + base::Bind(&PepperTCPSocketMessageFilter::OnFirewallHoleOpened, |
| + base::Unretained(this), context, pp_result); |
|
bbudge
2015/07/22 02:00:48
Why base::Unretained(this) instead of just 'this'?
avallee
2015/07/24 18:33:00
Was copying the other code in this file. Removed s
|
| + BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, |
| + base::Bind(&pepper_socket_utils::OpenTCPFirewallHole, |
| + local_addr, callback)); |
| +} |
| + |
| +void PepperTCPSocketMessageFilter::OnFirewallHoleOpened( |
| + const ppapi::host::ReplyMessageContext& context, |
| + int32_t result, |
| + scoped_ptr<chromeos::FirewallHole> hole) { |
| + LOG_IF(WARNING, !hole.get()) << "Firewall hole could not be opened."; |
| + firewall_hole_.reset(hole.release()); |
| + |
| + BrowserThread::PostTask( |
| + BrowserThread::IO, FROM_HERE, |
| + base::Bind(&PepperTCPSocketMessageFilter::OnListenCompleted, |
| + base::Unretained(this), context, result)); |
| +} |
| +#endif // defined(OS_CHROMEOS) |
| + |
| void PepperTCPSocketMessageFilter::OnAcceptCompleted( |
| const ppapi::host::ReplyMessageContext& context, |
| int net_result) { |