| 188 | } |
| 189 | |
| 190 | Status RequestPoolService::GetPoolConfig(const string& pool_name, |
| 191 | TPoolConfig* pool_config) { |
| 192 | if (default_pool_only_) { |
| 193 | pool_config->__set_max_requests( |
| 194 | FLAGS_disable_pool_max_requests ? -1 : FLAGS_default_pool_max_requests); |
| 195 | pool_config->__set_max_mem_resources( |
| 196 | FLAGS_disable_pool_mem_limits ? -1 : default_pool_mem_limit_); |
| 197 | pool_config->__set_max_queued(FLAGS_default_pool_max_queued); |
| 198 | pool_config->__set_default_query_options(""); |
| 199 | pool_config->__set_min_query_mem_limit(0); |
| 200 | pool_config->__set_max_query_mem_limit(0); |
| 201 | pool_config->__set_clamp_mem_limit_query_option(true); |
| 202 | return Status::OK(); |
| 203 | } |
| 204 | |
| 205 | TPoolConfigParams params; |
| 206 | params.__set_pool(pool_name); |
| 207 | RETURN_IF_ERROR(JniUtil::CallJniMethod( |
| 208 | jni_request_pool_service_, get_pool_config_id_, params, pool_config)); |
| 209 | if (FLAGS_disable_pool_max_requests) pool_config->__set_max_requests(-1); |
| 210 | if (FLAGS_disable_pool_mem_limits) pool_config->__set_max_mem_resources(-1); |
| 211 | return Status::OK(); |
| 212 | } |
| 213 | |
| 214 | Status RequestPoolService::GetHadoopGroups( |
| 215 | const TGetHadoopGroupsRequest& request, TGetHadoopGroupsResponse* response) { |