| /xiu/library/streamhub/src/ |
| H A D | utils.rs | 6 pub struct Uuid { struct
36 impl Uuid { impl
37 pub fn from_str2(uuid: &String) -> Option<Uuid> { in from_str2() argument
49 Some(Uuid { in from_str2()
99 impl fmt::Display for Uuid { implementation
112 use super::Uuid;
116 let id = Uuid::new(super::RandomDigitCount::Four); in test_uuid()
122 if let Some(u) = Uuid::from_str2(&s) { in test_uuid()
|
| H A D | lib.rs | 26 utils::Uuid,
36 id_to_frame_sender: Arc<Mutex<HashMap<Uuid, FrameDataSender>>>,
38 id_to_packet_sender: Arc<Mutex<HashMap<Uuid, PacketDataSender>>>,
60 frame_senders: Arc<Mutex<HashMap<Uuid, FrameDataSender>>>, in receive_frame_data_loop() argument
114 packet_senders: Arc<Mutex<HashMap<Uuid, PacketDataSender>>>, in receive_packet_data_loop() argument
165 packet_senders: Arc<Mutex<HashMap<Uuid, PacketDataSender>>>, in receive_event_loop() argument
166 frame_senders: Arc<Mutex<HashMap<Uuid, FrameDataSender>>>, in receive_event_loop() argument
263 streams_info: HashMap<Uuid, PubSubInfo>,
560 fn api_kick_off_client(&mut self, uid: Uuid) { in api_kick_off_client() argument
|
| H A D | define.rs | 15 utils::Uuid,
63 pub id: Uuid,
86 pub id: Uuid,
241 ApiKickClient { id: Uuid },
|
| /xiu/protocol/webrtc/src/ |
| H A D | webrtc.rs | 9 use streamhub::utils::Uuid;
17 uuid_2_sessions: Arc<Mutex<HashMap<Uuid, Arc<Mutex<WebRTCServerSession>>>>>,
|
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 16 utils::{RandomDigitCount, Uuid},
30 subscriber_id: Uuid,
42 let subscriber_id = Uuid::new(RandomDigitCount::Four); in new()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 32 utils::Uuid,
246 fn get_subscriber_info(&mut self, sub_id: Uuid) -> SubscriberInfo { in get_subscriber_info()
271 fn get_publisher_info(&mut self, sub_id: Uuid) -> PublisherInfo { in get_publisher_info()
299 sub_id: Uuid, in subscribe_from_channels() argument
338 sub_id: Uuid, in unsubscribe_from_channels() argument
361 pub_id: Uuid, in publish_to_channels() argument
394 pub_id: Uuid, in unpublish_to_channels() argument
|
| H A D | client_session.rs | 34 streamhub::utils::Uuid,
84 session_id: Uuid,
113 let subscriber_id = Uuid::new(RandomDigitCount::Four); in new()
|
| H A D | server_session.rs | 34 utils::{RandomDigitCount, Uuid},
62 pub session_id: Uuid,
95 session_id: Uuid::new(RandomDigitCount::Four), in new()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 19 utils::{RandomDigitCount, Uuid},
34 subscriber_id: Uuid,
49 let subscriber_id = Uuid::new(RandomDigitCount::Four); in new()
|
| /xiu/application/xiu/src/ |
| H A D | api.rs | 9 streamhub::{define, define::StreamHubEventSender, utils::Uuid},
74 let id_result = Uuid::from_str2(&id.id); in kick_off_client()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 10 utils::{RandomDigitCount, Uuid},
46 pub session_id: Option<Uuid>,
77 uuid_2_sessions: Arc<Mutex<HashMap<Uuid, Arc<Mutex<WebRTCServerSession>>>>>, in run() argument
148 self.session_id = Some(Uuid::new(RandomDigitCount::Zero)); in run()
183 if let Some(uuid) = Uuid::from_str2(session_id) { in run()
437 Uuid::new(RandomDigitCount::Zero) in get_subscriber_info()
455 Uuid::new(RandomDigitCount::Zero) in get_publisher_info()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 30 utils::{RandomDigitCount, Uuid},
40 publishe_id: Uuid,
44 subscribe_id: Uuid,
78 subscribe_id: Uuid::new(RandomDigitCount::Four), in new()
79 publishe_id: Uuid::new(RandomDigitCount::Four), in new()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 57 utils::{RandomDigitCount, Uuid},
69 pub session_id: Option<Uuid>,
337 self.session_id = Some(Uuid::new(RandomDigitCount::Zero)); in handle_setup()
665 Uuid::new(RandomDigitCount::Zero) in get_subscriber_info()
683 Uuid::new(RandomDigitCount::Zero) in get_publisher_info()
|