Index: net/socket/websocket_transport_client_socket_pool.cc |
diff --git a/net/socket/websocket_transport_client_socket_pool.cc b/net/socket/websocket_transport_client_socket_pool.cc |
index 6ca72b39a9da2e5e47ae7db54a660abadfe445ac..412a63a14d6877ccbfd0ce94c88dd44dc944f8a6 100644 |
--- a/net/socket/websocket_transport_client_socket_pool.cc |
+++ b/net/socket/websocket_transport_client_socket_pool.cc |
@@ -310,7 +310,7 @@ int WebSocketTransportClientSocketPool::RequestSocket( |
return ERR_IO_PENDING; |
} |
- scoped_ptr<WebSocketTransportConnectJob> connect_job( |
+ std::unique_ptr<WebSocketTransportConnectJob> connect_job( |
new WebSocketTransportConnectJob( |
group_name, priority, respect_limits, casted_params, |
ConnectionTimeout(), callback, client_socket_factory_, host_resolver_, |
@@ -333,7 +333,7 @@ int WebSocketTransportClientSocketPool::RequestSocket( |
// TODO(ricea): Implement backup job timer? |
AddJob(handle, std::move(connect_job)); |
} else { |
- scoped_ptr<StreamSocket> error_socket; |
+ std::unique_ptr<StreamSocket> error_socket; |
connect_job->GetAdditionalErrorState(handle); |
error_socket = connect_job->PassSocket(); |
if (error_socket) { |
@@ -363,7 +363,7 @@ void WebSocketTransportClientSocketPool::CancelRequest( |
DCHECK(!handle->is_initialized()); |
if (DeleteStalledRequest(handle)) |
return; |
- scoped_ptr<StreamSocket> socket = handle->PassSocket(); |
+ std::unique_ptr<StreamSocket> socket = handle->PassSocket(); |
if (socket) |
ReleaseSocket(handle->group_name(), std::move(socket), handle->id()); |
if (!DeleteJob(handle)) |
@@ -374,7 +374,7 @@ void WebSocketTransportClientSocketPool::CancelRequest( |
void WebSocketTransportClientSocketPool::ReleaseSocket( |
const std::string& group_name, |
- scoped_ptr<StreamSocket> socket, |
+ std::unique_ptr<StreamSocket> socket, |
int id) { |
WebSocketEndpointLockManager::GetInstance()->UnlockSocket(socket.get()); |
CHECK_GT(handed_out_socket_count_, 0); |
@@ -432,12 +432,12 @@ LoadState WebSocketTransportClientSocketPool::GetLoadState( |
return LookupConnectJob(handle)->GetLoadState(); |
} |
-scoped_ptr<base::DictionaryValue> |
- WebSocketTransportClientSocketPool::GetInfoAsValue( |
- const std::string& name, |
- const std::string& type, |
- bool include_nested_pools) const { |
- scoped_ptr<base::DictionaryValue> dict(new base::DictionaryValue()); |
+std::unique_ptr<base::DictionaryValue> |
+WebSocketTransportClientSocketPool::GetInfoAsValue( |
+ const std::string& name, |
+ const std::string& type, |
+ bool include_nested_pools) const { |
+ std::unique_ptr<base::DictionaryValue> dict(new base::DictionaryValue()); |
dict->SetString("name", name); |
dict->SetString("type", type); |
dict->SetInteger("handed_out_socket_count", handed_out_socket_count_); |
@@ -462,7 +462,7 @@ void WebSocketTransportClientSocketPool::OnConnectJobComplete( |
WebSocketTransportConnectJob* job) { |
DCHECK_NE(ERR_IO_PENDING, result); |
- scoped_ptr<StreamSocket> socket = job->PassSocket(); |
+ std::unique_ptr<StreamSocket> socket = job->PassSocket(); |
// See comment in FlushWithError. |
if (flushing_) { |
@@ -527,7 +527,7 @@ bool WebSocketTransportClientSocketPool::ReachedMaxSocketsLimit() const { |
} |
void WebSocketTransportClientSocketPool::HandOutSocket( |
- scoped_ptr<StreamSocket> socket, |
+ std::unique_ptr<StreamSocket> socket, |
const LoadTimingInfo::ConnectTiming& connect_timing, |
ClientSocketHandle* handle, |
const BoundNetLog& net_log) { |
@@ -547,7 +547,7 @@ void WebSocketTransportClientSocketPool::HandOutSocket( |
void WebSocketTransportClientSocketPool::AddJob( |
ClientSocketHandle* handle, |
- scoped_ptr<WebSocketTransportConnectJob> connect_job) { |
+ std::unique_ptr<WebSocketTransportConnectJob> connect_job) { |
bool inserted = |
pending_connects_.insert(PendingConnectsMap::value_type( |
handle, connect_job.release())).second; |