| /system/update_engine/common/ |
| D | multi_range_http_fetcher.cc | 38 if (delegate_) in BeginTransfer()
39 delegate_->TransferComplete(this, true); in BeginTransfer()
55 if (delegate_) in TerminateTransfer()
56 delegate_->TransferTerminated(this); in TerminateTransfer()
82 if (delegate_) in StartTransfer()
83 delegate_->SeekToOffset(range.offset()); in StartTransfer()
106 if (delegate_ && !delegate_->ReceivedBytes(this, bytes, next_size)) in ReceivedBytes()
134 if (delegate_) in TransferEnded()
135 delegate_->TransferTerminated(this); in TransferEnded()
147 if (delegate_) in TransferEnded()
[all …]
|
| D | file_fetcher.cc | 66 if (delegate_) in BeginTransfer()
67 delegate_->TransferComplete(this, false); in BeginTransfer()
90 if (delegate_) in BeginTransfer()
91 delegate_->TransferComplete(this, false); in BeginTransfer()
105 if (delegate_) { in TerminateTransfer()
107 delegate_->TransferTerminated(this); in TerminateTransfer()
137 if (delegate_) in ScheduleRead()
138 delegate_->TransferComplete(this, false); in ScheduleRead()
146 if (delegate_) in OnReadDoneCallback()
147 delegate_->TransferComplete(this, true); in OnReadDoneCallback()
[all …]
|
| D | action_processor.cc | 68 if (delegate_) in StopProcessing()
69 delegate_->ProcessingStopped(this); in StopProcessing()
111 if (delegate_) in ActionComplete()
112 delegate_->ActionCompleted(this, actionptr, code); in ActionComplete()
136 if (delegate_) { in StartNextActionOrFinish()
137 delegate_->ProcessingDone(this, code); in StartNextActionOrFinish()
|
| D | action_processor_unittest.cc | 98 action_processor_.set_delegate(&delegate_); in SetUp()
113 MyActionProcessorDelegate delegate_{&action_processor_}; member in chromeos_update_engine::ActionProcessorTest
139 EXPECT_TRUE(delegate_.processing_done_called_); in TEST_F()
140 EXPECT_TRUE(delegate_.action_completed_called_); in TEST_F()
147 EXPECT_TRUE(delegate_.processing_stopped_called_); in TEST_F()
148 EXPECT_FALSE(delegate_.action_completed_called_); in TEST_F()
244 EXPECT_FALSE(delegate_.processing_done_called_); in TEST_F()
248 EXPECT_TRUE(delegate_.processing_done_called_); in TEST_F()
249 EXPECT_FALSE(delegate_.processing_stopped_called_); in TEST_F()
264 EXPECT_TRUE(delegate_.processing_stopped_called_); in TEST_F()
[all …]
|
| D | mock_http_fetcher.cc | 77 CHECK(delegate_); in SendData()
78 delegate_->ReceivedBytes( in SendData()
103 if (delegate_) { in TerminateTransfer()
104 delegate_->TransferTerminated(this); in TerminateTransfer()
144 delegate_->TransferComplete(this, !fail_transfer_); in SignalTransferComplete()
|
| D | http_fetcher.h | 53 delegate_(nullptr), in HttpFetcher()
58 void set_delegate(HttpFetcherDelegate* delegate) { delegate_ = delegate; } in set_delegate()
59 HttpFetcherDelegate* delegate() const { return delegate_; } in delegate()
162 HttpFetcherDelegate* delegate_ = nullptr; variable
|
| D | action_processor.h | 82 ActionProcessorDelegate* delegate() const { return delegate_; } in delegate()
83 void set_delegate(ActionProcessorDelegate* delegate) { delegate_ = delegate; } in set_delegate()
118 ActionProcessorDelegate* delegate_{nullptr};
|
| D | download_action.h | 106 DownloadActionDelegate* delegate() const { return delegate_; } in delegate()
107 void set_delegate(DownloadActionDelegate* delegate) { delegate_ = delegate; } in set_delegate()
144 DownloadActionDelegate* delegate_; variable
|
| D | mock_http_fetcher.h | 65 if (delegate_) in SetOffset()
66 delegate_->SeekToOffset(offset); in SetOffset()
|
| /system/update_engine/ |
| D | download_action.cc | 51 delegate_(nullptr), in DownloadAction()
133 delegate_, in StartDownloading()
156 delegate_, in StartDownloading()
221 if (delegate_ && download_active_) { in ReceivedBytes()
222 delegate_->BytesReceived(length, bytes_downloaded_total, bytes_total_); in ReceivedBytes()
254 if (delegate_) in TransferComplete()
255 delegate_->DownloadComplete(); in TransferComplete()
|
| D | libcurl_http_fetcher.cc | 360 if (delegate_) { in ForceTransferTermination()
362 delegate_->TransferTerminated(this); in ForceTransferTermination()
546 if (delegate_) in CurlPerformOnce()
547 delegate_->TransferComplete(this, false); // signal fail in CurlPerformOnce()
560 if (delegate_) in CurlPerformOnce()
561 delegate_->TransferComplete(this, false); // signal fail in CurlPerformOnce()
574 if (delegate_) { in CurlPerformOnce()
576 delegate_->TransferComplete(this, success); in CurlPerformOnce()
611 if (delegate_) { in LibcurlWrite()
613 auto should_terminate = !delegate_->ReceivedBytes(this, ptr, payload_size); in LibcurlWrite()
|
| /system/update_engine/payload_consumer/ |
| D | filesystem_verifier_action.h | 77 this->delegate_ = delegate; in set_delegate()
80 return this->delegate_; in get_delegate()
173 FilesystemVerifyDelegate* delegate_{};
|
| D | postinstall_runner_action.h | 61 void set_delegate(DelegateInterface* delegate) { delegate_ = delegate; } in set_delegate()
127 DelegateInterface* delegate_{nullptr};
|
| D | postinstall_runner_action.cc | 360 if (!delegate_) in ReportProgress()
363 delegate_->ProgressUpdate(1.); in ReportProgress()
373 delegate_->ProgressUpdate(postinst_action_progress); in ReportProgress()
|
| D | filesystem_verifier_action.cc | 164 if (delegate_ != nullptr) { in UpdateProgress()
165 delegate_->OnVerifyProgressUpdate(progress); in UpdateProgress()
|
| /system/nvram/messages/ |
| D | io.cpp | 138 delegate_(delegate), in NestedInputStreamBuffer()
142 remaining_ -= end_ - delegate_->pos_; in Advance()
144 delegate_->pos_ = end_; in Advance()
147 bool status = delegate_->Advance(); in Advance()
148 pos_ = delegate_->pos_; in Advance()
149 end_ = ClampEnd(delegate_, remaining_); in Advance()
|
| /system/update_engine/aosp/ |
| D | cleanup_previous_update_action.h | 73 CleanupPreviousUpdateActionDelegateInterface* delegate_; variable
|
| D | cleanup_previous_update_action.cc | 65 delegate_(delegate), in CleanupPreviousUpdateAction()
364 if (delegate_) { in OnMergePercentageUpdate()
366 delegate_->OnCleanupProgressUpdate(percentage / 100); in OnMergePercentageUpdate()
|
| /system/nvram/messages/include/nvram/messages/ |
| D | io.h | 99 InputStreamBuffer* delegate_; variable
|