ACTUALLY_QUEUED_MIN_MS | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
add_request_to_stage(const RequestId request_id, const ExecutionRequestStage request_status) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
choose_next_request() | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
enable_debug_printing_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
enable_stats_printing_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
enqueue_request(const RequestInfo &request_info, const size_t timeout_in_ms, const ResourceGrant &min_resource_grant, const ResourceGrant &max_resource_grant) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
executing_requests_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
executing_set_mutex_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | mutableprivate |
executor_resource_pool_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
executor_stats_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
ExecutorResourceMgr(const std::vector< std::pair< ResourceType, size_t >> &total_resources, const std::vector< ConcurrentResourceGrantPolicy > &concurrent_resource_grant_policies, const std::vector< ResourceGrantPolicy > &max_per_request_resource_grant_policies, const double max_available_resource_use_ratio) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
get_chunk_request_info(const RequestId request_id) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
get_concurrent_resource_grant_policy(const ResourceType resource_type) const | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
get_executor_stats() const | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
get_request_for_id(const RequestId request_id) const | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
get_requests_for_stage(const ExecutionRequestStage request_status) const | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
get_resource_info(const ResourceType resource_type) const | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | inline |
get_resource_info() const | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | inline |
INVALID_REQUEST_ID | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
mark_request_dequed(const RequestId request_id) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
mark_request_error(const RequestId request_id, std::string error_msg) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
mark_request_finished(const RequestId request_id) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
mark_request_timed_out(const RequestId request_id) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
max_available_resource_use_ratio_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
outstanding_queue_requests_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
pause_process_queue() | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
pause_process_queue_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
pause_processor_queue_condition_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
pause_processor_queue_mutex_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | mutableprivate |
print_executor_stats() const | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
print_mutex_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | mutableprivate |
process_queue_counter_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
process_queue_is_paused_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
process_queue_loop() | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
process_queue_thread_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
processor_queue_condition_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
processor_queue_mutex_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | mutableprivate |
queue_stats_mutex_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | mutableprivate |
queued_requests_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
queued_set_mutex_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | mutableprivate |
release_resources(const RequestId request_id, const ResourceGrant &resource_grant) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
remove_request_from_stage(const RequestId request_id, const ExecutionRequestStage request_status) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
request_resources(const RequestInfo &request_info) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
request_resources_with_timeout(const RequestInfo &request_info, const size_t timeout_in_ms) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
requests_count_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
requests_stats_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
resume_process_queue() | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
set_concurrent_resource_grant_policy(const ConcurrentResourceGrantPolicy &concurrent_resource_grant_policy) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
set_process_queue_flag() | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | inlineprivate |
set_resource(const ResourceType resource_type, const size_t resoure_quantity) | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |
should_process_queue_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
stop_process_queue_thread() | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
stop_process_queue_thread_ | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | private |
~ExecutorResourceMgr() | ExecutorResourceMgr_Namespace::ExecutorResourceMgr | |