Home | History | Annotate | Download | only in indexed_db 
      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 WebIDBCursorImpl
     26     : NON_EXPORTED_BASE(public blink::WebIDBCursor) {
     27  public:
     28   WebIDBCursorImpl(int32 ipc_cursor_id, ThreadSafeSender* thread_safe_sender);
     29   virtual ~WebIDBCursorImpl();
     30 
     31   virtual void advance(unsigned long count, blink::WebIDBCallbacks* callback);
     32   virtual void continueFunction(const blink::WebIDBKey& key,
     33                                 blink::WebIDBCallbacks* callback);
     34   virtual void continueFunction(const blink::WebIDBKey& key,
     35                                 const blink::WebIDBKey& primary_key,
     36                                 blink::WebIDBCallbacks* callback);
     37   virtual void postSuccessHandlerCallback();
     38 
     39   void SetPrefetchData(const std::vector<IndexedDBKey>& keys,
     40                        const std::vector<IndexedDBKey>& primary_keys,
     41                        const std::vector<blink::WebData>& values);
     42 
     43   void CachedContinue(blink::WebIDBCallbacks* callbacks);
     44   void ResetPrefetchCache();
     45 
     46  private:
     47   FRIEND_TEST_ALL_PREFIXES(WebIDBCursorImplTest, PrefetchTest);
     48 
     49   int32 ipc_cursor_id_;
     50 
     51   // Prefetch cache.
     52   std::deque<IndexedDBKey> prefetch_keys_;
     53   std::deque<IndexedDBKey> prefetch_primary_keys_;
     54   std::deque<blink::WebData> prefetch_values_;
     55 
     56   // Number of continue calls that would qualify for a pre-fetch.
     57   int continue_count_;
     58 
     59   // Number of items used from the last prefetch.
     60   int used_prefetches_;
     61 
     62   // Number of onsuccess handlers we are waiting for.
     63   int pending_onsuccess_callbacks_;
     64 
     65   // Number of items to request in next prefetch.
     66   int prefetch_amount_;
     67 
     68   scoped_refptr<ThreadSafeSender> thread_safe_sender_;
     69 
     70   enum { kInvalidCursorId = -1 };
     71   enum { kPrefetchContinueThreshold = 2 };
     72   enum { kMinPrefetchAmount = 5 };
     73   enum { kMaxPrefetchAmount = 100 };
     74 };
     75 
     76 }  // namespace content
     77 
     78 #endif  // CONTENT_CHILD_INDEXED_DB_PROXY_WEBIDBCURSOR_IMPL_H_
     79