Clear syncing flag after a remote or local sync

webkit/fileapi/syncable/local_file_sync_context.cc

 // Copyright (c) 2012 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 "webkit/fileapi/syncable/local_file_sync_context.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/platform_file.h"
 #include "base/single_thread_task_runner.h"
@@ skipping 74 matching lines @@
   file_system_context->task_runners()->file_task_runner()->PostTaskAndReply(
       FROM_HERE,
       base::Bind(&LocalFileSyncContext::GetNextURLsForSyncOnFileThread,
                  this, make_scoped_refptr(file_system_context),
                  base::Unretained(urls)),
       base::Bind(&LocalFileSyncContext::TryPrepareForLocalSync,
                  this, make_scoped_refptr(file_system_context),
                  base::Owned(urls), callback));
 }
 
-void LocalFileSyncContext::FinalizeSyncForURL(
+void LocalFileSyncContext::ClearChangesForURL(
     FileSystemContext* file_system_context,
-    const FileSystemURL& url) {
+    const FileSystemURL& url,
+    const base::Closure& done_callback) {
   // This is initially called on UI thread and to be relayed to FILE thread.
   DCHECK(file_system_context);
   if (!file_system_context->task_runners()->file_task_runner()->
           RunsTasksOnCurrentThread()) {
     DCHECK(ui_task_runner_->RunsTasksOnCurrentThread());
     file_system_context->task_runners()->file_task_runner()->PostTask(
         FROM_HERE,
-        base::Bind(&LocalFileSyncContext::FinalizeSyncForURL,
-                   this, make_scoped_refptr(file_system_context), url));
+        base::Bind(&LocalFileSyncContext::ClearChangesForURL,
+                   this, make_scoped_refptr(file_system_context),
+                   url, done_callback));
     return;
   }
   DCHECK(file_system_context->change_tracker());
   file_system_context->change_tracker()->ClearChangesForURL(url);
 
-  // Call out to the IO thread to re-enable writing.
+  // Call the completion callback on UI thread.
+  ui_task_runner_->PostTask(FROM_HERE, done_callback);
+}
+
+void LocalFileSyncContext::ClearSyncFlagForURL(const FileSystemURL& url) {
+  // This is initially called on UI thread and to be relayed to IO thread.
   io_task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&LocalFileSyncContext::EnableWritingOnIOThread,
                  this, url));
 }
 
 void LocalFileSyncContext::PrepareForSync(
     FileSystemContext* file_system_context,
     const FileSystemURL& url,
     const LocalFileSyncInfoCallback& callback) {
@@ skipping 460 matching lines @@
                  metadata));
 }
 
 base::TimeDelta LocalFileSyncContext::NotifyChangesDuration() {
   if (mock_notify_changes_duration_in_sec_ >= 0)
     return base::TimeDelta::FromSeconds(mock_notify_changes_duration_in_sec_);
   return base::TimeDelta::FromSeconds(kNotifyChangesDurationInSec);
 }
 
 }  // namespace fileapi