| /net/sched/ |
| D | sch_gred.c | 40 u32 backlog; /* bytes on the virtualQ */ member
118 return sch->qstats.backlog; in gred_backlog()
120 return q->backlog; in gred_backlog()
232 if (q->backlog + qdisc_pkt_len(skb) <= q->limit) { in gred_enqueue()
233 q->backlog += qdisc_pkt_len(skb); in gred_enqueue()
261 q->backlog -= qdisc_pkt_len(skb); in gred_dequeue()
264 if (!sch->qstats.backlog) in gred_dequeue()
267 if (!q->backlog) in gred_dequeue()
293 q->backlog -= len; in gred_drop()
297 if (!sch->qstats.backlog) in gred_drop()
[all …]
|
| D | sch_sfq.c | 113 unsigned int backlog; member
330 slot->backlog -= len; in sfq_drop()
397 slot->backlog = 0; /* should already be 0 anyway... */ in sfq_enqueue()
404 slot->backlog); in sfq_enqueue()
455 sch->qstats.backlog -= delta; in sfq_enqueue()
456 slot->backlog -= delta; in sfq_enqueue()
465 slot->backlog += qdisc_pkt_len(skb); in sfq_enqueue()
524 slot->backlog -= qdisc_pkt_len(skb); in sfq_dequeue()
576 slot->backlog = 0; in sfq_rehash()
607 slot->backlog); in sfq_rehash()
[all …]
|
| D | sch_red.c | 67 child->qstats.backlog); in red_enqueue()
214 q->qdisc->qstats.backlog); in red_change()
272 sch->qstats.backlog = q->qdisc->qstats.backlog; in red_dump()
|
| D | sch_mqprio.c | 239 sch->qstats.backlog += qdisc->qstats.backlog; in mqprio_dump()
350 qstats.backlog += qdisc->qstats.backlog; in mqprio_dump_class_stats()
|
| D | sch_hhf.c | 421 prev_backlog = sch->qstats.backlog; in hhf_enqueue()
430 qdisc_tree_reduce_backlog(sch, 1, prev_backlog - sch->qstats.backlog); in hhf_enqueue()
590 prev_backlog = sch->qstats.backlog; in hhf_change()
597 prev_backlog - sch->qstats.backlog); in hhf_change()
|
| D | sch_fq_codel.c | 204 prev_backlog = sch->qstats.backlog; in fq_codel_enqueue()
213 qdisc_tree_reduce_backlog(sch, 1, prev_backlog - sch->qstats.backlog); in fq_codel_enqueue()
262 prev_backlog = sch->qstats.backlog; in fq_codel_dequeue()
557 qs.backlog = q->backlogs[idx]; in fq_codel_dump_class_stats()
|
| D | sch_mq.c | 115 sch->qstats.backlog += qdisc->qstats.backlog; in mq_dump()
|
| D | sch_tbf.c | 405 q->qdisc->qstats.backlog); in tbf_change()
459 sch->qstats.backlog = q->qdisc->qstats.backlog; in tbf_dump()
|
| D | sch_pie.c | 119 if (sch->qstats.backlog < 2 * mtu) in drop_early()
249 int qlen = sch->qstats.backlog; /* current queue size in bytes */ in pie_process_dequeue()
314 u32 qlen = sch->qstats.backlog; /* queue size in bytes */ in calculate_probability()
|
| D | sch_hfsc.c | 898 unsigned int backlog = cl->qdisc->qstats.backlog; in hfsc_purge_queue() local
901 qdisc_tree_reduce_backlog(cl->qdisc, len, backlog); in hfsc_purge_queue()
1370 cl->qstats.backlog = cl->qdisc->qstats.backlog; in hfsc_dump_class_stats()
1565 sch->qstats.backlog = 0; in hfsc_dump_qdisc()
1568 sch->qstats.backlog += cl->qdisc->qstats.backlog; in hfsc_dump_qdisc()
|
| D | sch_htb.c | 960 sch->qstats.backlog -= len; in htb_drop()
995 sch->qstats.backlog = 0; in htb_reset()
1293 unsigned int backlog = cl->un.leaf.q->qstats.backlog; in htb_delete() local
1296 qdisc_tree_reduce_backlog(cl->un.leaf.q, qlen, backlog); in htb_delete()
1430 unsigned int backlog = parent->un.leaf.q->qstats.backlog; in htb_change_class() local
1434 qdisc_tree_reduce_backlog(parent->un.leaf.q, qlen, backlog); in htb_change_class()
|
| D | sch_drr.c | 56 unsigned int backlog = cl->qdisc->qstats.backlog; in drr_purge_queue() local
59 qdisc_tree_reduce_backlog(cl->qdisc, len, backlog); in drr_purge_queue()
|
| D | sch_multiq.c | 222 child->qstats.backlog); in multiq_tune()
244 old->qstats.backlog); in multiq_tune()
|
| D | sch_prio.c | 194 qdisc_tree_reduce_backlog(child, child->q.qlen, child->qstats.backlog); in prio_tune()
215 old->qstats.backlog); in prio_tune()
|
| D | sch_sfb.c | 522 q->qdisc->qstats.backlog); in sfb_change()
574 sch->qstats.backlog = q->qdisc->qstats.backlog; in sfb_dump()
|
| D | sch_plug.c | 93 if (likely(sch->qstats.backlog + skb->len <= q->limit)) { in plug_enqueue()
|
| D | sch_fifo.c | 24 if (likely(sch->qstats.backlog + qdisc_pkt_len(skb) <= sch->limit)) in bfifo_enqueue()
|
| /net/core/ |
| D | gen_stats.c | 231 qstats->backlog += qcpu->backlog; in __gnet_stats_copy_queue_cpu()
247 qstats->backlog = q->backlog; in __gnet_stats_copy_queue()
282 d->tc_stats.backlog = qstats.backlog; in gnet_stats_copy_queue()
|
| /net/sunrpc/ |
| D | xprt.c | 945 xprt->stat.bklog_u += xprt->backlog.qlen; in xprt_transmit()
967 rpc_sleep_on(&xprt->backlog, task, NULL); in xprt_add_backlog()
972 if (rpc_wake_up_next(&xprt->backlog) == NULL) in xprt_wake_up_backlog()
984 rpc_sleep_on(&xprt->backlog, task, NULL); in xprt_throttle_congested()
1285 rpc_init_priority_wait_queue(&xprt->backlog, "xprt_backlog"); in xprt_init()
1358 rpc_destroy_wait_queue(&xprt->backlog); in xprt_destroy()
|
| /net/dccp/ |
| D | proto.c | 241 static inline int dccp_listen_start(struct sock *sk, int backlog) in dccp_listen_start() argument
249 return inet_csk_listen_start(sk, backlog); in dccp_listen_start()
925 int inet_dccp_listen(struct socket *sock, int backlog) in inet_dccp_listen() argument
949 err = dccp_listen_start(sk, backlog); in inet_dccp_listen()
953 sk->sk_max_ack_backlog = backlog; in inet_dccp_listen()
|
| /net/rxrpc/ |
| D | af_rxrpc.c | 188 static int rxrpc_listen(struct socket *sock, int backlog) in rxrpc_listen() argument
194 _enter("%p,%d", rx, backlog); in rxrpc_listen()
209 sk->sk_max_ack_backlog = backlog; in rxrpc_listen()
|
| /net/atm/ |
| D | svc.c | 281 static int svc_listen(struct socket *sock, int backlog) in svc_listen() argument
314 sk->sk_max_ack_backlog = backlog > 0 ? backlog : ATM_BACKLOG_DEFAULT; in svc_listen()
|
| /net/llc/ |
| D | af_llc.c | 505 static int llc_ui_listen(struct socket *sock, int backlog) in llc_ui_listen() argument
520 if (!(unsigned int)backlog) /* BSDism */ in llc_ui_listen()
521 backlog = 1; in llc_ui_listen()
522 sk->sk_max_ack_backlog = backlog; in llc_ui_listen()
|
| /net/nfc/ |
| D | llcp_sock.c | 199 static int llcp_sock_listen(struct socket *sock, int backlog) in llcp_sock_listen() argument
204 pr_debug("sk %p backlog %d\n", sk, backlog); in llcp_sock_listen()
214 sk->sk_max_ack_backlog = backlog; in llcp_sock_listen()
|
| /net/bluetooth/rfcomm/ |
| D | sock.c | 424 static int rfcomm_sock_listen(struct socket *sock, int backlog) in rfcomm_sock_listen() argument
429 BT_DBG("sk %p backlog %d", sk, backlog); in rfcomm_sock_listen()
464 sk->sk_max_ack_backlog = backlog; in rfcomm_sock_listen()
|