| Index: sync/notifier/invalidation_notifier_unittest.cc
|
| diff --git a/sync/notifier/invalidation_notifier_unittest.cc b/sync/notifier/invalidation_notifier_unittest.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..223fb28239b1b26f5fc51d56b38c5b9cd060bc0c
|
| --- /dev/null
|
| +++ b/sync/notifier/invalidation_notifier_unittest.cc
|
| @@ -0,0 +1,92 @@
|
| +// 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/invalidation_notifier.h"
|
| +
|
| +#include "base/memory/scoped_ptr.h"
|
| +#include "base/message_loop/message_loop.h"
|
| +#include "jingle/notifier/base/fake_base_task.h"
|
| +#include "jingle/notifier/base/notifier_options.h"
|
| +#include "jingle/notifier/listener/fake_push_client.h"
|
| +#include "net/url_request/url_request_test_util.h"
|
| +#include "sync/internal_api/public/base/model_type.h"
|
| +#include "sync/internal_api/public/util/weak_handle.h"
|
| +#include "sync/notifier/fake_invalidation_handler.h"
|
| +#include "sync/notifier/fake_invalidation_state_tracker.h"
|
| +#include "sync/notifier/invalidation_state_tracker.h"
|
| +#include "sync/notifier/invalidator_test_template.h"
|
| +#include "sync/notifier/push_client_channel.h"
|
| +#include "testing/gtest/include/gtest/gtest.h"
|
| +
|
| +namespace syncer {
|
| +
|
| +namespace {
|
| +
|
| +class InvalidationNotifierTestDelegate {
|
| + public:
|
| + InvalidationNotifierTestDelegate() {}
|
| +
|
| + ~InvalidationNotifierTestDelegate() {
|
| + DestroyInvalidator();
|
| + }
|
| +
|
| + void CreateInvalidator(
|
| + const std::string& invalidator_client_id,
|
| + const std::string& initial_state,
|
| + const base::WeakPtr<InvalidationStateTracker>&
|
| + invalidation_state_tracker) {
|
| + DCHECK(!invalidator_.get());
|
| + scoped_ptr<notifier::PushClient> push_client(
|
| + new notifier::FakePushClient());
|
| + scoped_ptr<SyncNetworkChannel> network_channel(
|
| + new PushClientChannel(push_client.Pass()));
|
| + invalidator_.reset(
|
| + new InvalidationNotifier(
|
| + network_channel.Pass(),
|
| + invalidator_client_id,
|
| + UnackedInvalidationsMap(),
|
| + initial_state,
|
| + MakeWeakHandle(invalidation_state_tracker),
|
| + "fake_client_info"));
|
| + }
|
| +
|
| + Invalidator* GetInvalidator() {
|
| + return invalidator_.get();
|
| + }
|
| +
|
| + void DestroyInvalidator() {
|
| + // Stopping the invalidation notifier stops its scheduler, which deletes
|
| + // any pending tasks without running them. Some tasks "run and delete"
|
| + // another task, so they must be run in order to avoid leaking the inner
|
| + // task. Stopping does not schedule any tasks, so it's both necessary and
|
| + // sufficient to drain the task queue before stopping the notifier.
|
| + message_loop_.RunUntilIdle();
|
| + invalidator_.reset();
|
| + }
|
| +
|
| + void WaitForInvalidator() {
|
| + message_loop_.RunUntilIdle();
|
| + }
|
| +
|
| + void TriggerOnInvalidatorStateChange(InvalidatorState state) {
|
| + invalidator_->OnInvalidatorStateChange(state);
|
| + }
|
| +
|
| + void TriggerOnIncomingInvalidation(
|
| + const ObjectIdInvalidationMap& invalidation_map) {
|
| + invalidator_->OnInvalidate(invalidation_map);
|
| + }
|
| +
|
| + private:
|
| + base::MessageLoop message_loop_;
|
| + scoped_ptr<InvalidationNotifier> invalidator_;
|
| +};
|
| +
|
| +INSTANTIATE_TYPED_TEST_CASE_P(
|
| + InvalidationNotifierTest, InvalidatorTest,
|
| + InvalidationNotifierTestDelegate);
|
| +
|
| +} // namespace
|
| +
|
| +} // namespace syncer
|
|
|