OLD | NEW |
1 // Copyright (c) 2010 The Chromium OS Authors. All rights reserved. | 1 // Copyright (c) 2010 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/download_action.h" | 5 #include "update_engine/download_action.h" |
6 #include <errno.h> | 6 #include <errno.h> |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <string> | 8 #include <string> |
9 #include <vector> | 9 #include <vector> |
10 #include <glib.h> | 10 #include <glib.h> |
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
100 if (writer_) { | 100 if (writer_) { |
101 LOG_IF(WARNING, writer_->Close() != 0) << "Error closing the writer."; | 101 LOG_IF(WARNING, writer_->Close() != 0) << "Error closing the writer."; |
102 writer_ = NULL; | 102 writer_ = NULL; |
103 } | 103 } |
104 http_fetcher_->TerminateTransfer(); | 104 http_fetcher_->TerminateTransfer(); |
105 if (delegate_) { | 105 if (delegate_) { |
106 delegate_->SetDownloadStatus(false); // Set to inactive. | 106 delegate_->SetDownloadStatus(false); // Set to inactive. |
107 } | 107 } |
108 } | 108 } |
109 | 109 |
| 110 void DownloadAction::SeekToOffset(off_t offset) { |
| 111 bytes_received_ = offset; |
| 112 } |
| 113 |
110 void DownloadAction::ReceivedBytes(HttpFetcher *fetcher, | 114 void DownloadAction::ReceivedBytes(HttpFetcher *fetcher, |
111 const char* bytes, | 115 const char* bytes, |
112 int length) { | 116 int length) { |
113 bytes_received_ += length; | 117 bytes_received_ += length; |
114 if (delegate_) | 118 if (delegate_) |
115 delegate_->BytesReceived(bytes_received_, install_plan_.size); | 119 delegate_->BytesReceived(bytes_received_, install_plan_.size); |
116 if (writer_ && writer_->Write(bytes, length) < 0) { | 120 if (writer_ && writer_->Write(bytes, length) < 0) { |
117 LOG(ERROR) << "Write error -- terminating processing."; | 121 LOG(ERROR) << "Write error -- terminating processing."; |
118 TerminateProcessing(); | 122 TerminateProcessing(); |
119 processor_->ActionComplete(this, kActionCodeDownloadWriteError); | 123 processor_->ActionComplete(this, kActionCodeDownloadWriteError); |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
181 | 185 |
182 FlushLinuxCaches(); | 186 FlushLinuxCaches(); |
183 | 187 |
184 // Write the path to the output pipe if we're successful. | 188 // Write the path to the output pipe if we're successful. |
185 if (code == kActionCodeSuccess && HasOutputPipe()) | 189 if (code == kActionCodeSuccess && HasOutputPipe()) |
186 SetOutputObject(GetInputObject()); | 190 SetOutputObject(GetInputObject()); |
187 processor_->ActionComplete(this, code); | 191 processor_->ActionComplete(this, code); |
188 } | 192 } |
189 | 193 |
190 }; // namespace {} | 194 }; // namespace {} |
OLD | NEW |