59 assign_port(mctx_t mctx, int sock)  in assign_port()  argument
66 	if (mtcp_getpeername(mctx, sock, (struct sockaddr *)&addr, &len,  in assign_port()
77 			 == mctx->cpu)  in assign_port()
82 		mtcp_set_uctx(mctx, sock, w);  in assign_port()
86 		TRACE_ERROR("No suitable port found! (CPU %d)\n", mctx->cpu);  in assign_port()
92 set_addr(mctx_t mctx, int sock, uint32_t ip, uint16_t port, int part)  in set_addr()  argument
104 	if (mtcp_setlastpkt(mctx, sock, 0, off_ip,  in set_addr()
110 	if (mtcp_setlastpkt(mctx, sock, 0, off_port,  in set_addr()
122 translate_addr(mctx_t mctx, int sock, int side, uint64_t events,  in translate_addr()  argument
127 	if (!(w = mtcp_get_uctx(mctx, sock)))  in translate_addr()
128 		assign_port(mctx, sock);  in translate_addr()
133 		if (!(w = mtcp_get_uctx(mctx, sock)))  in translate_addr()
136 		if (set_addr(mctx, sock, g_NATIP, w->port, SRC) < 0 &&  in translate_addr()
137 			mtcp_setlastpkt(mctx, sock, side, 0, NULL, 0, MOS_DROP) < 0)  in translate_addr()
144 		if (mtcp_getpeername(mctx, sock, (struct sockaddr *)&addr, &len,  in translate_addr()
150 		if (set_addr(mctx, sock, addr[MOS_SIDE_CLI].sin_addr.s_addr,  in translate_addr()
152 			mtcp_setlastpkt(mctx, sock, side, 0, NULL, 0, MOS_DROP) < 0)  in translate_addr()
158 release_port(mctx_t mctx, int sock, int side, uint64_t events,  in release_port()  argument
164 	if (!(w = mtcp_get_uctx(mctx, sock)))  in release_port()
170 	mtcp_set_uctx(mctx, sock, NULL);  in release_port()
175 init_monitor(mctx_t mctx)  in init_monitor()  argument
177 	int lsock = mtcp_socket(mctx, AF_INET, MOS_SOCK_MONITOR_STREAM, 0);  in init_monitor()
183 	if (mtcp_register_callback(mctx, lsock, MOS_ON_PKT_IN, MOS_HK_SND,  in init_monitor()
186 	if (mtcp_register_callback(mctx, lsock, MOS_ON_CONN_END, MOS_HK_SND,  in init_monitor()