Home
last modified time | relevance | path

Searched refs:in_flight (Results 1 – 25 of 46) sorted by relevance

12

/Linux-v5.15/drivers/md/
Ddm-io-tracker.h18 sector_t in_flight; member
31 iot->in_flight = 0ul; in dm_iot_init()
41 if (!iot->in_flight) in dm_iot_idle_for()
53 if (!iot->in_flight) in dm_iot_idle_time()
63 iot->in_flight += len; in dm_iot_io_begin()
75 iot->in_flight -= len; in dm_iot_io_end()
76 if (!iot->in_flight) in dm_iot_io_end()
Ddm-stats.c37 atomic_t in_flight[2]; member
187 return atomic_read(&shared->in_flight[READ]) + in dm_stat_in_flight()
188 atomic_read(&shared->in_flight[WRITE]); in dm_stat_in_flight()
224 atomic_read(&shared->in_flight[READ]), in dm_stats_cleanup()
225 atomic_read(&shared->in_flight[WRITE])); in dm_stats_cleanup()
314 atomic_set(&s->stat_shared[ni].in_flight[READ], 0); in dm_stats_create()
315 atomic_set(&s->stat_shared[ni].in_flight[WRITE], 0); in dm_stats_create()
501 in_flight_read = (unsigned)atomic_read(&shared->in_flight[READ]); in dm_stat_round()
502 in_flight_write = (unsigned)atomic_read(&shared->in_flight[WRITE]); in dm_stat_round()
547 atomic_inc(&shared->in_flight[idx]); in dm_stat_for_entry()
[all …]
Ddm-integrity.c305 atomic_t in_flight; member
315 atomic_t in_flight; member
888 BUG_ON(!atomic_read(&comp->in_flight)); in complete_journal_op()
889 if (likely(atomic_dec_and_test(&comp->in_flight))) in complete_journal_op()
911 atomic_add(roundup(pl_offset + n_bytes, PAGE_SIZE) >> PAGE_SHIFT, &comp->in_flight); in xor_journal()
991 atomic_add(2, &comp->in_flight); in crypt_journal()
1019 atomic_inc(&comp->in_flight); in crypt_journal()
1025 atomic_dec(&comp->in_flight); in crypt_journal()
1114 io_comp.in_flight = (atomic_t)ATOMIC_INIT(1); in write_journal()
1118 crypt_comp_1.in_flight = (atomic_t)ATOMIC_INIT(0); in write_journal()
[all …]
/Linux-v5.15/drivers/mmc/core/
Dqueue.h81 int in_flight[MMC_ISSUE_MAX]; member
111 return mq->in_flight[MMC_ISSUE_SYNC] + in mmc_tot_in_flight()
112 mq->in_flight[MMC_ISSUE_DCMD] + in mmc_tot_in_flight()
113 mq->in_flight[MMC_ISSUE_ASYNC]; in mmc_tot_in_flight()
118 return mq->in_flight[MMC_ISSUE_DCMD] + in mmc_cqe_qcnt()
119 mq->in_flight[MMC_ISSUE_ASYNC]; in mmc_cqe_qcnt()
Dqueue.c29 return mq->in_flight[MMC_ISSUE_DCMD]; in mmc_cqe_dcmd_busy()
266 if (host->hsq_enabled && mq->in_flight[issue_type] > 2) { in mmc_mq_queue_rq()
286 mq->in_flight[issue_type] += 1; in mmc_mq_queue_rq()
325 mq->in_flight[issue_type] -= 1; in mmc_mq_queue_rq()
/Linux-v5.15/fs/cifs/
Dtransport.c519 int scredits, in_flight; in wait_for_free_credits() local
538 server->in_flight++; in wait_for_free_credits()
539 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
540 server->max_in_flight = server->in_flight; in wait_for_free_credits()
544 in_flight = server->in_flight; in wait_for_free_credits()
548 server->conn_id, server->hostname, scredits, -1, in_flight); in wait_for_free_credits()
567 in_flight = server->in_flight; in wait_for_free_credits()
572 num_credits, in_flight); in wait_for_free_credits()
600 server->in_flight > 2 * MAX_COMPOUND && in wait_for_free_credits()
614 in_flight = server->in_flight; in wait_for_free_credits()
[all …]
Dtrace.h894 int in_flight),
895 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight),
902 __field(int, in_flight)
910 __entry->in_flight = in_flight;
919 __entry->in_flight)
929 int in_flight), \
930 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight))
Dsmb2ops.c66 int scredits, in_flight; in smb2_add_credits() local
88 server->in_flight--; in smb2_add_credits()
89 if (server->in_flight == 0 && in smb2_add_credits()
97 else if (server->in_flight > 0 && server->oplock_credits == 0 && in smb2_add_credits()
105 in_flight = server->in_flight; in smb2_add_credits()
111 server->conn_id, server->hostname, scredits, add, in_flight); in smb2_add_credits()
119 server->conn_id, server->hostname, scredits, add, in_flight); in smb2_add_credits()
147 server->conn_id, server->hostname, scredits, add, in_flight); in smb2_add_credits()
154 int scredits, in_flight; in smb2_set_credits() local
161 in_flight = server->in_flight; in smb2_set_credits()
[all …]
/Linux-v5.15/fs/fuse/
Dvirtio_fs.c50 long in_flight; member
89 struct fuse_req *req, bool in_flight);
139 fsvq->in_flight++; in inc_in_flight_req()
145 WARN_ON(fsvq->in_flight <= 0); in dec_in_flight_req()
146 fsvq->in_flight--; in dec_in_flight_req()
147 if (!fsvq->in_flight) in dec_in_flight_req()
176 WARN_ON(fsvq->in_flight < 0); in virtio_fs_drain_queue()
180 if (fsvq->in_flight) { in virtio_fs_drain_queue()
400 bool in_flight) in send_forget_request() argument
410 if (in_flight) in send_forget_request()
[all …]
/Linux-v5.15/drivers/usb/serial/
Dusb_wwan.c184 intfdata->in_flight++; in usb_wwan_write()
193 intfdata->in_flight--; in usb_wwan_write()
269 intfdata->in_flight--; in usb_wwan_outdat_callback()
549 if (intfdata->in_flight) { in usb_wwan_suspend()
589 data->in_flight++; in usb_wwan_submit_delayed_urbs()
Dsierra.c56 int in_flight; member
408 --intfdata->in_flight; in sierra_outdat_callback()
498 intfdata->in_flight++; in sierra_write()
937 if (intfdata->in_flight) { in sierra_suspend()
967 intfdata->in_flight++; in sierra_submit_delayed_urbs()
973 intfdata->in_flight--; in sierra_submit_delayed_urbs()
Dusb-wwan.h38 int in_flight; member
/Linux-v5.15/drivers/block/drbd/
Ddrbd_bitmap.c970 if (atomic_dec_and_test(&ctx->in_flight)) { in drbd_bm_endio()
1056 .in_flight = ATOMIC_INIT(1), in bm_rw()
1086 atomic_inc(&ctx->in_flight); in bm_rw()
1105 atomic_inc(&ctx->in_flight); in bm_rw()
1126 atomic_inc(&ctx->in_flight); in bm_rw()
1141 if (!atomic_dec_and_test(&ctx->in_flight)) in bm_rw()
1162 if (atomic_read(&ctx->in_flight)) in bm_rw()
Ddrbd_debugfs.c195 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-v5.15/include/linux/
Dpart_stat.h13 local_t in_flight[2]; member
/Linux-v5.15/drivers/firmware/arm_scmi/
Dnotify.c302 void *in_flight; member
475 pd->in_flight = NULL; in scmi_process_event_payload()
552 if (!pd->in_flight) { in scmi_events_dispatcher()
556 pd->in_flight = r_evt; in scmi_events_dispatcher()
558 r_evt = pd->in_flight; in scmi_events_dispatcher()
/Linux-v5.15/net/ipv4/
Dtcp_nv.c269 if (sample->in_flight == 0) in tcpnv_acked()
288 rate64 = ((u64)sample->in_flight) * 80000; in tcpnv_acked()
/Linux-v5.15/Documentation/block/
Dstat.rst37 in_flight requests number of I/Os currently in flight
84 in_flight chapter
/Linux-v5.15/drivers/scsi/
Dst.h99 atomic64_t in_flight; /* Number of I/Os in flight */ member
/Linux-v5.15/drivers/thunderbolt/
Dnhi.c201 list_move_tail(&frame->list, &ring->in_flight); in ring_write_descriptors()
240 list_splice_tail_init(&ring->in_flight, &done); in ring_work()
250 frame = list_first_entry(&ring->in_flight, typeof(*frame), in ring_work()
316 frame = list_first_entry(&ring->in_flight, typeof(*frame), in tb_ring_poll()
529 INIT_LIST_HEAD(&ring->in_flight); in tb_ring_alloc()
/Linux-v5.15/drivers/misc/genwqe/
Dcard_ddcb.c1344 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-v5.15/tools/testing/selftests/bpf/
Dbpf_tcp_helpers.h132 __u32 in_flight; member
/Linux-v5.15/drivers/scsi/fnic/
Dfnic_scsi.c219 while (atomic_read(&fnic->in_flight)) in fnic_fw_reset_handler()
491 atomic_inc(&fnic->in_flight); in fnic_queuecommand_lck()
584 atomic_dec(&fnic->in_flight); in fnic_queuecommand_lck()
613 atomic_dec(&fnic->in_flight); in fnic_queuecommand_lck()
1526 atomic_inc(&fnic->in_flight); in fnic_queue_abort_io_req()
1536 atomic_dec(&fnic->in_flight); in fnic_queue_abort_io_req()
1553 atomic_dec(&fnic->in_flight); in fnic_queue_abort_io_req()
1977 atomic_inc(&fnic->in_flight); in fnic_queue_dr_io_req()
2009 atomic_dec(&fnic->in_flight); in fnic_queue_dr_io_req()
/Linux-v5.15/block/
Dgenhd.c149 inflight += part_stat_local_read_cpu(part, in_flight[0], cpu) + in part_in_flight()
150 part_stat_local_read_cpu(part, in_flight[1], cpu); in part_in_flight()
166 inflight[0] += part_stat_local_read_cpu(part, in_flight[0], cpu); in part_in_flight_rw()
167 inflight[1] += part_stat_local_read_cpu(part, in_flight[1], cpu); in part_in_flight_rw()
/Linux-v5.15/drivers/md/bcache/
Dwriteback.c346 up(&dc->in_flight); in write_dirty_finish()
521 down(&dc->in_flight); in read_dirty()
1011 sema_init(&dc->in_flight, 64); in bch_cached_dev_writeback_init()

12