rename context_base inactive() to aborted()

Author: kuron99

src/jogasaki/executor/process/impl/ops/aggregate_group.cpp

@@ -158,7 +158,7 @@ operation_status aggregate_group::operator()(
     bool last_member,
     abstract::task_context* context
 ) {
-    if (ctx.inactive()) {
+    if (ctx.aborted()) {
         return {operation_status_kind::aborted};
     }
     for(std::size_t i=0, n=arguments_.size(); i < n; ++i) {
@@ -215,7 +215,7 @@ operator_kind aggregate_group::kind() const noexcept {
 void aggregate_group::finish(abstract::task_context* context) {
     auto& ctx = *create_context_if_not_found(context);
     context_helper helper{*context};
-    if (ctx.inactive()) {
+    if (ctx.aborted()) {
         return;
     }
     if (helper.empty_input_from_shuffle()) {

src/jogasaki/executor/process/impl/ops/apply.cpp

@@ -95,7 +95,7 @@ operation_status apply::process_record(abstract::task_context* context) {
 }
 
 operation_status apply::operator()(apply_context& ctx, abstract::task_context* context) {  //NOLINT(readability-function-cognitive-complexity)
-    if (ctx.inactive()) {
+    if (ctx.aborted()) {
         return {operation_status_kind::aborted};
     }
 

src/jogasaki/executor/process/impl/ops/context_base.cpp

@@ -94,7 +94,7 @@ class request_context* context_base::req_context() noexcept {
 }
 
 void context_base::abort() noexcept {
-    state(context_state::abort);
+    state(context_state::aborted);
 }
 
 void context_base::dump() const noexcept {

src/jogasaki/executor/process/impl/ops/context_base.h

@@ -37,7 +37,7 @@ enum class context_state {
     /**
      * @brief the operator with this context met error and is aborting/aborted
      */
-    abort,
+    aborted,
 };
 
 /**
@@ -49,7 +49,7 @@ enum class context_state {
     using namespace std::string_view_literals;
     switch (state) {
         case context_state::active: return "active"sv;
-        case context_state::abort: return "abort"sv;
+        case context_state::aborted: return "aborted"sv;
     }
     std::abort();
 }
@@ -166,10 +166,10 @@ class context_base {
     void abort() noexcept;
 
     /**
-     * @brief update the context state aborted
+     * @brief returns whether the context state is aborted
      */
-    [[nodiscard]] bool inactive() const noexcept {
-        return state_ != context_state::active;
+    [[nodiscard]] bool aborted() const noexcept {
+        return state_ == context_state::aborted;
     }
 
     /**

src/jogasaki/executor/process/impl/ops/emit.cpp

@@ -78,7 +78,7 @@ operation_status emit::process_record(abstract::task_context *context) {
 }
 
 operation_status emit::operator()(emit_context &ctx) {
-    if (ctx.inactive()) {
+    if (ctx.aborted()) {
         return {operation_status_kind::aborted};
     }
     auto target = ctx.buffer_.ref();

src/jogasaki/executor/process/impl/ops/filter.cpp

@@ -65,7 +65,7 @@ operation_status filter::process_record(abstract::task_context* context) {
 }
 
 operation_status filter::operator()(filter_context& ctx, abstract::task_context* context) {
-    if (ctx.inactive()) {
+    if (ctx.aborted()) {
         return {operation_status_kind::aborted};
     }
     auto& vars = ctx.input_variables();

src/jogasaki/executor/process/impl/ops/find.cpp

@@ -160,7 +160,7 @@ operation_status find::call_downstream(
 }
 
 operation_status find::operator()(class find_context& ctx, abstract::task_context* context) {  //NOLINT(readability-function-cognitive-complexity)
-    if (ctx.inactive()) {
+    if (ctx.aborted()) {
         return {operation_status_kind::aborted};
     }
     if(utils::request_cancel_enabled(request_cancel_kind::find) && ctx.req_context()) {

src/jogasaki/executor/process/impl/ops/flatten.cpp

@@ -58,7 +58,7 @@ operation_status flatten::process_group(abstract::task_context* context, bool la
 }
 
 operation_status flatten::operator()(flatten_context& ctx, abstract::task_context* context) {
-    if (ctx.inactive()) {
+    if (ctx.aborted()) {
         return {operation_status_kind::aborted};
     }
     if (downstream_) {

src/jogasaki/executor/process/impl/ops/index_join.h

@@ -325,7 +325,7 @@ class index_join : public record_operator {
      * @return status of the operation
      */
     operation_status operator()(index_join_context<MatchInfo>& ctx, abstract::task_context* context = nullptr) { //NOLINT(readability-function-cognitive-complexity)
-        if (ctx.inactive()) {
+        if (ctx.aborted()) {
             return {operation_status_kind::aborted};
         }
         auto resource = ctx.varlen_resource();

src/jogasaki/executor/process/impl/ops/join.h

@@ -201,7 +201,7 @@ class join : public cogroup_operator<Iterator> {
         constexpr static std::size_t primary_group_index = 0;
         constexpr static std::size_t secondary_group_index = 1;
 
-        if (ctx.inactive()) {
+        if (ctx.aborted()) {
             return {operation_status_kind::aborted};
         }
         std::size_t n = cgrp.groups().size();