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_ 77