| Index: net/socket/client_socket_pool_base.cc
|
| ===================================================================
|
| --- net/socket/client_socket_pool_base.cc (revision 45472)
|
| +++ net/socket/client_socket_pool_base.cc (working copy)
|
| @@ -58,7 +58,7 @@
|
| timer_.Start(timeout_duration_, this, &ConnectJob::OnTimeout);
|
|
|
| net_log_.BeginEventWithString(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB,
|
| - group_name_);
|
| + "group_name", group_name_);
|
| idle_ = false;
|
|
|
| int rv = ConnectInternal();
|
| @@ -202,7 +202,8 @@
|
|
|
| request->net_log().AddEvent(NetLog::TYPE_SOCKET_POOL_STALLED_MAX_SOCKETS);
|
| } else {
|
| - request->net_log().AddEvent(NetLog::TYPE_SOCKET_POOL_STALLED_MAX_SOCKETS_PER_GROUP);
|
| + request->net_log().AddEvent(
|
| + NetLog::TYPE_SOCKET_POOL_STALLED_MAX_SOCKETS_PER_GROUP);
|
| }
|
| return ERR_IO_PENDING;
|
| }
|
| @@ -234,7 +235,8 @@
|
| BoundNetLog job_net_log = BoundNetLog::Make(
|
| request->net_log().net_log(), NetLog::SOURCE_CONNECT_JOB);
|
| request->net_log().BeginEventWithInteger(
|
| - NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID, job_net_log.source().id);
|
| + NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID,
|
| + "source_id", job_net_log.source().id);
|
|
|
| scoped_ptr<ConnectJob> connect_job(
|
| connect_job_factory_->NewConnectJob(group_name, *request, this,
|
| @@ -243,7 +245,8 @@
|
| int rv = connect_job->Connect();
|
| if (rv == OK) {
|
| request->net_log().EndEventWithInteger(
|
| - NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID, job_net_log.source().id);
|
| + NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID,
|
| + "source_id", job_net_log.source().id);
|
| HandOutSocket(connect_job->ReleaseSocket(), false /* not reused */,
|
| handle, base::TimeDelta(), &group, request->net_log());
|
| } else if (rv == ERR_IO_PENDING) {
|
| @@ -264,7 +267,8 @@
|
| group.jobs.insert(job);
|
| } else {
|
| request->net_log().EndEventWithInteger(
|
| - NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID, job_net_log.source().id);
|
| + NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID,
|
| + "source_id", job_net_log.source().id);
|
| if (group.IsEmpty())
|
| group_map_.erase(group_name);
|
| }
|
| @@ -569,7 +573,7 @@
|
| scoped_ptr<const Request> r(RemoveRequestFromQueue(
|
| group.pending_requests.begin(), &group.pending_requests));
|
| r->net_log().EndEventWithInteger(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID,
|
| - job_log.source().id);
|
| + "source_id", job_log.source().id);
|
| r->net_log().EndEvent(NetLog::TYPE_SOCKET_POOL);
|
| HandOutSocket(
|
| socket.release(), false /* unused socket */, r->handle(),
|
| @@ -585,7 +589,7 @@
|
| scoped_ptr<const Request> r(RemoveRequestFromQueue(
|
| group.pending_requests.begin(), &group.pending_requests));
|
| r->net_log().EndEventWithInteger(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID,
|
| - job_log.source().id);
|
| + "source_id", job_log.source().id);
|
| r->net_log().EndEvent(NetLog::TYPE_SOCKET_POOL);
|
| r->callback()->Run(result);
|
| }
|
| @@ -673,15 +677,14 @@
|
| handle->set_is_reused(reused);
|
| handle->set_idle_time(idle_time);
|
|
|
| - if (reused)
|
| - net_log.AddStringLiteral("Reusing socket.");
|
| - if (idle_time != base::TimeDelta()) {
|
| - net_log.AddString(
|
| - StringPrintf("Socket sat idle for %" PRId64 " milliseconds",
|
| - idle_time.InMilliseconds()));
|
| + if (reused) {
|
| + net_log.AddEventWithInteger(
|
| + NetLog::TYPE_SOCKET_POOL_REUSED_AN_EXISTING_SOCKET,
|
| + "idle_ms", static_cast<int>(idle_time.InMilliseconds()));
|
| }
|
| +
|
| net_log.AddEventWithInteger(NetLog::TYPE_SOCKET_POOL_SOCKET_ID,
|
| - socket->NetLog().source().id);
|
| + "source_id", socket->NetLog().source().id);
|
|
|
| handed_out_socket_count_++;
|
| group->active_socket_count++;
|
|
|