| /linux/include/trace/events/ |
| A D | page_pool.h | 17 s32 inflight, u32 hold, u32 release),
19 TP_ARGS(pool, inflight, hold, release),
23 __field(s32, inflight)
31 __entry->inflight = inflight;
38 __entry->pool, __entry->inflight, __entry->hold,
|
| A D | wbt.h | 132 int step, unsigned int inflight),
134 TP_ARGS(bdi, status, step, inflight),
140 __field(unsigned int, inflight)
148 __entry->inflight = inflight;
152 __entry->status, __entry->step, __entry->inflight)
|
| /linux/block/ |
| A D | genhd.c | 154 if ((int)inflight < 0) in part_in_flight()
155 inflight = 0; in part_in_flight()
157 return inflight; in part_in_flight()
165 inflight[0] = 0; in part_in_flight_rw()
166 inflight[1] = 0; in part_in_flight_rw()
172 inflight[0] = 0; in part_in_flight_rw()
174 inflight[1] = 0; in part_in_flight_rw()
918 unsigned int inflight; in part_stat_show() local
941 inflight, in part_stat_show()
968 return sprintf(buf, "%8u %8u\n", inflight[0], inflight[1]); in part_inflight_show()
[all …]
|
| A D | blk-wbt.c | 131 int inflight, limit; in wbt_rqw_done() local
133 inflight = atomic_dec_return(&rqw->inflight); in wbt_rqw_done()
159 if (inflight && inflight >= limit) in wbt_rqw_done()
163 int diff = limit - inflight; in wbt_rqw_done()
165 if (!inflight || diff >= rwb->wb_background / 2) in wbt_rqw_done()
357 unsigned int inflight = wbt_inflight(rwb); in wb_timer_fn() local
366 inflight); in wb_timer_fn()
408 if (rqd->scale_step || inflight) in wb_timer_fn()
752 atomic_read(&rwb->rq_wait[i].inflight)); in wbt_inflight_show()
|
| A D | blk-iolatency.c | 271 atomic_dec(&rqw->inflight); in iolat_cleanup_cb()
300 atomic_inc(&rqw->inflight); in __blkcg_iolatency_throttle()
598 int inflight = 0; in blkcg_iolatency_done_bio() local
621 inflight = atomic_dec_return(&rqw->inflight); in blkcg_iolatency_done_bio()
622 WARN_ON_ONCE(inflight < 0); in blkcg_iolatency_done_bio()
|
| A D | blk-rq-qos.h | 25 atomic_t inflight; member
85 atomic_set(&rq_wait->inflight, 0); in rq_wait_init()
|
| A D | blk-wbt.h | 83 ret += atomic_read(&rwb->rq_wait[i].inflight); in wbt_inflight()
|
| /linux/net/core/ |
| A D | page_pool.c | 334 s32 inflight; in page_pool_inflight() local
339 WARN(inflight < 0, "Negative(%d) inflight packet-pages", inflight); in page_pool_inflight()
341 return inflight; in page_pool_inflight()
661 int inflight; in page_pool_release() local
664 inflight = page_pool_inflight(pool); in page_pool_release()
665 if (!inflight) in page_pool_release()
668 return inflight; in page_pool_release()
675 int inflight; in page_pool_release_retry() local
677 inflight = page_pool_release(pool); in page_pool_release_retry()
678 if (!inflight) in page_pool_release_retry()
[all …]
|
| /linux/net/unix/ |
| A D | garbage.c | 169 atomic_long_dec(&usk->inflight); in dec_inflight()
174 atomic_long_inc(&usk->inflight); in inc_inflight()
179 atomic_long_inc(&u->inflight); in inc_inflight_move_tail()
237 inflight_refs = atomic_long_read(&u->inflight); in unix_gc()
268 if (atomic_long_read(&u->inflight) > 0) { in unix_gc()
|
| A D | scm.c | 57 if (atomic_long_inc_return(&u->inflight) == 1) { in unix_inflight()
78 BUG_ON(!atomic_long_read(&u->inflight)); in unix_notinflight()
81 if (atomic_long_dec_and_test(&u->inflight)) in unix_notinflight()
|
| /linux/drivers/crypto/chelsio/ |
| A D | chcr_core.c | 56 if (atomic_read(&dev->inflight)) { in detach_work_fn()
60 atomic_read(&dev->inflight)); in detach_work_fn()
65 atomic_read(&dev->inflight)); in detach_work_fn()
103 atomic_set(&dev->inflight, 0); in chcr_dev_add()
122 atomic_set(&dev->inflight, 0); in chcr_dev_init()
232 if (atomic_read(&dev->inflight) != 0) { in chcr_detach_device()
|
| A D | chcr_core.h | 99 atomic_t inflight; member
|
| /linux/tools/io_uring/ |
| A D | io_uring-bench.c | 80 int inflight; member
272 s->inflight -= reaped; in reap_events()
292 if (!prepped && s->inflight < DEPTH) { in submitter_fn()
293 to_prep = min(DEPTH - s->inflight, BATCH_SUBMIT); in submitter_fn()
296 s->inflight += prepped; in submitter_fn()
300 if (to_submit && (s->inflight + to_submit <= DEPTH)) in submitter_fn()
303 to_wait = min(s->inflight + to_submit, BATCH_COMPLETE); in submitter_fn()
341 if (s->inflight) in submitter_fn()
581 this_done - done, rpc, ipc, s->inflight, in main()
|
| /linux/drivers/gpu/drm/i915/gt/ |
| A D | intel_context_types.h | 82 struct intel_engine_cs *inflight; member
86 __intel_context_inflight(READ_ONCE((ce)->inflight))
88 __intel_context_inflight_count(READ_ONCE((ce)->inflight))
|
| A D | intel_execlists_submission.c | 534 old = ce->inflight; in execlists_schedule_in()
598 GEM_BUG_ON(ce->inflight != engine); in __execlists_schedule_out()
645 WRITE_ONCE(ce->inflight, NULL); in __execlists_schedule_out()
655 GEM_BUG_ON(!ce->inflight); in execlists_schedule_out()
656 ce->inflight = ptr_dec(ce->inflight); in execlists_schedule_out()
1002 if (inflight && inflight != engine) in virtual_matches()
1634 clear_ports(execlists->inflight, ARRAY_SIZE(execlists->inflight)); in cancel_port_requests()
1924 copy_ports(execlists->inflight, in process_csb()
3237 if (!inflight) in kick_execlists()
3251 inflight->fence.context, inflight->fence.seqno, in kick_execlists()
[all …]
|
| A D | intel_timeline.c | 420 unsigned long count, ready, inflight; in intel_gt_show_timelines() local
437 inflight = 0; in intel_gt_show_timelines()
446 inflight++; in intel_gt_show_timelines()
451 count, ready, inflight); in intel_gt_show_timelines()
|
| /linux/net/atm/ |
| A D | pppoatm.c | 64 atomic_t inflight; member
139 atomic_dec(&pvcc->inflight); in pppoatm_pop()
244 atomic_inc_not_zero(&pvcc->inflight)) in pppoatm_may_send()
274 atomic_inc_not_zero(&pvcc->inflight)) in pppoatm_may_send()
406 atomic_set(&pvcc->inflight, NONE_INFLIGHT); in pppoatm_assign_vcc()
|
| /linux/drivers/infiniband/ulp/rtrs/ |
| A D | rtrs-clt-stats.c | 106 atomic_read(&stats->inflight), sum.failover_cnt); in rtrs_clt_stats_rdma_to_str()
162 atomic_set(&s->inflight, 0); in rtrs_clt_reset_all_stats()
190 atomic_inc(&stats->inflight); in rtrs_clt_update_all_stats()
|
| A D | README | 100 corresponding path is disconnected, all the inflight IO are failed over to a
131 inflight IO and for the error code.
149 inflight IO and for the error code. The new rkey is sent back using
171 outstanding inflight IO and the error code.
192 outstanding inflight IO and the error code. The new rkey is sent back using
|
| /linux/drivers/vhost/ |
| A D | scsi.c | 99 struct vhost_scsi_inflight *inflight; member
210 struct vhost_scsi_inflight *inflight; member
235 struct vhost_scsi_inflight *inflight; in vhost_scsi_done_inflight() local
238 complete(&inflight->comp); in vhost_scsi_done_inflight()
271 struct vhost_scsi_inflight *inflight; in vhost_scsi_get_inflight() local
276 kref_get(&inflight->kref); in vhost_scsi_get_inflight()
278 return inflight; in vhost_scsi_get_inflight()
331 struct vhost_scsi_inflight *inflight = tv_cmd->inflight; in vhost_scsi_release_cmd_res() local
344 vhost_scsi_put_inflight(inflight); in vhost_scsi_release_cmd_res()
350 struct vhost_scsi_inflight *inflight = tmf->inflight; in vhost_scsi_release_tmf_res() local
[all …]
|
| /linux/net/ipv4/ |
| A D | tcp_bbr.c | 414 u32 inflight; in bbr_inflight() local
416 inflight = bbr_bdp(sk, bw, gain); in bbr_inflight()
417 inflight = bbr_quantization_budget(sk, inflight); in bbr_inflight()
419 return inflight; in bbr_inflight()
561 u32 inflight, bw; in bbr_is_next_cycle_phase() local
569 inflight = bbr_packets_in_net_at_edt(sk, rs->prior_in_flight); in bbr_is_next_cycle_phase()
580 inflight >= bbr_inflight(sk, bw, bbr->pacing_gain)); in bbr_is_next_cycle_phase()
587 inflight <= bbr_inflight(sk, bw, BBR_UNIT); in bbr_is_next_cycle_phase()
|
| /linux/Documentation/networking/ |
| A D | page_pool.rst | 14 API keeps track of inflight pages, in order to let API user know
22 release the DMA mapping and inflight state accounting.
91 inflight counters.
|
| /linux/drivers/crypto/cavium/cpt/ |
| A D | cpt_hw_types.h | 443 u64 inflight:8; member
445 u64 inflight:8;
|
| /linux/Documentation/devicetree/bindings/net/dsa/ |
| A D | brcm,sf2.yaml | 74 brcm,acb-packets-inflight:
160 brcm,acb-packets-inflight;
|
| /linux/net/sctp/ |
| A D | output.c | 674 size_t datasize, rwnd, inflight, flight_size; in sctp_packet_can_append_data() local
693 inflight = q->outstanding_bytes; in sctp_packet_can_append_data()
698 if (datasize > rwnd && inflight > 0) in sctp_packet_can_append_data()
726 if ((sctp_sk(asoc->base.sk)->nodelay || inflight == 0) && in sctp_packet_can_append_data()
|