| /f-stack/dpdk/lib/librte_distributor/ |
| H A D | rte_distributor_single.c | 127 if (unlikely(d->backlog[wkr].count != 0)) { in handle_worker_shutdown()
140 struct rte_distributor_backlog *bl = &d->backlog[wkr]; in handle_worker_shutdown()
177 if (d->backlog[wkr].count) in process_returns()
180 backlog_pop(&d->backlog[wkr]), in process_returns()
261 if (add_to_backlog(&d->backlog[worker], in rte_distributor_process_single()
268 (d->backlog[wkr].count || next_mb)) { in rte_distributor_process_single()
270 if (d->backlog[wkr].count) in rte_distributor_process_single()
273 backlog_pop(&d->backlog[wkr]), in rte_distributor_process_single()
300 if (d->backlog[wkr].count && in rte_distributor_process_single()
312 backlog_pop(&d->backlog[wkr]), in rte_distributor_process_single()
[all …]
|
| H A D | rte_distributor.c | 259 bl = &d->backlog[i]; in find_match_scalar()
318 for (i = 0; i < d->backlog[wkr].count; i++) in handle_worker_shutdown()
320 (d->backlog[wkr].pkts[i] >> RTE_DISTRIB_FLAG_BITS)); in handle_worker_shutdown()
322 d->backlog[wkr].count = 0; in handle_worker_shutdown()
327 d->backlog[wkr].tags[i] = 0; in handle_worker_shutdown()
418 for (i = 0; i < d->backlog[wkr].count; i++) { in release()
419 d->bufs[wkr].bufptr64[i] = d->backlog[wkr].pkts[i] | in release()
421 d->in_flight_tags[wkr][i] = d->backlog[wkr].tags[i]; in release()
429 d->backlog[wkr].count = 0; in release()
544 &d->backlog[matches[j]-1]; in rte_distributor_process()
[all …]
|
| H A D | distributor_private.h | 97 struct rte_distributor_backlog backlog[RTE_DISTRIB_MAX_WORKERS]; member
148 struct rte_distributor_backlog backlog[RTE_DISTRIB_MAX_WORKERS] member
|
| H A D | rte_distributor_match_sse.c | 43 bl = &d->backlog[i]; in find_match_vec()
|
| /f-stack/app/redis-5.0.5/src/ |
| H A D | anet.h | 61 int anetTcpServer(char *err, int port, char *bindaddr, int backlog);
62 int anetTcp6Server(char *err, int port, char *bindaddr, int backlog);
63 int anetUnixServer(char *err, char *path, mode_t perm, int backlog);
|
| H A D | anet.c | 449 static int anetListen(char *err, int s, struct sockaddr *sa, socklen_t len, int backlog) { in anetListen() argument
456 if (listen(s, backlog) == -1) { in anetListen()
474 static int _anetTcpServer(char *err, int port, char *bindaddr, int af, int backlog) in _anetTcpServer() argument
496 if (anetListen(err,s,p->ai_addr,p->ai_addrlen,backlog) == ANET_ERR) s = ANET_ERR; in _anetTcpServer()
512 int anetTcpServer(char *err, int port, char *bindaddr, int backlog) in anetTcpServer() argument
514 return _anetTcpServer(err, port, bindaddr, AF_INET, backlog); in anetTcpServer()
517 int anetTcp6Server(char *err, int port, char *bindaddr, int backlog) in anetTcp6Server() argument
519 return _anetTcpServer(err, port, bindaddr, AF_INET6, backlog); in anetTcp6Server()
522 int anetUnixServer(char *err, char *path, mode_t perm, int backlog) in anetUnixServer() argument
533 if (anetListen(err,s,(struct sockaddr*)&sa,sizeof(sa),backlog) == ANET_ERR) in anetUnixServer()
|
| H A D | anet_ff.c | 234 listen(int sockfd, int backlog) in listen() argument
238 return real_listen(sockfd, backlog); in listen()
242 return ff_listen(sockfd, backlog); in listen()
244 return real_listen(sockfd, backlog); in listen()
|
| /f-stack/app/micro_thread/ |
| H A D | ff_hook.cpp | 142 int ff_hook_listen(int fd, int backlog) in ff_hook_listen() argument
145 return ff_listen(fd, backlog); in ff_hook_listen()
147 return mt_real_func(listen)(fd, backlog); in ff_hook_listen()
|
| H A D | mt_sys_hook.cpp | 336 int listen(int sockfd, int backlog) in listen() argument
341 return mt_real_func(listen)(sockfd, backlog); in listen()
344 return ff_hook_listen(sockfd, backlog); in listen()
|
| H A D | ff_hook.h | 42 int ff_hook_listen(int fd, int backlog);
|
| H A D | mt_sys_hook.h | 38 typedef int (*func_listen)(int sockfd, int backlog);
|
| /f-stack/app/nginx-1.16.1/src/stream/ |
| H A D | ngx_stream_core_module.c | 599 ngx_uint_t i, n, backlog; in ngx_stream_core_listen() local
631 ls->backlog = NGX_LISTEN_BACKLOG; in ngx_stream_core_listen()
641 backlog = 0; in ngx_stream_core_listen()
658 ls->backlog = ngx_atoi(value[i].data + 8, value[i].len - 8); in ngx_stream_core_listen()
661 if (ls->backlog == NGX_ERROR || ls->backlog == 0) { in ngx_stream_core_listen()
667 backlog = 1; in ngx_stream_core_listen()
864 if (backlog) { in ngx_stream_core_listen()
|
| /f-stack/app/redis-5.0.5/tests/integration/ |
| H A D | replication-psync.tcl | 143 test_psync {no backlog} 6 100 3600 0.5 {
151 test_psync {backlog expired} 3 100000000 1 3 {
|
| /f-stack/app/redis-5.0.5/deps/jemalloc/include/jemalloc/internal/ |
| H A D | arena_structs_b.h | 64 size_t backlog[SMOOTHSTEP_NSTEPS]; member
|
| /f-stack/app/nginx-1.16.1/src/event/modules/ |
| H A D | ngx_ff_module.c | 370 listen(int sockfd, int backlog) in listen() argument
374 return ff_listen(sockfd, backlog); in listen()
377 return SYSCALL(listen)(sockfd, backlog); in listen()
|
| /f-stack/app/nginx-1.16.1/src/mail/ |
| H A D | ngx_mail_core_module.c | 352 ls->backlog = NGX_LISTEN_BACKLOG; in ngx_mail_core_listen()
390 ls->backlog = ngx_atoi(value[i].data + 8, value[i].len - 8); in ngx_mail_core_listen()
393 if (ls->backlog == NGX_ERROR || ls->backlog == 0) { in ngx_mail_core_listen()
|
| H A D | ngx_mail.c | 335 ls->backlog = addr[i].opt.backlog; in ngx_mail_optimize_servers()
|
| /f-stack/tools/compat/include/sys/ |
| H A D | protosw.h | 199 int (*pru_listen)(struct socket *so, int backlog,
251 int pru_listen_notsupp(struct socket *so, int backlog, struct thread *td);
|
| H A D | socketvar.h | 435 int solisten(struct socket *so, int backlog, struct thread *td);
436 void solisten_proto(struct socket *so, int backlog);
|
| /f-stack/freebsd/sys/ |
| H A D | protosw.h | 201 int (*pru_listen)(struct socket *so, int backlog,
254 int pru_listen_notsupp(struct socket *so, int backlog, struct thread *td);
|
| H A D | socketvar.h | 435 int solisten(struct socket *so, int backlog, struct thread *td);
436 void solisten_proto(struct socket *so, int backlog);
|
| /f-stack/app/redis-5.0.5/ |
| H A D | redis.conf | 101 tcp-backlog 511
|
| /f-stack/app/nginx-1.16.1/src/core/ |
| H A D | ngx_connection.c | 124 ls->backlog = NGX_LISTEN_BACKLOG; in ngx_create_listening()
259 ls[i].backlog = NGX_LISTEN_BACKLOG; in ngx_set_inherited_sockets()
711 if (listen(s, ls[i].backlog) == -1) { in ngx_open_listening_sockets()
723 &ls[i].addr_text, ls[i].backlog); in ngx_open_listening_sockets()
920 if (listen(ls[i].fd, ls[i].backlog) == -1) { in ngx_configure_listening_sockets()
923 &ls[i].addr_text, ls[i].backlog); in ngx_configure_listening_sockets()
|
| H A D | ngx_connection.h | 28 int backlog; member
|
| /f-stack/lib/ |
| H A D | ff_api.h | 75 int ff_listen(int s, int backlog);
|