Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 <string> | 5 #include <string> |
| 6 | 6 |
| 7 #include "base/test/simple_test_tick_clock.h" | 7 #include "base/test/simple_test_tick_clock.h" |
| 8 #include "extensions/browser/api/cast_channel/cast_auth_util.h" | 8 #include "extensions/browser/api/cast_channel/cast_auth_util.h" |
| 9 #include "extensions/browser/api/cast_channel/logger.h" | 9 #include "extensions/browser/api/cast_channel/logger.h" |
| 10 #include "extensions/browser/api/cast_channel/logger_util.h" | 10 #include "extensions/browser/api/cast_channel/logger_util.h" |
| (...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 114 logger_->LogSocketChallengeReplyEvent(2, auth_result); | 114 logger_->LogSocketChallengeReplyEvent(2, auth_result); |
| 115 | 115 |
| 116 LastErrors last_errors = logger_->GetLastErrors(2); | 116 LastErrors last_errors = logger_->GetLastErrors(2); |
| 117 EXPECT_EQ(last_errors.event_type, proto::AUTH_CHALLENGE_REPLY); | 117 EXPECT_EQ(last_errors.event_type, proto::AUTH_CHALLENGE_REPLY); |
| 118 EXPECT_EQ(last_errors.net_return_value, net::OK); | 118 EXPECT_EQ(last_errors.net_return_value, net::OK); |
| 119 EXPECT_EQ(last_errors.challenge_reply_error_type, | 119 EXPECT_EQ(last_errors.challenge_reply_error_type, |
| 120 proto::CHALLENGE_REPLY_ERROR_CERT_PARSING_FAILED); | 120 proto::CHALLENGE_REPLY_ERROR_CERT_PARSING_FAILED); |
| 121 EXPECT_EQ(last_errors.nss_error_code, kTestNssErrorCode); | 121 EXPECT_EQ(last_errors.nss_error_code, kTestNssErrorCode); |
| 122 | 122 |
| 123 scoped_ptr<Log> log = GetLog(); | 123 scoped_ptr<Log> log = GetLog(); |
| 124 ASSERT_TRUE(log.get() != NULL); | 124 ASSERT_TRUE(log.get() != nullptr); |
| 125 | 125 |
| 126 ASSERT_EQ(2, log->aggregated_socket_event_size()); | 126 ASSERT_EQ(2, log->aggregated_socket_event_size()); |
| 127 { | 127 { |
| 128 const AggregatedSocketEvent& aggregated_socket_event = | 128 const AggregatedSocketEvent& aggregated_socket_event = |
| 129 log->aggregated_socket_event(0); | 129 log->aggregated_socket_event(0); |
| 130 EXPECT_EQ(1, aggregated_socket_event.id()); | 130 EXPECT_EQ(1, aggregated_socket_event.id()); |
| 131 EXPECT_EQ(3, aggregated_socket_event.socket_event_size()); | 131 EXPECT_EQ(3, aggregated_socket_event.socket_event_size()); |
| 132 { | 132 { |
| 133 const SocketEvent& event = aggregated_socket_event.socket_event(0); | 133 const SocketEvent& event = aggregated_socket_event.socket_event(0); |
| 134 EXPECT_EQ(EventType::CAST_SOCKET_CREATED, event.type()); | 134 EXPECT_EQ(EventType::CAST_SOCKET_CREATED, event.type()); |
| (...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 250 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); | 250 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); |
| 251 | 251 |
| 252 logger_->LogSocketEventWithRv(2, EventType::SOCKET_READ, 100); | 252 logger_->LogSocketEventWithRv(2, EventType::SOCKET_READ, 100); |
| 253 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); | 253 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); |
| 254 logger_->LogSocketEventWithRv(2, EventType::SOCKET_WRITE, 100); | 254 logger_->LogSocketEventWithRv(2, EventType::SOCKET_WRITE, 100); |
| 255 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); | 255 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); |
| 256 logger_->LogSocketEventWithRv(2, EventType::SOCKET_WRITE, -5); | 256 logger_->LogSocketEventWithRv(2, EventType::SOCKET_WRITE, -5); |
| 257 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); | 257 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); |
| 258 | 258 |
| 259 scoped_ptr<Log> log = GetLog(); | 259 scoped_ptr<Log> log = GetLog(); |
| 260 ASSERT_TRUE(log.get() != NULL); | 260 ASSERT_TRUE(log.get() != nullptr); |
|
imcheng
2015/01/15 19:26:45
ASSERT_TRUE(log.get()); same for below.
Kevin M
2015/01/27 00:56:45
Done.
| |
| 261 | 261 |
| 262 ASSERT_EQ(2, log->aggregated_socket_event_size()); | 262 ASSERT_EQ(2, log->aggregated_socket_event_size()); |
| 263 { | 263 { |
| 264 const AggregatedSocketEvent& aggregated_socket_event = | 264 const AggregatedSocketEvent& aggregated_socket_event = |
| 265 log->aggregated_socket_event(0); | 265 log->aggregated_socket_event(0); |
| 266 EXPECT_EQ(1, aggregated_socket_event.id()); | 266 EXPECT_EQ(1, aggregated_socket_event.id()); |
| 267 EXPECT_EQ(4, aggregated_socket_event.socket_event_size()); | 267 EXPECT_EQ(4, aggregated_socket_event.socket_event_size()); |
| 268 EXPECT_EQ(80, aggregated_socket_event.bytes_read()); | 268 EXPECT_EQ(80, aggregated_socket_event.bytes_read()); |
| 269 EXPECT_EQ(20, aggregated_socket_event.bytes_written()); | 269 EXPECT_EQ(20, aggregated_socket_event.bytes_written()); |
| 270 } | 270 } |
| 271 { | 271 { |
| 272 const AggregatedSocketEvent& aggregated_socket_event = | 272 const AggregatedSocketEvent& aggregated_socket_event = |
| 273 log->aggregated_socket_event(1); | 273 log->aggregated_socket_event(1); |
| 274 EXPECT_EQ(2, aggregated_socket_event.id()); | 274 EXPECT_EQ(2, aggregated_socket_event.id()); |
| 275 EXPECT_EQ(3, aggregated_socket_event.socket_event_size()); | 275 EXPECT_EQ(3, aggregated_socket_event.socket_event_size()); |
| 276 EXPECT_EQ(100, aggregated_socket_event.bytes_read()); | 276 EXPECT_EQ(100, aggregated_socket_event.bytes_read()); |
| 277 EXPECT_EQ(100, aggregated_socket_event.bytes_written()); | 277 EXPECT_EQ(100, aggregated_socket_event.bytes_written()); |
| 278 } | 278 } |
| 279 } | 279 } |
| 280 | 280 |
| 281 TEST_F(CastChannelLoggerTest, TooManySockets) { | 281 TEST_F(CastChannelLoggerTest, TooManySockets) { |
| 282 for (int i = 0; i < kMaxSocketsToLog + 5; i++) { | 282 for (int i = 0; i < kMaxSocketsToLog + 5; i++) { |
| 283 logger_->LogSocketEvent(i, EventType::CAST_SOCKET_CREATED); | 283 logger_->LogSocketEvent(i, EventType::CAST_SOCKET_CREATED); |
| 284 } | 284 } |
| 285 | 285 |
| 286 scoped_ptr<Log> log = GetLog(); | 286 scoped_ptr<Log> log = GetLog(); |
| 287 ASSERT_TRUE(log.get() != NULL); | 287 ASSERT_TRUE(log.get() != nullptr); |
| 288 | 288 |
| 289 ASSERT_EQ(kMaxSocketsToLog, log->aggregated_socket_event_size()); | 289 ASSERT_EQ(kMaxSocketsToLog, log->aggregated_socket_event_size()); |
| 290 EXPECT_EQ(5, log->num_evicted_aggregated_socket_events()); | 290 EXPECT_EQ(5, log->num_evicted_aggregated_socket_events()); |
| 291 EXPECT_EQ(5, log->num_evicted_socket_events()); | 291 EXPECT_EQ(5, log->num_evicted_socket_events()); |
| 292 | 292 |
| 293 const AggregatedSocketEvent& aggregated_socket_event = | 293 const AggregatedSocketEvent& aggregated_socket_event = |
| 294 log->aggregated_socket_event(0); | 294 log->aggregated_socket_event(0); |
| 295 EXPECT_EQ(5, aggregated_socket_event.id()); | 295 EXPECT_EQ(5, aggregated_socket_event.id()); |
| 296 } | 296 } |
| 297 | 297 |
| 298 TEST_F(CastChannelLoggerTest, TooManyEvents) { | 298 TEST_F(CastChannelLoggerTest, TooManyEvents) { |
| 299 for (int i = 0; i < kMaxEventsPerSocket + 5; i++) { | 299 for (int i = 0; i < kMaxEventsPerSocket + 5; i++) { |
| 300 logger_->LogSocketEvent(1, EventType::CAST_SOCKET_CREATED); | 300 logger_->LogSocketEvent(1, EventType::CAST_SOCKET_CREATED); |
| 301 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); | 301 clock_->Advance(base::TimeDelta::FromMicroseconds(1)); |
| 302 } | 302 } |
| 303 | 303 |
| 304 scoped_ptr<Log> log = GetLog(); | 304 scoped_ptr<Log> log = GetLog(); |
| 305 ASSERT_TRUE(log.get() != NULL); | 305 ASSERT_TRUE(log.get() != nullptr); |
| 306 | 306 |
| 307 ASSERT_EQ(1, log->aggregated_socket_event_size()); | 307 ASSERT_EQ(1, log->aggregated_socket_event_size()); |
| 308 EXPECT_EQ(0, log->num_evicted_aggregated_socket_events()); | 308 EXPECT_EQ(0, log->num_evicted_aggregated_socket_events()); |
| 309 EXPECT_EQ(5, log->num_evicted_socket_events()); | 309 EXPECT_EQ(5, log->num_evicted_socket_events()); |
| 310 | 310 |
| 311 const AggregatedSocketEvent& aggregated_socket_event = | 311 const AggregatedSocketEvent& aggregated_socket_event = |
| 312 log->aggregated_socket_event(0); | 312 log->aggregated_socket_event(0); |
| 313 ASSERT_EQ(kMaxEventsPerSocket, aggregated_socket_event.socket_event_size()); | 313 ASSERT_EQ(kMaxEventsPerSocket, aggregated_socket_event.socket_event_size()); |
| 314 EXPECT_EQ(5, aggregated_socket_event.socket_event(0).timestamp_micros()); | 314 EXPECT_EQ(5, aggregated_socket_event.socket_event(0).timestamp_micros()); |
| 315 } | 315 } |
| 316 | 316 |
| 317 TEST_F(CastChannelLoggerTest, Reset) { | 317 TEST_F(CastChannelLoggerTest, Reset) { |
| 318 logger_->LogSocketEvent(1, EventType::CAST_SOCKET_CREATED); | 318 logger_->LogSocketEvent(1, EventType::CAST_SOCKET_CREATED); |
| 319 | 319 |
| 320 scoped_ptr<Log> log = GetLog(); | 320 scoped_ptr<Log> log = GetLog(); |
| 321 ASSERT_TRUE(log.get() != NULL); | 321 ASSERT_TRUE(log.get() != nullptr); |
| 322 | 322 |
| 323 EXPECT_EQ(1, log->aggregated_socket_event_size()); | 323 EXPECT_EQ(1, log->aggregated_socket_event_size()); |
| 324 | 324 |
| 325 logger_->Reset(); | 325 logger_->Reset(); |
| 326 | 326 |
| 327 log = GetLog(); | 327 log = GetLog(); |
| 328 ASSERT_TRUE(log.get() != NULL); | 328 ASSERT_TRUE(log.get() != nullptr); |
| 329 | 329 |
| 330 EXPECT_EQ(0, log->aggregated_socket_event_size()); | 330 EXPECT_EQ(0, log->aggregated_socket_event_size()); |
| 331 } | 331 } |
| 332 | 332 |
| 333 } // namespace cast_channel | 333 } // namespace cast_channel |
| 334 } // namespace core_api | 334 } // namespace core_api |
| 335 } // namespace extensions | 335 } // namespace extensions |
| OLD | NEW |