Lines Matching refs:request
24 // disabled, sockets are closed next time a socket request is made.
140 ClientSocketPoolBaseHelper::Request::Request(
162 ClientSocketPoolBaseHelper::Request::~Request() {}
200 // InsertRequestIntoQueue inserts the request into the queue based on
206 const Request* r, RequestQueue* pending_requests) {
214 const ClientSocketPoolBaseHelper::Request*
217 const Request* req = *it;
227 const Request* request) {
228 CHECK(request->callback());
229 CHECK(request->handle());
235 request->net_log().BeginEvent(NetLog::TYPE_SOCKET_POOL, NULL);
238 int rv = RequestSocketInternal(group_name, request);
240 request->net_log().EndEventWithNetErrorCode(NetLog::TYPE_SOCKET_POOL, rv);
241 CHECK(!request->handle()->is_initialized());
242 delete request;
244 InsertRequestIntoQueue(request, group->mutable_pending_requests());
251 const Request& request,
253 DCHECK(!request.callback());
254 DCHECK(!request.handle());
264 request.net_log().BeginEvent(
278 rv = RequestSocketInternal(group_name, &request);
299 request.net_log().EndEventWithNetErrorCode(
305 const Request* request) {
306 DCHECK_GE(request->priority(), 0);
307 ClientSocketHandle* const handle = request->handle();
311 if (!(request->flags() & NO_IDLE_SOCKETS)) {
313 if (AssignIdleSocketToGroup(request, group))
322 !request->ignore_limits()) {
323 request->net_log().AddEvent(
328 if (ReachedMaxSocketsLimit() && !request->ignore_limits()) {
336 request->net_log().AddEvent(
344 connect_job_factory_->NewConnectJob(group_name, *request, this));
349 LogBoundConnectJobToRequest(connect_job->net_log().source(), request);
352 handle, base::TimeDelta(), group, request->net_log());
370 LogBoundConnectJobToRequest(connect_job->net_log().source(), request);
379 base::TimeDelta(), group, request->net_log());
389 const Request* request, Group* group) {
429 request->handle(),
432 request->net_log());
441 const NetLog::Source& connect_job_source, const Request* request) {
442 request->net_log().AddEvent(
471 scoped_ptr<const Request> req(RemoveRequestFromQueue(it, group));
760 // Search for the highest priority pending request, amongst the groups that
809 scoped_ptr<const Request> r(RemoveRequestFromQueue(
827 scoped_ptr<const Request> r(RemoveRequestFromQueue(
893 scoped_ptr<const Request> request(RemoveRequestFromQueue(
898 request->net_log().EndEventWithNetErrorCode(NetLog::TYPE_SOCKET_POOL, rv);
899 InvokeUserCallbackLater(request->handle(), request->callback(), rv);
969 scoped_ptr<const Request> request(*it2);
971 request->handle(), request->callback(), ERR_ABORTED);
1043 // Exit if the request has already been cancelled.
1108 LOG(DFATAL) << "No pending request for backup job.";
