Functions — github.com/KallDrexx/rust-media-libs

hub / github.com/KallDrexx/rust-media-libs / functions

Functions487 in github.com/KallDrexx/rust-media-libs

Turns an RTMP message payload into binary data (representing RTMP chunks) that can be sent over the network. The RTMP chunk format has a basic form o

rtmp/src/chunk_io/serializer.rs:91

↓ 82 callersMethodinto_message_payload

( self, timestamp: RtmpTimestamp, message_stream_id: u32, )

rtmp/src/messages/mod.rs:132

↓ 46 callersMethodget_next_message

Attempts to read a complete RTMP message from the passed in bytes. It is normal that one set of bytes will not form a complete RTMP message (or even

rtmp/src/chunk_io/deserializer.rs:147

↓ 39 callersFunctionsplit_results

( deserializer: &mut ChunkDeserializer, mut results: Vec<ClientSessionResult>, )

rtmp/src/sessions/client/tests.rs:1581

↓ 37 callersMethodhandle_input

Takes in any number of bytes from the peer and processes them. Any resulting responses or events are returned.

rtmp/src/sessions/client/mod.rs:97

↓ 32 callersFunctionsplit_results

( deserializer: &mut ChunkDeserializer, mut results: Vec<ServerSessionResult>, )

rtmp/src/sessions/server/tests.rs:1574

↓ 31 callersFunctionconsume_results

(deserializer: &mut ChunkDeserializer, results: Vec<ClientSessionResult>)

rtmp/src/sessions/client/tests.rs:1621

↓ 27 callersMethodhandle_input

Takes in bytes that are encoding RTMP chunks and returns any responses or events that can be reacted to.

rtmp/src/sessions/server/mod.rs:146

↓ 25 callersMethodread

(&mut self)

examples/threaded_rtmp_server/src/connection.rs:62

↓ 23 callersMethodto_rtmp_message

Deserializes the message data in the specified payload into its corresponding `RtmpMessage`. Note that flash clients (like Wowza's test client) lie a

rtmp/src/messages/message_payload.rs:47

↓ 22 callersFunctioncommon_basic_setup

()

rtmp/src/sessions/server/tests.rs:1570

↓ 21 callersFunctionperform_connection

( app_name: &str, session: &mut ServerSession, serializer: &mut ChunkSerializer, deserializer:

rtmp/src/sessions/server/tests.rs:1642

↓ 21 callersFunctionsend

Sends a message over an unbounded receiver and returns true if the message was sent or false if the channel has been closed.

examples/tokio_rtmp_server/src/main.rs:47

↓ 20 callersMethodaccept_request

Tells the server session that it should accept an outstanding request

rtmp/src/sessions/server/mod.rs:246

↓ 19 callersMethodget_epoch

(&self)

rtmp/src/sessions/server/mod.rs:1350

↓ 18 callersFunctionperform_successful_connect

( app_name: String, session: &mut ClientSession, serializer: &mut ChunkSerializer, deserialize

rtmp/src/sessions/client/tests.rs:1773

↓ 15 callersFunctioncreate_active_stream

( session: &mut ServerSession, serializer: &mut ChunkSerializer, deserializer: &mut ChunkDeseriali

rtmp/src/sessions/server/tests.rs:1673

↓ 15 callersMethodprocess_bytes

Processes the passed in bytes as part of the handshake process. If not enough bytes were received to complete the next handshake step then the handsh

rtmp/src/handshake/mod.rs:220

↓ 14 callersFunctiondeserialize

(data: Bytes)

rtmp/src/messages/types/abort.rs:16

↓ 14 callersMethodget_epoch

(&self)

rtmp/src/sessions/client/mod.rs:940

↓ 13 callersFunctionform_type_0_chunk

( csid: u32, timestamp: u32, message_stream_id: u32, type_id: u8, payl

rtmp/src/chunk_io/deserializer.rs:1004

↓ 11 callersMethodcleanup_connection

(&mut self, connection_id: i32)

examples/tokio_rtmp_server/src/stream_manager/mod.rs:60

↓ 11 callersFunctionserialize

(stream_id: u32)

rtmp/src/messages/types/abort.rs:8

↓ 11 callersMethodwrite

(&self, bytes: Vec<u8>)

examples/threaded_rtmp_server/src/connection.rs:58

↓ 10 callersMethodcreate_error_packet

( &mut self, code: &str, description: &str, transaction_id: f64, strea

rtmp/src/sessions/server/mod.rs:1365

↓ 10 callersMethodregister

(&mut self, poll: &mut Poll)

examples/mio_rtmp_server/src/connection.rs:258

↓ 10 callersMethodrequest_connection

Forms an RTMP message requesting a connection to the specified application on the server. An event will be raised when the request is accepted or reje

rtmp/src/sessions/client/mod.rs:186

↓ 10 callersMethodset_max_chunk_size

Changes the maximum amount of bytes from RTMP messages that can be in a single RTMP chunk. Changing the maximum chunk size requires notifying the rec

rtmp/src/chunk_io/serializer.rs:52

↓ 9 callersFunctiondeserialize

Turns any readable byte stream and converts it into an array of AMF0 values

amf0/src/deserialization.rs:18

↓ 9 callersFunctiondeserialize

(data: Bytes)

rtmp/src/messages/types/user_control.rs:34

↓ 9 callersMethodget_number

(self)

amf0/src/lib.rs:59

↓ 9 callersFunctionserialize

Serializes values into an amf0 encoded vector of bytes

amf0/src/serialization.rs:12

↓ 9 callersFunctionserialize

( event_type: UserControlEventType, stream_id: Option<u32>, buffer_length: Option<u32>, timest

rtmp/src/messages/types/user_control.rs:9

↓ 8 callersMethodsend_video_data

Prepare video data to be sent to the client

rtmp/src/sessions/server/mod.rs:363

↓ 8 callersFunctionspawn

(future: F)

examples/tokio_rtmp_server/src/main.rs:33

↓ 7 callersFunctionconsume_results

(deserializer: &mut ChunkDeserializer, results: Vec<ServerSessionResult>)

rtmp/src/sessions/server/tests.rs:1612

↓ 7 callersMethodgenerate_outbound_p0_and_p1

Creates the packets 0 and 1 that should get sent to the peer. This is only strictly required to be called by the client in the connection process to

rtmp/src/handshake/mod.rs:170

↓ 6 callersFunctioncreate_status_object

(level: &str, code: &str, description: &str)

rtmp/src/sessions/server/mod.rs:1383

↓ 6 callersFunctionget_create_stream_success_response

( transaction_id: f64, serializer: &mut ChunkSerializer, )

rtmp/src/sessions/client/tests.rs:1698

↓ 6 callersMethodhandle_push_session_results

( &mut self, session_results: Vec<ClientSessionResult>, server_results: &mut Vec<Serve

examples/mio_rtmp_server/src/server.rs:1056

↓ 6 callersMethodsend_audio_data

Prepare audio data to be sent to the client

rtmp/src/sessions/server/mod.rs:377

↓ 6 callersMethodsend_metadata

Prepares metadata information to be sent to the client

rtmp/src/sessions/server/mod.rs:298

↓ 6 callersFunctionstart_playing

( stream_key: &str, stream_id: u32, session: &mut ServerSession, serializer: &mut ChunkSeriali

rtmp/src/sessions/server/tests.rs:1788

↓ 6 callersFunctionstart_publishing

( stream_key: &str, stream_id: u32, session: &mut ServerSession, serializer: &mut ChunkSeriali

rtmp/src/sessions/server/tests.rs:1746

↓ 6 callersFunctionwrite_stream_event

( bytes: &mut W, event_id: u16, stream_id: Option<u32>, )

rtmp/src/messages/types/user_control.rs:82

↓ 5 callersFunctionform_type_1_chunk

(csid: u32, delta: u32, type_id: u8, payload: &[u8])

rtmp/src/chunk_io/deserializer.rs:1059

↓ 5 callersFunctionget_basic_config

()

rtmp/src/sessions/server/tests.rs:1550

↓ 5 callersMethodhandle_server_session_results

( &mut self, executed_connection_id: usize, session_results: Vec<ServerSessionResult>,

examples/mio_rtmp_server/src/server.rs:325

↓ 5 callersMethodhandle_session_results

( &mut self, executed_connection_id: usize, session_results: Vec<ServerSessionResult>,

examples/threaded_rtmp_server/src/server.rs:139

↓ 5 callersFunctionperform_successful_play_request

( config: ClientSessionConfig, session: &mut ClientSession, serializer: &mut ChunkSerializer,

rtmp/src/sessions/client/tests.rs:1796

↓ 5 callersMethodrequest_playback

Starts the process of requesting playback on the server for the specified stream key. An event will be raised when the request is accepted or rejecte

rtmp/src/sessions/client/mod.rs:236

↓ 4 callersFunctioncalc_hmac

(input: &[u8], key: &[u8])

rtmp/src/handshake/mod.rs:490

↓ 4 callersFunctioncalc_hmac_from_parts

(part1: &[u8], part2: &[u8], key: &[u8])

rtmp/src/handshake/mod.rs:477

↓ 4 callersFunctioncompare

(value1: &u32, value2: &u32)

rtmp/src/time.rs:166

↓ 4 callersFunctioncreate_connect_message

( app_name: String, timestamp: u32, stream_id: u32, object_encoding: f64, )

rtmp/src/sessions/server/tests.rs:1617

↓ 4 callersFunctionform_type_2_chunk

(csid: u32, delta: u32, payload: &[u8])

rtmp/src/chunk_io/deserializer.rs:1085

↓ 4 callersFunctionget_client_digest_offset

(data: &[u8; RTMP_PACKET_SIZE])

rtmp/src/handshake/mod.rs:451

↓ 4 callersFunctionget_connect_success_response

(serializer: &mut ChunkSerializer)

rtmp/src/sessions/client/tests.rs:1626

↓ 4 callersFunctionget_server_digest_offset

(data: &[u8; RTMP_PACKET_SIZE])

rtmp/src/handshake/mod.rs:444

↓ 4 callersFunctionperform_successful_publish_request

( session: &mut ClientSession, serializer: &mut ChunkSerializer, deserializer: &mut ChunkDeseriali

rtmp/src/sessions/client/tests.rs:1922

↓ 4 callersMethodset_max_chunk_size

Tells the deserializer that the peer will start sending RTMP chunks with a different max chunk size. When an RTMP message is larger than the current

rtmp/src/chunk_io/deserializer.rs:183

↓ 4 callersFunctionverify_is_onstatus

(subject: &RtmpMessage, expected_status: &str, expected_code: &str)

rtmp/src/sessions/server/tests.rs:1833

↓ 3 callersFunctioncommon_setup

( config: &ServerSessionConfig, )

rtmp/src/sessions/server/tests.rs:1560

↓ 3 callersFunctiondeserialize

(data: Bytes)

rtmp/src/messages/types/set_peer_bandwidth.rs:26

↓ 3 callersFunctionfill_with_random_data

(buffer: &mut [u8])

rtmp/src/handshake/mod.rs:512

↓ 3 callersFunctionform_type_3_chunk

( csid: u32, payload: &[u8], max_chunk_length: usize, option_extended_timestam

rtmp/src/chunk_io/deserializer.rs:1109

↓ 3 callersMethodget_active_stream_id

(&self)

examples/threaded_rtmp_server/src/server.rs:31

↓ 3 callersFunctionget_message_parts

( handshake: &[u8; RTMP_PACKET_SIZE], digest_offset: u32, )

rtmp/src/handshake/mod.rs:458

↓ 3 callersMethodget_next_transaction_id

(&mut self)

rtmp/src/sessions/client/mod.rs:955

↓ 3 callersMethodhandle_audio_video_data_received

( &mut self, stream_key: String, timestamp: RtmpTimestamp, data: Bytes,

examples/mio_rtmp_server/src/server.rs:760

↓ 3 callersMethodpublish_audio_data

If publishing, this allows us to send audio data to the server on the publishing stream.

rtmp/src/sessions/client/mod.rs:492

↓ 3 callersMethodpublish_video_data

If publishing, this allows us to send video data to the server on the publishing stream.

rtmp/src/sessions/client/mod.rs:463

↓ 3 callersFunctionread_next_value

(bytes: &mut R)

amf0/src/deserialization.rs:31

↓ 3 callersMethodrequest_publishing

Starts the process of requesting to publish to the server on the specified stream key. An event will be raised when the request is accepted or reject

rtmp/src/sessions/client/mod.rs:272

↓ 3 callersFunctionserialize

( limit_type: PeerBandwidthLimitType, size: u32, )

rtmp/src/messages/types/set_peer_bandwidth.rs:8

↓ 3 callersFunctionserialize_value

(value: &Amf0Value, bytes: &mut Vec<u8>)

amf0/src/serialization.rs:21

↓ 3 callersMethodset

Sets the timestamp to a new time value

rtmp/src/time.rs:77

↓ 2 callersFunctionadd_values

(value1: u32, value2: u32)

rtmp/src/time.rs:158

↓ 2 callersMethodapply_metadata_values

Iterates through the passed in hashmap and uses their values to set the metadata properties. The keys are based on standard metadata property names se

rtmp/src/sessions/mod.rs:73

↓ 2 callersMethodcmp

(&self, other: &Self)

rtmp/src/time.rs:123

↓ 2 callersFunctioncreate_active_stream

(session: &mut ServerSession, serializer: &mut ChunkSerializer)

benchmarks/video-relay/src/main.rs:165

↓ 2 callersMethodcreate_error_response

( &mut self, transaction_id: f64, command_object: Amf0Value, additional_argume

rtmp/src/sessions/server/mod.rs:1331

↓ 2 callersFunctioncreate_player_session

()

benchmarks/video-relay/src/main.rs:101

↓ 2 callersFunctiondeserialize

(data: Bytes)

rtmp/src/messages/types/amf0_data.rs:15

↓ 2 callersFunctiondeserialize

(data: Bytes)

rtmp/src/messages/types/amf0_command.rs:27

↓ 2 callersMethodenqueue_response

(&mut self, poll: &mut Poll, bytes: Vec<u8>)

examples/mio_rtmp_server/src/connection.rs:125

↓ 2 callersMethodfinish_playing

Changes stream to Completed, and sends out an `onStatus(code: NetStream.Play.Complete)`

rtmp/src/sessions/server/mod.rs:407

↓ 2 callersMethodget_active_stream_id

(&self)

examples/mio_rtmp_server/src/server.rs:35

↓ 2 callersFunctionget_digest_for_received_packet

( packet: &[u8; RTMP_PACKET_SIZE], key: &[u8], )

rtmp/src/handshake/mod.rs:421

↓ 2 callersFunctionget_play_success_response

(serializer: &mut ChunkSerializer, stream_id: u32)

rtmp/src/sessions/client/tests.rs:1717

↓ 2 callersFunctionget_publish_success_response

(serializer: &mut ChunkSerializer, stream_id: u32)

rtmp/src/sessions/client/tests.rs:1745

↓ 2 callersMethodhandle_audio_video_data_received

( &mut self, stream_key: String, timestamp: RtmpTimestamp, data: Bytes,

examples/threaded_rtmp_server/src/server.rs:600

↓ 2 callersMethodhandle_metadata_received

( &mut self, app_name: String, stream_key: String, metadata: StreamMetadata,

examples/mio_rtmp_server/src/server.rs:710

↓ 2 callersMethodhandle_pull_audio_video_data_received

( &mut self, data: Bytes, data_type: ReceivedDataType, timestamp: RtmpTimestam

examples/mio_rtmp_server/src/server.rs:1022

↓ 2 callersMethodhandle_pull_session_results

( &mut self, session_results: Vec<ClientSessionResult>, server_results: &mut Vec<Serve

examples/mio_rtmp_server/src/server.rs:909

↓ 2 callersFunctionhandle_read_bytes

( bytes: &[u8], from_token: usize, server: &mut Server, connections: &mut Slab<Connection>,

examples/mio_rtmp_server/src/main.rs:271

↓ 2 callersFunctionis_audio_sequence_header

(data: Bytes)

examples/threaded_rtmp_server/src/server.rs:721

↓ 2 callersFunctionis_audio_sequence_header

(data: Bytes)

examples/mio_rtmp_server/src/server.rs:1203

↓ 2 callersFunctionis_video_keyframe

(data: Bytes)

examples/threaded_rtmp_server/src/server.rs:726

↓ 2 callersFunctionis_video_keyframe

(data: Bytes)

examples/mio_rtmp_server/src/server.rs:1208

next →1–100 of 487, ranked by callers