summaryrefslogtreecommitdiffstats
path: root/net/socket/client_socket_pool_base.cc
diff options
context:
space:
mode:
authormbelshe@chromium.org <mbelshe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2010-07-10 23:55:26 +0000
committermbelshe@chromium.org <mbelshe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2010-07-10 23:55:26 +0000
commit25eea382645f91215c911aa607d5dec8a6a3218f (patch)
treebd7b460a0fa39dd2a9afb4684ebde468c23aa396 /net/socket/client_socket_pool_base.cc
parentfe4eda3cb52471546b21eb442d026f2a7015c41d (diff)
downloadchromium_src-25eea382645f91215c911aa607d5dec8a6a3218f.zip
chromium_src-25eea382645f91215c911aa607d5dec8a6a3218f.tar.gz
chromium_src-25eea382645f91215c911aa607d5dec8a6a3218f.tar.bz2
Fix a bug in backup socket cleanup where when we call RemoveConnectJob,
we didn't necessarily cleanup the pending backup socket task. In addition to this, make the OnBackupSocketTimerFired more robust - in the case that this ever should happen, it will simply fallout rather than triggering a CRASH (and burn). Test case included. BUG=47375 TEST=ClientSocketPoolBaseTest.BackupSocketCancelAtMaxSockets Review URL: http://codereview.chromium.org/2942006 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@52049 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net/socket/client_socket_pool_base.cc')
-rw-r--r--net/socket/client_socket_pool_base.cc28
1 files changed, 17 insertions, 11 deletions
diff --git a/net/socket/client_socket_pool_base.cc b/net/socket/client_socket_pool_base.cc
index 40daa35..9bc663f 100644
--- a/net/socket/client_socket_pool_base.cc
+++ b/net/socket/client_socket_pool_base.cc
@@ -318,9 +318,15 @@ void ClientSocketPoolBaseHelper::OnBackupSocketTimerFired(
CHECK(group.backup_job);
+ // If there are no more jobs pending, there is no work to do.
+ // If we've done our cleanups correctly, this should not happen.
+ if (group.jobs.empty()) {
+ NOTREACHED();
+ return;
+ }
+
// If our backup job is waiting on DNS, or if we can't create any sockets
// right now due to limits, just reset the timer.
- CHECK(group.jobs.size());
if (ReachedMaxSocketsLimit() ||
!group.HasAvailableSocketSlot(max_sockets_per_group_) ||
(*group.jobs.begin())->GetLoadState() == LOAD_STATE_RESOLVING_HOST) {
@@ -598,10 +604,6 @@ void ClientSocketPoolBaseHelper::OnConnectJobComplete(
CHECK(group_it != group_map_.end());
Group& group = group_it->second;
- // We've had a connect on the socket; discard any pending backup job
- // for this group and kill the pending task.
- group.CleanupBackupJob();
-
scoped_ptr<ClientSocket> socket(job->ReleaseSocket());
BoundNetLog job_log = job->net_log();
@@ -646,18 +648,22 @@ void ClientSocketPoolBaseHelper::Flush() {
CloseIdleSockets();
}
-void ClientSocketPoolBaseHelper::RemoveConnectJob(const ConnectJob *job,
+void ClientSocketPoolBaseHelper::RemoveConnectJob(const ConnectJob* job,
Group* group) {
CHECK_GT(connecting_socket_count_, 0);
connecting_socket_count_--;
+ DCHECK(group);
+ DCHECK(ContainsKey(group->jobs, job));
+ group->jobs.erase(job);
+
+ // If we've got no more jobs for this group, then we no longer need a
+ // backup job either.
+ if (group->jobs.empty())
+ group->CleanupBackupJob();
+
DCHECK(job);
delete job;
-
- if (group) {
- DCHECK(ContainsKey(group->jobs, job));
- group->jobs.erase(job);
- }
}
void ClientSocketPoolBaseHelper::MaybeOnAvailableSocketSlot(