Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(477)

Side by Side Diff: extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc

Issue 1226353004: Generate all extension schema namespaces as "api" and instead vary the generated bundle names. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: rebase Created 5 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 "extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.h" 5 #include "extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.h"
6 6
7 #include "content/public/common/socket_permission_request.h" 7 #include "content/public/common/socket_permission_request.h"
8 #include "extensions/browser/api/socket/tcp_socket.h" 8 #include "extensions/browser/api/socket/tcp_socket.h"
9 #include "extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_disp atcher.h" 9 #include "extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_disp atcher.h"
10 #include "extensions/common/api/sockets/sockets_manifest_data.h" 10 #include "extensions/common/api/sockets/sockets_manifest_data.h"
11 #include "extensions/common/permissions/permissions_data.h" 11 #include "extensions/common/permissions/permissions_data.h"
12 #include "extensions/common/permissions/socket_permission.h" 12 #include "extensions/common/permissions/socket_permission.h"
13 #include "net/base/net_errors.h" 13 #include "net/base/net_errors.h"
14 14
15 using content::SocketPermissionRequest; 15 using content::SocketPermissionRequest;
16 using extensions::ResumableTCPServerSocket; 16 using extensions::ResumableTCPServerSocket;
17 using extensions::core_api::sockets_tcp_server::SocketInfo; 17 using extensions::api::sockets_tcp_server::SocketInfo;
18 using extensions::core_api::sockets_tcp_server::SocketProperties; 18 using extensions::api::sockets_tcp_server::SocketProperties;
19 19
20 namespace { 20 namespace {
21 21
22 const char kSocketNotFoundError[] = "Socket not found"; 22 const char kSocketNotFoundError[] = "Socket not found";
23 const char kPermissionError[] = "Does not have permission"; 23 const char kPermissionError[] = "Does not have permission";
24 const int kDefaultListenBacklog = SOMAXCONN; 24 const int kDefaultListenBacklog = SOMAXCONN;
25 25
26 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, 26 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id,
27 ResumableTCPServerSocket* socket) { 27 ResumableTCPServerSocket* socket) {
28 linked_ptr<SocketInfo> socket_info(new SocketInfo()); 28 linked_ptr<SocketInfo> socket_info(new SocketInfo());
(...skipping 23 matching lines...) Expand all
52 socket->set_name(*properties->name.get()); 52 socket->set_name(*properties->name.get());
53 } 53 }
54 if (properties->persistent.get()) { 54 if (properties->persistent.get()) {
55 socket->set_persistent(*properties->persistent.get()); 55 socket->set_persistent(*properties->persistent.get());
56 } 56 }
57 } 57 }
58 58
59 } // namespace 59 } // namespace
60 60
61 namespace extensions { 61 namespace extensions {
62 namespace core_api { 62 namespace api {
63 63
64 TCPServerSocketAsyncApiFunction::~TCPServerSocketAsyncApiFunction() {} 64 TCPServerSocketAsyncApiFunction::~TCPServerSocketAsyncApiFunction() {}
65 65
66 scoped_ptr<SocketResourceManagerInterface> 66 scoped_ptr<SocketResourceManagerInterface>
67 TCPServerSocketAsyncApiFunction::CreateSocketResourceManager() { 67 TCPServerSocketAsyncApiFunction::CreateSocketResourceManager() {
68 return scoped_ptr<SocketResourceManagerInterface>( 68 return scoped_ptr<SocketResourceManagerInterface>(
69 new SocketResourceManager<ResumableTCPServerSocket>()).Pass(); 69 new SocketResourceManager<ResumableTCPServerSocket>()).Pass();
70 } 70 }
71 71
72 ResumableTCPServerSocket* TCPServerSocketAsyncApiFunction::GetTcpSocket( 72 ResumableTCPServerSocket* TCPServerSocketAsyncApiFunction::GetTcpSocket(
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after
119 SetSocketProperties(socket, &params_.get()->properties); 119 SetSocketProperties(socket, &params_.get()->properties);
120 results_ = sockets_tcp_server::Update::Results::Create(); 120 results_ = sockets_tcp_server::Update::Results::Create();
121 } 121 }
122 122
123 SocketsTcpServerSetPausedFunction::SocketsTcpServerSetPausedFunction() 123 SocketsTcpServerSetPausedFunction::SocketsTcpServerSetPausedFunction()
124 : socket_event_dispatcher_(NULL) {} 124 : socket_event_dispatcher_(NULL) {}
125 125
126 SocketsTcpServerSetPausedFunction::~SocketsTcpServerSetPausedFunction() {} 126 SocketsTcpServerSetPausedFunction::~SocketsTcpServerSetPausedFunction() {}
127 127
128 bool SocketsTcpServerSetPausedFunction::Prepare() { 128 bool SocketsTcpServerSetPausedFunction::Prepare() {
129 params_ = core_api::sockets_tcp_server::SetPaused::Params::Create(*args_); 129 params_ = api::sockets_tcp_server::SetPaused::Params::Create(*args_);
130 EXTENSION_FUNCTION_VALIDATE(params_.get()); 130 EXTENSION_FUNCTION_VALIDATE(params_.get());
131 131
132 socket_event_dispatcher_ = 132 socket_event_dispatcher_ =
133 TCPServerSocketEventDispatcher::Get(browser_context()); 133 TCPServerSocketEventDispatcher::Get(browser_context());
134 DCHECK(socket_event_dispatcher_) 134 DCHECK(socket_event_dispatcher_)
135 << "There is no socket event dispatcher. " 135 << "There is no socket event dispatcher. "
136 "If this assertion is failing during a test, then it is likely that " 136 "If this assertion is failing during a test, then it is likely that "
137 "TestExtensionSystem is failing to provide an instance of " 137 "TestExtensionSystem is failing to provide an instance of "
138 "TCPServerSocketEventDispatcher."; 138 "TCPServerSocketEventDispatcher.";
139 return socket_event_dispatcher_ != NULL; 139 return socket_event_dispatcher_ != NULL;
(...skipping 16 matching lines...) Expand all
156 156
157 results_ = sockets_tcp_server::SetPaused::Results::Create(); 157 results_ = sockets_tcp_server::SetPaused::Results::Create();
158 } 158 }
159 159
160 SocketsTcpServerListenFunction::SocketsTcpServerListenFunction() 160 SocketsTcpServerListenFunction::SocketsTcpServerListenFunction()
161 : socket_event_dispatcher_(NULL) {} 161 : socket_event_dispatcher_(NULL) {}
162 162
163 SocketsTcpServerListenFunction::~SocketsTcpServerListenFunction() {} 163 SocketsTcpServerListenFunction::~SocketsTcpServerListenFunction() {}
164 164
165 bool SocketsTcpServerListenFunction::Prepare() { 165 bool SocketsTcpServerListenFunction::Prepare() {
166 params_ = core_api::sockets_tcp_server::Listen::Params::Create(*args_); 166 params_ = api::sockets_tcp_server::Listen::Params::Create(*args_);
167 EXTENSION_FUNCTION_VALIDATE(params_.get()); 167 EXTENSION_FUNCTION_VALIDATE(params_.get());
168 168
169 socket_event_dispatcher_ = 169 socket_event_dispatcher_ =
170 TCPServerSocketEventDispatcher::Get(browser_context()); 170 TCPServerSocketEventDispatcher::Get(browser_context());
171 DCHECK(socket_event_dispatcher_) 171 DCHECK(socket_event_dispatcher_)
172 << "There is no socket event dispatcher. " 172 << "There is no socket event dispatcher. "
173 "If this assertion is failing during a test, then it is likely that " 173 "If this assertion is failing during a test, then it is likely that "
174 "TestExtensionSystem is failing to provide an instance of " 174 "TestExtensionSystem is failing to provide an instance of "
175 "TCPServerSocketEventDispatcher."; 175 "TCPServerSocketEventDispatcher.";
176 return socket_event_dispatcher_ != NULL; 176 return socket_event_dispatcher_ != NULL;
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after
290 int socket_id = *it; 290 int socket_id = *it;
291 ResumableTCPServerSocket* socket = GetTcpSocket(socket_id); 291 ResumableTCPServerSocket* socket = GetTcpSocket(socket_id);
292 if (socket) { 292 if (socket) {
293 socket_infos.push_back(CreateSocketInfo(socket_id, socket)); 293 socket_infos.push_back(CreateSocketInfo(socket_id, socket));
294 } 294 }
295 } 295 }
296 } 296 }
297 results_ = sockets_tcp_server::GetSockets::Results::Create(socket_infos); 297 results_ = sockets_tcp_server::GetSockets::Results::Create(socket_infos);
298 } 298 }
299 299
300 } // namespace core_api 300 } // namespace api
301 } // namespace extensions 301 } // namespace extensions
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698