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

Side by Side Diff: net/url_request/sdch_dictionary_fetcher.h

Issue 901303002: Make SDCH dictionaries persistent across browser restart. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: More fixes Created 5 years, 10 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 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 // TODO(rdsmith): This class needs to delegate URLRequest::Delegate methods 5 // TODO(rdsmith): This class needs to delegate URLRequest::Delegate methods
6 // to the net/ embedder for correct implementation of authentication. 6 // to the net/ embedder for correct implementation of authentication.
7 // Specifically, this class needs the embedder to provide functionality 7 // Specifically, this class needs the embedder to provide functionality
8 // corresponding to 8 // corresponding to
9 // URLRequest::Delegate::{OnAuthRequired,OnCertificateRequested}. 9 // URLRequest::Delegate::{OnAuthRequired,OnCertificateRequested}.
10 10
(...skipping 27 matching lines...) Expand all
38 // attempting to fetch each dictionary once. 38 // attempting to fetch each dictionary once.
39 class NET_EXPORT SdchDictionaryFetcher : public URLRequest::Delegate, 39 class NET_EXPORT SdchDictionaryFetcher : public URLRequest::Delegate,
40 public base::NonThreadSafe { 40 public base::NonThreadSafe {
41 public: 41 public:
42 typedef base::Callback<void(const std::string& dictionary_text, 42 typedef base::Callback<void(const std::string& dictionary_text,
43 const GURL& dictionary_url, 43 const GURL& dictionary_url,
44 const BoundNetLog& net_log)> 44 const BoundNetLog& net_log)>
45 OnDictionaryFetchedCallback; 45 OnDictionaryFetchedCallback;
46 46
47 // The consumer must guarantee that |*context| outlives this object. 47 // The consumer must guarantee that |*context| outlives this object.
48 // |callback| will be called on successful dictionary fetch 48 explicit SdchDictionaryFetcher(URLRequestContext* context);
49 // requested through Schedule(). |callback| will not be called
50 // after object destruction.
51 SdchDictionaryFetcher(URLRequestContext* context,
52 const OnDictionaryFetchedCallback& callback);
53 ~SdchDictionaryFetcher() override; 49 ~SdchDictionaryFetcher() override;
54 50
55 // Request a new dictionary fetch. 51 // Request a new dictionary fetch. The callback will be called
56 void Schedule(const GURL& dictionary_url); 52 // only if the dictionary is successfully fetched.
53 virtual void Schedule(const GURL& dictionary_url,
54 const OnDictionaryFetchedCallback& callback);
Randy Smith (Not in Mondays) 2015/02/16 01:10:05 nit, confusion: Bad indentation? But if 'git cl f
Elly Fong-Jones 2015/02/17 20:35:29 Done.
55
56 // Request a dictionary fetch from cache only. The callback will be called
57 // only if the dictionary is successfully fetched.
58 virtual void ScheduleReload(const GURL& dictionary_url,
59 const OnDictionaryFetchedCallback& callback);
57 60
58 // Cancel any in-progress requests. 61 // Cancel any in-progress requests.
59 void Cancel(); 62 virtual void Cancel();
60 63
61 // Implementation of URLRequest::Delegate methods. 64 // Implementation of URLRequest::Delegate methods.
62 void OnResponseStarted(URLRequest* request) override; 65 void OnResponseStarted(URLRequest* request) override;
63 void OnReadCompleted(URLRequest* request, int bytes_read) override; 66 void OnReadCompleted(URLRequest* request, int bytes_read) override;
64 67
65 private: 68 private:
66 enum State { 69 enum State {
67 STATE_NONE, 70 STATE_NONE,
68 STATE_SEND_REQUEST, 71 STATE_SEND_REQUEST,
69 STATE_SEND_REQUEST_COMPLETE, 72 STATE_SEND_REQUEST_COMPLETE,
70 STATE_READ_BODY, 73 STATE_READ_BODY,
71 STATE_READ_BODY_COMPLETE, 74 STATE_READ_BODY_COMPLETE,
72 STATE_REQUEST_COMPLETE, 75 STATE_REQUEST_COMPLETE,
73 }; 76 };
74 77
78 // Represents an entry in the queue of SDCH dictionaries to fetch. |url| is
79 // the URL to fetch from, |download_only_from_cache| is true if the fetch
80 // should only be served from cache, and |callback| is called when this queued
81 // fetch is complete.
82 struct QueuedFetchInfo {
83 QueuedFetchInfo();
84 QueuedFetchInfo(const GURL& url,
85 bool download_only_from_cache,
86 const OnDictionaryFetchedCallback& callback);
87 QueuedFetchInfo(const QueuedFetchInfo& rhs);
88 QueuedFetchInfo& operator=(const QueuedFetchInfo& rhs);
89
90 ~QueuedFetchInfo();
91
92 GURL url;
93 bool download_only_from_cache;
94 OnDictionaryFetchedCallback callback;
95 };
96
97 // Schedule implementation.
98 void ScheduleInternal(const GURL& dictionary_url,
99 bool reload,
100 const OnDictionaryFetchedCallback& callback);
101
102 // Null out the current request and push the state machine to the
103 // next request, if any.
104 void ResetRequest();
105
75 // State machine implementation. 106 // State machine implementation.
76 int DoLoop(int rv); 107 int DoLoop(int rv);
77 int DoSendRequest(int rv); 108 int DoSendRequest(int rv);
78 int DoSendRequestComplete(int rv); 109 int DoSendRequestComplete(int rv);
79 int DoReadBody(int rv); 110 int DoReadBody(int rv);
80 int DoReadBodyComplete(int rv); 111 int DoReadBodyComplete(int rv);
81 int DoCompleteRequest(int rv); 112 int DoCompleteRequest(int rv);
82 113
83 State next_state_; 114 State next_state_;
84 bool in_loop_; 115 bool in_loop_;
85 116
86 // A queue of URLs that are being used to download dictionaries. 117 // A queue of URLs that are being used to download dictionaries.
87 std::queue<GURL> fetch_queue_; 118 std::queue<QueuedFetchInfo> fetch_queue_;
88 119
89 // The request and buffer used for getting the current dictionary 120 // The request, buffer, and consumer supplied data used for getting
90 // Both are null when a fetch is not in progress. 121 // the current dictionary. All are null when a fetch is not in progress.
91 scoped_ptr<URLRequest> current_request_; 122 scoped_ptr<URLRequest> current_request_;
92 scoped_refptr<IOBuffer> buffer_; 123 scoped_refptr<IOBuffer> buffer_;
124 OnDictionaryFetchedCallback current_callback_;
93 125
94 // The currently accumulating dictionary. 126 // The currently accumulating dictionary.
95 std::string dictionary_; 127 std::string dictionary_;
96 128
97 // Althought the SDCH spec does not preclude a server from using a single URL 129 // Althought the SDCH spec does not preclude a server from using a single URL
98 // to load several distinct dictionaries (by telling a client to load a 130 // to load several distinct dictionaries (by telling a client to load a
99 // dictionary from an URL several times), current implementations seem to have 131 // dictionary from an URL several times), current implementations seem to have
100 // that 1-1 relationship (i.e., each URL points at a single dictionary, and 132 // that 1-1 relationship (i.e., each URL points at a single dictionary, and
101 // the dictionary content does not change over time, and hence is not worth 133 // the dictionary content does not change over time, and hence is not worth
102 // trying to load more than once). In addition, some dictionaries prove 134 // trying to load more than once). In addition, some dictionaries prove
103 // unloadable only after downloading them (because they are too large? ...or 135 // unloadable only after downloading them (because they are too large? ...or
104 // malformed?). As a protective element, Chromium will *only* load a 136 // malformed?). As a protective element, Chromium will *only* load a
105 // dictionary at most once from a given URL (so that it doesn't waste 137 // dictionary at most once from a given URL (so that it doesn't waste
106 // bandwidth trying repeatedly). 138 // bandwidth trying repeatedly).
107 // The following set lists all the dictionary URLs that we've tried to load, 139 // The following set lists all the dictionary URLs that we've tried to load,
108 // so that we won't try to load from an URL more than once. 140 // so that we won't try to load from an URL more than once.
109 // TODO(jar): Try to augment the SDCH proposal to include this restiction. 141 // TODO(jar): Try to augment the SDCH proposal to include this restiction.
110 std::set<GURL> attempted_load_; 142 std::set<GURL> attempted_load_;
111 143
112 // Store the URLRequestContext associated with the owning SdchManager for 144 // Store the URLRequestContext associated with the owning SdchManager for
113 // use while fetching. 145 // use while fetching.
114 URLRequestContext* const context_; 146 URLRequestContext* const context_;
115 147
116 const OnDictionaryFetchedCallback dictionary_fetched_callback_;
117
118 base::WeakPtrFactory<SdchDictionaryFetcher> weak_factory_; 148 base::WeakPtrFactory<SdchDictionaryFetcher> weak_factory_;
119 149
120 DISALLOW_COPY_AND_ASSIGN(SdchDictionaryFetcher); 150 DISALLOW_COPY_AND_ASSIGN(SdchDictionaryFetcher);
121 }; 151 };
122 152
123 } // namespace net 153 } // namespace net
124 154
125 #endif // NET_URL_REQUEST_SDCH_DICTIONARY_FETCHER_H_ 155 #endif // NET_URL_REQUEST_SDCH_DICTIONARY_FETCHER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698