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

Unified Diff: components/invalidation/mock_ack_handler.cc

Issue 1191393008: Introduce a layering in the invalidation component as public and impl (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Explicitly forbid content to prevent future additions Created 5 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 | « components/invalidation/mock_ack_handler.h ('k') | components/invalidation/non_blocking_invalidator.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: components/invalidation/mock_ack_handler.cc
diff --git a/components/invalidation/mock_ack_handler.cc b/components/invalidation/mock_ack_handler.cc
deleted file mode 100644
index c43ed3312506e9051c0ddd5c821c53dfc2ce7c8a..0000000000000000000000000000000000000000
--- a/components/invalidation/mock_ack_handler.cc
+++ /dev/null
@@ -1,120 +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.
-
-#include "components/invalidation/mock_ack_handler.h"
-
-#include "base/thread_task_runner_handle.h"
-#include "components/invalidation/ack_handle.h"
-#include "components/invalidation/invalidation.h"
-
-namespace syncer {
-
-namespace {
-
-struct AckHandleMatcher {
- AckHandleMatcher(const AckHandle& handle);
- bool operator()(const syncer::Invalidation& invalidation) const;
-
- syncer::AckHandle handle_;
-};
-
-AckHandleMatcher::AckHandleMatcher(const AckHandle& handle)
- : handle_(handle) {}
-
-bool AckHandleMatcher::operator()(
- const syncer::Invalidation& invalidation) const {
- return handle_.Equals(invalidation.ack_handle());
-}
-
-} // namespace
-
-MockAckHandler::MockAckHandler() {}
-
-MockAckHandler::~MockAckHandler() {}
-
-void MockAckHandler::RegisterInvalidation(Invalidation* invalidation) {
- unacked_invalidations_.push_back(*invalidation);
- invalidation->SetAckHandler(AsWeakPtr(), base::ThreadTaskRunnerHandle::Get());
-}
-
-void MockAckHandler::RegisterUnsentInvalidation(Invalidation* invalidation) {
- unsent_invalidations_.push_back(*invalidation);
-}
-
-bool MockAckHandler::IsUnacked(const Invalidation& invalidation) const {
- AckHandleMatcher matcher(invalidation.ack_handle());
- InvalidationVector::const_iterator it = std::find_if(
- unacked_invalidations_.begin(),
- unacked_invalidations_.end(),
- matcher);
- return it != unacked_invalidations_.end();
-}
-
-bool MockAckHandler::IsAcknowledged(const Invalidation& invalidation) const {
- AckHandleMatcher matcher(invalidation.ack_handle());
- InvalidationVector::const_iterator it = std::find_if(
- acked_invalidations_.begin(),
- acked_invalidations_.end(),
- matcher);
- return it != acked_invalidations_.end();
-}
-
-bool MockAckHandler::IsDropped(const Invalidation& invalidation) const {
- AckHandleMatcher matcher(invalidation.ack_handle());
- InvalidationVector::const_iterator it = std::find_if(
- dropped_invalidations_.begin(),
- dropped_invalidations_.end(),
- matcher);
- return it != dropped_invalidations_.end();
-}
-
-bool MockAckHandler::IsUnsent(const Invalidation& invalidation) const {
- AckHandleMatcher matcher(invalidation.ack_handle());
- InvalidationVector::const_iterator it1 = std::find_if(
- unsent_invalidations_.begin(),
- unsent_invalidations_.end(),
- matcher);
- return it1 != unsent_invalidations_.end();
-}
-
-bool MockAckHandler::AllInvalidationsAccountedFor() const {
- return unacked_invalidations_.empty() && unrecovered_drop_events_.empty();
-}
-
-void MockAckHandler::Acknowledge(
- const invalidation::ObjectId& id,
- const AckHandle& handle) {
- AckHandleMatcher matcher(handle);
- InvalidationVector::iterator it = std::find_if(
- unacked_invalidations_.begin(),
- unacked_invalidations_.end(),
- matcher);
- if (it != unacked_invalidations_.end()) {
- acked_invalidations_.push_back(*it);
- unacked_invalidations_.erase(it);
- }
-
- IdHandleMap::iterator it2 = unrecovered_drop_events_.find(id);
- if (it2 != unrecovered_drop_events_.end() && it2->second.Equals(handle)) {
- unrecovered_drop_events_.erase(it2);
- }
-}
-
-void MockAckHandler::Drop(
- const invalidation::ObjectId& id,
- const AckHandle& handle) {
- AckHandleMatcher matcher(handle);
- InvalidationVector::iterator it = std::find_if(
- unacked_invalidations_.begin(),
- unacked_invalidations_.end(),
- matcher);
- if (it != unacked_invalidations_.end()) {
- dropped_invalidations_.push_back(*it);
- unacked_invalidations_.erase(it);
- }
- unrecovered_drop_events_.erase(id);
- unrecovered_drop_events_.insert(std::make_pair(id, handle));
-}
-
-} // namespace syncer
« no previous file with comments | « components/invalidation/mock_ack_handler.h ('k') | components/invalidation/non_blocking_invalidator.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698