42 const std::chrono::duration kConnectionDeadline = std::chrono::seconds(1);
43 std::string custom_packet_stream_endpoint = "";
44 std::shared_ptr<grpc::Channel> packet_stream_channel;
45 std::mutex channel_mutex;
47 std::shared_ptr<grpc::Channel> CreateGrpcChannel() {  in CreateGrpcChannel()
58   std::vector<  in CreateGrpcChannel()
59       std::unique_ptr<grpc::experimental::ClientInterceptorFactoryInterface>>  in CreateGrpcChannel()
61   interceptors.emplace_back(std::make_unique<MetricsInterceptorFactory>());  in CreateGrpcChannel()
65       std::move(interceptors));  in CreateGrpcChannel()
68 bool GrpcChannelReady(const std::shared_ptr<grpc::Channel> &channel) {  in GrpcChannelReady()
70     auto deadline = std::chrono::system_clock::now() + kConnectionDeadline;  in GrpcChannelReady()
76 std::unique_ptr<android::base::ObservableProcess> RunNetsimd(  in RunNetsimd()
79   std::vector<std::string> program_with_args{exe};  in RunNetsimd()
86     program_with_args.push_back(std::string(flag));  in RunNetsimd()
102 void SetPacketStreamEndpoint(const std::string &endpoint) {  in SetPacketStreamEndpoint()
106 std::shared_ptr<grpc::Channel> GetChannel(NetsimdOptions options) {  in GetChannel()
107   std::lock_guard<std::mutex> lock(channel_mutex);  in GetChannel()
110   std::unique_ptr<android::base::ObservableProcess> netsimProc;  in GetChannel()
124     std::this_thread::sleep_for(std::chrono::seconds(second));  in GetChannel()
131 std::shared_ptr<grpc::Channel> CreateChannel(NetsimdOptions options) {  in CreateChannel()
135 std::shared_ptr<grpc::Channel> CreateChannel(  in CreateChannel()
136     std::string _rootcanal_controller_properties_file) {  in CreateChannel()