Lines Matching refs:u32
48 type ConnectTypeMap_ = Arc<RwLock<HashMap<u32, ConnectType>>>;
61 pub async fn put(session_id: u32, conn_type: ConnectType) {
68 pub async fn get(session_id: u32) -> Option<ConnectType> {
74 pub async fn del(session_id: u32) {
82 pub async fn get_all_session() -> Vec<u32> {
111 map: Mutex<HashMap<u32, TcpWriter_>>,
129 async fn put(session_id: u32, data: TaskMessage) {
141 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> {
150 u32::to_be_bytes(buf.len() as u32).as_slice(),
164 pub async fn start(id: u32, wr: SplitWriteHalf) {
173 pub async fn end(id: u32) {
186 map: std::sync::Mutex<HashMap<u32, UsbWriter>>,
207 async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> {
255 pub async fn start(session_id: u32, wr: UsbWriter) {
278 pub async fn end(session_id: u32) {
303 type UartMap_ = Arc<RwLock<HashMap<u32, UartWriter_>>>;
317 pub async fn put(session_id: u32, data: Vec<u8>) -> io::Result<()> {
328 pub async fn start(session_id: u32, wr: UartWriter) {
341 pub async fn put(session_id: u32, data: TaskMessage) {
373 pub async fn send_channel_data(channel_id: u32, data: Vec<u8>) {
395 pub async fn send_channel_msg(channel_id: u32, level: EchoLevel, msg: String) -> io::Result<()> {
407 type ChannelMap_ = Arc<RwLock<HashMap<u32, TcpRecver_>>>;
438 pub fn usb_start_recv(fd: i32, _session_id: u32) -> mpsc::BoundedReceiver<(TaskMessage, u32, u32)> {
439 let (tx, rx) = mpsc::bounded_channel::<(TaskMessage, u32, u32)>(config::USB_QUEUE_LEN);
453 set: Arc<RwLock<HashSet<u32>>>,
454 queue: Arc<RwLock<VecDeque<u32>>>,
473 pub async fn add(session_id: u32) {
488 pub async fn get(session_id: u32) -> bool {