Home
last modified time | relevance | path

Searched refs:backlog (Results 1 – 25 of 178) sorted by relevance

12345678

/Linux-v4.19/drivers/crypto/ccp/
Dccp-crypto-main.c58 struct list_head *backlog; member
100 struct ccp_crypto_cmd *crypto_cmd, struct ccp_crypto_cmd **backlog) in ccp_crypto_cmd_complete() argument
105 *backlog = NULL; in ccp_crypto_cmd_complete()
124 if (req_queue.backlog != &req_queue.cmds) { in ccp_crypto_cmd_complete()
126 if (req_queue.backlog == &crypto_cmd->entry) in ccp_crypto_cmd_complete()
127 req_queue.backlog = crypto_cmd->entry.next; in ccp_crypto_cmd_complete()
129 *backlog = container_of(req_queue.backlog, in ccp_crypto_cmd_complete()
131 req_queue.backlog = req_queue.backlog->next; in ccp_crypto_cmd_complete()
134 if (req_queue.backlog == &crypto_cmd->entry) in ccp_crypto_cmd_complete()
135 req_queue.backlog = crypto_cmd->entry.next; in ccp_crypto_cmd_complete()
[all …]
Dccp-dev.c297 list_add_tail(&cmd->entry, &ccp->backlog); in ccp_enqueue_cmd()
360 struct ccp_cmd *backlog = NULL; in ccp_dequeue_cmd() local
385 if (!list_empty(&ccp->backlog)) { in ccp_dequeue_cmd()
386 backlog = list_first_entry(&ccp->backlog, struct ccp_cmd, in ccp_dequeue_cmd()
388 list_del(&backlog->entry); in ccp_dequeue_cmd()
393 if (backlog) { in ccp_dequeue_cmd()
394 INIT_WORK(&backlog->work, ccp_do_cmd_backlog); in ccp_dequeue_cmd()
395 schedule_work(&backlog->work); in ccp_dequeue_cmd()
470 INIT_LIST_HEAD(&ccp->backlog); in ccp_alloc_struct()
/Linux-v4.19/drivers/net/ethernet/mellanox/mlxsw/
Dspectrum_qdisc.c59 u64 backlog; member
277 stats_base->backlog = 0; in mlxsw_sp_setup_tc_qdisc_red_clean_stats()
287 root_qdisc->stats_base.backlog -= in mlxsw_sp_qdisc_red_destroy()
288 mlxsw_sp_qdisc->stats_base.backlog; in mlxsw_sp_qdisc_red_destroy()
349 u64 backlog; in mlxsw_sp_qdisc_red_unoffload() local
351 backlog = mlxsw_sp_cells_bytes(mlxsw_sp_port->mlxsw_sp, in mlxsw_sp_qdisc_red_unoffload()
352 mlxsw_sp_qdisc->stats_base.backlog); in mlxsw_sp_qdisc_red_unoffload()
353 p->qstats->backlog -= backlog; in mlxsw_sp_qdisc_red_unoffload()
354 mlxsw_sp_qdisc->stats_base.backlog = 0; in mlxsw_sp_qdisc_red_unoffload()
389 u64 tx_bytes, tx_packets, overlimits, drops, backlog; in mlxsw_sp_qdisc_get_red_stats() local
[all …]
/Linux-v4.19/tools/perf/ui/gtk/
Dhelpline.c32 static int backlog; in gtk_helpline_show() local
34 ret = vscnprintf(ui_helpline__current + backlog, in gtk_helpline_show()
35 sizeof(ui_helpline__current) - backlog, fmt, ap); in gtk_helpline_show()
36 backlog += ret; in gtk_helpline_show()
40 if (ptr && (ptr - ui_helpline__current) <= backlog) { in gtk_helpline_show()
43 backlog = 0; in gtk_helpline_show()
/Linux-v4.19/tools/perf/ui/tui/
Dhelpline.c33 static int backlog; in tui_helpline__show() local
36 ret = vscnprintf(ui_helpline__last_msg + backlog, in tui_helpline__show()
37 sizeof(ui_helpline__last_msg) - backlog, format, ap); in tui_helpline__show()
38 backlog += ret; in tui_helpline__show()
42 if (ui_helpline__last_msg[backlog - 1] == '\n') { in tui_helpline__show()
45 backlog = 0; in tui_helpline__show()
/Linux-v4.19/include/net/
Dfq_impl.h23 flow->backlog -= skb->len; in fq_adjust_removal()
24 fq->backlog--; in fq_adjust_removal()
32 if (flow->backlog == 0) { in fq_rejigger_backlog()
38 if (i->backlog < flow->backlog) in fq_rejigger_backlog()
149 if (i->backlog > flow->backlog) in fq_recalc_backlog()
169 flow->backlog += skb->len; in fq_tin_enqueue()
173 fq->backlog++; in fq_tin_enqueue()
185 while (fq->backlog > fq->limit || oom) { in fq_tin_enqueue()
263 WARN_ON_ONCE(flow->backlog); in fq_flow_reset()
Dcodel_impl.h107 u32 *backlog, in codel_should_drop() argument
125 *backlog <= params->mtu) { in codel_should_drop()
143 u32 *backlog, in codel_dequeue() argument
162 skb_len_func, skb_time_func, backlog, now); in codel_dequeue()
198 backlog, now)) { in codel_dequeue()
223 skb_time_func, backlog, now); in codel_dequeue()
Dfq.h35 u32 backlog; member
78 u32 backlog; member
Dred.h292 unsigned int backlog) in red_calc_qavg_no_idle_time() argument
303 return v->qavg + (backlog - (v->qavg >> p->Wlog)); in red_calc_qavg_no_idle_time()
308 unsigned int backlog) in red_calc_qavg() argument
311 return red_calc_qavg_no_idle_time(p, v, backlog); in red_calc_qavg()
/Linux-v4.19/net/sched/
Dsch_gred.c40 u32 backlog; /* bytes on the virtualQ */ member
118 return sch->qstats.backlog; in gred_backlog()
120 return q->backlog; in gred_backlog()
169 if (likely(sch->qstats.backlog + qdisc_pkt_len(skb) <= in gred_enqueue()
235 q->backlog += qdisc_pkt_len(skb); in gred_enqueue()
263 q->backlog -= qdisc_pkt_len(skb); in gred_dequeue()
266 if (!sch->qstats.backlog) in gred_dequeue()
269 if (!q->backlog) in gred_dequeue()
294 q->backlog = 0; in gred_reset()
377 if (q->backlog == 0) in gred_change_vq()
[all …]
Dsch_sfq.c113 unsigned int backlog; member
312 slot->backlog -= len; in sfq_drop()
378 slot->backlog = 0; /* should already be 0 anyway... */ in sfq_enqueue()
385 slot->backlog); in sfq_enqueue()
436 sch->qstats.backlog -= delta; in sfq_enqueue()
437 slot->backlog -= delta; in sfq_enqueue()
447 slot->backlog += qdisc_pkt_len(skb); in sfq_enqueue()
508 slot->backlog -= qdisc_pkt_len(skb); in sfq_dequeue()
560 slot->backlog = 0; in sfq_rehash()
591 slot->backlog); in sfq_rehash()
[all …]
Dsch_skbprio.c89 q->qstats[prio].backlog += qdisc_pkt_len(skb); in skbprio_enqueue()
112 q->qstats[prio].backlog += qdisc_pkt_len(skb); in skbprio_enqueue()
121 q->qstats[lp].backlog -= qdisc_pkt_len(to_drop); in skbprio_enqueue()
156 q->qstats[q->highest_prio].backlog -= qdisc_pkt_len(skb); in skbprio_dequeue()
217 sch->qstats.backlog = 0; in skbprio_reset()
Dsch_fifo.c25 if (likely(sch->qstats.backlog + qdisc_pkt_len(skb) <= sch->limit)) in bfifo_enqueue()
48 prev_backlog = sch->qstats.backlog; in pfifo_tail_enqueue()
54 qdisc_tree_reduce_backlog(sch, 0, prev_backlog - sch->qstats.backlog); in pfifo_tail_enqueue()
/Linux-v4.19/net/core/
Dgen_stats.c260 qstats->backlog += qcpu->backlog; in __gnet_stats_copy_queue_cpu()
276 qstats->backlog = q->backlog; in __gnet_stats_copy_queue()
312 d->tc_stats.backlog = qstats.backlog; in gnet_stats_copy_queue()
/Linux-v4.19/drivers/crypto/qce/
Dcore.c83 struct crypto_async_request *async_req, *backlog; in qce_handle_queue() local
98 backlog = crypto_get_backlog(&qce->queue); in qce_handle_queue()
108 if (backlog) { in qce_handle_queue()
110 backlog->complete(backlog, -EINPROGRESS); in qce_handle_queue()
/Linux-v4.19/net/sunrpc/
Dstats.c153 ktime_t backlog, execute, now; in rpc_count_iostats_metrics() local
169 backlog = 0; in rpc_count_iostats_metrics()
171 backlog = ktime_sub(req->rq_xtime, task->tk_start); in rpc_count_iostats_metrics()
172 op_metrics->om_queue = ktime_add(op_metrics->om_queue, backlog); in rpc_count_iostats_metrics()
182 trace_rpc_stats_latency(req->rq_task, backlog, req->rq_rtt, execute); in rpc_count_iostats_metrics()
/Linux-v4.19/crypto/
Dcrypto_engine.c73 struct crypto_async_request *async_req, *backlog; in crypto_pump_requests() local
117 backlog = crypto_get_backlog(&engine->queue); in crypto_pump_requests()
123 if (backlog) in crypto_pump_requests()
124 backlog->complete(backlog, -EINPROGRESS); in crypto_pump_requests()
/Linux-v4.19/drivers/crypto/rockchip/
Drk3288_crypto.c209 struct crypto_async_request *async_req, *backlog; in rk_crypto_queue_task_cb() local
215 backlog = crypto_get_backlog(&dev->queue); in rk_crypto_queue_task_cb()
225 if (backlog) { in rk_crypto_queue_task_cb()
226 backlog->complete(backlog, -EINPROGRESS); in rk_crypto_queue_task_cb()
227 backlog = NULL; in rk_crypto_queue_task_cb()
/Linux-v4.19/drivers/crypto/
Dmxs-dcp.c347 struct crypto_async_request *backlog; in dcp_chan_thread_aes() local
356 backlog = crypto_get_backlog(&sdcp->queue[chan]); in dcp_chan_thread_aes()
360 if (!backlog && !arq) { in dcp_chan_thread_aes()
367 if (backlog) in dcp_chan_thread_aes()
368 backlog->complete(backlog, -EINPROGRESS); in dcp_chan_thread_aes()
639 struct crypto_async_request *backlog; in dcp_chan_thread_sha() local
651 backlog = crypto_get_backlog(&sdcp->queue[chan]); in dcp_chan_thread_sha()
655 if (!backlog && !arq) { in dcp_chan_thread_sha()
662 if (backlog) in dcp_chan_thread_sha()
663 backlog->complete(backlog, -EINPROGRESS); in dcp_chan_thread_sha()
Domap-aes-gcm.c254 struct aead_request *backlog; in omap_aes_gcm_handle_queue() local
267 backlog = aead_get_backlog(&dd->aead_queue); in omap_aes_gcm_handle_queue()
276 if (backlog) in omap_aes_gcm_handle_queue()
277 backlog->base.complete(&backlog->base, -EINPROGRESS); in omap_aes_gcm_handle_queue()
/Linux-v4.19/drivers/crypto/marvell/
Dtdma.c139 struct crypto_async_request *backlog = NULL; in mv_cesa_tdma_process() local
152 &backlog); in mv_cesa_tdma_process()
173 if (backlog) in mv_cesa_tdma_process()
174 backlog->complete(backlog, -EINPROGRESS); in mv_cesa_tdma_process()
Dcesa.c42 struct crypto_async_request **backlog) in mv_cesa_dequeue_req_locked() argument
46 *backlog = crypto_get_backlog(&engine->queue); in mv_cesa_dequeue_req_locked()
57 struct crypto_async_request *req = NULL, *backlog = NULL; in mv_cesa_rearm_engine() local
63 req = mv_cesa_dequeue_req_locked(engine, &backlog); in mv_cesa_rearm_engine()
71 if (backlog) in mv_cesa_rearm_engine()
72 backlog->complete(backlog, -EINPROGRESS); in mv_cesa_rearm_engine()
/Linux-v4.19/include/rdma/
Diw_cm.h126 int backlog);
185 int iw_cm_listen(struct iw_cm_id *cm_id, int backlog);
/Linux-v4.19/drivers/net/ipvlan/
Dipvlan_core.c245 spin_lock_bh(&port->backlog.lock); in ipvlan_process_multicast()
246 skb_queue_splice_tail_init(&port->backlog, &list); in ipvlan_process_multicast()
247 spin_unlock_bh(&port->backlog.lock); in ipvlan_process_multicast()
553 spin_lock(&port->backlog.lock); in ipvlan_multicast_enqueue()
554 if (skb_queue_len(&port->backlog) < IPVLAN_QBACKLOG_LIMIT) { in ipvlan_multicast_enqueue()
557 __skb_queue_tail(&port->backlog, skb); in ipvlan_multicast_enqueue()
558 spin_unlock(&port->backlog.lock); in ipvlan_multicast_enqueue()
561 spin_unlock(&port->backlog.lock); in ipvlan_multicast_enqueue()
/Linux-v4.19/net/rxrpc/
Daf_rxrpc.c210 static int rxrpc_listen(struct socket *sock, int backlog) in rxrpc_listen() argument
217 _enter("%p,%d", rx, backlog); in rxrpc_listen()
230 if (backlog == INT_MAX) in rxrpc_listen()
231 backlog = max; in rxrpc_listen()
232 else if (backlog < 0 || backlog > max) in rxrpc_listen()
235 sk->sk_max_ack_backlog = backlog; in rxrpc_listen()
243 if (backlog == 0) { in rxrpc_listen()

12345678