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

WebCore/Modules/websockets/WorkerThreadableWebSocketChannel.h

 /*
  * Copyright (C) 2011 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 27 matching lines @@
 #include "WorkerContext.h"
 
 #include <wtf/PassRefPtr.h>
 #include <wtf/RefCounted.h>
 #include <wtf/RefPtr.h>
 #include <wtf/Threading.h>
 #include <wtf/text/WTFString.h>
 
 namespace WebCore {
 
+class BlobDataHandle;
 class KURL;
 class ScriptExecutionContext;
 class ThreadableWebSocketChannelClientWrapper;
 class WorkerContext;
 class WorkerLoaderProxy;
 class WorkerRunLoop;
 
 class WorkerThreadableWebSocketChannel : public RefCounted<WorkerThreadableWebSocketChannel>, public ThreadableWebSocketChannel {
     WTF_MAKE_FAST_ALLOCATED;
 public:
@@ skipping 25 matching lines @@
         static Peer* create(PassRefPtr<ThreadableWebSocketChannelClientWrapper> clientWrapper, WorkerLoaderProxy& loaderProxy, ScriptExecutionContext* context, const String& taskMode)
         {
             return new Peer(clientWrapper, loaderProxy, context, taskMode);
         }
         ~Peer();
 
         void connect(const KURL&, const String& protocol);
         void send(const String& message);
         void send(const ArrayBuffer&);
         void send(const Blob&);
+        void send(PassRefPtr<BlobDataHandle> blobDataHandle);
         void bufferedAmount();
         void close(int code, const String& reason);
         void fail(const String& reason);
         void disconnect();
         void suspend();
         void resume();
 
         // WebSocketChannelClient functions.
         virtual void didConnect() OVERRIDE;
         virtual void didReceiveMessage(const String& message) OVERRIDE;
@@ skipping 25 matching lines @@
     public:
         static PassRefPtr<Bridge> create(PassRefPtr<ThreadableWebSocketChannelClientWrapper> workerClientWrapper, PassRefPtr<WorkerContext> workerContext, const String& taskMode)
         {
             return adoptRef(new Bridge(workerClientWrapper, workerContext, taskMode));
         }
         ~Bridge();
         void initialize();
         void connect(const KURL&, const String& protocol);
         ThreadableWebSocketChannel::SendResult send(const String& message);
         ThreadableWebSocketChannel::SendResult send(const ArrayBuffer&, unsigned byteOffset, unsigned byteLength);
-        ThreadableWebSocketChannel::SendResult send(const Blob&);
+        ThreadableWebSocketChannel::SendResult send(PassRefPtr<BlobDataHandle> blobDataHandle);
         unsigned long bufferedAmount();
         void close(int code, const String& reason);
         void fail(const String& reason);
         void disconnect();
         void suspend();
         void resume();
 
         using RefCounted<Bridge>::ref;
         using RefCounted<Bridge>::deref;
 
@@ skipping 16 matching lines @@
         WorkerLoaderProxy& m_loaderProxy;
         String m_taskMode;
         Peer* m_peer;
     };
 
     WorkerThreadableWebSocketChannel(WorkerContext*, WebSocketChannelClient*, const String& taskMode);
 
     static void mainThreadConnect(ScriptExecutionContext*, Peer*, const KURL&, const String& protocol);
     static void mainThreadSend(ScriptExecutionContext*, Peer*, const String& message);
     static void mainThreadSendArrayBuffer(ScriptExecutionContext*, Peer*, PassOwnPtr<Vector<char> >);
-    static void mainThreadSendBlob(ScriptExecutionContext*, Peer*, const KURL&, const String& type, long long size);
+    static void mainThreadSendBlob(ScriptExecutionContext*, Peer*, PassRefPtr<BlobDataHandle> blobDataHandle);
     static void mainThreadBufferedAmount(ScriptExecutionContext*, Peer*);
     static void mainThreadClose(ScriptExecutionContext*, Peer*, int code, const String& reason);
     static void mainThreadFail(ScriptExecutionContext*, Peer*, const String& reason);
     static void mainThreadDestroy(ScriptExecutionContext*, PassOwnPtr<Peer>);
     static void mainThreadSuspend(ScriptExecutionContext*, Peer*);
     static void mainThreadResume(ScriptExecutionContext*, Peer*);
 
     class WorkerContextDidInitializeTask;
 
     RefPtr<WorkerContext> m_workerContext;
     RefPtr<ThreadableWebSocketChannelClientWrapper> m_workerClientWrapper;
     RefPtr<Bridge> m_bridge;
 };
 
 } // namespace WebCore
 
 #endif // ENABLE(WEB_SOCKETS)
 
 #endif // WorkerThreadableWebSocketChannel_h