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