Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
cangfengzhs committed Aug 25, 2021
1 parent a0e5146 commit ef7c86f
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 10 deletions.
8 changes: 4 additions & 4 deletions src/storage/exec/IndexOutputNode.h
Expand Up @@ -120,10 +120,10 @@ class IndexOutputNode final : public RelNode<T> {
private:
nebula::cpp2::ErrorCode collectResult(const std::vector<kvstore::KV>& data) {
if (context_->env()->metaClient_ &&
context_->env()->metaClient_->checkIsPlanKilled(context_->planContext_->sessionId_,
context_->planContext_->planId_)) {
return nebula::cpp2::ErrorCode::E_PLAN_IS_KILLED;
}
context_->env()->metaClient_->checkIsPlanKilled(context_->planContext_->sessionId_,
context_->planContext_->planId_)) {
return nebula::cpp2::ErrorCode::E_PLAN_IS_KILLED;
}
auto ret = nebula::cpp2::ErrorCode::SUCCEEDED;
switch (type_) {
case IndexResultType::kEdgeFromIndexScan:
Expand Down
8 changes: 2 additions & 6 deletions src/storage/mutate/UpdateEdgeProcessor.cpp
Expand Up @@ -59,12 +59,8 @@ void UpdateEdgeProcessor::doProcess(const cpp2::UpdateEdgeRequest& req) {
auto plan_id = req.common_ref().has_value() && req.common_ref().value().plan_id_ref().has_value()
? *req.get_common()->get_plan_id()
: 0;
planContext_ = std::make_unique<PlanContext>(env_,
spaceId_,
session_id,
plan_id,
spaceVidLen_,
isIntId_);
planContext_ =
std::make_unique<PlanContext>(env_, spaceId_, session_id, plan_id, spaceVidLen_, isIntId_);
context_ = std::make_unique<RuntimeContext>(planContext_.get());
if (env_->txnMan_ && env_->txnMan_->enableToss(spaceId_)) {
planContext_->defaultEdgeVer_ = 1L;
Expand Down

0 comments on commit ef7c86f

Please sign in to comment.