| /xiu/library/streamhub/src/notify/ |
| H A D | mod.rs | 35 log::error!("on_publish error: {}", err); in on_publish_notify()
38 log::info!("on_publish success: {:?}", response); in on_publish_notify()
54 log::error!("on_unpublish error: {}", err); in on_unpublish_notify()
57 log::info!("on_unpublish success: {:?}", response); in on_unpublish_notify()
73 log::error!("on_play error: {}", err); in on_play_notify()
76 log::info!("on_play success: {:?}", response); in on_play_notify()
92 log::error!("on_stop error: {}", err); in on_stop_notify()
95 log::info!("on_stop success: {:?}", response); in on_stop_notify()
|
| /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/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 26 log::info!("rtmp remuxer start..."); in run()
30 log::info!("{:?}", val); in run()
38 log::error!("rtsp2rtmp session error: {}", err); in run()
44 log::trace!("other infos..."); in run()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | unpacketizer.rs | 114 log::trace!( in extend_data()
130 log::trace!( in read_chunks()
168 log::trace!( in read_chunks()
194 log::trace!( in read_chunk()
216 log::trace!( in read_chunk()
228 log::trace!( in print_current_basic_header()
369 log::trace!( in print_current_message_header()
381 log::trace!( in read_message_header()
582 log::trace!( in read_message_payload()
599 log::trace!( in read_message_payload()
[all …]
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 331 log::info!("event data: {}", data); in event_loop()
413 log::error!( in event_loop()
498 log::error!("event_loop api error: {}", err); in event_loop()
510 log::error!("event_loop request error: {}", err); in event_loop()
524 log::info!("Request: stream identifier: {}", identifier); in request()
551 log::error!("TransmitterEvent api send size err: {}", err); in api_statistic()
570 log::error!( in api_kick_off_client()
582 log::error!( in api_kick_off_client()
604 log::info!("subscribe: stream identifier: {}", identifer); in subscribe()
639 log::info!("unsubscribe....:{}", identifer); in unsubscribe()
[all …]
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | push_client.rs | 32 log::info!("push client run..."); in run()
44 log::info!( in run()
64 log::error!("client_session as push client run error: {}", err); in run()
71 log::info!("push client receive other events"); in run()
|
| H A D | pull_client.rs | 42 log::info!( in run()
61 log::error!("client_session as pull client run error: {}", err); in run()
|
| /xiu/application/xiu/src/ |
| H A D | service.rs | 58 log::info!("stream hub end..."); in run()
100 log::info!("start rtmp push client.."); in start_rtmp()
114 log::error!("push client error {}", err); in start_rtmp()
138 log::error!("pull client error {}", err); in start_rtmp()
152 log::error!("rtmp server error: {}", err); in start_rtmp()
189 log::error!("rtmp remuxer server error: {}", err); in start_rtmp_remuxer()
211 log::error!("rtsp server error: {}", err); in start_rtsp()
235 log::error!("webrtc server error: {}", err); in start_webrtc()
255 log::error!("httpflv server error: {}", err); in start_httpflv()
281 log::error!("rtmp event processor error: {}", err); in start_hls()
[all …]
|
| H A D | api.rs | 44 log::error!("send api event error: {}", err); in get_stream_status()
62 log::error!("start_api_service recv size error: {}", err); in get_stream_status()
80 log::error!("send api kick_off_client event error: {}", err); in kick_off_client()
117 log::info!("Http api server listening on http://0.0.0.0:{}", port); in run()
|
| /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()
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()
288 log::info!("[C <- S] on_amf0_command_message..."); in on_amf0_command_message()
[all …]
|
| H A D | server_session.rs | 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()
594 log::trace!( in on_play()
641 log::info!( in on_play()
702 log::info!( in on_publish()
709 log::info!( in on_publish()
[all …]
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 88 log::trace!( in run()
123 log::error!( in run()
168 log::error!( in run()
199 log::error!( in run()
217 log::error!( in run()
233 log::warn!( in run()
289 log::error!("handle whip err: {}", err); in publish_whip()
363 log::info!("state: {}", state); in subscribe_whep()
385 log::info!("recv"); in subscribe_whep()
399 log::info!("before whep 1"); in subscribe_whep()
[all …]
|
| /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()
320 log::warn!("complex handshake failed.. err:{}", err); in handshake()
|
| /xiu/protocol/webrtc/src/ |
| 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()
131 log::error!("on_peer_connection_state_change send state err: {}", err); in handle_whep()
163 log::error!("send video data error: {}", err); in handle_whep()
168 log::error!("send audio data error: {}", err); in handle_whep()
|
| H A D | whip.rs | 131 log::error!("send video packet error: {}", err); in handle_whip()
141 log::error!("send audio packet error: {}", err); in handle_whip()
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()
|
| /xiu/application/xiu/src/config/ |
| H A D | config.toml | 64 [log]
66 [log.file]
67 # write log to file or not（Writing logs to file or console cannot be satisfied at the same time）.
|
| /xiu/protocol/rtsp/src/sdp/ |
| H A D | fmtp.rs | 77 log::warn!("H264FmtpSdp parse err: {}", raw_data); in unmarshal()
89 log::warn!("H264FmtpSdp parse key=value err: {}", parameter); in unmarshal()
109 log::info!("not parsed: {}", kv[0]) in unmarshal()
140 log::warn!("H265FmtpSdp parse err: {}", raw_data); in unmarshal()
152 log::warn!("H265FmtpSdp parse key=value err: {}", parameter); in unmarshal()
167 log::info!("not parsed: {}", kv[0]) in unmarshal()
198 log::warn!("Mpeg4FmtpSdp parse err: {}", raw_data); in unmarshal()
210 log::warn!("Mpeg4FmtpSdp parse key=value err: {}", parameter); in unmarshal()
240 log::info!("not parsed: {}", kv[0]) in unmarshal()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp.rs | 25 log::info!("Rtsp server listening on tcp://{}", socket_addr); in run()
31 log::error!("session run error, err: {}", err); in run()
|
| H A D | rtsp_track.rs | 71 log::error!("rtp_receive_loop on_packet error: {}", err); in rtp_receive_loop()
75 log::error!("read error: {:?}", err); in rtp_receive_loop()
94 log::error!("read error: {:?}", err); in rtcp_receive_loop()
111 log::info!("it is a udp transport!!!"); in set_transport()
|
| /xiu/application/pprtmp/src/ |
| H A D | main.rs | 59 log::error!("err: {}", err); in main()
74 log::error!("pull_client_session as pull client run error: {}", err); in main()
82 log::error!("err: {}", err); in main()
100 log::error!("push_client_session as push client run error: {}", err); in main()
|
| /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/protocol/rtsp/src/session/ |
| H A D | mod.rs | 88 log::debug!("dollar sign: {}", is_dollar_sign); in new()
92 log::debug!("channel_identifier: {}", channel_identifier); in new()
94 log::debug!("length: {}", length); in new()
257 log::debug!("sdp: {}", sdp); in handle_describe()
304 log::error!("send frame error: {}", err); in handle_announce()
516 log::info!( in handle_play()
538 log::error!("unsubscribe_from_stream_hub err {}", err); in unsubscribe_from_stream_hub()
581 log::info!( in handle_teardown()
599 log::info!("media_name: {}", media_name); in new_tracks()
805 log::error!("send media info error: {}", err); in send_prior_data()
[all …]
|
| /xiu/library/logger/src/ |
| H A D | logger.rs | 206 log::trace!("some trace log"); in test_log()
207 log::debug!("some debug log"); in test_log()
208 log::info!("some information log"); in test_log()
209 log::warn!("some warning log"); in test_log()
210 log::error!("some error log"); in test_log()
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | parser.rs | 62 log::trace!( in parse()
72 log::trace!( in parse()
81 log::trace!( in parse()
125 log::warn!( in parse()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 83 log::info!("write_flv_tag: {}", err_in); in send_media_stream()
87 log::error!("write_flv_tag err: {}", err); in send_media_stream()
114 log::error!("should not be here!!!"); in write_flv_tag()
160 log::error!("unsubscribe_from_channels err {}", err); in unsubscribe_from_rtmp_channels()
|