1 // Copyright 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 // An implementation of SyncNotifier that wraps InvalidationNotifier
8 #ifndef SYNC_NOTIFIER_NON_BLOCKING_INVALIDATOR_H_
9 #define SYNC_NOTIFIER_NON_BLOCKING_INVALIDATOR_H_
13 #include "base/basictypes.h"
14 #include "base/compiler_specific.h"
15 #include "base/memory/ref_counted.h"
16 #include "base/memory/weak_ptr.h"
17 #include "jingle/notifier/base/notifier_options.h"
18 #include "sync/base/sync_export.h"
19 #include "sync/internal_api/public/util/weak_handle.h"
20 #include "sync/notifier/invalidation_handler.h"
21 #include "sync/notifier/invalidation_state_tracker.h"
22 #include "sync/notifier/invalidator.h"
23 #include "sync/notifier/invalidator_registrar.h"
26 class SingleThreadTaskRunner
;
31 // TODO(akalin): Generalize the interface so it can use any Invalidator.
32 // (http://crbug.com/140409).
33 class SYNC_EXPORT_PRIVATE NonBlockingInvalidator
35 // InvalidationHandler to "observe" our Core via WeakHandle.
36 public InvalidationHandler
{
38 // |invalidation_state_tracker| must be initialized.
39 NonBlockingInvalidator(
40 const notifier::NotifierOptions
& notifier_options
,
41 const InvalidationStateMap
& initial_invalidation_state_map
,
42 const std::string
& invalidation_bootstrap_data
,
43 const WeakHandle
<InvalidationStateTracker
>&
44 invalidation_state_tracker
,
45 const std::string
& client_info
);
47 virtual ~NonBlockingInvalidator();
49 // Invalidator implementation.
50 virtual void RegisterHandler(InvalidationHandler
* handler
) OVERRIDE
;
51 virtual void UpdateRegisteredIds(InvalidationHandler
* handler
,
52 const ObjectIdSet
& ids
) OVERRIDE
;
53 virtual void UnregisterHandler(InvalidationHandler
* handler
) OVERRIDE
;
54 virtual InvalidatorState
GetInvalidatorState() const OVERRIDE
;
55 virtual void SetUniqueId(const std::string
& unique_id
) OVERRIDE
;
56 virtual void SetStateDeprecated(const std::string
& state
) OVERRIDE
;
57 virtual void UpdateCredentials(
58 const std::string
& email
, const std::string
& token
) OVERRIDE
;
59 virtual void SendInvalidation(
60 const ObjectIdInvalidationMap
& invalidation_map
) OVERRIDE
;
62 // InvalidationHandler implementation.
63 virtual void OnInvalidatorStateChange(InvalidatorState state
) OVERRIDE
;
64 virtual void OnIncomingInvalidation(
65 const ObjectIdInvalidationMap
& invalidation_map
,
66 IncomingInvalidationSource source
) OVERRIDE
;
71 base::WeakPtrFactory
<NonBlockingInvalidator
> weak_ptr_factory_
;
73 InvalidatorRegistrar registrar_
;
75 // The real guts of NonBlockingInvalidator, which allows this class to live
76 // completely on the parent thread.
77 scoped_refptr
<Core
> core_
;
78 scoped_refptr
<base::SingleThreadTaskRunner
> parent_task_runner_
;
79 scoped_refptr
<base::SingleThreadTaskRunner
> network_task_runner_
;
81 DISALLOW_COPY_AND_ASSIGN(NonBlockingInvalidator
);
86 #endif // SYNC_NOTIFIER_NON_BLOCKING_INVALIDATOR_H_