Skip to content

Commit

Permalink
Switched to use third-party v3
Browse files Browse the repository at this point in the history
1) Switched from HeaderClientChannel to the RocketChannel
   (common/thrif/ThriftClientManager-inc.h)
2) Fixed a bug in common/process/ProcessUtils.cpp
3) Fixed all UT
4) 99.9% of changes are mechanical: set_xxx(yyy)  ==> xxx_ref() = yyy
  • Loading branch information
sherman-the-tank committed Dec 13, 2021
1 parent 9a0fbb6 commit e3cb2fa
Show file tree
Hide file tree
Showing 194 changed files with 4,494 additions and 4,425 deletions.
1 change: 0 additions & 1 deletion cmake/nebula/ThirdPartyConfig.cmake
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,6 @@ set(CMAKE_EXE_LINKER_FLAGS "${CMAKE_EXE_LINKER_FLAGS} -L ${NEBULA_THIRDPARTY_ROO
# All thrift libraries
set(THRIFT_LIBRARIES
thriftcpp2
rocketupgrade
async
thriftprotocol
transport
Expand Down
314 changes: 157 additions & 157 deletions src/clients/meta/MetaClient.cpp

Large diffs are not rendered by default.

19 changes: 10 additions & 9 deletions src/clients/storage/InternalStorageClient.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -55,10 +55,10 @@ void InternalStorageClient::chainUpdateEdge(cpp2::UpdateEdgeRequest& reversedReq
VLOG(1) << "leader host: " << leader;

cpp2::ChainUpdateEdgeRequest chainReq;
chainReq.set_update_edge_request(reversedRequest);
chainReq.set_term(termOfSrc);
chainReq.update_edge_request_ref() = reversedRequest;
chainReq.term_ref() = termOfSrc;
if (optVersion) {
chainReq.set_edge_version(optVersion.value());
chainReq.edge_version_ref() = optVersion.value();
}
auto resp = getResponse(
evb,
Expand All @@ -79,6 +79,7 @@ void InternalStorageClient::chainUpdateEdge(cpp2::UpdateEdgeRequest& reversedReq
});
}


void InternalStorageClient::chainAddEdges(cpp2::AddEdgesRequest& directReq,
TermID termId,
folly::Optional<int64_t> optVersion,
Expand Down Expand Up @@ -120,13 +121,13 @@ cpp2::ChainAddEdgesRequest InternalStorageClient::makeChainAddReq(const cpp2::Ad
TermID termId,
folly::Optional<int64_t> ver) {
cpp2::ChainAddEdgesRequest ret;
ret.set_space_id(req.get_space_id());
ret.set_parts(req.get_parts());
ret.set_prop_names(req.get_prop_names());
ret.set_if_not_exists(req.get_if_not_exists());
ret.set_term(termId);
ret.space_id_ref() = req.get_space_id();
ret.parts_ref() = req.get_parts();
ret.prop_names_ref() = req.get_prop_names();
ret.if_not_exists_ref() = req.get_if_not_exists();
ret.term_ref() = termId;
if (ver) {
ret.set_edge_version(ver.value());
ret.edge_version_ref() = ver.value();
}
return ret;
}
Expand Down
Loading

0 comments on commit e3cb2fa

Please sign in to comment.