| 119 | virtual ~ImpalaKRPCTestBackend() {} |
| 120 | |
| 121 | Status Init() { |
| 122 | int num_svc_threads = FLAGS_datastream_service_num_svc_threads > 0 ? |
| 123 | FLAGS_datastream_service_num_svc_threads : CpuInfo::num_cores(); |
| 124 | LOG(INFO) << "Num svc thread=" << num_svc_threads; |
| 125 | return rpc_mgr_->RegisterService(num_svc_threads, 1024, |
| 126 | METRIC_data_stream_test_incoming_queue_time.Instantiate( |
| 127 | rpc_mgr_->metric_entity()), |
| 128 | this, mem_tracker(), ExecEnv::GetInstance()->rpc_metrics()); |
| 129 | } |
| 130 | |
| 131 | virtual bool Authorize(const google::protobuf::Message* req, |
| 132 | google::protobuf::Message* resp, kudu::rpc::RpcContext* context) { |
no test coverage detected