/linux-6.12.1/drivers/md/ |
D | dm-io-tracker.h | 19 sector_t in_flight; member 32 iot->in_flight = 0ul; in dm_iot_init() 42 if (!iot->in_flight) in dm_iot_idle_for() 54 if (!iot->in_flight) in dm_iot_idle_time() 64 iot->in_flight += len; in dm_iot_io_begin() 76 iot->in_flight -= len; in dm_iot_io_end() 77 if (!iot->in_flight) in dm_iot_io_end()
|
D | dm-stats.c | 37 atomic_t in_flight[2]; member 190 return atomic_read(&shared->in_flight[READ]) + in dm_stat_in_flight() 191 atomic_read(&shared->in_flight[WRITE]); in dm_stat_in_flight() 233 atomic_read(&shared->in_flight[READ]), in dm_stats_cleanup() 234 atomic_read(&shared->in_flight[WRITE])); in dm_stats_cleanup() 346 atomic_set(&s->stat_shared[ni].in_flight[READ], 0); in dm_stats_create() 347 atomic_set(&s->stat_shared[ni].in_flight[WRITE], 0); in dm_stats_create() 549 in_flight_read = (unsigned int)atomic_read(&shared->in_flight[READ]); in dm_stat_round() 550 in_flight_write = (unsigned int)atomic_read(&shared->in_flight[WRITE]); in dm_stat_round() 596 atomic_inc(&shared->in_flight[idx]); in dm_stat_for_entry() [all …]
|
D | dm-integrity.c | 317 atomic_t in_flight; member 332 atomic_t in_flight; member 874 BUG_ON(!atomic_read(&comp->in_flight)); in complete_journal_op() 875 if (likely(atomic_dec_and_test(&comp->in_flight))) in complete_journal_op() 897 atomic_add(roundup(pl_offset + n_bytes, PAGE_SIZE) >> PAGE_SHIFT, &comp->in_flight); in xor_journal() 980 atomic_add(2, &comp->in_flight); in crypt_journal() 1008 atomic_inc(&comp->in_flight); in crypt_journal() 1014 atomic_dec(&comp->in_flight); in crypt_journal() 1106 io_comp.in_flight = (atomic_t)ATOMIC_INIT(1); in write_journal() 1110 crypt_comp_1.in_flight = (atomic_t)ATOMIC_INIT(0); in write_journal() [all …]
|
/linux-6.12.1/drivers/mmc/core/ |
D | queue.h | 81 int in_flight[MMC_ISSUE_MAX]; member 112 return mq->in_flight[MMC_ISSUE_SYNC] + in mmc_tot_in_flight() 113 mq->in_flight[MMC_ISSUE_DCMD] + in mmc_tot_in_flight() 114 mq->in_flight[MMC_ISSUE_ASYNC]; in mmc_tot_in_flight() 119 return mq->in_flight[MMC_ISSUE_DCMD] + in mmc_cqe_qcnt() 120 mq->in_flight[MMC_ISSUE_ASYNC]; in mmc_cqe_qcnt()
|
D | queue.c | 29 return mq->in_flight[MMC_ISSUE_DCMD]; in mmc_cqe_dcmd_busy() 265 if (host->hsq_enabled && mq->in_flight[issue_type] > host->hsq_depth) { in mmc_mq_queue_rq() 285 mq->in_flight[issue_type] += 1; in mmc_mq_queue_rq() 324 mq->in_flight[issue_type] -= 1; in mmc_mq_queue_rq()
|
/linux-6.12.1/fs/smb/client/ |
D | transport.c | 498 int scredits, in_flight; in wait_for_free_credits() local 517 server->in_flight++; in wait_for_free_credits() 518 if (server->in_flight > server->max_in_flight) in wait_for_free_credits() 519 server->max_in_flight = server->in_flight; in wait_for_free_credits() 523 in_flight = server->in_flight; in wait_for_free_credits() 527 server->conn_id, server->hostname, scredits, -1, in_flight); in wait_for_free_credits() 556 in_flight = server->in_flight; in wait_for_free_credits() 561 num_credits, in_flight); in wait_for_free_credits() 584 server->in_flight > 2 * MAX_COMPOUND && in wait_for_free_credits() 598 in_flight = server->in_flight; in wait_for_free_credits() [all …]
|
D | smb2ops.c | 73 int scredits, in_flight; in smb2_add_credits() local 96 add, server->in_flight); in smb2_add_credits() 104 if (WARN_ON_ONCE(server->in_flight == 0)) { in smb2_add_credits() 110 server->credits, server->in_flight, 0, in smb2_add_credits() 113 server->in_flight--; in smb2_add_credits() 114 if (server->in_flight == 0 && in smb2_add_credits() 122 else if (server->in_flight > 0 && server->oplock_credits == 0 && in smb2_add_credits() 128 } else if ((server->in_flight > 0) && (server->oplock_credits > 3) && in smb2_add_credits() 134 in_flight = server->in_flight; in smb2_add_credits() 140 server->conn_id, server->hostname, scredits, add, in_flight); in smb2_add_credits() [all …]
|
D | trace.h | 1463 int in_flight), 1464 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight), 1471 __field(int, in_flight) 1479 __entry->in_flight = in_flight; 1488 __entry->in_flight) 1498 int in_flight), \ 1499 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight)) 1552 __field(int, in_flight) 1561 __entry->in_flight = server_in_flight; 1569 __entry->server_credits, __entry->in_flight)
|
/linux-6.12.1/fs/fuse/ |
D | virtio_fs.c | 57 long in_flight; member 100 struct fuse_req *req, bool in_flight); 162 fsvq->in_flight++; in inc_in_flight_req() 168 WARN_ON(fsvq->in_flight <= 0); in dec_in_flight_req() 169 fsvq->in_flight--; in dec_in_flight_req() 170 if (!fsvq->in_flight) in dec_in_flight_req() 297 WARN_ON(fsvq->in_flight < 0); in virtio_fs_drain_queue() 301 if (fsvq->in_flight) { in virtio_fs_drain_queue() 613 bool in_flight) in send_forget_request() argument 623 if (in_flight) in send_forget_request() [all …]
|
/linux-6.12.1/drivers/usb/serial/ |
D | usb_wwan.c | 185 intfdata->in_flight++; in usb_wwan_write() 194 intfdata->in_flight--; in usb_wwan_write() 270 intfdata->in_flight--; in usb_wwan_outdat_callback() 551 if (intfdata->in_flight) { in usb_wwan_suspend() 591 data->in_flight++; in usb_wwan_submit_delayed_urbs()
|
D | sierra.c | 56 int in_flight; member 408 --intfdata->in_flight; in sierra_outdat_callback() 496 intfdata->in_flight++; in sierra_write() 936 if (intfdata->in_flight) { in sierra_suspend() 966 intfdata->in_flight++; in sierra_submit_delayed_urbs() 972 intfdata->in_flight--; in sierra_submit_delayed_urbs()
|
D | usb-wwan.h | 38 int in_flight; member
|
/linux-6.12.1/drivers/block/drbd/ |
D | drbd_bitmap.c | 970 if (atomic_dec_and_test(&ctx->in_flight)) { in drbd_bm_endio() 1022 if (atomic_dec_and_test(&ctx->in_flight)) { in bm_page_io_async() 1088 .in_flight = ATOMIC_INIT(1), in bm_rw() 1118 atomic_inc(&ctx->in_flight); in bm_rw() 1137 atomic_inc(&ctx->in_flight); in bm_rw() 1158 atomic_inc(&ctx->in_flight); in bm_rw() 1173 if (!atomic_dec_and_test(&ctx->in_flight)) in bm_rw() 1194 if (atomic_read(&ctx->in_flight)) in bm_rw()
|
D | drbd_debugfs.c | 195 unsigned int in_flight; in seq_print_device_bitmap_io() local 203 in_flight = atomic_read(&ctx->in_flight); in seq_print_device_bitmap_io() 212 in_flight); in seq_print_device_bitmap_io()
|
/linux-6.12.1/fs/bcachefs/ |
D | movinggc.c | 156 size_t saw = 0, in_flight = 0, not_movable = 0, sectors = 0; in bch2_copygc_get_buckets() local 186 in_flight++; in bch2_copygc_get_buckets() 201 saw, in_flight, not_movable, buckets->nr, sectors, nr_to_get, ret); in bch2_copygc_get_buckets()
|
/linux-6.12.1/drivers/firmware/arm_scmi/ |
D | notify.c | 303 void *in_flight; member 476 pd->in_flight = NULL; in scmi_process_event_payload() 553 if (!pd->in_flight) { in scmi_events_dispatcher() 557 pd->in_flight = r_evt; in scmi_events_dispatcher() 559 r_evt = pd->in_flight; in scmi_events_dispatcher()
|
/linux-6.12.1/include/linux/ |
D | part_stat.h | 14 local_t in_flight[2]; member
|
/linux-6.12.1/Documentation/block/ |
D | stat.rst | 37 in_flight requests number of I/Os currently in flight 84 in_flight chapter
|
/linux-6.12.1/net/ipv4/ |
D | tcp_nv.c | 268 if (sample->in_flight == 0) in tcpnv_acked() 287 rate64 = ((u64)sample->in_flight) * 80000; in tcpnv_acked()
|
/linux-6.12.1/drivers/scsi/ |
D | st.h | 99 atomic64_t in_flight; /* Number of I/Os in flight */ member
|
/linux-6.12.1/drivers/misc/genwqe/ |
D | card_ddcb.c | 1344 int i, rc = 0, in_flight; in genwqe_finish_queue() local 1362 in_flight = genwqe_ddcbs_in_flight(cd); in genwqe_finish_queue() 1364 if (in_flight == 0) in genwqe_finish_queue() 1369 i, waitmax, in_flight); in genwqe_finish_queue()
|
/linux-6.12.1/drivers/usb/host/ |
D | xen-hcd.c | 54 bool in_flight; member 722 if (!shadow->in_flight) { in xenhcd_gnttab_done() 726 shadow->in_flight = false; in xenhcd_gnttab_done() 811 info->shadow[id].in_flight = true; in xenhcd_do_request() 1492 info->shadow[i].in_flight = false; in xenhcd_create_hcd()
|
/linux-6.12.1/drivers/thunderbolt/ |
D | nhi.c | 246 list_move_tail(&frame->list, &ring->in_flight); in ring_write_descriptors() 285 list_splice_tail_init(&ring->in_flight, &done); in ring_work() 295 frame = list_first_entry(&ring->in_flight, typeof(*frame), in ring_work() 361 frame = list_first_entry(&ring->in_flight, typeof(*frame), in tb_ring_poll() 593 INIT_LIST_HEAD(&ring->in_flight); in tb_ring_alloc()
|
/linux-6.12.1/block/ |
D | genhd.c | 127 inflight += part_stat_local_read_cpu(part, in_flight[0], cpu) + in part_in_flight() 128 part_stat_local_read_cpu(part, in_flight[1], cpu); in part_in_flight() 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()
|
/linux-6.12.1/drivers/scsi/fnic/ |
D | fnic_scsi.c | 190 while (atomic_read(&fnic->in_flight)) in fnic_fw_reset_handler() 478 atomic_inc(&fnic->in_flight); in fnic_queuecommand() 577 atomic_dec(&fnic->in_flight); in fnic_queuecommand() 604 atomic_dec(&fnic->in_flight); in fnic_queuecommand() 1577 atomic_inc(&fnic->in_flight); in fnic_queue_abort_io_req() 1587 atomic_dec(&fnic->in_flight); in fnic_queue_abort_io_req() 1604 atomic_dec(&fnic->in_flight); in fnic_queue_abort_io_req() 2041 atomic_inc(&fnic->in_flight); in fnic_queue_dr_io_req() 2074 atomic_dec(&fnic->in_flight); in fnic_queue_dr_io_req()
|