| /linux/drivers/crypto/intel/qat/qat_common/ |
| H A D | qat_algs_send.c | 24 void qat_alg_send_backlog(struct qat_instance_backlog *backlog) in qat_alg_send_backlog() argument
28 spin_lock_bh(&backlog->lock); in qat_alg_send_backlog()
29 list_for_each_entry_safe(req, tmp, &backlog->list, list) { in qat_alg_send_backlog()
40 spin_unlock_bh(&backlog->lock); in qat_alg_send_backlog()
45 struct qat_instance_backlog *backlog = req->backlog; in qat_alg_try_enqueue() local
50 if (!list_empty(&backlog->list)) in qat_alg_try_enqueue()
67 struct qat_instance_backlog *backlog = req->backlog; in qat_alg_send_message_maybacklog() local
73 spin_lock_bh(&backlog->lock); in qat_alg_send_message_maybacklog()
75 list_add_tail(&req->list, &backlog->list); in qat_alg_send_message_maybacklog()
78 spin_unlock_bh(&backlog->lock); in qat_alg_send_message_maybacklog()
|
| H A D | qat_algs_send.h | 19 struct qat_instance_backlog *backlog; member
23 void qat_alg_send_backlog(struct qat_instance_backlog *backlog);
|
| /linux/drivers/crypto/ccp/ |
| H A D | ccp-crypto-main.c | 58 struct list_head *backlog; member
93 struct ccp_crypto_cmd *crypto_cmd, struct ccp_crypto_cmd **backlog) in ccp_crypto_cmd_complete() argument
98 *backlog = NULL; in ccp_crypto_cmd_complete()
117 if (req_queue.backlog != &req_queue.cmds) { in ccp_crypto_cmd_complete()
119 if (req_queue.backlog == &crypto_cmd->entry) in ccp_crypto_cmd_complete()
120 req_queue.backlog = crypto_cmd->entry.next; in ccp_crypto_cmd_complete()
122 *backlog = container_of(req_queue.backlog, in ccp_crypto_cmd_complete()
124 req_queue.backlog = req_queue.backlog->next; in ccp_crypto_cmd_complete()
127 if (req_queue.backlog == &crypto_cmd->entry) in ccp_crypto_cmd_complete()
128 req_queue.backlog = crypto_cmd->entry.next; in ccp_crypto_cmd_complete()
[all …]
|
| H A D | ccp-dev.c | 315 list_add_tail(&cmd->entry, &ccp->backlog); in ccp_enqueue_cmd()
378 struct ccp_cmd *backlog = NULL; in ccp_dequeue_cmd() local
403 if (!list_empty(&ccp->backlog)) { in ccp_dequeue_cmd()
404 backlog = list_first_entry(&ccp->backlog, struct ccp_cmd, in ccp_dequeue_cmd()
406 list_del(&backlog->entry); in ccp_dequeue_cmd()
411 if (backlog) { in ccp_dequeue_cmd()
412 INIT_WORK(&backlog->work, ccp_do_cmd_backlog); in ccp_dequeue_cmd()
413 schedule_work(&backlog->work); in ccp_dequeue_cmd()
488 INIT_LIST_HEAD(&ccp->backlog); in ccp_alloc_struct()
|
| /linux/tools/perf/ui/tui/ |
| H A D | helpline.c | 33 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/tools/perf/ui/gtk/ |
| H A D | helpline.c | 32 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/fs/smb/smbdirect/ |
| H A D | listen.c | 13 int smbdirect_socket_listen(struct smbdirect_socket *sc, int backlog) in smbdirect_socket_listen() argument
17 if (backlog < 0) in smbdirect_socket_listen()
19 if (!backlog) in smbdirect_socket_listen()
20 backlog = 1; /* use 1 as default for now */ in smbdirect_socket_listen()
50 ret = rdma_listen(sc->rdma.cm_id, backlog); in smbdirect_socket_listen()
75 sc->listen.backlog = backlog; in smbdirect_socket_listen()
214 size_t backlog = max_t(size_t, 1, lsc->listen.backlog); in smbdirect_listen_connect_request() local
259 if (psockets > backlog || in smbdirect_listen_connect_request()
260 rsockets > backlog || in smbdirect_listen_connect_request()
261 (psockets + rsockets) > backlog) { in smbdirect_listen_connect_request()
[all …]
|
| /linux/net/sched/ |
| H A D | sch_pie.c | 34 struct pie_vars *vars, u32 backlog, u32 packet_size) in pie_drop_early() argument
54 if (backlog < 2 * mtu) in pie_drop_early()
99 if (!pie_drop_early(sch, &q->params, &q->vars, sch->qstats.backlog, in pie_qdisc_enqueue()
213 struct pie_vars *vars, u32 backlog) in pie_process_dequeue() argument
223 backlog ? now - pie_get_enqueue_time(skb) : 0); in pie_process_dequeue()
240 if (backlog >= QUEUE_THRESHOLD && vars->dq_count == DQCOUNT_INVALID) { in pie_process_dequeue()
279 if (backlog < QUEUE_THRESHOLD) { in pie_process_dequeue()
303 u32 backlog) in pie_calculate_probability() argument
318 qdelay = (backlog << PIE_SCALE) / vars->avg_dq_rate; in pie_calculate_probability()
329 if (qdelay == 0 && backlog != 0) in pie_calculate_probability()
[all …]
|
| H A D | sch_sfq.c | 103 unsigned int backlog; member
303 WRITE_ONCE(slot->backlog, slot->backlog - len); in sfq_drop()
372 WRITE_ONCE(slot->backlog, 0); /* should already be 0 anyway... */ in sfq_enqueue()
379 slot->backlog); in sfq_enqueue()
430 sch->qstats.backlog -= delta; in sfq_enqueue()
431 WRITE_ONCE(slot->backlog, slot->backlog - delta); in sfq_enqueue()
441 WRITE_ONCE(slot->backlog, slot->backlog + qdisc_pkt_len(skb)); in sfq_enqueue()
502 WRITE_ONCE(slot->backlog, slot->backlog - qdisc_pkt_len(skb)); in sfq_dequeue()
554 WRITE_ONCE(slot->backlog, 0); in sfq_rehash()
585 slot->backlog); in sfq_rehash()
[all …]
|
| H A D | sch_gred.c | 39 u32 backlog; /* bytes on the virtualQ */ member
118 return sch->qstats.backlog; in gred_backlog()
120 return q->backlog; in gred_backlog()
182 if (likely(sch->qstats.backlog + qdisc_pkt_len(skb) <= in gred_enqueue()
248 q->backlog += qdisc_pkt_len(skb); in gred_enqueue()
273 net_warn_ratelimited("GRED: Unable to relocate VQ 0x%x after dequeue, screwing up backlog\n", in gred_dequeue()
276 q->backlog -= qdisc_pkt_len(skb); in gred_dequeue()
279 if (!sch->qstats.backlog) in gred_dequeue()
282 if (!q->backlog) in gred_dequeue()
307 q->backlog in gred_reset()
[all...] |
| H A D | sch_fq_pie.c | 48 u32 backlog; member
168 sel_flow->backlog, skb->len)) { in fq_pie_qdisc_enqueue()
187 sch->qstats.backlog += pkt_len; in fq_pie_qdisc_enqueue()
195 sel_flow->backlog = 0; in fq_pie_qdisc_enqueue()
198 sel_flow->backlog += pkt_len; in fq_pie_qdisc_enqueue()
265 sch->qstats.backlog -= pkt_len; in fq_pie_qdisc_dequeue()
281 flow->backlog -= pkt_len; in fq_pie_qdisc_dequeue()
283 pie_process_dequeue(skb, &q->p_params, &flow->vars, flow->backlog); in fq_pie_qdisc_dequeue()
404 q->flows[q->flows_cursor].backlog); in fq_pie_timer()
|
| H A D | sch_skbprio.c | 87 q->qstats[prio].backlog += qdisc_pkt_len(skb); in skbprio_enqueue()
110 q->qstats[prio].backlog += qdisc_pkt_len(skb); in skbprio_enqueue()
119 q->qstats[lp].backlog -= qdisc_pkt_len(to_drop); in skbprio_enqueue()
152 q->qstats[q->highest_prio].backlog -= qdisc_pkt_len(skb); in skbprio_dequeue()
|
| /linux/include/net/ |
| H A D | fq_impl.h | 24 flow->backlog -= bytes; in __fq_adjust_removal()
25 fq->backlog -= packets; in __fq_adjust_removal()
28 if (flow->backlog) in __fq_adjust_removal()
176 cur_len = cur->backlog; in fq_find_fattest_flow()
185 unsigned int cur_len = tin->default_flow.backlog; in fq_find_fattest_flow()
210 if (!flow->backlog) { in fq_tin_enqueue()
220 flow->backlog += skb->len; in fq_tin_enqueue()
224 fq->backlog++; in fq_tin_enqueue()
235 while (fq->backlog > fq->limit || oom) { in fq_tin_enqueue()
308 WARN_ON_ONCE(flow->backlog); in fq_flow_reset()
|
| H A D | codel_impl.h | 111 u32 *backlog, in codel_should_drop() argument
129 *backlog <= params->mtu) { in codel_should_drop()
147 u32 *backlog, in codel_dequeue() argument
167 skb_len_func, skb_time_func, backlog, now); in codel_dequeue()
205 backlog, now)) { in codel_dequeue()
230 skb_time_func, backlog, now); in codel_dequeue()
|
| H A D | fq.h | 35 u32 backlog; member
79 u32 backlog; member
|
| H A D | red.h | 339 unsigned int backlog) in red_calc_qavg_no_idle_time() argument
350 return v->qavg + (backlog - (v->qavg >> p->Wlog)); in red_calc_qavg_no_idle_time()
355 unsigned int backlog) in red_calc_qavg() argument
358 return red_calc_qavg_no_idle_time(p, v, backlog); in red_calc_qavg()
|
| H A D | sch_generic.h | 961 sch->qstats.backlog -= qdisc_pkt_len(skb); in qdisc_qstats_backlog_dec()
967 this_cpu_sub(sch->cpu_qstats->backlog, qdisc_pkt_len(skb)); in qdisc_qstats_cpu_backlog_dec()
973 sch->qstats.backlog += qdisc_pkt_len(skb); in qdisc_qstats_backlog_inc()
979 this_cpu_add(sch->cpu_qstats->backlog, qdisc_pkt_len(skb)); in qdisc_qstats_cpu_backlog_inc()
1035 __u32 *backlog) in qdisc_qstats_qlen_backlog() argument
1041 *backlog = qstats.backlog; in qdisc_qstats_qlen_backlog()
1046 __u32 qlen, backlog; in qdisc_purge_queue() local
1048 qdisc_qstats_qlen_backlog(sch, &qlen, &backlog); in qdisc_purge_queue()
1050 qdisc_tree_reduce_backlog(sch, qlen, backlog); in qdisc_purge_queue()
1290 this_cpu_add(sch->cpu_qstats->backlog, pkt_len); in qdisc_update_stats_at_enqueue()
[all …]
|
| /linux/drivers/net/ethernet/mellanox/mlxsw/ |
| H A D | spectrum_qdisc.c | 79 u64 backlog; member
200 tmp->stats_base.backlog -= mlxsw_sp_qdisc->stats_base.backlog; in mlxsw_sp_qdisc_reduce_parent_backlog()
502 return xstats->backlog[tclass_num] + in mlxsw_sp_xstats_backlog()
503 xstats->backlog[tclass_num + 8]; in mlxsw_sp_xstats_backlog()
560 u64 drops, u64 backlog, in mlxsw_sp_qdisc_update_stats() argument
568 backlog -= stats_base->backlog; in mlxsw_sp_qdisc_update_stats()
572 stats_ptr->qstats->backlog += mlxsw_sp_cells_bytes(mlxsw_sp, backlog); in mlxsw_sp_qdisc_update_stats()
574 stats_base->backlog += backlog; in mlxsw_sp_qdisc_update_stats()
587 u64 backlog = 0; in mlxsw_sp_qdisc_get_tc_stats() local
592 &drops, &backlog); in mlxsw_sp_qdisc_get_tc_stats()
[all …]
|
| /linux/net/core/ |
| H A D | gen_stats.c | 349 qstats->backlog += qcpu->backlog; in gnet_stats_add_queue_cpu()
364 qstats->backlog += q->backlog; in gnet_stats_add_queue()
399 d->tc_stats.backlog = qstats.backlog; in gnet_stats_copy_queue()
|
| /linux/drivers/crypto/qce/ |
| H A D | core.c | 90 struct crypto_async_request *async_req, *backlog; in qce_handle_queue() local
101 backlog = crypto_get_backlog(&qce->queue); in qce_handle_queue()
110 if (backlog) { in qce_handle_queue()
112 crypto_request_complete(backlog, -EINPROGRESS); in qce_handle_queue()
|
| /linux/net/sunrpc/ |
| H A D | stats.c | 158 ktime_t backlog, execute, now; in rpc_count_iostats_metrics() local
174 backlog = 0; in rpc_count_iostats_metrics()
176 backlog = ktime_sub(req->rq_xtime, task->tk_start); in rpc_count_iostats_metrics()
177 op_metrics->om_queue = ktime_add(op_metrics->om_queue, backlog); in rpc_count_iostats_metrics()
189 trace_rpc_stats_latency(req->rq_task, backlog, req->rq_rtt, execute); in rpc_count_iostats_metrics()
|
| /linux/net/rxrpc/ |
| H A D | call_accept.c | 164 struct rxrpc_backlog *b = rx->backlog; in rxrpc_service_prealloc()
170 rx->backlog = b; in rxrpc_service_prealloc()
181 struct rxrpc_backlog *b = rx->backlog; in rxrpc_discard_prealloc()
187 rx->backlog = NULL; in rxrpc_discard_prealloc()
253 struct rxrpc_backlog *b = rx->backlog; in rxrpc_alloc_incoming_call()
446 struct rxrpc_backlog *b = rx->backlog; in rxrpc_user_charge_accept()
475 struct rxrpc_backlog *b = rx->backlog; in rxrpc_kernel_charge_accept()
|
| /linux/kernel/printk/ |
| H A D | nbcon.c | 1017 ctxt->backlog = printk_get_next_message(&pmsg, ctxt->seq, is_extended, true); in nbcon_emit_next_record()
1018 if (!ctxt->backlog) in nbcon_emit_next_record()
1162 ret = ctxt->backlog; in nbcon_emit_one()
1229 bool backlog; in nbcon_kthread_func() local
1259 backlog = false; in nbcon_kthread_func()
1271 backlog = nbcon_emit_one(&wctxt, false); in nbcon_kthread_func()
1277 } while (backlog); in nbcon_kthread_func()
1598 if (!ctxt->backlog) { in __nbcon_atomic_flush_pending_con()
|
| /linux/include/crypto/ |
| H A D | algapi.h | 104 struct list_head *backlog; member
228 return queue->backlog == &queue->list ? NULL : in crypto_get_backlog()
229 container_of(queue->backlog, struct crypto_async_request, list); in crypto_get_backlog()
|
| /linux/net/tipc/ |
| H A D | link.c | 178 } backlog[5]; member
918 avail[imp] = l->backlog[imp].limit - l->backlog[imp].len; in link_prepare_wakeup()
976 l->backlog[imp].len = 0; in tipc_link_reset()
977 l->backlog[imp].target_bskb = NULL; in tipc_link_reset()
1043 if (unlikely(l->backlog[imp].len >= l->backlog[imp].limit)) { in tipc_link_xmit()
1079 if (tipc_msg_try_bundle(l->backlog[imp].target_bskb, &skb, in tipc_link_xmit()
1083 l->backlog[imp].target_bskb = skb; in tipc_link_xmit()
1084 l->backlog[imp].len++; in tipc_link_xmit()
1095 l->backlog[imp].target_bskb = NULL; in tipc_link_xmit()
1096 l->backlog[imp].len += (1 + skb_queue_len(list)); in tipc_link_xmit()
[all …]
|