| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | writer.rs | 125 String::from("flashVer"), in write_connect() 155 String::from("audioCodecs"), in write_connect() 201 String::from("fmsVer"), in write_connect_response() 205 String::from("capabilities"), in write_connect_response() 214 String::from("level"), in write_connect_response() 218 String::from("code"), in write_connect_response() 222 String::from("description"), in write_connect_response() 226 String::from("objectEncoding"), in write_connect_response() 288 String::from("level"), in error() 292 String::from("code"), in error() [all …]
|
| H A D | errors.rs | 25 fn from(error: Amf0WriteError) -> Self { in from() method 33 fn from(error: Amf0ReadError) -> Self { in from() method 41 fn from(error: PackError) -> Self { in from() method
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_reader.rs | 207 Amf0ValueType::UTF8String(String::from("connect")) in test_amf_reader() 216 String::from("app"), in test_amf_reader() 217 Amf0ValueType::UTF8String(String::from("harlan")), in test_amf_reader() 220 String::from("type"), in test_amf_reader() 224 String::from("flashVer"), in test_amf_reader() 228 String::from("swfUrl"), in test_amf_reader() 232 String::from("tcUrl"), in test_amf_reader() 335 Amf0ValueType::UTF8String(String::from("connect")) in test_player_connect_reader() 353 String::from("tcUrl"), in test_player_connect_reader() 358 String::from("app"), in test_player_connect_reader() [all …]
|
| H A D | errors.rs | 27 fn from(error: string::FromUtf8Error) -> Self { in from() method 35 fn from(error: BytesReadError) -> Self { in from() method 58 fn from(error: io::Error) -> Self { in from() method 66 fn from(error: BytesWriteError) -> Self { in from() method
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | errors.rs | 85 fn from(error: Amf0WriteError) -> Self { in from() method 93 fn from(error: BytesWriteError) -> Self { in from() method 109 fn from(error: UnpackError) -> Self { in from() method 117 fn from(error: MessageError) -> Self { in from() method 141 fn from(error: NetStreamError) -> Self { in from() method 157 fn from(error: BytesIOError) -> Self { in from() method 165 fn from(error: PackError) -> Self { in from() method 173 fn from(error: HandshakeError) -> Self { in from() method 181 fn from(error: CacheError) -> Self { in from() method 189 fn from(error: RecvError) -> Self { in from() method [all …]
|
| /xiu/protocol/hls/src/ |
| H A D | errors.rs | 50 fn from(error: SessionError) -> Self { in from() method 58 fn from(error: FlvDemuxerError) -> Self { in from() method 66 fn from(error: MpegTsError) -> Self { in from() method 74 fn from(error: Amf0WriteError) -> Self { in from() method 82 fn from(error: MetadataError) -> Self { in from() method 90 fn from(error: std::io::Error) -> Self { in from() method 141 fn from(error: RecvError) -> Self { in from() method 149 fn from(error: MediaError) -> Self { in from() method 157 fn from(error: SessionError) -> Self { in from() method 181 fn from(error: MetadataError) -> Self { in from() method [all …]
|
| H A D | server.rs | 17 let mut file_path: String = String::from(""); in handle_connection() 27 let app_name = String::from(rv[1]); in handle_connection() 28 let stream_name = String::from(rv[2]); in handle_connection() 41 let app_name = String::from(rv[1]); in handle_connection() 42 let stream_name = String::from(rv[2]); in handle_connection() 43 let ts_name = String::from(rv[3]); in handle_connection()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | errors.rs | 49 fn from(error: RecvError) -> Self { in from() method 57 fn from(error: SessionError) -> Self { in from() method 65 fn from(error: Amf0WriteError) -> Self { in from() method 73 fn from(error: MetadataError) -> Self { in from() method 81 fn from(error: BytesReadError) -> Self { in from() method 89 fn from(error: BytesWriteError) -> Self { in from() method 97 fn from(error: Mpeg4AvcHevcError) -> Self { in from() method 105 fn from(error: FlvMuxerError) -> Self { in from() method 113 fn from(error: ChannelError) -> Self { in from() method 121 fn from(error: OneshotRecvError) -> Self { in from() method
|
| H A D | rtsp2rtmp.rs | 66 (String::from("rtsp"), String::from(eles[0])) in new() 68 (String::from(eles[0]), String::from(eles[1])) in new() 126 request_url: String::from(""), in subscribe_rtsp() 127 remote_addr: String::from(""), in subscribe_rtsp() 156 request_url: String::from(""), in unsubscribe_rtsp() 157 remote_addr: String::from(""), in unsubscribe_rtsp() 344 amf_writer.write_string(&String::from("@setDataFrame"))?; in gen_rtmp_meta_data() 345 amf_writer.write_string(&String::from("onMetaData"))?; in gen_rtmp_meta_data() 348 properties.insert(String::from("width"), Amf0ValueType::Number(width as f64)); in gen_rtmp_meta_data() 350 properties.insert(String::from("videocodecid"), Amf0ValueType::Number(7.)); in gen_rtmp_meta_data() [all …]
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | writer.rs | 50 self.amf0_writer.write_string(&String::from("play"))?; in write_play() 66 .write_string(&String::from("deleteStream"))?; in write_delete_stream() 80 .write_string(&String::from("closeStream"))?; in write_close_stream() 94 .write_string(&String::from("releaseStream"))?; in write_release_stream() 122 .write_string(&String::from("receiveAudio"))?; in write_receive_audio() 136 .write_string(&String::from("receiveVideo"))?; in write_receive_video() 159 self.amf0_writer.write_string(&String::from("seek"))?; in write_seek() 173 self.amf0_writer.write_string(&String::from("pause"))?; in write_pause() 210 String::from("level"), in write_on_status() 214 String::from("code"), in write_on_status() [all …]
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | errors.rs | 44 fn from(error: BytesIOError) -> Self { in from() method 52 fn from(error: BytesReadError) -> Self { in from() method 60 fn from(error: BytesWriteError) -> Self { in from() method 68 fn from(error: Utf8Error) -> Self { in from() method 76 fn from(error: PackerError) -> Self { in from() method 84 fn from(error: UnPackerError) -> Self { in from() method 92 fn from(error: ChannelError) -> Self { in from() method 100 fn from(error: RecvError) -> Self { in from() method
|
| /xiu/protocol/httpflv/src/ |
| H A D | errors.rs | 52 fn from(error: SessionError) -> Self { in from() method 60 fn from(error: FlvMuxerError) -> Self { in from() method 68 fn from(error: SendError) -> Self { in from() method 76 fn from(error: Amf0WriteError) -> Self { in from() method 84 fn from(error: MetadataError) -> Self { in from() method 92 fn from(error: ChannelError) -> Self { in from() method 100 fn from(error: RecvError) -> Self { in from() method
|
| /xiu/library/container/flv/src/ |
| H A D | errors.rs | 24 fn from(error: BytesReadError) -> Self { in from() method 60 fn from(error: BytesWriteError) -> Self { in from() method 103 fn from(error: BytesWriteError) -> Self { in from() method 111 fn from(error: BytesReadError) -> Self { in from() method 127 fn from(error: MpegAacError) -> Self { in from() method 173 fn from(error: BytesReadError) -> Self { in from() method 181 fn from(error: BytesWriteError) -> Self { in from() method 189 fn from(error: H264Error) -> Self { in from() method 218 fn from(error: BytesReadError) -> Self { in from() method 226 fn from(error: BytesWriteError) -> Self { in from() method [all …]
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | errors.rs | 37 fn from(error: FlvDemuxerError) -> Self { in from() method 45 fn from(error: H264Error) -> Self { in from() method 53 fn from(error: MpegAacError) -> Self { in from() method 61 fn from(error: Mpeg4AvcHevcError) -> Self { in from() method 69 fn from(error: BytesReadError) -> Self { in from() method 77 fn from(error: PackError) -> Self { in from() method 109 fn from(error: Amf0WriteError) -> Self { in from() method
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | errors.rs | 26 fn from(error: Error) -> Self { in from() method 39 fn from(val: HandshakeErrorValue) -> Self { in from() method 45 fn from(error: BytesReadError) -> Self { in from() method 53 fn from(error: BytesWriteError) -> Self { in from() method 61 fn from(error: SystemTimeError) -> Self { in from() method 69 fn from(error: DigestError) -> Self { in from() method 110 fn from(error: BytesReadError) -> Self { in from() method
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | errors.rs | 50 fn from(error: RTCError) -> Self { in from() method 58 fn from(error: BytesIOError) -> Self { in from() method 66 fn from(error: BytesReadError) -> Self { in from() method 74 fn from(error: BytesWriteError) -> Self { in from() method 82 fn from(error: Utf8Error) -> Self { in from() method 90 fn from(error: ChannelError) -> Self { in from() method 98 fn from(error: RecvError) -> Self { in from() method
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | errors.rs | 34 fn from(val: MessageErrorValue) -> Self { in from() method 40 fn from(error: BytesReadError) -> Self { in from() method 48 fn from(error: Amf0ReadError) -> Self { in from() method 56 fn from(error: ProtocolControlMessageReaderError) -> Self { in from() method 64 fn from(error: EventMessagesError) -> Self { in from() method
|
| /xiu/library/bytesio/src/ |
| H A D | bytes_errors.rs | 30 fn from(val: BytesReadErrorValue) -> Self { in from() method 36 fn from(error: io::Error) -> Self { in from() method 44 fn from(error: BytesIOError) -> Self { in from() method 77 fn from(error: io::Error) -> Self { in from() method 85 fn from(error: BytesIOError) -> Self { in from() method
|
| H A D | bits_errors.rs | 25 fn from(val: BitErrorValue) -> Self { in from() method 31 fn from(error: BytesReadError) -> Self { in from() method 39 fn from(error: BytesWriteError) -> Self { in from() method
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | errors.rs | 39 fn from(error: BytesReadError) -> Self { in from() method 47 fn from(error: BytesWriteError) -> Self { in from() method 68 fn from(error: BytesReadError) -> Self { in from() method 76 fn from(error: BytesWriteError) -> Self { in from() method
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | errors.rs | 26 fn from(val: UnpackErrorValue) -> Self { in from() method 32 fn from(error: BytesReadError) -> Self { in from() method 55 fn from(val: PackErrorValue) -> Self { in from() method 61 fn from(error: BytesWriteError) -> Self { in from() method
|
| /xiu/protocol/rtmp/src/user_control_messages/ |
| H A D | errors.rs | 26 fn from(error: Amf0WriteError) -> Self { in from() method 34 fn from(error: BytesWriteError) -> Self { in from() method 42 fn from(error: BytesReadError) -> Self { in from() method
|
| /xiu/library/container/mpegts/src/ |
| H A D | errors.rs | 37 fn from(error: BytesReadError) -> Self { in from() method 45 fn from(error: BytesWriteError) -> Self { in from() method 53 fn from(error: Error) -> Self { in from() method
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_transport.rs | 121 String::from("") in marshal() 127 String::from("") in marshal() 133 String::from("") in marshal() 139 String::from("") in marshal() 145 String::from("") in marshal()
|
| /xiu/protocol/rtsp/src/rtp/rtcp/ |
| H A D | errors.rs | 19 fn from(error: BytesReadError) -> Self { in from() method 27 fn from(error: BytesWriteError) -> Self { in from() method
|