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

Side by Side Diff: webkit/quota/quota_manager.h

Issue 10197007: Change webkit/{fileapi,quota} code to use TaskRunner. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: test fix Created 8 years, 7 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 | Annotate | Revision Log
« no previous file with comments | « webkit/quota/mock_quota_manager.cc ('k') | webkit/quota/quota_manager.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 WEBKIT_QUOTA_QUOTA_MANAGER_H_ 5 #ifndef WEBKIT_QUOTA_QUOTA_MANAGER_H_
6 #define WEBKIT_QUOTA_QUOTA_MANAGER_H_ 6 #define WEBKIT_QUOTA_QUOTA_MANAGER_H_
7 #pragma once 7 #pragma once
8 8
9 #include <deque> 9 #include <deque>
10 #include <list> 10 #include <list>
11 #include <map> 11 #include <map>
12 #include <set> 12 #include <set>
13 #include <string> 13 #include <string>
14 #include <utility> 14 #include <utility>
15 #include <vector> 15 #include <vector>
16 16
17 #include "base/basictypes.h" 17 #include "base/basictypes.h"
18 #include "base/callback.h" 18 #include "base/callback.h"
19 #include "base/file_path.h" 19 #include "base/file_path.h"
20 #include "base/memory/ref_counted.h" 20 #include "base/memory/ref_counted.h"
21 #include "base/memory/weak_ptr.h"
22 #include "base/memory/scoped_ptr.h" 21 #include "base/memory/scoped_ptr.h"
23 #include "base/memory/weak_ptr.h" 22 #include "base/memory/weak_ptr.h"
23 #include "base/memory/weak_ptr.h"
24 #include "base/sequenced_task_runner_helpers.h" 24 #include "base/sequenced_task_runner_helpers.h"
25 #include "webkit/quota/quota_client.h"
25 #include "webkit/quota/quota_database.h" 26 #include "webkit/quota/quota_database.h"
26 #include "webkit/quota/quota_client.h"
27 #include "webkit/quota/quota_task.h" 27 #include "webkit/quota/quota_task.h"
28 #include "webkit/quota/quota_types.h" 28 #include "webkit/quota/quota_types.h"
29 #include "webkit/quota/special_storage_policy.h" 29 #include "webkit/quota/special_storage_policy.h"
30 30
31 class FilePath; 31 class FilePath;
32 32
33 namespace base { 33 namespace base {
34 class MessageLoopProxy; 34 class SequencedTaskRunner;
35 class SingleThreadTaskRunner;
35 } 36 }
36 37
37 namespace quota_internals { 38 namespace quota_internals {
38 class QuotaInternalsProxy; 39 class QuotaInternalsProxy;
39 } 40 }
40 41
41 namespace quota { 42 namespace quota {
42 43
43 struct QuotaManagerDeleter; 44 struct QuotaManagerDeleter;
44 45
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after
99 public base::RefCountedThreadSafe< 100 public base::RefCountedThreadSafe<
100 QuotaManager, QuotaManagerDeleter> { 101 QuotaManager, QuotaManagerDeleter> {
101 public: 102 public:
102 typedef base::Callback<void(QuotaStatusCode, 103 typedef base::Callback<void(QuotaStatusCode,
103 int64 /* usage */, 104 int64 /* usage */,
104 int64 /* quota */)> 105 int64 /* quota */)>
105 GetUsageAndQuotaCallback; 106 GetUsageAndQuotaCallback;
106 107
107 QuotaManager(bool is_incognito, 108 QuotaManager(bool is_incognito,
108 const FilePath& profile_path, 109 const FilePath& profile_path,
109 base::MessageLoopProxy* io_thread, 110 base::SingleThreadTaskRunner* io_thread,
110 base::MessageLoopProxy* db_thread, 111 base::SequencedTaskRunner* db_thread,
111 SpecialStoragePolicy* special_storage_policy); 112 SpecialStoragePolicy* special_storage_policy);
112 113
113 // Returns a proxy object that can be used on any thread. 114 // Returns a proxy object that can be used on any thread.
114 QuotaManagerProxy* proxy() { return proxy_.get(); } 115 QuotaManagerProxy* proxy() { return proxy_.get(); }
115 116
116 // Called by clients or webapps. Returns usage per host. 117 // Called by clients or webapps. Returns usage per host.
117 void GetUsageInfo(const GetUsageInfoCallback& callback); 118 void GetUsageInfo(const GetUsageInfoCallback& callback);
118 119
119 // Called by clients or webapps. 120 // Called by clients or webapps.
120 // This method is declared as virtual to allow test code to override it. 121 // This method is declared as virtual to allow test code to override it.
(...skipping 224 matching lines...) Expand 10 before | Expand all | Expand 10 after
345 void DidGetDatabaseLRUOrigin(const GURL& origin); 346 void DidGetDatabaseLRUOrigin(const GURL& origin);
346 347
347 void DeleteOnCorrectThread() const; 348 void DeleteOnCorrectThread() const;
348 349
349 const bool is_incognito_; 350 const bool is_incognito_;
350 const FilePath profile_path_; 351 const FilePath profile_path_;
351 352
352 scoped_refptr<QuotaManagerProxy> proxy_; 353 scoped_refptr<QuotaManagerProxy> proxy_;
353 bool db_disabled_; 354 bool db_disabled_;
354 bool eviction_disabled_; 355 bool eviction_disabled_;
355 scoped_refptr<base::MessageLoopProxy> io_thread_; 356 scoped_refptr<base::SingleThreadTaskRunner> io_thread_;
356 scoped_refptr<base::MessageLoopProxy> db_thread_; 357 scoped_refptr<base::SequencedTaskRunner> db_thread_;
357 mutable scoped_ptr<QuotaDatabase> database_; 358 mutable scoped_ptr<QuotaDatabase> database_;
358 359
359 GetLRUOriginCallback lru_origin_callback_; 360 GetLRUOriginCallback lru_origin_callback_;
360 std::set<GURL> access_notified_origins_; 361 std::set<GURL> access_notified_origins_;
361 362
362 QuotaClientList clients_; 363 QuotaClientList clients_;
363 364
364 scoped_ptr<UsageTracker> temporary_usage_tracker_; 365 scoped_ptr<UsageTracker> temporary_usage_tracker_;
365 scoped_ptr<UsageTracker> persistent_usage_tracker_; 366 scoped_ptr<UsageTracker> persistent_usage_tracker_;
366 // TODO(michaeln): Need a way to clear the cache, drop and 367 // TODO(michaeln): Need a way to clear the cache, drop and
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
411 virtual void NotifyOriginNoLongerInUse(const GURL& origin); 412 virtual void NotifyOriginNoLongerInUse(const GURL& origin);
412 413
413 // This method may only be called on the IO thread. 414 // This method may only be called on the IO thread.
414 // It may return NULL if the manager has already been deleted. 415 // It may return NULL if the manager has already been deleted.
415 QuotaManager* quota_manager() const; 416 QuotaManager* quota_manager() const;
416 417
417 protected: 418 protected:
418 friend class QuotaManager; 419 friend class QuotaManager;
419 friend class base::RefCountedThreadSafe<QuotaManagerProxy>; 420 friend class base::RefCountedThreadSafe<QuotaManagerProxy>;
420 421
421 QuotaManagerProxy(QuotaManager* manager, base::MessageLoopProxy* io_thread); 422 QuotaManagerProxy(QuotaManager* manager,
423 base::SingleThreadTaskRunner* io_thread);
422 virtual ~QuotaManagerProxy(); 424 virtual ~QuotaManagerProxy();
423 425
424 QuotaManager* manager_; // only accessed on the io thread 426 QuotaManager* manager_; // only accessed on the io thread
425 scoped_refptr<base::MessageLoopProxy> io_thread_; 427 scoped_refptr<base::SingleThreadTaskRunner> io_thread_;
426 428
427 DISALLOW_COPY_AND_ASSIGN(QuotaManagerProxy); 429 DISALLOW_COPY_AND_ASSIGN(QuotaManagerProxy);
428 }; 430 };
429 431
430 } // namespace quota 432 } // namespace quota
431 433
432 #endif // WEBKIT_QUOTA_QUOTA_MANAGER_H_ 434 #endif // WEBKIT_QUOTA_QUOTA_MANAGER_H_
OLDNEW
« no previous file with comments | « webkit/quota/mock_quota_manager.cc ('k') | webkit/quota/quota_manager.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698