71 cb_creation(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg)  in cb_creation()  argument
82 	if (mtcp_getpeername(mctx, c->sock, (void *)c->addrs, &addrslen,  in cb_creation()
90 	TAILQ_INSERT_TAIL(&g_sockq[mctx->cpu], c, link);  in cb_creation()
95 cb_destroy(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg)  in cb_destroy()  argument
99 	if (!(c = find_connection(mctx->cpu, sock)))  in cb_destroy()
102 	TAILQ_REMOVE(&g_sockq[mctx->cpu], c, link);  in cb_destroy()
108 cb_st_chg(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg)  in cb_st_chg()  argument
113 	if (!(c = find_connection(mctx->cpu, sock)))  in cb_st_chg()
117 		if (mtcp_getsockopt(mctx, c->sock, SOL_MONSOCKET, MOS_TCP_STATE_CLI,  in cb_st_chg()
123 		if (mtcp_getsockopt(mctx, c->sock, SOL_MONSOCKET, MOS_TCP_STATE_SVR,  in cb_st_chg()
155 cb_printstat(mctx_t mctx, int sock, int side,  in cb_printstat()  argument
186 	if (mtcp_settimer(mctx, sock, &tv_1sec, cb_printstat)) {  in cb_printstat()
196 RegisterCallbacks(mctx_t mctx, int sock, event_t ev_new_syn)  in RegisterCallbacks()  argument
204 	if (mtcp_register_callback(mctx, sock, MOS_ON_CONN_START,  in RegisterCallbacks()
209 	if (mtcp_register_callback(mctx, sock, MOS_ON_CONN_END,  in RegisterCallbacks()
214 	if (mtcp_register_callback(mctx, sock, MOS_ON_TCP_STATE_CHANGE,  in RegisterCallbacks()
219 	if (mtcp_register_callback(mctx, sock, MOS_ON_TCP_STATE_CHANGE,  in RegisterCallbacks()
226 	if (mctx->cpu == 0 &&  in RegisterCallbacks()
227 		mtcp_settimer(mctx, sock, &tv_1sec, cb_printstat)) {  in RegisterCallbacks()
235 InitMonitor(mctx_t mctx, event_t ev_new_syn)  in InitMonitor()  argument
240 	TAILQ_INIT(&g_sockq[mctx->cpu]);  in InitMonitor()
243 	if ((sock = mtcp_socket(mctx, AF_INET,  in InitMonitor()
251 	if (mtcp_setsockopt(mctx, sock, SOL_MONSOCKET, MOS_CLIBUF,  in InitMonitor()
255 	if (mtcp_setsockopt(mctx, sock, SOL_MONSOCKET, MOS_SVRBUF,  in InitMonitor()
260 	RegisterCallbacks(mctx, sock, ev_new_syn);  in InitMonitor()