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

Unified Diff: sync/engine/non_blocking_type_processor.h

Issue 351523003: sync: Mass rename of non-blocking sync classes (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: const ref some smart pointers Created 6 years, 6 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/engine/non_blocking_type_commit_contribution.cc ('k') | sync/engine/non_blocking_type_processor.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sync/engine/non_blocking_type_processor.h
diff --git a/sync/engine/non_blocking_type_processor.h b/sync/engine/non_blocking_type_processor.h
deleted file mode 100644
index da680f199f5a6339f94c076e00b419adc3171ba0..0000000000000000000000000000000000000000
--- a/sync/engine/non_blocking_type_processor.h
+++ /dev/null
@@ -1,138 +0,0 @@
-// Copyright 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.
-
-#ifndef SYNC_ENGINE_NON_BLOCKING_TYPE_PROCESSOR_H_
-#define SYNC_ENGINE_NON_BLOCKING_TYPE_PROCESSOR_H_
-
-#include "base/memory/weak_ptr.h"
-#include "base/stl_util.h"
-#include "base/threading/non_thread_safe.h"
-#include "sync/base/sync_export.h"
-#include "sync/engine/non_blocking_sync_common.h"
-#include "sync/internal_api/public/base/model_type.h"
-#include "sync/protocol/sync.pb.h"
-
-namespace syncer {
-
-class SyncCoreProxy;
-class ModelThreadSyncEntity;
-class NonBlockingTypeProcessorCoreInterface;
-
-// A sync component embedded on the synced type's thread that helps to handle
-// communication between sync and model type threads.
-class SYNC_EXPORT_PRIVATE NonBlockingTypeProcessor : base::NonThreadSafe {
- public:
- NonBlockingTypeProcessor(ModelType type);
- virtual ~NonBlockingTypeProcessor();
-
- // Returns true if this object believes that sync is preferred for this type.
- //
- // By "preferred", we mean that a policy decision has been made that this
- // type should be synced. Most of the time this is controlled by a user
- // clicking a checkbox on the settings page.
- //
- // The canonical preferred state is based on SyncPrefs on the UI thread. At
- // best, this value is stale and may lag behind the one set on the UI thread.
- // Before this type has registered with the UI thread, it's mostly just an
- // informed guess.
- bool IsPreferred() const;
-
- // Returns true if the handshake with sync thread is complete.
- bool IsConnected() const;
-
- // Returns the model type handled by this processor.
- ModelType GetModelType() const;
-
- // Starts the handshake with the sync thread.
- void Enable(scoped_ptr<SyncCoreProxy> core_proxy);
-
- // Severs all ties to the sync thread and may delete local sync state.
- // Another call to Enable() can be used to re-establish this connection.
- void Disable();
-
- // Severs all ties to the sync thread.
- // Another call to Enable() can be used to re-establish this connection.
- void Disconnect();
-
- // Callback used to process the handshake response.
- void OnConnect(
- scoped_ptr<NonBlockingTypeProcessorCoreInterface> core_interface);
-
- // Requests that an item be stored in sync.
- void Put(const std::string& client_tag,
- const sync_pb::EntitySpecifics& specifics);
-
- // Deletes an item from sync.
- void Delete(const std::string& client_tag);
-
- // Informs this object that some of its commit requests have been
- // successfully serviced.
- void OnCommitCompletion(const DataTypeState& type_state,
- const CommitResponseDataList& response_list);
-
- // Informs this object that there are some incoming updates is should
- // handle.
- void OnUpdateReceived(const DataTypeState& type_state,
- const UpdateResponseDataList& response_list);
-
- // Returns the long-lived WeakPtr that is intended to be registered with the
- // ProfileSyncService.
- base::WeakPtr<NonBlockingTypeProcessor> AsWeakPtrForUI();
-
- private:
- typedef std::map<std::string, ModelThreadSyncEntity*> EntityMap;
-
- // Sends all commit requests that are due to be sent to the sync thread.
- void FlushPendingCommitRequests();
-
- // Clears any state related to outstanding communications with the
- // NonBlockingTypeProcessorCore. Used when we want to disconnect from
- // the current core.
- void ClearTransientSyncState();
-
- // Clears any state related to our communications with the current sync
- // account. Useful when a user signs out of the current account.
- void ClearSyncState();
-
- ModelType type_;
- DataTypeState data_type_state_;
-
- // Whether or not sync is preferred for this type. This is a cached copy of
- // the canonical copy information on the UI thread.
- bool is_preferred_;
-
- // Whether or not this object has completed its initial handshake with the
- // SyncCoreProxy.
- bool is_connected_;
-
- // Our link to data type management on the sync thread.
- // Used for enabling and disabling sync for this type.
- //
- // Beware of NULL pointers: This object is uninitialized when we are not
- // connected to sync.
- scoped_ptr<SyncCoreProxy> sync_core_proxy_;
-
- // Reference to the NonBlockingTypeProcessorCore.
- //
- // The interface hides the posting of tasks across threads as well as the
- // NonBlockingTypeProcessorCore's implementation. Both of these features are
- // useful in tests.
- scoped_ptr<NonBlockingTypeProcessorCoreInterface> core_interface_;
-
- // The set of sync entities known to this object.
- EntityMap entities_;
- STLValueDeleter<EntityMap> entities_deleter_;
-
- // We use two different WeakPtrFactories because we want the pointers they
- // issue to have different lifetimes. When asked to disconnect from the sync
- // thread, we want to make sure that no tasks generated as part of the
- // now-obsolete connection to affect us. But we also want the WeakPtr we
- // sent to the UI thread to remain valid.
- base::WeakPtrFactory<NonBlockingTypeProcessor> weak_ptr_factory_for_ui_;
- base::WeakPtrFactory<NonBlockingTypeProcessor> weak_ptr_factory_for_sync_;
-};
-
-} // namespace syncer
-
-#endif // SYNC_ENGINE_NON_BLOCKING_TYPE_PROCESSOR_H_
« no previous file with comments | « sync/engine/non_blocking_type_commit_contribution.cc ('k') | sync/engine/non_blocking_type_processor.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698