| OLD | NEW |
| 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" |
| (...skipping 30 matching lines...) Expand all Loading... |
| 41 new std::string(localAddress.ToStringWithoutPort())); | 41 new std::string(localAddress.ToStringWithoutPort())); |
| 42 socket_info.local_port.reset(new int(localAddress.port())); | 42 socket_info.local_port.reset(new int(localAddress.port())); |
| 43 } | 43 } |
| 44 | 44 |
| 45 return socket_info; | 45 return socket_info; |
| 46 } | 46 } |
| 47 | 47 |
| 48 void SetSocketProperties(ResumableTCPServerSocket* socket, | 48 void SetSocketProperties(ResumableTCPServerSocket* socket, |
| 49 SocketProperties* properties) { | 49 SocketProperties* properties) { |
| 50 if (properties->name.get()) { | 50 if (properties->name.get()) { |
| 51 socket->set_name(*properties->name.get()); | 51 socket->set_name(*properties->name); |
| 52 } | 52 } |
| 53 if (properties->persistent.get()) { | 53 if (properties->persistent.get()) { |
| 54 socket->set_persistent(*properties->persistent.get()); | 54 socket->set_persistent(*properties->persistent); |
| 55 } | 55 } |
| 56 } | 56 } |
| 57 | 57 |
| 58 } // namespace | 58 } // namespace |
| 59 | 59 |
| 60 namespace extensions { | 60 namespace extensions { |
| 61 namespace api { | 61 namespace api { |
| 62 | 62 |
| 63 TCPServerSocketAsyncApiFunction::~TCPServerSocketAsyncApiFunction() {} | 63 TCPServerSocketAsyncApiFunction::~TCPServerSocketAsyncApiFunction() {} |
| 64 | 64 |
| (...skipping 15 matching lines...) Expand all Loading... |
| 80 bool SocketsTcpServerCreateFunction::Prepare() { | 80 bool SocketsTcpServerCreateFunction::Prepare() { |
| 81 params_ = sockets_tcp_server::Create::Params::Create(*args_); | 81 params_ = sockets_tcp_server::Create::Params::Create(*args_); |
| 82 EXTENSION_FUNCTION_VALIDATE(params_.get()); | 82 EXTENSION_FUNCTION_VALIDATE(params_.get()); |
| 83 return true; | 83 return true; |
| 84 } | 84 } |
| 85 | 85 |
| 86 void SocketsTcpServerCreateFunction::Work() { | 86 void SocketsTcpServerCreateFunction::Work() { |
| 87 ResumableTCPServerSocket* socket = | 87 ResumableTCPServerSocket* socket = |
| 88 new ResumableTCPServerSocket(extension_->id()); | 88 new ResumableTCPServerSocket(extension_->id()); |
| 89 | 89 |
| 90 sockets_tcp_server::SocketProperties* properties = | 90 sockets_tcp_server::SocketProperties* properties = params_->properties.get(); |
| 91 params_.get()->properties.get(); | |
| 92 if (properties) { | 91 if (properties) { |
| 93 SetSocketProperties(socket, properties); | 92 SetSocketProperties(socket, properties); |
| 94 } | 93 } |
| 95 | 94 |
| 96 sockets_tcp_server::CreateInfo create_info; | 95 sockets_tcp_server::CreateInfo create_info; |
| 97 create_info.socket_id = AddSocket(socket); | 96 create_info.socket_id = AddSocket(socket); |
| 98 results_ = sockets_tcp_server::Create::Results::Create(create_info); | 97 results_ = sockets_tcp_server::Create::Results::Create(create_info); |
| 99 } | 98 } |
| 100 | 99 |
| 101 SocketsTcpServerUpdateFunction::SocketsTcpServerUpdateFunction() {} | 100 SocketsTcpServerUpdateFunction::SocketsTcpServerUpdateFunction() {} |
| 102 | 101 |
| 103 SocketsTcpServerUpdateFunction::~SocketsTcpServerUpdateFunction() {} | 102 SocketsTcpServerUpdateFunction::~SocketsTcpServerUpdateFunction() {} |
| 104 | 103 |
| 105 bool SocketsTcpServerUpdateFunction::Prepare() { | 104 bool SocketsTcpServerUpdateFunction::Prepare() { |
| 106 params_ = sockets_tcp_server::Update::Params::Create(*args_); | 105 params_ = sockets_tcp_server::Update::Params::Create(*args_); |
| 107 EXTENSION_FUNCTION_VALIDATE(params_.get()); | 106 EXTENSION_FUNCTION_VALIDATE(params_.get()); |
| 108 return true; | 107 return true; |
| 109 } | 108 } |
| 110 | 109 |
| 111 void SocketsTcpServerUpdateFunction::Work() { | 110 void SocketsTcpServerUpdateFunction::Work() { |
| 112 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); | 111 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); |
| 113 if (!socket) { | 112 if (!socket) { |
| 114 error_ = kSocketNotFoundError; | 113 error_ = kSocketNotFoundError; |
| 115 return; | 114 return; |
| 116 } | 115 } |
| 117 | 116 |
| 118 SetSocketProperties(socket, ¶ms_.get()->properties); | 117 SetSocketProperties(socket, ¶ms_->properties); |
| 119 results_ = sockets_tcp_server::Update::Results::Create(); | 118 results_ = sockets_tcp_server::Update::Results::Create(); |
| 120 } | 119 } |
| 121 | 120 |
| 122 SocketsTcpServerSetPausedFunction::SocketsTcpServerSetPausedFunction() | 121 SocketsTcpServerSetPausedFunction::SocketsTcpServerSetPausedFunction() |
| 123 : socket_event_dispatcher_(NULL) {} | 122 : socket_event_dispatcher_(NULL) {} |
| 124 | 123 |
| 125 SocketsTcpServerSetPausedFunction::~SocketsTcpServerSetPausedFunction() {} | 124 SocketsTcpServerSetPausedFunction::~SocketsTcpServerSetPausedFunction() {} |
| 126 | 125 |
| 127 bool SocketsTcpServerSetPausedFunction::Prepare() { | 126 bool SocketsTcpServerSetPausedFunction::Prepare() { |
| 128 params_ = api::sockets_tcp_server::SetPaused::Params::Create(*args_); | 127 params_ = api::sockets_tcp_server::SetPaused::Params::Create(*args_); |
| (...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 185 | 184 |
| 186 SocketPermissionRequest param( | 185 SocketPermissionRequest param( |
| 187 SocketPermissionRequest::TCP_LISTEN, params_->address, params_->port); | 186 SocketPermissionRequest::TCP_LISTEN, params_->address, params_->port); |
| 188 if (!SocketsManifestData::CheckRequest(extension(), param)) { | 187 if (!SocketsManifestData::CheckRequest(extension(), param)) { |
| 189 error_ = kPermissionError; | 188 error_ = kPermissionError; |
| 190 AsyncWorkCompleted(); | 189 AsyncWorkCompleted(); |
| 191 return; | 190 return; |
| 192 } | 191 } |
| 193 | 192 |
| 194 int net_result = socket->Listen( | 193 int net_result = socket->Listen( |
| 195 params_->address, | 194 params_->address, params_->port, |
| 196 params_->port, | 195 params_->backlog.get() ? *params_->backlog : kDefaultListenBacklog, |
| 197 params_->backlog.get() ? *params_->backlog.get() : kDefaultListenBacklog, | |
| 198 &error_); | 196 &error_); |
| 199 results_ = sockets_tcp_server::Listen::Results::Create(net_result); | 197 results_ = sockets_tcp_server::Listen::Results::Create(net_result); |
| 200 if (net_result == net::OK) { | 198 if (net_result == net::OK) { |
| 201 socket_event_dispatcher_->OnServerSocketListen(extension_->id(), | 199 socket_event_dispatcher_->OnServerSocketListen(extension_->id(), |
| 202 params_->socket_id); | 200 params_->socket_id); |
| 203 } else { | 201 } else { |
| 204 error_ = net::ErrorToString(net_result); | 202 error_ = net::ErrorToString(net_result); |
| 205 AsyncWorkCompleted(); | 203 AsyncWorkCompleted(); |
| 206 return; | 204 return; |
| 207 } | 205 } |
| (...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 288 if (socket) { | 286 if (socket) { |
| 289 socket_infos.push_back(CreateSocketInfo(socket_id, socket)); | 287 socket_infos.push_back(CreateSocketInfo(socket_id, socket)); |
| 290 } | 288 } |
| 291 } | 289 } |
| 292 } | 290 } |
| 293 results_ = sockets_tcp_server::GetSockets::Results::Create(socket_infos); | 291 results_ = sockets_tcp_server::GetSockets::Results::Create(socket_infos); |
| 294 } | 292 } |
| 295 | 293 |
| 296 } // namespace api | 294 } // namespace api |
| 297 } // namespace extensions | 295 } // namespace extensions |
| OLD | NEW |