Home
last modified time | relevance | path

Searched refs:channel_ (Results 1 – 25 of 99) sorted by relevance

1234

/external/webrtc/talk/media/base/
Dvideoengine_unittest.h145 channel_.reset( in SetUp()
147 EXPECT_TRUE(channel_.get() != NULL); in SetUp()
148 network_interface_.SetDestination(channel_.get()); in SetUp()
149 channel_->SetInterface(&network_interface_); in SetUp()
153 channel_->SetRecvParameters(parameters); in SetUp()
154 EXPECT_TRUE(channel_->AddSendStream(DefaultSendStreamParams())); in SetUp()
160 EXPECT_TRUE(channel_->SetCapturer(kSsrc, video_capturer_.get())); in SetUp()
172 EXPECT_TRUE(channel_->AddRecvStream( in SetUpSecondStream()
175 EXPECT_TRUE(channel_->SetRenderer(kSsrc + 2, &renderer2_)); in SetUpSecondStream()
181 EXPECT_TRUE(channel_->AddRecvStream( in SetUpSecondStreamWithNoRecv()
[all …]
/external/webrtc/webrtc/voice_engine/test/auto_test/standard/
Dcodec_test.cc29 EXPECT_EQ(0, voe_codec_->SetSendCodec(channel_, codec_instance_)); in SetArbitrarySendCodec()
52 EXPECT_EQ(0, voe_codec_->GetSendCodec(channel_, codec_instance_)); in TEST_F()
66 voe_codec_->GetVADStatus(channel_, vad_enabled, vad_mode, dtx_disabled); in TEST_F()
74 EXPECT_EQ(0, voe_codec_->SetVADStatus(channel_, true)); in TEST_F()
80 voe_codec_->GetVADStatus(channel_, vad_enabled, vad_mode, dtx_disabled); in TEST_F()
93 channel_, true, webrtc::kVadAggressiveLow, false)); in TEST_F()
95 channel_, vad_enabled, vad_mode, dtx_disabled)); in TEST_F()
100 channel_, true, webrtc::kVadAggressiveMid, false)); in TEST_F()
102 channel_, vad_enabled, vad_mode, dtx_disabled)); in TEST_F()
108 EXPECT_EQ(0, voe_codec_->SetVADStatus(channel_, true, in TEST_F()
[all …]
Dvideo_sync_test.cc37 EXPECT_EQ(0, voe_vsync_->GetDelayEstimate(channel_, in CollectEstimatesDuring15Seconds()
77 EXPECT_EQ(-1, voe_vsync_->GetPlayoutTimestamp(channel_, ignored)); in TEST_F()
81 EXPECT_EQ(-1, voe_vsync_->SetInitTimestamp(channel_, 12345)); in TEST_F()
85 EXPECT_EQ(-1, voe_vsync_->SetInitSequenceNumber(channel_, 123)); in TEST_F()
89 EXPECT_EQ(0, voe_base_->StopSend(channel_)); in TEST_F()
90 EXPECT_EQ(0, voe_vsync_->SetInitTimestamp(channel_, 12345)); in TEST_F()
94 EXPECT_EQ(0, voe_base_->StopSend(channel_)); in TEST_F()
95 EXPECT_EQ(0, voe_vsync_->SetInitSequenceNumber(channel_, 123)); in TEST_F()
102 EXPECT_EQ(0, voe_base_->StopSend(channel_)); in TEST_F()
103 EXPECT_EQ(0, voe_vsync_->SetInitTimestamp(channel_, 12345)); in TEST_F()
[all …]
Dcodec_before_streaming_test.cc21 channel_ = voe_base_->CreateChannel(); in SetUp()
25 voe_base_->DeleteChannel(channel_); in TearDown()
29 int channel_; member in CodecBeforeStreamingTest
38 EXPECT_NE(0, voe_codec_->GetRecPayloadType(channel_, codec_instance_)); in TEST_F()
43 EXPECT_EQ(0, voe_codec_->GetRecPayloadType(channel_, codec_instance_)); in TEST_F()
45 EXPECT_EQ(0, voe_codec_->GetRecPayloadType(channel_, codec_instance_)); in TEST_F()
53 EXPECT_EQ(0, voe_codec_->SetRecPayloadType(channel_, codec_instance_)); in TEST_F()
54 EXPECT_EQ(0, voe_codec_->GetRecPayloadType(channel_, codec_instance_)); in TEST_F()
58 EXPECT_EQ(0, voe_codec_->SetRecPayloadType(channel_, codec_instance_)); in TEST_F()
59 EXPECT_EQ(0, voe_codec_->GetRecPayloadType(channel_, codec_instance_)); in TEST_F()
[all …]
Dexternal_media_test.cc41 TestRegisterExternalMedia(channel_, webrtc::kRecordingPerChannel); in TEST_F()
53 EXPECT_EQ(-1, voe_xmedia_->SetExternalMixing(channel_, true)); in TEST_F()
54 EXPECT_EQ(-1, voe_xmedia_->SetExternalMixing(channel_, false)); in TEST_F()
60 EXPECT_EQ(-1, voe_xmedia_->GetAudioFrame(channel_, 0, &frame)); in TEST_F()
66 ASSERT_EQ(0, voe_xmedia_->SetExternalMixing(channel_, true)); in TEST_F()
71 ASSERT_EQ(0, voe_xmedia_->SetExternalMixing(channel_, false)); in TEST_F()
82 EXPECT_EQ(0, voe_xmedia_->SetExternalMixing(channel_, true)); in TEST_F()
84 EXPECT_EQ(0, voe_xmedia_->GetAudioFrame(channel_, 0, &frame)); in TEST_F()
88 EXPECT_EQ(0, voe_xmedia_->SetExternalMixing(channel_, false)); in TEST_F()
97 EXPECT_EQ(0, voe_xmedia_->SetExternalMixing(channel_, true)); in TEST_F()
[all …]
Drtp_rtcp_before_streaming_test.cc21 int channel_; member in RtpRtcpBeforeStreamingTest
25 EXPECT_THAT(channel_ = voe_base_->CreateChannel(), Not(Lt(0))); in SetUp()
29 EXPECT_EQ(0, voe_base_->DeleteChannel(channel_)); in TearDown()
35 EXPECT_EQ(0, voe_rtp_rtcp_->GetRTCPStatus(channel_, on)); in TEST_F()
37 EXPECT_EQ(0, voe_rtp_rtcp_->SetRTCPStatus(channel_, false)); in TEST_F()
38 EXPECT_EQ(0, voe_rtp_rtcp_->GetRTCPStatus(channel_, on)); in TEST_F()
40 EXPECT_EQ(0, voe_rtp_rtcp_->SetRTCPStatus(channel_, true)); in TEST_F()
41 EXPECT_EQ(0, voe_rtp_rtcp_->GetRTCPStatus(channel_, on)); in TEST_F()
46 EXPECT_EQ(0, voe_rtp_rtcp_->SetLocalSSRC(channel_, 1234)); in TEST_F()
48 EXPECT_EQ(0, voe_rtp_rtcp_->GetLocalSSRC(channel_, result)); in TEST_F()
Ddtmf_test.cc24 channel_, i, out_of_band, 160, 10)); in RunSixteenDtmfEvents()
51 EXPECT_EQ(0, voe_dtmf_->SendTelephoneEvent(channel_, 32, true)); in TEST_F()
52 EXPECT_EQ(0, voe_dtmf_->SendTelephoneEvent(channel_, 110, true)); in TEST_F()
67 EXPECT_EQ(0, voe_base_->StopSend(channel_)); in TEST_F()
68 EXPECT_EQ(0, voe_base_->StopPlayout(channel_)); in TEST_F()
69 EXPECT_EQ(0, voe_base_->StopReceive(channel_)); in TEST_F()
70 EXPECT_EQ(0, voe_codec_->SetRecPayloadType(channel_, codec_instance)); in TEST_F()
71 EXPECT_EQ(0, voe_base_->StartReceive(channel_)); in TEST_F()
72 EXPECT_EQ(0, voe_base_->StartPlayout(channel_)); in TEST_F()
73 EXPECT_EQ(0, voe_base_->StartSend(channel_)); in TEST_F()
[all …]
Dfile_before_streaming_test.cc32 channel_ = voe_base_->CreateChannel(); in SetUp()
36 voe_base_->DeleteChannel(channel_); in TearDown()
91 int channel_; member in FileBeforeStreamingTest
107 channel_, input_filename_.c_str(), true)); in TEST_F()
108 EXPECT_EQ(1, voe_file_->IsPlayingFileLocally(channel_)); in TEST_F()
113 EXPECT_EQ(0, voe_base_->StartPlayout(channel_)); in TEST_F()
118 EXPECT_EQ(0, voe_file_->StopPlayingFileLocally(channel_)); in TEST_F()
119 EXPECT_EQ(0, voe_file_->IsPlayingFileLocally(channel_)); in TEST_F()
125 channel_, input_filename_.c_str(), true)); in TEST_F()
126 EXPECT_EQ(1, voe_file_->IsPlayingFileLocally(channel_)); in TEST_F()
[all …]
Dvolume_test.cc53 bool success = voe_volume_control_->SetInputMute(channel_, enable) == 0; in SetAndVerifyInputMute()
63 success = voe_volume_control_->GetInputMute(channel_, is_muted) == 0; in SetAndVerifyInputMute()
92 EXPECT_EQ(-1, voe_volume_control_->SetOutputVolumePan(channel_, -0.1f, 0.5f)); in TEST_F()
93 EXPECT_EQ(-1, voe_volume_control_->SetOutputVolumePan(channel_, 1.1f, 0.5f)); in TEST_F()
94 EXPECT_EQ(-1, voe_volume_control_->SetOutputVolumePan(channel_, 0.5f, -0.1f)); in TEST_F()
95 EXPECT_EQ(-1, voe_volume_control_->SetOutputVolumePan(channel_, 0.5f, 1.1f)); in TEST_F()
208 channel_, scaling)); in TEST_F()
214 channel_, 0.1f)); in TEST_F()
218 channel_, scaling)); in TEST_F()
228 EXPECT_EQ(0, voe_volume_control_->GetInputMute(channel_, is_muted)); in TEST_F()
[all …]
Dfile_test.cc53 channel_, recording_filename.c_str()));
58 EXPECT_EQ(1, voe_file_->IsPlayingFileLocally(channel_));
65 voe_codec_->GetSendCodec(channel_, send_codec); in TEST_F()
72 channel_, recording_filename.c_str(), &send_codec)); in TEST_F()
74 EXPECT_EQ(0, voe_file_->StopRecordingPlayout(channel_)); in TEST_F()
78 channel_, recording_filename.c_str(), true, false, in TEST_F()
82 EXPECT_EQ(1, voe_file_->IsPlayingFileAsMicrophone(channel_)); in TEST_F()
85 EXPECT_EQ(1, voe_file_->IsPlayingFileAsMicrophone(channel_)); in TEST_F()
Daudio_processing_test.cc47 EXPECT_EQ(0, voe_apm_->SetRxAgcStatus(channel_, true, agc_mode_to_set)); in TryEnablingRxAgcWithMode()
52 EXPECT_EQ(0, voe_apm_->GetRxAgcStatus(channel_, rx_agc_enabled, agc_mode)); in TryEnablingRxAgcWithMode()
99 EXPECT_EQ(0, voe_apm_->SetRxNsStatus(channel_, true, ns_mode_to_set)); in TryEnablingRxNsWithMode()
103 EXPECT_EQ(0, voe_apm_->GetRxNsStatus(channel_, ns_status, ns_mode)); in TryEnablingRxNsWithMode()
111 EXPECT_EQ(0, voe_codec_->SetVADStatus(channel_, true)); in TryDetectingSilence()
112 EXPECT_EQ(0, voe_volume_control_->SetInputMute(channel_, true)); in TryDetectingSilence()
113 EXPECT_EQ(0, voe_file_->StopPlayingFileAsMicrophone(channel_)); in TryDetectingSilence()
118 EXPECT_EQ(0, voe_apm_->VoiceActivityIndicator(channel_)); in TryDetectingSilence()
126 EXPECT_EQ(0, voe_codec_->SetVADStatus(channel_, false)); in TryDetectingSpeechAfterSilence()
127 EXPECT_EQ(0, voe_volume_control_->SetInputMute(channel_, false)); in TryDetectingSpeechAfterSilence()
[all …]
Drtp_rtcp_extensions.cc96 EXPECT_EQ(0, voe_network_->DeRegisterExternalTransport(channel_)); in SetUp()
97 EXPECT_EQ(0, voe_network_->RegisterExternalTransport(channel_, in SetUp()
112 EXPECT_EQ(0, voe_rtp_rtcp_->SetSendAudioLevelIndicationStatus(channel_, true, in TEST_F()
127 EXPECT_EQ(0, voe_rtp_rtcp_->SetSendAbsoluteSenderTimeStatus(channel_, true, in TEST_F()
135 EXPECT_EQ(0, voe_rtp_rtcp_->SetSendAudioLevelIndicationStatus(channel_, true, in TEST_F()
137 EXPECT_EQ(0, voe_rtp_rtcp_->SetSendAbsoluteSenderTimeStatus(channel_, true, in TEST_F()
146 EXPECT_EQ(0, voe_rtp_rtcp_->SetSendAbsoluteSenderTimeStatus(channel_, true, in TEST_F()
148 EXPECT_EQ(0, voe_rtp_rtcp_->SetSendAudioLevelIndicationStatus(channel_, true, in TEST_F()
/external/webrtc/webrtc/voice_engine/test/auto_test/fixtures/
Dbefore_streaming_fixture.cc14 : channel_(voe_base_->CreateChannel()), in BeforeStreamingFixture()
16 EXPECT_GE(channel_, 0); in BeforeStreamingFixture()
26 voe_file_->StopPlayingFileAsMicrophone(channel_); in ~BeforeStreamingFixture()
29 EXPECT_EQ(0, voe_network_->DeRegisterExternalTransport(channel_)); in ~BeforeStreamingFixture()
30 voe_base_->DeleteChannel(channel_); in ~BeforeStreamingFixture()
35 EXPECT_EQ(0, voe_file_->StopPlayingFileAsMicrophone(channel_)); in SwitchToManualMicrophone()
44 channel_, fake_microphone_input_file_.c_str(), true, true)); in RestartFakeMicrophone()
48 EXPECT_EQ(0, voe_base_->StopSend(channel_)); in PausePlaying()
49 EXPECT_EQ(0, voe_base_->StopPlayout(channel_)); in PausePlaying()
50 EXPECT_EQ(0, voe_base_->StopReceive(channel_)); in PausePlaying()
[all …]
/external/webrtc/talk/media/webrtc/
Dwebrtcvoiceengine_unittest.cc80 channel_(nullptr) { in WebRtcVoiceEngineTestFake()
88 channel_ = engine_.CreateChannel(&call_, cricket::AudioOptions()); in SetupEngine()
89 return (channel_ != nullptr); in SetupEngine()
95 return channel_->AddRecvStream( in SetupEngineWithRecvStream()
102 return channel_->AddSendStream( in SetupEngineWithSendStream()
109 EXPECT_TRUE(channel_->RemoveSendStream(kSsrc1)); in SetupForMultiSendStream()
115 channel_->OnPacketReceived(&packet, rtc::PacketTime()); in DeliverPacket()
118 delete channel_; in TearDown()
142 channel_ = engine_.CreateChannel(&call_, cricket::AudioOptions()); in TestInsertDtmf()
143 EXPECT_TRUE(channel_ != nullptr); in TestInsertDtmf()
[all …]
Dwebrtcvideoengine2_unittest.cc874 EXPECT_TRUE(channel_->SetCapturer(kSsrc, NULL)); in TEST_F()
875 EXPECT_TRUE(channel_->SetRenderer(kDefaultReceiveSsrc, &renderer_)); in TEST_F()
876 channel_->UpdateAspectRatio(1280, 720); in TEST_F()
882 EXPECT_TRUE(channel_->SetCapturer(kSsrc, video_capturer_.get())); in TEST_F()
903 channel_.reset( in SetUp()
908 ASSERT_TRUE(channel_->SetSendParameters(send_parameters_)); in SetUp()
918 EXPECT_TRUE(channel_->AddSendStream(sp)); in AddSendStream()
935 EXPECT_TRUE(channel_->AddRecvStream(sp)); in AddRecvStream()
954 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_)); in SetSendCodecsShouldWorkForBitrates()
971 EXPECT_TRUE(channel_->SetSendParameters(parameters)); in TestSetSendRtpHeaderExtensions()
[all …]
/external/webrtc/webrtc/p2p/base/
Dtransport_unittest.cc37 : transport_(new FakeTransport("test content name")), channel_(NULL) {} in TransportTest()
42 channel_ = CreateChannel(1); in SetupChannel()
43 return (channel_ != NULL); in SetupChannel()
51 channel_ = NULL; in DestroyChannel()
56 FakeTransportChannel* channel_; member in TransportTest
71 EXPECT_EQ(cricket::ICEROLE_CONTROLLING, channel_->GetIceRole()); in TEST_F()
72 EXPECT_EQ(cricket::ICEMODE_FULL, channel_->remote_ice_mode()); in TEST_F()
73 EXPECT_EQ(kIceUfrag1, channel_->ice_ufrag()); in TEST_F()
74 EXPECT_EQ(kIcePwd1, channel_->ice_pwd()); in TEST_F()
80 EXPECT_EQ(cricket::ICEROLE_CONTROLLING, channel_->GetIceRole()); in TEST_F()
[all …]
Ddtlstransportchannel.cc45 : channel_(channel), in StreamInterfaceChannel()
73 channel_->SendPacket(static_cast<const char*>(data), data_len, in Write()
97 channel_(channel), in DtlsTransportChannelWrapper()
101 channel_->SignalWritableState.connect(this, in DtlsTransportChannelWrapper()
103 channel_->SignalReadPacket.connect(this, in DtlsTransportChannelWrapper()
105 channel_->SignalSentPacket.connect( in DtlsTransportChannelWrapper()
107 channel_->SignalReadyToSend.connect(this, in DtlsTransportChannelWrapper()
109 channel_->SignalGatheringState.connect( in DtlsTransportChannelWrapper()
111 channel_->SignalCandidateGathered.connect( in DtlsTransportChannelWrapper()
113 channel_->SignalRoleConflict.connect(this, in DtlsTransportChannelWrapper()
[all …]
Ddtlstransportchannel.h48 TransportChannel* channel_; // owned by DtlsTransportChannelWrapper
91 void SetIceRole(IceRole role) override { channel_->SetIceRole(role); } in SetIceRole()
92 IceRole GetIceRole() const override { return channel_->GetIceRole(); } in GetIceRole()
113 return channel_->SetOption(opt, value); in SetOption()
116 return channel_->GetOption(opt, value); in GetOption()
118 int GetError() override { return channel_->GetError(); } in GetError()
120 return channel_->GetStats(infos); in GetStats()
122 const std::string SessionId() const override { return channel_->SessionId(); } in SessionId()
165 return channel_->GetState(); in GetState()
168 channel_->SetIceTiebreaker(tiebreaker); in SetIceTiebreaker()
[all …]
/external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/
DGetTopChannelsResponse.java19 channel_ = java.util.Collections.emptyList(); in GetTopChannelsResponse()
56 channel_ = new java.util.ArrayList<io.grpc.channelz.v1.Channel>(); in GetTopChannelsResponse()
59 channel_.add( in GetTopChannelsResponse()
77 channel_ = java.util.Collections.unmodifiableList(channel_); in GetTopChannelsResponse()
97 private java.util.List<io.grpc.channelz.v1.Channel> channel_; field in GetTopChannelsResponse
107 return channel_; in getChannelList()
119 return channel_; in getChannelOrBuilderList()
130 return channel_.size(); in getChannelCount()
141 return channel_.get(index); in getChannel()
153 return channel_.get(index); in getChannelOrBuilder()
[all …]
DGetChannelResponse.java54 if (channel_ != null) { in GetChannelResponse()
55 subBuilder = channel_.toBuilder(); in GetChannelResponse()
57 channel_ = input.readMessage(io.grpc.channelz.v1.Channel.parser(), extensionRegistry); in GetChannelResponse()
59 subBuilder.mergeFrom(channel_); in GetChannelResponse()
60 channel_ = subBuilder.buildPartial(); in GetChannelResponse()
90 private io.grpc.channelz.v1.Channel channel_; field in GetChannelResponse
100 return channel_ != null; in hasChannel()
111 return channel_ == null ? io.grpc.channelz.v1.Channel.getDefaultInstance() : channel_; in getChannel()
137 if (channel_ != null) { in writeTo()
148 if (channel_ != null) { in getSerializedSize()
[all …]
/external/webrtc/webrtc/voice_engine/test/auto_test/
Dvoe_output_test.cc72 int channel_; member in voetest::OutputTest
86 channel_ = base->CreateChannel(); in OutputTest()
90 new VoiceChannelTransport(network, channel_); in OutputTest()
95 EXPECT_EQ(0, codec->SetSendCodec(channel_, kCodecInst)); in OutputTest()
96 EXPECT_EQ(0, codec->SetOpusDtx(channel_, true)); in OutputTest()
101 channel_, ProcessingTypes::kPlaybackPerChannel, output_checker_); in OutputTest()
105 EXPECT_EQ(0, manager_.NetworkPtr()->DeRegisterExternalTransport(channel_)); in ~OutputTest()
115 channel_, file_name.c_str(), true, false, kInputFormat, 1.0)); in Start()
118 ASSERT_EQ(0, base->StartPlayout(channel_)); in Start()
119 ASSERT_EQ(0, base->StartSend(channel_)); in Start()
[all …]
/external/webrtc/webrtc/tools/agc/
Dagc_harness.cc93 channel_(-1), in AgcVoiceEngine()
118 channel_ = base_->CreateChannel(); in SetUp()
119 RTC_CHECK_NE(-1, channel_); in SetUp()
122 new test::VoiceChannelTransport(network, channel_)); in SetUp()
140 RTC_CHECK_EQ(0, codec_->SetSendCodec(channel_, codec_params)); in SetUp()
149 RTC_CHECK_EQ(0, base_->DeleteChannel(channel_)); in TearDown()
185 void StartSending() { RTC_CHECK_EQ(0, base_->StartSend(channel_)); } in StartSending()
191 volume->SetOutputVolumePan(channel_, 1, 0); in StartPlaying()
193 volume->SetOutputVolumePan(channel_, 0, 1); in StartPlaying()
198 0, file->StartPlayingFileLocally(channel_, filename.c_str(), true, in StartPlaying()
[all …]
/external/ImageMagick/Magick++/lib/Magick++/
DImage.h157 void channelDepth(const ChannelType channel_,const size_t depth_);
158 size_t channelDepth(const ChannelType channel_);
557 void adaptiveSharpenChannel(const ChannelType channel_,
569 void addNoiseChannel(const ChannelType channel_,
634 void autoGammaChannel(const ChannelType channel_);
639 void autoLevelChannel(const ChannelType channel_);
652 void blackThresholdChannel(const ChannelType channel_,
663 void blurChannel(const ChannelType channel_,const double radius_=0.0,
674 void brightnessContrastChannel(const ChannelType channel_,
687 void channel(const ChannelType channel_);
[all …]
/external/libchrome/ipc/
Dipc_channel_proxy.cc62 DCHECK(!channel_); in CreateChannel()
64 channel_ = factory->BuildChannel(this); in CreateChannel()
67 channel_->GetAssociatedInterfaceSupport(); in CreateChannel()
102 DCHECK(channel_); in PauseChannel()
103 channel_->Pause(); in PauseChannel()
108 DCHECK(channel_); in UnpauseChannel()
109 channel_->Unpause(flush); in UnpauseChannel()
114 DCHECK(channel_); in FlushChannel()
115 channel_->Flush(); in FlushChannel()
173 DCHECK(channel_ != NULL); in OnChannelOpened()
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service_impl.cc53 : channel_(channel), in Stub()
83 channel_.get(), rpcmethod_CreateSession_, context, request, response); in CreateSession()
90 channel_.get(), rpcmethod_ExtendSession_, context, request, response); in ExtendSession()
97 channel_.get(), rpcmethod_PartialRunSetup_, context, request, response); in PartialRunSetup()
103 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RunStep_, in RunStep()
111 channel_.get(), rpcmethod_CloseSession_, context, request, response); in CloseSession()
118 channel_.get(), rpcmethod_ListDevices_, context, request, response); in ListDevices()
124 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Reset_, in Reset()
132 channel_.get(), rpcmethod_MakeCallable_, context, request, response); in MakeCallable()
139 channel_.get(), rpcmethod_RunCallable_, context, request, response); in RunCallable()
[all …]

1234