| /mOS-networking-stack/core/src/ |
| H A D | addr_pool.c | 46 int i, j, cnt; in CreateAddressPool() local
84 cnt = 0; in CreateAddressPool()
95 if ((++cnt) >= num_entry) in CreateAddressPool()
99 ap->num_entry = cnt; in CreateAddressPool()
100 ap->num_free = cnt; in CreateAddressPool()
114 int i, j, cnt; in CreateAddressPoolPerCore() local
157 cnt = 0; in CreateAddressPoolPerCore()
162 if (cnt >= num_entry) in CreateAddressPoolPerCore()
175 cnt++; in CreateAddressPoolPerCore()
179 ap->num_entry = cnt; in CreateAddressPoolPerCore()
[all …]
|
| H A D | logger.c | 116 int cnt; in ThreadLogMain() local
126 cnt = 0; in ThreadLogMain()
128 if (++cnt > NUM_LOG_BUFF) { in ThreadLogMain()
130 ctx->cpu, cnt); in ThreadLogMain()
153 cnt = 0; in ThreadLogMain()
155 if (++cnt > NUM_LOG_BUFF) { in ThreadLogMain()
157 "Exceed NUM_LOG_BUFF %d in final loop.\n", ctx->cpu, cnt); in ThreadLogMain()
|
| H A D | timer.c | 358 int cnt = 0; in RearrangeRTOStore() local
376 cnt++; in RearrangeRTOStore()
385 int cnt; in CheckRtmTimeout() local
393 cnt = 0; in CheckRtmTimeout()
425 if (cnt > thresh) { in CheckRtmTimeout()
444 int cnt; in CheckTimewaitExpire() local
448 cnt = 0; in CheckTimewaitExpire()
452 if (++cnt > thresh) in CheckTimewaitExpire()
457 cnt, walk->s_id); in CheckTimewaitExpire()
497 int cnt; in CheckConnectionTimeout() local
[all …]
|
| H A D | tcp_out.c | 577 int cnt = 0; in WriteTCPControlList() local
583 cnt = 0; in WriteTCPControlList()
587 if (++cnt > thresh) in WriteTCPControlList()
618 return cnt; in WriteTCPControlList()
627 int cnt = 0; in WriteTCPDataList() local
631 cnt = 0; in WriteTCPDataList()
635 if (++cnt > thresh) in WriteTCPDataList()
708 return cnt; in WriteTCPDataList()
718 int cnt = 0; in WriteTCPACKList() local
722 cnt = 0; in WriteTCPACKList()
[all …]
|
| H A D | eventpoll.c | 347 int i, cnt, ret; in mtcp_epoll_wait() local
460 cnt = 0; in mtcp_epoll_wait()
462 for (i = 0; i < num_events && cnt < maxevents; i++) { in mtcp_epoll_wait()
473 events[cnt++] = eq->events[eq->start].ev; in mtcp_epoll_wait()
500 for (i = 0; i < num_events && cnt < maxevents; i++) { in mtcp_epoll_wait()
511 events[cnt++] = eq->events[eq->start].ev; in mtcp_epoll_wait()
535 if (cnt == 0 && timeout != 0) in mtcp_epoll_wait()
540 return cnt; in mtcp_epoll_wait()
|
| H A D | core.c | 152 counter->cnt = 0; in InitStatCounter()
161 counter->cnt++; in UpdateStatCounter()
172 return counter->cnt ? (counter->sum / counter->cnt) : 0; in GetAverageStat()
558 int cnt, max_cnt; in HandleApplicationCalls() local
665 cnt = 0; in HandleApplicationCalls()
667 while (cnt++ < max_cnt) { in HandleApplicationCalls()
731 cnt = 0; in HandleApplicationCalls()
797 int cnt, i; in DestroyRemainingFlows() local
799 cnt = 0; in DestroyRemainingFlows()
812 cnt++; in DestroyRemainingFlows()
[all …]
|
| H A D | dpdk_module.c | 241 int cnt = dpc->wmbufs[nif].len; in dpdk_send_pkts() local
244 mtcp->nstat.tx_packets[nif] += cnt; in dpdk_send_pkts()
260 pkts, cnt); in dpdk_send_pkts()
262 cnt -= ret; in dpdk_send_pkts()
264 } while (cnt > 0); in dpdk_send_pkts()
|
| H A D | netmap_module.c | 170 int cnt = MAX_PKT_BURST; in netmap_recv_pkts() local
174 for (c = 0; c < n && cnt != got && npc->dev_poll_flag[ifidx]; c++) { in netmap_recv_pkts()
182 for ( ; !nm_ring_empty(ring) && cnt != got; got++) { in netmap_recv_pkts()
|
| H A D | config.c | 730 int flags, num, cnt, use, metric; in FetchRouteKernelEntries() local
746 &flags, &cnt, &use, &metric, in FetchRouteKernelEntries()
|
| /mOS-networking-stack/util/ |
| H A D | rss.c | 232 CheckRSSHash(int cnt, const char* src_ip, const char* dest_ip, int32_t src_port, int32_t dest_port) in CheckRSSHash() argument
250 for( i =0; i < cnt; i++){ in CheckRSSHash()
315 int cnt = -1; in main() local
322 cnt = atoi(optarg); in main()
342 if (cnt < 1) { in main()
350 CheckRSSHash(cnt, srcIP, destIP, sport, dport); in main()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | netmap_user.h | 952 nm_dispatch(struct nm_desc *d, int cnt, nm_cb_t cb, u_char *arg) in nm_dispatch() argument
957 if (cnt == 0) in nm_dispatch()
958 cnt = -1; in nm_dispatch()
963 for (c=0; c < n && cnt != got; c++) { in nm_dispatch()
971 for ( ; !nm_ring_empty(ring) && cnt != got; got++) { in nm_dispatch()
|
| H A D | stat.h | 31 uint64_t cnt; member
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/src/ |
| H A D | connections.c | 1305 int cnt; local
1323 if (-1 == (cnt = mtcp_accept(srv->mctx, srv_socket->fd, NULL, NULL))) {
1326 if (-1 == (cnt = accept(srv_socket->fd, (struct sockaddr *) &cnt_addr, &cnt_len))) {
1353 "appected()", cnt);
1359 con->fd = cnt;
1392 if (1 != (SSL_set_fd(con->ssl, cnt))) {
|
| H A D | lemon.c | 1807 int cnt = 0; in OptNArgs() local
1812 if( dashdash || !ISOPT(argv[i]) ) cnt++; in OptNArgs()
1816 return cnt; in OptNArgs()
|