[Not ready for review] Add Streams API support to FileReader

Source/core/fileapi/FileReader.cpp

 /*
  * 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
@@ skipping 37 matching lines @@
 const CString utf8BlobURL(Blob* blob)
 {
     return blob->url().string().utf8();
 }
 
 const CString utf8FilePath(Blob* blob)
 {
     return blob->isFile() ? toFile(blob)->path().utf8() : "";
 }
 
+const CString utf8BlobURL(Stream* stream)
+{
+    return stream->url().string().utf8();
+}
+
 } // namespace
 
 static const double progressNotificationIntervalMS = 50;
 
 PassRefPtr<FileReader> FileReader::create(ScriptExecutionContext* context)
 {
     RefPtr<FileReader> fileReader(adoptRef(new FileReader(context)));
     fileReader->suspendIfNeeded();
     return fileReader.release();
 }
@@ skipping 27 matching lines @@
 void FileReader::stop()
 {
     terminate();
 }
 
 void FileReader::readAsArrayBuffer(Blob* blob, ExceptionCode& ec)
 {
     if (!blob)
         return;
 
-    LOG(FileAPI, "FileReader: reading as array buffer: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
+    LOG(FileAPI, "FileReader: reading Blob as array buffer: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
 
-    readInternal(blob, FileReaderLoader::ReadAsArrayBuffer, ec);
+    readInternal(blob, 0, FileReaderLoader::ReadAsArrayBuffer, ec);
 }
 
 void FileReader::readAsBinaryString(Blob* blob, ExceptionCode& ec)
 {
     if (!blob)
         return;
 
-    LOG(FileAPI, "FileReader: reading as binary: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
+    LOG(FileAPI, "FileReader: reading Blob as binary: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
 
-    readInternal(blob, FileReaderLoader::ReadAsBinaryString, ec);
+    readInternal(blob, 0, FileReaderLoader::ReadAsBinaryString, ec);
 }
 
 void FileReader::readAsText(Blob* blob, const String& encoding, ExceptionCode& ec)
 {
     if (!blob)
         return;
 
-    LOG(FileAPI, "FileReader: reading as text: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
+    LOG(FileAPI, "FileReader: reading Blob as text: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
 
     m_encoding = encoding;
-    readInternal(blob, FileReaderLoader::ReadAsText, ec);
+    readInternal(blob, 0, FileReaderLoader::ReadAsText, ec);
 }
 
 void FileReader::readAsText(Blob* blob, ExceptionCode& ec)
 {
     readAsText(blob, String(), ec);
 }
 
 void FileReader::readAsDataURL(Blob* blob, ExceptionCode& ec)
 {
     if (!blob)
         return;
 
-    LOG(FileAPI, "FileReader: reading as data URL: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
+    LOG(FileAPI, "FileReader: reading Blob as data URL: %s %s\n", utf8BlobURL(blob).data(), utf8FilePath(blob).data());
 
-    readInternal(blob, FileReaderLoader::ReadAsDataURL, ec);
+    readInternal(blob, 0, FileReaderLoader::ReadAsDataURL, ec);
 }
 
-void FileReader::readInternal(Blob* blob, FileReaderLoader::ReadType type, ExceptionCode& ec)
+void FileReader::readAsArrayBuffer(Stream* stream, ExceptionCode& ec)
+{
+    if (!stream)
+        return;
+
+    LOG(FileAPI, "FileReader: reading Stream as array buffer: %s\n", utf8BlobURL(stream).data());
+
+    readInternal(0, stream, FileReaderLoader::ReadAsArrayBuffer, ec);
+}
+
+void FileReader::readInternal(Blob* blob, Stream* stream, FileReaderLoader::ReadType type, ExceptionCode& ec)
 {
     // If multiple concurrent read methods are called on the same FileReader, InvalidStateError should be thrown when the state is LOADING.
     if (m_state == LOADING) {
         ec = InvalidStateError;
         return;
     }
 
     setPendingActivity(this);
 
     m_blob = blob;
+    m_stream = stream;
     m_readType = type;
     m_state = LOADING;
     m_error = 0;
 
     m_loader = adoptPtr(new FileReaderLoader(m_readType, this));
     m_loader->setEncoding(m_encoding);
-    m_loader->setDataType(m_blob->type());
-    m_loader->start(scriptExecutionContext(), *m_blob);
+    if (m_blob) {
+        m_loader->setDataType(m_blob->type());
+        m_loader->start(scriptExecutionContext(), m_blob.get());
+    } else if (m_stream) {
+        if (m_stream->isNeutered()) {
+            ec = InvalidStateError;
+            return;
+        }
+        stream->neuter();
+        m_loader->setDataType(m_stream->type());
+        m_loader->start(scriptExecutionContext(), m_stream.get());
+    }
 }
 
 static void delayedAbort(ScriptExecutionContext*, FileReader* reader)
 {
     reader->doAbort();
 }
 
 void FileReader::abort()
 {
     LOG(FileAPI, "FileReader: aborting\n");
@@ skipping 35 matching lines @@
 
 void FileReader::didStartLoading()
 {
     fireEvent(eventNames().loadstartEvent);
 }
 
 void FileReader::didReceiveData()
 {
     // Fire the progress event at least every 50ms.
     double now = currentTimeMS();
+
+    LOG(FileAPI, "FileReader::didReceiveData %f", now);
+
     if (!m_lastProgressNotificationTimeMS)
         m_lastProgressNotificationTimeMS = now;
     else if (now - m_lastProgressNotificationTimeMS > progressNotificationIntervalMS) {
         fireEvent(eventNames().progressEvent);
         m_lastProgressNotificationTimeMS = now;
     }
 }
 
 void FileReader::didFinishLoading()
 {
@@ skipping 41 matching lines @@
 }
 
 String FileReader::stringResult()
 {
     if (!m_loader || m_error)
         return String();
     return m_loader->stringResult();
 }
 
 } // namespace WebCore