Lines Matching refs:tm
97 TransferManagerPtr tm = static_cast<TransferManagerPtr>(arg);
98 WriterThreadInfo *info = tm->GetTransferParams()->writerThreadInfo.get();
106 auto env = tm->GetTransferParams()->env;
188 static int32_t ExecuteTransferCommand(int fd, const std::vector<std::string> &lines, TransferManagerPtr tm,
191 auto transferParams = tm->GetTransferParams();
205 if (!tm->CommandsParser(fd, lines)) {
228 static int InitThread(const struct UpdateBlockInfo &infos, TransferManagerPtr tm)
230 auto transferParams = tm->GetTransferParams();
239 int error = pthread_create(&transferParams->thread, &attr, UnpackNewData, tm);
283 static int32_t DoExecuteUpdateBlock(const UpdateBlockInfo &infos, TransferManagerPtr tm,
287 auto env = tm->GetTransferParams()->env;
293 int32_t ret = ExecuteTransferCommand(fd, lines, tm, context, infos);
362 std::unique_ptr<TransferManager> tm = std::make_unique<TransferManager>();
364 auto transferParams = tm->GetTransferParams();
381 if (InitThread(infos, tm.get()) != 0) {
387 return DoExecuteUpdateBlock(infos, tm.get(), outStream, lines, context);
505 std::unique_ptr<TransferManager> tm = std::make_unique<TransferManager>();
506 auto transferParams = tm->GetTransferParams();
524 if (!tm->CommandsParser(fd, lines)) {