blob hacking webcore style

Source/modules/websockets/MainThreadWebSocketChannel.h

 /*
  * Copyright (C) 2011, 2012 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 32 matching lines @@
 #include "platform/network/SocketStreamHandleClient.h"
 #include "wtf/Deque.h"
 #include "wtf/Forward.h"
 #include "wtf/PassOwnPtr.h"
 #include "wtf/RefCounted.h"
 #include "wtf/Vector.h"
 #include "wtf/text/CString.h"
 
 namespace WebCore {
 
-class Blob;
+class BlobDataHandle;
 class Document;
 class FileReaderLoader;
 class SocketStreamHandle;
 class SocketStreamError;
 class WebSocketChannelClient;
 
 class MainThreadWebSocketChannel : public RefCounted<MainThreadWebSocketChannel>, public SocketStreamHandleClient, public WebSocketChannel, public FileReaderLoaderClient {
     WTF_MAKE_FAST_ALLOCATED;
 public:
     // You can specify the source file and the line number information
     // explicitly by passing the last parameter.
     // In the usual case, they are set automatically and you don't have to
     // pass it.
     static PassRefPtr<MainThreadWebSocketChannel> create(Document* document, WebSocketChannelClient* client, const String& sourceURL = String(), unsigned lineNumber = 0) { return adoptRef(new MainThreadWebSocketChannel(document, client, sourceURL, lineNumber)); }
     virtual ~MainThreadWebSocketChannel();
 
     bool send(const char* data, int length);
 
     // WebSocketChannel functions.
     virtual void connect(const KURL&, const String& protocol) OVERRIDE;
     virtual String subprotocol() OVERRIDE;
     virtual String extensions() OVERRIDE;
     virtual WebSocketChannel::SendResult send(const String& message) OVERRIDE;
     virtual WebSocketChannel::SendResult send(const ArrayBuffer&, unsigned byteOffset, unsigned byteLength) OVERRIDE;
-    virtual WebSocketChannel::SendResult send(const Blob&) OVERRIDE;
+    virtual WebSocketChannel::SendResult send(PassRefPtr<BlobDataHandle>) OVERRIDE;
     virtual unsigned long bufferedAmount() const OVERRIDE;
     // Start closing handshake. Use the CloseEventCodeNotSpecified for the code
     // argument to omit payload.
     virtual void close(int code, const String& reason) OVERRIDE;
     virtual void fail(const String& reason, MessageLevel, const String&, unsigned lineNumber) OVERRIDE;
     using WebSocketChannel::fail;
     virtual void disconnect() OVERRIDE;
 
     virtual void suspend() OVERRIDE;
     virtual void resume() OVERRIDE;
@@ skipping 44 matching lines @@
         QueuedFrameTypeString,
         QueuedFrameTypeVector,
         QueuedFrameTypeBlob
     };
     struct QueuedFrame {
         WebSocketFrame::OpCode opCode;
         QueuedFrameType frameType;
         // Only one of the following items is used, according to the value of frameType.
         CString stringData;
         Vector<char> vectorData;
-        RefPtr<Blob> blobData;
+        RefPtr<BlobDataHandle> blobData;
     };
     void enqueueTextFrame(const CString&);
     void enqueueRawFrame(WebSocketFrame::OpCode, const char* data, size_t dataLength);
-    void enqueueBlobFrame(WebSocketFrame::OpCode, const Blob&);
+    void enqueueBlobFrame(WebSocketFrame::OpCode, PassRefPtr<BlobDataHandle>);
 
     void failAsError(const String& reason) { fail(reason, ErrorMessageLevel, m_sourceURLAtConnection, m_lineNumberAtConnection); }
     void processOutgoingFrameQueue();
     void abortOutgoingFrameQueue();
 
     enum OutgoingFrameQueueStatus {
         // It is allowed to put a new item into the queue.
         OutgoingFrameQueueOpen,
         // Close frame has already been put into the queue but may not have been sent yet;
         // m_handle->close() will be called as soon as the queue is cleared. It is not
@@ skipping 55 matching lines @@
 
     String m_sourceURLAtConnection;
     unsigned m_lineNumberAtConnection;
     WebSocketPerMessageDeflate m_perMessageDeflate;
     WebSocketDeflateFramer m_deflateFramer;
 };
 
 } // namespace WebCore
 
 #endif // MainThreadWebSocketChannel_h