Index: net/base/network_activity_monitor_unittest.cc |
diff --git a/net/base/network_activity_monitor_unittest.cc b/net/base/network_activity_monitor_unittest.cc |
deleted file mode 100644 |
index e625c55409d1510253f7b536f01e3282d36581ed..0000000000000000000000000000000000000000 |
--- a/net/base/network_activity_monitor_unittest.cc |
+++ /dev/null |
@@ -1,131 +0,0 @@ |
-// Copyright (c) 2014 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "net/base/network_activity_monitor.h" |
- |
-#include <vector> |
- |
-#include "base/bind.h" |
-#include "base/port.h" |
-#include "base/stl_util.h" |
-#include "base/strings/string_number_conversions.h" |
-#include "base/synchronization/lock.h" |
-#include "base/threading/thread.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-namespace net { |
- |
-namespace test { |
- |
-class NetworkActivityMonitorPeer { |
- public: |
- static void ResetMonitor() { |
- NetworkActivityMonitor* monitor = NetworkActivityMonitor::GetInstance(); |
- base::AutoLock lock(monitor->lock_); |
- monitor->bytes_sent_ = 0; |
- monitor->bytes_received_ = 0; |
- monitor->last_received_ticks_ = base::TimeTicks(); |
- monitor->last_sent_ticks_ = base::TimeTicks(); |
- } |
-}; |
- |
- |
-class NetworkActivityMontiorTest : public testing::Test { |
- public: |
- NetworkActivityMontiorTest() { |
- NetworkActivityMonitorPeer::ResetMonitor(); |
- } |
-}; |
- |
-TEST_F(NetworkActivityMontiorTest, GetInstance) { |
- NetworkActivityMonitor* monitor = NetworkActivityMonitor::GetInstance(); |
- EXPECT_TRUE(monitor != NULL); |
- EXPECT_TRUE(monitor == NetworkActivityMonitor::GetInstance()); |
-} |
- |
-TEST_F(NetworkActivityMontiorTest, BytesReceived) { |
- NetworkActivityMonitor* monitor = NetworkActivityMonitor::GetInstance(); |
- |
- EXPECT_EQ(0u, monitor->GetBytesReceived()); |
- |
- base::TimeTicks start = base::TimeTicks::Now(); |
- uint64_t bytes = 12345; |
- monitor->IncrementBytesReceived(bytes); |
- EXPECT_EQ(bytes, monitor->GetBytesReceived()); |
- base::TimeDelta delta = monitor->GetTimeSinceLastReceived(); |
- EXPECT_LE(base::TimeDelta(), delta); |
- EXPECT_GE(base::TimeTicks::Now() - start, delta); |
-} |
- |
-TEST_F(NetworkActivityMontiorTest, BytesSent) { |
- NetworkActivityMonitor* monitor = NetworkActivityMonitor::GetInstance(); |
- |
- EXPECT_EQ(0u, monitor->GetBytesSent()); |
- |
- base::TimeTicks start = base::TimeTicks::Now(); |
- uint64_t bytes = 12345; |
- monitor->IncrementBytesSent(bytes); |
- EXPECT_EQ(bytes, monitor->GetBytesSent()); |
- base::TimeDelta delta = monitor->GetTimeSinceLastSent(); |
- EXPECT_LE(base::TimeDelta(), delta); |
- EXPECT_GE(base::TimeTicks::Now() - start, delta); |
-} |
- |
-namespace { |
- |
-void VerifyBytesReceivedIsMultipleOf(uint64_t bytes) { |
- EXPECT_EQ(0u, |
- NetworkActivityMonitor::GetInstance()->GetBytesReceived() % bytes); |
-} |
- |
-void VerifyBytesSentIsMultipleOf(uint64_t bytes) { |
- EXPECT_EQ(0u, NetworkActivityMonitor::GetInstance()->GetBytesSent() % bytes); |
-} |
- |
-void IncrementBytesReceived(uint64_t bytes) { |
- NetworkActivityMonitor::GetInstance()->IncrementBytesReceived(bytes); |
-} |
- |
-void IncrementBytesSent(uint64_t bytes) { |
- NetworkActivityMonitor::GetInstance()->IncrementBytesSent(bytes); |
-} |
- |
-} // namespace |
- |
-TEST_F(NetworkActivityMontiorTest, Threading) { |
- std::vector<base::Thread*> threads; |
- for (size_t i = 0; i < 3; ++i) { |
- threads.push_back(new base::Thread(base::UintToString(i))); |
- ASSERT_TRUE(threads.back()->Start()); |
- } |
- |
- size_t num_increments = 157; |
- uint64_t bytes_received = GG_UINT64_C(7294954321); |
- uint64_t bytes_sent = GG_UINT64_C(91294998765); |
- for (size_t i = 0; i < num_increments; ++i) { |
- size_t thread_num = i % threads.size(); |
- threads[thread_num]->task_runner()->PostTask( |
- FROM_HERE, |
- base::Bind(&IncrementBytesReceived, bytes_received)); |
- threads[thread_num]->task_runner()->PostTask( |
- FROM_HERE, |
- base::Bind(&IncrementBytesSent, bytes_sent)); |
- threads[thread_num]->task_runner()->PostTask( |
- FROM_HERE, |
- base::Bind(&VerifyBytesSentIsMultipleOf, bytes_sent)); |
- threads[thread_num]->task_runner()->PostTask( |
- FROM_HERE, |
- base::Bind(&VerifyBytesReceivedIsMultipleOf, bytes_received)); |
- } |
- |
- STLDeleteElements(&threads); |
- |
- NetworkActivityMonitor* monitor = NetworkActivityMonitor::GetInstance(); |
- EXPECT_EQ(num_increments * bytes_received, monitor->GetBytesReceived()); |
- EXPECT_EQ(num_increments * bytes_sent, monitor->GetBytesSent()); |
-} |
- |
-} // namespace test |
- |
-} // namespace net |