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

Unified Diff: net/socket/client_socket_pool_base.h

Issue 1580903002: Convert ignore_limits from a SocketParam to a socket request argument. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: RespectLimits Created 4 years, 11 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/socket/client_socket_pool.h ('k') | net/socket/client_socket_pool_base.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/socket/client_socket_pool_base.h
diff --git a/net/socket/client_socket_pool_base.h b/net/socket/client_socket_pool_base.h
index cd13ce0dbdd41ab0398d2600d34c4cbc488e6528..d28868412991c74b42e52ee0159b8214b2d19a2e 100644
--- a/net/socket/client_socket_pool_base.h
+++ b/net/socket/client_socket_pool_base.h
@@ -81,6 +81,7 @@ class NET_EXPORT_PRIVATE ConnectJob {
ConnectJob(const std::string& group_name,
base::TimeDelta timeout_duration,
RequestPriority priority,
+ ClientSocketPool::RespectLimits respect_limits,
Delegate* delegate,
const BoundNetLog& net_log);
virtual ~ConnectJob();
@@ -117,6 +118,9 @@ class NET_EXPORT_PRIVATE ConnectJob {
protected:
RequestPriority priority() const { return priority_; }
+ ClientSocketPool::RespectLimits respect_limits() const {
+ return respect_limits_;
+ }
void SetSocket(scoped_ptr<StreamSocket> socket);
StreamSocket* socket() { return socket_.get(); }
void NotifyDelegateOfCompletion(int rv);
@@ -138,6 +142,7 @@ class NET_EXPORT_PRIVATE ConnectJob {
const base::TimeDelta timeout_duration_;
// TODO(akalin): Support reprioritization.
const RequestPriority priority_;
+ const ClientSocketPool::RespectLimits respect_limits_;
// Timer to abort jobs that take too long.
base::OneShotTimer timer_;
Delegate* delegate_;
@@ -173,7 +178,7 @@ class NET_EXPORT_PRIVATE ClientSocketPoolBaseHelper
Request(ClientSocketHandle* handle,
const CompletionCallback& callback,
RequestPriority priority,
- bool ignore_limits,
+ ClientSocketPool::RespectLimits respect_limits,
Flags flags,
const BoundNetLog& net_log);
@@ -182,7 +187,9 @@ class NET_EXPORT_PRIVATE ClientSocketPoolBaseHelper
ClientSocketHandle* handle() const { return handle_; }
const CompletionCallback& callback() const { return callback_; }
RequestPriority priority() const { return priority_; }
- bool ignore_limits() const { return ignore_limits_; }
+ ClientSocketPool::RespectLimits respect_limits() const {
+ return respect_limits_;
+ }
Flags flags() const { return flags_; }
const BoundNetLog& net_log() const { return net_log_; }
@@ -200,7 +207,7 @@ class NET_EXPORT_PRIVATE ClientSocketPoolBaseHelper
const CompletionCallback callback_;
// TODO(akalin): Support reprioritization.
const RequestPriority priority_;
- const bool ignore_limits_;
+ const ClientSocketPool::RespectLimits respect_limits_;
const Flags flags_;
const BoundNetLog net_log_;
@@ -406,8 +413,8 @@ class NET_EXPORT_PRIVATE ClientSocketPoolBaseHelper
// Returns the priority of the top of the pending request queue
// (which may be less than the maximum priority over the entire
- // queue, due to how we prioritize requests with |ignore_limits|
- // set over others).
+ // queue, due to how we prioritize requests with |respect_limits|
+ // DISABLED over others).
RequestPriority TopPendingPriority() const {
// NOTE: FirstMax().value()->priority() is not the same as
// FirstMax().priority()!
@@ -680,12 +687,16 @@ class ClientSocketPoolBase {
Request(ClientSocketHandle* handle,
const CompletionCallback& callback,
RequestPriority priority,
+ ClientSocketPool::RespectLimits respect_limits,
internal::ClientSocketPoolBaseHelper::Flags flags,
- bool ignore_limits,
const scoped_refptr<SocketParams>& params,
const BoundNetLog& net_log)
- : internal::ClientSocketPoolBaseHelper::Request(
- handle, callback, priority, ignore_limits, flags, net_log),
+ : internal::ClientSocketPoolBaseHelper::Request(handle,
+ callback,
+ priority,
+ respect_limits,
+ flags,
+ net_log),
params_(params) {}
const scoped_refptr<SocketParams>& params() const { return params_; }
@@ -749,14 +760,13 @@ class ClientSocketPoolBase {
int RequestSocket(const std::string& group_name,
const scoped_refptr<SocketParams>& params,
RequestPriority priority,
+ ClientSocketPool::RespectLimits respect_limits,
ClientSocketHandle* handle,
const CompletionCallback& callback,
const BoundNetLog& net_log) {
- scoped_ptr<const Request> request(
- new Request(handle, callback, priority,
- internal::ClientSocketPoolBaseHelper::NORMAL,
- params->ignore_limits(),
- params, net_log));
+ scoped_ptr<const Request> request(new Request(
+ handle, callback, priority, respect_limits,
+ internal::ClientSocketPoolBaseHelper::NORMAL, params, net_log));
return helper_.RequestSocket(group_name, std::move(request));
}
@@ -767,9 +777,10 @@ class ClientSocketPoolBase {
const scoped_refptr<SocketParams>& params,
int num_sockets,
const BoundNetLog& net_log) {
- const Request request(NULL /* no handle */, CompletionCallback(), IDLE,
+ const Request request(nullptr /* no handle */, CompletionCallback(), IDLE,
+ ClientSocketPool::RespectLimits::ENABLED,
internal::ClientSocketPoolBaseHelper::NO_IDLE_SOCKETS,
- params->ignore_limits(), params, net_log);
+ params, net_log);
helper_.RequestSockets(group_name, request, num_sockets);
}
« no previous file with comments | « net/socket/client_socket_pool.h ('k') | net/socket/client_socket_pool_base.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698