| Index: content/browser/fileapi/fileapi_message_filter.cc
|
| diff --git a/content/browser/fileapi/fileapi_message_filter.cc b/content/browser/fileapi/fileapi_message_filter.cc
|
| index b4ef0cea7c125c4e5a9f6292322912dfea8fecfd..ca67e188207080a054ed968347622f679c5a8d40 100644
|
| --- a/content/browser/fileapi/fileapi_message_filter.cc
|
| +++ b/content/browser/fileapi/fileapi_message_filter.cc
|
| @@ -106,7 +106,7 @@ FileAPIMessageFilter::FileAPIMessageFilter(
|
| }
|
|
|
| void FileAPIMessageFilter::OnChannelConnected(int32 peer_pid) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (request_context_getter_.get()) {
|
| DCHECK(!request_context_);
|
| @@ -122,7 +122,7 @@ void FileAPIMessageFilter::OnChannelConnected(int32 peer_pid) {
|
| }
|
|
|
| void FileAPIMessageFilter::OnChannelClosing() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| // Unregister all the blob and stream URLs that are previously registered in
|
| // this process.
|
| @@ -206,7 +206,7 @@ void FileAPIMessageFilter::BadMessageReceived() {
|
| void FileAPIMessageFilter::OnOpenFileSystem(int request_id,
|
| const GURL& origin_url,
|
| storage::FileSystemType type) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (type == storage::kFileSystemTypeTemporary) {
|
| RecordAction(base::UserMetricsAction("OpenFileSystemTemporary"));
|
| } else if (type == storage::kFileSystemTypePersistent) {
|
| @@ -221,7 +221,7 @@ void FileAPIMessageFilter::OnOpenFileSystem(int request_id,
|
| void FileAPIMessageFilter::OnResolveURL(
|
| int request_id,
|
| const GURL& filesystem_url) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(filesystem_url));
|
| if (!ValidateFileSystemURL(request_id, url))
|
| return;
|
| @@ -238,14 +238,14 @@ void FileAPIMessageFilter::OnResolveURL(
|
| void FileAPIMessageFilter::OnDeleteFileSystem(int request_id,
|
| const GURL& origin_url,
|
| storage::FileSystemType type) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| context_->DeleteFileSystem(origin_url, type, base::Bind(
|
| &FileAPIMessageFilter::DidDeleteFileSystem, this, request_id));
|
| }
|
|
|
| void FileAPIMessageFilter::OnMove(
|
| int request_id, const GURL& src_path, const GURL& dest_path) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL src_url(context_->CrackURL(src_path));
|
| FileSystemURL dest_url(context_->CrackURL(dest_path));
|
| if (!ValidateFileSystemURL(request_id, src_url) ||
|
| @@ -269,7 +269,7 @@ void FileAPIMessageFilter::OnMove(
|
|
|
| void FileAPIMessageFilter::OnCopy(
|
| int request_id, const GURL& src_path, const GURL& dest_path) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL src_url(context_->CrackURL(src_path));
|
| FileSystemURL dest_url(context_->CrackURL(dest_path));
|
| if (!ValidateFileSystemURL(request_id, src_url) ||
|
| @@ -293,7 +293,7 @@ void FileAPIMessageFilter::OnCopy(
|
|
|
| void FileAPIMessageFilter::OnRemove(
|
| int request_id, const GURL& path, bool recursive) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(path));
|
| if (!ValidateFileSystemURL(request_id, url))
|
| return;
|
| @@ -310,7 +310,7 @@ void FileAPIMessageFilter::OnRemove(
|
|
|
| void FileAPIMessageFilter::OnReadMetadata(
|
| int request_id, const GURL& path) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(path));
|
| if (!ValidateFileSystemURL(request_id, url))
|
| return;
|
| @@ -327,7 +327,7 @@ void FileAPIMessageFilter::OnReadMetadata(
|
| void FileAPIMessageFilter::OnCreate(
|
| int request_id, const GURL& path, bool exclusive,
|
| bool is_directory, bool recursive) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(path));
|
| if (!ValidateFileSystemURL(request_id, url))
|
| return;
|
| @@ -350,7 +350,7 @@ void FileAPIMessageFilter::OnCreate(
|
|
|
| void FileAPIMessageFilter::OnExists(
|
| int request_id, const GURL& path, bool is_directory) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(path));
|
| if (!ValidateFileSystemURL(request_id, url))
|
| return;
|
| @@ -373,7 +373,7 @@ void FileAPIMessageFilter::OnExists(
|
|
|
| void FileAPIMessageFilter::OnReadDirectory(
|
| int request_id, const GURL& path) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(path));
|
| if (!ValidateFileSystemURL(request_id, url))
|
| return;
|
| @@ -393,7 +393,7 @@ void FileAPIMessageFilter::OnWrite(
|
| const GURL& path,
|
| const std::string& blob_uuid,
|
| int64 offset) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!request_context_) {
|
| // We can't write w/o a request context, trying to do so will crash.
|
| NOTREACHED();
|
| @@ -440,7 +440,7 @@ void FileAPIMessageFilter::OnTouchFile(
|
| const GURL& path,
|
| const base::Time& last_access_time,
|
| const base::Time& last_modified_time) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(path));
|
| if (!ValidateFileSystemURL(request_id, url))
|
| return;
|
| @@ -458,7 +458,7 @@ void FileAPIMessageFilter::OnTouchFile(
|
| void FileAPIMessageFilter::OnCancel(
|
| int request_id,
|
| int request_id_to_cancel) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| OperationsMap::iterator found = operations_.find(request_id_to_cancel);
|
| if (found != operations_.end()) {
|
| @@ -481,7 +481,7 @@ void FileAPIMessageFilter::OnSyncGetPlatformPath(
|
|
|
| void FileAPIMessageFilter::OnCreateSnapshotFile(
|
| int request_id, const GURL& path) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| FileSystemURL url(context_->CrackURL(path));
|
|
|
| // Make sure if this file can be read by the renderer as this is
|
| @@ -510,19 +510,19 @@ void FileAPIMessageFilter::OnCreateSnapshotFile(
|
| }
|
|
|
| void FileAPIMessageFilter::OnDidReceiveSnapshotFile(int request_id) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| in_transit_snapshot_files_.erase(request_id);
|
| }
|
|
|
| void FileAPIMessageFilter::OnStartBuildingBlob(const std::string& uuid) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| ignore_result(blob_storage_host_->StartBuildingBlob(uuid));
|
| }
|
|
|
| void FileAPIMessageFilter::OnAppendBlobDataItemToBlob(
|
| const std::string& uuid,
|
| const storage::DataElement& item) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (item.type() == storage::DataElement::TYPE_FILE_FILESYSTEM) {
|
| FileSystemURL filesystem_url(context_->CrackURL(item.filesystem_url()));
|
| if (!FileSystemURLIsValid(context_, filesystem_url) ||
|
| @@ -570,35 +570,35 @@ void FileAPIMessageFilter::OnAppendSharedMemoryToBlob(
|
|
|
| void FileAPIMessageFilter::OnFinishBuildingBlob(
|
| const std::string& uuid, const std::string& content_type) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| ignore_result(blob_storage_host_->FinishBuildingBlob(uuid, content_type));
|
| // TODO(michaeln): check return values once blink has migrated, crbug/174200
|
| }
|
|
|
| void FileAPIMessageFilter::OnIncrementBlobRefCount(const std::string& uuid) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| ignore_result(blob_storage_host_->IncrementBlobRefCount(uuid));
|
| }
|
|
|
| void FileAPIMessageFilter::OnDecrementBlobRefCount(const std::string& uuid) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| ignore_result(blob_storage_host_->DecrementBlobRefCount(uuid));
|
| }
|
|
|
| void FileAPIMessageFilter::OnRegisterPublicBlobURL(
|
| const GURL& public_url, const std::string& uuid) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| ignore_result(blob_storage_host_->RegisterPublicBlobURL(public_url, uuid));
|
| }
|
|
|
| void FileAPIMessageFilter::OnRevokePublicBlobURL(const GURL& public_url) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| ignore_result(blob_storage_host_->RevokePublicBlobURL(public_url));
|
| }
|
|
|
| void FileAPIMessageFilter::OnStartBuildingStream(
|
| const GURL& url, const std::string& content_type) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| // Only an internal Blob URL is expected here. See the BlobURL of the Blink.
|
| if (!StartsWithASCII(
|
| url.path(), "blobinternal%3A///", true /* case_sensitive */)) {
|
| @@ -617,7 +617,7 @@ void FileAPIMessageFilter::OnStartBuildingStream(
|
| void FileAPIMessageFilter::OnAppendBlobDataItemToStream(
|
| const GURL& url,
|
| const storage::DataElement& item) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| scoped_refptr<Stream> stream(GetStreamForURL(url));
|
| // Stream instances may be deleted on error. Just abort if there's no Stream
|
| @@ -658,21 +658,21 @@ void FileAPIMessageFilter::OnAppendSharedMemoryToStream(
|
| }
|
|
|
| void FileAPIMessageFilter::OnFlushStream(const GURL& url) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| scoped_refptr<Stream> stream(GetStreamForURL(url));
|
| if (stream.get())
|
| stream->Flush();
|
| }
|
|
|
| void FileAPIMessageFilter::OnFinishBuildingStream(const GURL& url) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| scoped_refptr<Stream> stream(GetStreamForURL(url));
|
| if (stream.get())
|
| stream->Finalize();
|
| }
|
|
|
| void FileAPIMessageFilter::OnAbortBuildingStream(const GURL& url) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| scoped_refptr<Stream> stream(GetStreamForURL(url));
|
| if (stream.get())
|
| stream->Abort();
|
| @@ -680,7 +680,7 @@ void FileAPIMessageFilter::OnAbortBuildingStream(const GURL& url) {
|
|
|
| void FileAPIMessageFilter::OnCloneStream(
|
| const GURL& url, const GURL& src_url) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| // Abort if there's no Stream instance for |src_url| (source Stream which
|
| // we're going to make |url| point to) in the registry.
|
| if (!GetStreamForURL(src_url).get())
|
| @@ -691,7 +691,7 @@ void FileAPIMessageFilter::OnCloneStream(
|
| }
|
|
|
| void FileAPIMessageFilter::OnRemoveStream(const GURL& url) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!GetStreamForURL(url).get())
|
| return;
|
| @@ -769,7 +769,7 @@ void FileAPIMessageFilter::DidOpenFileSystem(int request_id,
|
| const GURL& root,
|
| const std::string& filesystem_name,
|
| base::File::Error result) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (result == base::File::FILE_OK) {
|
| DCHECK(root.is_valid());
|
| Send(new FileSystemMsg_DidOpenFileSystem(
|
| @@ -786,7 +786,7 @@ void FileAPIMessageFilter::DidResolveURL(
|
| const storage::FileSystemInfo& info,
|
| const base::FilePath& file_path,
|
| storage::FileSystemContext::ResolvedEntryType type) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (result == base::File::FILE_OK &&
|
| type == storage::FileSystemContext::RESOLVED_ENTRY_NOT_FOUND)
|
| result = base::File::FILE_ERROR_NOT_FOUND;
|
| @@ -822,7 +822,7 @@ void FileAPIMessageFilter::DidCreateSnapshot(
|
| const base::File::Info& info,
|
| const base::FilePath& platform_path,
|
| const scoped_refptr<storage::ShareableFileReference>& /* unused */) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| operations_.erase(request_id);
|
|
|
| if (result != base::File::FILE_OK) {
|
|
|