gecko/dom/filehandle/FileStreamWrappers.cpp

416 lines
9.7 KiB
C++
Raw Normal View History

/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim: set ts=8 sts=2 et sw=2 tw=80: */
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
* You can obtain one at http://mozilla.org/MPL/2.0/. */
#include "FileStreamWrappers.h"
Bug 975696 - Split ArchiveReader and FileHandle implementation into separate dirs. r=bent f=baku --HG-- rename : dom/file/ArchiveEvent.cpp => dom/archivereader/ArchiveEvent.cpp rename : dom/file/ArchiveEvent.h => dom/archivereader/ArchiveEvent.h rename : dom/file/ArchiveReader.cpp => dom/archivereader/ArchiveReader.cpp rename : dom/file/ArchiveReader.h => dom/archivereader/ArchiveReader.h rename : dom/file/ArchiveRequest.cpp => dom/archivereader/ArchiveRequest.cpp rename : dom/file/ArchiveRequest.h => dom/archivereader/ArchiveRequest.h rename : dom/file/ArchiveZipEvent.cpp => dom/archivereader/ArchiveZipEvent.cpp rename : dom/file/ArchiveZipEvent.h => dom/archivereader/ArchiveZipEvent.h rename : dom/file/ArchiveZipFile.cpp => dom/archivereader/ArchiveZipFile.cpp rename : dom/file/ArchiveZipFile.h => dom/archivereader/ArchiveZipFile.h rename : dom/file/test/test_archivereader.html => dom/archivereader/test/test_basic.html rename : dom/file/test/test_archivereader_nonUnicode.html => dom/archivereader/test/test_nonUnicode.html rename : dom/file/test/test_archivereader_zip_in_zip.html => dom/archivereader/test/test_zip_in_zip.html rename : dom/file/test/test_bug_793311.html => dom/base/test/test_bug793311.html rename : dom/file/AsyncHelper.cpp => dom/filehandle/AsyncHelper.cpp rename : dom/file/AsyncHelper.h => dom/filehandle/AsyncHelper.h rename : dom/file/File.cpp => dom/filehandle/File.cpp rename : dom/file/File.h => dom/filehandle/File.h rename : dom/file/FileHandle.cpp => dom/filehandle/FileHandle.cpp rename : dom/file/FileHandle.h => dom/filehandle/FileHandle.h rename : dom/file/FileHelper.cpp => dom/filehandle/FileHelper.cpp rename : dom/file/FileHelper.h => dom/filehandle/FileHelper.h rename : dom/file/FileRequest.cpp => dom/filehandle/FileRequest.cpp rename : dom/file/FileRequest.h => dom/filehandle/FileRequest.h rename : dom/file/FileService.cpp => dom/filehandle/FileService.cpp rename : dom/file/FileService.h => dom/filehandle/FileService.h rename : dom/file/FileStreamWrappers.cpp => dom/filehandle/FileStreamWrappers.cpp rename : dom/file/FileStreamWrappers.h => dom/filehandle/FileStreamWrappers.h rename : dom/file/LockedFile.cpp => dom/filehandle/LockedFile.cpp rename : dom/file/LockedFile.h => dom/filehandle/LockedFile.h rename : dom/file/MemoryStreams.cpp => dom/filehandle/MemoryStreams.cpp rename : dom/file/MemoryStreams.h => dom/filehandle/MemoryStreams.h rename : dom/file/MetadataHelper.cpp => dom/filehandle/MetadataHelper.cpp rename : dom/file/MetadataHelper.h => dom/filehandle/MetadataHelper.h rename : dom/file/moz.build => dom/filehandle/moz.build rename : dom/file/nsIFileStorage.h => dom/filehandle/nsIFileStorage.h rename : dom/file/test/dummy_worker.js => dom/filehandle/test/dummy_worker.js rename : dom/file/test/helpers.js => dom/filehandle/test/helpers.js rename : dom/file/test/mochitest.ini => dom/filehandle/test/mochitest.ini rename : dom/file/test/moz.build => dom/filehandle/test/moz.build rename : dom/file/test/test_append_read_data.html => dom/filehandle/test/test_append_read_data.html rename : dom/file/test/test_getFile.html => dom/filehandle/test/test_getFile.html rename : dom/file/test/test_getFileId.html => dom/filehandle/test/test_getFileId.html rename : dom/file/test/test_location.html => dom/filehandle/test/test_location.html rename : dom/file/test/test_lockedfile_lifetimes.html => dom/filehandle/test/test_lockedfile_lifetimes.html rename : dom/file/test/test_lockedfile_lifetimes_nested.html => dom/filehandle/test/test_lockedfile_lifetimes_nested.html rename : dom/file/test/test_lockedfile_ordering.html => dom/filehandle/test/test_lockedfile_ordering.html rename : dom/file/test/test_overlapping_lockedfiles.html => dom/filehandle/test/test_overlapping_lockedfiles.html rename : dom/file/test/test_progress_events.html => dom/filehandle/test/test_progress_events.html rename : dom/file/test/test_readonly_lockedfiles.html => dom/filehandle/test/test_readonly_lockedfiles.html rename : dom/file/test/test_request_readyState.html => dom/filehandle/test/test_request_readyState.html rename : dom/file/test/test_stream_tracking.html => dom/filehandle/test/test_stream_tracking.html rename : dom/file/test/test_success_events_after_abort.html => dom/filehandle/test/test_success_events_after_abort.html rename : dom/file/test/test_truncate.html => dom/filehandle/test/test_truncate.html rename : dom/file/test/test_workers.html => dom/filehandle/test/test_workers.html rename : dom/file/test/test_write_read_data.html => dom/filehandle/test/test_write_read_data.html
2014-05-07 07:32:12 -07:00
#include "FileHelper.h"
#include "MainThreadUtils.h"
#include "mozilla/Assertions.h"
Bug 975696 - Split ArchiveReader and FileHandle implementation into separate dirs. r=bent f=baku --HG-- rename : dom/file/ArchiveEvent.cpp => dom/archivereader/ArchiveEvent.cpp rename : dom/file/ArchiveEvent.h => dom/archivereader/ArchiveEvent.h rename : dom/file/ArchiveReader.cpp => dom/archivereader/ArchiveReader.cpp rename : dom/file/ArchiveReader.h => dom/archivereader/ArchiveReader.h rename : dom/file/ArchiveRequest.cpp => dom/archivereader/ArchiveRequest.cpp rename : dom/file/ArchiveRequest.h => dom/archivereader/ArchiveRequest.h rename : dom/file/ArchiveZipEvent.cpp => dom/archivereader/ArchiveZipEvent.cpp rename : dom/file/ArchiveZipEvent.h => dom/archivereader/ArchiveZipEvent.h rename : dom/file/ArchiveZipFile.cpp => dom/archivereader/ArchiveZipFile.cpp rename : dom/file/ArchiveZipFile.h => dom/archivereader/ArchiveZipFile.h rename : dom/file/test/test_archivereader.html => dom/archivereader/test/test_basic.html rename : dom/file/test/test_archivereader_nonUnicode.html => dom/archivereader/test/test_nonUnicode.html rename : dom/file/test/test_archivereader_zip_in_zip.html => dom/archivereader/test/test_zip_in_zip.html rename : dom/file/test/test_bug_793311.html => dom/base/test/test_bug793311.html rename : dom/file/AsyncHelper.cpp => dom/filehandle/AsyncHelper.cpp rename : dom/file/AsyncHelper.h => dom/filehandle/AsyncHelper.h rename : dom/file/File.cpp => dom/filehandle/File.cpp rename : dom/file/File.h => dom/filehandle/File.h rename : dom/file/FileHandle.cpp => dom/filehandle/FileHandle.cpp rename : dom/file/FileHandle.h => dom/filehandle/FileHandle.h rename : dom/file/FileHelper.cpp => dom/filehandle/FileHelper.cpp rename : dom/file/FileHelper.h => dom/filehandle/FileHelper.h rename : dom/file/FileRequest.cpp => dom/filehandle/FileRequest.cpp rename : dom/file/FileRequest.h => dom/filehandle/FileRequest.h rename : dom/file/FileService.cpp => dom/filehandle/FileService.cpp rename : dom/file/FileService.h => dom/filehandle/FileService.h rename : dom/file/FileStreamWrappers.cpp => dom/filehandle/FileStreamWrappers.cpp rename : dom/file/FileStreamWrappers.h => dom/filehandle/FileStreamWrappers.h rename : dom/file/LockedFile.cpp => dom/filehandle/LockedFile.cpp rename : dom/file/LockedFile.h => dom/filehandle/LockedFile.h rename : dom/file/MemoryStreams.cpp => dom/filehandle/MemoryStreams.cpp rename : dom/file/MemoryStreams.h => dom/filehandle/MemoryStreams.h rename : dom/file/MetadataHelper.cpp => dom/filehandle/MetadataHelper.cpp rename : dom/file/MetadataHelper.h => dom/filehandle/MetadataHelper.h rename : dom/file/moz.build => dom/filehandle/moz.build rename : dom/file/nsIFileStorage.h => dom/filehandle/nsIFileStorage.h rename : dom/file/test/dummy_worker.js => dom/filehandle/test/dummy_worker.js rename : dom/file/test/helpers.js => dom/filehandle/test/helpers.js rename : dom/file/test/mochitest.ini => dom/filehandle/test/mochitest.ini rename : dom/file/test/moz.build => dom/filehandle/test/moz.build rename : dom/file/test/test_append_read_data.html => dom/filehandle/test/test_append_read_data.html rename : dom/file/test/test_getFile.html => dom/filehandle/test/test_getFile.html rename : dom/file/test/test_getFileId.html => dom/filehandle/test/test_getFileId.html rename : dom/file/test/test_location.html => dom/filehandle/test/test_location.html rename : dom/file/test/test_lockedfile_lifetimes.html => dom/filehandle/test/test_lockedfile_lifetimes.html rename : dom/file/test/test_lockedfile_lifetimes_nested.html => dom/filehandle/test/test_lockedfile_lifetimes_nested.html rename : dom/file/test/test_lockedfile_ordering.html => dom/filehandle/test/test_lockedfile_ordering.html rename : dom/file/test/test_overlapping_lockedfiles.html => dom/filehandle/test/test_overlapping_lockedfiles.html rename : dom/file/test/test_progress_events.html => dom/filehandle/test/test_progress_events.html rename : dom/file/test/test_readonly_lockedfiles.html => dom/filehandle/test/test_readonly_lockedfiles.html rename : dom/file/test/test_request_readyState.html => dom/filehandle/test/test_request_readyState.html rename : dom/file/test/test_stream_tracking.html => dom/filehandle/test/test_stream_tracking.html rename : dom/file/test/test_success_events_after_abort.html => dom/filehandle/test/test_success_events_after_abort.html rename : dom/file/test/test_truncate.html => dom/filehandle/test/test_truncate.html rename : dom/file/test/test_workers.html => dom/filehandle/test/test_workers.html rename : dom/file/test/test_write_read_data.html => dom/filehandle/test/test_write_read_data.html
2014-05-07 07:32:12 -07:00
#include "mozilla/Attributes.h"
#include "mozilla/ipc/InputStreamParams.h"
#include "MutableFile.h"
Bug 975696 - Split ArchiveReader and FileHandle implementation into separate dirs. r=bent f=baku --HG-- rename : dom/file/ArchiveEvent.cpp => dom/archivereader/ArchiveEvent.cpp rename : dom/file/ArchiveEvent.h => dom/archivereader/ArchiveEvent.h rename : dom/file/ArchiveReader.cpp => dom/archivereader/ArchiveReader.cpp rename : dom/file/ArchiveReader.h => dom/archivereader/ArchiveReader.h rename : dom/file/ArchiveRequest.cpp => dom/archivereader/ArchiveRequest.cpp rename : dom/file/ArchiveRequest.h => dom/archivereader/ArchiveRequest.h rename : dom/file/ArchiveZipEvent.cpp => dom/archivereader/ArchiveZipEvent.cpp rename : dom/file/ArchiveZipEvent.h => dom/archivereader/ArchiveZipEvent.h rename : dom/file/ArchiveZipFile.cpp => dom/archivereader/ArchiveZipFile.cpp rename : dom/file/ArchiveZipFile.h => dom/archivereader/ArchiveZipFile.h rename : dom/file/test/test_archivereader.html => dom/archivereader/test/test_basic.html rename : dom/file/test/test_archivereader_nonUnicode.html => dom/archivereader/test/test_nonUnicode.html rename : dom/file/test/test_archivereader_zip_in_zip.html => dom/archivereader/test/test_zip_in_zip.html rename : dom/file/test/test_bug_793311.html => dom/base/test/test_bug793311.html rename : dom/file/AsyncHelper.cpp => dom/filehandle/AsyncHelper.cpp rename : dom/file/AsyncHelper.h => dom/filehandle/AsyncHelper.h rename : dom/file/File.cpp => dom/filehandle/File.cpp rename : dom/file/File.h => dom/filehandle/File.h rename : dom/file/FileHandle.cpp => dom/filehandle/FileHandle.cpp rename : dom/file/FileHandle.h => dom/filehandle/FileHandle.h rename : dom/file/FileHelper.cpp => dom/filehandle/FileHelper.cpp rename : dom/file/FileHelper.h => dom/filehandle/FileHelper.h rename : dom/file/FileRequest.cpp => dom/filehandle/FileRequest.cpp rename : dom/file/FileRequest.h => dom/filehandle/FileRequest.h rename : dom/file/FileService.cpp => dom/filehandle/FileService.cpp rename : dom/file/FileService.h => dom/filehandle/FileService.h rename : dom/file/FileStreamWrappers.cpp => dom/filehandle/FileStreamWrappers.cpp rename : dom/file/FileStreamWrappers.h => dom/filehandle/FileStreamWrappers.h rename : dom/file/LockedFile.cpp => dom/filehandle/LockedFile.cpp rename : dom/file/LockedFile.h => dom/filehandle/LockedFile.h rename : dom/file/MemoryStreams.cpp => dom/filehandle/MemoryStreams.cpp rename : dom/file/MemoryStreams.h => dom/filehandle/MemoryStreams.h rename : dom/file/MetadataHelper.cpp => dom/filehandle/MetadataHelper.cpp rename : dom/file/MetadataHelper.h => dom/filehandle/MetadataHelper.h rename : dom/file/moz.build => dom/filehandle/moz.build rename : dom/file/nsIFileStorage.h => dom/filehandle/nsIFileStorage.h rename : dom/file/test/dummy_worker.js => dom/filehandle/test/dummy_worker.js rename : dom/file/test/helpers.js => dom/filehandle/test/helpers.js rename : dom/file/test/mochitest.ini => dom/filehandle/test/mochitest.ini rename : dom/file/test/moz.build => dom/filehandle/test/moz.build rename : dom/file/test/test_append_read_data.html => dom/filehandle/test/test_append_read_data.html rename : dom/file/test/test_getFile.html => dom/filehandle/test/test_getFile.html rename : dom/file/test/test_getFileId.html => dom/filehandle/test/test_getFileId.html rename : dom/file/test/test_location.html => dom/filehandle/test/test_location.html rename : dom/file/test/test_lockedfile_lifetimes.html => dom/filehandle/test/test_lockedfile_lifetimes.html rename : dom/file/test/test_lockedfile_lifetimes_nested.html => dom/filehandle/test/test_lockedfile_lifetimes_nested.html rename : dom/file/test/test_lockedfile_ordering.html => dom/filehandle/test/test_lockedfile_ordering.html rename : dom/file/test/test_overlapping_lockedfiles.html => dom/filehandle/test/test_overlapping_lockedfiles.html rename : dom/file/test/test_progress_events.html => dom/filehandle/test/test_progress_events.html rename : dom/file/test/test_readonly_lockedfiles.html => dom/filehandle/test/test_readonly_lockedfiles.html rename : dom/file/test/test_request_readyState.html => dom/filehandle/test/test_request_readyState.html rename : dom/file/test/test_stream_tracking.html => dom/filehandle/test/test_stream_tracking.html rename : dom/file/test/test_success_events_after_abort.html => dom/filehandle/test/test_success_events_after_abort.html rename : dom/file/test/test_truncate.html => dom/filehandle/test/test_truncate.html rename : dom/file/test/test_workers.html => dom/filehandle/test/test_workers.html rename : dom/file/test/test_write_read_data.html => dom/filehandle/test/test_write_read_data.html
2014-05-07 07:32:12 -07:00
#include "nsDebug.h"
#include "nsError.h"
#include "nsIRunnable.h"
#include "nsISeekableStream.h"
Bug 975696 - Split ArchiveReader and FileHandle implementation into separate dirs. r=bent f=baku --HG-- rename : dom/file/ArchiveEvent.cpp => dom/archivereader/ArchiveEvent.cpp rename : dom/file/ArchiveEvent.h => dom/archivereader/ArchiveEvent.h rename : dom/file/ArchiveReader.cpp => dom/archivereader/ArchiveReader.cpp rename : dom/file/ArchiveReader.h => dom/archivereader/ArchiveReader.h rename : dom/file/ArchiveRequest.cpp => dom/archivereader/ArchiveRequest.cpp rename : dom/file/ArchiveRequest.h => dom/archivereader/ArchiveRequest.h rename : dom/file/ArchiveZipEvent.cpp => dom/archivereader/ArchiveZipEvent.cpp rename : dom/file/ArchiveZipEvent.h => dom/archivereader/ArchiveZipEvent.h rename : dom/file/ArchiveZipFile.cpp => dom/archivereader/ArchiveZipFile.cpp rename : dom/file/ArchiveZipFile.h => dom/archivereader/ArchiveZipFile.h rename : dom/file/test/test_archivereader.html => dom/archivereader/test/test_basic.html rename : dom/file/test/test_archivereader_nonUnicode.html => dom/archivereader/test/test_nonUnicode.html rename : dom/file/test/test_archivereader_zip_in_zip.html => dom/archivereader/test/test_zip_in_zip.html rename : dom/file/test/test_bug_793311.html => dom/base/test/test_bug793311.html rename : dom/file/AsyncHelper.cpp => dom/filehandle/AsyncHelper.cpp rename : dom/file/AsyncHelper.h => dom/filehandle/AsyncHelper.h rename : dom/file/File.cpp => dom/filehandle/File.cpp rename : dom/file/File.h => dom/filehandle/File.h rename : dom/file/FileHandle.cpp => dom/filehandle/FileHandle.cpp rename : dom/file/FileHandle.h => dom/filehandle/FileHandle.h rename : dom/file/FileHelper.cpp => dom/filehandle/FileHelper.cpp rename : dom/file/FileHelper.h => dom/filehandle/FileHelper.h rename : dom/file/FileRequest.cpp => dom/filehandle/FileRequest.cpp rename : dom/file/FileRequest.h => dom/filehandle/FileRequest.h rename : dom/file/FileService.cpp => dom/filehandle/FileService.cpp rename : dom/file/FileService.h => dom/filehandle/FileService.h rename : dom/file/FileStreamWrappers.cpp => dom/filehandle/FileStreamWrappers.cpp rename : dom/file/FileStreamWrappers.h => dom/filehandle/FileStreamWrappers.h rename : dom/file/LockedFile.cpp => dom/filehandle/LockedFile.cpp rename : dom/file/LockedFile.h => dom/filehandle/LockedFile.h rename : dom/file/MemoryStreams.cpp => dom/filehandle/MemoryStreams.cpp rename : dom/file/MemoryStreams.h => dom/filehandle/MemoryStreams.h rename : dom/file/MetadataHelper.cpp => dom/filehandle/MetadataHelper.cpp rename : dom/file/MetadataHelper.h => dom/filehandle/MetadataHelper.h rename : dom/file/moz.build => dom/filehandle/moz.build rename : dom/file/nsIFileStorage.h => dom/filehandle/nsIFileStorage.h rename : dom/file/test/dummy_worker.js => dom/filehandle/test/dummy_worker.js rename : dom/file/test/helpers.js => dom/filehandle/test/helpers.js rename : dom/file/test/mochitest.ini => dom/filehandle/test/mochitest.ini rename : dom/file/test/moz.build => dom/filehandle/test/moz.build rename : dom/file/test/test_append_read_data.html => dom/filehandle/test/test_append_read_data.html rename : dom/file/test/test_getFile.html => dom/filehandle/test/test_getFile.html rename : dom/file/test/test_getFileId.html => dom/filehandle/test/test_getFileId.html rename : dom/file/test/test_location.html => dom/filehandle/test/test_location.html rename : dom/file/test/test_lockedfile_lifetimes.html => dom/filehandle/test/test_lockedfile_lifetimes.html rename : dom/file/test/test_lockedfile_lifetimes_nested.html => dom/filehandle/test/test_lockedfile_lifetimes_nested.html rename : dom/file/test/test_lockedfile_ordering.html => dom/filehandle/test/test_lockedfile_ordering.html rename : dom/file/test/test_overlapping_lockedfiles.html => dom/filehandle/test/test_overlapping_lockedfiles.html rename : dom/file/test/test_progress_events.html => dom/filehandle/test/test_progress_events.html rename : dom/file/test/test_readonly_lockedfiles.html => dom/filehandle/test/test_readonly_lockedfiles.html rename : dom/file/test/test_request_readyState.html => dom/filehandle/test/test_request_readyState.html rename : dom/file/test/test_stream_tracking.html => dom/filehandle/test/test_stream_tracking.html rename : dom/file/test/test_success_events_after_abort.html => dom/filehandle/test/test_success_events_after_abort.html rename : dom/file/test/test_truncate.html => dom/filehandle/test/test_truncate.html rename : dom/file/test/test_workers.html => dom/filehandle/test/test_workers.html rename : dom/file/test/test_write_read_data.html => dom/filehandle/test/test_write_read_data.html
2014-05-07 07:32:12 -07:00
#include "nsThreadUtils.h"
#include "nsQueryObject.h"
#ifdef DEBUG
#include "nsXULAppAPI.h"
#endif
Bug 975696 - Split ArchiveReader and FileHandle implementation into separate dirs. r=bent f=baku --HG-- rename : dom/file/ArchiveEvent.cpp => dom/archivereader/ArchiveEvent.cpp rename : dom/file/ArchiveEvent.h => dom/archivereader/ArchiveEvent.h rename : dom/file/ArchiveReader.cpp => dom/archivereader/ArchiveReader.cpp rename : dom/file/ArchiveReader.h => dom/archivereader/ArchiveReader.h rename : dom/file/ArchiveRequest.cpp => dom/archivereader/ArchiveRequest.cpp rename : dom/file/ArchiveRequest.h => dom/archivereader/ArchiveRequest.h rename : dom/file/ArchiveZipEvent.cpp => dom/archivereader/ArchiveZipEvent.cpp rename : dom/file/ArchiveZipEvent.h => dom/archivereader/ArchiveZipEvent.h rename : dom/file/ArchiveZipFile.cpp => dom/archivereader/ArchiveZipFile.cpp rename : dom/file/ArchiveZipFile.h => dom/archivereader/ArchiveZipFile.h rename : dom/file/test/test_archivereader.html => dom/archivereader/test/test_basic.html rename : dom/file/test/test_archivereader_nonUnicode.html => dom/archivereader/test/test_nonUnicode.html rename : dom/file/test/test_archivereader_zip_in_zip.html => dom/archivereader/test/test_zip_in_zip.html rename : dom/file/test/test_bug_793311.html => dom/base/test/test_bug793311.html rename : dom/file/AsyncHelper.cpp => dom/filehandle/AsyncHelper.cpp rename : dom/file/AsyncHelper.h => dom/filehandle/AsyncHelper.h rename : dom/file/File.cpp => dom/filehandle/File.cpp rename : dom/file/File.h => dom/filehandle/File.h rename : dom/file/FileHandle.cpp => dom/filehandle/FileHandle.cpp rename : dom/file/FileHandle.h => dom/filehandle/FileHandle.h rename : dom/file/FileHelper.cpp => dom/filehandle/FileHelper.cpp rename : dom/file/FileHelper.h => dom/filehandle/FileHelper.h rename : dom/file/FileRequest.cpp => dom/filehandle/FileRequest.cpp rename : dom/file/FileRequest.h => dom/filehandle/FileRequest.h rename : dom/file/FileService.cpp => dom/filehandle/FileService.cpp rename : dom/file/FileService.h => dom/filehandle/FileService.h rename : dom/file/FileStreamWrappers.cpp => dom/filehandle/FileStreamWrappers.cpp rename : dom/file/FileStreamWrappers.h => dom/filehandle/FileStreamWrappers.h rename : dom/file/LockedFile.cpp => dom/filehandle/LockedFile.cpp rename : dom/file/LockedFile.h => dom/filehandle/LockedFile.h rename : dom/file/MemoryStreams.cpp => dom/filehandle/MemoryStreams.cpp rename : dom/file/MemoryStreams.h => dom/filehandle/MemoryStreams.h rename : dom/file/MetadataHelper.cpp => dom/filehandle/MetadataHelper.cpp rename : dom/file/MetadataHelper.h => dom/filehandle/MetadataHelper.h rename : dom/file/moz.build => dom/filehandle/moz.build rename : dom/file/nsIFileStorage.h => dom/filehandle/nsIFileStorage.h rename : dom/file/test/dummy_worker.js => dom/filehandle/test/dummy_worker.js rename : dom/file/test/helpers.js => dom/filehandle/test/helpers.js rename : dom/file/test/mochitest.ini => dom/filehandle/test/mochitest.ini rename : dom/file/test/moz.build => dom/filehandle/test/moz.build rename : dom/file/test/test_append_read_data.html => dom/filehandle/test/test_append_read_data.html rename : dom/file/test/test_getFile.html => dom/filehandle/test/test_getFile.html rename : dom/file/test/test_getFileId.html => dom/filehandle/test/test_getFileId.html rename : dom/file/test/test_location.html => dom/filehandle/test/test_location.html rename : dom/file/test/test_lockedfile_lifetimes.html => dom/filehandle/test/test_lockedfile_lifetimes.html rename : dom/file/test/test_lockedfile_lifetimes_nested.html => dom/filehandle/test/test_lockedfile_lifetimes_nested.html rename : dom/file/test/test_lockedfile_ordering.html => dom/filehandle/test/test_lockedfile_ordering.html rename : dom/file/test/test_overlapping_lockedfiles.html => dom/filehandle/test/test_overlapping_lockedfiles.html rename : dom/file/test/test_progress_events.html => dom/filehandle/test/test_progress_events.html rename : dom/file/test/test_readonly_lockedfiles.html => dom/filehandle/test/test_readonly_lockedfiles.html rename : dom/file/test/test_request_readyState.html => dom/filehandle/test/test_request_readyState.html rename : dom/file/test/test_stream_tracking.html => dom/filehandle/test/test_stream_tracking.html rename : dom/file/test/test_success_events_after_abort.html => dom/filehandle/test/test_success_events_after_abort.html rename : dom/file/test/test_truncate.html => dom/filehandle/test/test_truncate.html rename : dom/file/test/test_workers.html => dom/filehandle/test/test_workers.html rename : dom/file/test/test_write_read_data.html => dom/filehandle/test/test_write_read_data.html
2014-05-07 07:32:12 -07:00
namespace mozilla {
namespace dom {
namespace {
class ProgressRunnable final : public nsIRunnable
{
public:
NS_DECL_THREADSAFE_ISUPPORTS
NS_DECL_NSIRUNNABLE
ProgressRunnable(FileHelper* aFileHelper,
uint64_t aProgress,
uint64_t aProgressMax)
: mFileHelper(aFileHelper),
mProgress(aProgress),
mProgressMax(aProgressMax)
{
}
private:
~ProgressRunnable() {}
nsRefPtr<FileHelper> mFileHelper;
uint64_t mProgress;
uint64_t mProgressMax;
};
class CloseRunnable final : public nsIRunnable
{
public:
NS_DECL_THREADSAFE_ISUPPORTS
NS_DECL_NSIRUNNABLE
explicit CloseRunnable(FileHelper* aFileHelper)
: mFileHelper(aFileHelper)
{ }
private:
~CloseRunnable() {}
nsRefPtr<FileHelper> mFileHelper;
};
class DestroyRunnable final : public nsIRunnable
{
public:
NS_DECL_THREADSAFE_ISUPPORTS
NS_DECL_NSIRUNNABLE
explicit DestroyRunnable(FileHelper* aFileHelper)
: mFileHelper(aFileHelper)
{ }
private:
~DestroyRunnable() {}
nsRefPtr<FileHelper> mFileHelper;
};
} // namespace
FileStreamWrapper::FileStreamWrapper(nsISupports* aFileStream,
FileHelper* aFileHelper,
uint64_t aOffset,
uint64_t aLimit,
uint32_t aFlags)
: mFileStream(aFileStream),
mFileHelper(aFileHelper),
mOffset(aOffset),
mLimit(aLimit),
mFlags(aFlags),
mFirstTime(true)
{
NS_ASSERTION(mFileStream, "Must have a file stream!");
NS_ASSERTION(mFileHelper, "Must have a file helper!");
}
FileStreamWrapper::~FileStreamWrapper()
{
if (mFlags & NOTIFY_DESTROY) {
if (NS_IsMainThread()) {
mFileHelper->OnStreamDestroy();
}
else {
nsCOMPtr<nsIRunnable> runnable =
new DestroyRunnable(mFileHelper);
nsresult rv = NS_DispatchToMainThread(runnable);
if (NS_FAILED(rv)) {
NS_WARNING("Failed to dispatch to the main thread!");
}
}
}
}
NS_IMPL_ISUPPORTS0(FileStreamWrapper)
FileInputStreamWrapper::FileInputStreamWrapper(nsISupports* aFileStream,
FileHelper* aFileHelper,
uint64_t aOffset,
uint64_t aLimit,
uint32_t aFlags)
: FileStreamWrapper(aFileStream, aFileHelper, aOffset, aLimit, aFlags)
{
mInputStream = do_QueryInterface(mFileStream);
NS_ASSERTION(mInputStream, "This should always succeed!");
}
NS_IMPL_ISUPPORTS_INHERITED(FileInputStreamWrapper,
FileStreamWrapper,
nsIInputStream,
nsIIPCSerializableInputStream)
NS_IMETHODIMP
FileInputStreamWrapper::Close()
{
NS_ASSERTION(!NS_IsMainThread(), "Wrong thread!");
if (mFlags & NOTIFY_CLOSE) {
nsCOMPtr<nsIRunnable> runnable = new CloseRunnable(mFileHelper);
if (NS_FAILED(NS_DispatchToMainThread(runnable))) {
NS_WARNING("Failed to dispatch to the main thread!");
}
}
mOffset = 0;
mLimit = 0;
return NS_OK;
}
NS_IMETHODIMP
FileInputStreamWrapper::Available(uint64_t* _retval)
{
// Performing sync IO on the main thread is generally not allowed.
// However, the input stream wrapper is also used to track reads performed by
// other APIs like FileReader, XHR, etc.
// In that case nsInputStreamChannel::OpenContentStream() calls Available()
// before setting the content length property. This property is not important
// to perform reads properly, so we can just return NS_BASE_STREAM_CLOSED
// here. It causes OpenContentStream() to set the content length property to
// zero.
if (NS_IsMainThread()) {
return NS_BASE_STREAM_CLOSED;
}
return mInputStream->Available(_retval);
}
NS_IMETHODIMP
FileInputStreamWrapper::Read(char* aBuf, uint32_t aCount, uint32_t* _retval)
{
NS_ASSERTION(!NS_IsMainThread(), "Wrong thread!");
nsresult rv;
if (mFirstTime) {
mFirstTime = false;
if (mOffset != UINT64_MAX) {
nsCOMPtr<nsISeekableStream> seekable = do_QueryInterface(mInputStream);
if (seekable) {
rv = seekable->Seek(nsISeekableStream::NS_SEEK_SET, mOffset);
NS_ENSURE_SUCCESS(rv, rv);
}
}
mOffset = 0;
}
uint64_t max = mLimit - mOffset;
if (max == 0) {
*_retval = 0;
return NS_OK;
}
if (aCount > max) {
aCount = max;
}
rv = mInputStream->Read(aBuf, aCount, _retval);
NS_ENSURE_SUCCESS(rv, rv);
mOffset += *_retval;
if (mFlags & NOTIFY_PROGRESS) {
nsCOMPtr<nsIRunnable> runnable =
new ProgressRunnable(mFileHelper, mOffset, mLimit);
rv = NS_DispatchToMainThread(runnable);
if (NS_FAILED(rv)) {
NS_WARNING("Failed to dispatch to the main thread!");
}
}
return NS_OK;
}
NS_IMETHODIMP
FileInputStreamWrapper::ReadSegments(nsWriteSegmentFun aWriter, void* aClosure,
uint32_t aCount, uint32_t* _retval)
{
return NS_ERROR_NOT_IMPLEMENTED;
}
NS_IMETHODIMP
FileInputStreamWrapper::IsNonBlocking(bool* _retval)
{
*_retval = false;
return NS_OK;
}
void
FileInputStreamWrapper::Serialize(InputStreamParams& aParams,
FileDescriptorArray& /* aFDs */)
{
MOZ_ASSERT(XRE_IsParentProcess());
MOZ_ASSERT(NS_IsMainThread());
nsCOMPtr<nsIInputStream> thisStream = do_QueryObject(this);
aParams = mozilla::ipc::SameProcessInputStreamParams(
reinterpret_cast<intptr_t>(thisStream.forget().take()));
}
bool
FileInputStreamWrapper::Deserialize(const InputStreamParams& /* aParams */,
const FileDescriptorArray& /* aFDs */)
{
MOZ_CRASH("Should never get here!");
}
FileOutputStreamWrapper::FileOutputStreamWrapper(nsISupports* aFileStream,
FileHelper* aFileHelper,
uint64_t aOffset,
uint64_t aLimit,
uint32_t aFlags)
: FileStreamWrapper(aFileStream, aFileHelper, aOffset, aLimit, aFlags)
{
mOutputStream = do_QueryInterface(mFileStream);
NS_ASSERTION(mOutputStream, "This should always succeed!");
}
NS_IMPL_ISUPPORTS_INHERITED(FileOutputStreamWrapper,
FileStreamWrapper,
nsIOutputStream)
NS_IMETHODIMP
FileOutputStreamWrapper::Close()
{
NS_ASSERTION(!NS_IsMainThread(), "Wrong thread!");
nsresult rv = NS_OK;
if (mFlags & NOTIFY_CLOSE) {
nsCOMPtr<nsIRunnable> runnable = new CloseRunnable(mFileHelper);
if (NS_FAILED(NS_DispatchToMainThread(runnable))) {
NS_WARNING("Failed to dispatch to the main thread!");
}
}
mOffset = 0;
mLimit = 0;
return rv;
}
NS_IMETHODIMP
FileOutputStreamWrapper::Write(const char* aBuf, uint32_t aCount,
uint32_t* _retval)
{
NS_ASSERTION(!NS_IsMainThread(), "Wrong thread!");
nsresult rv;
if (mFirstTime) {
mFirstTime = false;
nsCOMPtr<nsISeekableStream> seekable = do_QueryInterface(mOutputStream);
if (seekable) {
if (mOffset == UINT64_MAX) {
rv = seekable->Seek(nsISeekableStream::NS_SEEK_END, 0);
}
else {
rv = seekable->Seek(nsISeekableStream::NS_SEEK_SET, mOffset);
}
NS_ENSURE_SUCCESS(rv, rv);
}
mOffset = 0;
}
uint64_t max = mLimit - mOffset;
if (max == 0) {
*_retval = 0;
return NS_OK;
}
if (aCount > max) {
aCount = max;
}
rv = mOutputStream->Write(aBuf, aCount, _retval);
NS_ENSURE_SUCCESS(rv, rv);
mOffset += *_retval;
if (mFlags & NOTIFY_PROGRESS) {
nsCOMPtr<nsIRunnable> runnable =
new ProgressRunnable(mFileHelper, mOffset, mLimit);
NS_DispatchToMainThread(runnable);
}
return NS_OK;
}
NS_IMETHODIMP
FileOutputStreamWrapper::Flush()
{
return NS_OK;
}
NS_IMETHODIMP
FileOutputStreamWrapper::WriteFrom(nsIInputStream* aFromStream,
uint32_t aCount, uint32_t* _retval)
{
return NS_ERROR_NOT_IMPLEMENTED;
}
NS_IMETHODIMP
FileOutputStreamWrapper::WriteSegments(nsReadSegmentFun aReader,
void* aClosure, uint32_t aCount,
uint32_t* _retval)
{
return NS_ERROR_NOT_IMPLEMENTED;
}
NS_IMETHODIMP
FileOutputStreamWrapper::IsNonBlocking(bool* _retval)
{
*_retval = false;
return NS_OK;
}
NS_IMPL_ISUPPORTS(ProgressRunnable, nsIRunnable)
NS_IMETHODIMP
ProgressRunnable::Run()
{
NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
mFileHelper->OnStreamProgress(mProgress, mProgressMax);
mFileHelper = nullptr;
return NS_OK;
}
NS_IMPL_ISUPPORTS(CloseRunnable, nsIRunnable)
NS_IMETHODIMP
CloseRunnable::Run()
{
NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
mFileHelper->OnStreamClose();
mFileHelper = nullptr;
return NS_OK;
}
NS_IMPL_ISUPPORTS(DestroyRunnable, nsIRunnable)
NS_IMETHODIMP
DestroyRunnable::Run()
{
NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
mFileHelper->OnStreamDestroy();
mFileHelper = nullptr;
return NS_OK;
}
Bug 975696 - Split ArchiveReader and FileHandle implementation into separate dirs. r=bent f=baku --HG-- rename : dom/file/ArchiveEvent.cpp => dom/archivereader/ArchiveEvent.cpp rename : dom/file/ArchiveEvent.h => dom/archivereader/ArchiveEvent.h rename : dom/file/ArchiveReader.cpp => dom/archivereader/ArchiveReader.cpp rename : dom/file/ArchiveReader.h => dom/archivereader/ArchiveReader.h rename : dom/file/ArchiveRequest.cpp => dom/archivereader/ArchiveRequest.cpp rename : dom/file/ArchiveRequest.h => dom/archivereader/ArchiveRequest.h rename : dom/file/ArchiveZipEvent.cpp => dom/archivereader/ArchiveZipEvent.cpp rename : dom/file/ArchiveZipEvent.h => dom/archivereader/ArchiveZipEvent.h rename : dom/file/ArchiveZipFile.cpp => dom/archivereader/ArchiveZipFile.cpp rename : dom/file/ArchiveZipFile.h => dom/archivereader/ArchiveZipFile.h rename : dom/file/test/test_archivereader.html => dom/archivereader/test/test_basic.html rename : dom/file/test/test_archivereader_nonUnicode.html => dom/archivereader/test/test_nonUnicode.html rename : dom/file/test/test_archivereader_zip_in_zip.html => dom/archivereader/test/test_zip_in_zip.html rename : dom/file/test/test_bug_793311.html => dom/base/test/test_bug793311.html rename : dom/file/AsyncHelper.cpp => dom/filehandle/AsyncHelper.cpp rename : dom/file/AsyncHelper.h => dom/filehandle/AsyncHelper.h rename : dom/file/File.cpp => dom/filehandle/File.cpp rename : dom/file/File.h => dom/filehandle/File.h rename : dom/file/FileHandle.cpp => dom/filehandle/FileHandle.cpp rename : dom/file/FileHandle.h => dom/filehandle/FileHandle.h rename : dom/file/FileHelper.cpp => dom/filehandle/FileHelper.cpp rename : dom/file/FileHelper.h => dom/filehandle/FileHelper.h rename : dom/file/FileRequest.cpp => dom/filehandle/FileRequest.cpp rename : dom/file/FileRequest.h => dom/filehandle/FileRequest.h rename : dom/file/FileService.cpp => dom/filehandle/FileService.cpp rename : dom/file/FileService.h => dom/filehandle/FileService.h rename : dom/file/FileStreamWrappers.cpp => dom/filehandle/FileStreamWrappers.cpp rename : dom/file/FileStreamWrappers.h => dom/filehandle/FileStreamWrappers.h rename : dom/file/LockedFile.cpp => dom/filehandle/LockedFile.cpp rename : dom/file/LockedFile.h => dom/filehandle/LockedFile.h rename : dom/file/MemoryStreams.cpp => dom/filehandle/MemoryStreams.cpp rename : dom/file/MemoryStreams.h => dom/filehandle/MemoryStreams.h rename : dom/file/MetadataHelper.cpp => dom/filehandle/MetadataHelper.cpp rename : dom/file/MetadataHelper.h => dom/filehandle/MetadataHelper.h rename : dom/file/moz.build => dom/filehandle/moz.build rename : dom/file/nsIFileStorage.h => dom/filehandle/nsIFileStorage.h rename : dom/file/test/dummy_worker.js => dom/filehandle/test/dummy_worker.js rename : dom/file/test/helpers.js => dom/filehandle/test/helpers.js rename : dom/file/test/mochitest.ini => dom/filehandle/test/mochitest.ini rename : dom/file/test/moz.build => dom/filehandle/test/moz.build rename : dom/file/test/test_append_read_data.html => dom/filehandle/test/test_append_read_data.html rename : dom/file/test/test_getFile.html => dom/filehandle/test/test_getFile.html rename : dom/file/test/test_getFileId.html => dom/filehandle/test/test_getFileId.html rename : dom/file/test/test_location.html => dom/filehandle/test/test_location.html rename : dom/file/test/test_lockedfile_lifetimes.html => dom/filehandle/test/test_lockedfile_lifetimes.html rename : dom/file/test/test_lockedfile_lifetimes_nested.html => dom/filehandle/test/test_lockedfile_lifetimes_nested.html rename : dom/file/test/test_lockedfile_ordering.html => dom/filehandle/test/test_lockedfile_ordering.html rename : dom/file/test/test_overlapping_lockedfiles.html => dom/filehandle/test/test_overlapping_lockedfiles.html rename : dom/file/test/test_progress_events.html => dom/filehandle/test/test_progress_events.html rename : dom/file/test/test_readonly_lockedfiles.html => dom/filehandle/test/test_readonly_lockedfiles.html rename : dom/file/test/test_request_readyState.html => dom/filehandle/test/test_request_readyState.html rename : dom/file/test/test_stream_tracking.html => dom/filehandle/test/test_stream_tracking.html rename : dom/file/test/test_success_events_after_abort.html => dom/filehandle/test/test_success_events_after_abort.html rename : dom/file/test/test_truncate.html => dom/filehandle/test/test_truncate.html rename : dom/file/test/test_workers.html => dom/filehandle/test/test_workers.html rename : dom/file/test/test_write_read_data.html => dom/filehandle/test/test_write_read_data.html
2014-05-07 07:32:12 -07:00
} // namespace dom
} // namespace mozilla