Searched refs:max_concurrency (Results 1 – 14 of 14) sorted by relevance
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()1153 g_config.mos->max_concurrency); 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()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()[all …]
140 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_getsockname()185 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_getsockopt()273 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_setsockopt()474 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_setsock_nonblock()503 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_ioctl()567 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_monitor()598 g_config.mos->max_concurrency); in mtcp_monitor()691 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_bind()753 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_listen()831 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_accept()[all …]
254 if (epid < 0 || epid >= g_config.mos->max_concurrency) { in mtcp_epoll_ctl()260 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_epoll_ctl()355 if (epid < 0 || epid >= g_config.mos->max_concurrency) { in mtcp_epoll_wait()
183 if (ap->num_entry < g_config.mos->max_concurrency) { in CreateAddressPoolPerCore()186 ap->num_entry, g_config.mos->max_concurrency); in CreateAddressPoolPerCore()
170 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in GetSocket()
111 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_bind_monitor_filter()196 if (msock < 0 || msock >= g_config.mos->max_concurrency) { in mtcp_set_uctx()227 if (msock < 0 || msock >= g_config.mos->max_concurrency) { in mtcp_get_uctx()865 if (sockfd < 0 || sockfd >= g_config.mos->max_concurrency) { in mtcp_getpeername()
200 else if (TRY_ASSIGN_NUM(max_concurrency, conf, item, value)); in FeedMosConfLine()543 printf("| max_concurrency: %d\n", conf->max_concurrency); in MosConfPrint()610 conf->max_concurrency = 100000; in InitMosBlock()
444 g_config.mos->max_concurrency, mtcp->flow_cnt);
79 int max_concurrency; /**< number of concurrent flows per core*/ member
134 int max_concurrency; member
589 mcfg.max_concurrency = max_fds; in GlbInitWget()
587 mcfg.max_concurrency = max_fds; in GlbInitWget()
1603 mcfg.max_concurrency = mcfg.max_num_buffers = srv_states[0]->max_conns; in main()