summaryrefslogtreecommitdiff
path: root/chromium/net/server/web_socket_encoder.cc
diff options
context:
space:
mode:
Diffstat (limited to 'chromium/net/server/web_socket_encoder.cc')
-rw-r--r--chromium/net/server/web_socket_encoder.cc39
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)) {}