Home
last modified time | relevance | path

Searched refs:data_channel (Results 1 – 25 of 181) sorted by relevance

12345678

/dports/net-im/tg_owt/tg_owt-d578c76/src/pc/
H A Ddata_channel_integrationtest.cc170 ASSERT_NE(nullptr, caller()->data_channel()); in TEST_P()
171 ASSERT_NE(nullptr, callee()->data_channel()); in TEST_P()
192 ASSERT_TRUE(data_channel.get() != nullptr); in TEST_P()
224 ASSERT_NE(nullptr, caller()->data_channel()); in TEST_P()
225 ASSERT_NE(nullptr, callee()->data_channel()); in TEST_P()
230 callee()->data_channel()->Close(); in TEST_P()
311 EXPECT_EQ(nullptr, callee()->data_channel()); in TEST_P()
331 ASSERT_NE(nullptr, caller()->data_channel()); in TEST_P()
516 callee()->data_channel()->Close(); in TEST_P()
783 caller()->data_channel()->Close(); in TEST_F()
[all …]
H A Dchannel_manager.cc318 auto data_channel = std::make_unique<RtpDataChannel>( in CreateRtpDataChannel() local
324 data_channel->Init_w(rtp_transport); in CreateRtpDataChannel()
326 RtpDataChannel* data_channel_ptr = data_channel.get(); in CreateRtpDataChannel()
327 data_channels_.push_back(std::move(data_channel)); in CreateRtpDataChannel()
331 void ChannelManager::DestroyRtpDataChannel(RtpDataChannel* data_channel) { in DestroyRtpDataChannel() argument
333 if (!data_channel) { in DestroyRtpDataChannel()
338 RTC_FROM_HERE, [&] { return DestroyRtpDataChannel(data_channel); }); in DestroyRtpDataChannel()
345 return p.get() == data_channel; in DestroyRtpDataChannel()
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/api/test/
H A Dfakedatachannelprovider.h43 bool ConnectDataChannel(webrtc::DataChannel* data_channel) override { in ConnectDataChannel() argument
44 ASSERT(connected_channels_.find(data_channel) == connected_channels_.end()); in ConnectDataChannel()
48 LOG(LS_INFO) << "DataChannel connected " << data_channel; in ConnectDataChannel()
49 connected_channels_.insert(data_channel); in ConnectDataChannel()
53 void DisconnectDataChannel(webrtc::DataChannel* data_channel) override { in DisconnectDataChannel() argument
54 ASSERT(connected_channels_.find(data_channel) != connected_channels_.end()); in DisconnectDataChannel()
55 LOG(LS_INFO) << "DataChannel disconnected " << data_channel; in DisconnectDataChannel()
56 connected_channels_.erase(data_channel); in DisconnectDataChannel()
122 bool IsConnected(webrtc::DataChannel* data_channel) const { in IsConnected() argument
123 return connected_channels_.find(data_channel) != connected_channels_.end(); in IsConnected()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/pc/test/
H A Dfake_data_channel_provider.h47 bool ConnectDataChannel(webrtc::DataChannel* data_channel) override { in ConnectDataChannel() argument
48 RTC_CHECK(connected_channels_.find(data_channel) == in ConnectDataChannel()
53 RTC_LOG(LS_INFO) << "DataChannel connected " << data_channel; in ConnectDataChannel()
54 connected_channels_.insert(data_channel); in ConnectDataChannel()
58 void DisconnectDataChannel(webrtc::DataChannel* data_channel) override { in DisconnectDataChannel() argument
59 RTC_CHECK(connected_channels_.find(data_channel) != in DisconnectDataChannel()
61 RTC_LOG(LS_INFO) << "DataChannel disconnected " << data_channel; in DisconnectDataChannel()
62 connected_channels_.erase(data_channel); in DisconnectDataChannel()
133 bool IsConnected(webrtc::DataChannel* data_channel) const { in IsConnected() argument
134 return connected_channels_.find(data_channel) != connected_channels_.end(); in IsConnected()
/dports/net-im/tg_owt/tg_owt-d578c76/src/pc/test/
H A Dfake_data_channel_provider.h48 bool ConnectDataChannel(webrtc::SctpDataChannel* data_channel) override { in ConnectDataChannel() argument
49 RTC_CHECK(connected_channels_.find(data_channel) == in ConnectDataChannel()
54 RTC_LOG(LS_INFO) << "DataChannel connected " << data_channel; in ConnectDataChannel()
55 connected_channels_.insert(data_channel); in ConnectDataChannel()
59 void DisconnectDataChannel(webrtc::SctpDataChannel* data_channel) override { in DisconnectDataChannel() argument
60 RTC_CHECK(connected_channels_.find(data_channel) != in DisconnectDataChannel()
62 RTC_LOG(LS_INFO) << "DataChannel disconnected " << data_channel; in DisconnectDataChannel()
63 connected_channels_.erase(data_channel); in DisconnectDataChannel()
134 bool IsConnected(webrtc::SctpDataChannel* data_channel) const { in IsConnected() argument
135 return connected_channels_.find(data_channel) != connected_channels_.end(); in IsConnected()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/pc/test/
H A Dfake_data_channel_provider.h48 bool ConnectDataChannel(webrtc::SctpDataChannel* data_channel) override { in ConnectDataChannel() argument
49 RTC_CHECK(connected_channels_.find(data_channel) == in ConnectDataChannel()
54 RTC_LOG(LS_INFO) << "DataChannel connected " << data_channel; in ConnectDataChannel()
55 connected_channels_.insert(data_channel); in ConnectDataChannel()
59 void DisconnectDataChannel(webrtc::SctpDataChannel* data_channel) override { in DisconnectDataChannel() argument
60 RTC_CHECK(connected_channels_.find(data_channel) != in DisconnectDataChannel()
62 RTC_LOG(LS_INFO) << "DataChannel disconnected " << data_channel; in DisconnectDataChannel()
63 connected_channels_.erase(data_channel); in DisconnectDataChannel()
134 bool IsConnected(webrtc::SctpDataChannel* data_channel) const { in IsConnected() argument
135 return connected_channels_.find(data_channel) != connected_channels_.end(); in IsConnected()
/dports/devel/pycos/pycos-4.8.11/py3.7/pycos/examples/
H A Ddispycos_client6_channel.py82 data_channel = pycos.Channel('data_channel')
89 rtask_avg = yield computation.run(rtask_avg_proc, data_channel, 0.4, trend_task, 10)
91 rtask_save = yield computation.run(rtask_save_proc, data_channel)
96 assert (yield data_channel.deliver('start', n=2)) == 2
114 data_channel.send(item)
117 data_channel.send(item)
120 data_channel.close()
/dports/devel/pycos/pycos-4.8.11/py2/pycos/examples/
H A Ddispycos_client6_channel.py82 data_channel = pycos.Channel('data_channel')
89 rtask_avg = yield computation.run(rtask_avg_proc, data_channel, 0.4, trend_task, 10)
91 rtask_save = yield computation.run(rtask_save_proc, data_channel)
96 assert (yield data_channel.deliver('start', n=2)) == 2
114 data_channel.send(item)
117 data_channel.send(item)
120 data_channel.close()
/dports/devel/pycos/pycos-4.8.11/py3/pycos/examples/
H A Ddispycos_client6_channel.py82 data_channel = pycos.Channel('data_channel')
89 rtask_avg = yield computation.run(rtask_avg_proc, data_channel, 0.4, trend_task, 10)
91 rtask_save = yield computation.run(rtask_save_proc, data_channel)
96 assert (yield data_channel.deliver('start', n=2)) == 2
114 data_channel.send(item)
117 data_channel.send(item)
120 data_channel.close()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/nearby/src/cpp/core/internal/mediums/webrtc/
H A Dconnection_flow.cc117 rtc::scoped_refptr<webrtc::DataChannelInterface> data_channel = in CreateOffer() local
119 data_channel->RegisterObserver(CreateDataChannelObserver(data_channel)); in CreateOffer()
305 rtc::scoped_refptr<webrtc::DataChannelInterface> data_channel) { in CreateDataChannelObserver() argument
308 data_channel{std::move(data_channel)}]() { in CreateDataChannelObserver()
309 if (data_channel->state() == in CreateDataChannelObserver()
311 data_channel_future_.Set(std::move(data_channel)); in CreateDataChannelObserver()
313 } else if (data_channel->state() == in CreateDataChannelObserver()
315 data_channel->UnregisterObserver(); in CreateDataChannelObserver()
H A Dpeer_connection_observer_impl.cc48 rtc::scoped_refptr<webrtc::DataChannelInterface> data_channel) { in OnDataChannel() argument
51 data_channel->RegisterObserver( in OnDataChannel()
52 connection_flow_->CreateDataChannelObserver(data_channel)); in OnDataChannel()
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/pc/
H A Dchannelmanager.cc389 RtpDataChannel* data_channel = new RtpDataChannel( in CreateRtpDataChannel_w() local
392 data_channel->SetCryptoOptions(crypto_options_); in CreateRtpDataChannel_w()
393 if (!data_channel->Init_w(rtp_transport, rtcp_transport)) { in CreateRtpDataChannel_w()
395 delete data_channel; in CreateRtpDataChannel_w()
398 data_channels_.push_back(data_channel); in CreateRtpDataChannel_w()
399 return data_channel; in CreateRtpDataChannel_w()
402 void ChannelManager::DestroyRtpDataChannel(RtpDataChannel* data_channel) { in DestroyRtpDataChannel() argument
404 if (data_channel) { in DestroyRtpDataChannel()
407 Bind(&ChannelManager::DestroyRtpDataChannel_w, this, data_channel)); in DestroyRtpDataChannel()
411 void ChannelManager::DestroyRtpDataChannel_w(RtpDataChannel* data_channel) { in DestroyRtpDataChannel_w() argument
[all …]
/dports/lang/v8/v8-9.6.180.12/test/fuzzilli/
H A Dlibreprl.c78 struct data_channel { struct
95 struct data_channel* data_in; argument
97 struct data_channel* data_out;
100 struct data_channel* stdout;
101 struct data_channel* stderr;
123 static struct data_channel* reprl_create_data_channel(struct reprl_context* ctx) in reprl_create_data_channel()
146 struct data_channel* channel = malloc(sizeof(struct data_channel)); in reprl_create_data_channel()
152 static void reprl_destroy_data_channel(struct reprl_context* ctx, struct data_channel* channel) in reprl_destroy_data_channel()
453 static const char* fetch_data_channel_content(struct data_channel* channel) in fetch_data_channel_content()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/pc/
H A Dpeer_connection_integrationtest.cc1007 data_channel_ = data_channel; in OnDataChannel()
3474 ASSERT_NE(nullptr, caller()->data_channel()); in TEST_P()
3475 ASSERT_NE(nullptr, callee()->data_channel()); in TEST_P()
3496 ASSERT_TRUE(data_channel.get() != nullptr); in TEST_P()
3529 ASSERT_NE(nullptr, caller()->data_channel()); in TEST_P()
3530 ASSERT_NE(nullptr, callee()->data_channel()); in TEST_P()
3535 callee()->data_channel()->Close(); in TEST_P()
3698 callee()->data_channel()->Close(); in TEST_P()
4654 callee()->data_channel()->Close(); in TEST_P()
6454 caller()->data_channel()->Close(); in TEST_F()
[all …]
H A Dchannel_manager.cc352 auto data_channel = std::make_unique<RtpDataChannel>( in CreateRtpDataChannel() local
358 data_channel->Init_w(rtp_transport, webrtc::MediaTransportConfig()); in CreateRtpDataChannel()
360 RtpDataChannel* data_channel_ptr = data_channel.get(); in CreateRtpDataChannel()
361 data_channels_.push_back(std::move(data_channel)); in CreateRtpDataChannel()
365 void ChannelManager::DestroyRtpDataChannel(RtpDataChannel* data_channel) { in DestroyRtpDataChannel() argument
367 if (!data_channel) { in DestroyRtpDataChannel()
372 RTC_FROM_HERE, [&] { return DestroyRtpDataChannel(data_channel); }); in DestroyRtpDataChannel()
380 return p.get() == data_channel; in DestroyRtpDataChannel()
/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/demos/
H A DDraw2Channels.java25 private Channel data_channel=null; field in Draw2Channels
109 data_channel=new JChannel(data_props); in go()
110 data_channel.setReceiver(data_receiver); in go()
113 data_channel.connect(data_groupname); in go()
173 data_channel.send(new Message(null, null, buf)); in sendClearPanelMsg()
199 data_channel.close(); in actionPerformed()
258 data_channel.send(new Message(null, null, buf)); in mouseDragged()
309 data_channel.down(new Event(Event.VIEW_CHANGE, v)); in viewAccepted()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/pc/
H A Dchannel_manager.cc355 auto data_channel = std::make_unique<RtpDataChannel>( in CreateRtpDataChannel() local
361 data_channel->Init_w(rtp_transport); in CreateRtpDataChannel()
363 RtpDataChannel* data_channel_ptr = data_channel.get(); in CreateRtpDataChannel()
364 data_channels_.push_back(std::move(data_channel)); in CreateRtpDataChannel()
368 void ChannelManager::DestroyRtpDataChannel(RtpDataChannel* data_channel) { in DestroyRtpDataChannel() argument
370 if (!data_channel) { in DestroyRtpDataChannel()
375 RTC_FROM_HERE, [&] { return DestroyRtpDataChannel(data_channel); }); in DestroyRtpDataChannel()
383 return p.get() == data_channel; in DestroyRtpDataChannel()
/dports/ftp/py-pyftpdlib/pyftpdlib-1.5.6/pyftpdlib/
H A Dhandlers.py1226 self.data_channel = None
1591 self.data_channel.close()
1592 del self.data_channel
1710 self.data_channel.cmd = cmd
1733 self.data_channel = None
1805 self.data_channel = None
1960 self.data_channel.close()
1961 self.data_channel = None
1983 self.data_channel.close()
1984 self.data_channel = None
[all …]
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/session/phone/
H A Dcall.cc222 DataChannel* data_channel = NULL; in AddSession() local
262 if (data_channel) { in AddSession()
263 data_channel_map_[session->id()] = data_channel; in AddSession()
327 DataChannel* data_channel = it_dchannel->second; in RemoveSession() local
365 DataChannel* data_channel = GetDataChannel(*it); in EnableChannels() local
370 if (data_channel != NULL) in EnableChannels()
371 data_channel->Enable(enable); in EnableChannels()
400 DataChannel* data_channel = GetDataChannel(session); in SendData() local
401 if (!data_channel) { in SendData()
406 data_channel->SendData(params, data); in SendData()
[all …]
H A Dchannelmanager.cc83 data_channel(NULL) { in CreationParams()
90 DataChannel* data_channel; member
462 DataChannel* data_channel = new DataChannel( in CreateDataChannel_w() local
465 if (!data_channel->Init()) { in CreateDataChannel_w()
467 delete data_channel; in CreateDataChannel_w()
470 data_channels_.push_back(data_channel); in CreateDataChannel_w()
471 return data_channel; in CreateDataChannel_w()
475 if (data_channel) { in DestroyDataChannel()
485 data_channels_.end(), data_channel); in DestroyDataChannel_w()
491 delete data_channel; in DestroyDataChannel_w()
[all …]
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/test/fuzzers/corpora/sdp-corpus/
H A Dunittest-3.sdp11 a=ssrc:10 msid:data_channel data_channeld0
12 a=ssrc:10 mslabel:data_channel
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/test/fuzzers/corpora/sdp-corpus/
H A Dunittest-3.sdp11 a=ssrc:10 msid:data_channel data_channeld0
12 a=ssrc:10 mslabel:data_channel
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/test/fuzzers/corpora/sdp-corpus/
H A Dunittest-3.sdp11 a=ssrc:10 msid:data_channel data_channeld0
12 a=ssrc:10 mslabel:data_channel
/dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/test/fuzzers/corpora/sdp-corpus/
H A Dunittest-3.sdp11 a=ssrc:10 msid:data_channel data_channeld0
12 a=ssrc:10 mslabel:data_channel
/dports/www/janus/janus-gateway-0.11.6/fuzzers/corpora/sdp_fuzzer/2webrtc/
H A Dunittest-3.sdp11 a=ssrc:10 msid:data_channel data_channeld0
12 a=ssrc:10 mslabel:data_channel

12345678