Lines Matching refs:max_concurrency

767 	int thresh = g_config.mos->max_concurrency;  in WritePacketsToChunks()
942 thresh = g_config.mos->max_concurrency; in RunMainLoop()
949 thresh = g_config.mos->max_concurrency; in RunMainLoop()
1116 sizeof(tcpbufseg_t) * g_config.mos->max_concurrency * 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()
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()
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()
1498 for (i = 0; i < g_config.mos->max_concurrency; i++) { in mtcp_free_context()
1651 conf->max_concurrency = g_config.mos->max_concurrency; in mtcp_getconf()
1682 g_config.mos->max_concurrency = conf->max_concurrency; in mtcp_setconf()