Lines Matching refs:handle
43 ClientSocketHandle* handle,
54 handle_(handle),
262 ClientSocketHandle* handle) {
263 DCHECK(handle->is_initialized());
264 DCHECK(handle->socket());
266 if (handle->socket()->GetPeerAddress(&address) == OK)
274 ClientSocketHandle* handle,
284 CHECK(handle);
292 casted_params, priority, handle, callback, request_net_log);
296 DCHECK_EQ(handle, iterator->handle);
303 StalledRequestMap::value_type(handle, iterator));
315 handle,
322 // |handle|, since this pool uses early-binding. So the binding is logged
330 handle,
335 AddJob(handle, connect_job.Pass());
338 connect_job->GetAdditionalErrorState(handle);
343 handle,
365 ClientSocketHandle* handle) {
366 DCHECK(!handle->is_initialized());
367 if (DeleteStalledRequest(handle))
369 scoped_ptr<StreamSocket> socket = handle->PassSocket();
371 ReleaseSocket(handle->group_name(), socket.Pass(), handle->id());
372 if (!DeleteJob(handle))
373 pending_callbacks_.erase(handle);
401 it->second->handle(), it->second->callback(), error);
408 InvokeUserCallbackLater(it->handle, it->callback, error);
430 const ClientSocketHandle* handle) const {
431 if (stalled_request_map_.find(handle) != stalled_request_map_.end())
433 if (pending_callbacks_.count(handle))
435 return LookupConnectJob(handle)->GetLoadState();
484 ClientSocketHandle* const handle = job->handle();
490 HandOutSocket(socket.Pass(), connect_timing, handle, request_net_log);
495 job->GetAdditionalErrorState(handle);
498 HandOutSocket(socket.Pass(), connect_timing, handle, request_net_log);
502 bool delete_succeeded = DeleteJob(handle);
507 InvokeUserCallbackLater(handle, callback, result);
511 ClientSocketHandle* handle,
514 DCHECK(!pending_callbacks_.count(handle));
515 pending_callbacks_.insert(handle);
520 handle,
526 ClientSocketHandle* handle,
529 if (pending_callbacks_.erase(handle))
542 ClientSocketHandle* handle,
545 handle->SetSocket(socket.Pass());
546 DCHECK_EQ(ClientSocketHandle::UNUSED, handle->reuse_type());
547 DCHECK_EQ(0, handle->idle_time().InMicroseconds());
548 handle->set_pool_id(0);
549 handle->set_connect_timing(connect_timing);
553 handle->socket()->NetLog().source().ToEventParametersCallback());
559 ClientSocketHandle* handle,
563 handle, connect_job.release())).second;
567 bool WebSocketTransportClientSocketPool::DeleteJob(ClientSocketHandle* handle) {
568 PendingConnectsMap::iterator it = pending_connects_.find(handle);
577 DCHECK(pending_connects_.find(handle) == it);
584 const ClientSocketHandle* handle) const {
585 PendingConnectsMap::const_iterator it = pending_connects_.find(handle);
599 stalled_request_map_.erase(request.handle);
603 request.handle,
609 InvokeUserCallbackLater(request.handle, request.callback, rv);
614 ClientSocketHandle* handle) {
615 StalledRequestMap::iterator it = stalled_request_map_.find(handle);
640 ClientSocketHandle* handle,
645 handle(handle),