Home
last modified time | relevance | path

Searched refs:Err (Results 1 – 25 of 51) sorted by relevance

123

/xiu/library/bytesio/src/
H A Dbytesio.rs41 if let Err(err) = local_socket.connect(remote_socket_addr).await { in new()
76 Err(err) => Err(BytesIOError { in read_timeout()
121 Err(err) => Err(BytesIOError { in read_timeout()
133 Err(err) => Err(BytesIOError { in read()
137 None => Err(BytesIOError { in read()
H A Dbytes_writer.rs36 return Err(BytesWriteError { in or_u8_at()
47 return Err(BytesWriteError { in add_u8_at()
58 return Err(BytesWriteError { in write_u8_at()
223 Err(_) => { in flush_timeout()
224 return Err(BytesWriteError { in flush_timeout()
/xiu/library/streamhub/src/
H A Dlib.rs397 Err(err) => { in event_loop()
399 Err(err) in event_loop()
475 Err(err) => { in event_loop()
477 Err(err) in event_loop()
544 return Err(ChannelError { in api_statistic()
552 return Err(ChannelError { in api_statistic()
627 Err(ChannelError { in subscribe()
646 return Err(ChannelError { in unsubscribe()
663 return Err(ChannelError { in publish()
673 if let Err(err) = transmitter.run().await { in publish()
[all …]
/xiu/library/streamhub/src/notify/
H A Dmod.rs34 Err(err) => { in on_publish_notify()
53 Err(err) => { in on_unpublish_notify()
72 Err(err) => { in on_play_notify()
91 Err(err) => { in on_stop_notify()
/xiu/library/logger/src/
H A Dlogger.rs29 type Err = (); typedef
30 fn from_str(input: &str) -> Result<Rotate, Self::Err> { in from_str() argument
35 _ => Err(()), in from_str()
120 Err(err) => { in gen_log_file_thread_run()
157 if let Err(err) = fs::create_dir_all(path_val.clone()) { in new()
178 if let Err(err) = sender.send(true) { in stop()
222 if let Err(err) = file.write_all(&[b'h', b'e', b'l', b'l', b'o', b'o']) { in test_write_file()
226 Err(err) => { in test_write_file()
/xiu/application/xiu/src/
H A Dapi.rs43 if let Err(err) = self.channel_event_producer.send(hub_event) { in get_stream_status()
61 Err(err) => { in get_stream_status()
79 if let Err(err) = self.channel_event_producer.send(hub_event) { in kick_off_client()
100 Err(_) => "error".to_owned(), in run()
108 Err(_) => "error".to_owned(), in run()
H A Dservice.rs113 if let Err(err) = push_client.run().await { in start_rtmp()
137 if let Err(err) = pull_client.run().await { in start_rtmp()
151 if let Err(err) = rtmp_server.run().await { in start_rtmp()
188 if let Err(err) = remuxer.run().await { in start_rtmp_remuxer()
210 if let Err(err) = rtsp_server.run().await { in start_rtsp()
234 if let Err(err) = webrtc_server.run().await { in start_webrtc()
254 if let Err(err) = httpflv_server::run(event_producer, port).await { in start_httpflv()
280 if let Err(err) = hls_remuxer.run().await { in start_hls()
288 if let Err(err) = hls_server::run(port).await { in start_hls()
/xiu/protocol/rtmp/src/session/
H A Dcommon.rs180 Err(err) => { in on_video_data()
182 return Err(SessionError { in on_video_data()
207 Err(err) => { in on_audio_data()
209 return Err(SessionError { in on_audio_data()
234 Err(_) => { in on_meta_data()
235 return Err(SessionError { in on_meta_data()
323 return Err(SessionError { in subscribe_from_channels()
380 return Err(SessionError { in publish_to_channels()
410 Err(_) => { in unpublish_to_channels()
416 return Err(SessionError { in unpublish_to_channels()
[all …]
H A Dserver_session.rs162 Err(err) => { in read_parse_chunks()
171 return Err(SessionError { in read_parse_chunks()
197 Err(err) => { in read_parse_chunks()
206 return Err(err)?; in read_parse_chunks()
218 Err(err) => { in play()
226 return Err(err); in play()
454 return Err(SessionError { in on_connect()
672 return Err(SessionError { in on_publish()
680 return Err(SessionError { in on_publish()
696 return Err(SessionError { in on_publish()
/xiu/application/pprtmp/src/
H A Dmain.rs58 if let Err(err) = pull_parser.parse_url() { in main()
73 if let Err(err) = pull_client_session.run().await { in main()
81 if let Err(err) = push_parser.parse_url() { in main()
99 if let Err(err) = push_client_session.run().await { in main()
/xiu/protocol/webrtc/src/session/
H A Dmod.rs128 return Err(SessionError { in run()
144 return Err(SessionError { in run()
173 return Err(SessionError { in run()
222 return Err(SessionError { in run()
266 return Err(SessionError { in publish_whip()
288 Err(err) => { in publish_whip()
313 return Err(SessionError { in unpublish_whip()
342 return Err(SessionError { in subscribe_whep()
372 if let Err(err) = Self::unsubscribe_whep( in subscribe_whep()
402 Err(err) => { in subscribe_whep()
[all …]
/xiu/protocol/webrtc/src/
H A Dwhep.rs130 if let Err(err) = state_sender.send(s) { in handle_whep()
162 if let Err(err) = video_track.write(&data[..]).await { in handle_whep()
167 if let Err(err) = audio_track.write(&data[..]).await { in handle_whep()
189 Err(WebRTCError { in handle_whep()
H A Dwhip.rs130 if let Err(err) = sender_clone.send(video_packet) { in handle_whip()
140 if let Err(err) = sender_clone.send(audio_packet) { in handle_whip()
203 Err(WebRTCError { in handle_whip()
/xiu/protocol/rtsp/src/session/
H A Dmod.rs242 return Err(SessionError { in handle_describe()
290 return Err(SessionError { in handle_announce()
303 if let Err(err) = sender_out.send(msg) { in handle_announce()
475 return Err(SessionError { in handle_play()
522 return Err(SessionError { in handle_play()
537 if let Err(err) = self.event_producer.send(subscribe_event) { in unsubscribe_from_stream_hub()
574 Err(_) => { in handle_teardown()
576 Err(SessionError { in handle_teardown()
731 return Err(ChannelError { in send_prior_data()
797 if let Err(err) = sender.send(FrameData::MediaInfo { in send_prior_data()
[all …]
/xiu/protocol/rtsp/src/
H A Drtsp_track.rs70 if let Err(err) = rtp_channel_in.on_packet(&mut reader) { in rtp_receive_loop()
74 Err(err) => { in rtp_receive_loop()
93 Err(err) => { in rtcp_receive_loop()
H A Drtsp.rs30 if let Err(err) = session.run().await { in run()
/xiu/protocol/rtmp/src/handshake/
H A Ddigest.rs77 return Err(DigestError { in find_digest_offset()
116 return Err(DigestError { in make_digest()
137 Err(DigestError { in generate_and_validate()
/xiu/protocol/rtmp/
H A DREADME.md30 if let Err(err) = rtmp_server.run().await {
71 if let Err(err) = push_client.run().await {
87 if let Err(err) = pull_client.run().await {
99 if let Err(err) = rtmp_server.run().await {
/xiu/protocol/httpflv/src/
H A Dhttpflv.rs80 if let Err(err) = self.write_flv_tag(data) { in send_media_stream()
159 if let Err(err) = self.event_producer.send(subscribe_event) { in unsubscribe_from_rtmp_channels()
195 return Err(HttpFLvError { in subscribe_from_rtmp_channels()
/xiu/protocol/rtmp/src/utils/
H A Dmod.rs48 return Err(RtmpUrlParseError { in parse_url()
60 return Err(RtmpUrlParseError { in parse_url()
/xiu/protocol/rtmp/src/remuxer/
H A Dmod.rs37 if let Err(err) = session.run().await { in run()
/xiu/protocol/hls/src/
H A Dremuxer.rs47 if let Err(err) = rtmp_subscriber.run().await { in run()
/xiu/protocol/rtmp/src/
H A Drtmp.rs38 if let Err(err) = session.run().await { in run()
/xiu/library/container/mpegts/src/
H A Dts.rs351 Err(MpegTsError { in find_stream()
373 return Err(MpegTsError { in pmt_add_stream()
407 return Err(MpegTsError { in add_program()
414 return Err(MpegTsError { in add_program()
/xiu/protocol/rtmp/src/relay/
H A Dpull_client.rs60 if let Err(err) = client_session.run().await { in run()

123