Home
last modified time | relevance | path

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

/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()
230 atomic_read(&shared->in_flight[READ]), in dm_stats_cleanup()
231 atomic_read(&shared->in_flight[WRITE])); in dm_stats_cleanup()
337 atomic_set(&s->stat_shared[ni].in_flight[READ], 0); in dm_stats_create()
338 atomic_set(&s->stat_shared[ni].in_flight[WRITE], 0); in dm_stats_create()
534 in_flight_read = (unsigned)atomic_read(&shared->in_flight[READ]); in dm_stat_round()
535 in_flight_write = (unsigned)atomic_read(&shared->in_flight[WRITE]); in dm_stat_round()
580 atomic_inc(&shared->in_flight[idx]); in dm_stat_for_entry()
[all …]
Ddm-integrity.c306 atomic_t in_flight; member
316 atomic_t in_flight; member
889 BUG_ON(!atomic_read(&comp->in_flight)); in complete_journal_op()
890 if (likely(atomic_dec_and_test(&comp->in_flight))) in complete_journal_op()
912 atomic_add(roundup(pl_offset + n_bytes, PAGE_SIZE) >> PAGE_SHIFT, &comp->in_flight); in xor_journal()
992 atomic_add(2, &comp->in_flight); in crypt_journal()
1020 atomic_inc(&comp->in_flight); in crypt_journal()
1026 atomic_dec(&comp->in_flight); in crypt_journal()
1115 io_comp.in_flight = (atomic_t)ATOMIC_INIT(1); in write_journal()
1119 crypt_comp_1.in_flight = (atomic_t)ATOMIC_INIT(0); in write_journal()
[all …]
Ddm-cache-target.c2763 WARN_ON(cache->tracker.in_flight); in cache_postsuspend()
/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.c30 return mq->in_flight[MMC_ISSUE_DCMD]; in mmc_cqe_dcmd_busy()
269 if (!ret && host->hsq_enabled && mq->in_flight[issue_type] > 2) { in mmc_mq_queue_rq()
289 mq->in_flight[issue_type] += 1; in mmc_mq_queue_rq()
328 mq->in_flight[issue_type] -= 1; in mmc_mq_queue_rq()
Dblock.c1522 mq->in_flight[issue_type] -= 1; in mmc_blk_cqe_complete_rq()
2140 mq->in_flight[issue_type] -= 1; in mmc_blk_mq_dec_in_flight()
/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()
550 if (intfdata->in_flight) { in usb_wwan_suspend()
590 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()
938 if (intfdata->in_flight) { in sierra_suspend()
968 intfdata->in_flight++; in sierra_submit_delayed_urbs()
974 intfdata->in_flight--; in sierra_submit_delayed_urbs()
Dusb-wwan.h38 int in_flight; member
/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()
Ddrbd_int.h977 atomic_t in_flight; member
/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()
/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()
/drivers/scsi/
Dst.h99 atomic64_t in_flight; /* Number of I/Os in flight */ member
Dscsi_lib.c1123 bool in_flight; in scsi_init_command() local
1133 in_flight = test_bit(SCMD_STATE_INFLIGHT, &cmd->state); in scsi_init_command()
1152 if (in_flight) in scsi_init_command()
Dst.c511 atomic64_dec(&STp->stats->in_flight); in st_do_stats()
565 atomic64_inc(&STp->stats->in_flight); in st_scsi_execute()
4760 (long long)atomic64_read(&STm->tape->stats->in_flight)); in in_flight_show()
4762 static DEVICE_ATTR_RO(in_flight);
/drivers/thunderbolt/
Dnhi.c239 list_move_tail(&frame->list, &ring->in_flight); in ring_write_descriptors()
278 list_splice_tail_init(&ring->in_flight, &done); in ring_work()
288 frame = list_first_entry(&ring->in_flight, typeof(*frame), in ring_work()
354 frame = list_first_entry(&ring->in_flight, typeof(*frame), in tb_ring_poll()
585 INIT_LIST_HEAD(&ring->in_flight); in tb_ring_alloc()
/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()
Dfnic.h252 atomic_t in_flight; /* io counter */ member
Dfnic_main.c792 atomic_set(&fnic->in_flight, 0); in fnic_probe()
/drivers/md/bcache/
Dwriteback.c377 up(&dc->in_flight); in write_dirty_finish()
552 down(&dc->in_flight); in read_dirty()
1040 sema_init(&dc->in_flight, 64); in bch_cached_dev_writeback_init()
Dbcache.h341 struct semaphore in_flight; member