| 2762 | } |
| 2763 | |
| 2764 | void ImpalaServer::BuildLocalBackendDescriptorInternal(BackendDescriptorPB* be_desc) { |
| 2765 | DCHECK(AreServicesReady()); |
| 2766 | bool is_quiescing = shutting_down_.Load() != 0; |
| 2767 | |
| 2768 | *be_desc->mutable_backend_id() = exec_env_->backend_id(); |
| 2769 | *be_desc->mutable_address() = |
| 2770 | MakeNetworkAddressPB(exec_env_->configured_backend_address().hostname, |
| 2771 | exec_env_->configured_backend_address().port, exec_env_->backend_id(), |
| 2772 | exec_env_->rpc_mgr()->GetUdsAddressUniqueId()); |
| 2773 | be_desc->set_ip_address(exec_env_->ip_address()); |
| 2774 | be_desc->set_is_coordinator(FLAGS_is_coordinator); |
| 2775 | be_desc->set_is_executor(FLAGS_is_executor); |
| 2776 | |
| 2777 | Webserver* webserver = ExecEnv::GetInstance()->webserver(); |
| 2778 | if (webserver != nullptr) { |
| 2779 | *be_desc->mutable_debug_http_address() = |
| 2780 | MakeNetworkAddressPB(webserver->hostname(), webserver->port()); |
| 2781 | be_desc->set_secure_webserver(webserver->IsSecure()); |
| 2782 | } |
| 2783 | |
| 2784 | const NetworkAddressPB& krpc_address = exec_env_->krpc_address(); |
| 2785 | DCHECK(IsResolvedAddress(krpc_address)); |
| 2786 | *be_desc->mutable_krpc_address() = krpc_address; |
| 2787 | |
| 2788 | be_desc->set_admit_mem_limit(exec_env_->admit_mem_limit()); |
| 2789 | be_desc->set_admission_slots(exec_env_->admission_slots()); |
| 2790 | be_desc->set_is_quiescing(is_quiescing); |
| 2791 | SetExecutorGroups(FLAGS_executor_groups, be_desc); |
| 2792 | |
| 2793 | if (CommonMetrics::PROCESS_START_TIME != nullptr) { |
| 2794 | be_desc->set_process_start_time(CommonMetrics::PROCESS_START_TIME->GetValue()); |
| 2795 | } else { |
| 2796 | be_desc->set_process_start_time(CurrentTimeString()); |
| 2797 | } |
| 2798 | be_desc->set_version(GetBuildVersion(/* compact */ true)); |
| 2799 | be_desc->set_scheduling_seed(FLAGS_scheduling_seed); |
| 2800 | |
| 2801 | // Add machine information for runtime profile |
| 2802 | MachineInfoPB* machine_info = be_desc->mutable_machine_info(); |
| 2803 | machine_info->set_cpu_model_name(CpuInfo::model_name()); |
| 2804 | machine_info->set_cpu_num_cores(CpuInfo::num_cores()); |
| 2805 | machine_info->set_os_distribution(OsInfo::os_distribution()); |
| 2806 | } |
| 2807 | |
| 2808 | void ImpalaServer::ConnectionStart( |
| 2809 | const ThriftServer::ConnectionContext& connection_context) { |
nothing calls this directly
no test coverage detected