src/content/child/indexed_db/proxy_webidbcursor_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_INDEXED_DB_PROXY_WEBIDBCURSOR_IMPL_H_
   6 #define CONTENT_CHILD_INDEXED_DB_PROXY_WEBIDBCURSOR_IMPL_H_
   7
   8 #include <deque>
   9 #include <vector>
  10
  11 #include "base/basictypes.h"
  12 #include "base/compiler_specific.h"
  13 #include "base/gtest_prod_util.h"
  14 #include "base/memory/ref_counted.h"
  15 #include "content/common/content_export.h"
  16 #include "content/common/indexed_db/indexed_db_key.h"
  17 #include "third_party/WebKit/public/platform/WebData.h"
  18 #include "third_party/WebKit/public/platform/WebIDBCallbacks.h"
  19 #include "third_party/WebKit/public/platform/WebIDBCursor.h"
  20 #include "third_party/WebKit/public/platform/WebIDBKey.h"
  21
  22 namespace content {
  23 class ThreadSafeSender;
  24
  25 class CONTENT_EXPORT RendererWebIDBCursorImpl
  26     : NON_EXPORTED_BASE(public WebKit::WebIDBCursor) {
  27  public:
  28   RendererWebIDBCursorImpl(int32 ipc_cursor_id,
  29                            ThreadSafeSender* thread_safe_sender);
  30   virtual ~RendererWebIDBCursorImpl();
  31
  32   virtual void advance(unsigned long count, WebKit::WebIDBCallbacks* callback);
  33   virtual void continueFunction(const WebKit::WebIDBKey& key,
  34                                 WebKit::WebIDBCallbacks* callback);
  35   virtual void postSuccessHandlerCallback();
  36
  37   void SetPrefetchData(const std::vector<IndexedDBKey>& keys,
  38                        const std::vector<IndexedDBKey>& primary_keys,
  39                        const std::vector<WebKit::WebData>& values);
  40
  41   void CachedContinue(WebKit::WebIDBCallbacks* callbacks);
  42   void ResetPrefetchCache();
  43
  44  private:
  45   FRIEND_TEST_ALL_PREFIXES(RendererWebIDBCursorImplTest, PrefetchTest);
  46
  47   int32 ipc_cursor_id_;
  48
  49   // Prefetch cache.
  50   std::deque<IndexedDBKey> prefetch_keys_;
  51   std::deque<IndexedDBKey> prefetch_primary_keys_;
  52   std::deque<WebKit::WebData> prefetch_values_;
  53
  54   // Number of continue calls that would qualify for a pre-fetch.
  55   int continue_count_;
  56
  57   // Number of items used from the last prefetch.
  58   int used_prefetches_;
  59
  60   // Number of onsuccess handlers we are waiting for.
  61   int pending_onsuccess_callbacks_;
  62
  63   // Number of items to request in next prefetch.
  64   int prefetch_amount_;
  65
  66   scoped_refptr<ThreadSafeSender> thread_safe_sender_;
  67
  68   enum { kInvalidCursorId = -1 };
  69   enum { kPrefetchContinueThreshold = 2 };
  70   enum { kMinPrefetchAmount = 5 };
  71   enum { kMaxPrefetchAmount = 100 };
  72 };
  73
  74 }  // namespace content
  75
  76 #endif  // CONTENT_CHILD_INDEXED_DB_PROXY_WEBIDBCURSOR_IMPL_H_