Lines Matching refs:mctx
73 mctx_t mctx; /* per-thread mos context */ member
79 DumpFWRuleTable(mctx_t mctx, int sock, int side, in DumpFWRuleTable() argument
124 if (mtcp_settimer(mctx, sock, &tv_1sec, DumpFWRuleTable)) in DumpFWRuleTable()
333 ApplyActionPerFlow(mctx_t mctx, int msock, int side, in ApplyActionPerFlow() argument
342 if (mtcp_getlastpkt(mctx, msock, side, &p) < 0) in ApplyActionPerFlow()
350 mtcp_setlastpkt(mctx, msock, side, 0, NULL, 0, MOS_DROP); in ApplyActionPerFlow()
355 if (mtcp_setsockopt(mctx, msock, SOL_MONSOCKET, in ApplyActionPerFlow()
363 CatchInitSYN(mctx_t mctx, int sockid, in CatchInitSYN() argument
368 if (mtcp_getlastpkt(mctx, sockid, side, &p) < 0) in CatchInitSYN()
383 ctx->mctx = mtcp_create_context(core); in CreateAndInitThreadContext()
386 ctx->mon_listener = mtcp_socket(ctx->mctx, AF_INET, in CreateAndInitThreadContext()
392 if (mtcp_register_callback(ctx->mctx, ctx->mon_listener, in CreateAndInitThreadContext()
399 if (ctx->mctx->cpu == 0 && in CreateAndInitThreadContext()
400 mtcp_settimer(ctx->mctx, ctx->mon_listener, in CreateAndInitThreadContext()
410 mtcp_app_join(ctx->mctx); in WaitAndCleanupThreadContext()
413 mtcp_close(ctx->mctx, ctx->mon_listener); in WaitAndCleanupThreadContext()
416 mtcp_destroy_context(ctx->mctx); in WaitAndCleanupThreadContext()