Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(308)

Side by Side Diff: components/offline_pages/background/request_queue_store_sql.h

Issue 2228813003: Changes to fit better with the needs of the download manager. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Use typedef to hide an ugly type. Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef COMPONENTS_OFFLINE_PAGES_BACKGROUND_REQUEST_QUEUE_STORE_SQL_H_ 5 #ifndef COMPONENTS_OFFLINE_PAGES_BACKGROUND_REQUEST_QUEUE_STORE_SQL_H_
6 #define COMPONENTS_OFFLINE_PAGES_BACKGROUND_REQUEST_QUEUE_STORE_SQL_H_ 6 #define COMPONENTS_OFFLINE_PAGES_BACKGROUND_REQUEST_QUEUE_STORE_SQL_H_
7 7
8 #include <stdint.h> 8 #include <stdint.h>
9 9
10 #include <memory> 10 #include <memory>
(...skipping 20 matching lines...) Expand all
31 scoped_refptr<base::SequencedTaskRunner> background_task_runner, 31 scoped_refptr<base::SequencedTaskRunner> background_task_runner,
32 const base::FilePath& database_dir); 32 const base::FilePath& database_dir);
33 ~RequestQueueStoreSQL() override; 33 ~RequestQueueStoreSQL() override;
34 34
35 // RequestQueueStore implementation. 35 // RequestQueueStore implementation.
36 void GetRequests(const GetRequestsCallback& callback) override; 36 void GetRequests(const GetRequestsCallback& callback) override;
37 void AddOrUpdateRequest(const SavePageRequest& offline_page, 37 void AddOrUpdateRequest(const SavePageRequest& offline_page,
38 const UpdateCallback& callback) override; 38 const UpdateCallback& callback) override;
39 void RemoveRequests(const std::vector<int64_t>& request_ids, 39 void RemoveRequests(const std::vector<int64_t>& request_ids,
40 const RemoveCallback& callback) override; 40 const RemoveCallback& callback) override;
41 void RemoveRequestsByClientId(const std::vector<ClientId>& client_ids,
42 const RemoveCallback& callback) override;
43 void Reset(const ResetCallback& callback) override; 41 void Reset(const ResetCallback& callback) override;
44 42
45 private: 43 private:
46 // Synchronous implementations, these are run on the background thread 44 // Synchronous implementations, these are run on the background thread
47 // and actually do the work to access SQL. The implementations above 45 // and actually do the work to access SQL. The implementations above
48 // simply dispatch to the corresponding *Sync method on the background thread. 46 // simply dispatch to the corresponding *Sync method on the background thread.
49 // 'runner' is where to run the callback. 47 // 'runner' is where to run the callback.
50 static void GetRequestsSync( 48 static void GetRequestsSync(
51 sql::Connection* db, 49 sql::Connection* db,
52 scoped_refptr<base::SingleThreadTaskRunner> runner, 50 scoped_refptr<base::SingleThreadTaskRunner> runner,
53 const GetRequestsCallback& callback); 51 const GetRequestsCallback& callback);
54 static void AddOrUpdateRequestSync( 52 static void AddOrUpdateRequestSync(
55 sql::Connection* db, 53 sql::Connection* db,
56 scoped_refptr<base::SingleThreadTaskRunner> runner, 54 scoped_refptr<base::SingleThreadTaskRunner> runner,
57 const SavePageRequest& offline_page, 55 const SavePageRequest& offline_page,
58 const UpdateCallback& callback); 56 const UpdateCallback& callback);
59 static void RemoveRequestsSync( 57 static void RemoveRequestsSync(
60 sql::Connection* db, 58 sql::Connection* db,
61 scoped_refptr<base::SingleThreadTaskRunner> runner, 59 scoped_refptr<base::SingleThreadTaskRunner> runner,
62 const std::vector<int64_t>& request_ids, 60 const std::vector<int64_t>& request_ids,
63 const RemoveCallback& callback); 61 const RemoveCallback& callback);
64 static void RemoveRequestsByClientIdSync(
65 sql::Connection* db,
66 scoped_refptr<base::SingleThreadTaskRunner> runner,
67 const std::vector<ClientId>& client_ids,
68 const RemoveCallback& callback);
69 static void ResetSync(sql::Connection* db, 62 static void ResetSync(sql::Connection* db,
70 const base::FilePath& db_file_path, 63 const base::FilePath& db_file_path,
71 scoped_refptr<base::SingleThreadTaskRunner> runner, 64 scoped_refptr<base::SingleThreadTaskRunner> runner,
72 const ResetCallback& callback); 65 const ResetCallback& callback);
73 66
74 // Used to initialize DB connection. 67 // Used to initialize DB connection.
75 static void OpenConnectionSync( 68 static void OpenConnectionSync(
76 sql::Connection* db, 69 sql::Connection* db,
77 scoped_refptr<base::SingleThreadTaskRunner> runner, 70 scoped_refptr<base::SingleThreadTaskRunner> runner,
78 const base::FilePath& path, 71 const base::FilePath& path,
(...skipping 13 matching lines...) Expand all
92 // Database connection. 85 // Database connection.
93 std::unique_ptr<sql::Connection> db_; 86 std::unique_ptr<sql::Connection> db_;
94 87
95 base::WeakPtrFactory<RequestQueueStoreSQL> weak_ptr_factory_; 88 base::WeakPtrFactory<RequestQueueStoreSQL> weak_ptr_factory_;
96 DISALLOW_COPY_AND_ASSIGN(RequestQueueStoreSQL); 89 DISALLOW_COPY_AND_ASSIGN(RequestQueueStoreSQL);
97 }; 90 };
98 91
99 } // namespace offline_pages 92 } // namespace offline_pages
100 93
101 #endif // COMPONENTS_OFFLINE_PAGES_BACKGROUND_REQUEST_QUEUE_STORE_SQL_H_ 94 #endif // COMPONENTS_OFFLINE_PAGES_BACKGROUND_REQUEST_QUEUE_STORE_SQL_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698