1 files changed, 0 insertions, 219 deletions
diff --git a/WebCore/fileapi/FileStreamProxy.cpp b/WebCore/fileapi/FileStreamProxy.cpp
deleted file mode 100644
index 5daf983..0000000
--- a/WebCore/fileapi/FileStreamProxy.cpp
+++ /dev/null
@@ -1,219 +0,0 @@
-/*
- * Copyright (C) 2010 Google Inc.  All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- *
- *     * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- *     * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following disclaimer
- * in the documentation and/or other materials provided with the
- * distribution.
- *     * Neither the name of Google Inc. nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
-
-#include "config.h"
-
-#if ENABLE(BLOB) || ENABLE(FILE_SYSTEM)
-
-#include "FileStreamProxy.h"
-
-#include "Blob.h"
-#include "CrossThreadTask.h"
-#include "FileStream.h"
-#include "FileThread.h"
-#include "FileThreadTask.h"
-#include "PlatformString.h"
-#include "ScriptExecutionContext.h"
-
-namespace WebCore {
-
-inline FileStreamProxy::FileStreamProxy(ScriptExecutionContext* context, FileStreamClient* client)
-    : AsyncFileStream(client)
-    , m_context(context)
-    , m_stream(FileStream::create())
-{
-}
-
-PassRefPtr<FileStreamProxy> FileStreamProxy::create(ScriptExecutionContext* context, FileStreamClient* client)
-{
-    RefPtr<FileStreamProxy> proxy = adoptRef(new FileStreamProxy(context, client));
-
-    // Hold an ref so that the instance will not get deleted while there are tasks on the file thread.
-    // This is balanced by the deref in derefProxyOnContext below.
-    proxy->ref();
-
-    proxy->fileThread()->postTask(createFileThreadTask(proxy.get(), &FileStreamProxy::startOnFileThread));
-
-    return proxy.release();
-}
-
-FileStreamProxy::~FileStreamProxy()
-{
-}
-
-FileThread* FileStreamProxy::fileThread()
-{
-    ASSERT(m_context->isContextThread());
-    ASSERT(m_context->fileThread());
-    return m_context->fileThread();
-}
-
-static void didStart(ScriptExecutionContext*, FileStreamProxy* proxy)
-{
-    if (proxy->client())
-        proxy->client()->didStart();
-}
-
-void FileStreamProxy::startOnFileThread()
-{
-    m_stream->start();
-    m_context->postTask(createCallbackTask(&didStart, this));
-}
-
-void FileStreamProxy::stop()
-{
-    // Clear the client so that we won't be calling callbacks on the client.
-    setClient(0);
-
-    fileThread()->unscheduleTasks(m_stream.get());
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::stopOnFileThread));
-}
-
-static void derefProxyOnContext(ScriptExecutionContext*, FileStreamProxy* proxy)
-{
-    ASSERT(proxy->hasOneRef());
-    proxy->deref();
-}
-
-void FileStreamProxy::stopOnFileThread()
-{
-    m_stream->stop();
-    m_context->postTask(createCallbackTask(&derefProxyOnContext, this));
-}
-
-static void didGetSize(ScriptExecutionContext*, FileStreamProxy* proxy, long long size)
-{
-    if (proxy->client())
-        proxy->client()->didGetSize(size);
-}
-
-void FileStreamProxy::getSize(const String& path, double expectedModificationTime)
-{
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::getSizeOnFileThread, path, expectedModificationTime));
-}
-
-void FileStreamProxy::getSizeOnFileThread(const String& path, double expectedModificationTime)
-{
-    long long size = m_stream->getSize(path, expectedModificationTime);
-    m_context->postTask(createCallbackTask(&didGetSize, this, size));
-}
-
-static void didOpen(ScriptExecutionContext*, FileStreamProxy* proxy, bool success)
-{
-    if (proxy->client())
-        proxy->client()->didOpen(success);
-}
-
-void FileStreamProxy::openForRead(const String& path, long long offset, long long length)
-{
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::openForReadOnFileThread, path, offset, length));
-}
-
-void FileStreamProxy::openForReadOnFileThread(const String& path, long long offset, long long length)
-{
-    bool success = m_stream->openForRead(path, offset, length);
-    m_context->postTask(createCallbackTask(&didOpen, this, success));
-}
-
-void FileStreamProxy::openForWrite(const String& path)
-{
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::openForWriteOnFileThread, path));
-}
-
-void FileStreamProxy::openForWriteOnFileThread(const String& path)
-{
-    bool success = m_stream->openForWrite(path);
-    m_context->postTask(createCallbackTask(&didOpen, this, success));
-}
-
-void FileStreamProxy::close()
-{
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::closeOnFileThread));
-}
-
-void FileStreamProxy::closeOnFileThread()
-{
-    m_stream->close();
-}
-
-static void didRead(ScriptExecutionContext*, FileStreamProxy* proxy, int bytesRead)
-{
-    if (proxy->client())
-        proxy->client()->didRead(bytesRead);
-}
-
-void FileStreamProxy::read(char* buffer, int length)
-{
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::readOnFileThread, buffer, length));
-}
-
-void FileStreamProxy::readOnFileThread(char* buffer, int length)
-{
-    int bytesRead = m_stream->read(buffer, length);
-    m_context->postTask(createCallbackTask(&didRead, this, bytesRead));
-}
-
-static void didWrite(ScriptExecutionContext*, FileStreamProxy* proxy, int bytesWritten)
-{
-    if (proxy->client())
-        proxy->client()->didWrite(bytesWritten);
-}
-
-void FileStreamProxy::write(const KURL& blobURL, long long position, int length)
-{
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::writeOnFileThread, blobURL, position, length));
-}
-
-void FileStreamProxy::writeOnFileThread(const KURL& blobURL, long long position, int length)
-{
-    int bytesWritten = m_stream->write(blobURL, position, length);
-    m_context->postTask(createCallbackTask(&didWrite, this, bytesWritten));
-}
-
-static void didTruncate(ScriptExecutionContext*, FileStreamProxy* proxy, bool success)
-{
-    if (proxy->client())
-        proxy->client()->didTruncate(success);
-}
-
-void FileStreamProxy::truncate(long long position)
-{
-    fileThread()->postTask(createFileThreadTask(this, &FileStreamProxy::truncateOnFileThread, position));
-}
-
-void FileStreamProxy::truncateOnFileThread(long long position)
-{
-    bool success = m_stream->truncate(position);
-    m_context->postTask(createCallbackTask(&didTruncate, this, success));
-}
-
-} // namespace WebCore
-
-#endif // ENABLE(BLOB) || ENABLE(FILE_SYSTEM)