Home
last modified time | relevance | path

Searched refs:Ok (Results 1 – 25 of 86) sorted by relevance

1234

/xiu/protocol/rtmp/src/messages/
H A Dparser.rs47 Ok(val) => val, in parse()
53 return Ok(Some(RtmpMessageData::Amf0Command { in parse()
67 return Ok(Some(RtmpMessageData::AudioData { in parse()
76 return Ok(Some(RtmpMessageData::VideoData { in parse()
86 return Ok(Some(data)); in parse()
90 return Ok(Some(RtmpMessageData::SetChunkSize { chunk_size })); in parse()
95 return Ok(Some(RtmpMessageData::AbortMessage { chunk_stream_id })); in parse()
110 return Ok(Some(RtmpMessageData::SetPeerBandwidth { properties })); in parse()
114 return Ok(Some(RtmpMessageData::AmfData { in parse()
129 Ok(None) in parse()
[all …]
/xiu/protocol/rtmp/src/handshake/
H A Dhandshake_client.rs39 Ok(()) in flush()
72 Ok(()) in handshake()
79 Ok(()) in write_c0()
87 Ok(()) in write_c1()
91 Ok(()) in write_c2()
96 Ok(()) in read_s0()
100 Ok(()) in read_s1()
104 Ok(()) in read_s2()
H A Dhandshake_server.rs82 Ok(()) in handshake()
136 Ok(()) in handshake()
143 Ok(()) in read_c0()
153 Ok(()) in read_c1()
158 Ok(()) in read_c2()
163 Ok(()) in write_s0()
174 Ok(()) in write_s1()
180 Ok(()) in write_s2()
187 Ok(()) in read_c0()
205 Ok(()) in read_c1()
[all …]
H A Ddigest.rs28 if let Ok(digest) = self.generate_and_validate(SchemaVersion::Schema0) { in read_digest()
29 return Ok((digest, SchemaVersion::Schema0)); in read_digest()
33 Ok((digest, SchemaVersion::Schema1)) in read_digest()
43 Ok(result) in generate_and_fill_digest()
51 Ok(digest) in generate_digest()
83 Ok(digest_offset) in find_digest_offset()
108 Ok((left_part, digest_data, right_part)) in cook_raw_message()
124 Ok(rv) in make_digest()
134 return Ok(digest_data); in generate_and_validate()
/xiu/protocol/rtmp/src/protocol_control_messages/
H A Dreader.rs17 Ok(chunk_size) in read_set_chunk_size()
22 Ok(chunk_stream_id) in read_abort_message()
27 Ok(sequence_number) in read_acknowledgement()
34 Ok(window_acknowledgement_size) in read_window_acknowledgement_size()
43 Ok(SetPeerBandwidthProperties::new(window_size, limit_type)) in read_set_peer_bandwidth()
H A Dwriter.rs31 Ok(()) in write_control_message_header()
42 Ok(()) in write_set_chunk_size()
53 Ok(()) in write_abort_message()
64 Ok(()) in write_acknowledgement()
75 Ok(()) in write_window_acknowledgement_size()
89 Ok(()) in write_set_peer_bandwidth()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_writer.rs25 Ok(()) in write_anys()
35 _ => Ok(()), in write_any()
42 Ok(()) in write_number()
48 Ok(()) in write_bool()
62 Ok(()) in write_string()
67 Ok(()) in write_null()
73 Ok(()) in write_object_eof()
89 Ok(()) in write_object()
107 Ok(()) in write_eacm_array()
H A Damf0_reader.rs31 Ok(results) in read_all()
35 return Ok(Amf0ValueType::END); in read_any()
40 return Ok(Amf0ValueType::END); in read_any()
71 Ok(value) in read_number()
89 Ok(val) in read_raw_string()
98 Ok(Amf0ValueType::Null) in read_null()
105 return Ok(true); in is_read_object_eof()
107 Ok(false) in is_read_object_eof()
126 Ok(Amf0ValueType::Object(properties)) in read_object()
146 Ok(Amf0ValueType::Object(properties)) in read_ecma_array()
[all …]
/xiu/protocol/rtmp/src/user_control_messages/
H A Dwriter.rs30 Ok(()) in write_control_message_header()
40 Ok(()) in write_stream_begin()
51 Ok(()) in write_stream_eof()
62 Ok(()) in write_stream_dry()
78 Ok(()) in write_set_buffer_length()
92 Ok(()) in write_stream_is_record()
103 Ok(()) in write_ping_request()
114 Ok(()) in write_ping_response()
H A Dreader.rs47 Ok(message_define::RtmpMessageData::SetBufferLength { in read_set_buffer_length()
58 Ok(message_define::RtmpMessageData::StreamBegin { in read_stream_begin()
68 Ok(message_define::RtmpMessageData::StreamIsRecorded { in read_stream_is_recorded()
/xiu/library/bytesio/src/
H A Dbytes_writer.rs31 Ok(()) in write_u8()
42 Ok(()) in or_u8_at()
53 Ok(()) in add_u8_at()
64 Ok(()) in write_u8_at()
73 Ok(()) in write_u16()
79 Ok(()) in write_u24()
84 Ok(()) in write_u32()
89 Ok(()) in write_f64()
94 Ok(()) in write_u64()
99 Ok(()) in write()
[all …]
H A Dbytesio.rs39 if let Ok(local_socket) = UdpSocket::bind(local_address).await { in new()
40 if let Ok(remote_socket_addr) = remote_address.parse::<SocketAddr>() { in new()
53 if let Ok(local_addr) = self.socket.local_addr() { in get_local_port()
70 Ok(()) in write()
75 Ok(data) => data, in read_timeout()
88 Ok(rv) in read()
115 Ok(()) in write()
120 Ok(data) => data, in read_timeout()
132 Ok(bytes) => Ok(bytes), in read()
H A Dbytes_reader.rs58 Ok(tmp_cursor) in read_bytes_cursor()
67 Ok(tmp_cursor) in advance_bytes_cursor()
73 Ok(cursor.read_u8()?) in read_u8()
84 Ok(val) in read_u16()
90 Ok(val) in read_u24()
102 Ok(val) in read_u32()
109 Ok(val) in read_u48()
116 Ok(val) in read_f64()
123 Ok(val) in read_u64()
170 Ok(()) in read()
[all …]
H A Dbits_writer.rs26 Ok(()) in write_bytes()
39 Ok(()) in write_bit()
50 Ok(()) in write_8bit()
62 Ok(()) in flush()
89 return Ok(()); in write_n_bits()
106 Ok(()) in write_n_bits()
112 Ok(()) in bits_aligment_8()
/xiu/application/xiu/src/
H A Dapi.rs48 Ok(size) => { in get_stream_status()
50 return Ok(String::from("no stream data")); in get_stream_status()
66 if let Ok(data) = serde_json::to_string(&data) { in get_stream_status()
67 return Ok(data); in get_stream_status()
70 Ok(String::from("")) in get_stream_status()
84 Ok(String::from("ok")) in kick_off_client()
99 Ok(response) => response, in run()
107 Ok(response) => response, in run()
H A Dservice.rs60 Ok(()) in run()
75 Ok(()) in start_http_api_server()
83 return Ok(()); in start_rtmp()
157 Ok(()) in start_rtmp()
169 return Ok(()); in start_rtmp_remuxer()
179 return Ok(()); in start_rtmp_remuxer()
192 Ok(()) in start_rtmp_remuxer()
216 Ok(()) in start_rtsp()
240 Ok(()) in start_webrtc()
260 Ok(()) in start_httpflv()
[all …]
/xiu/library/container/flv/src/
H A Ddemuxer.rs139 return Ok(None); in demux()
152 return Ok(Some(video_data)); in demux()
158 Ok(None) in demux()
189 return Ok(FlvDemuxerAudioData::new()); in demux()
202 return Ok(audio_data); in demux()
208 Ok(FlvDemuxerAudioData::new()) in demux()
226 Ok(()) in read_flv_header()
251 return Ok(Some(FlvData::Video { in read_flv_tag()
257 return Ok(Some(FlvData::Audio { in read_flv_tag()
266 Ok(None) in read_flv_tag()
H A Dmuxer.rs34 Ok(()) in write_flv_header()
55 Ok(()) in write_flv_tag_header()
60 Ok(()) in write_flv_tag_body()
65 Ok(()) in write_previous_tag_size()
/xiu/library/logger/src/
H A Dtarget.rs13 Ok(Self { in new()
22 Ok(rv) => Ok(rv), in write()
25 Ok(0) in write()
H A Dlogger.rs32 "day" => Ok(Rotate::Day), in from_str()
33 "hour" => Ok(Rotate::Hour), in from_str()
34 "minute" => Ok(Rotate::Minute), in from_str()
79 Ok(File::create(full_path)?) in gen_log_file()
83 Ok(file) in gen_log_file()
116 Ok(file) => { in gen_log_file_thread_run()
144 return Ok(Self { in new()
172 Ok(Self { in new()
221 Ok(mut file) => { in test_write_file()
/xiu/protocol/rtmp/src/session/
H A Dclient_session.rs228 Ok(()) in handshake()
278 Ok(()) in process_messages()
336 Ok(()) in on_amf0_command_message()
374 Ok(()) in send_connect()
381 Ok(()) in send_create_stream()
394 Ok(()) in send_delete_stream()
408 Ok(()) in send_publish()
431 Ok(()) in send_play()
438 Ok(()) in send_set_chunk_size()
450 Ok(()) in send_window_acknowledgement_size()
[all …]
H A Dcommon.rs125 Ok(()) in send_audio()
143 Ok(()) in send_video()
165 Ok(()) in send_metadata()
192 Ok(()) in on_video_data()
219 Ok(()) in on_audio_data()
243 Ok(()) in on_meta_data()
331 Ok(()) in subscribe_from_channels()
353 Ok(()) in unsubscribe_from_channels()
387 Ok(()) in publish_to_channels()
428 Ok(()) in unpublish_to_channels()
[all …]
/xiu/protocol/hls/src/
H A Dflv2hls.rs77 return Ok(()); in process_flv_data()
80 _ => return Ok(()), in process_flv_data()
85 Ok(()) in process_flv_data()
102 Ok(()) in flush_remaining_data()
133 return Ok(()); in process_demux_data()
141 _ => return Ok(()), in process_demux_data()
167 Ok(()) in process_demux_data()
H A Dserver.rs63 if let Ok(file) = File::open(filename).await { in simple_file_send()
66 return Ok(Response::new(body)); in simple_file_send()
69 Ok(not_found()) in simple_file_send()
77 make_service_fn(move |_| async { Ok::<_, GenericError>(service_fn(handle_connection)) }); in run()
83 Ok(()) in run()
/xiu/library/streamhub/src/notify/
H A Dmod.rs37 Ok(response) => { in on_publish_notify()
56 Ok(response) => { in on_unpublish_notify()
75 Ok(response) => { in on_play_notify()
94 Ok(response) => { in on_stop_notify()

1234