Fix incremental sync behavior of DriveFileSyncService.

chrome/browser/sync_file_system/drive_file_sync_service.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 "chrome/browser/sync_file_system/drive_file_sync_service.h"
 
 #include <algorithm>
 #include <utility>
 
 #include "base/bind.h"
@@ skipping 121 matching lines @@
   DISALLOW_COPY_AND_ASSIGN(TaskToken);
 };
 
 struct DriveFileSyncService::ProcessRemoteChangeParam {
   scoped_ptr<TaskToken> token;
   RemoteChangeProcessor* processor;
   RemoteChange remote_change;
   fileapi::SyncOperationCallback callback;
 
   DriveMetadata drive_metadata;
-  bool missing_db_entry;
   bool metadata_updated;
   FilePath temporary_file_path;
   std::string md5_checksum;
   fileapi::SyncOperationType operation_type;
 
   ProcessRemoteChangeParam(scoped_ptr<TaskToken> token,
                            RemoteChangeProcessor* processor,
                            const RemoteChange& remote_change,
                            const fileapi::SyncOperationCallback& callback)
       : token(token.Pass()),
         processor(processor),
         remote_change(remote_change),
         callback(callback),
-        missing_db_entry(false),
         metadata_updated(false),
         operation_type(fileapi::SYNC_OPERATION_NONE) {
   }
 };
 
 DriveFileSyncService::ChangeQueueItem::ChangeQueueItem()
     : changestamp(0),
       sync_type(REMOTE_SYNC_TYPE_INCREMENTAL) {
 }
 
@@ skipping 968 matching lines @@
     DCHECK(local_changes.list().back().IsDelete());
     param->operation_type = fileapi::SYNC_OPERATION_ADD;
     DownloadForRemoteSync(param.Pass());
     return;
   }
 
   DCHECK(param->remote_change.change.IsDelete());
   if (local_changes.empty()) {
     if (missing_local_file) {
       param->operation_type = fileapi::SYNC_OPERATION_NONE;
-      DeleteMetadataForRemoteSync(param.Pass());
+      if (missing_db_entry)
+        CompleteRemoteSync(param.Pass(), fileapi::SYNC_STATUS_OK);
+      else
+        DeleteMetadataForRemoteSync(param.Pass());
       return;
     }
     DCHECK(!missing_local_file);
     param->operation_type = fileapi::SYNC_OPERATION_DELETE;
 
     const fileapi::FileChange& file_change = param->remote_change.change;
     param->processor->ApplyRemoteChange(
         file_change, FilePath(), url,
         base::Bind(&DriveFileSyncService::DidApplyRemoteChange, AsWeakPtr(),
                    base::Passed(&param)));
     return;
   }
 
   DCHECK(!local_changes.empty());
   if (local_changes.list().back().IsAddOrUpdate()) {
     param->operation_type = fileapi::SYNC_OPERATION_NONE;
     CompleteRemoteSync(param.Pass(), fileapi::SYNC_STATUS_OK);
     return;
   }
 
   DCHECK(local_changes.list().back().IsDelete());
   param->operation_type = fileapi::SYNC_OPERATION_NONE;
-  DeleteMetadataForRemoteSync(param.Pass());
+  if (missing_db_entry)
+    CompleteRemoteSync(param.Pass(), fileapi::SYNC_STATUS_OK);
+  else
+    DeleteMetadataForRemoteSync(param.Pass());
 }
 
 void DriveFileSyncService::DownloadForRemoteSync(
     scoped_ptr<ProcessRemoteChangeParam> param) {
   // TODO(tzik): Use ShareableFileReference here after we get thread-safe
   // version of it. crbug.com/162598
   FilePath* temporary_file_path = &param->temporary_file_path;
   content::BrowserThread::PostTaskAndReplyWithResult(
       content::BrowserThread::FILE, FROM_HERE,
       base::Bind(&CreateTemporaryFile,
@@ skipping 217 matching lines @@
 
   polling_enabled_ = false;
   token->set_completion_callback(base::Bind(&EnablePolling, &polling_enabled_));
 
   if (metadata_store_->incremental_sync_origins().empty()) {
     NotifyTaskDone(fileapi::SYNC_STATUS_OK, token.Pass());
     return;
   }
 
   sync_client_->ListChanges(
-      largest_fetched_changestamp_,
+      largest_fetched_changestamp_ + 1,
       base::Bind(&DriveFileSyncService::DidFetchChangesForIncrementalSync,
                  AsWeakPtr(), base::Passed(&token)));
 }
 
 void DriveFileSyncService::DidFetchChangesForIncrementalSync(
     scoped_ptr<TaskToken> token,
     google_apis::GDataErrorCode error,
     scoped_ptr<google_apis::DocumentFeed> changes) {
   if (error != google_apis::HTTP_SUCCESS) {
     NotifyTaskDone(GDataErrorCodeToSyncStatusCodeWrapper(error), token.Pass());
@@ skipping 90 matching lines @@
 fileapi::SyncStatusCode
 DriveFileSyncService::GDataErrorCodeToSyncStatusCodeWrapper(
     google_apis::GDataErrorCode error) const {
   fileapi::SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error);
   if (status != fileapi::SYNC_STATUS_OK && !sync_client_->IsAuthenticated())
     return fileapi::SYNC_STATUS_AUTHENTICATION_FAILED;
   return status;
 }
 
 }  // namespace sync_file_system