Searched refs:state (Results 1 – 9 of 9) sorted by relevance
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | handshake_server.rs | 19 pub state: ServerHandshakeState, field
28 pub state: ServerHandshakeState, field
39 state: ServerHandshakeState::ReadC0C1, in new()
51 match self.state { in handshake()
65 self.state = ServerHandshakeState::ReadC2; in handshake()
72 self.state = ServerHandshakeState::Finish; in handshake()
91 state: ServerHandshakeState::ReadC0C1, in new()
104 match self.state { in handshake()
297 pub fn state(&mut self) -> ServerHandshakeState { in state() method
299 self.complex_handshaker.state in state()
[all …]
|
| H A D | handshake_client.rs | 21 pub state: ClientHandshakeState, field
30 state: ClientHandshakeState::WriteC0C1, in new()
44 match self.state { in handshake()
49 self.state = ClientHandshakeState::ReadS0S1S2; in handshake()
57 self.state = ClientHandshakeState::WriteC2; in handshake()
63 self.state = ClientHandshakeState::Finish; in handshake()
|
| /xiu/library/streamhub/src/ |
| H A D | define.rs | 75 let mut state = serializer.serialize_struct("SubscriberInfo", 3)?; in serialize() localVariable
77 state.serialize_field("id", &self.id.to_string())?; in serialize()
78 state.serialize_field("sub_type", &self.sub_type)?; in serialize()
79 state.serialize_field("notify_info", &self.notify_info)?; in serialize()
80 state.end() in serialize()
98 let mut state = serializer.serialize_struct("PublisherInfo", 3)?; in serialize() localVariable
100 state.serialize_field("id", &self.id.to_string())?; in serialize()
101 state.serialize_field("sub_type", &self.pub_type)?; in serialize()
102 state.serialize_field("notify_info", &self.notify_info)?; in serialize()
103 state.end() in serialize()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 85 state: ClientSessionState, field
137 state: ClientSessionState::Handshake, in new()
147 match self.state { in run()
157 self.state = ClientSessionState::WaitStateChange; in run()
163 self.state = ClientSessionState::WaitStateChange; in run()
169 self.state = ClientSessionState::WaitStateChange; in run()
175 self.state = ClientSessionState::WaitStateChange; in run()
226 self.state = ClientSessionState::Connect; in handshake()
477 self.state = ClientSessionState::CreateStream; in on_result_connect()
485 self.state = ClientSessionState::Play; in on_result_create_stream()
[all …]
|
| H A D | server_session.rs | 56 state: ServerSessionState, field
88 state: ServerSessionState::Handshake, in new()
105 match self.state { in run()
135 if let ServerHandshakeState::Finish = self.handshaker.state() { in handshake()
136 self.state = ServerSessionState::ReadChunk; in handshake()
329 self.state = ServerSessionState::DeleteStream; in on_amf0_command_message()
658 self.state = ServerSessionState::Play; in on_play()
|
| /xiu/protocol/webrtc/src/ |
| H A D | whep.rs | 175 if let Ok(state) = pc_state{ in handle_whep()
176 if state == RTCPeerConnectionState::Closed { in handle_whep()
|
| /xiu/library/logger/src/ |
| H A D | logger.rs | 117 let mut state = file_handler.lock().expect("Could not lock mutex"); in gen_log_file_thread_run() localVariable
118 *state = file; in gen_log_file_thread_run()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 362 if let Ok(state) = pc_state_receiver.recv().await { in subscribe_whep()
363 log::info!("state: {}", state); in subscribe_whep()
364 match state { in subscribe_whep()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | unpacketizer.rs | 368 fn print_current_message_header(&self, state: ChunkReadState) { in print_current_message_header()
371 state, in print_current_message_header()
|