Open a firewall hole when a TCP server or UDP socket is bound.

extensions/browser/api/sockets_udp/sockets_udp_api.cc

 // Copyright 2014 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.
 
 #include "extensions/browser/api/sockets_udp/sockets_udp_api.h"
 
 #include "content/public/common/socket_permission_request.h"
 #include "extensions/browser/api/socket/udp_socket.h"
 #include "extensions/browser/api/sockets_udp/udp_socket_event_dispatcher.h"
 #include "extensions/common/api/sockets/sockets_manifest_data.h"
@@ skipping 167 matching lines @@
 
   socket_event_dispatcher_ = UDPSocketEventDispatcher::Get(browser_context());
   DCHECK(socket_event_dispatcher_)
       << "There is no socket event dispatcher. "
          "If this assertion is failing during a test, then it is likely that "
          "TestExtensionSystem is failing to provide an instance of "
          "UDPSocketEventDispatcher.";
   return socket_event_dispatcher_ != NULL;
 }
 
-void SocketsUdpBindFunction::Work() {
+void SocketsUdpBindFunction::AsyncWorkStart() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
+    AsyncWorkCompleted();
     return;
   }
 
   content::SocketPermissionRequest param(
       SocketPermissionRequest::UDP_BIND, params_->address, params_->port);
   if (!SocketsManifestData::CheckRequest(extension(), param)) {
     error_ = kPermissionError;
+    AsyncWorkCompleted();
     return;
   }
 
   int net_result = socket->Bind(params_->address, params_->port);
+  results_ = sockets_udp::Bind::Results::Create(net_result);
   if (net_result == net::OK) {
     socket_event_dispatcher_->OnSocketBind(extension_->id(),
                                            params_->socket_id);
+  } else {
+    error_ = net::ErrorToString(net_result);
+    AsyncWorkCompleted();
+    return;
   }
 
-  if (net_result != net::OK)
-    error_ = net::ErrorToString(net_result);
-  results_ = sockets_udp::Bind::Results::Create(net_result);
+  OpenFirewallHole(params_->address, params_->socket_id, socket);
 }
 
 SocketsUdpSendFunction::SocketsUdpSendFunction() : io_buffer_size_(0) {}
 
 SocketsUdpSendFunction::~SocketsUdpSendFunction() {}
 
 bool SocketsUdpSendFunction::Prepare() {
   params_ = sockets_udp::Send::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
   io_buffer_size_ = params_->data.size();
@@ skipping 275 matching lines @@
     error_ = kPermissionError;
     return;
   }
 
   const std::vector<std::string>& groups = socket->GetJoinedGroups();
   results_ = sockets_udp::GetJoinedGroups::Results::Create(groups);
 }
 
 }  // namespace core_api
 }  // namespace extensions