| /system/update_engine/common/ |
| D | multi_range_http_fetcher.cc | 36 if (delegate_) in BeginTransfer()
37 delegate_->TransferComplete(this, true); in BeginTransfer()
53 if (delegate_) in TerminateTransfer()
54 delegate_->TransferTerminated(this); in TerminateTransfer()
80 if (delegate_) in StartTransfer()
81 delegate_->SeekToOffset(range.offset()); in StartTransfer()
104 if (delegate_ && !delegate_->ReceivedBytes(this, bytes, next_size)) in ReceivedBytes()
132 if (delegate_) in TransferEnded()
133 delegate_->TransferTerminated(this); in TransferEnded()
145 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 | 81 ActionProcessorDelegate* delegate() const { return delegate_; } in delegate()
82 void set_delegate(ActionProcessorDelegate* delegate) { delegate_ = delegate; } in set_delegate()
117 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( in ReceivedBytes()
259 if (delegate_) in TransferComplete()
260 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 | 62 void set_delegate(DelegateInterface* delegate) { delegate_ = delegate; } in set_delegate()
128 DelegateInterface* delegate_{nullptr};
|
| D | postinstall_runner_action.cc | 361 if (!delegate_) in ReportProgress()
364 delegate_->ProgressUpdate(1.); in ReportProgress()
374 delegate_->ProgressUpdate(postinst_action_progress); in ReportProgress()
|
| D | filesystem_verifier_action.cc | 157 if (delegate_ != nullptr) { in UpdateProgress()
158 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/media/audio_utils/tests/ |
| D | audio_tflite_tests.cpp | 185 delegate_ = NnApiDelegate(); // singleton in BuildTestModel()
186 delegate_status = interpreter_->ModifyGraphWithDelegate(delegate_); in BuildTestModel()
194 delegate_ = nullptr; in CleanUp()
207 TfLiteDelegate* delegate_ = nullptr; member in tflite::__anona2f1aff10111::ModelTest
|
| /system/core/fs_mgr/libsnapshot/snapuserd/ |
| D | dm_user_block_server.cpp | 29 : misc_name_(misc_name), ctrl_fd_(std::move(ctrl_fd)), delegate_(delegate) { in DmUserBlockServer()
70 return delegate_->RequestSectors(header->sector, header->len); in ProcessRequest()
|
| /system/core/fs_mgr/libsnapshot/snapuserd/include/snapuserd/ |
| D | dm_user_block_server.h | 43 Delegate* delegate_; variable
|
| /system/update_engine/aosp/ |
| D | cleanup_previous_update_action.h | 73 CleanupPreviousUpdateActionDelegateInterface* delegate_; variable
|
| D | cleanup_previous_update_action.cc | 69 delegate_(delegate), in CleanupPreviousUpdateAction()
395 if (delegate_) { in OnMergePercentageUpdate()
397 delegate_->OnCleanupProgressUpdate(percentage / 100); in OnMergePercentageUpdate()
|
| /system/nvram/messages/include/nvram/messages/ |
| D | io.h | 99 InputStreamBuffer* delegate_; variable
|