Lines Matching refs:core
94 int core; member
148 ctx->core = mctx->cpu; in CreateContext()
150 g_mctx[ctx->core] = mctx; in CreateContext()
158 g_stat[ctx->core] = NULL; in DestroyContext()
222 done[ctx->core] = TRUE; in CloseConnection()
615 int core = mctx->cpu; in InitWget() local
620 g_ctx[core] = ctx; in InitWget()
621 g_stat[core] = &ctx->stat; in InitWget()
626 if (flows[core] == 0) { in InitWget()
627 TRACE_DBG("Application thread %d finished.\n", core); in InitWget()
630 ctx->target = flows[core]; in InitWget()
673 int core = ctx->core; in RunWget() local
677 core, flows[core], inet_ntoa(daddr_in), ntohs(dport)); in RunWget()
682 while (!done[core]) { in RunWget()
686 if (core == 0 && cur_tv.tv_sec > prev_tv.tv_sec) { in RunWget()
693 done[core] = TRUE; in RunWget()
706 done[core] = TRUE; in RunWget()
719 core, ctx->events[i].data.sockid); in RunWget()
759 TRACE_INFO("Wget thread %d waiting for mtcp to be destroyed.\n", core); in RunWget()
761 g_stat[core] = NULL; in RunWget()
762 g_ctx[core] = NULL; in RunWget()
787 int core = *(int *)arg; in RunMTCP() local
790 mtcp_core_affinitize(core); in RunMTCP()
793 mctx = mtcp_create_context(core); in RunMTCP()