diff --git a/src/kvstore/raftex/RaftPart.cpp b/src/kvstore/raftex/RaftPart.cpp index e02e1eb6674..645e0b60fcd 100644 --- a/src/kvstore/raftex/RaftPart.cpp +++ b/src/kvstore/raftex/RaftPart.cpp @@ -697,19 +697,19 @@ folly::Future RaftPart::appendLogAsync(ClusterID source // until majority accept the logs, the leadership changes, or // the partition stops VLOG(4) << idStr_ << "Calling appendLogsInternal()"; - AppendLogsIterator it(firstId, - termId, - std::move(swappedOutLogs), - [this](AtomicOp opCB) -> folly::Optional { - CHECK(opCB != nullptr); - auto opRet = opCB(); - if (!opRet.hasValue()) { - // Failed - sendingPromise_.setOneSingleValue( - nebula::cpp2::ErrorCode::E_RAFT_ATOMIC_OP_FAILED); - } - return opRet; - }); + AppendLogsIterator it( + firstId, + termId, + std::move(swappedOutLogs), + [this](AtomicOp opCB) -> folly::Optional { + CHECK(opCB != nullptr); + auto opRet = opCB(); + if (!opRet.hasValue()) { + // Failed + sendingPromise_.setOneSingleValue(nebula::cpp2::ErrorCode::E_RAFT_ATOMIC_OP_FAILED); + } + return opRet; + }); appendLogsInternal(std::move(it), termId); return retFuture;