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

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: Add unit tests for attempted load 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. Returns true if a
53 // request for |dictionary_url| has been scheduled, and false otherwise.
54 virtual bool Schedule(const GURL& dictionary_url,
55 const OnDictionaryFetchedCallback& callback);
56
57 // Request a dictionary fetch from cache only. The callback will be called
58 // only if the dictionary is successfully fetched. Returns true if a request
59 // for |dictionary_url| has been scheduled, and false otherwise.
60 virtual bool ScheduleReload(const GURL& dictionary_url,
61 const OnDictionaryFetchedCallback& callback);
57 62
58 // Cancel any in-progress requests. 63 // Cancel any in-progress requests.
59 void Cancel(); 64 virtual void Cancel();
60 65
61 // Implementation of URLRequest::Delegate methods. 66 // Implementation of URLRequest::Delegate methods.
62 void OnResponseStarted(URLRequest* request) override; 67 void OnResponseStarted(URLRequest* request) override;
63 void OnReadCompleted(URLRequest* request, int bytes_read) override; 68 void OnReadCompleted(URLRequest* request, int bytes_read) override;
64 69
65 private: 70 private:
66 enum State { 71 enum State {
67 STATE_NONE, 72 STATE_NONE,
68 STATE_SEND_REQUEST, 73 STATE_SEND_REQUEST,
69 STATE_SEND_REQUEST_COMPLETE, 74 STATE_SEND_REQUEST_COMPLETE,
70 STATE_READ_BODY, 75 STATE_READ_BODY,
71 STATE_READ_BODY_COMPLETE, 76 STATE_READ_BODY_COMPLETE,
72 STATE_REQUEST_COMPLETE, 77 STATE_REQUEST_COMPLETE,
73 }; 78 };
74 79
80 // Represents an entry in the queue of SDCH dictionaries to fetch. |url| is
81 // the URL to fetch from, |download_only_from_cache| is true if the fetch
82 // should only be served from cache, and |callback| is called when this queued
83 // fetch is complete.
84 struct QueuedFetchInfo {
85 QueuedFetchInfo();
86 QueuedFetchInfo(const GURL& url,
87 bool download_only_from_cache,
88 const OnDictionaryFetchedCallback& callback);
89 QueuedFetchInfo(const QueuedFetchInfo& rhs);
90 QueuedFetchInfo& operator=(const QueuedFetchInfo& rhs);
91
92 ~QueuedFetchInfo();
93
94 GURL url;
95 bool download_only_from_cache;
96 OnDictionaryFetchedCallback callback;
97 };
98
99 // Schedule implementation. Returns true if a request for |dictionary_url| has
100 // been added to the queue, and false otherwise.
101 bool ScheduleInternal(const GURL& dictionary_url,
102 bool reload,
103 const OnDictionaryFetchedCallback& callback);
104
105 // Null out the current request and push the state machine to the
106 // next request, if any.
107 void ResetRequest();
108
75 // State machine implementation. 109 // State machine implementation.
76 int DoLoop(int rv); 110 int DoLoop(int rv);
77 int DoSendRequest(int rv); 111 int DoSendRequest(int rv);
78 int DoSendRequestComplete(int rv); 112 int DoSendRequestComplete(int rv);
79 int DoReadBody(int rv); 113 int DoReadBody(int rv);
80 int DoReadBodyComplete(int rv); 114 int DoReadBodyComplete(int rv);
81 int DoCompleteRequest(int rv); 115 int DoCompleteRequest(int rv);
82 116
83 State next_state_; 117 State next_state_;
84 bool in_loop_; 118 bool in_loop_;
85 119
86 // A queue of URLs that are being used to download dictionaries. 120 // A queue of URLs that are being used to download dictionaries.
87 std::queue<GURL> fetch_queue_; 121 std::queue<QueuedFetchInfo> fetch_queue_;
88 122
89 // The request and buffer used for getting the current dictionary 123 // The request, buffer, and consumer supplied data used for getting
90 // Both are null when a fetch is not in progress. 124 // the current dictionary. All are null when a fetch is not in progress.
91 scoped_ptr<URLRequest> current_request_; 125 scoped_ptr<URLRequest> current_request_;
92 scoped_refptr<IOBuffer> buffer_; 126 scoped_refptr<IOBuffer> buffer_;
127 OnDictionaryFetchedCallback current_callback_;
93 128
94 // The currently accumulating dictionary. 129 // The currently accumulating dictionary.
95 std::string dictionary_; 130 std::string dictionary_;
96 131
97 // Althought the SDCH spec does not preclude a server from using a single URL 132 // 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 133 // to load several distinct dictionaries (by telling a client to load a
99 // dictionary from an URL several times), current implementations seem to have 134 // 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 135 // 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 136 // 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 137 // trying to load more than once). In addition, some dictionaries prove
103 // unloadable only after downloading them (because they are too large? ...or 138 // unloadable only after downloading them (because they are too large? ...or
104 // malformed?). As a protective element, Chromium will *only* load a 139 // 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 140 // dictionary at most once from a given URL (so that it doesn't waste
106 // bandwidth trying repeatedly). 141 // bandwidth trying repeatedly).
107 // The following set lists all the dictionary URLs that we've tried to load, 142 // 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. 143 // 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. 144 // TODO(jar): Try to augment the SDCH proposal to include this restiction.
110 std::set<GURL> attempted_load_; 145 std::set<GURL> attempted_load_;
111 146
112 // Store the URLRequestContext associated with the owning SdchManager for 147 // Store the URLRequestContext associated with the owning SdchManager for
113 // use while fetching. 148 // use while fetching.
114 URLRequestContext* const context_; 149 URLRequestContext* const context_;
115 150
116 const OnDictionaryFetchedCallback dictionary_fetched_callback_;
117
118 base::WeakPtrFactory<SdchDictionaryFetcher> weak_factory_; 151 base::WeakPtrFactory<SdchDictionaryFetcher> weak_factory_;
119 152
120 DISALLOW_COPY_AND_ASSIGN(SdchDictionaryFetcher); 153 DISALLOW_COPY_AND_ASSIGN(SdchDictionaryFetcher);
121 }; 154 };
122 155
123 } // namespace net 156 } // namespace net
124 157
125 #endif // NET_URL_REQUEST_SDCH_DICTIONARY_FETCHER_H_ 158 #endif // NET_URL_REQUEST_SDCH_DICTIONARY_FETCHER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698