Lines Matching refs:id
108 id: u32,
205 async fn put(id: u32, wr: SplitWriteHalf) {
209 map.insert(id, arc_wr);
212 async fn write(id: u32, data: Vec<u8>) -> bool {
215 let Some(arc_wr) = map.get(&id) else {
216 crate::error!("TcpWriteStreamMap failed to get id {:#?}", id);
222 crate::error!("TcpWriteStreamMap write_all error. id = {:#?}", id);
227 pub async fn end(id: u32) {
230 if let Some(arc_wr) = map.remove(&id) {
250 async fn put(id: u32, listener: JoinHandle<()>) {
254 map.insert(id, arc_listener);
255 crate::info!("forward tcp put listener id = {id}");
258 pub async fn end(id: u32) {
261 if let Some(arc_listener) = map.remove(&id) {
373 let id = key;
374 channel_list.push(id);
378 for id in channel_list {
379 free_channel_task(id.0, id.1).await;
430 let cid = task.context_forward.id;
611 free_context(ctx.id, false).await;
677 ForwardContextMap::update(client_context.id, client_context.clone()).await;
678 crate::info!("malloc client_context id = {:#?}", client_context.id);
679 TcpWriteStreamMap::put(client_context.id, wr).await;
680 on_accept(client_context.id).await;
682 recv_tcp_msg(session_tmp, channel_tmp, rd, client_context.id).await;
716 ctx.id,
739 TcpWriteStreamMap::put(ctx.id, wr).await;
740 ForwardContextMap::update(ctx.id, ctx.clone()).await;
843 ctx.id,
850 TcpWriteStreamMap::end(ctx.id).await;
853 TcpWriteStreamMap::end(ctx.id).await;
855 crate::debug!("close context_forward fd, ret={}, id={}", ret, ctx.id,);
858 "close context_forward target fd, ret={}, id={}",
860 ctx.id,
879 let cid = ctx.id;
884 ForwardContextMap::update(ctx.id, ctx.clone()).await;
901 ForwardContextMap::update(ctx.id, ctx.clone()).await;
902 let cid = ctx.id;
972 let cid = ctx.id;
974 ForwardContextMap::update(ctx.id, ctx.clone()).await;
1037 let cid = ctx.id;
1156 free_context(ctx.id, true).await;
1178 crate::error!("server socket bind listen failed id={:?}", ctx.id);
1194 ForwardContextMap::update(ctx.id, ctx.clone()).await;
1233 ForwardContextMap::update(ctx.id, ctx.clone()).await;
1265 let id: u32 = u32::from_be_bytes(id_bytes);
1266 id
1278 ctx.id,
1281 free_context(ctx.id, false).await;
1290 ctx.id,
1294 free_context(ctx.id, true).await;
1373 context_forward.id,
1387 if let Ok((content, id)) = filter_command(payload) {
1394 context_forward.id = id;
1395 ForwardContextMap::update(id, context_forward.clone()).await;
1401 free_context(context_forward.id, true).await;
1402 ForwardContextMap::update(context_forward.id, context_forward.clone()).await;
1408 ForwardContextMap::update(context_forward.id, context_forward.clone()).await;
1413 let cid = ctx.id;
1440 let id: u32 = u32::from_be_bytes(id_bytes);
1441 return Ok((content, id));
1472 return TcpWriteStreamMap::write(ctx.id, content).await;
1477 "write_forward_bufer get dev_path is failed ctx.id = {:#?}",
1478 ctx.id
1505 ctx.id = utils::get_current_time() as u32;
1509 crate::info!("malloc_context success id = {:#?}", ctx.id);
1510 ForwardContextMap::update(ctx.id, ctx.clone()).await;
1543 free_context(ctx.id, false).await;