Skip to content

Commit

Permalink
refactor and rename range to scan_range
Browse files Browse the repository at this point in the history
  • Loading branch information
YoshiakiNishimura committed Nov 13, 2024
1 parent e8c2287 commit 75b8abf
Show file tree
Hide file tree
Showing 15 changed files with 289 additions and 182 deletions.
4 changes: 2 additions & 2 deletions src/jogasaki/executor/process/impl/bound.h
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ class bound {
bound() = default;
bound(bound const& other) = delete;
bound& operator=(bound const& other) = delete;
bound(bound&& other) noexcept = delete;
bound& operator=(bound&& other) noexcept = delete;
bound(bound&& other) noexcept = default;
bound& operator=(bound&& other) noexcept = default;
~bound() = default;
bound(kvs::end_point_kind endpointkind, std::size_t len,
std::unique_ptr<data::aligned_buffer> key)
Expand Down
32 changes: 13 additions & 19 deletions src/jogasaki/executor/process/impl/ops/details/encode_key.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -97,34 +97,28 @@ status encode_key( //NOLINT(readability-function-cognitive-complexity)
return status::ok;
}

status two_encode_keys(
request_context* context,
status two_encode_keys(request_context* context,
std::vector<details::search_key_field_info> const& begin_keys,
std::vector<details::search_key_field_info> const& end_keys,
variable_table& input_variables,
memory::lifo_paged_memory_resource& resource,
data::aligned_buffer& key_begin,
std::size_t& blen,
data::aligned_buffer& key_end,
std::size_t& elen
) {
std::vector<details::search_key_field_info> const& end_keys, variable_table& input_variables,
memory::lifo_paged_memory_resource& resource, data::aligned_buffer& key_begin,
std::size_t& blen, data::aligned_buffer& key_end, std::size_t& elen) {
status status_result = status::ok;
std::string message;
if ((status_result = impl::ops::details::encode_key(
context, begin_keys, input_variables, resource, key_begin, blen, message))
!= status::ok) {

if ((status_result = impl::ops::details::encode_key(context, begin_keys, input_variables,
resource, key_begin, blen, message)) != status::ok) {

if (status_result == status::err_type_mismatch) {
set_error(*context, error_code::unsupported_runtime_feature_exception, message, status_result);
set_error(*context, error_code::unsupported_runtime_feature_exception, message,
status_result);
}
return status_result;
}
if ((status_result = impl::ops::details::encode_key(
context, end_keys, input_variables, resource, key_end, elen, message))
!= status::ok) {

context, end_keys, input_variables, resource, key_end, elen, message)) != status::ok) {

if (status_result == status::err_type_mismatch) {
set_error(*context, error_code::unsupported_runtime_feature_exception, message, status_result);
set_error(*context, error_code::unsupported_runtime_feature_exception, message,
status_result);
}
return status_result;
}
Expand Down
Loading

0 comments on commit 75b8abf

Please sign in to comment.