Lines Matching refs:mos
103 for (i = 0; i < g_config.mos->num_cores; i++) { in HandleSignal()
110 for (i = 0; i < g_config.mos->num_cores; i++) { in HandleSignal()
115 for (i = 0; i < g_config.mos->num_cores; i++) { in HandleSignal()
189 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in PrintThreadNetworkStats()
197 if (g_config.mos->netdev_table->ent[i]->stat_print) { in PrintThreadNetworkStats()
202 g_config.mos->netdev_table->ent[i]->dev_name, in PrintThreadNetworkStats()
318 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
323 for (j = 0; j < g_config.mos->netdev_table->num; j++) { in PrintNetworkStats()
335 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in PrintNetworkStats()
336 if (g_config.mos->netdev_table->ent[i]->stat_print) { in PrintNetworkStats()
340 g_config.mos->netdev_table->ent[i]->dev_name, in PrintNetworkStats()
377 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
403 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
411 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
604 if (g_config.mos->tcp_timeout > 0) in HandleApplicationCalls()
697 if (g_config.mos->tcp_timeout > 0) in HandleApplicationCalls()
767 int thresh = g_config.mos->max_concurrency; in WritePacketsToChunks()
780 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in WritePacketsToChunks()
897 for (rx_inf = 0; rx_inf < g_config.mos->netdev_table->num; rx_inf++) { in RunMainLoop()
942 thresh = g_config.mos->max_concurrency; in RunMainLoop()
949 thresh = g_config.mos->max_concurrency; in RunMainLoop()
954 if (g_config.mos->tcp_timeout > 0 && ts != ts_prev) { in RunMainLoop()
1003 int num_dev = g_config.mos->netdev_table->num; in RunMainLoop()
1116 sizeof(tcpbufseg_t) * g_config.mos->max_concurrency * in InitializeMTCPManager()
1117 ((g_config.mos->rmem_size - 1) / UNITBUFSIZE + 1), 0))) { in InitializeMTCPManager()
1122 sizeof(struct sockent) * g_config.mos->max_concurrency * 3, 0))) { in InitializeMTCPManager()
1128 sizeof(struct timer) * g_config.mos->max_concurrency * 10, 0))) { in InitializeMTCPManager()
1134 sizeof(tcp_stream) * g_config.mos->max_concurrency, IS_HUGEPAGE); in InitializeMTCPManager()
1140 sizeof(struct tcp_recv_vars) * g_config.mos->max_concurrency, IS_HUGEPAGE); in InitializeMTCPManager()
1146 sizeof(struct tcp_send_vars) * g_config.mos->max_concurrency, IS_HUGEPAGE); in InitializeMTCPManager()
1152 mtcp->rbm_snd = SBManagerCreate(g_config.mos->wmem_size, g_config.mos->no_ring_buffers, in InitializeMTCPManager()
1153 g_config.mos->max_concurrency); in InitializeMTCPManager()
1159 mtcp->smap = (socket_map_t)calloc(g_config.mos->max_concurrency, sizeof(struct socket_map)); in InitializeMTCPManager()
1167 mtcp->msmap = (socket_map_t)calloc(g_config.mos->max_concurrency, sizeof(struct socket_map)); in InitializeMTCPManager()
1174 for (i = 0; i < g_config.mos->max_concurrency; i++) { in InitializeMTCPManager()
1188 for (i = 0; i < g_config.mos->max_concurrency; i++) { in InitializeMTCPManager()
1198 for (i = 0; i < g_config.mos->max_concurrency; i++) { in InitializeMTCPManager()
1210 g_config.mos->mos_log, ctx->cpu); in InitializeMTCPManager()
1225 mtcp->sendq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()
1230 mtcp->ackq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()
1235 mtcp->closeq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()
1240 mtcp->closeq_int = CreateInternalStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()
1245 mtcp->resetq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()
1250 mtcp->resetq_int = CreateInternalStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()
1255 mtcp->destroyq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()
1266 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in InitializeMTCPManager()
1374 if (cpu >= g_config.mos->num_cores) { in mtcp_create_context()
1377 cpu, g_config.mos->num_cores); in mtcp_create_context()
1498 for (i = 0; i < g_config.mos->max_concurrency; i++) { in mtcp_free_context()
1591 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in mtcp_free_context()
1650 conf->num_cores = g_config.mos->num_cores; in mtcp_getconf()
1651 conf->max_concurrency = g_config.mos->max_concurrency; in mtcp_getconf()
1652 conf->cpu_mask = g_config.mos->cpu_mask; in mtcp_getconf()
1654 conf->rcvbuf_size = g_config.mos->rmem_size; in mtcp_getconf()
1655 conf->sndbuf_size = g_config.mos->wmem_size; in mtcp_getconf()
1657 conf->tcp_timewait = g_config.mos->tcp_tw_interval; in mtcp_getconf()
1658 conf->tcp_timeout = g_config.mos->tcp_timeout; in mtcp_getconf()
1681 g_config.mos->num_cores = conf->num_cores; in mtcp_setconf()
1682 g_config.mos->max_concurrency = conf->max_concurrency; in mtcp_setconf()
1684 g_config.mos->rmem_size = conf->rcvbuf_size; in mtcp_setconf()
1685 g_config.mos->wmem_size = conf->sndbuf_size; in mtcp_setconf()
1687 g_config.mos->tcp_tw_interval = conf->tcp_timewait; in mtcp_setconf()
1688 g_config.mos->tcp_timeout = conf->tcp_timeout; in mtcp_setconf()
1742 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in mtcp_init()
1743 ap[i] = CreateAddressPool(g_config.mos->netdev_table->ent[i]->ip_addr, 1); in mtcp_init()
1793 for (i = 0; i < g_config.mos->netdev_table->num; i++) in mtcp_destroy()