Lines Matching refs:i
89 int i = 0; in HandleSignal() local
103 for (i = 0; i < g_config.mos->num_cores; i++) { in HandleSignal()
104 if (running[i]) { in HandleSignal()
106 g_pctx[i]->exit = TRUE; in HandleSignal()
110 for (i = 0; i < g_config.mos->num_cores; i++) { in HandleSignal()
111 if (g_pctx[i]) in HandleSignal()
112 g_pctx[i]->interrupt = TRUE; in HandleSignal()
115 for (i = 0; i < g_config.mos->num_cores; i++) { in HandleSignal()
116 if (running[i]) { in HandleSignal()
118 g_pctx[i]->exit = TRUE; in HandleSignal()
187 int i; in PrintThreadNetworkStats() local
189 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in PrintThreadNetworkStats()
190 ns->rx_packets[i] = mtcp->nstat.rx_packets[i] - mtcp->p_nstat.rx_packets[i]; in PrintThreadNetworkStats()
191 ns->rx_errors[i] = mtcp->nstat.rx_errors[i] - mtcp->p_nstat.rx_errors[i]; in PrintThreadNetworkStats()
192 ns->rx_bytes[i] = mtcp->nstat.rx_bytes[i] - mtcp->p_nstat.rx_bytes[i]; in PrintThreadNetworkStats()
193 ns->tx_packets[i] = mtcp->nstat.tx_packets[i] - mtcp->p_nstat.tx_packets[i]; in PrintThreadNetworkStats()
194 ns->tx_drops[i] = mtcp->nstat.tx_drops[i] - mtcp->p_nstat.tx_drops[i]; in PrintThreadNetworkStats()
195 ns->tx_bytes[i] = mtcp->nstat.tx_bytes[i] - mtcp->p_nstat.tx_bytes[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()
204 (long long unsigned)ns->rx_packets[i], in PrintThreadNetworkStats()
205 (long long unsigned)ns->rx_errors[i], in PrintThreadNetworkStats()
206 GBPS(ns->rx_bytes[i]), in PrintThreadNetworkStats()
207 (long long unsigned)ns->tx_packets[i], in PrintThreadNetworkStats()
208 GBPS(ns->tx_bytes[i])); in PrintThreadNetworkStats()
290 int i; in PrintNetworkStats() local
318 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
319 if (running[i]) { in PrintNetworkStats()
320 PrintThreadNetworkStats(g_mtcp[i], &ns); in PrintNetworkStats()
322 gflow_cnt += g_mtcp[i]->flow_cnt; 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()
341 (long long unsigned)g_nstat.rx_packets[i], in PrintNetworkStats()
342 (long long unsigned)g_nstat.rx_errors[i], in PrintNetworkStats()
343 GBPS(g_nstat.rx_bytes[i]), in PrintNetworkStats()
344 (long long unsigned)g_nstat.tx_packets[i], in PrintNetworkStats()
345 GBPS(g_nstat.tx_bytes[i])); in PrintNetworkStats()
346 total_rx_gbps += GBPS(g_nstat.rx_bytes[i]); in PrintNetworkStats()
347 total_tx_gbps += GBPS(g_nstat.tx_bytes[i]); in PrintNetworkStats()
377 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
378 if (running[i]) { in PrintNetworkStats()
379 PrintThreadRoundStats(g_mtcp[i], &rs); in PrintNetworkStats()
403 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
404 if (running[i]) { in PrintNetworkStats()
405 PrintThreadRoundTime(g_mtcp[i]); in PrintNetworkStats()
411 for (i = 0; i < g_config.mos->num_cores; i++) { in PrintNetworkStats()
412 if (running[i] && g_mtcp[i]->ep) { in PrintNetworkStats()
413 PrintEventStat(i, &g_mtcp[i]->ep->stat); in PrintNetworkStats()
472 int i; in FlushBufferedReadEvents() local
488 for (i = 0; i < mtcpq->num_events; i++) { in FlushBufferedReadEvents()
768 int i; in WritePacketsToChunks() local
780 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in WritePacketsToChunks()
781 assert(mtcp->n_sender[i] != NULL); in WritePacketsToChunks()
782 if (mtcp->n_sender[i]->control_list_cnt) in WritePacketsToChunks()
783 WriteTCPControlList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
784 if (mtcp->n_sender[i]->ack_list_cnt) in WritePacketsToChunks()
785 WriteTCPACKList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
786 if (mtcp->n_sender[i]->send_list_cnt) in WritePacketsToChunks()
787 WriteTCPDataList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
797 int cnt, i; in DestroyRemainingFlows() local
804 for (i = 0; i < NUM_BINS; i++) { in DestroyRemainingFlows()
805 TAILQ_FOREACH(walk, &ht->ht_table[i], rcvvar->he_link) { in DestroyRemainingFlows()
855 int i; in RunMainLoop() local
902 for (i = 0; i < recv_cnt; i++) { in RunMainLoop()
905 pktbuf = mtcp->iom->get_rptr(mtcp->ctx, rx_inf, i, &len); in RunMainLoop()
906 ProcessPacket(mtcp, rx_inf, i, ts, pktbuf, len); in RunMainLoop()
1083 int i; in InitializeMTCPManager() local
1174 for (i = 0; i < g_config.mos->max_concurrency; i++) { in InitializeMTCPManager()
1175 mtcp->msmap[i].monitor_stream = calloc(1, sizeof(struct mon_stream)); in InitializeMTCPManager()
1176 if (!mtcp->msmap[i].monitor_stream) { in InitializeMTCPManager()
1188 for (i = 0; i < g_config.mos->max_concurrency; i++) { in InitializeMTCPManager()
1189 mtcp->smap[i].id = i; in InitializeMTCPManager()
1190 mtcp->smap[i].socktype = MOS_SOCK_UNUSED; in InitializeMTCPManager()
1191 memset(&mtcp->smap[i].saddr, 0, sizeof(struct sockaddr_in)); in InitializeMTCPManager()
1192 mtcp->smap[i].stream = NULL; in InitializeMTCPManager()
1193 TAILQ_INSERT_TAIL(&mtcp->free_smap, &mtcp->smap[i], link); in InitializeMTCPManager()
1198 for (i = 0; i < g_config.mos->max_concurrency; i++) { in InitializeMTCPManager()
1199 mtcp->msmap[i].id = i; in InitializeMTCPManager()
1200 mtcp->msmap[i].socktype = MOS_SOCK_UNUSED; in InitializeMTCPManager()
1201 memset(&mtcp->msmap[i].saddr, 0, sizeof(struct sockaddr_in)); in InitializeMTCPManager()
1202 TAILQ_INSERT_TAIL(&mtcp->free_msmap, &mtcp->msmap[i], link); in InitializeMTCPManager()
1266 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in InitializeMTCPManager()
1267 mtcp->n_sender[i] = CreateMTCPSender(i); in InitializeMTCPManager()
1268 if (!mtcp->n_sender[i]) { in InitializeMTCPManager()
1490 int ret, i; in mtcp_free_context() local
1498 for (i = 0; i < g_config.mos->max_concurrency; i++) { in mtcp_free_context()
1499 if (mtcp->smap[i].socktype == MOS_SOCK_STREAM) { in mtcp_free_context()
1501 i, TCPStateToString(mtcp->smap[i].stream)); in mtcp_free_context()
1503 DumpStream(mtcp, mtcp->smap[i].stream); in mtcp_free_context()
1505 mtcp_close(mctx, i); in mtcp_free_context()
1533 for (i = 0; i < num_cpus; i++) { in mtcp_free_context()
1534 if (i != mctx->cpu && running[i]) { in mtcp_free_context()
1535 printer = i; in mtcp_free_context()
1591 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in mtcp_free_context()
1592 DestroyMTCPSender(mtcp->n_sender[i]); in mtcp_free_context()
1643 int i, j; in mtcp_getconf() local
1660 i = 0; in mtcp_getconf()
1665 conf->app_argv[i][j] = app_conf->app_argv[j]; in mtcp_getconf()
1666 conf->app_argc[i] = app_conf->app_argc; in mtcp_getconf()
1667 conf->app_cpu_mask[i] = app_conf->cpu_mask; in mtcp_getconf()
1668 i++; in mtcp_getconf()
1670 conf->num_app = i; in mtcp_getconf()
1699 int i; in mtcp_init() local
1713 for (i = 0; i < num_cpus; i++) { in mtcp_init()
1714 g_mtcp[i] = NULL; in mtcp_init()
1715 running[i] = FALSE; in mtcp_init()
1716 sigint_cnt[i] = 0; in mtcp_init()
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()
1744 if (!ap[i]) { in mtcp_init()
1746 i); in mtcp_init()
1781 int i; in mtcp_destroy() local
1793 for (i = 0; i < g_config.mos->netdev_table->num; i++) in mtcp_destroy()
1794 DestroyAddressPool(ap[i]); in mtcp_destroy()