Home
last modified time | relevance | path

Searched refs:event_stream (Results 1 – 25 of 410) sorted by relevance

12345678910>>...17

/dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/event_handlers/mod_kazoo/
H A Dkazoo_event_stream.c261 ,(void *)event_stream, ip_addr, port, event_stream->pid.node, event_stream->pid.creation in event_stream_loop()
262 ,event_stream->pid.num, event_stream->pid.serial); in event_stream_loop()
371 switch_pollset_remove(event_stream->pollset, event_stream->pollfd); in event_stream_loop()
411 memset(event_stream, 0, sizeof(*event_stream)); in new_event_stream()
470 if (event_stream) { in new_event_stream()
500 event_stream = event_stream->next; in find_event_stream()
524 event_stream = event_stream->next; in remove_event_stream()
550 event_stream = event_stream->next; in remove_event_streams()
654 ,event_binding->id, (void *)event_stream, event_stream->pid.node, event_stream->pid.creation in add_event_binding()
700 ,event_binding->id, (void *)event_stream, event_stream->pid.node, event_stream->pid.creation in remove_event_binding()
[all …]
H A Dkazoo_api.c260 switch_mutex_lock(event_stream->socket_mutex); in handle_node_api_event_stream()
261 if (event_stream->connected == SWITCH_FALSE) { in handle_node_api_event_stream()
288 ,event_stream->local_ip, event_stream->local_port in handle_node_api_event_stream()
289 ,event_stream->remote_ip, event_stream->remote_port in handle_node_api_event_stream()
293 binding = event_stream->bindings; in handle_node_api_event_stream()
308 switch_mutex_unlock(event_stream->socket_mutex); in handle_node_api_event_stream()
320 ei_event_stream_t *event_stream; in handle_node_api_event_streams() local
323 event_stream = ei_node->event_streams; in handle_node_api_event_streams()
324 while(event_stream != NULL) { in handle_node_api_event_streams()
325 handle_node_api_event_stream(event_stream, stream); in handle_node_api_event_streams()
[all …]
/dports/net-im/tg_owt/tg_owt-d578c76/src/logging/rtc_event_log/encoder/
H A Drtc_event_log_encoder_new_format.h77 rtclog2::EventStream* event_stream);
82 rtclog2::EventStream* event_stream);
85 rtclog2::EventStream* event_stream);
88 rtclog2::EventStream* event_stream);
91 rtclog2::EventStream* event_stream);
94 rtclog2::EventStream* event_stream);
97 rtclog2::EventStream* event_stream);
100 rtclog2::EventStream* event_stream);
103 rtclog2::EventStream* event_stream);
106 rtclog2::EventStream* event_stream);
[all …]
H A Drtc_event_log_encoder_new_format.cc666 rtclog2::EventStream event_stream; in EncodeLogStart() local
675 rtclog2::EventStream event_stream; in EncodeLogEnd() local
684 rtclog2::EventStream event_stream; in EncodeBatch() local
928 rtclog2::EventStream* event_stream) { in EncodeAlrState() argument
939 rtclog2::EventStream* event_stream) { in EncodeAudioNetworkAdaptation() argument
1091 rtclog2::EventStream* event_stream) { in EncodeAudioPlayout() argument
1133 rtclog2::EventStream* event_stream) { in EncodeAudioRecvStreamConfig() argument
1152 rtclog2::EventStream* event_stream) { in EncodeAudioSendStreamConfig() argument
1170 rtclog2::EventStream* event_stream) { in EncodeBweUpdateDelayBased() argument
1227 rtclog2::EventStream* event_stream) { in EncodeBweUpdateLossBased() argument
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/logging/rtc_event_log/encoder/
H A Drtc_event_log_encoder_new_format.h77 rtclog2::EventStream* event_stream);
82 rtclog2::EventStream* event_stream);
85 rtclog2::EventStream* event_stream);
88 rtclog2::EventStream* event_stream);
91 rtclog2::EventStream* event_stream);
94 rtclog2::EventStream* event_stream);
97 rtclog2::EventStream* event_stream);
100 rtclog2::EventStream* event_stream);
103 rtclog2::EventStream* event_stream);
106 rtclog2::EventStream* event_stream);
[all …]
H A Drtc_event_log_encoder_new_format.cc666 rtclog2::EventStream event_stream; in EncodeLogStart() local
675 rtclog2::EventStream event_stream; in EncodeLogEnd() local
684 rtclog2::EventStream event_stream; in EncodeBatch() local
928 rtclog2::EventStream* event_stream) { in EncodeAlrState() argument
939 rtclog2::EventStream* event_stream) { in EncodeAudioNetworkAdaptation() argument
1091 rtclog2::EventStream* event_stream) { in EncodeAudioPlayout() argument
1133 rtclog2::EventStream* event_stream) { in EncodeAudioRecvStreamConfig() argument
1152 rtclog2::EventStream* event_stream) { in EncodeAudioSendStreamConfig() argument
1170 rtclog2::EventStream* event_stream) { in EncodeBweUpdateDelayBased() argument
1227 rtclog2::EventStream* event_stream) { in EncodeBweUpdateLossBased() argument
[all …]
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/logging/rtc_event_log/encoder/
H A Drtc_event_log_encoder_new_format.h77 rtclog2::EventStream* event_stream);
82 rtclog2::EventStream* event_stream);
85 rtclog2::EventStream* event_stream);
88 rtclog2::EventStream* event_stream);
91 rtclog2::EventStream* event_stream);
94 rtclog2::EventStream* event_stream);
97 rtclog2::EventStream* event_stream);
100 rtclog2::EventStream* event_stream);
103 rtclog2::EventStream* event_stream);
106 rtclog2::EventStream* event_stream);
[all …]
H A Drtc_event_log_encoder_new_format.cc668 rtclog2::EventStream event_stream; in EncodeLogStart() local
677 rtclog2::EventStream event_stream; in EncodeLogEnd() local
686 rtclog2::EventStream event_stream; in EncodeBatch() local
930 rtclog2::EventStream* event_stream) { in EncodeAlrState() argument
941 rtclog2::EventStream* event_stream) { in EncodeAudioNetworkAdaptation() argument
1093 rtclog2::EventStream* event_stream) { in EncodeAudioPlayout() argument
1135 rtclog2::EventStream* event_stream) { in EncodeAudioRecvStreamConfig() argument
1154 rtclog2::EventStream* event_stream) { in EncodeAudioSendStreamConfig() argument
1172 rtclog2::EventStream* event_stream) { in EncodeBweUpdateDelayBased() argument
1229 rtclog2::EventStream* event_stream) { in EncodeBweUpdateLossBased() argument
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/logging/rtc_event_log/encoder/
H A Drtc_event_log_encoder_new_format.h76 rtclog2::EventStream* event_stream);
81 rtclog2::EventStream* event_stream);
84 rtclog2::EventStream* event_stream);
87 rtclog2::EventStream* event_stream);
90 rtclog2::EventStream* event_stream);
93 rtclog2::EventStream* event_stream);
96 rtclog2::EventStream* event_stream);
99 rtclog2::EventStream* event_stream);
102 rtclog2::EventStream* event_stream);
105 rtclog2::EventStream* event_stream);
[all …]
H A Drtc_event_log_encoder_new_format.cc645 rtclog2::EventStream event_stream; in EncodeLogStart() local
654 rtclog2::EventStream event_stream; in EncodeLogEnd() local
663 rtclog2::EventStream event_stream; in EncodeBatch() local
896 rtclog2::EventStream* event_stream) { in EncodeAlrState() argument
907 rtclog2::EventStream* event_stream) { in EncodeAudioNetworkAdaptation() argument
1059 rtclog2::EventStream* event_stream) { in EncodeAudioPlayout() argument
1101 rtclog2::EventStream* event_stream) { in EncodeAudioRecvStreamConfig() argument
1120 rtclog2::EventStream* event_stream) { in EncodeAudioSendStreamConfig() argument
1138 rtclog2::EventStream* event_stream) { in EncodeBweUpdateDelayBased() argument
1195 rtclog2::EventStream* event_stream) { in EncodeBweUpdateLossBased() argument
[all …]
/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/lib_rpl/rpl/
H A Devent_stream.h23 class event_stream {
25 event_stream();
26 event_stream(event_stream &&other);
27 event_stream &operator=(event_stream &&other);
84 ~event_stream(); in events()
98 inline event_stream<Value, Error>::event_stream() { in event_stream() function
102 inline event_stream<Value, Error>::event_stream(event_stream &&other) in event_stream() function
107 inline event_stream<Value, Error> &event_stream<Value, Error>::operator=(
108 event_stream &&other) {
212 inline event_stream<Value, Error>::~event_stream() { in ~event_stream()
[all …]
/dports/devel/py-graphql-core/graphql-core-3.1.6/src/graphql/subscription/
H A Dsubscribe.py183 event_stream = resolve_fn(context.root_value, info, **args)
184 if context.is_awaitable(event_stream):
185 event_stream = await event_stream
187 event_stream = error
189 if isinstance(event_stream, Exception):
190 raise located_error(event_stream, field_nodes, path.as_list())
193 if not isinstance(event_stream, AsyncIterable):
199 return event_stream
/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/storage/
H A Dfile_upload.h141 rpl::event_stream<UploadedPhoto> _photoReady;
142 rpl::event_stream<UploadedDocument> _documentReady;
143 rpl::event_stream<UploadSecureDone> _secureReady;
144 rpl::event_stream<FullMsgId> _photoProgress;
145 rpl::event_stream<FullMsgId> _documentProgress;
146 rpl::event_stream<UploadSecureProgress> _secureProgress;
147 rpl::event_stream<FullMsgId> _photoFailed;
148 rpl::event_stream<FullMsgId> _documentFailed;
149 rpl::event_stream<FullMsgId> _secureFailed;
/dports/devel/py-botocore/botocore-1.21.61/tests/unit/
H A Dtest_eventstream.py442 event_stream = EventStream(raw_stream, output_shape, parser, '')
443 events = list(event_stream)
459 event_stream = EventStream(raw_stream, output_shape, parser, '')
461 list(event_stream)
466 event_stream = EventStream(raw_stream, None, None, '')
467 event_stream.close()
479 event_stream = EventStream(raw_stream, output_shape, parser, '')
480 event = event_stream.get_initial_response()
498 event_stream = EventStream(raw_stream, output_shape, parser, '')
500 event_stream.get_initial_response()
[all …]
/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/mtproto/details/
H A Dmtproto_abstract_socket.h60 rpl::event_stream<> _connected;
61 rpl::event_stream<> _disconnected;
62 rpl::event_stream<> _readyRead;
63 rpl::event_stream<> _error;
64 rpl::event_stream<> _syncTimeRequests;
/dports/net-p2p/bazarr/bazarr-1.0.2/bazarr/
H A Devent_handler.py6 def event_stream(type, action="update", payload=None): function
23 event_stream(type="message", payload=msg)
27 …event_stream(type="progress", payload={"id": id, "header": header, "name": name, "value": value, "…
31 event_stream(type="progress", action="delete", payload=id)
/dports/devel/clixon/clixon-4.8.0/lib/clixon/
H A Dclixon_handle.h93 struct event_stream *clicon_stream(clicon_handle h);
94 struct event_stream;
95 int clicon_stream_set(clicon_handle h, struct event_stream *es);
96 int clicon_stream_append(clicon_handle h, struct event_stream *es);
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/utils/hsdis/
H A Dhsdis.h60 void* event_stream,
73 void* event_stream,
85 void* event_stream,
92 void* event_stream,
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/utils/hsdis/
H A Dhsdis.h82 void* event_stream,
95 void* event_stream,
107 void* event_stream,
114 void* event_stream,
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/utils/hsdis/
H A Dhsdis.h82 void* event_stream,
95 void* event_stream,
107 void* event_stream,
114 void* event_stream,
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/utils/hsdis/
H A Dhsdis.h82 void* event_stream,
95 void* event_stream,
107 void* event_stream,
114 void* event_stream,
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/utils/hsdis/
H A Dhsdis.h82 void* event_stream,
95 void* event_stream,
107 void* event_stream,
114 void* event_stream,
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/utils/hsdis/
H A Dhsdis.h60 void* event_stream,
73 void* event_stream,
85 void* event_stream,
92 void* event_stream,
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/utils/hsdis/
H A Dhsdis.h82 void* event_stream,
95 void* event_stream,
107 void* event_stream,
114 void* event_stream,
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/utils/hsdis/
H A Dhsdis.h82 void* event_stream,
95 void* event_stream,
107 void* event_stream,
114 void* event_stream,

12345678910>>...17