void ConflictResolver::RunPreflight(scoped_ptr<SyncTaskToken> token) {
token->InitializeTaskLog("Conflict Resolution");
- scoped_ptr<BlockingFactor> blocking_factor(new BlockingFactor);
- blocking_factor->exclusive = true;
- SyncTaskManager::UpdateBlockingFactor(
- token.Pass(), blocking_factor.Pass(),
+ scoped_ptr<TaskBlocker> task_blocker(new TaskBlocker);
+ task_blocker->exclusive = true;
+ SyncTaskManager::UpdateTaskBlocker(
+ token.Pass(), task_blocker.Pass(),
base::Bind(&ConflictResolver::RunExclusive,
weak_ptr_factory_.GetWeakPtr()));
}
return;
}
- metadata_database()->UpdateByDeletedRemoteFileList(
- deleted_file_ids_, SyncTaskToken::WrapToCallback(token.Pass()));
+ status = metadata_database()->UpdateByDeletedRemoteFileList(
+ deleted_file_ids_);
+ SyncTaskManager::NotifyTaskDone(token.Pass(), status);
}
bool ConflictResolver::IsContextReady() {
}
if (error != google_apis::HTTP_NOT_FOUND) {
- metadata_database()->UpdateByDeletedRemoteFile(
- file_id, SyncTaskToken::WrapToCallback(token.Pass()));
+ status = metadata_database()->UpdateByDeletedRemoteFile(file_id);
+ SyncTaskManager::NotifyTaskDone(token.Pass(), status);
return;
}
return;
}
- metadata_database()->UpdateByFileResource(
- *entry, SyncTaskToken::WrapToCallback(token.Pass()));
+ status = metadata_database()->UpdateByFileResource(*entry);
+ SyncTaskManager::NotifyTaskDone(token.Pass(), status);
}
drive::DriveServiceInterface* ConflictResolver::drive_service() {