Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(419)

Unified Diff: sync/notifier/sync_system_resources_unittest.cc

Issue 294123004: Move some sync/notifier to components/invalidation (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « sync/notifier/sync_system_resources.cc ('k') | sync/notifier/unacked_invalidation_set.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sync/notifier/sync_system_resources_unittest.cc
diff --git a/sync/notifier/sync_system_resources_unittest.cc b/sync/notifier/sync_system_resources_unittest.cc
deleted file mode 100644
index 8acc729d27a5aabcbd219c4ea9aeb8d4328d1fc6..0000000000000000000000000000000000000000
--- a/sync/notifier/sync_system_resources_unittest.cc
+++ /dev/null
@@ -1,249 +0,0 @@
-// Copyright (c) 2012 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 "sync/notifier/sync_system_resources.h"
-
-#include <string>
-
-#include "base/bind.h"
-#include "base/bind_helpers.h"
-#include "base/callback.h"
-#include "base/message_loop/message_loop.h"
-
-#include "google/cacheinvalidation/include/types.h"
-#include "jingle/notifier/listener/fake_push_client.h"
-#include "sync/notifier/push_client_channel.h"
-#include "sync/notifier/state_writer.h"
-#include "testing/gmock/include/gmock/gmock.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-namespace syncer {
-namespace {
-
-using ::testing::_;
-using ::testing::SaveArg;
-
-class MockStateWriter : public StateWriter {
- public:
- MOCK_METHOD1(WriteState, void(const std::string&));
-};
-
-class MockClosure {
- public:
- MOCK_CONST_METHOD0(Run, void(void));
- base::Closure* CreateClosure() {
- return new base::Closure(
- base::Bind(&MockClosure::Run, base::Unretained(this)));
- }
-};
-
-class MockStorageCallback {
- public:
- MOCK_CONST_METHOD1(Run, void(invalidation::Status));
- base::Callback<void(invalidation::Status)>* CreateCallback() {
- return new base::Callback<void(invalidation::Status)>(
- base::Bind(&MockStorageCallback::Run, base::Unretained(this)));
- }
-};
-
-class SyncSystemResourcesTest : public testing::Test {
- protected:
- SyncSystemResourcesTest()
- : push_client_channel_(
- scoped_ptr<notifier::PushClient>(new notifier::FakePushClient())),
- sync_system_resources_(&push_client_channel_, &mock_state_writer_) {}
-
- virtual ~SyncSystemResourcesTest() {}
-
- void ScheduleShouldNotRun() {
- {
- // Owned by ScheduleImmediately.
- MockClosure mock_closure;
- base::Closure* should_not_run = mock_closure.CreateClosure();
- EXPECT_CALL(mock_closure, Run()).Times(0);
- sync_system_resources_.internal_scheduler()->Schedule(
- invalidation::Scheduler::NoDelay(), should_not_run);
- }
- {
- // Owned by ScheduleOnListenerThread.
- MockClosure mock_closure;
- base::Closure* should_not_run = mock_closure.CreateClosure();
- EXPECT_CALL(mock_closure, Run()).Times(0);
- sync_system_resources_.listener_scheduler()->Schedule(
- invalidation::Scheduler::NoDelay(), should_not_run);
- }
- {
- // Owned by ScheduleWithDelay.
- MockClosure mock_closure;
- base::Closure* should_not_run = mock_closure.CreateClosure();
- EXPECT_CALL(mock_closure, Run()).Times(0);
- sync_system_resources_.internal_scheduler()->Schedule(
- invalidation::TimeDelta::FromSeconds(0), should_not_run);
- }
- }
-
- // Needed by |sync_system_resources_|.
- base::MessageLoop message_loop_;
- MockStateWriter mock_state_writer_;
- PushClientChannel push_client_channel_;
- SyncSystemResources sync_system_resources_;
-
- private:
- DISALLOW_COPY_AND_ASSIGN(SyncSystemResourcesTest);
-};
-
-// Make sure current_time() doesn't crash or leak.
-TEST_F(SyncSystemResourcesTest, CurrentTime) {
- invalidation::Time current_time =
- sync_system_resources_.internal_scheduler()->GetCurrentTime();
- DVLOG(1) << "current_time returned: " << current_time.ToInternalValue();
-}
-
-// Make sure Log() doesn't crash or leak.
-TEST_F(SyncSystemResourcesTest, Log) {
- sync_system_resources_.logger()->Log(SyncLogger::INFO_LEVEL,
- __FILE__, __LINE__, "%s %d",
- "test string", 5);
-}
-
-TEST_F(SyncSystemResourcesTest, ScheduleBeforeStart) {
- ScheduleShouldNotRun();
- sync_system_resources_.Start();
-}
-
-TEST_F(SyncSystemResourcesTest, ScheduleAfterStop) {
- sync_system_resources_.Start();
- sync_system_resources_.Stop();
- ScheduleShouldNotRun();
-}
-
-TEST_F(SyncSystemResourcesTest, ScheduleAndStop) {
- sync_system_resources_.Start();
- ScheduleShouldNotRun();
- sync_system_resources_.Stop();
-}
-
-TEST_F(SyncSystemResourcesTest, ScheduleAndDestroy) {
- sync_system_resources_.Start();
- ScheduleShouldNotRun();
-}
-
-TEST_F(SyncSystemResourcesTest, ScheduleImmediately) {
- sync_system_resources_.Start();
- MockClosure mock_closure;
- EXPECT_CALL(mock_closure, Run());
- sync_system_resources_.internal_scheduler()->Schedule(
- invalidation::Scheduler::NoDelay(), mock_closure.CreateClosure());
- message_loop_.RunUntilIdle();
-}
-
-TEST_F(SyncSystemResourcesTest, ScheduleOnListenerThread) {
- sync_system_resources_.Start();
- MockClosure mock_closure;
- EXPECT_CALL(mock_closure, Run());
- sync_system_resources_.listener_scheduler()->Schedule(
- invalidation::Scheduler::NoDelay(), mock_closure.CreateClosure());
- EXPECT_TRUE(
- sync_system_resources_.internal_scheduler()->IsRunningOnThread());
- message_loop_.RunUntilIdle();
-}
-
-TEST_F(SyncSystemResourcesTest, ScheduleWithZeroDelay) {
- sync_system_resources_.Start();
- MockClosure mock_closure;
- EXPECT_CALL(mock_closure, Run());
- sync_system_resources_.internal_scheduler()->Schedule(
- invalidation::TimeDelta::FromSeconds(0), mock_closure.CreateClosure());
- message_loop_.RunUntilIdle();
-}
-
-// TODO(akalin): Figure out how to test with a non-zero delay.
-
-TEST_F(SyncSystemResourcesTest, WriteState) {
- sync_system_resources_.Start();
- EXPECT_CALL(mock_state_writer_, WriteState(_));
- // Owned by WriteState.
- MockStorageCallback mock_storage_callback;
- invalidation::Status results(invalidation::Status::PERMANENT_FAILURE,
- "fake-failure");
- EXPECT_CALL(mock_storage_callback, Run(_))
- .WillOnce(SaveArg<0>(&results));
- sync_system_resources_.storage()->WriteKey(
- std::string(), "state", mock_storage_callback.CreateCallback());
- message_loop_.RunUntilIdle();
- EXPECT_EQ(invalidation::Status(invalidation::Status::SUCCESS, std::string()),
- results);
-}
-
-class TestSyncNetworkChannel : public SyncNetworkChannel {
- public:
- TestSyncNetworkChannel() {}
- virtual ~TestSyncNetworkChannel() {}
-
- using SyncNetworkChannel::NotifyStateChange;
- using SyncNetworkChannel::DeliverIncomingMessage;
-
- virtual void SendMessage(const std::string& message) OVERRIDE {
- }
-
- virtual void UpdateCredentials(const std::string& email,
- const std::string& token) OVERRIDE {
- }
-
- virtual int GetInvalidationClientType() OVERRIDE {
- return 0;
- }
-
- virtual void RequestDetailedStatus(
- base::Callback<void(const base::DictionaryValue&)> callback) OVERRIDE {
- base::DictionaryValue value;
- callback.Run(value);
- }
-};
-
-class SyncNetworkChannelTest
- : public testing::Test,
- public SyncNetworkChannel::Observer {
- protected:
- SyncNetworkChannelTest()
- : last_invalidator_state_(DEFAULT_INVALIDATION_ERROR),
- connected_(false) {
- network_channel_.AddObserver(this);
- network_channel_.AddNetworkStatusReceiver(
- invalidation::NewPermanentCallback(
- this, &SyncNetworkChannelTest::OnNetworkStatusChange));
- }
-
- virtual ~SyncNetworkChannelTest() {
- network_channel_.RemoveObserver(this);
- }
-
- virtual void OnNetworkChannelStateChanged(
- InvalidatorState invalidator_state) OVERRIDE {
- last_invalidator_state_ = invalidator_state;
- }
-
- void OnNetworkStatusChange(bool connected) {
- connected_ = connected;
- }
-
- TestSyncNetworkChannel network_channel_;
- InvalidatorState last_invalidator_state_;
- bool connected_;
-};
-
-// Simulate network channel state change. It should propagate to observer.
-TEST_F(SyncNetworkChannelTest, OnNetworkChannelStateChanged) {
- EXPECT_EQ(DEFAULT_INVALIDATION_ERROR, last_invalidator_state_);
- EXPECT_FALSE(connected_);
- network_channel_.NotifyStateChange(INVALIDATIONS_ENABLED);
- EXPECT_EQ(INVALIDATIONS_ENABLED, last_invalidator_state_);
- EXPECT_TRUE(connected_);
- network_channel_.NotifyStateChange(INVALIDATION_CREDENTIALS_REJECTED);
- EXPECT_EQ(INVALIDATION_CREDENTIALS_REJECTED, last_invalidator_state_);
- EXPECT_FALSE(connected_);
-}
-
-} // namespace
-} // namespace syncer
« no previous file with comments | « sync/notifier/sync_system_resources.cc ('k') | sync/notifier/unacked_invalidation_set.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698