| /xiu/application/http-server/src/ |
| H A D | main.rs | 21 log::info!("http server listen on: {}", 3001); in main()
34 log::info!("on_publish body: {}", body); in on_publish()
38 log::info!("on_unpublish body: {}", body); in on_unpublish()
42 log::info!("on_play body: {}", body); in on_play()
46 log::info!("on_stop body: {}", body); in on_stop()
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 193 TransmitterEvent::UnSubscribe { info } => match info.sub_type { in receive_event_loop()
331 log::info!("event data: {}", data); in event_loop()
340 info, in event_loop()
410 info: _, in event_loop()
426 info, in event_loop()
429 let sub_id = info.id; in event_loop()
430 let info_clone = info.clone(); in event_loop()
561 let info = if let Some(info) = self.streams_info.get(&uid) { in api_kick_off_client() localVariable
562 info.clone() in api_kick_off_client()
567 match info { in api_kick_off_client()
[all …]
|
| H A D | define.rs | 215 info: SubscriberInfo,
221 info: SubscriberInfo,
225 info: PublisherInfo,
233 info: PublisherInfo,
254 info: SubscriberInfo,
257 info: SubscriberInfo,
|
| /xiu/library/streamhub/src/notify/ |
| H A D | mod.rs | 38 log::info!("on_publish success: {:?}", response); in on_publish_notify()
57 log::info!("on_unpublish success: {:?}", response); in on_unpublish_notify()
76 log::info!("on_play success: {:?}", response); in on_play_notify()
95 log::info!("on_stop success: {:?}", response); in on_stop_notify()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 104 log::info!("server session: {}", addr.to_string()); in new()
149 log::info!("[C -> S] handshake..."); in run()
154 log::info!("[C -> S] connect..."); in run()
160 log::info!("[C -> S] CreateStream..."); in run()
166 log::info!("[C -> S] Play..."); in run()
172 log::info!("[C -> S] PublishingContent..."); in run()
178 log::info!("[C -> S] StartPublish..."); in run()
214 log::info!("handshake finish"); in handshake()
255 log::info!("[C <- S] on_set_chunk_size..."); in process_messages()
259 log::info!("[C <- S] on_stream_begin..."); in process_messages()
[all …]
|
| H A D | server_session.rs | 308 log::info!("[ S<-C ] [connect] "); in on_amf0_command_message()
322 log::info!( in on_amf0_command_message()
333 log::info!( in on_amf0_command_message()
352 log::info!( in on_set_chunk_size()
483 log::info!( in on_create_stream()
515 log::info!( in on_delete_stream()
589 log::info!( in on_play()
641 log::info!( in on_play()
702 log::info!( in on_publish()
709 log::info!( in on_publish()
[all …]
|
| H A D | common.rs | 301 log::info!( in subscribe_from_channels()
317 info: self.get_subscriber_info(sub_id), in subscribe_from_channels()
347 info: self.get_subscriber_info(sub_id), in unsubscribe_from_channels()
374 info: self.get_publisher_info(pub_id), in publish_to_channels()
396 log::info!( in unpublish_to_channels()
406 info: self.get_publisher_info(pub_id), in unpublish_to_channels()
421 log::info!( in unpublish_to_channels()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | push_client.rs | 32 log::info!("push client run..."); in run()
44 log::info!( in run()
71 log::info!("push client receive other events"); in run()
|
| H A D | pull_client.rs | 42 log::info!( in run()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | handshake_server.rs | 53 log::info!("[ S<-C ] [simple handshake] read C0C1"); in handshake()
60 log::info!("[ S->C ] [simple handshake] write S0S1S2"); in handshake()
70 log::info!("[ S<-C ] [simple handshake] read C2"); in handshake()
76 log::info!("simple handshake successfully.."); in handshake()
106 log::info!("[ S<-C ] [complex handshake] read C0C1"); in handshake()
113 log::info!("[ S->C ] [complex handshake] write S0S1S2"); in handshake()
118 log::info!("[ S->C ] [complex handshake] write S0S1S2 finish"); in handshake()
124 log::info!("[ S<-C ] [complex handshake] read C2"); in handshake()
130 log::info!("complex handshake successfully.."); in handshake()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 26 log::info!("rtmp remuxer start..."); in run()
30 log::info!("{:?}", val); in run()
|
| /xiu/protocol/rtmp/src/ |
| H A D | rtmp.rs | 27 log::info!("Rtmp server listening on tcp://{}", socket_addr); in run()
39 log::info!( in run()
|
| /xiu/application/xiu/src/config/ |
| H A D | config_rtmp.toml | 13 level = "info"
|
| H A D | config_rtmp_hls.toml | 22 level = "info"
|
| H A D | config_rtmp_httpflv_hls.toml | 28 level = "info"
|
| H A D | config_rtmp_httpflv.toml | 28 level = "info"
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 137 log::info!("1:{},2:{},3:{}", t, app_name, stream_name); in run()
191 log::info!("close peer connection successfully."); in run()
261 info: self.get_publisher_info(), in publish_whip()
309 info: publish_info, in unpublish_whip()
337 info: subscriber_info.clone(), in subscribe_whep()
363 log::info!("state: {}", state); in subscribe_whep()
385 log::info!("recv"); in subscribe_whep()
399 log::info!("before whep 1"); in subscribe_whep()
422 info: subscriber_info, in unsubscribe_whep()
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 37 log::info!("remote address: {}", remote_address); in new()
42 log::info!("connect to remote udp socket error: {}", err); in new()
54 log::info!("local address: {}", local_addr); in get_local_port()
|
| /xiu/protocol/webrtc/src/ |
| H A D | whip.rs | 158 log::info!("Connection State has changed {connection_state}"); in handle_whip()
160 log::info!("Ctrl+C the remote client to stop the demo"); in handle_whip()
170 log::info!("Peer Connection State has changed: {s}"); in handle_whip()
|
| H A D | whep.rs | 109 log::info!("Connection State has changed {connection_state}"); in handle_whep()
121 log::info!("Peer Connection State has changed: {s}"); in handle_whep()
127 log::info!("Peer Connection has gone to failed exiting: Done forwarding"); in handle_whep()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 83 log::info!("write_flv_tag: {}", err_in); in send_media_stream()
157 info: sub_info, in unsubscribe_from_rtmp_channels()
186 info: sub_info, in subscribe_from_rtmp_channels()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp.rs | 25 log::info!("Rtsp server listening on tcp://{}", socket_addr); in run()
|
| /xiu/library/container/flv/src/ |
| H A D | mpeg4_avc.rs | 187 log::info!("mpeg4 avc profile: {}", self.mpeg4_avc.profile); in decoder_configuration_record_load()
188 log::info!("mpeg4 avc compatibility: {}", self.mpeg4_avc.compatibility); in decoder_configuration_record_load()
189 log::info!("mpeg4 avc level: {}", self.mpeg4_avc.level); in decoder_configuration_record_load()
190 log::info!( in decoder_configuration_record_load()
|
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 120 info: sub_info, in subscribe_from_rtmp_channels()
159 info: sub_info, in unsubscribe_from_rtmp_channels()
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | metadata.rs | 60 log::info!("metadata: {:?}", values); in is_metadata()
|