Move sockets APIs out of src/chrome

extensions/browser/api/sockets_udp/sockets_udp_api.cc

 // Copyright 2013 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 "chrome/browser/extensions/api/sockets_udp/sockets_udp_api.h"
+#include "extensions/browser/api/sockets_udp/sockets_udp_api.h"
 
-#include "chrome/browser/extensions/api/socket/udp_socket.h"
-#include "chrome/browser/extensions/api/sockets_udp/udp_socket_event_dispatcher.h"
 #include "chrome/common/extensions/api/sockets/sockets_manifest_data.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 "net/base/net_errors.h"
 
 namespace extensions {
-namespace api {
+namespace core_api {
 
 using content::SocketPermissionRequest;
 
 const char kSocketNotFoundError[] = "Socket not found";
 const char kPermissionError[] = "App does not have permission";
 const char kWildcardAddress[] = "*";
 const int kWildcardPort = 0;
 
 UDPSocketAsyncApiFunction::~UDPSocketAsyncApiFunction() {}
 
 scoped_ptr<SocketResourceManagerInterface>
-    UDPSocketAsyncApiFunction::CreateSocketResourceManager() {
+UDPSocketAsyncApiFunction::CreateSocketResourceManager() {
   return scoped_ptr<SocketResourceManagerInterface>(
-      new SocketResourceManager<ResumableUDPSocket>()).Pass();
+             new SocketResourceManager<ResumableUDPSocket>()).Pass();
 }
 
 ResumableUDPSocket* UDPSocketAsyncApiFunction::GetUdpSocket(int socket_id) {
   return static_cast<ResumableUDPSocket*>(GetSocket(socket_id));
 }
 
 UDPSocketExtensionWithDnsLookupFunction::
     ~UDPSocketExtensionWithDnsLookupFunction() {}
 
 scoped_ptr<SocketResourceManagerInterface>
-    UDPSocketExtensionWithDnsLookupFunction::CreateSocketResourceManager() {
+UDPSocketExtensionWithDnsLookupFunction::CreateSocketResourceManager() {
   return scoped_ptr<SocketResourceManagerInterface>(
-      new SocketResourceManager<ResumableUDPSocket>()).Pass();
+             new SocketResourceManager<ResumableUDPSocket>()).Pass();
 }
 
 ResumableUDPSocket* UDPSocketExtensionWithDnsLookupFunction::GetUdpSocket(
     int socket_id) {
   return static_cast<ResumableUDPSocket*>(GetSocket(socket_id));
 }
 
 linked_ptr<sockets_udp::SocketInfo> CreateSocketInfo(
     int socket_id,
     ResumableUDPSocket* socket) {
@@ skipping 78 matching lines @@
   SetSocketProperties(socket, &params_.get()->properties);
   results_ = sockets_udp::Update::Results::Create();
 }
 
 SocketsUdpSetPausedFunction::SocketsUdpSetPausedFunction()
     : socket_event_dispatcher_(NULL) {}
 
 SocketsUdpSetPausedFunction::~SocketsUdpSetPausedFunction() {}
 
 bool SocketsUdpSetPausedFunction::Prepare() {
-  params_ = api::sockets_udp::SetPaused::Params::Create(*args_);
+  params_ = core_api::sockets_udp::SetPaused::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
 
   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.";
+  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 SocketsUdpSetPausedFunction::Work() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
 
   if (socket->paused() != params_->paused) {
     socket->set_paused(params_->paused);
     if (socket->IsBound() && !params_->paused) {
       socket_event_dispatcher_->OnSocketResume(extension_->id(),
                                                params_->socket_id);
     }
   }
 
   results_ = sockets_udp::SetPaused::Results::Create();
 }
 
 SocketsUdpBindFunction::SocketsUdpBindFunction()
-    : socket_event_dispatcher_(NULL) {
-}
+    : socket_event_dispatcher_(NULL) {}
 
 SocketsUdpBindFunction::~SocketsUdpBindFunction() {}
 
 bool SocketsUdpBindFunction::Prepare() {
   params_ = sockets_udp::Bind::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
 
   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.";
+  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() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
 
   content::SocketPermissionRequest param(
-      SocketPermissionRequest::UDP_BIND,
-      params_->address,
-      params_->port);
+      SocketPermissionRequest::UDP_BIND, params_->address, params_->port);
   if (!SocketsManifestData::CheckRequest(GetExtension(), param)) {
     error_ = kPermissionError;
     return;
   }
 
   int net_result = socket->Bind(params_->address, params_->port);
   if (net_result == net::OK) {
     socket_event_dispatcher_->OnSocketBind(extension_->id(),
                                            params_->socket_id);
   }
 
   if (net_result != net::OK)
     error_ = net::ErrorToString(net_result);
   results_ = sockets_udp::Bind::Results::Create(net_result);
 }
 
-SocketsUdpSendFunction::SocketsUdpSendFunction()
-    : io_buffer_size_(0) {}
+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();
   io_buffer_ = new net::WrappedIOBuffer(params_->data.data());
 
   return true;
 }
 
 void SocketsUdpSendFunction::AsyncWorkStart() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     AsyncWorkCompleted();
     return;
   }
 
   content::SocketPermissionRequest param(
-      SocketPermissionRequest::UDP_SEND_TO,
-      params_->address,
-      params_->port);
+      SocketPermissionRequest::UDP_SEND_TO, params_->address, params_->port);
   if (!SocketsManifestData::CheckRequest(GetExtension(), param)) {
     error_ = kPermissionError;
     AsyncWorkCompleted();
     return;
   }
 
   StartDnsLookup(params_->address);
 }
 
 void SocketsUdpSendFunction::AfterDnsLookup(int lookup_result) {
   if (lookup_result == net::OK) {
     StartSendTo();
   } else {
     SetSendResult(lookup_result, -1);
   }
 }
 
 void SocketsUdpSendFunction::StartSendTo() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     AsyncWorkCompleted();
     return;
   }
 
-  socket->SendTo(io_buffer_, io_buffer_size_, resolved_address_, params_->port,
-                  base::Bind(&SocketsUdpSendFunction::OnCompleted, this));
+  socket->SendTo(io_buffer_,
+                 io_buffer_size_,
+                 resolved_address_,
+                 params_->port,
+                 base::Bind(&SocketsUdpSendFunction::OnCompleted, this));
 }
 
 void SocketsUdpSendFunction::OnCompleted(int net_result) {
   if (net_result >= net::OK) {
     SetSendResult(net::OK, net_result);
   } else {
     SetSendResult(net_result, -1);
   }
 }
 
@@ skipping 53 matching lines @@
 
   linked_ptr<sockets_udp::SocketInfo> socket_info =
       CreateSocketInfo(params_->socket_id, socket);
   results_ = sockets_udp::GetInfo::Results::Create(*socket_info);
 }
 
 SocketsUdpGetSocketsFunction::SocketsUdpGetSocketsFunction() {}
 
 SocketsUdpGetSocketsFunction::~SocketsUdpGetSocketsFunction() {}
 
-bool SocketsUdpGetSocketsFunction::Prepare() {
-  return true;
-}
+bool SocketsUdpGetSocketsFunction::Prepare() { return true; }
 
 void SocketsUdpGetSocketsFunction::Work() {
   std::vector<linked_ptr<sockets_udp::SocketInfo> > socket_infos;
   base::hash_set<int>* resource_ids = GetSocketIds();
   if (resource_ids != NULL) {
     for (base::hash_set<int>::iterator it = resource_ids->begin();
-             it != resource_ids->end(); ++it) {
+         it != resource_ids->end();
+         ++it) {
       int socket_id = *it;
       ResumableUDPSocket* socket = GetUdpSocket(socket_id);
       if (socket) {
         socket_infos.push_back(CreateSocketInfo(socket_id, socket));
       }
     }
   }
   results_ = sockets_udp::GetSockets::Results::Create(socket_infos);
 }
 
@@ skipping 27 matching lines @@
   if (net_result != net::OK)
     error_ = net::ErrorToString(net_result);
   results_ = sockets_udp::JoinGroup::Results::Create(net_result);
 }
 
 SocketsUdpLeaveGroupFunction::SocketsUdpLeaveGroupFunction() {}
 
 SocketsUdpLeaveGroupFunction::~SocketsUdpLeaveGroupFunction() {}
 
 bool SocketsUdpLeaveGroupFunction::Prepare() {
-  params_ = api::sockets_udp::LeaveGroup::Params::Create(*args_);
+  params_ = core_api::sockets_udp::LeaveGroup::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
   return true;
 }
 
 void SocketsUdpLeaveGroupFunction::Work() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
@@ skipping 13 matching lines @@
   results_ = sockets_udp::LeaveGroup::Results::Create(net_result);
 }
 
 SocketsUdpSetMulticastTimeToLiveFunction::
     SocketsUdpSetMulticastTimeToLiveFunction() {}
 
 SocketsUdpSetMulticastTimeToLiveFunction::
     ~SocketsUdpSetMulticastTimeToLiveFunction() {}
 
 bool SocketsUdpSetMulticastTimeToLiveFunction::Prepare() {
-  params_ = api::sockets_udp::SetMulticastTimeToLive::Params::Create(*args_);
+  params_ =
+      core_api::sockets_udp::SetMulticastTimeToLive::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
   return true;
 }
 
 void SocketsUdpSetMulticastTimeToLiveFunction::Work() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
 
   int net_result = socket->SetMulticastTimeToLive(params_->ttl);
   if (net_result != net::OK)
     error_ = net::ErrorToString(net_result);
   results_ = sockets_udp::SetMulticastTimeToLive::Results::Create(net_result);
 }
 
 SocketsUdpSetMulticastLoopbackModeFunction::
     SocketsUdpSetMulticastLoopbackModeFunction() {}
 
 SocketsUdpSetMulticastLoopbackModeFunction::
-  ~SocketsUdpSetMulticastLoopbackModeFunction() {}
+    ~SocketsUdpSetMulticastLoopbackModeFunction() {}
 
 bool SocketsUdpSetMulticastLoopbackModeFunction::Prepare() {
-  params_ = api::sockets_udp::SetMulticastLoopbackMode::Params::Create(*args_);
+  params_ =
+      core_api::sockets_udp::SetMulticastLoopbackMode::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
   return true;
 }
 
 void SocketsUdpSetMulticastLoopbackModeFunction::Work() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
 
   int net_result = socket->SetMulticastLoopbackMode(params_->enabled);
   if (net_result != net::OK)
     error_ = net::ErrorToString(net_result);
   results_ = sockets_udp::SetMulticastLoopbackMode::Results::Create(net_result);
 }
 
 SocketsUdpGetJoinedGroupsFunction::SocketsUdpGetJoinedGroupsFunction() {}
 
 SocketsUdpGetJoinedGroupsFunction::~SocketsUdpGetJoinedGroupsFunction() {}
 
 bool SocketsUdpGetJoinedGroupsFunction::Prepare() {
-  params_ = api::sockets_udp::GetJoinedGroups::Params::Create(*args_);
+  params_ = core_api::sockets_udp::GetJoinedGroups::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
   return true;
 }
 
 void SocketsUdpGetJoinedGroupsFunction::Work() {
   ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
 
   content::SocketPermissionRequest param(
       SocketPermissionRequest::UDP_MULTICAST_MEMBERSHIP,
       kWildcardAddress,
       kWildcardPort);
   if (!SocketsManifestData::CheckRequest(GetExtension(), param)) {
     error_ = kPermissionError;
     return;
   }
 
   const std::vector<std::string>& groups = socket->GetJoinedGroups();
   results_ = sockets_udp::GetJoinedGroups::Results::Create(groups);
 }
 
-}  // namespace api
+}  // namespace core_api
 }  // namespace extensions