| /mOS-networking-stack/core/src/ |
| H A D | core.c | 201 mtcp->ctx->cpu, in PrintThreadNetworkStats()
925 struct mtcp_context mctx = {.cpu = ctx->cpu}; in RunMainLoop()
1285 int cpu = mctx->cpu; in MTCPRunThread() local
1302 ctx->cpu = cpu; in MTCPRunThread()
1334 g_pctx[cpu] = ctx; in MTCPRunThread()
1405 mctx->cpu = cpu; in mtcp_create_context()
1406 g_ctx[cpu] = mctx; in mtcp_create_context()
1416 InitLogThreadContext(g_logctx[cpu], cpu); in mtcp_create_context()
1454 running[cpu] = TRUE; in mtcp_create_context()
1459 printer = cpu; in mtcp_create_context()
[all …]
|
| H A D | logger.c | 77 InitLogThreadContext(struct log_thread_context *ctx, int cpu) in InitLogThreadContext() argument
84 ctx->cpu = cpu; in InitLogThreadContext()
118 mtcp_core_affinitize(ctx->cpu); in ThreadLogMain()
122 TRACE_LOG("Log thread %d is starting.\n", ctx->cpu); in ThreadLogMain()
130 ctx->cpu, cnt); in ThreadLogMain()
136 ctx->cpu, w_buff->buff_len, len); in ThreadLogMain()
151 TRACE_LOG("Log thread %d out of first loop.\n", ctx->cpu); in ThreadLogMain()
157 "Exceed NUM_LOG_BUFF %d in final loop.\n", ctx->cpu, cnt); in ThreadLogMain()
165 TRACE_LOG("Log thread %d finished.\n", ctx->cpu); in ThreadLogMain()
|
| H A D | cpu.c | 32 mtcp_core_affinitize(int cpu) in mtcp_core_affinitize() argument
46 if (cpu < 0 || cpu >= (int) n) { in mtcp_core_affinitize()
52 CPU_SET((unsigned)cpu, &cpus); in mtcp_core_affinitize()
66 "/sys/devices/system/cpu/cpu%d/topology/physical_package_id", cpu); in mtcp_core_affinitize()
|
| H A D | dpdk_module.c | 189 sprintf(mempool_name, "mbuf_pool-%d", ctxt->cpu); in dpdk_init_handle()
191 dpc->pktmbuf_pool = pktmbuf_pool[ctxt->cpu]; in dpdk_init_handle()
197 dpc->wmbufs[j].m_table[i] = rte_pktmbuf_alloc(pktmbuf_pool[ctxt->cpu]); in dpdk_init_handle()
200 ctxt->cpu, i, j); in dpdk_init_handle()
213 ctxt->cpu); in dpdk_init_handle()
229 qid = cpu_qid_map[nif][ctxt->cpu]; in dpdk_send_pkts()
251 ss.qid = ctxt->cpu; in dpdk_send_pkts()
274 ctxt->cpu, i, nif); in dpdk_send_pkts()
373 qid = cpu_qid_map[ifidx][ctxt->cpu]; in dpdk_recv_pkts()
585 int cpu = g_config.mos->num_cores, ret; in dpdk_load_module_upper_half() local
[all …]
|
| H A D | socket.c | 73 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in AllocateSocket()
135 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in FreeSocket()
175 return &g_mtcp[mctx->cpu]->smap[sockid]; in GetSocket()
|
| H A D | api.c | 59 if (mctx->cpu < 0 || mctx->cpu >= num_cpus) { in GetMTCPManager()
64 if (!g_mtcp[mctx->cpu] || g_mtcp[mctx->cpu]->ctx->done || g_mtcp[mctx->cpu]->ctx->exit) { in GetMTCPManager()
69 return g_mtcp[mctx->cpu]; in GetMTCPManager()
939 ap = CreateAddressPoolPerCore(mctx->cpu, num_cpus, in mtcp_init_rss()
1058 if (rss_core != mctx->cpu) { in mtcp_connect()
1065 mctx->cpu, num_queues, addr_in, &socket->saddr); in mtcp_connect()
1073 mctx->cpu, num_queues, addr_in, &socket->saddr); in mtcp_connect()
|
| H A D | netmap_module.c | 73 sprintf(nifname, "netmap:%s-%d", ifname, ctxt->cpu); in netmap_init_handle()
75 TRACE_INFO("Opening %s with j: %d (cpu: %d)\n", nifname, j, ctxt->cpu); in netmap_init_handle()
|
| H A D | tcp_stream.c | 334 mctx.cpu = mtcp->ctx->cpu; in AddMonitorStreamSockets()
405 mctx.cpu = mtcp->ctx->cpu; in DestroyMonitorStreamSocket()
|
| H A D | Makefile.in | 76 arp.c timer.c cpu.c util.c addr_pool.c fhash.c memory_mgt.c logger.c debug.c \
|
| /mOS-networking-stack/util/ |
| H A D | cpu.c | 19 CoreAffinitize(int cpu) in CoreAffinitize() argument
28 if (cpu < 0 || cpu >= (int) n) { in CoreAffinitize()
38 CPU_SET_S(cpu, n, cmask); in CoreAffinitize()
50 numa_bitmask_setbit(bmask, cpu %2); in CoreAffinitize()
|
| /mOS-networking-stack/samples/midstat/ |
| H A D | midstat.c | 58 find_connection(int cpu, int sock) in find_connection() argument
62 TAILQ_FOREACH(c, &g_sockq[cpu], link) in find_connection()
90 TAILQ_INSERT_TAIL(&g_sockq[mctx->cpu], c, link); in cb_creation()
99 if (!(c = find_connection(mctx->cpu, sock))) in cb_destroy()
102 TAILQ_REMOVE(&g_sockq[mctx->cpu], c, link); in cb_destroy()
113 if (!(c = find_connection(mctx->cpu, sock))) in cb_st_chg()
226 if (mctx->cpu == 0 && in RegisterCallbacks()
240 TAILQ_INIT(&g_sockq[mctx->cpu]); in InitMonitor()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | logger.h | 25 int cpu; member
44 void InitLogThreadContext (log_thread_context *ctx, int cpu);
|
| H A D | mtcp_api.h | 25 int cpu; member
160 mtcp_core_affinitize(int cpu);
168 mtcp_create_context(int cpu);
|
| H A D | debug.h | 17 fprintf(stderr, "[CPU %d][%10s:%4d] " f, mtcp->ctx->cpu, \
42 fprintf(stderr, "[CPU %d][%10s:%4d] " f, mtcp->ctx->cpu, __FUNCTION__, __LINE__, ##m); \
54 .cpu = sched_getcpu(), \
|
| H A D | tcp.h | 13 tcp_stream *cur_stream, int cpu);
|
| H A D | mtcp.h | 306 int cpu; member
|
| /mOS-networking-stack/core/include/ |
| H A D | mtcp_api.h | 25 int cpu; member
160 mtcp_core_affinitize(int cpu);
168 mtcp_create_context(int cpu);
|
| /mOS-networking-stack/util/include/ |
| H A D | cpu.h | 5 int CoreAffinitize(int cpu);
|
| /mOS-networking-stack/samples/nat/ |
| H A D | nat.c | 77 == mctx->cpu) in assign_port()
86 TRACE_ERROR("No suitable port found! (CPU %d)\n", mctx->cpu); in assign_port()
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/src/ |
| H A D | server.c | 496 core_affinitize(int cpu) in core_affinitize() argument
505 if (cpu < 0 || cpu >= (int) n) { in core_affinitize()
515 CPU_SET_S(cpu, n, cmask); in core_affinitize()
527 numa_bitmask_setbit(bmask, cpu % 2); in core_affinitize()
623 size_t cpu = srv->cpu; in start_server() local
627 core_affinitize(cpu); in start_server()
632 srv->mctx = mtcp_create_context(cpu); in start_server()
1613 srv_states[i]->cpu = i; in main()
|
| H A D | base.h | 669 unsigned char cpu; member
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/ |
| H A D | config.guess | 644 long cpu = sysconf (_SC_CPU_VERSION);
646 switch (cpu)
704 long cpu = sysconf (_SC_CPU_VERSION);
708 if (CPU_IS_PA_RISC (cpu))
710 switch (cpu)
718 else if (CPU_IS_HP_MC68K (cpu))
|
| H A D | README | 17 low memory footprint compared to other webservers and takes care of cpu-load.
|
| /mOS-networking-stack/samples/epwget/ |
| H A D | epwget.c | 148 ctx->core = mctx->cpu; in CreateContext()
615 int core = mctx->cpu; in InitWget()
779 TRACE_INFO("run application on core %d\n", mctx->cpu); in RunApplication()
|
| H A D | epwget-mp.c | 147 ctx->core = mctx->cpu; in CreateContext()
613 int core = mctx->cpu; in InitWget()
777 TRACE_INFO("run application on core %d\n", mctx->cpu); in RunApplication()
|