Lines Matching refs:u32
60 response_waiters: HashMap<u32, Waiter>,
62 empty_waiters: HashMap<u32, Waiter>,
76 async fn start_session(session_id: u32) {
83 async fn wait_response(session_id: u32) {
92 async fn wakeup_response_wait(session_id: u32) {
101 async fn wait_empty(session_id: u32) {
110 async fn wakeup_empty_wait(session_id: u32) {
129 session_id: u32,
132 package_index: u32,
135 retry_count: u32,
150 data_map: HashMap<u32, OutputDataVec_>,
151 thread_map: HashMap<u32, JoinHandle<()>>,
152 stop_flag_map: HashMap<u32, Arc<Mutex<u8>>>,
179 async fn get_package(session_id: u32, index: usize) -> Option<OutputData> {
197 async fn put_package(session_id: u32, data: OutputData) {
214 async fn update_package(session_id: u32, index: usize, data: OutputData) -> bool {
233 async fn get_stop_flag(session_id: u32) -> Option<u8> {
246 async fn set_stop_flag(session_id: u32) {
253 async fn remove_package(session_id: u32, index: usize) -> bool {
267 async fn remove_session(session_id: u32) {
276 async fn check_stop(session_id: u32) -> bool {
283 async fn session_loop(session_id: u32) {
399 pub async fn start_session(session_id: u32) {
417 async fn stop_session(session_id: u32) {
427 pub async fn stop_other_session(session_id: u32) {
444 session_id: u32,
447 package_index: u32,
492 let head_sum = header.iter().fold(0u32, |acc, &x| acc + x as u32);
493 header_obj.head_checksum = u32::to_le(head_sum);
500 fn get_package_index(is_create: bool) -> u32 {
501 static mut PACKAGE_INDEX: u32 = 888;
513 pub async fn start_uart(session_id: u32, wr: UartWriter) {
518 pub async fn wrap_put(session_id: u32, data: TaskMessage, package_index: u32, option: u8) {
545 let data_sum = data.iter().fold(0u32, |acc, &x| acc + x as u32);
547 header_obj.data_checksum = u32::to_le(data_sum);
550 let head_sum = header.iter().fold(0u32, |acc, &x| acc + x as u32);
551 header_obj.head_checksum = u32::to_le(head_sum);