Skip to content

Commit

Permalink
update license & fix gcc compile error
Browse files Browse the repository at this point in the history
  • Loading branch information
liuyu85cn committed Dec 13, 2021
1 parent 5d7c392 commit 421473b
Show file tree
Hide file tree
Showing 13 changed files with 16 additions and 28 deletions.
2 changes: 1 addition & 1 deletion src/storage/mutate/DeleteEdgesProcessor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ void DeleteEdgesProcessor::process(const cpp2::DeleteEdgesRequest& req) {
spaceId_,
partId,
std::move(para.result.value()),
[partId, this](nebula::cpp2::ErrorCode code) { handleAsync(spaceId_, partId, code); });
[partId, this](nebula::cpp2::ErrorCode rc) { handleAsync(spaceId_, partId, rc); });
} else {
doRemove(spaceId_, partId, std::move(keys));
}
Expand Down
3 changes: 1 addition & 2 deletions src/storage/test/ChainDeleteEdgesTest.cpp
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#include <folly/Benchmark.h>
Expand Down
7 changes: 3 additions & 4 deletions src/storage/transaction/ChainDeleteEdgesGroupProcessor.cpp
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#include "storage/transaction/ChainDeleteEdgesGroupProcessor.h"
Expand Down Expand Up @@ -30,15 +29,15 @@ void ChainDeleteEdgesGroupProcessor::process(const cpp2::DeleteEdgesRequest& req

callingNum_ = splitedRequest.size();

auto fnSplit = [&](auto& req) {
auto fnSplit = [&](auto& request) {
auto* proc = ChainDeleteEdgesLocalProcessor::instance(env_);
proc->getFuture().thenValue([=](auto&& resp) {
auto code = resp.get_result().get_failed_parts().empty()
? nebula::cpp2::ErrorCode::SUCCEEDED
: resp.get_result().get_failed_parts().begin()->get_code();
handleAsync(spaceId, localPartId, code);
});
proc->process(req.second);
proc->process(request.second);
};

std::for_each(splitedRequest.begin(), splitedRequest.end(), fnSplit);
Expand Down
3 changes: 1 addition & 2 deletions src/storage/transaction/ChainDeleteEdgesGroupProcessor.h
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#pragma once
Expand Down
3 changes: 1 addition & 2 deletions src/storage/transaction/ChainDeleteEdgesLocalProcessor.cpp
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#include "storage/transaction/ChainDeleteEdgesLocalProcessor.h"
Expand Down
3 changes: 1 addition & 2 deletions src/storage/transaction/ChainDeleteEdgesLocalProcessor.h
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#pragma once
Expand Down
3 changes: 1 addition & 2 deletions src/storage/transaction/ChainDeleteEdgesRemoteProcessor.cpp
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#include "storage/transaction/ChainDeleteEdgesRemoteProcessor.h"
Expand Down
3 changes: 1 addition & 2 deletions src/storage/transaction/ChainDeleteEdgesRemoteProcessor.h
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#pragma once
Expand Down
3 changes: 1 addition & 2 deletions src/storage/transaction/ChainDeleteEdgesResumeProcessor.cpp
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#include "storage/transaction/ChainDeleteEdgesResumeProcessor.h"
Expand Down
3 changes: 1 addition & 2 deletions src/storage/transaction/ChainDeleteEdgesResumeProcessor.h
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#pragma once
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#include "storage/transaction/ChainDeleteEdgesResumeRemoteProcessor.h"
Expand Down Expand Up @@ -52,8 +51,8 @@ folly::SemiFuture<Code> ChainDeleteEdgesResumeRemoteProcessor::processLocal(Code

folly::Baton<true, std::atomic> baton;
env_->kvstore_->asyncMultiRemove(
spaceId_, localPartId_, std::move(doublePrimeKeys), [this](auto&& code) {
this->code_ = code;
spaceId_, localPartId_, std::move(doublePrimeKeys), [this](auto&& rc) {
this->code_ = rc;
});
baton.wait();
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
* This source code is licensed under Apache 2.0 License.
*/

#pragma once
Expand Down
1 change: 0 additions & 1 deletion src/storage/transaction/ConsistTypes.h
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
/* Copyright (c) 2021 vesoft inc. All rights reserved.
*
* This source code is licensed under Apache 2.0 License,
* attached with Common Clause Condition 1.0, found in the LICENSES directory.
*/

#pragma once
Expand Down

0 comments on commit 421473b

Please sign in to comment.