| /openbmc/linux/include/trace/events/ |
| H 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,
|
| H 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)
|
| /openbmc/linux/block/ |
| H A D | genhd.c | 123 unsigned int inflight = 0; in part_in_flight() local
127 inflight += part_stat_local_read_cpu(part, in_flight[0], cpu) + in part_in_flight()
130 if ((int)inflight < 0) in part_in_flight()
131 inflight = 0; in part_in_flight()
133 return inflight; in part_in_flight()
137 unsigned int inflight[2]) in part_in_flight_rw()
141 inflight[0] = 0; in part_in_flight_rw()
142 inflight[1] = 0; in part_in_flight_rw()
144 inflight[0] += part_stat_local_read_cpu(part, in_flight[0], cpu); in part_in_flight_rw()
145 inflight[1] += part_stat_local_read_cpu(part, in_flight[1], cpu); in part_in_flight_rw()
[all …]
|
| H A D | blk-wbt.c | 199 int inflight, limit; in wbt_rqw_done() local
201 inflight = atomic_dec_return(&rqw->inflight); in wbt_rqw_done()
218 if (inflight && inflight >= limit) in wbt_rqw_done()
222 int diff = limit - inflight; in wbt_rqw_done()
224 if (!inflight || diff >= rwb->wb_background / 2) in wbt_rqw_done()
292 ret += atomic_read(&rwb->rq_wait[i].inflight); in wbt_inflight()
426 unsigned int inflight = wbt_inflight(rwb); in wb_timer_fn() local
434 trace_wbt_timer(rwb->rqos.disk->bdi, status, rqd->scale_step, inflight); in wb_timer_fn()
476 if (rqd->scale_step || inflight) in wb_timer_fn()
831 atomic_read(&rwb->rq_wait[i].inflight)); in wbt_inflight_show()
|
| /openbmc/linux/net/unix/ |
| H A D | garbage.c | 169 usk->inflight--; in dec_inflight()
174 usk->inflight++; in inc_inflight()
179 u->inflight++; in inc_inflight_move_tail()
255 BUG_ON(!u->inflight); in unix_gc()
256 BUG_ON(total_refs < u->inflight); in unix_gc()
257 if (total_refs == u->inflight) { in unix_gc()
289 if (u->inflight) { in unix_gc()
|
| H A D | scm.c | 56 if (!u->inflight) { in unix_inflight()
62 u->inflight++; in unix_inflight()
79 BUG_ON(!u->inflight); in unix_notinflight()
82 u->inflight--; in unix_notinflight()
83 if (!u->inflight) in unix_notinflight()
|
| /openbmc/linux/drivers/firmware/arm_scmi/ |
| H A D | smc.c | 62 atomic_t inflight; member
91 atomic_set(&scmi_info->inflight, INFLIGHT_NONE); in smc_channel_lock_init()
96 static bool smc_xfer_inflight(struct scmi_xfer *xfer, atomic_t *inflight) in smc_xfer_inflight() argument
100 ret = atomic_cmpxchg(inflight, INFLIGHT_NONE, xfer->hdr.seq); in smc_xfer_inflight()
110 spin_until_cond(smc_xfer_inflight(xfer, &scmi_info->inflight)); in smc_channel_lock_acquire()
118 atomic_set(&scmi_info->inflight, INFLIGHT_NONE); in smc_channel_lock_release()
|
| /openbmc/qemu/subprojects/libvduse/ |
| H A D | libvduse.c | 62 uint8_t inflight; member
78 VduseVirtqLogInflight inflight; member
238 if (unlikely(vq->log->inflight.used_idx != vq->used_idx)) { in vduse_queue_check_inflights()
239 if (vq->log->inflight.last_batch_head > VIRTQUEUE_MAX_SIZE) { in vduse_queue_check_inflights()
243 vq->log->inflight.desc[vq->log->inflight.last_batch_head].inflight = 0; in vduse_queue_check_inflights()
247 vq->log->inflight.used_idx = vq->used_idx; in vduse_queue_check_inflights()
250 for (i = 0; i < vq->log->inflight.desc_num; i++) { in vduse_queue_check_inflights()
251 if (vq->log->inflight.desc[i].inflight == 1) { in vduse_queue_check_inflights()
264 for (i = 0; i < vq->log->inflight.desc_num; i++) { in vduse_queue_check_inflights()
265 if (vq->log->inflight.desc[i].inflight) { in vduse_queue_check_inflights()
[all …]
|
| /openbmc/linux/net/core/ |
| H A D | page_pool.c | 499 s32 inflight; in page_pool_inflight() local
501 inflight = _distance(hold_cnt, release_cnt); in page_pool_inflight()
503 trace_page_pool_release(pool, inflight, hold_cnt, release_cnt); in page_pool_inflight()
504 WARN(inflight < 0, "Negative(%d) inflight packet-pages", inflight); in page_pool_inflight()
506 return inflight; in page_pool_inflight()
851 int inflight; in page_pool_release() local
854 inflight = page_pool_inflight(pool); in page_pool_release()
855 if (!inflight) in page_pool_release()
858 return inflight; in page_pool_release()
865 int inflight; in page_pool_release_retry() local
[all …]
|
| /openbmc/qemu/subprojects/libvhost-user/ |
| H A D | libvhost-user.c | 1340 if (unlikely(!vq->inflight)) { in vu_check_queue_inflights()
1344 if (unlikely(!vq->inflight->version)) { in vu_check_queue_inflights()
1346 vq->inflight->version = INFLIGHT_VERSION; in vu_check_queue_inflights()
1355 if (unlikely(vq->inflight->used_idx != vq->used_idx)) { in vu_check_queue_inflights()
1356 vq->inflight->desc[vq->inflight->last_batch_head].inflight = 0; in vu_check_queue_inflights()
1360 vq->inflight->used_idx = vq->used_idx; in vu_check_queue_inflights()
1363 for (i = 0; i < vq->inflight->desc_num; i++) { in vu_check_queue_inflights()
1364 if (vq->inflight->desc[i].inflight == 1) { in vu_check_queue_inflights()
1377 for (i = 0; i < vq->inflight->desc_num; i++) { in vu_check_queue_inflights()
1378 if (vq->inflight->desc[i].inflight) { in vu_check_queue_inflights()
[all …]
|
| /openbmc/linux/drivers/crypto/chelsio/ |
| H 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()
|
| /openbmc/qemu/hw/scsi/ |
| H A D | vhost-scsi-common.c | 63 if (vsc->inflight) { in vhost_scsi_common_start()
64 if (!vsc->inflight->addr) { in vhost_scsi_common_start()
67 vsc->inflight); in vhost_scsi_common_start()
74 ret = vhost_dev_set_inflight(&vsc->dev, vsc->inflight); in vhost_scsi_common_start()
|
| H A D | vhost-user-scsi.c | 280 vsc->inflight = g_new0(struct vhost_inflight, 1); in vhost_user_scsi_realize()
312 g_free(vsc->inflight); in vhost_user_scsi_realize()
313 vsc->inflight = NULL; in vhost_user_scsi_realize()
336 vhost_dev_free_inflight(vsc->inflight); in vhost_user_scsi_unrealize()
337 g_free(vsc->inflight); in vhost_user_scsi_unrealize()
338 vsc->inflight = NULL; in vhost_user_scsi_unrealize()
371 vhost_dev_free_inflight(vsc->inflight); in vhost_user_scsi_reset()
|
| /openbmc/qemu/hw/block/ |
| H A D | vhost-user-blk.c | 165 if (!s->inflight->addr) { in vhost_user_blk_start()
166 ret = vhost_dev_get_inflight(&s->dev, s->queue_size, s->inflight); in vhost_user_blk_start()
173 ret = vhost_dev_set_inflight(&s->dev, s->inflight); in vhost_user_blk_start()
326 vhost_dev_free_inflight(s->inflight); in vhost_user_blk_reset()
488 s->inflight = g_new0(struct vhost_inflight, 1); in vhost_user_blk_device_realize()
515 g_free(s->inflight); in vhost_user_blk_device_realize()
516 s->inflight = NULL; in vhost_user_blk_device_realize()
535 vhost_dev_free_inflight(s->inflight); in vhost_user_blk_device_unrealize()
538 g_free(s->inflight); in vhost_user_blk_device_unrealize()
539 s->inflight = NULL; in vhost_user_blk_device_unrealize()
|
| /openbmc/qemu/include/hw/virtio/ |
| H A D | vhost.h | 339 void vhost_dev_reset_inflight(struct vhost_inflight *inflight);
340 void vhost_dev_free_inflight(struct vhost_inflight *inflight);
343 struct vhost_inflight *inflight);
345 struct vhost_inflight *inflight);
|
| /openbmc/linux/drivers/gpu/drm/i915/gt/ |
| H A D | intel_context_types.h | 90 struct intel_engine_cs *inflight; member
94 __intel_context_inflight(READ_ONCE((ce)->inflight))
96 __intel_context_inflight_count(READ_ONCE((ce)->inflight))
|
| H A D | intel_execlists_submission.c | 538 old = ce->inflight; in execlists_schedule_in()
541 WRITE_ONCE(ce->inflight, ptr_inc(old)); in execlists_schedule_in()
602 GEM_BUG_ON(ce->inflight != engine); in __execlists_schedule_out()
647 WRITE_ONCE(ce->inflight, NULL); in __execlists_schedule_out()
657 GEM_BUG_ON(!ce->inflight); in execlists_schedule_out()
658 ce->inflight = ptr_dec(ce->inflight); in execlists_schedule_out()
659 if (!__intel_context_inflight_count(ce->inflight)) in execlists_schedule_out()
1000 const struct intel_engine_cs *inflight; in virtual_matches() local
1017 inflight = intel_context_inflight(&ve->context); in virtual_matches()
1018 if (inflight && inflight != engine) in virtual_matches()
[all …]
|
| H A D | intel_timeline.c | 423 unsigned long count, ready, inflight; in intel_gt_show_timelines() local
440 inflight = 0; in intel_gt_show_timelines()
449 inflight++; in intel_gt_show_timelines()
454 count, ready, inflight); in intel_gt_show_timelines()
|
| /openbmc/linux/net/atm/ |
| H 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()
|
| /openbmc/qemu/block/export/ |
| H A D | vduse-blk.c | 34 unsigned int inflight; /* atomic */ member
45 if (qatomic_fetch_inc(&vblk_exp->inflight) == 0) { in vduse_blk_inflight_inc()
53 if (qatomic_fetch_dec(&vblk_exp->inflight) == 1) { in vduse_blk_inflight_dec()
258 return qatomic_read(&vblk_exp->inflight) > 0; in vduse_blk_drained_poll()
392 assert(qatomic_read(&vblk_exp->inflight) == 0); in vduse_blk_exp_delete()
|
| /openbmc/qemu/hw/virtio/ |
| H A D | vhost-user.c | 224 VhostUserInflight inflight; member
2666 struct vhost_inflight *inflight) in vhost_user_get_inflight_fd() argument
2676 .payload.inflight.num_queues = dev->nvqs, in vhost_user_get_inflight_fd()
2677 .payload.inflight.queue_size = queue_size, in vhost_user_get_inflight_fd()
2678 .hdr.size = sizeof(msg.payload.inflight), in vhost_user_get_inflight_fd()
2703 if (msg.hdr.size != sizeof(msg.payload.inflight)) { in vhost_user_get_inflight_fd()
2708 if (!msg.payload.inflight.mmap_size) { in vhost_user_get_inflight_fd()
2718 addr = mmap(0, msg.payload.inflight.mmap_size, PROT_READ | PROT_WRITE, in vhost_user_get_inflight_fd()
2719 MAP_SHARED, fd, msg.payload.inflight.mmap_offset); in vhost_user_get_inflight_fd()
2727 inflight->addr = addr; in vhost_user_get_inflight_fd()
[all …]
|
| /openbmc/linux/drivers/infiniband/ulp/rtrs/ |
| H A D | rtrs-clt-stats.c | 102 atomic_read(&stats->inflight), sum.failover_cnt); in rtrs_clt_stats_rdma_to_str()
158 atomic_set(&s->inflight, 0); in rtrs_clt_reset_all_stats()
182 atomic_inc(&stats->inflight); in rtrs_clt_update_all_stats()
|
| /openbmc/linux/net/ipv4/ |
| H 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()
|
| /openbmc/qemu/hw/usb/ |
| H A D | host-libusb.c | 150 QTAILQ_HEAD(, USBHostIsoXfer) inflight;
503 bool inflight = (r->p && r->p->state == USB_PACKET_ASYNC); in usb_host_req_abort() local
505 if (inflight) { in usb_host_req_abort()
534 QTAILQ_REMOVE(&xfer->ring->inflight, xfer, next); in usb_host_req_complete_iso()
535 if (QTAILQ_EMPTY(&xfer->ring->inflight)) { in usb_host_req_complete_iso()
558 QTAILQ_INIT(&ring->inflight); in usb_host_iso_alloc()
606 static void usb_host_iso_free_xfer(USBHostIsoXfer *xfer, bool inflight) in usb_host_iso_free_xfer() argument
608 if (inflight) { in usb_host_iso_free_xfer()
621 while ((xfer = QTAILQ_FIRST(&ring->inflight)) != NULL) { in usb_host_iso_free()
622 QTAILQ_REMOVE(&ring->inflight, xfer, next); in usb_host_iso_free()
[all …]
|
| /openbmc/linux/drivers/vhost/ |
| H A D | scsi.c | 104 struct vhost_scsi_inflight *inflight; member
218 struct vhost_scsi_inflight *inflight; member
246 struct vhost_scsi_inflight *inflight; in vhost_scsi_done_inflight() local
248 inflight = container_of(kref, struct vhost_scsi_inflight, kref); in vhost_scsi_done_inflight()
249 complete(&inflight->comp); in vhost_scsi_done_inflight()
282 struct vhost_scsi_inflight *inflight; in vhost_scsi_get_inflight() local
286 inflight = &svq->inflights[svq->inflight_idx]; in vhost_scsi_get_inflight()
287 kref_get(&inflight->kref); in vhost_scsi_get_inflight()
289 return inflight; in vhost_scsi_get_inflight()
292 static void vhost_scsi_put_inflight(struct vhost_scsi_inflight *inflight) in vhost_scsi_put_inflight() argument
[all …]
|