| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "sync/notifier/invalidation_notifier.h" | 5 #include "sync/notifier/invalidation_notifier.h" |
| 6 | 6 |
| 7 #include "base/memory/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
| 8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
| 9 #include "jingle/notifier/base/fake_base_task.h" | 9 #include "jingle/notifier/base/fake_base_task.h" |
| 10 #include "jingle/notifier/base/notifier_options.h" | 10 #include "jingle/notifier/base/notifier_options.h" |
| 11 #include "jingle/notifier/listener/fake_push_client.h" | 11 #include "jingle/notifier/listener/fake_push_client.h" |
| 12 #include "net/url_request/url_request_test_util.h" | 12 #include "net/url_request/url_request_test_util.h" |
| 13 #include "sync/internal_api/public/syncable/model_type.h" | 13 #include "sync/internal_api/public/syncable/model_type.h" |
| 14 #include "sync/internal_api/public/syncable/model_type_payload_map.h" | 14 #include "sync/internal_api/public/syncable/model_type_payload_map.h" |
| 15 #include "sync/internal_api/public/util/weak_handle.h" | 15 #include "sync/internal_api/public/util/weak_handle.h" |
| 16 #include "sync/notifier/invalidation_state_tracker.h" | 16 #include "sync/notifier/invalidation_state_tracker.h" |
| 17 #include "sync/notifier/mock_invalidation_state_tracker.h" | 17 #include "sync/notifier/mock_invalidation_state_tracker.h" |
| 18 #include "sync/notifier/mock_sync_notifier_observer.h" | 18 #include "sync/notifier/mock_sync_notifier_observer.h" |
| 19 #include "testing/gmock/include/gmock/gmock.h" | 19 #include "testing/gmock/include/gmock/gmock.h" |
| 20 #include "testing/gtest/include/gtest/gtest.h" | 20 #include "testing/gtest/include/gtest/gtest.h" |
| 21 | 21 |
| 22 namespace csync { | 22 namespace syncer { |
| 23 | 23 |
| 24 namespace { | 24 namespace { |
| 25 | 25 |
| 26 using ::testing::InSequence; | 26 using ::testing::InSequence; |
| 27 using ::testing::StrictMock; | 27 using ::testing::StrictMock; |
| 28 | 28 |
| 29 class InvalidationNotifierTest : public testing::Test { | 29 class InvalidationNotifierTest : public testing::Test { |
| 30 protected: | 30 protected: |
| 31 virtual void TearDown() { | 31 virtual void TearDown() { |
| 32 if (invalidation_notifier_.get()) | 32 if (invalidation_notifier_.get()) |
| 33 ResetNotifier(); | 33 ResetNotifier(); |
| 34 } | 34 } |
| 35 | 35 |
| 36 // Constructs an InvalidationNotifier, places it in | 36 // Constructs an InvalidationNotifier, places it in |
| 37 // |invalidation_notifier_|, and adds |mock_observer_| as an observer. This | 37 // |invalidation_notifier_|, and adds |mock_observer_| as an observer. This |
| 38 // remains in place until either TearDown (automatic) or ResetNotifier | 38 // remains in place until either TearDown (automatic) or ResetNotifier |
| 39 // (manual) is called. | 39 // (manual) is called. |
| 40 void CreateAndObserveNotifier( | 40 void CreateAndObserveNotifier( |
| 41 const std::string& initial_invalidation_state) { | 41 const std::string& initial_invalidation_state) { |
| 42 notifier::NotifierOptions notifier_options; | 42 notifier::NotifierOptions notifier_options; |
| 43 // Note: URLRequestContextGetters are ref-counted. | 43 // Note: URLRequestContextGetters are ref-counted. |
| 44 notifier_options.request_context_getter = | 44 notifier_options.request_context_getter = |
| 45 new TestURLRequestContextGetter(message_loop_.message_loop_proxy()); | 45 new TestURLRequestContextGetter(message_loop_.message_loop_proxy()); |
| 46 invalidation_notifier_.reset( | 46 invalidation_notifier_.reset( |
| 47 new InvalidationNotifier( | 47 new InvalidationNotifier( |
| 48 scoped_ptr<notifier::PushClient>(new notifier::FakePushClient()), | 48 scoped_ptr<notifier::PushClient>(new notifier::FakePushClient()), |
| 49 InvalidationVersionMap(), | 49 InvalidationVersionMap(), |
| 50 initial_invalidation_state, | 50 initial_invalidation_state, |
| 51 csync::MakeWeakHandle(mock_tracker_.AsWeakPtr()), | 51 syncer::MakeWeakHandle(mock_tracker_.AsWeakPtr()), |
| 52 "fake_client_info")); | 52 "fake_client_info")); |
| 53 invalidation_notifier_->AddObserver(&mock_observer_); | 53 invalidation_notifier_->AddObserver(&mock_observer_); |
| 54 } | 54 } |
| 55 | 55 |
| 56 void ResetNotifier() { | 56 void ResetNotifier() { |
| 57 invalidation_notifier_->RemoveObserver(&mock_observer_); | 57 invalidation_notifier_->RemoveObserver(&mock_observer_); |
| 58 // Stopping the invalidation notifier stops its scheduler, which deletes any | 58 // Stopping the invalidation notifier stops its scheduler, which deletes any |
| 59 // pending tasks without running them. Some tasks "run and delete" another | 59 // pending tasks without running them. Some tasks "run and delete" another |
| 60 // task, so they must be run in order to avoid leaking the inner task. | 60 // task, so they must be run in order to avoid leaking the inner task. |
| 61 // Stopping does not schedule any tasks, so it's both necessary and | 61 // Stopping does not schedule any tasks, so it's both necessary and |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 120 // Pretend Chrome shut down. | 120 // Pretend Chrome shut down. |
| 121 ResetNotifier(); | 121 ResetNotifier(); |
| 122 | 122 |
| 123 CreateAndObserveNotifier("fake_state"); | 123 CreateAndObserveNotifier("fake_state"); |
| 124 // Should do nothing. | 124 // Should do nothing. |
| 125 invalidation_notifier_->SetStateDeprecated("more_spurious_fake_state"); | 125 invalidation_notifier_->SetStateDeprecated("more_spurious_fake_state"); |
| 126 } | 126 } |
| 127 | 127 |
| 128 } // namespace | 128 } // namespace |
| 129 | 129 |
| 130 } // namespace csync | 130 } // namespace syncer |
| OLD | NEW |