Lines Matching refs:u32
55 pub const ARG_COUNT2: u32 = 2;
64 pub session_id: u32,
65 pub channel_id: u32,
74 session_id: u32,
75 channel_id: u32,
104 session_id: u32,
105 channel_id: u32,
108 id: u32,
193 type TcpWriterMap_ = Arc<RwLock<HashMap<u32, TcpWriter>>>;
205 async fn put(id: u32, wr: SplitWriteHalf) {
212 async fn write(id: u32, data: Vec<u8>) -> bool {
227 pub async fn end(id: u32) {
238 type TcpListenerMap_ = Arc<RwLock<HashMap<u32, TcpListener_>>>;
250 async fn put(id: u32, listener: JoinHandle<()>) {
258 pub async fn end(id: u32) {
268 type MapContextForward_ = Arc<Mutex<HashMap<u32, ContextForward>>>;
283 pub async fn update(cid: u32, value: ContextForward) {
289 pub async fn remove(cid: u32) {
296 pub async fn get(cid: u32) -> Option<ContextForward> {
310 type MapForward_ = Arc<Mutex<HashMap<(u32, u32), HdcForward>>>;
322 pub async fn update(session_id: u32, channel_id: u32, value: HdcForward) {
328 pub async fn remove(session_id: u32, channel_id: u32) {
335 pub async fn get(session_id: u32, channel_id: u32) -> Option<HdcForward> {
352 pub async fn get_channel_id(session_id: u32, task_string: String) -> Option<u32> {
363 pub async fn clear(session_id: u32) {
425 pub async fn free_channel_task(session_id: u32, channel_id: u32) {
467 pub async fn stop_task(session_id: u32) {
477 session_id: u32,
478 channel_id: u32,
489 pub fn new(session_id: u32, channel_id: u32, server_or_daemon: bool) -> Self {
519 match array[1].parse::<u32>() {
539 pub async fn on_forward_success(task_message: TaskMessage, session_id: u32) -> io::Result<()> {
653 pub async fn forward_tcp_accept(ctx: &mut ContextForward, port: u32) -> io::Result<()> {
697 pub async fn on_accept(cid: u32) {
721 pub async fn daemon_connect_tcp(cid: u32, port: u32) {
750 pub async fn update_context_to_task(session_id: u32, channel_id:u32, ctx: &mut ContextForward) {
764 pub async fn recv_tcp_msg(session_id: u32, channel_id: u32, mut rd: SplitReadHalf, cid: u32) {
795 pub async fn deamon_read_socket_msg(session_id: u32, channel_id: u32, fd: i32, cid: u32) {
828 pub async fn free_context(cid: u32, notify_remote: bool) {
875 let Ok(port) = ctx.local_args[1].parse::<u32>() else {
1009 fn get_pid(parameter: &str, forward_type: ForwardType) -> u32 {
1011 true => parameter.parse::<u32>().unwrap_or_else(|e| {
1017 params[0].parse::<u32>().unwrap_or_else(|e| {
1133 async fn task_finish(session_id: u32, channel_id: u32) {
1239 session_id: u32,
1240 channel_id: u32,
1244 cid: u32,
1251 let mut new_buf = [u32::to_be_bytes(cid).as_slice(), buf_ptr].concat();
1262 pub fn get_cid(_payload: &[u8]) -> u32 {
1265 let id: u32 = u32::from_be_bytes(id_bytes);
1330 pub async fn begin_forward(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool {
1380 session_id: u32,
1381 channel_id: u32,
1434 pub fn filter_command(_payload: &[u8]) -> io::Result<(String, u32)> {
1440 let id: u32 = u32::from_be_bytes(id_bytes);
1498 session_id: u32,
1499 channel_id: u32,
1505 ctx.id = utils::get_current_time() as u32;
1515 session_id: u32,
1516 channel_id: u32,
1556 async fn print_error_info(session_id: u32, channel_id: u32) {
1583 session_id: u32,
1584 channel_id: u32,