Home
last modified time | relevance | path

Searched refs:writerThreadInfo (Results 1 - 8 of 8) sorted by relevance

/base/update/updater/services/applypatch/
H A Dcommand_process.cpp48 auto writerThreadInfo = params.GetTransferParams()->writerThreadInfo.get(); in Execute() local
49 pthread_mutex_lock(&writerThreadInfo->mutex); in Execute()
50 writerThreadInfo->writer = std::make_unique<BlockWriter>(params.GetFileDescriptor(), bs); in Execute()
51 pthread_cond_broadcast(&writerThreadInfo->cond); in Execute()
52 while (writerThreadInfo->writer != nullptr) { in Execute()
54 if (!writerThreadInfo->readyToWrite) { in Execute()
56 writerThreadInfo->writer->GetTotalWritten() << " bytes lost"; in Execute()
57 pthread_mutex_unlock(&writerThreadInfo->mutex); in Execute()
58 writerThreadInfo in Execute()
[all...]
H A Dtransfer_manager.cpp33 transferParams_->writerThreadInfo = std::make_unique<WriterThreadInfo>(); in TransferManager()
/base/update/updater/services/diffpatch/patch_shared/
H A Dpatch_shared.cpp156 auto writerThreadInfo = transferParams->writerThreadInfo.get(); in ExecuteTransferCommand() local
170 pthread_mutex_lock(&writerThreadInfo->mutex); in ExecuteTransferCommand()
171 if (writerThreadInfo->readyToWrite) { in ExecuteTransferCommand()
175 writerThreadInfo->readyToWrite = false; in ExecuteTransferCommand()
176 pthread_cond_broadcast(&writerThreadInfo->cond); in ExecuteTransferCommand()
177 pthread_mutex_unlock(&writerThreadInfo->mutex); in ExecuteTransferCommand()
265 WriterThreadInfo *info = tm->GetTransferParams()->writerThreadInfo.get(); in UnpackNewDataFunc()
300 auto writerThreadInfo = transferParams->writerThreadInfo in InitThread() local
[all...]
/base/update/updater/services/updater_binary/
H A Dupdate_image_block.cpp98 WriterThreadInfo *info = tm->GetTransferParams()->writerThreadInfo.get(); in UnpackNewData()
192 auto writerThreadInfo = transferParams->writerThreadInfo.get(); in ExecuteTransferCommand() local
208 pthread_mutex_lock(&writerThreadInfo->mutex); in ExecuteTransferCommand()
209 if (writerThreadInfo->readyToWrite) { in ExecuteTransferCommand()
213 writerThreadInfo->readyToWrite = false; in ExecuteTransferCommand()
214 pthread_cond_broadcast(&writerThreadInfo->cond); in ExecuteTransferCommand()
215 pthread_mutex_unlock(&writerThreadInfo->mutex); in ExecuteTransferCommand()
231 auto writerThreadInfo = transferParams->writerThreadInfo in InitThread() local
[all...]
/base/update/updater/test/unittest/applypatch_test/
H A Dcommands_unittest.cpp58 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>(); in HWTEST_F()
76 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>(); in HWTEST_F()
H A Dcommandsfunction_unittest.cpp65 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>(); in HWTEST_F()
H A Dblockset_unittest.cpp124 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>(); in HWTEST_F()
/base/update/updater/services/include/applypatch/
H A Dtransfer_manager.h49 std::unique_ptr<WriterThreadInfo> writerThreadInfo; member

Completed in 7 milliseconds