72         session_id: u32,  in new()
73         channel_id: u32,  in new()
203     async fn put(id: u32, wr: SplitWriteHalf) {  in put()
210     async fn write(id: u32, data: Vec<u8>) -> bool {  in write()
225     pub async fn end(id: u32) {  in end()
248     async fn put(id: u32, listener: JoinHandle<()>) {  in put()
256     pub async fn end(id: u32) {  in end()
278     pub async fn add(cid: u32, value: ContextForward) {  in add()
284     pub async fn update(cid: u32, value: ContextForward) {  in update()
290     pub async fn remove(cid: u32) {  in remove()
323     pub async fn update(session_id: u32, channel_id: u32, value: HdcForward) {  in update()
329     pub async fn remove(session_id: u32, channel_id: u32) {  in remove()
336     pub async fn get(session_id: u32, channel_id: u32) -> Option<HdcForward> {  in get()
353     pub async fn get_channel_id(session_id: u32, task_string: String) -> Option<u32> {  in get_channel_id()
364     pub async fn clear(session_id: u32) {  in clear()
426 pub async fn free_channel_task(session_id: u32, channel_id: u32) {  in free_channel_task()
467 pub async fn stop_task(session_id: u32) {  in stop_task()
489     pub fn new(session_id: u32, channel_id: u32, server_or_daemon: bool) -> Self {  in new()
692 pub async fn on_accept(cid: u32) {  in on_accept()
716 pub async fn daemon_connect_tcp(cid: u32, port: u32) {  in daemon_connect_tcp()
739 pub async fn recv_tcp_msg(session_id: u32, channel_id: u32, mut rd: SplitReadHalf, cid: u32) {  in recv_tcp_msg()
769 pub async fn deamon_read_socket_msg(session_id: u32, channel_id: u32, fd: i32, cid: u32) {  in deamon_read_socket_msg()
802 pub async fn free_context(cid: u32, notify_remote: bool) {  in free_context()
984 fn get_pid(parameter: &str, forward_type: ForwardType) -> u32 {  in get_pid()
1108 async fn task_finish(session_id: u32, channel_id: u32) {  in task_finish()
1213     session_id: u32,  in send_to_task()
1214     channel_id: u32,  in send_to_task()
1218     cid: u32,  in send_to_task()
1236 pub fn get_cid(_payload: &[u8]) -> u32 {  in get_cid()
1304 pub async fn begin_forward(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool {  in begin_forward()
1354     session_id: u32,  in slave_connect()
1355     channel_id: u32,  in slave_connect()
1408 pub fn filter_command(_payload: &[u8]) -> io::Result<(String, u32)> {  in filter_command()  argument
1472     session_id: u32,  in malloc_context()
1473     channel_id: u32,  in malloc_context()
1488     session_id: u32,  in forward_command_dispatch()
1489     channel_id: u32,  in forward_command_dispatch()
1529 async fn print_error_info(session_id: u32, channel_id: u32) {  in print_error_info()
1556     session_id: u32,  in command_dispatch()
1557     channel_id: u32,  in command_dispatch()