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

extensions/browser/api/sockets_tcp_server/sockets_tcp_server_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_tcp_server/sockets_tcp_server_api.h"
 
 #include "content/public/common/socket_permission_request.h"
 #include "extensions/browser/api/socket/tcp_socket.h"
 #include "extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.h"
 #include "extensions/common/api/sockets/sockets_manifest_data.h"
@@ skipping 158 matching lines @@
   socket_event_dispatcher_ =
       TCPServerSocketEventDispatcher::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 "
          "TCPServerSocketEventDispatcher.";
   return socket_event_dispatcher_ != NULL;
 }
 
-void SocketsTcpServerListenFunction::Work() {
+void SocketsTcpServerListenFunction::AsyncWorkStart() {
   ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
+    AsyncWorkCompleted();
     return;
   }
 
   SocketPermissionRequest param(
       SocketPermissionRequest::TCP_LISTEN, params_->address, params_->port);
   if (!SocketsManifestData::CheckRequest(extension(), param)) {
     error_ = kPermissionError;
+    AsyncWorkCompleted();
     return;
   }
 
   int net_result = socket->Listen(
       params_->address,
       params_->port,
       params_->backlog.get() ? *params_->backlog.get() : kDefaultListenBacklog,
       &error_);
-
-  if (net_result != net::OK)
-    error_ = net::ErrorToString(net_result);
-
+  results_ = sockets_tcp_server::Listen::Results::Create(net_result);
   if (net_result == net::OK) {
     socket_event_dispatcher_->OnServerSocketListen(extension_->id(),
                                                    params_->socket_id);
+  } else {
+    error_ = net::ErrorToString(net_result);
+    AsyncWorkCompleted();
+    return;
   }
 
-  results_ = sockets_tcp_server::Listen::Results::Create(net_result);
+  OpenFirewallHole(params_->address, params_->socket_id, socket);
 }
 
 SocketsTcpServerDisconnectFunction::SocketsTcpServerDisconnectFunction() {}
 
 SocketsTcpServerDisconnectFunction::~SocketsTcpServerDisconnectFunction() {}
 
 bool SocketsTcpServerDisconnectFunction::Prepare() {
   params_ = sockets_tcp_server::Disconnect::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
   return true;
@@ skipping 71 matching lines @@
       if (socket) {
         socket_infos.push_back(CreateSocketInfo(socket_id, socket));
       }
     }
   }
   results_ = sockets_tcp_server::GetSockets::Results::Create(socket_infos);
 }
 
 }  // namespace core_api
 }  // namespace extensions