| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/net/passive_log_collector.h" | 5 #include "chrome/browser/net/passive_log_collector.h" |
| 6 | 6 |
| 7 #include "base/compiler_specific.h" | 7 #include "base/compiler_specific.h" |
| 8 #include "base/format_macros.h" | 8 #include "base/format_macros.h" |
| 9 #include "base/string_util.h" | 9 #include "base/string_util.h" |
| 10 #include "testing/gtest/include/gtest/gtest.h" | 10 #include "testing/gtest/include/gtest/gtest.h" |
| 11 | 11 |
| 12 namespace { | 12 namespace { |
| 13 | 13 |
| 14 typedef PassiveLogCollector::RequestTracker RequestTracker; | 14 typedef PassiveLogCollector::RequestTracker RequestTracker; |
| 15 typedef PassiveLogCollector::RequestInfoList RequestInfoList; | 15 typedef PassiveLogCollector::RequestInfoList RequestInfoList; |
| 16 typedef net::NetLog NetLog; | 16 typedef net::NetLog NetLog; |
| 17 | 17 |
| 18 const NetLog::SourceType kSourceType = NetLog::SOURCE_NONE; | 18 const NetLog::SourceType kSourceType = NetLog::SOURCE_NONE; |
| 19 | 19 |
| 20 PassiveLogCollector::Entry MakeStartLogEntryWithURL(int source_id, | 20 PassiveLogCollector::Entry MakeStartLogEntryWithURL(int source_id, |
| 21 const std::string& url) { | 21 const std::string& url) { |
| 22 return PassiveLogCollector::Entry( | 22 return PassiveLogCollector::Entry( |
| 23 0, | 23 0, |
| 24 NetLog::TYPE_URL_REQUEST_START, | 24 NetLog::TYPE_URL_REQUEST_START, |
| 25 base::TimeTicks(), | 25 base::TimeTicks(), |
| 26 NetLog::Source(kSourceType, source_id), | 26 NetLog::Source(kSourceType, source_id), |
| 27 NetLog::PHASE_BEGIN, | 27 NetLog::PHASE_BEGIN, |
| 28 new net::NetLogStringParameter(url)); | 28 new net::NetLogStringParameter("url", url)); |
| 29 } | 29 } |
| 30 | 30 |
| 31 PassiveLogCollector::Entry MakeStartLogEntry(int source_id) { | 31 PassiveLogCollector::Entry MakeStartLogEntry(int source_id) { |
| 32 return MakeStartLogEntryWithURL(source_id, | 32 return MakeStartLogEntryWithURL(source_id, |
| 33 StringPrintf("http://req%d", source_id)); | 33 StringPrintf("http://req%d", source_id)); |
| 34 } | 34 } |
| 35 | 35 |
| 36 PassiveLogCollector::Entry MakeEndLogEntry(int source_id) { | 36 PassiveLogCollector::Entry MakeEndLogEntry(int source_id) { |
| 37 return PassiveLogCollector::Entry( | 37 return PassiveLogCollector::Entry( |
| 38 0, | 38 0, |
| 39 NetLog::TYPE_REQUEST_ALIVE, | 39 NetLog::TYPE_REQUEST_ALIVE, |
| 40 base::TimeTicks(), | 40 base::TimeTicks(), |
| 41 NetLog::Source(kSourceType, source_id), | 41 NetLog::Source(kSourceType, source_id), |
| 42 NetLog::PHASE_END, | 42 NetLog::PHASE_END, |
| 43 NULL); | 43 NULL); |
| 44 } | 44 } |
| 45 | 45 |
| 46 void AddStartURLRequestEntries(PassiveLogCollector* collector, uint32 id) { | 46 void AddStartURLRequestEntries(PassiveLogCollector* collector, uint32 id) { |
| 47 collector->OnAddEntry(NetLog::TYPE_REQUEST_ALIVE, base::TimeTicks(), | 47 collector->OnAddEntry(NetLog::TYPE_REQUEST_ALIVE, base::TimeTicks(), |
| 48 NetLog::Source(NetLog::SOURCE_URL_REQUEST, id), | 48 NetLog::Source(NetLog::SOURCE_URL_REQUEST, id), |
| 49 NetLog::PHASE_BEGIN, NULL); | 49 NetLog::PHASE_BEGIN, NULL); |
| 50 collector->OnAddEntry(NetLog::TYPE_URL_REQUEST_START, base::TimeTicks(), | 50 collector->OnAddEntry(NetLog::TYPE_URL_REQUEST_START, base::TimeTicks(), |
| 51 NetLog::Source(NetLog::SOURCE_URL_REQUEST, id), | 51 NetLog::Source(NetLog::SOURCE_URL_REQUEST, id), |
| 52 NetLog::PHASE_BEGIN, new net::NetLogStringParameter( | 52 NetLog::PHASE_BEGIN, new net::NetLogStringParameter( |
| 53 StringPrintf("http://req%d", id))); | 53 "url", StringPrintf("http://req%d", id))); |
| 54 } | 54 } |
| 55 | 55 |
| 56 void AddEndURLRequestEntries(PassiveLogCollector* collector, uint32 id) { | 56 void AddEndURLRequestEntries(PassiveLogCollector* collector, uint32 id) { |
| 57 collector->OnAddEntry(NetLog::TYPE_REQUEST_ALIVE, base::TimeTicks(), | 57 collector->OnAddEntry(NetLog::TYPE_REQUEST_ALIVE, base::TimeTicks(), |
| 58 NetLog::Source(NetLog::SOURCE_URL_REQUEST, id), | 58 NetLog::Source(NetLog::SOURCE_URL_REQUEST, id), |
| 59 NetLog::PHASE_END, NULL); | 59 NetLog::PHASE_END, NULL); |
| 60 } | 60 } |
| 61 | 61 |
| 62 std::string GetStringParam(const PassiveLogCollector::Entry& entry) { |
| 63 return static_cast<net::NetLogStringParameter*>( |
| 64 entry.extra_parameters.get())->value(); |
| 65 } |
| 66 |
| 62 static const int kMaxNumLoadLogEntries = 1; | 67 static const int kMaxNumLoadLogEntries = 1; |
| 63 | 68 |
| 64 } // namespace | 69 } // namespace |
| 65 | 70 |
| 66 TEST(RequestTrackerTest, BasicBounded) { | 71 TEST(RequestTrackerTest, BasicBounded) { |
| 67 RequestTracker tracker(NULL, NULL); | 72 RequestTracker tracker(NULL, NULL); |
| 68 EXPECT_FALSE(tracker.is_unbounded()); | 73 EXPECT_FALSE(tracker.is_unbounded()); |
| 69 EXPECT_EQ(0u, tracker.GetLiveRequests().size()); | 74 EXPECT_EQ(0u, tracker.GetLiveRequests().size()); |
| 70 EXPECT_EQ(0u, tracker.GetRecentlyDeceased().size()); | 75 EXPECT_EQ(0u, tracker.GetRecentlyDeceased().size()); |
| 71 | 76 |
| (...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 224 requests = log.url_request_tracker()->GetLiveRequests(); | 229 requests = log.url_request_tracker()->GetLiveRequests(); |
| 225 EXPECT_EQ(2u, requests.size()); | 230 EXPECT_EQ(2u, requests.size()); |
| 226 | 231 |
| 227 EXPECT_EQ(10u, requests[0].source_id); | 232 EXPECT_EQ(10u, requests[0].source_id); |
| 228 EXPECT_EQ(2u, requests[0].entries.size()); | 233 EXPECT_EQ(2u, requests[0].entries.size()); |
| 229 EXPECT_EQ(20u, requests[1].source_id); | 234 EXPECT_EQ(20u, requests[1].source_id); |
| 230 EXPECT_EQ(2u, requests[1].entries.size()); | 235 EXPECT_EQ(2u, requests[1].entries.size()); |
| 231 | 236 |
| 232 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 237 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 233 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 238 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 234 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(11)); | 239 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 11)); |
| 235 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 240 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 236 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 241 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 237 NetLog::PHASE_BEGIN, NULL); | 242 NetLog::PHASE_BEGIN, NULL); |
| 238 | 243 |
| 239 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 244 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 240 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 245 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 241 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(21)); | 246 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 21)); |
| 242 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 247 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 243 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 248 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 244 NetLog::PHASE_BEGIN, NULL); | 249 NetLog::PHASE_BEGIN, NULL); |
| 245 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 250 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 246 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 251 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 247 NetLog::PHASE_END, NULL); | 252 NetLog::PHASE_END, NULL); |
| 248 | 253 |
| 249 requests = log.url_request_tracker()->GetLiveRequests(); | 254 requests = log.url_request_tracker()->GetLiveRequests(); |
| 250 EXPECT_EQ(2u, requests.size()); | 255 EXPECT_EQ(2u, requests.size()); |
| 251 | 256 |
| (...skipping 16 matching lines...) Expand all Loading... |
| 268 PassiveLogCollector log; | 273 PassiveLogCollector log; |
| 269 | 274 |
| 270 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 275 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 271 EXPECT_EQ(0u, requests.size()); | 276 EXPECT_EQ(0u, requests.size()); |
| 272 | 277 |
| 273 AddStartURLRequestEntries(&log, 10); | 278 AddStartURLRequestEntries(&log, 10); |
| 274 AddStartURLRequestEntries(&log, 20); | 279 AddStartURLRequestEntries(&log, 20); |
| 275 | 280 |
| 276 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 281 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 277 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 282 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 278 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(11)); | 283 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 11)); |
| 279 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 284 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 280 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 285 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 281 NetLog::PHASE_BEGIN, NULL); | 286 NetLog::PHASE_BEGIN, NULL); |
| 282 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 287 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 283 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 288 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 284 NetLog::PHASE_END, NULL); | 289 NetLog::PHASE_END, NULL); |
| 285 | 290 |
| 286 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 291 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 287 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 292 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 288 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(21)); | 293 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 21)); |
| 289 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 294 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 290 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 295 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 291 NetLog::PHASE_BEGIN, NULL); | 296 NetLog::PHASE_BEGIN, NULL); |
| 292 log.OnAddEntry(NetLog::TYPE_TCP_CONNECT , base::TimeTicks(), | 297 log.OnAddEntry(NetLog::TYPE_TCP_CONNECT , base::TimeTicks(), |
| 293 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 298 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 294 NetLog::PHASE_NONE, NULL); | 299 NetLog::PHASE_NONE, NULL); |
| 295 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 300 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 296 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 301 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 297 NetLog::PHASE_END, NULL); | 302 NetLog::PHASE_END, NULL); |
| 298 | 303 |
| 299 requests = log.url_request_tracker()->GetLiveRequests(); | 304 requests = log.url_request_tracker()->GetLiveRequests(); |
| 300 EXPECT_EQ(2u, requests.size()); | 305 EXPECT_EQ(2u, requests.size()); |
| 301 | 306 |
| 302 EXPECT_EQ(5u, requests[0].entries.size()); | 307 EXPECT_EQ(5u, requests[0].entries.size()); |
| 303 EXPECT_EQ(6u, requests[1].entries.size()); | 308 EXPECT_EQ(6u, requests[1].entries.size()); |
| 304 | 309 |
| 305 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 310 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 306 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 311 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 307 NetLog::PHASE_END, new net::NetLogIntegerParameter(11)); | 312 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 11)); |
| 308 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 313 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 309 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 314 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 310 NetLog::PHASE_END, new net::NetLogIntegerParameter(21)); | 315 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 21)); |
| 311 | 316 |
| 312 requests = log.url_request_tracker()->GetLiveRequests(); | 317 requests = log.url_request_tracker()->GetLiveRequests(); |
| 313 EXPECT_EQ(2u, requests.size()); | 318 EXPECT_EQ(2u, requests.size()); |
| 314 | 319 |
| 315 EXPECT_EQ(6u, requests[0].entries.size()); | 320 EXPECT_EQ(6u, requests[0].entries.size()); |
| 316 EXPECT_EQ(7u, requests[1].entries.size()); | 321 EXPECT_EQ(7u, requests[1].entries.size()); |
| 317 | 322 |
| 318 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 323 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 319 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 324 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 320 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 325 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 321 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 326 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 322 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 327 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 323 NetLog::PHASE_END, new net::NetLogIntegerParameter(25)); | 328 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 25)); |
| 324 | 329 |
| 325 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 330 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 326 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 331 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 327 NetLog::PHASE_NONE, NULL); | 332 NetLog::PHASE_NONE, NULL); |
| 328 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 333 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 329 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 334 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 330 NetLog::PHASE_BEGIN, NULL); | 335 NetLog::PHASE_BEGIN, NULL); |
| 331 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 336 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 332 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 337 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 333 NetLog::PHASE_END, NULL); | 338 NetLog::PHASE_END, NULL); |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 370 NetLog::PHASE_NONE, NULL); | 375 NetLog::PHASE_NONE, NULL); |
| 371 | 376 |
| 372 requests = log.url_request_tracker()->GetLiveRequests(); | 377 requests = log.url_request_tracker()->GetLiveRequests(); |
| 373 EXPECT_EQ(2u, requests.size()); | 378 EXPECT_EQ(2u, requests.size()); |
| 374 | 379 |
| 375 EXPECT_EQ(2u, requests[0].entries.size()); | 380 EXPECT_EQ(2u, requests[0].entries.size()); |
| 376 EXPECT_EQ(3u, requests[1].entries.size()); | 381 EXPECT_EQ(3u, requests[1].entries.size()); |
| 377 | 382 |
| 378 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 383 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 379 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 384 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 380 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 385 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 381 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 386 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 382 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 387 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 383 NetLog::PHASE_END, new net::NetLogIntegerParameter(25)); | 388 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 25)); |
| 384 | 389 |
| 385 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 390 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 386 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 391 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 387 NetLog::PHASE_NONE, NULL); | 392 NetLog::PHASE_NONE, NULL); |
| 388 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 393 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 389 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 394 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 390 NetLog::PHASE_BEGIN, NULL); | 395 NetLog::PHASE_BEGIN, NULL); |
| 391 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 396 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 392 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 397 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 393 NetLog::PHASE_END, NULL); | 398 NetLog::PHASE_END, NULL); |
| (...skipping 27 matching lines...) Expand all Loading... |
| 421 PassiveLogCollector log; | 426 PassiveLogCollector log; |
| 422 | 427 |
| 423 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 428 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 424 EXPECT_EQ(0u, requests.size()); | 429 EXPECT_EQ(0u, requests.size()); |
| 425 | 430 |
| 426 AddStartURLRequestEntries(&log, 10); | 431 AddStartURLRequestEntries(&log, 10); |
| 427 AddStartURLRequestEntries(&log, 20); | 432 AddStartURLRequestEntries(&log, 20); |
| 428 | 433 |
| 429 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 434 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 430 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 435 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 431 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(11)); | 436 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 11)); |
| 432 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 437 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 433 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 438 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 434 NetLog::PHASE_BEGIN, NULL); | 439 NetLog::PHASE_BEGIN, NULL); |
| 435 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 440 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 436 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 441 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 437 NetLog::PHASE_END, NULL); | 442 NetLog::PHASE_END, NULL); |
| 438 | 443 |
| 439 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 444 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 440 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 445 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 441 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(21)); | 446 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 21)); |
| 442 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 447 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 443 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 448 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 444 NetLog::PHASE_BEGIN, NULL); | 449 NetLog::PHASE_BEGIN, NULL); |
| 445 log.OnAddEntry(NetLog::TYPE_TCP_CONNECT , base::TimeTicks(), | 450 log.OnAddEntry(NetLog::TYPE_TCP_CONNECT , base::TimeTicks(), |
| 446 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 451 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 447 NetLog::PHASE_NONE, NULL); | 452 NetLog::PHASE_NONE, NULL); |
| 448 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 453 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 449 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 454 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 450 NetLog::PHASE_END, NULL); | 455 NetLog::PHASE_END, NULL); |
| 451 | 456 |
| 452 requests = log.url_request_tracker()->GetLiveRequests(); | 457 requests = log.url_request_tracker()->GetLiveRequests(); |
| 453 EXPECT_EQ(2u, requests.size()); | 458 EXPECT_EQ(2u, requests.size()); |
| 454 | 459 |
| 455 EXPECT_EQ(5u, requests[0].entries.size()); | 460 EXPECT_EQ(5u, requests[0].entries.size()); |
| 456 EXPECT_EQ(6u, requests[1].entries.size()); | 461 EXPECT_EQ(6u, requests[1].entries.size()); |
| 457 | 462 |
| 458 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 463 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 459 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 464 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 460 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 465 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 461 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 466 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 462 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 467 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 463 NetLog::PHASE_END, new net::NetLogIntegerParameter(25)); | 468 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 25)); |
| 464 | 469 |
| 465 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 470 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 466 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 471 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 467 NetLog::PHASE_NONE, NULL); | 472 NetLog::PHASE_NONE, NULL); |
| 468 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 473 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 469 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 474 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 470 NetLog::PHASE_BEGIN, NULL); | 475 NetLog::PHASE_BEGIN, NULL); |
| 471 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 476 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 472 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 477 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 473 NetLog::PHASE_END, NULL); | 478 NetLog::PHASE_END, NULL); |
| (...skipping 27 matching lines...) Expand all Loading... |
| 501 PassiveLogCollector log; | 506 PassiveLogCollector log; |
| 502 | 507 |
| 503 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 508 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 504 EXPECT_EQ(0u, requests.size()); | 509 EXPECT_EQ(0u, requests.size()); |
| 505 | 510 |
| 506 AddStartURLRequestEntries(&log, 10); | 511 AddStartURLRequestEntries(&log, 10); |
| 507 AddStartURLRequestEntries(&log, 20); | 512 AddStartURLRequestEntries(&log, 20); |
| 508 | 513 |
| 509 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 514 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 510 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 515 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 511 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(11)); | 516 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 11)); |
| 512 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 517 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 513 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 518 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 514 NetLog::PHASE_BEGIN, NULL); | 519 NetLog::PHASE_BEGIN, NULL); |
| 515 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 520 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 516 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 521 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 517 NetLog::PHASE_END, NULL); | 522 NetLog::PHASE_END, NULL); |
| 518 | 523 |
| 519 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 524 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 520 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 525 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 521 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(21)); | 526 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 21)); |
| 522 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 527 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 523 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 528 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 524 NetLog::PHASE_BEGIN, NULL); | 529 NetLog::PHASE_BEGIN, NULL); |
| 525 log.OnAddEntry(NetLog::TYPE_TCP_CONNECT , base::TimeTicks(), | 530 log.OnAddEntry(NetLog::TYPE_TCP_CONNECT , base::TimeTicks(), |
| 526 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 531 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 527 NetLog::PHASE_NONE, NULL); | 532 NetLog::PHASE_NONE, NULL); |
| 528 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 533 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 529 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), | 534 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 21), |
| 530 NetLog::PHASE_END, NULL); | 535 NetLog::PHASE_END, NULL); |
| 531 | 536 |
| (...skipping 11 matching lines...) Expand all Loading... |
| 543 NetLog::PHASE_END, NULL); | 548 NetLog::PHASE_END, NULL); |
| 544 | 549 |
| 545 requests = log.url_request_tracker()->GetLiveRequests(); | 550 requests = log.url_request_tracker()->GetLiveRequests(); |
| 546 EXPECT_EQ(2u, requests.size()); | 551 EXPECT_EQ(2u, requests.size()); |
| 547 | 552 |
| 548 EXPECT_EQ(5u, requests[0].entries.size()); | 553 EXPECT_EQ(5u, requests[0].entries.size()); |
| 549 EXPECT_EQ(6u, requests[1].entries.size()); | 554 EXPECT_EQ(6u, requests[1].entries.size()); |
| 550 | 555 |
| 551 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 556 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 552 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 557 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 553 NetLog::PHASE_END, new net::NetLogIntegerParameter(21)); | 558 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 21)); |
| 554 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 559 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 555 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 560 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 556 NetLog::PHASE_END, new net::NetLogIntegerParameter(31)); | 561 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 31)); |
| 557 | 562 |
| 558 requests = log.url_request_tracker()->GetLiveRequests(); | 563 requests = log.url_request_tracker()->GetLiveRequests(); |
| 559 EXPECT_EQ(2u, requests.size()); | 564 EXPECT_EQ(2u, requests.size()); |
| 560 | 565 |
| 561 EXPECT_EQ(7u, requests[0].entries.size()); | 566 EXPECT_EQ(7u, requests[0].entries.size()); |
| 562 EXPECT_EQ(8u, requests[1].entries.size()); | 567 EXPECT_EQ(8u, requests[1].entries.size()); |
| 563 | 568 |
| 564 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 569 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 565 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 570 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 566 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 571 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 567 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 572 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 568 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 573 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 569 NetLog::PHASE_END, new net::NetLogIntegerParameter(25)); | 574 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 25)); |
| 570 | 575 |
| 571 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 576 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 572 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 577 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 573 NetLog::PHASE_NONE, NULL); | 578 NetLog::PHASE_NONE, NULL); |
| 574 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 579 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 575 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 580 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 576 NetLog::PHASE_BEGIN, NULL); | 581 NetLog::PHASE_BEGIN, NULL); |
| 577 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 582 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 578 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 583 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 579 NetLog::PHASE_END, NULL); | 584 NetLog::PHASE_END, NULL); |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 630 NetLog::PHASE_END, NULL); | 635 NetLog::PHASE_END, NULL); |
| 631 | 636 |
| 632 requests = log.url_request_tracker()->GetLiveRequests(); | 637 requests = log.url_request_tracker()->GetLiveRequests(); |
| 633 EXPECT_EQ(2u, requests.size()); | 638 EXPECT_EQ(2u, requests.size()); |
| 634 | 639 |
| 635 EXPECT_EQ(2u, requests[0].entries.size()); | 640 EXPECT_EQ(2u, requests[0].entries.size()); |
| 636 EXPECT_EQ(2u, requests[1].entries.size()); | 641 EXPECT_EQ(2u, requests[1].entries.size()); |
| 637 | 642 |
| 638 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 643 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 639 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 644 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 640 NetLog::PHASE_END, new net::NetLogIntegerParameter(11)); | 645 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 11)); |
| 641 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 646 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 642 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 647 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 643 NetLog::PHASE_END, new net::NetLogIntegerParameter(21)); | 648 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 21)); |
| 644 | 649 |
| 645 requests = log.url_request_tracker()->GetLiveRequests(); | 650 requests = log.url_request_tracker()->GetLiveRequests(); |
| 646 EXPECT_EQ(2u, requests.size()); | 651 EXPECT_EQ(2u, requests.size()); |
| 647 | 652 |
| 648 EXPECT_EQ(5u, requests[0].entries.size()); | 653 EXPECT_EQ(5u, requests[0].entries.size()); |
| 649 EXPECT_EQ(6u, requests[1].entries.size()); | 654 EXPECT_EQ(6u, requests[1].entries.size()); |
| 650 | 655 |
| 651 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 656 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 652 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 657 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 653 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 658 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 654 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 659 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 655 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 660 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 656 NetLog::PHASE_END, new net::NetLogIntegerParameter(25)); | 661 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 25)); |
| 657 | 662 |
| 658 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 663 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 659 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 664 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 660 NetLog::PHASE_NONE, NULL); | 665 NetLog::PHASE_NONE, NULL); |
| 661 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 666 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 662 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 667 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 663 NetLog::PHASE_BEGIN, NULL); | 668 NetLog::PHASE_BEGIN, NULL); |
| 664 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 669 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 665 NetLog::Source(NetLog::SOURCE_SOCKET, 25), | 670 NetLog::Source(NetLog::SOURCE_SOCKET, 25), |
| 666 NetLog::PHASE_END, NULL); | 671 NetLog::PHASE_END, NULL); |
| (...skipping 27 matching lines...) Expand all Loading... |
| 694 PassiveLogCollector log; | 699 PassiveLogCollector log; |
| 695 | 700 |
| 696 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 701 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 697 EXPECT_EQ(0u, requests.size()); | 702 EXPECT_EQ(0u, requests.size()); |
| 698 | 703 |
| 699 AddStartURLRequestEntries(&log, 10); | 704 AddStartURLRequestEntries(&log, 10); |
| 700 | 705 |
| 701 // Initial socket. | 706 // Initial socket. |
| 702 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 707 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 703 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 708 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 704 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 709 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 705 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 710 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 706 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 711 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 707 NetLog::PHASE_NONE, NULL); | 712 NetLog::PHASE_NONE, NULL); |
| 708 | 713 |
| 709 requests = log.url_request_tracker()->GetLiveRequests(); | 714 requests = log.url_request_tracker()->GetLiveRequests(); |
| 710 EXPECT_EQ(1u, requests.size()); | 715 EXPECT_EQ(1u, requests.size()); |
| 711 EXPECT_EQ(4u, requests[0].entries.size()); | 716 EXPECT_EQ(4u, requests[0].entries.size()); |
| 712 | 717 |
| 713 // Reconnect. | 718 // Reconnect. |
| 714 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 719 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 715 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 720 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 716 NetLog::PHASE_END, new net::NetLogIntegerParameter(17)); | 721 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 17)); |
| 717 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 722 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 718 NetLog::Source(NetLog::SOURCE_SOCKET, 17), | 723 NetLog::Source(NetLog::SOURCE_SOCKET, 17), |
| 719 NetLog::PHASE_NONE, NULL); | 724 NetLog::PHASE_NONE, NULL); |
| 720 | 725 |
| 721 requests = log.url_request_tracker()->GetLiveRequests(); | 726 requests = log.url_request_tracker()->GetLiveRequests(); |
| 722 EXPECT_EQ(1u, requests.size()); | 727 EXPECT_EQ(1u, requests.size()); |
| 723 EXPECT_EQ(6u, requests[0].entries.size()); | 728 EXPECT_EQ(6u, requests[0].entries.size()); |
| 724 | 729 |
| 725 AddEndURLRequestEntries(&log, 10); | 730 AddEndURLRequestEntries(&log, 10); |
| 726 | 731 |
| (...skipping 13 matching lines...) Expand all Loading... |
| 740 PassiveLogCollector log; | 745 PassiveLogCollector log; |
| 741 | 746 |
| 742 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 747 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 743 EXPECT_EQ(0u, requests.size()); | 748 EXPECT_EQ(0u, requests.size()); |
| 744 | 749 |
| 745 AddStartURLRequestEntries(&log, 10); | 750 AddStartURLRequestEntries(&log, 10); |
| 746 | 751 |
| 747 // Initial socket. | 752 // Initial socket. |
| 748 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 753 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 749 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 754 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 750 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 755 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 751 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 756 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 752 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 757 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 753 NetLog::PHASE_NONE, NULL); | 758 NetLog::PHASE_NONE, NULL); |
| 754 | 759 |
| 755 requests = log.url_request_tracker()->GetLiveRequests(); | 760 requests = log.url_request_tracker()->GetLiveRequests(); |
| 756 EXPECT_EQ(1u, requests.size()); | 761 EXPECT_EQ(1u, requests.size()); |
| 757 EXPECT_EQ(4u, requests[0].entries.size()); | 762 EXPECT_EQ(4u, requests[0].entries.size()); |
| 758 | 763 |
| 759 // Now reconnect. | 764 // Now reconnect. |
| 760 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 765 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 761 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 766 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 762 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(11)); | 767 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 11)); |
| 763 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 768 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 764 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 769 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 765 NetLog::PHASE_BEGIN, NULL); | 770 NetLog::PHASE_BEGIN, NULL); |
| 766 | 771 |
| 767 requests = log.url_request_tracker()->GetLiveRequests(); | 772 requests = log.url_request_tracker()->GetLiveRequests(); |
| 768 EXPECT_EQ(1u, requests.size()); | 773 EXPECT_EQ(1u, requests.size()); |
| 769 EXPECT_EQ(6u, requests[0].entries.size()); | 774 EXPECT_EQ(6u, requests[0].entries.size()); |
| 770 | 775 |
| 771 // But we get late bound to an idle socket. | 776 // But we get late bound to an idle socket. |
| 772 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 777 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 773 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 778 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 774 NetLog::PHASE_END, new net::NetLogIntegerParameter(17)); | 779 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 17)); |
| 775 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 780 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 776 NetLog::Source(NetLog::SOURCE_SOCKET, 17), | 781 NetLog::Source(NetLog::SOURCE_SOCKET, 17), |
| 777 NetLog::PHASE_NONE, NULL); | 782 NetLog::PHASE_NONE, NULL); |
| 778 | 783 |
| 779 requests = log.url_request_tracker()->GetLiveRequests(); | 784 requests = log.url_request_tracker()->GetLiveRequests(); |
| 780 EXPECT_EQ(1u, requests.size()); | 785 EXPECT_EQ(1u, requests.size()); |
| 781 EXPECT_EQ(7u, requests[0].entries.size()); | 786 EXPECT_EQ(7u, requests[0].entries.size()); |
| 782 | 787 |
| 783 AddEndURLRequestEntries(&log, 10); | 788 AddEndURLRequestEntries(&log, 10); |
| 784 | 789 |
| (...skipping 13 matching lines...) Expand all Loading... |
| 798 PassiveLogCollector log; | 803 PassiveLogCollector log; |
| 799 | 804 |
| 800 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 805 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 801 EXPECT_EQ(0u, requests.size()); | 806 EXPECT_EQ(0u, requests.size()); |
| 802 | 807 |
| 803 AddStartURLRequestEntries(&log, 10); | 808 AddStartURLRequestEntries(&log, 10); |
| 804 | 809 |
| 805 // Initial socket. | 810 // Initial socket. |
| 806 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 811 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 807 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 812 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 808 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 813 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 809 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 814 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 810 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 815 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 811 NetLog::PHASE_NONE, NULL); | 816 NetLog::PHASE_NONE, NULL); |
| 812 | 817 |
| 813 requests = log.url_request_tracker()->GetLiveRequests(); | 818 requests = log.url_request_tracker()->GetLiveRequests(); |
| 814 EXPECT_EQ(1u, requests.size()); | 819 EXPECT_EQ(1u, requests.size()); |
| 815 EXPECT_EQ(4u, requests[0].entries.size()); | 820 EXPECT_EQ(4u, requests[0].entries.size()); |
| 816 | 821 |
| 817 // Now reconnect. | 822 // Now reconnect. |
| 818 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 823 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 819 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 824 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 820 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(11)); | 825 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 11)); |
| 821 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 826 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 822 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 827 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 823 NetLog::PHASE_BEGIN, NULL); | 828 NetLog::PHASE_BEGIN, NULL); |
| 824 | 829 |
| 825 requests = log.url_request_tracker()->GetLiveRequests(); | 830 requests = log.url_request_tracker()->GetLiveRequests(); |
| 826 EXPECT_EQ(1u, requests.size()); | 831 EXPECT_EQ(1u, requests.size()); |
| 827 EXPECT_EQ(6u, requests[0].entries.size()); | 832 EXPECT_EQ(6u, requests[0].entries.size()); |
| 828 | 833 |
| 829 // But we get late bound to a different ConnectJob. | 834 // But we get late bound to a different ConnectJob. |
| 830 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 835 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 831 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 12), | 836 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 12), |
| 832 NetLog::PHASE_BEGIN, NULL); | 837 NetLog::PHASE_BEGIN, NULL); |
| 833 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 838 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 834 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 12), | 839 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 12), |
| 835 NetLog::PHASE_END, NULL); | 840 NetLog::PHASE_END, NULL); |
| 836 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 841 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 837 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 842 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 838 NetLog::PHASE_END, new net::NetLogIntegerParameter(12)); | 843 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 12)); |
| 839 | 844 |
| 840 requests = log.url_request_tracker()->GetLiveRequests(); | 845 requests = log.url_request_tracker()->GetLiveRequests(); |
| 841 EXPECT_EQ(1u, requests.size()); | 846 EXPECT_EQ(1u, requests.size()); |
| 842 EXPECT_EQ(8u, requests[0].entries.size()); | 847 EXPECT_EQ(8u, requests[0].entries.size()); |
| 843 | 848 |
| 844 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 849 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 845 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 850 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 846 NetLog::PHASE_END, new net::NetLogIntegerParameter(17)); | 851 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 17)); |
| 847 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 852 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 848 NetLog::Source(NetLog::SOURCE_SOCKET, 17), | 853 NetLog::Source(NetLog::SOURCE_SOCKET, 17), |
| 849 NetLog::PHASE_NONE, NULL); | 854 NetLog::PHASE_NONE, NULL); |
| 850 | 855 |
| 851 requests = log.url_request_tracker()->GetLiveRequests(); | 856 requests = log.url_request_tracker()->GetLiveRequests(); |
| 852 EXPECT_EQ(1u, requests.size()); | 857 EXPECT_EQ(1u, requests.size()); |
| 853 EXPECT_EQ(10u, requests[0].entries.size()); | 858 EXPECT_EQ(10u, requests[0].entries.size()); |
| 854 | 859 |
| 855 AddEndURLRequestEntries(&log, 10); | 860 AddEndURLRequestEntries(&log, 10); |
| 856 | 861 |
| (...skipping 12 matching lines...) Expand all Loading... |
| 869 TEST(PassiveLogCollectorTest, LostConnectJob) { | 874 TEST(PassiveLogCollectorTest, LostConnectJob) { |
| 870 PassiveLogCollector log; | 875 PassiveLogCollector log; |
| 871 | 876 |
| 872 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 877 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 873 EXPECT_EQ(0u, requests.size()); | 878 EXPECT_EQ(0u, requests.size()); |
| 874 | 879 |
| 875 AddStartURLRequestEntries(&log, 10); | 880 AddStartURLRequestEntries(&log, 10); |
| 876 | 881 |
| 877 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 882 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 878 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 883 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 879 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter(11)); | 884 NetLog::PHASE_BEGIN, new net::NetLogIntegerParameter("x", 11)); |
| 880 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 885 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 881 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 886 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 882 NetLog::PHASE_BEGIN, NULL); | 887 NetLog::PHASE_BEGIN, NULL); |
| 883 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 888 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 884 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 889 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 885 NetLog::PHASE_NONE, NULL); | 890 NetLog::PHASE_NONE, NULL); |
| 886 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), | 891 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB , base::TimeTicks(), |
| 887 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), | 892 NetLog::Source(NetLog::SOURCE_CONNECT_JOB, 11), |
| 888 NetLog::PHASE_END, NULL); | 893 NetLog::PHASE_END, NULL); |
| 889 | 894 |
| 890 requests = log.url_request_tracker()->GetLiveRequests(); | 895 requests = log.url_request_tracker()->GetLiveRequests(); |
| 891 EXPECT_EQ(1u, requests.size()); | 896 EXPECT_EQ(1u, requests.size()); |
| 892 EXPECT_EQ(6u, requests[0].entries.size()); | 897 EXPECT_EQ(6u, requests[0].entries.size()); |
| 893 | 898 |
| 894 log.connect_job_tracker_.Clear(); | 899 log.connect_job_tracker_.Clear(); |
| 895 | 900 |
| 896 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), | 901 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_CONNECT_JOB_ID , base::TimeTicks(), |
| 897 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 902 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 898 NetLog::PHASE_END, new net::NetLogIntegerParameter(11)); | 903 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 11)); |
| 899 | 904 |
| 900 requests = log.url_request_tracker()->GetLiveRequests(); | 905 requests = log.url_request_tracker()->GetLiveRequests(); |
| 901 EXPECT_EQ(1u, requests.size()); | 906 EXPECT_EQ(1u, requests.size()); |
| 902 EXPECT_EQ(5u, requests[0].entries.size()); | 907 EXPECT_EQ(5u, requests[0].entries.size()); |
| 903 } | 908 } |
| 904 | 909 |
| 905 TEST(PassiveLogCollectorTest, LostSocket) { | 910 TEST(PassiveLogCollectorTest, LostSocket) { |
| 906 PassiveLogCollector log; | 911 PassiveLogCollector log; |
| 907 | 912 |
| 908 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 913 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 909 EXPECT_EQ(0u, requests.size()); | 914 EXPECT_EQ(0u, requests.size()); |
| 910 | 915 |
| 911 AddStartURLRequestEntries(&log, 10); | 916 AddStartURLRequestEntries(&log, 10); |
| 912 | 917 |
| 913 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 918 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 914 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 919 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 915 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 920 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 916 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 921 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 917 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 922 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 918 NetLog::PHASE_BEGIN, NULL); | 923 NetLog::PHASE_BEGIN, NULL); |
| 919 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 924 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 920 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 925 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 921 NetLog::PHASE_END, NULL); | 926 NetLog::PHASE_END, NULL); |
| 922 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 927 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| 923 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 928 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 924 NetLog::PHASE_BEGIN, NULL); | 929 NetLog::PHASE_BEGIN, NULL); |
| 925 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), | 930 log.OnAddEntry(NetLog::TYPE_SSL_CONNECT , base::TimeTicks(), |
| (...skipping 14 matching lines...) Expand all Loading... |
| 940 TEST(PassiveLogCollectorTest, AccumulateRxTxData) { | 945 TEST(PassiveLogCollectorTest, AccumulateRxTxData) { |
| 941 PassiveLogCollector log; | 946 PassiveLogCollector log; |
| 942 | 947 |
| 943 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); | 948 RequestInfoList requests = log.url_request_tracker()->GetLiveRequests(); |
| 944 EXPECT_EQ(0u, requests.size()); | 949 EXPECT_EQ(0u, requests.size()); |
| 945 | 950 |
| 946 AddStartURLRequestEntries(&log, 10); | 951 AddStartURLRequestEntries(&log, 10); |
| 947 | 952 |
| 948 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 953 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 949 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), | 954 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 10), |
| 950 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 955 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 951 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 956 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 952 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 957 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 953 NetLog::PHASE_NONE, NULL); | 958 NetLog::PHASE_NONE, NULL); |
| 954 | 959 |
| 955 requests = log.url_request_tracker()->GetLiveRequests(); | 960 requests = log.url_request_tracker()->GetLiveRequests(); |
| 956 EXPECT_EQ(1u, requests.size()); | 961 EXPECT_EQ(1u, requests.size()); |
| 957 EXPECT_EQ(4u, requests[0].entries.size()); | 962 EXPECT_EQ(4u, requests[0].entries.size()); |
| 958 | 963 |
| 959 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_SENT , base::TimeTicks(), | 964 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_SENT , base::TimeTicks(), |
| 960 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 965 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 961 NetLog::PHASE_END, new net::NetLogIntegerParameter(1)); | 966 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 1)); |
| 962 requests = log.url_request_tracker()->GetLiveRequests(); | 967 requests = log.url_request_tracker()->GetLiveRequests(); |
| 963 EXPECT_EQ(1u, requests.size()); | 968 EXPECT_EQ(1u, requests.size()); |
| 964 EXPECT_EQ(5u, requests[0].entries.size()); | 969 EXPECT_EQ(5u, requests[0].entries.size()); |
| 965 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); | 970 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); |
| 966 EXPECT_EQ("Tx/Rx: 1/0 [1/0 total on socket] (Bytes)", | 971 EXPECT_EQ("Tx/Rx: 1/0 [1/0 total on socket] (Bytes)", |
| 967 requests[0].entries[4].extra_parameters->ToString()); | 972 GetStringParam(requests[0].entries[4])); |
| 968 | 973 |
| 969 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_RECEIVED , base::TimeTicks(), | 974 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_RECEIVED , base::TimeTicks(), |
| 970 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 975 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 971 NetLog::PHASE_END, new net::NetLogIntegerParameter(2)); | 976 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 2)); |
| 972 requests = log.url_request_tracker()->GetLiveRequests(); | 977 requests = log.url_request_tracker()->GetLiveRequests(); |
| 973 EXPECT_EQ(1u, requests.size()); | 978 EXPECT_EQ(1u, requests.size()); |
| 974 EXPECT_EQ(5u, requests[0].entries.size()); | 979 EXPECT_EQ(5u, requests[0].entries.size()); |
| 975 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); | 980 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); |
| 976 EXPECT_EQ("Tx/Rx: 1/2 [1/2 total on socket] (Bytes)", | 981 EXPECT_EQ("Tx/Rx: 1/2 [1/2 total on socket] (Bytes)", |
| 977 requests[0].entries[4].extra_parameters->ToString()); | 982 GetStringParam(requests[0].entries[4])); |
| 978 | 983 |
| 979 AddEndURLRequestEntries(&log, 10); | 984 AddEndURLRequestEntries(&log, 10); |
| 980 requests = log.url_request_tracker()->GetLiveRequests(); | 985 requests = log.url_request_tracker()->GetLiveRequests(); |
| 981 EXPECT_EQ(0u, requests.size()); | 986 EXPECT_EQ(0u, requests.size()); |
| 982 requests = log.url_request_tracker()->GetRecentlyDeceased(); | 987 requests = log.url_request_tracker()->GetRecentlyDeceased(); |
| 983 EXPECT_EQ(1u, requests.size()); | 988 EXPECT_EQ(1u, requests.size()); |
| 984 EXPECT_EQ(6u, requests[0].entries.size()); | 989 EXPECT_EQ(6u, requests[0].entries.size()); |
| 985 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); | 990 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); |
| 986 EXPECT_EQ("Tx/Rx: 1/2 [1/2 total on socket] (Bytes)", | 991 EXPECT_EQ("Tx/Rx: 1/2 [1/2 total on socket] (Bytes)", |
| 987 requests[0].entries[4].extra_parameters->ToString()); | 992 GetStringParam(requests[0].entries[4])); |
| 988 | 993 |
| 989 AddStartURLRequestEntries(&log, 20); | 994 AddStartURLRequestEntries(&log, 20); |
| 990 | 995 |
| 991 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), | 996 log.OnAddEntry(NetLog::TYPE_SOCKET_POOL_SOCKET_ID , base::TimeTicks(), |
| 992 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), | 997 NetLog::Source(NetLog::SOURCE_URL_REQUEST, 20), |
| 993 NetLog::PHASE_END, new net::NetLogIntegerParameter(15)); | 998 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 15)); |
| 994 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), | 999 log.OnAddEntry(NetLog::TYPE_SOCKS_CONNECT , base::TimeTicks(), |
| 995 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 1000 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 996 NetLog::PHASE_NONE, NULL); | 1001 NetLog::PHASE_NONE, NULL); |
| 997 | 1002 |
| 998 requests = log.url_request_tracker()->GetLiveRequests(); | 1003 requests = log.url_request_tracker()->GetLiveRequests(); |
| 999 EXPECT_EQ(1u, requests.size()); | 1004 EXPECT_EQ(1u, requests.size()); |
| 1000 EXPECT_EQ(4u, requests[0].entries.size()); | 1005 EXPECT_EQ(4u, requests[0].entries.size()); |
| 1001 | 1006 |
| 1002 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_SENT , base::TimeTicks(), | 1007 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_SENT , base::TimeTicks(), |
| 1003 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 1008 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 1004 NetLog::PHASE_END, new net::NetLogIntegerParameter(4)); | 1009 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 4)); |
| 1005 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_RECEIVED , base::TimeTicks(), | 1010 log.OnAddEntry(NetLog::TYPE_SOCKET_BYTES_RECEIVED , base::TimeTicks(), |
| 1006 NetLog::Source(NetLog::SOURCE_SOCKET, 15), | 1011 NetLog::Source(NetLog::SOURCE_SOCKET, 15), |
| 1007 NetLog::PHASE_END, new net::NetLogIntegerParameter(8)); | 1012 NetLog::PHASE_END, new net::NetLogIntegerParameter("x", 8)); |
| 1008 requests = log.url_request_tracker()->GetLiveRequests(); | 1013 requests = log.url_request_tracker()->GetLiveRequests(); |
| 1009 EXPECT_EQ(1u, requests.size()); | 1014 EXPECT_EQ(1u, requests.size()); |
| 1010 EXPECT_EQ(5u, requests[0].entries.size()); | 1015 EXPECT_EQ(5u, requests[0].entries.size()); |
| 1011 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); | 1016 EXPECT_EQ(NetLog::TYPE_TODO_STRING, requests[0].entries[4].type); |
| 1012 EXPECT_EQ("Tx/Rx: 4/8 [5/10 total on socket] (Bytes)", | 1017 EXPECT_EQ("Tx/Rx: 4/8 [5/10 total on socket] (Bytes)", |
| 1013 requests[0].entries[4].extra_parameters->ToString()); | 1018 GetStringParam(requests[0].entries[4])); |
| 1014 | 1019 |
| 1015 AddEndURLRequestEntries(&log, 20); | 1020 AddEndURLRequestEntries(&log, 20); |
| 1016 requests = log.url_request_tracker()->GetLiveRequests(); | 1021 requests = log.url_request_tracker()->GetLiveRequests(); |
| 1017 EXPECT_EQ(0u, requests.size()); | 1022 EXPECT_EQ(0u, requests.size()); |
| 1018 requests = log.url_request_tracker()->GetRecentlyDeceased(); | 1023 requests = log.url_request_tracker()->GetRecentlyDeceased(); |
| 1019 EXPECT_EQ(2u, requests.size()); | 1024 EXPECT_EQ(2u, requests.size()); |
| 1020 EXPECT_EQ(6u, requests[0].entries.size()); | 1025 EXPECT_EQ(6u, requests[0].entries.size()); |
| 1021 EXPECT_EQ(6u, requests[1].entries.size()); | 1026 EXPECT_EQ(6u, requests[1].entries.size()); |
| 1022 } | 1027 } |
| OLD | NEW |