Home
last modified time | relevance | path

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

12345

/external/webrtc/media/engine/
Dwebrtc_video_engine_unittest.cc1329 channel_(absl::WrapUnique(static_cast<cricket::WebRtcVideoChannel*>(
1336 network_interface_.SetDestination(channel_.get());
1337 channel_->SetInterface(&network_interface_);
1340 channel_->SetRecvParameters(parameters);
1371 std::unique_ptr<WebRtcVideoChannel> channel_; member in cricket::WebRtcVideoChannelEncodedFrameCallbackTest
1384 EXPECT_TRUE(channel_->AddRecvStream( in TEST_F()
1386 channel_->SetRecordableEncodedFrameCallback(/*ssrc=*/0, in TEST_F()
1388 EXPECT_TRUE(channel_->SetSink(kSsrc, &renderer_)); in TEST_F()
1392 channel_->RemoveRecvStream(kSsrc); in TEST_F()
1399 EXPECT_TRUE(channel_->AddRecvStream( in TEST_F()
[all …]
Dwebrtc_voice_engine_unittest.cc236 channel_ = engine_->CreateMediaChannel(&call_, cricket::MediaConfig(), in SetupChannel()
239 return (channel_ != nullptr); in SetupChannel()
257 if (!channel_->AddSendStream(sp)) { in SetupSendStream()
263 return channel_->SetAudioSend(kSsrcX, true, nullptr, &fake_source_); in SetupSendStream()
267 EXPECT_TRUE(channel_); in AddRecvStream()
268 return channel_->AddRecvStream(cricket::StreamParams::CreateLegacy(ssrc)); in AddRecvStream()
275 EXPECT_TRUE(channel_->RemoveSendStream(kSsrcX)); in SetupForMultiSendStream()
282 channel_->OnPacketReceived(packet, /* packet_time_us */ -1); in DeliverPacket()
285 void TearDown() override { delete channel_; } in TearDown()
308 ASSERT_TRUE(channel_); in SetSend()
[all …]
/external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/
Dares-test-misc.cc11 std::vector<std::string> servers = GetNameServers(channel_); in TEST_F()
21 ares_set_servers_csv(channel_, "1.2.3.4,2.3.4.5")); in TEST_F()
24 EXPECT_EQ(ARES_ENOMEM, ares_get_servers(channel_, &servers)); in TEST_F()
26 EXPECT_EQ(ARES_ENOMEM, ares_get_servers(channel_, &servers)); in TEST_F()
31 EXPECT_EQ(ARES_SUCCESS, ares_set_servers(channel_, nullptr)); in TEST_F()
33 EXPECT_EQ(empty, GetNameServers(channel_)); in TEST_F()
45 EXPECT_EQ(ARES_SUCCESS, ares_set_servers(channel_, &server1)); in TEST_F()
47 EXPECT_EQ(expected, GetNameServers(channel_)); in TEST_F()
51 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result); in TEST_F()
52 EXPECT_EQ(ARES_ENOTIMP, ares_set_servers(channel_, &server1)); in TEST_F()
[all …]
Dares-test-live.cc23 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result); in VIRT_NONVIRT_TEST_F()
33 ares_gethostbyname(channel_, "www.google.com.", AF_INET6, HostCallback, &result); in VIRT_NONVIRT_TEST_F()
43 ares_gethostbyaddr(channel_, gdns_addr4, sizeof(gdns_addr4), AF_INET, HostCallback, &result); in VIRT_NONVIRT_TEST_F()
53 ares_gethostbyaddr(channel_, gdns_addr6, sizeof(gdns_addr6), AF_INET6, HostCallback, &result); in VIRT_NONVIRT_TEST_F()
68 int rc = ares_gethostbyname_file(channel_, "bogus.mcname", AF_INET, &host); in VIRT_NONVIRT_TEST_F()
72 rc = ares_gethostbyname_file(channel_, "localhost", AF_INET, &host); in VIRT_NONVIRT_TEST_F()
81 ares_gethostbyname(channel_, "localhost", AF_INET, HostCallback, &result); in TEST_P()
94 ares_gethostbyname(channel_, "localhost", AF_INET6, HostCallback, &result); in TEST_P()
108 ares_gethostbyname(channel_, "127.0.0.1", AF_INET, HostCallback, &result); in TEST_P()
121 ares_gethostbyname(channel_, "::1", AF_INET6, HostCallback, &result); in TEST_P()
[all …]
Dares-test-mock.cc45 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result); in TEST_P()
69 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result1); in TEST_P()
71 ares_gethostbyname(channel_, "www.example.com.", AF_INET, HostCallback, &result2); in TEST_P()
73 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result3); in TEST_P()
102 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result); in TEST_P()
128 ares_set_socket_callback(channel_, SocketConnectCallback, &rc); in TEST_P()
132 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result); in TEST_P()
144 ares_set_socket_callback(channel_, SocketConnectCallback, &rc); in TEST_P()
148 ares_gethostbyname(channel_, "www.google.com.", AF_INET, HostCallback, &result); in TEST_P()
173 ares_set_socket_configure_callback(channel_, SocketConfigureCallback, &rc); in TEST_P()
[all …]
Dares-test.h93 DefaultChannelTest() : channel_(nullptr) { in DefaultChannelTest()
94 EXPECT_EQ(ARES_SUCCESS, ares_init(&channel_)); in DefaultChannelTest()
95 EXPECT_NE(nullptr, channel_); in DefaultChannelTest()
99 ares_destroy(channel_); in ~DefaultChannelTest()
100 channel_ = nullptr; in ~DefaultChannelTest()
107 ares_channel channel_;
115 DefaultChannelModeTest() : channel_(nullptr) { in DefaultChannelModeTest()
119 EXPECT_EQ(ARES_SUCCESS, ares_init_options(&channel_, &opts, optmask)); in DefaultChannelModeTest()
120 EXPECT_NE(nullptr, channel_); in DefaultChannelModeTest()
125 ares_destroy(channel_); in ~DefaultChannelModeTest()
[all …]
/external/webrtc/pc/
Dvideo_rtp_receiver_unittest.cc53 channel_(nullptr, cricket::VideoOptions()), in VideoRtpReceiverTest()
58 receiver_->SetMediaChannel(&channel_);
66 MockVideoMediaChannel channel_; member in webrtc::__anond821efe30111::VideoRtpReceiverTest
75 EXPECT_CALL(channel_, GenerateKeyFrame(0)); in TEST_F()
84 EXPECT_CALL(channel_, GenerateKeyFrame).Times(0); in TEST_F()
102 EXPECT_CALL(channel_, SetRecordableEncodedFrameCallback(/*ssrc=*/0, _)); in TEST_F()
103 EXPECT_CALL(channel_, ClearRecordableEncodedFrameCallback).Times(0); in TEST_F()
109 EXPECT_CALL(channel_, ClearRecordableEncodedFrameCallback(/*ssrc=*/0)); in TEST_F()
117 EXPECT_CALL(channel_, SetRecordableEncodedFrameCallback); in TEST_F()
118 EXPECT_CALL(channel_, ClearRecordableEncodedFrameCallback); in TEST_F()
[all …]
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dintercepted_channel.h37 ~InterceptedChannel() override { channel_ = nullptr; } in ~InterceptedChannel()
42 return channel_->GetState(try_to_connect); in GetState()
47 : channel_(channel), interceptor_pos_(pos) {} in InterceptedChannel()
51 return channel_->CreateCallInternal(method, context, cq, interceptor_pos_); in CreateCall()
55 return channel_->PerformOpsOnCall(ops, call); in PerformOpsOnCall()
58 return channel_->RegisterMethod(method); in RegisterMethod()
65 return channel_->NotifyOnStateChangeImpl(last_observed, deadline, cq, tag); in NotifyOnStateChangeImpl()
69 return channel_->WaitForStateChangeImpl(last_observed, deadline); in WaitForStateChangeImpl()
73 return channel_->CallbackCQ(); in CallbackCQ()
76 ChannelInterface* channel_; variable
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dintercepted_channel.h37 ~InterceptedChannel() override { channel_ = nullptr; } in ~InterceptedChannel()
42 return channel_->GetState(try_to_connect); in GetState()
47 : channel_(channel), interceptor_pos_(pos) {} in InterceptedChannel()
51 return channel_->CreateCallInternal(method, context, cq, interceptor_pos_); in CreateCall()
55 return channel_->PerformOpsOnCall(ops, call); in PerformOpsOnCall()
58 return channel_->RegisterMethod(method); in RegisterMethod()
65 return channel_->NotifyOnStateChangeImpl(last_observed, deadline, cq, tag); in NotifyOnStateChangeImpl()
69 return channel_->WaitForStateChangeImpl(last_observed, deadline); in WaitForStateChangeImpl()
73 return channel_->CallbackCQ(); in CallbackCQ()
76 ChannelInterface* channel_; variable
/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/examples/androidvoip/jni/
Dandroid_voip_client.cc182 if (!channel_) { in SetEncoder()
191 *channel_, GetPayloadType(encoder.format.name), encoder.format); in SetEncoder()
200 if (!channel_) { in SetDecoders()
217 voip_engine_->Codec().SetReceiveCodecs(*channel_, decoder_specs); in SetDecoders()
244 channel_ = voip_thread_->Invoke<absl::optional<webrtc::ChannelId>>( in StartSession()
247 if (!channel_) { in StartSession()
274 if (!channel_) { in StopSession()
288 voip_engine_->Base().ReleaseChannel(*channel_); in StopSession()
290 channel_ = absl::nullopt; in StopSession()
295 if (!channel_) { in StartSend()
[all …]
/external/pigweed/pw_rpc/
Dbase_client_call.cc23 channel_->Send(NewPacket(PacketType::CANCEL_SERVER_STREAM)); in Cancel()
32 request_ = channel_->AcquireBuffer(); in AcquirePayloadBuffer()
42 return channel_->Send(request_, NewPacket(PacketType::REQUEST, payload)); in ReleasePayloadBuffer()
47 return Packet(type, channel_->id(), service_id_, method_id_, payload); in NewPacket()
50 void BaseClientCall::Register() { channel_->client()->RegisterCall(*this); } in Register()
54 channel_->client()->RemoveCall(*this); in Unregister()
/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 …]
DStatistic.h65 ChannelMoments(const PixelChannel channel_,
91 ChannelPerceptualHash(const PixelChannel channel_,
120 ChannelPerceptualHash(const PixelChannel channel_,
197 ChannelStatistics(const PixelChannel channel_,
232 ChannelMoments channel(const PixelChannel channel_) const;
263 ChannelPerceptualHash channel(const PixelChannel channel_) const;
295 ChannelStatistics channel(const PixelChannel channel_) const;
/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 …]
/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 …]
Dipc_test_base.cc41 channel_ = IPC::ChannelMojo::Create( in CreateChannel()
47 return channel_->Connect(); in ConnectChannel()
51 channel_.reset(); in DestroyChannel()
67 channel_ = IPC::ChannelMojo::Create( in Connect()
70 CHECK(channel_->Connect()); in Connect()
74 channel_->Close(); in Close()
Dipc_sync_message_filter.cc104 channel_ = channel; in OnFilterAdded()
115 channel_ = nullptr; in OnChannelError()
121 channel_ = nullptr; in OnChannelClosing()
146 : channel_(nullptr), in SyncMessageFilter()
153 if (channel_) { in SendOnIOThread()
154 channel_->Send(message); in SendOnIOThread()
184 if (!channel_) { in GetGenericRemoteAssociatedInterface()
193 channel_->GetAssociatedInterfaceSupport(); in GetGenericRemoteAssociatedInterface()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_channel.cc32 if (channel_) { in ~ChannelDestroyerFixture()
33 grpc_channel_destroy(channel_); in ~ChannelDestroyerFixture()
39 grpc_channel* channel_ = nullptr; member in ChannelDestroyerFixture
46 channel_ = grpc_insecure_channel_create("localhost:1234", nullptr, nullptr); in Init()
54 channel_ = grpc_lame_client_channel_create( in Init()
/external/pigweed/pw_rpc/public/pw_rpc/internal/
Dcall.h42 channel_(nullptr), in ServerCall()
51 channel_(&channel), in ServerCall()
67 PW_DCHECK_NOTNULL(channel_); in channel()
68 return *channel_; in channel()
83 Channel* channel_; variable
/external/libchrome/mojo/core/
Dbroker_host.cc38 channel_ = Channel::Create(this, std::move(connection_params), in BrokerHost()
40 channel_->Start(); in BrokerHost()
47 if (channel_) in ~BrokerHost()
48 channel_->ShutDown(); in ~BrokerHost()
67 CHECK(channel_); in SendChannel()
87 channel_->Write(std::move(message)); in SendChannel()
101 channel_->Write(std::move(message)); in SendNamedChannel()
139 channel_->Write(std::move(message)); in OnBufferRequest()
/external/rust/crates/grpcio-sys/grpc/src/cpp/client/
Dchannel_test_peer.cc30 grpc_core::MutexLock lock(&channel_->c_channel_->registration_table->mu); in registered_calls()
31 return static_cast<int>(channel_->c_channel_->registration_table->map.size()); in registered_calls()
35 grpc_core::MutexLock lock(&channel_->c_channel_->registration_table->mu); in registration_attempts()
36 return channel_->c_channel_->registration_table->method_registration_attempts; in registration_attempts()
/external/pigweed/pw_rpc/pw_rpc_private/
Dinternal_test_utils.h94 : channel_(Channel::Create<kChannelId>(&output_)), in ServerContextForTest()
95 server_(std::span(&channel_, 1)), in ServerContextForTest()
98 static_cast<internal::Channel&>(channel_), in ServerContextForTest()
120 Channel channel_; variable
139 : channel_(Channel::Create<kChannelId>(&output_)), in ClientContextForTest()
140 client_(std::span(&channel_, 1)) {} in ClientContextForTest()
143 Channel& channel() { return channel_; } in channel()
165 Channel channel_; variable
/external/flatbuffers/tests/
Dmonster_test.grpc.fb.cc32 …: channel_(channel) , rpcmethod_Store_(MonsterStorage_method_names[0], ::grpc::internal::RpcMetho… in Stub()
39 …return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Store_, context, request, res… in Store()
43 …ntAsyncResponseReaderFactory< flatbuffers::grpc::Message<Stat>>::Create(channel_.get(), cq, rpcmet… in AsyncStoreRaw()
47 …ntAsyncResponseReaderFactory< flatbuffers::grpc::Message<Stat>>::Create(channel_.get(), cq, rpcmet… in PrepareAsyncStoreRaw()
51 …rnal::ClientReaderFactory< flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), rpcmethod_… in RetrieveRaw()
55 …:ClientAsyncReaderFactory< flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq, rpcmet… in AsyncRetrieveRaw()
59 …:ClientAsyncReaderFactory< flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq, rpcmet… in PrepareAsyncRetrieveRaw()
63 …rnal::ClientWriterFactory< flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), rpcmethod_… in GetMaxHitPointRaw()
67 …:ClientAsyncWriterFactory< flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq, rpcmet… in AsyncGetMaxHitPointRaw()
71 …:ClientAsyncWriterFactory< flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq, rpcmet… in PrepareAsyncGetMaxHitPointRaw()
[all …]

12345