content/child/webblobregistry_impl.h

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef CONTENT_CHILD_WEBBLOBREGISTRY_IMPL_H_
   6 #define CONTENT_CHILD_WEBBLOBREGISTRY_IMPL_H_
   7
   8 #include <string>
   9 #include <vector>
  10
  11 #include "base/memory/ref_counted.h"
  12 #include "third_party/WebKit/public/platform/WebBlobRegistry.h"
  13
  14 namespace blink {
  15 class WebThreadSafeData;
  16 }  // namespace blink
  17
  18 namespace storage {
  19 class DataElement;
  20 }
  21
  22 namespace content {
  23 class ThreadSafeSender;
  24
  25 class WebBlobRegistryImpl : public blink::WebBlobRegistry {
  26  public:
  27   explicit WebBlobRegistryImpl(ThreadSafeSender* sender);
  28   virtual ~WebBlobRegistryImpl();
  29
  30   virtual void registerBlobData(const blink::WebString& uuid,
  31                                 const blink::WebBlobData& data);
  32   virtual void addBlobDataRef(const blink::WebString& uuid);
  33   virtual void removeBlobDataRef(const blink::WebString& uuid);
  34   virtual void registerPublicBlobURL(const blink::WebURL&,
  35                                      const blink::WebString& uuid);
  36   virtual void revokePublicBlobURL(const blink::WebURL&);
  37
  38   // Additional support for Streams.
  39   virtual void registerStreamURL(const blink::WebURL& url,
  40                                  const blink::WebString& content_type);
  41   virtual void registerStreamURL(const blink::WebURL& url,
  42                                  const blink::WebURL& src_url);
  43   virtual void addDataToStream(const blink::WebURL& url,
  44                                const char* data, size_t length);
  45   virtual void flushStream(const blink::WebURL& url);
  46   virtual void finalizeStream(const blink::WebURL& url);
  47   virtual void abortStream(const blink::WebURL& url);
  48   virtual void unregisterStreamURL(const blink::WebURL& url);
  49
  50  private:
  51   // Sends the data in the buffer as a blob item, then resets the buffer size.
  52   void FlushBlobItemBuffer(const std::string& uuid_str,
  53                            storage::DataElement* data_buffer) const;
  54
  55   // Adds the item to the consolidating buffer, flushing the buffer if needed.
  56   // If the item is too big for the buffer, it is sent as Sync messages in
  57   // shared memory instead.
  58   void BufferBlobData(const std::string& uuid_str,
  59                       const blink::WebThreadSafeData& data,
  60                       storage::DataElement* data_buffer);
  61   // Sends data that is larger than the threshold.
  62   void SendOversizedDataForBlob(const std::string& uuid_str,
  63                                 const blink::WebThreadSafeData& data);
  64
  65   scoped_refptr<ThreadSafeSender> sender_;
  66 };
  67
  68 }  // namespace content
  69
  70 #endif  // CONTENT_CHILD_WEBBLOBREGISTRY_IMPL_H_