Searched refs:transferParams (Results 1 – 6 of 6) sorted by relevance
131 auto transferParams = tm->GetTransferParams(); in ExecuteTransferCommand() local132 auto writerThreadInfo = transferParams->writerThreadInfo.get(); in ExecuteTransferCommand()141 transferParams->storeCreated = ret; in ExecuteTransferCommand()154 ret = pthread_join(transferParams->thread, nullptr); in ExecuteTransferCommand()160 if (transferParams->storeCreated != -1) { in ExecuteTransferCommand()161 Store::DoFreeSpace(transferParams->storeBase); in ExecuteTransferCommand()162 (void)Utils::DeleteFile(transferParams->storeBase); in ExecuteTransferCommand()276 auto transferParams = tm->GetTransferParams(); in InitThread() local351 auto transferParams = tm->GetTransferParams(); in ExecuteUpdateBlock() local353 transferParams->env = &env; in ExecuteUpdateBlock()[all …]
64 std::unique_ptr<TransferParams> transferParams = std::make_unique<TransferParams>(); variable65 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();66 std::shared_ptr<Command> cmd = std::make_shared<Command>(transferParams.get());68 transferParams->storeBase = "data/updater/updater/tmp/cmdtest";69 Store::DoFreeSpace(transferParams->storeBase);70 Utils::MkdirRecursive(transferParams->storeBase, dirMode);83 transferParams->storeCreated = 0;
57 std::unique_ptr<TransferParams> transferParams = std::make_unique<TransferParams>(); variable58 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();59 Command *cmd = new Command(transferParams.get());75 std::unique_ptr<TransferParams> transferParams = std::make_unique<TransferParams>(); variable76 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();77 Command *cmd = new Command(transferParams.get());
123 std::unique_ptr<TransferParams> transferParams = std::make_unique<TransferParams>(); variable124 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();125 Command *cmd = new Command(transferParams.get());
191 auto transferParams = tm->GetTransferParams(); in ExecuteTransferCommand() local196 transferParams->devPath = infos.devPath; in ExecuteTransferCommand()198 int32_t ret = Store::CreateNewSpace(transferParams->storeBase, !transferParams->env->IsRetry()); in ExecuteTransferCommand()203 transferParams->storeCreated = ret; in ExecuteTransferCommand()216 ret = pthread_join(transferParams->thread, nullptr); in ExecuteTransferCommand()222 if (transferParams->storeCreated != -1) { in ExecuteTransferCommand()223 Store::DoFreeSpace(transferParams->storeBase); in ExecuteTransferCommand()230 auto transferParams = tm->GetTransferParams(); in InitThread() local364 auto transferParams = tm->GetTransferParams(); in ExecuteUpdateBlock() local366 transferParams->env = &env; in ExecuteUpdateBlock()[all …]
33 explicit Command(TransferParams* transferParams):transferParams_(transferParams) {} in Command() argument