remove set_group_id limit
This commit is contained in:
9
deps/oblib/src/lib/worker.cpp
vendored
9
deps/oblib/src/lib/worker.cpp
vendored
@ -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;
|
||||
|
2
deps/oblib/src/lib/worker.h
vendored
2
deps/oblib/src/lib/worker.h
vendored
@ -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; }
|
||||
|
Reference in New Issue
Block a user