Lines Matching refs:i
185 int i; in HandleReadEvent() local
223 for (i = 0; i < nfiles; i++) { in HandleReadEvent()
224 if (strcmp(sv->fname, fcache[i].fullname) == 0) { in HandleReadEvent()
225 sv->fsize = fcache[i].size; in HandleReadEvent()
226 sv->fidx = i; in HandleReadEvent()
476 int i, ret; in RunServer() local
499 for (i = 0; i < nevents; i++) { in RunServer()
501 if (events[i].data.sock == ctx->listener) { in RunServer()
505 } else if (events[i].events & MOS_EPOLLERR) { in RunServer()
511 core, events[i].data.sock); in RunServer()
512 if (mtcp_getsockopt(mctx, events[i].data.sock, in RunServer()
516 events[i].data.sock, strerror(err)); in RunServer()
520 strerror(errno), events[i].data.sock); in RunServer()
523 CloseConnection(ctx, events[i].data.sock, in RunServer()
524 &ctx->svars[events[i].data.sock]); in RunServer()
526 } else if (events[i].events & MOS_EPOLLIN) { in RunServer()
527 ret = HandleReadEvent(ctx, events[i].data.sock, in RunServer()
528 &ctx->svars[events[i].data.sock]); in RunServer()
532 CloseConnection(ctx, events[i].data.sock, in RunServer()
533 &ctx->svars[events[i].data.sock]); in RunServer()
537 CloseConnection(ctx, events[i].data.sock, in RunServer()
538 &ctx->svars[events[i].data.sock]); in RunServer()
542 } else if (events[i].events & MOS_EPOLLOUT) { in RunServer()
543 struct server_vars *sv = &ctx->svars[events[i].data.sock]; in RunServer()
545 SendUntilAvailable(ctx, events[i].data.sock, sv); in RunServer()
548 events[i].data.sock); in RunServer()
615 int ret, i; in main() local
646 for (i = 0; i < core_limit; i++) { in main()
647 cores[i] = i; in main()
650 if ((g_mcfg.cpu_mask & (1L << i)) && in main()
651 pthread_create(&mtcp_thread[i], NULL, RunMTCP, (void *)&cores[i])) { in main()
658 for (i = 0; i < core_limit; i++) { in main()
659 if (g_mcfg.cpu_mask & (1L << i)) in main()
660 pthread_join(mtcp_thread[i], NULL); in main()
661 TRACE_INFO("Message test thread %d joined.\n", i); in main()