Home
last modified time | relevance | path

Searched refs:inflight (Results 1 – 25 of 83) sorted by relevance

1234

/openbmc/linux/include/trace/events/
H A Dpage_pool.h17 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 Dwbt.h132 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 Dgenhd.c131 inflight = 0; in part_in_flight()
133 return inflight; in part_in_flight()
141 inflight[0] = 0; in part_in_flight_rw()
142 inflight[1] = 0; in part_in_flight_rw()
148 inflight[0] = 0; in part_in_flight_rw()
150 inflight[1] = 0; in part_in_flight_rw()
956 if (inflight) { in part_stat_show()
977 inflight, in part_stat_show()
1004 return sprintf(buf, "%8u %8u\n", inflight[0], inflight[1]); in part_inflight_show()
1257 if (inflight) { in diskstats_show()
[all …]
H A Dblk-wbt.c199 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 Dgarbage.c169 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 Dscm.c56 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 Dsmc.c62 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/include/hw/virtio/
H A Dvhost.h335 void vhost_dev_reset_inflight(struct vhost_inflight *inflight);
336 void vhost_dev_free_inflight(struct vhost_inflight *inflight);
337 void vhost_dev_save_inflight(struct vhost_inflight *inflight, QEMUFile *f);
338 int vhost_dev_load_inflight(struct vhost_inflight *inflight, QEMUFile *f);
341 struct vhost_inflight *inflight);
343 struct vhost_inflight *inflight);
/openbmc/qemu/subprojects/libvduse/
H A Dlibvduse.c62 uint8_t inflight; member
78 VduseVirtqLogInflight inflight; member
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()
265 if (vq->log->inflight.desc[i].inflight) { in vduse_queue_check_inflights()
291 vq->log->inflight.desc[desc_idx].inflight = 1; in vduse_queue_inflight_get()
298 vq->log->inflight.last_batch_head = desc_idx; in vduse_queue_inflight_pre_put()
305 vq->log->inflight.desc[desc_idx].inflight = 0; in vduse_queue_inflight_post_put()
[all …]
/openbmc/linux/net/core/
H A Dpage_pool.c499 s32 inflight; in page_pool_inflight() local
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
867 inflight = page_pool_release(pool); in page_pool_release_retry()
868 if (!inflight) in page_pool_release_retry()
[all …]
/openbmc/qemu/hw/scsi/
H A Dvhost-scsi-common.c63 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 Dvhost-user-scsi.c280 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/linux/drivers/crypto/chelsio/
H A Dchcr_core.c56 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/block/
H A Dvhost-user-blk.c153 if (!s->inflight->addr) { in vhost_user_blk_start()
154 ret = vhost_dev_get_inflight(&s->dev, s->queue_size, s->inflight); in vhost_user_blk_start()
161 ret = vhost_dev_set_inflight(&s->dev, s->inflight); in vhost_user_blk_start()
314 vhost_dev_free_inflight(s->inflight); in vhost_user_blk_reset()
476 s->inflight = g_new0(struct vhost_inflight, 1); in vhost_user_blk_device_realize()
503 g_free(s->inflight); in vhost_user_blk_device_realize()
504 s->inflight = NULL; in vhost_user_blk_device_realize()
523 vhost_dev_free_inflight(s->inflight); in vhost_user_blk_device_unrealize()
526 g_free(s->inflight); in vhost_user_blk_device_unrealize()
527 s->inflight = NULL; in vhost_user_blk_device_unrealize()
/openbmc/qemu/subprojects/libvhost-user/
H A Dlibvhost-user.c1340 if (unlikely(!vq->inflight)) { in vu_check_queue_inflights()
1356 vq->inflight->desc[vq->inflight->last_batch_head].inflight = 0; in vu_check_queue_inflights()
1364 if (vq->inflight->desc[i].inflight == 1) { in vu_check_queue_inflights()
1378 if (vq->inflight->desc[i].inflight) { in vu_check_queue_inflights()
2222 vq->inflight = NULL; in vu_deinit()
2885 if (unlikely(!vq->inflight)) { in vu_queue_inflight_get()
2890 vq->inflight->desc[desc_idx].inflight = 1; in vu_queue_inflight_get()
2902 if (unlikely(!vq->inflight)) { in vu_queue_inflight_pre_put()
2918 if (unlikely(!vq->inflight)) { in vu_queue_inflight_post_put()
2924 vq->inflight->desc[desc_idx].inflight = 0; in vu_queue_inflight_post_put()
[all …]
/openbmc/qemu/hw/virtio/
H A Dvhost.c1926 if (inflight && inflight->addr) { in vhost_dev_free_inflight()
1927 qemu_memfd_free(inflight->addr, inflight->size, inflight->fd); in vhost_dev_free_inflight()
1928 inflight->addr = NULL; in vhost_dev_free_inflight()
1929 inflight->fd = -1; in vhost_dev_free_inflight()
1948 inflight->offset = 0; in vhost_dev_resize_inflight()
1949 inflight->addr = addr; in vhost_dev_resize_inflight()
1950 inflight->fd = fd; in vhost_dev_resize_inflight()
1951 inflight->size = new_size; in vhost_dev_resize_inflight()
1958 if (inflight->addr) { in vhost_dev_save_inflight()
1961 qemu_put_buffer(f, inflight->addr, inflight->size); in vhost_dev_save_inflight()
[all …]
H A Dvhost-user.c224 VhostUserInflight inflight; member
2655 .payload.inflight.num_queues = dev->nvqs, in vhost_user_get_inflight_fd()
2687 if (!msg.payload.inflight.mmap_size) { in vhost_user_get_inflight_fd()
2706 inflight->addr = addr; in vhost_user_get_inflight_fd()
2707 inflight->fd = fd; in vhost_user_get_inflight_fd()
2708 inflight->size = msg.payload.inflight.mmap_size; in vhost_user_get_inflight_fd()
2709 inflight->offset = msg.payload.inflight.mmap_offset; in vhost_user_get_inflight_fd()
2710 inflight->queue_size = queue_size; in vhost_user_get_inflight_fd()
2721 .payload.inflight.mmap_size = inflight->size, in vhost_user_set_inflight_fd()
2722 .payload.inflight.mmap_offset = inflight->offset, in vhost_user_set_inflight_fd()
[all …]
/openbmc/linux/drivers/gpu/drm/i915/gt/
H A Dintel_context_types.h90 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 Dintel_execlists_submission.c538 old = ce->inflight; 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()
1018 if (inflight && inflight != engine) in virtual_matches()
1653 clear_ports(execlists->inflight, ARRAY_SIZE(execlists->inflight)); in cancel_port_requests()
1937 copy_ports(execlists->inflight, in process_csb()
3338 if (!inflight) in kick_execlists()
3352 inflight->fence.context, inflight->fence.seqno, in kick_execlists()
[all …]
/openbmc/linux/net/atm/
H A Dpppoatm.c64 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 Dvduse-blk.c34 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()
395 assert(qatomic_read(&vblk_exp->inflight) == 0); in vduse_blk_exp_delete()
/openbmc/linux/drivers/infiniband/ulp/rtrs/
H A Drtrs-clt-stats.c102 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 Dtcp_bbr.c414 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 Dhost-libusb.c150 QTAILQ_HEAD(, USBHostIsoXfer) inflight;
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()
608 if (inflight) { in usb_host_iso_free_xfer()
622 QTAILQ_REMOVE(&ring->inflight, xfer, next); in usb_host_iso_free()
707 if (QTAILQ_EMPTY(&ring->inflight)) { in usb_host_iso_data_in()
710 QTAILQ_INSERT_TAIL(&ring->inflight, xfer, next); in usb_host_iso_data_in()
748 if (QTAILQ_EMPTY(&ring->inflight)) { in usb_host_iso_data_out()
[all …]
/openbmc/linux/drivers/vhost/
H A Dscsi.c104 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
249 complete(&inflight->comp); in vhost_scsi_done_inflight()
282 struct vhost_scsi_inflight *inflight; in vhost_scsi_get_inflight() local
287 kref_get(&inflight->kref); in vhost_scsi_get_inflight()
289 return inflight; in vhost_scsi_get_inflight()
332 struct vhost_scsi_inflight *inflight = tv_cmd->inflight; in vhost_scsi_release_cmd_res() local
350 vhost_scsi_put_inflight(inflight); in vhost_scsi_release_cmd_res()
355 struct vhost_scsi_inflight *inflight = tmf->inflight; in vhost_scsi_release_tmf_res() local
[all …]

1234