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

Side by Side Diff: src/platform/update_engine/update_check_action.cc

Issue 466036: AU: Beginnings of delta support (Closed)
Patch Set: Created 11 years 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 (c) 2009 The Chromium OS Authors. All rights reserved. 1 // Copyright (c) 2009 The Chromium OS 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 #include "update_engine/update_check_action.h" 5 #include "update_engine/update_check_action.h"
6 #include <sstream> 6 #include <sstream>
7 7
8 #include <libxml/parser.h> 8 #include <libxml/parser.h>
9 #include <libxml/xpath.h> 9 #include <libxml/xpath.h>
10 #include <libxml/xpathInternals.h> 10 #include <libxml/xpathInternals.h>
11 11
12 #include "chromeos/obsolete_logging.h"
12 #include "update_engine/action_pipe.h" 13 #include "update_engine/action_pipe.h"
14 #include "update_engine/utils.h"
13 15
14 using std::string; 16 using std::string;
15 17
16 namespace chromeos_update_engine { 18 namespace chromeos_update_engine {
17 19
18 const char* const UpdateCheckParams::kAppId( 20 const char* const UpdateCheckParams::kAppId(
19 "87efface-864d-49a5-9bb3-4b050a7c227a"); 21 "{87efface-864d-49a5-9bb3-4b050a7c227a}");
20 const char* const UpdateCheckParams::kOsPlatform("Chrome OS"); 22 const char* const UpdateCheckParams::kOsPlatform("Chrome OS");
21 const char* const UpdateCheckParams::kOsVersion("Indy"); 23 const char* const UpdateCheckParams::kOsVersion("Indy");
22 24
23 namespace { 25 namespace {
24 26
25 const string kGupdateVersion("ChromeOSUpdateEngine-0.1.0.0"); 27 const string kGupdateVersion("ChromeOSUpdateEngine-0.1.0.0");
26 28
27 // This is handy for passing strings into libxml2 29 // This is handy for passing strings into libxml2
28 #define ConstXMLStr(x) (reinterpret_cast<const xmlChar*>(x)) 30 #define ConstXMLStr(x) (reinterpret_cast<const xmlChar*>(x))
29 31
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after
84 // xmlNewDoc(ConstXMLStr("1.0"))); 86 // xmlNewDoc(ConstXMLStr("1.0")));
85 // if (!xml_doc.get()) { 87 // if (!xml_doc.get()) {
86 // LOG(ERROR) << "Unable to create xmlDoc"; 88 // LOG(ERROR) << "Unable to create xmlDoc";
87 // return ""; 89 // return "";
88 // } 90 // }
89 scoped_ptr_malloc<xmlChar, ScopedPtrXmlFree> str( 91 scoped_ptr_malloc<xmlChar, ScopedPtrXmlFree> str(
90 xmlEncodeEntitiesReentrant(NULL, ConstXMLStr(input.c_str()))); 92 xmlEncodeEntitiesReentrant(NULL, ConstXMLStr(input.c_str())));
91 return string(reinterpret_cast<const char *>(str.get())); 93 return string(reinterpret_cast<const char *>(str.get()));
92 } 94 }
93 95
94 UpdateCheckAction::UpdateCheckAction(const UpdateCheckParams& params, 96 UpdateCheckAction::UpdateCheckAction(HttpFetcher* http_fetcher)
95 HttpFetcher* http_fetcher) 97 : http_fetcher_(http_fetcher) {}
96 : params_(params), http_fetcher_(http_fetcher) {}
97 98
98 UpdateCheckAction::~UpdateCheckAction() {} 99 UpdateCheckAction::~UpdateCheckAction() {}
99 100
100 void UpdateCheckAction::PerformAction() { 101 void UpdateCheckAction::PerformAction() {
102 CHECK(HasInputObject());
103 params_ = GetInputObject();
101 http_fetcher_->set_delegate(this); 104 http_fetcher_->set_delegate(this);
102 string request_post(FormatRequest(params_)); 105 string request_post(FormatRequest(params_));
103 http_fetcher_->SetPostData(request_post.data(), request_post.size()); 106 http_fetcher_->SetPostData(request_post.data(), request_post.size());
104 http_fetcher_->BeginTransfer("https://tools.google.com/service/update2"); 107 http_fetcher_->BeginTransfer("https://tools.google.com/service/update2");
105 } 108 }
106 109
107 void UpdateCheckAction::TerminateProcessing() { 110 void UpdateCheckAction::TerminateProcessing() {
108 http_fetcher_->TerminateTransfer(); 111 http_fetcher_->TerminateTransfer();
109 } 112 }
110 113
111 // We just store the response in the buffer. Once we've received all bytes, 114 // We just store the response in the buffer. Once we've received all bytes,
112 // we'll look in the buffer and decide what to do. 115 // we'll look in the buffer and decide what to do.
113 void UpdateCheckAction::ReceivedBytes(HttpFetcher *fetcher, 116 void UpdateCheckAction::ReceivedBytes(HttpFetcher *fetcher,
114 const char* bytes, 117 const char* bytes,
115 int length) { 118 int length) {
116 response_buffer_.reserve(response_buffer_.size() + length); 119 response_buffer_.reserve(response_buffer_.size() + length);
117 response_buffer_.insert(response_buffer_.end(), bytes, bytes + length); 120 response_buffer_.insert(response_buffer_.end(), bytes, bytes + length);
118 } 121 }
119 122
120 namespace { 123 namespace {
121 // A little object to call ActionComplete on the ActionProcessor when
122 // it's destructed.
123 class ScopedActionCompleter {
124 public:
125 explicit ScopedActionCompleter(ActionProcessor* processor,
126 AbstractAction* action)
127 : processor_(processor), action_(action), success_(false) {}
128 ~ScopedActionCompleter() {
129 processor_->ActionComplete(action_, success_);
130 }
131 void set_success(bool success) {
132 success_ = success;
133 }
134 private:
135 ActionProcessor* processor_;
136 AbstractAction* action_;
137 bool success_;
138 DISALLOW_COPY_AND_ASSIGN(ScopedActionCompleter);
139 };
140
141 // If non-NULL response, caller is responsible for calling xmlXPathFreeObject() 124 // If non-NULL response, caller is responsible for calling xmlXPathFreeObject()
142 // on the returned object. 125 // on the returned object.
143 // This code is roughly based on the libxml tutorial at: 126 // This code is roughly based on the libxml tutorial at:
144 // http://xmlsoft.org/tutorial/apd.html 127 // http://xmlsoft.org/tutorial/apd.html
145 xmlXPathObject* GetNodeSet(xmlDoc* doc, const xmlChar* xpath, 128 xmlXPathObject* GetNodeSet(xmlDoc* doc, const xmlChar* xpath,
146 const xmlChar* ns, const xmlChar* ns_url) { 129 const xmlChar* ns, const xmlChar* ns_url) {
147 xmlXPathObject* result = NULL; 130 xmlXPathObject* result = NULL;
148 131
149 scoped_ptr_malloc<xmlXPathContext, ScopedPtrXmlXPathContextFree> context( 132 scoped_ptr_malloc<xmlXPathContext, ScopedPtrXmlXPathContextFree> context(
150 xmlXPathNewContext(doc)); 133 xmlXPathNewContext(doc));
(...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after
272 output_object.hash = XmlGetProperty(updatecheck_node, "hash"); 255 output_object.hash = XmlGetProperty(updatecheck_node, "hash");
273 output_object.size = ParseInt(XmlGetProperty(updatecheck_node, "size")); 256 output_object.size = ParseInt(XmlGetProperty(updatecheck_node, "size"));
274 output_object.needs_admin = 257 output_object.needs_admin =
275 XmlGetProperty(updatecheck_node, "needsadmin") == "true"; 258 XmlGetProperty(updatecheck_node, "needsadmin") == "true";
276 output_object.prompt = XmlGetProperty(updatecheck_node, "Prompt") == "true"; 259 output_object.prompt = XmlGetProperty(updatecheck_node, "Prompt") == "true";
277 SetOutputObject(output_object); 260 SetOutputObject(output_object);
278 return; 261 return;
279 } 262 }
280 263
281 }; // namespace chromeos_update_engine 264 }; // namespace chromeos_update_engine
OLDNEW
« no previous file with comments | « src/platform/update_engine/update_check_action.h ('k') | src/platform/update_engine/update_check_action_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698