sync: beginnings of MessageLoop based SyncerThread

chrome/browser/sync/engine/syncer_thread.cc

 // Copyright (c) 2010 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/engine/syncer_thread.h"
 
 #include "build/build_config.h"
 
 #if defined(OS_MACOSX)
 #include <CoreFoundation/CFNumber.h>
 #include <IOKit/IOTypes.h>
@@ skipping 318 matching lines @@
         // off the queue and wait for that delta.  If it was a spurious signal,
         // we'll keep waiting for the same moment in time as we just were.
         continue;
        }
     }
 
     // Handle a nudge, caused by either a notification or a local bookmark
     // event.  This will also update the source of the following SyncMain call.
     VLOG(1) << "Calling Sync Main at time " << Time::Now().ToInternalValue();
     bool nudged = false;
-    scoped_ptr<SyncSession> session;
-    session.reset(SyncMain(vault_.syncer_,
-        throttled, continue_sync_cycle, &initial_sync_for_thread, &nudged));
+    scoped_refptr<SyncSession> session;
+    session = SyncMain(vault_.syncer_,
+        throttled, continue_sync_cycle, &initial_sync_for_thread, &nudged);
 
     // Update timing information for how often these datatypes are triggering
     // nudges.
     base::TimeTicks now = TimeTicks::Now();
     for (size_t i = syncable::FIRST_REAL_MODEL_TYPE;
          i < session->source().second.size();
          ++i) {
       if (session->source().second[i]) {
         syncable::PostTimeToTypeHistogram(syncable::ModelType(i),
                                           now - last_sync_time);
@@ skipping 176 matching lines @@
   // are not currently silenced so reset this state for the next session which
   // may need to use it.
   silenced_until_ = base::TimeTicks();
 
   ModelSafeRoutingInfo routes;
   std::vector<ModelSafeWorker*> workers;
   session_context_->registrar()->GetModelSafeRoutingInfo(&routes);
   session_context_->registrar()->GetWorkers(&workers);
   SyncSourceInfo info(GetAndResetNudgeSource(was_throttled,
       continue_sync_cycle, initial_sync_for_thread, was_nudged));
-  scoped_ptr<SyncSession> session;
+  scoped_refptr<SyncSession> session;
 
   AutoUnlock unlock(lock_);
   do {
-    session.reset(new SyncSession(session_context_.get(), this,
-                                  info, routes, workers));
+    session = new SyncSession(session_context_.get(), this,
+                              info, routes, workers);
     VLOG(1) << "Calling SyncShare.";
     syncer->SyncShare(session.get());
   } while (session->HasMoreToSync() && silenced_until_.is_null());
 
   VLOG(1) << "Done calling SyncShare.";
   return session.release();
 }
 
 SyncSourceInfo SyncerThread::GetAndResetNudgeSource(bool was_throttled,
                                                     bool continue_sync_cycle,
@@ skipping 269 matching lines @@
     was_logged = true;
     VLOG(1) << "UserIdleTime unimplemented on this platform, synchronization "
                "will not throttle when user idle";
   }
 #endif
 
   return 0;
 }
 
 }  // namespace browser_sync