********** WebCore blob hacking

WebCore/platform/network/BlobData.h

 /*
  * 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 21 matching lines @@
 #define BlobData_h
 
 #include "FileSystem.h"
 #include "KURL.h"
 #include <wtf/Forward.h>
 #include <wtf/ThreadSafeRefCounted.h>
 #include <wtf/text/WTFString.h>
 
 namespace WebCore {
 
+class BlobDataHandle;
+
 class RawData : public ThreadSafeRefCounted<RawData> {
 public:
     static PassRefPtr<RawData> create()
     {
         return adoptRef(new RawData());
     }
 
     void detachFromCurrentThread();
 
     const char* data() const { return m_data.data(); }
@@ skipping 42 matching lines @@
     BlobDataItem(const String& path, long long offset, long long length, double expectedModificationTime)
         : type(File)
         , path(path)
         , offset(offset)
         , length(length)
         , expectedModificationTime(expectedModificationTime)
     {
     }
 
     // Constructor for Blob type.
-    BlobDataItem(const KURL& url, long long offset, long long length)
+    BlobDataItem(PassRefPtr<BlobDataHandle> blobDataHandle, long long offset, long long length)
         : type(Blob)
-        , url(url)
+        , blobDataHandle(blobDataHandle)
         , offset(offset)
         , length(length)
         , expectedModificationTime(invalidFileTime())
     {
     }
 
 #if ENABLE(FILE_SYSTEM)
     // Constructor for URL type (e.g. FileSystem files).
-    BlobDataItem(const KURL& url, long long offset, long long length, double expectedModificationTime)
-        : type(URL)
-        , url(url)
+    BlobDataItem(const KURL& fileSystemURL, long long offset, long long length, double expectedModificationTime)
+        : type(FileSystemURL)
+        , fileSystemURL(fileSystemURL)
         , offset(offset)
         , length(length)
         , expectedModificationTime(expectedModificationTime)
     {
     }
 #endif
 
     // Detaches from current thread so that it can be passed to another thread.
     void detachFromCurrentThread();
 
     enum {
         Data,
         File,
         Blob
 #if ENABLE(FILE_SYSTEM)
-        , URL
+        , FileSystemURL
 #endif
     } type;
 
     // For Data type.
     RefPtr<RawData> data;
 
     // For File type.
     String path;
 
-    // For Blob or URL type.
-    KURL url;
+    // For FileSystem URL type.
+    KURL fileSystemURL;
+
+    // For Blob type.
+    RefPtr<BlobDataHandle> blobDataHandle;
 
     long long offset;
     long long length;
     double expectedModificationTime;
 
 private:
     friend class BlobData;
 
     // Constructor for String type (partial string).
     BlobDataItem(PassRefPtr<RawData> data, long long offset, long long length)
@@ skipping 21 matching lines @@
 
     const String& contentDisposition() const { return m_contentDisposition; }
     void setContentDisposition(const String& contentDisposition) { m_contentDisposition = contentDisposition; }
 
     const BlobDataItemList& items() const { return m_items; }
     void swapItems(BlobDataItemList&);
 
     void appendData(PassRefPtr<RawData>, long long offset, long long length);
     void appendFile(const String& path);
     void appendFile(const String& path, long long offset, long long length, double expectedModificationTime);
-    void appendBlob(const KURL&, long long offset, long long length);
+    void appendBlob(PassRefPtr<BlobDataHandle>, long long offset, long long length);
 #if ENABLE(FILE_SYSTEM)
-    void appendURL(const KURL&, long long offset, long long length, double expectedModificationTime);
+    void appendFileSystemURL(const KURL&, long long offset, long long length, double expectedModificationTime);
 #endif
 
 private:
     friend class BlobRegistryImpl;
     friend class BlobStorageData;
 
     BlobData() { }
 
     // This is only exposed to BlobStorageData.
     void appendData(const RawData&, long long offset, long long length);
 
     String m_contentType;
     String m_contentDisposition;
     BlobDataItemList m_items;
 };
 
+class BlobDataHandle : public ThreadSafeRefCounted<BlobDataHandle> {
+public:
+    // For empty blob construction.
+    static PassRefPtr<BlobDataHandle> create()
+    {
+        return adoptRef(new BlobDataHandle());
+    }
+
+    // For initial creation.
+    static PassRefPtr<BlobDataHandle> create(PassOwnPtr<BlobData> data, long long size)
+    {
+        return adoptRef(new BlobDataHandle(data, size));
+    }
+
+    // For deserialization of script values and ipc messages.
+    static PassRefPtr<BlobDataHandle> create(const String& uuid, const String& type, long long size)
+    {
+        return adoptRef(new BlobDataHandle(uuid, type, size));
+    }
+
+    String uuid() const { return m_uuid.isolatedCopy(); }
+    String type() const { return m_type.isolatedCopy(); }
+    unsigned long long size() { return m_size; }
+
+    ~BlobDataHandle();
+
+private:
+    BlobDataHandle();  
+    BlobDataHandle(PassOwnPtr<BlobData> data, long long size);
+    BlobDataHandle(const String& uuid, const String& type, long long size);
+
+    // FIXME: check that null or empty strings don't have some wierd thread affinity that isolatedCopy() doesn't evade???
+    const String m_uuid;
+    const String m_type;
+    const long long m_size;
+};
+
 } // namespace WebCore
 
 #endif // BlobData_h