Lines Matching refs:transferParams_
32 transferParams_ = std::make_unique<TransferParams>();
33 transferParams_->writerThreadInfo = std::make_unique<WriterThreadInfo>();
65 transferParams_->version = Utils::String2Int<size_t>(*ct++, Utils::N_DEC);
66 transferParams_->blockCount = Utils::String2Int<size_t>(*ct++, Utils::N_DEC);
67 transferParams_->maxEntries = Utils::String2Int<size_t>(*ct++, Utils::N_DEC);
68 transferParams_->maxBlocks = Utils::String2Int<size_t>(*ct++, Utils::N_DEC);
69 if (transferParams_->env != nullptr && transferParams_->env->IsRetry()) {
81 if (transferParams_ == nullptr) {
82 LOG(ERROR) << "transferParams_ is nullptr";
97 size_t totalSize = transferParams_->blockCount;
100 std::unique_ptr<Command> cmd = std::make_unique<Command>(transferParams_.get());
105 if (!cmd->Init(*ct) || transferParams_->env == nullptr) {
108 if (!retryCmd.empty() && transferParams_->env->IsRetry()) {
117 if (!transferParams_->canWrite && !JudgeBlockVerifyCmdType(*cmd)) {
124 if (!transferParams_->canWrite) {
128 initBlock = transferParams_->written;
130 if (totalSize != 0 && (transferParams_->written - initBlock) > 0) {
142 float p = static_cast<float>(transferParams_->written - initBlock) / totalSize\
145 initBlock = transferParams_->written;
150 std::string path = transferParams_->retryFile;
167 std::string path = transferParams_->retryFile;
192 if (transferParams_->env != nullptr) {
193 transferParams_->env->PostMessage("retry_update", IO_FAILED_REBOOT);