diff options
Diffstat (limited to 'chromium/net/server/web_socket_encoder.cc')
-rw-r--r-- | chromium/net/server/web_socket_encoder.cc | 39 |
1 files changed, 20 insertions, 19 deletions
diff --git a/chromium/net/server/web_socket_encoder.cc b/chromium/net/server/web_socket_encoder.cc index d90a156aaae..60a9a47021c 100644 --- a/chromium/net/server/web_socket_encoder.cc +++ b/chromium/net/server/web_socket_encoder.cc @@ -9,6 +9,7 @@ #include <vector> #include "base/logging.h" +#include "base/memory/ptr_util.h" #include "base/strings/string_number_conversions.h" #include "base/strings/stringprintf.h" #include "net/base/io_buffer.h" @@ -186,12 +187,12 @@ void EncodeFrameHybi17(const std::string& message, } // anonymous namespace // static -scoped_ptr<WebSocketEncoder> WebSocketEncoder::CreateServer() { - return make_scoped_ptr(new WebSocketEncoder(FOR_SERVER, nullptr, nullptr)); +std::unique_ptr<WebSocketEncoder> WebSocketEncoder::CreateServer() { + return base::WrapUnique(new WebSocketEncoder(FOR_SERVER, nullptr, nullptr)); } // static -scoped_ptr<WebSocketEncoder> WebSocketEncoder::CreateServer( +std::unique_ptr<WebSocketEncoder> WebSocketEncoder::CreateServer( const std::string& extensions, WebSocketDeflateParameters* deflate_parameters) { WebSocketExtensionParser parser; @@ -218,9 +219,9 @@ scoped_ptr<WebSocketEncoder> WebSocketEncoder::CreateServer( } DCHECK(response.IsValidAsResponse()); DCHECK(offer.IsCompatibleWith(response)); - auto deflater = make_scoped_ptr( + auto deflater = base::WrapUnique( new WebSocketDeflater(response.server_context_take_over_mode())); - auto inflater = make_scoped_ptr( + auto inflater = base::WrapUnique( new WebSocketInflater(kInflaterChunkSize, kInflaterChunkSize)); if (!deflater->Initialize(response.PermissiveServerMaxWindowBits()) || !inflater->Initialize(response.PermissiveClientMaxWindowBits())) { @@ -228,16 +229,16 @@ scoped_ptr<WebSocketEncoder> WebSocketEncoder::CreateServer( continue; } *deflate_parameters = response; - return make_scoped_ptr(new WebSocketEncoder(FOR_SERVER, std::move(deflater), - std::move(inflater))); + return base::WrapUnique(new WebSocketEncoder( + FOR_SERVER, std::move(deflater), std::move(inflater))); } // We cannot find an acceptable offer. - return make_scoped_ptr(new WebSocketEncoder(FOR_SERVER, nullptr, nullptr)); + return base::WrapUnique(new WebSocketEncoder(FOR_SERVER, nullptr, nullptr)); } // static -scoped_ptr<WebSocketEncoder> WebSocketEncoder::CreateClient( +std::unique_ptr<WebSocketEncoder> WebSocketEncoder::CreateClient( const std::string& response_extensions) { // TODO(yhirano): Add a way to return an error. @@ -248,12 +249,12 @@ scoped_ptr<WebSocketEncoder> WebSocketEncoder::CreateClient( // 2) There is a malformed Sec-WebSocketExtensions header. // We should return a deflate-disabled encoder for the former case and // fail the connection for the latter case. - return make_scoped_ptr(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); + return base::WrapUnique(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); } if (parser.extensions().size() != 1) { // Only permessage-deflate extension is supported. // TODO (yhirano): Fail the connection. - return make_scoped_ptr(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); + return base::WrapUnique(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); } const auto& extension = parser.extensions()[0]; WebSocketDeflateParameters params; @@ -261,26 +262,26 @@ scoped_ptr<WebSocketEncoder> WebSocketEncoder::CreateClient( if (!params.Initialize(extension, &failure_message) || !params.IsValidAsResponse(&failure_message)) { // TODO (yhirano): Fail the connection. - return make_scoped_ptr(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); + return base::WrapUnique(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); } - auto deflater = make_scoped_ptr( + auto deflater = base::WrapUnique( new WebSocketDeflater(params.client_context_take_over_mode())); - auto inflater = make_scoped_ptr( + auto inflater = base::WrapUnique( new WebSocketInflater(kInflaterChunkSize, kInflaterChunkSize)); if (!deflater->Initialize(params.PermissiveClientMaxWindowBits()) || !inflater->Initialize(params.PermissiveServerMaxWindowBits())) { // TODO (yhirano): Fail the connection. - return make_scoped_ptr(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); + return base::WrapUnique(new WebSocketEncoder(FOR_CLIENT, nullptr, nullptr)); } - return make_scoped_ptr(new WebSocketEncoder(FOR_CLIENT, std::move(deflater), - std::move(inflater))); + return base::WrapUnique(new WebSocketEncoder(FOR_CLIENT, std::move(deflater), + std::move(inflater))); } WebSocketEncoder::WebSocketEncoder(Type type, - scoped_ptr<WebSocketDeflater> deflater, - scoped_ptr<WebSocketInflater> inflater) + std::unique_ptr<WebSocketDeflater> deflater, + std::unique_ptr<WebSocketInflater> inflater) : type_(type), deflater_(std::move(deflater)), inflater_(std::move(inflater)) {} |