Lines Matching refs:mtcp
96 mtcp_manager_t mtcp; in mtcp_bind_monitor_filter() local
98 mtcp = GetMTCPManager(mctx); in mtcp_bind_monitor_filter()
99 if (!mtcp) { in mtcp_bind_monitor_filter()
116 sock = &mtcp->msmap[sockid]; in mtcp_bind_monitor_filter()
173 mtcp_manager_t mtcp = GetMTCPManager(mctx); in mtcp_app_join() local
174 if (!mtcp) return; in mtcp_app_join()
176 RunPassiveLoop(mtcp); in mtcp_app_join()
185 mtcp_manager_t mtcp; in mtcp_set_uctx() local
187 mtcp = GetMTCPManager(mctx); in mtcp_set_uctx()
188 if (!mtcp) { in mtcp_set_uctx()
193 if (mtcp->ctx->thread != pthread_self()) in mtcp_set_uctx()
202 socket_map_t socket = &mtcp->msmap[msock]; in mtcp_set_uctx()
213 mtcp_manager_t mtcp; in mtcp_get_uctx() local
215 mtcp = GetMTCPManager(mctx); in mtcp_get_uctx()
216 if (!mtcp) { in mtcp_get_uctx()
222 if (mtcp->ctx->thread != pthread_self()) { in mtcp_get_uctx()
233 socket_map_t socket = &mtcp->msmap[msock]; in mtcp_get_uctx()
248 mtcp_manager_t mtcp; in mtcp_peek() local
252 mtcp = GetMTCPManager(mctx); in mtcp_peek()
253 if (!mtcp) { in mtcp_peek()
259 if (mtcp->ctx->thread != pthread_self()) { in mtcp_peek()
265 sock = &mtcp->msmap[msock]; in mtcp_peek()
364 mtcp_manager_t mtcp; in mtcp_ppeek() local
369 mtcp = GetMTCPManager(mctx); in mtcp_ppeek()
370 if (!mtcp) { in mtcp_ppeek()
376 if (mtcp->ctx->thread != pthread_self()) { in mtcp_ppeek()
382 sock = &mtcp->msmap[msock]; in mtcp_ppeek()
455 mtcp_manager_t mtcp; in mtcp_getlastpkt() local
459 mtcp = GetMTCPManager(mctx); in mtcp_getlastpkt()
460 if (!mtcp) { in mtcp_getlastpkt()
466 if (mtcp->ctx->thread != pthread_self()) { in mtcp_getlastpkt()
472 socket = &mtcp->msmap[sock]; in mtcp_getlastpkt()
478 if (mtcp->pctx == NULL) { in mtcp_getlastpkt()
482 cur_pkt_ctx = mtcp->pctx; in mtcp_getlastpkt()
507 cur_pkt_ctx = mtcp->pctx; in mtcp_getlastpkt()
513 cur_pkt_ctx = mtcp->pctx; in mtcp_getlastpkt()
528 mtcp_manager_t mtcp; in mtcp_getlastpkt() local
530 mtcp = GetMTCPManager(mctx); in mtcp_getlastpkt()
531 if (!mtcp) { in mtcp_getlastpkt()
537 if (mtcp->ctx->thread != pthread_self()) { in mtcp_getlastpkt()
542 *pctx = mtcp->pctx; in mtcp_getlastpkt()
557 mtcp_manager_t mtcp; in mtcp_sendpkt() local
560 mtcp = GetMTCPManager(mctx); in mtcp_sendpkt()
561 if (!mtcp || !pkt) { in mtcp_sendpkt()
567 if (mtcp->ctx->thread != pthread_self()) { in mtcp_sendpkt()
573 socket = &mtcp->msmap[sock]; in mtcp_sendpkt()
582 SendTCPPacketStandalone(mtcp, in mtcp_sendpkt()
607 RemoveMonitorEvents(mtcp_manager_t mtcp, socket_map_t socket, int side) in RemoveMonitorEvents() argument
612 if (mtcp == NULL) { in RemoveMonitorEvents()
638 stree_dec_ref(mtcp->ev_store, mstream->stree_dontcare); in RemoveMonitorEvents()
639 stree_dec_ref(mtcp->ev_store, mstream->stree_pre_rcv); in RemoveMonitorEvents()
640 stree_dec_ref(mtcp->ev_store, mstream->stree_post_snd); in RemoveMonitorEvents()
675 stree_dec_ref(mtcp->ev_store, mlistener->stree_dontcare); in RemoveMonitorEvents()
676 stree_dec_ref(mtcp->ev_store, mlistener->stree_pre_rcv); in RemoveMonitorEvents()
677 stree_dec_ref(mtcp->ev_store, mlistener->stree_post_snd); in RemoveMonitorEvents()
688 CleanupEvB(mtcp, &mlistener->dontcare_evb); in RemoveMonitorEvents()
689 CleanupEvB(mtcp, &mlistener->pre_tcp_evb); in RemoveMonitorEvents()
690 CleanupEvB(mtcp, &mlistener->post_tcp_evb); in RemoveMonitorEvents()
707 mtcp_manager_t mtcp; in mtcp_cb_stop() local
713 mtcp = GetMTCPManager(mctx); in mtcp_cb_stop()
714 if (!mtcp) { in mtcp_cb_stop()
719 socket = &mtcp->msmap[sock]; in mtcp_cb_stop()
722 RemoveMonitorEvents(mtcp, socket, side); in mtcp_cb_stop()
781 SendRSTPacketStandalone(mtcp_manager_t mtcp, struct tcp_stream *stream) { in SendRSTPacketStandalone() argument
782 SendTCPPacketStandalone(mtcp, in SendRSTPacketStandalone()
785 NULL, 0, mtcp->cur_ts, 0, 0, -1); in SendRSTPacketStandalone()
794 mtcp_manager_t mtcp; in mtcp_reset_conn() local
797 mtcp = GetMTCPManager(mctx); in mtcp_reset_conn()
798 if (!mtcp) { in mtcp_reset_conn()
803 socket = &mtcp->msmap[sock]; in mtcp_reset_conn()
812 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream); in mtcp_reset_conn()
813 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream->pair_stream); in mtcp_reset_conn()
821 mtcp_manager_t mtcp; in mtcp_cb_get_ts() local
823 mtcp = GetMTCPManager(mctx); in mtcp_cb_get_ts()
824 if (!mtcp) { in mtcp_cb_get_ts()
831 if (mtcp->ctx->thread != pthread_self()) { in mtcp_cb_get_ts()
836 return TS_TO_USEC(mtcp->cur_ts); in mtcp_cb_get_ts()
851 mtcp_manager_t mtcp; in mtcp_getpeername() local
857 mtcp = GetMTCPManager(mctx); in mtcp_getpeername()
858 if (!mtcp) { in mtcp_getpeername()
872 if (mtcp->ctx->thread != pthread_self()) { in mtcp_getpeername()
877 socket = &mtcp->msmap[sockfd]; in mtcp_getpeername()
935 mtcp_manager_t mtcp; in mtcp_setlastpkt() local
948 mtcp = GetMTCPManager(mctx); in mtcp_setlastpkt()
949 if (!mtcp) { in mtcp_setlastpkt()
956 if (mtcp->ctx->thread != pthread_self()) { in mtcp_setlastpkt()
964 socket = &mtcp->msmap[sock]; in mtcp_setlastpkt()
985 cur_pkt_ctx = mtcp->pctx; in mtcp_setlastpkt()
1010 mtcp->pctx->forward = 0; in mtcp_setlastpkt()
1213 mtcp_manager_t mtcp; in mtcp_cb_dropcurpkt() local
1216 mtcp = GetMTCPManager(mctx); in mtcp_cb_dropcurpkt()
1217 if (!mtcp) { in mtcp_cb_dropcurpkt()
1224 if (mtcp->ctx->thread != pthread_self()) { in mtcp_cb_dropcurpkt()
1231 if (mtcp->pctx == NULL) { in mtcp_cb_dropcurpkt()
1237 mtcp->pctx->forward = 0; in mtcp_cb_dropcurpkt()
1243 mtcp_set_debug_string(mtcp_manager_t mtcp, const char *fmt, ...) in mtcp_set_debug_string() argument
1249 assert(mtcp); in mtcp_set_debug_string()
1252 mtcp->dbg_buf[0] = '\0'; in mtcp_set_debug_string()
1257 i = vsnprintf(mtcp->dbg_buf, DBG_BUF_LEN - 1, fmt, args); in mtcp_set_debug_string()
1270 mtcp_manager_t mtcp; in mtcp_get_debug_string() local
1278 if (!(mtcp = GetMTCPManager(mctx))) in mtcp_get_debug_string()
1281 copylen = MIN(strlen(mtcp->dbg_buf), len); in mtcp_get_debug_string()
1282 strncpy(buf, mtcp->dbg_buf, copylen); in mtcp_get_debug_string()