From 2266d37762427b5cde1883fbd0219c18b32726de Mon Sep 17 00:00:00 2001 From: zhjc1124 Date: Wed, 21 Aug 2024 04:20:00 +0000 Subject: [PATCH] remove set_group_id limit --- deps/oblib/src/lib/worker.cpp | 9 --------- deps/oblib/src/lib/worker.h | 2 +- 2 files changed, 1 insertion(+), 10 deletions(-) diff --git a/deps/oblib/src/lib/worker.cpp b/deps/oblib/src/lib/worker.cpp index 8b3c089d34..02169ac95d 100644 --- a/deps/oblib/src/lib/worker.cpp +++ b/deps/oblib/src/lib/worker.cpp @@ -85,15 +85,6 @@ Worker::Status Worker::check_wait() return ret_status; } -void Worker::set_group_id(int32_t group_id) -{ - if (OBCG_DEFAULT_GROUP_ID == group_id_ || (is_user_group(group_id_) && is_valid_resource_group(group_id))) { - group_id_ = group_id; - } else { - LOG_ERROR_RET(OB_INNER_STAT_ERROR, "group_id is unexpected", K(group_id_), K(group_id)); - } -} - bool Worker::sched_wait() { return true; diff --git a/deps/oblib/src/lib/worker.h b/deps/oblib/src/lib/worker.h index 4dda7ca79d..48fc3c3950 100644 --- a/deps/oblib/src/lib/worker.h +++ b/deps/oblib/src/lib/worker.h @@ -83,7 +83,7 @@ public: OB_INLINE void set_curr_request_level(const int32_t level) { curr_request_level_ = level; } OB_INLINE int32_t get_curr_request_level() const { return curr_request_level_; } - void set_group_id(int32_t group_id); + OB_INLINE void set_group_id(int32_t group_id) { group_id_ = group_id; } OB_INLINE int32_t get_group_id() const { return group_id_; } OB_INLINE void set_rpc_stat_srv(void *rpc_stat_srv) { rpc_stat_srv_ = rpc_stat_srv; }