OLD | NEW |
---|---|
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 Loading... | |
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_ |
OLD | NEW |