Lines Matching refs:tm
129 TransferManagerPtr tm, const std::string &partitionName, const std::string &targetPath) in ExecuteTransferCommand() argument
131 auto transferParams = tm->GetTransferParams(); in ExecuteTransferCommand()
143 if (!tm->CommandsParser(fd, lines)) { in ExecuteTransferCommand()
167 static int32_t DoExecuteUpdateBlock(const UpdateBlockInfo &infos, TransferManagerPtr tm, in DoExecuteUpdateBlock() argument
175 int32_t ret = ExecuteTransferCommand(fd, lines, tm, infos.partitionName, targetPath); in DoExecuteUpdateBlock()
241 TransferManagerPtr tm = static_cast<TransferManagerPtr>(arg); in UnpackNewDataFunc() local
242 WriterThreadInfo *info = tm->GetTransferParams()->writerThreadInfo.get(); in UnpackNewDataFunc()
250 auto env = tm->GetTransferParams()->env; in UnpackNewDataFunc()
274 static int InitThread(const struct UpdateBlockInfo &infos, TransferManagerPtr tm) in InitThread() argument
276 auto transferParams = tm->GetTransferParams(); in InitThread()
285 int error = pthread_create(&transferParams->thread, &attr, UnpackNewDataFunc, tm); in InitThread()
350 std::unique_ptr<TransferManager> tm = std::make_unique<TransferManager>(); in ExecuteUpdateBlock() local
351 auto transferParams = tm->GetTransferParams(); in ExecuteUpdateBlock()
379 if (InitThread(infos, tm.get()) != 0) { in ExecuteUpdateBlock()
383 int32_t ret = DoExecuteUpdateBlock(infos, tm.get(), lines, targetPath, destImage); in ExecuteUpdateBlock()