sync: beginnings of MessageLoop based SyncerThread

chrome/browser/sync/sessions/sync_session_unittest.cc

 // Copyright (c) 2009 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 "chrome/browser/sync/sessions/sync_session.h"
 
 #include "chrome/browser/sync/engine/conflict_resolver.h"
 #include "chrome/browser/sync/engine/syncer_types.h"
 #include "chrome/browser/sync/engine/syncer_util.h"
 #include "chrome/browser/sync/syncable/directory_manager.h"
@@ skipping 12 matching lines @@
                         public SyncSession::Delegate,
                         public ModelSafeWorkerRegistrar {
  public:
   SyncSessionTest() : controller_invocations_allowed_(false) {
     GetModelSafeRoutingInfo(&routes_);
   }
 
   SyncSession* MakeSession() {
     return new SyncSession(context_.get(), this, SyncSourceInfo(), routes_,
                            std::vector<ModelSafeWorker*>());
-  }  
+  }
 
   virtual void SetUp() {
     context_.reset(new SyncSessionContext(NULL, NULL, this,
         std::vector<SyncEngineEventListener*>()));
     routes_.clear();
     routes_[syncable::BOOKMARKS] = GROUP_UI;
     routes_[syncable::AUTOFILL] = GROUP_UI;
-    session_.reset(MakeSession());
+    session_ = MakeSession();
   }
   virtual void TearDown() {
-    session_.reset();
+    session_ = NULL;
     context_.reset();
   }
 
   virtual void OnSilencedUntil(const base::TimeTicks& silenced_until) {
     FailControllerInvocationIfDisabled("OnSilencedUntil");
   }
   virtual bool IsSyncingCurrentlySilenced() {
     FailControllerInvocationIfDisabled("IsSyncingCurrentlySilenced");
     return false;
   }
@@ skipping 31 matching lines @@
   }
 
   MultiTypeTimeStamp ParamsMeaningJustOneEnabledType() {
     MultiTypeTimeStamp request_params;
     request_params.timestamp = 5000;
     request_params.data_types[syncable::AUTOFILL] = true;
     return request_params;
   }
 
   bool controller_invocations_allowed_;
-  scoped_ptr<SyncSession> session_;
+  scoped_refptr<SyncSession> session_;
   scoped_ptr<SyncSessionContext> context_;
   ModelSafeRoutingInfo routes_;
 };
 
 TEST_F(SyncSessionTest, ScopedContextHelpers) {
   ConflictResolver resolver;
   EXPECT_FALSE(context_->resolver());
   {
     ScopedSessionContextConflictResolver s_resolver(context_.get(), &resolver);
     EXPECT_EQ(&resolver, context_->resolver());
   }
   EXPECT_FALSE(context_->resolver());
 }
 
 TEST_F(SyncSessionTest, SetWriteTransaction) {
   TestDirectorySetterUpper db;
   db.SetUp();
-  session_.reset(NULL);
+  session_ = NULL;
   context_.reset(new SyncSessionContext(NULL, db.manager(), this,
       std::vector<SyncEngineEventListener*>()));
-  session_.reset(MakeSession());
+  session_ = MakeSession();
   context_->set_account_name(db.name());
   syncable::ScopedDirLookup dir(context_->directory_manager(),
                                 context_->account_name());
   ASSERT_TRUE(dir.good());
 
-  scoped_ptr<SyncSession> session(MakeSession());
+  scoped_refptr<SyncSession> session(MakeSession());
   EXPECT_TRUE(NULL == session->write_transaction());
   {
     WriteTransaction trans(dir, syncable::UNITTEST, __FILE__, __LINE__);
     sessions::ScopedSetSessionWriteTransaction set_trans(session.get(), &trans);
     EXPECT_TRUE(&trans == session->write_transaction());
   }
   db.TearDown();
 }
 
 TEST_F(SyncSessionTest, MoreToSyncIfUnsyncedGreaterThanCommitted) {
@@ skipping 87 matching lines @@
   status()->mutable_updates_response()->mutable_get_updates()
       ->set_new_timestamp(1000000L);;
   EXPECT_FALSE(status()->ServerSaysNothingMoreToDownload());
   EXPECT_TRUE(status()->download_updates_succeeded());
 
   // Download updates has its own loop in the syncer; it shouldn't factor
   // into HasMoreToSync.
   EXPECT_FALSE(session_->HasMoreToSync());
 }
 
-
 TEST_F(SyncSessionTest, MoreToSyncIfConflictsResolved) {
   // Conflict resolution happens after get updates and commit,
   // so we need to loop back and get updates / commit again now
   // that we have made forward progress.
   status()->update_conflicts_resolved(true);
   EXPECT_TRUE(session_->HasMoreToSync());
 }
 
+TEST_F(SyncSessionTest, ResetTransientState) {
+  status()->update_conflicts_resolved(true);
+  status()->increment_num_successful_commits();
+  EXPECT_TRUE(session_->HasMoreToSync());
+  session_->ResetTransientState();
+  EXPECT_FALSE(status()->conflicts_resolved());
+  EXPECT_FALSE(session_->HasMoreToSync());
+  EXPECT_FALSE(status()->TestAndClearIsDirty());
+}
+
+TEST_F(SyncSessionTest, Coalesce) {
+
+}
+
 }  // namespace
 }  // namespace sessions
 }  // namespace browser_sync