Home
last modified time | relevance | path

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

12

/Linux-v5.4/drivers/mmc/core/
Dqueue.h81 int in_flight[MMC_ISSUE_MAX]; member
113 return mq->in_flight[MMC_ISSUE_SYNC] + in mmc_tot_in_flight()
114 mq->in_flight[MMC_ISSUE_DCMD] + in mmc_tot_in_flight()
115 mq->in_flight[MMC_ISSUE_ASYNC]; in mmc_tot_in_flight()
120 return mq->in_flight[MMC_ISSUE_DCMD] + in mmc_cqe_qcnt()
121 mq->in_flight[MMC_ISSUE_ASYNC]; in mmc_cqe_qcnt()
Dqueue.c29 return mq->in_flight[MMC_ISSUE_DCMD]; in mmc_cqe_dcmd_busy()
298 mq->in_flight[issue_type] += 1; in mmc_mq_queue_rq()
337 mq->in_flight[issue_type] -= 1; in mmc_mq_queue_rq()
/Linux-v5.4/drivers/md/
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.c288 atomic_t in_flight; member
302 atomic_t in_flight; member
777 BUG_ON(!atomic_read(&comp->in_flight)); in complete_journal_op()
778 if (likely(atomic_dec_and_test(&comp->in_flight))) in complete_journal_op()
800 atomic_add(roundup(pl_offset + n_bytes, PAGE_SIZE) >> PAGE_SHIFT, &comp->in_flight); in xor_journal()
880 atomic_add(2, &comp->in_flight); in crypt_journal()
908 atomic_inc(&comp->in_flight); in crypt_journal()
914 atomic_dec(&comp->in_flight); in crypt_journal()
1003 io_comp.in_flight = (atomic_t)ATOMIC_INIT(1); in write_journal()
1007 crypt_comp_1.in_flight = (atomic_t)ATOMIC_INIT(0); in write_journal()
[all …]
/Linux-v5.4/drivers/usb/serial/
Dusb_wwan.c229 intfdata->in_flight++; in usb_wwan_write()
238 intfdata->in_flight--; in usb_wwan_write()
310 intfdata->in_flight--; in usb_wwan_outdat_callback()
588 if (intfdata->in_flight) { in usb_wwan_suspend()
628 data->in_flight++; in usb_wwan_submit_delayed_urbs()
Dsierra.c57 int in_flight; member
427 --intfdata->in_flight; in sierra_outdat_callback()
517 intfdata->in_flight++; in sierra_write()
959 if (intfdata->in_flight) { in sierra_suspend()
989 intfdata->in_flight++; in sierra_submit_delayed_urbs()
995 intfdata->in_flight--; in sierra_submit_delayed_urbs()
Dusb-wwan.h41 int in_flight; member
/Linux-v5.4/fs/fuse/
Dvirtio_fs.c37 long in_flight; member
59 struct fuse_req *req, bool in_flight);
76 fsvq->in_flight++; in inc_in_flight_req()
82 WARN_ON(fsvq->in_flight <= 0); in dec_in_flight_req()
83 fsvq->in_flight--; in dec_in_flight_req()
111 WARN_ON(fsvq->in_flight < 0); in virtio_fs_drain_queue()
116 if (!fsvq->in_flight) { in virtio_fs_drain_queue()
876 struct fuse_req *req, bool in_flight) in virtio_fs_enqueue_req() argument
956 if (!in_flight) in virtio_fs_enqueue_req()
/Linux-v5.4/fs/cifs/
Dtransport.c535 server->in_flight++; in wait_for_free_credits()
536 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
537 server->max_in_flight = server->in_flight; in wait_for_free_credits()
581 server->in_flight > 2 * MAX_COMPOUND && in wait_for_free_credits()
613 server->in_flight += num_credits; in wait_for_free_credits()
614 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
615 server->max_in_flight = server->in_flight; in wait_for_free_credits()
647 if (server->in_flight < num - *credits) { in wait_for_compound_request()
Dcifsglob.h682 unsigned int in_flight; /* number of requests on the wire to server */ member
778 in_flight(struct TCP_Server_Info *server) in in_flight() function
782 num = server->in_flight; in in_flight()
/Linux-v5.4/block/
Dgenhd.c54 part_stat_local_inc(part, in_flight[rw]); in part_inc_in_flight()
56 part_stat_local_inc(&part_to_disk(part)->part0, in_flight[rw]); in part_inc_in_flight()
64 part_stat_local_dec(part, in_flight[rw]); in part_dec_in_flight()
66 part_stat_local_dec(&part_to_disk(part)->part0, in_flight[rw]); in part_dec_in_flight()
80 inflight += part_stat_local_read_cpu(part, in_flight[0], cpu) + in part_in_flight()
81 part_stat_local_read_cpu(part, in_flight[1], cpu); in part_in_flight()
102 inflight[0] += part_stat_local_read_cpu(part, in_flight[0], cpu); in part_in_flight_rw()
103 inflight[1] += part_stat_local_read_cpu(part, in_flight[1], cpu); in part_in_flight_rw()
/Linux-v5.4/drivers/block/drbd/
Ddrbd_bitmap.c972 if (atomic_dec_and_test(&ctx->in_flight)) { in drbd_bm_endio()
1058 .in_flight = ATOMIC_INIT(1), in bm_rw()
1088 atomic_inc(&ctx->in_flight); in bm_rw()
1107 atomic_inc(&ctx->in_flight); in bm_rw()
1128 atomic_inc(&ctx->in_flight); in bm_rw()
1143 if (!atomic_dec_and_test(&ctx->in_flight)) in bm_rw()
1164 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.4/Documentation/block/
Dstat.rst37 in_flight requests number of I/Os currently in flight
74 in_flight chapter
/Linux-v5.4/net/ipv4/
Dtcp_nv.c269 if (sample->in_flight == 0) in tcpnv_acked()
288 rate64 = ((u64)sample->in_flight) * 80000; in tcpnv_acked()
Dtcp_output.c1034 TCP_SKB_CB(skb)->tx.in_flight = TCP_SKB_CB(skb)->end_seq in __tcp_transmit_skb()
1794 u32 in_flight, cwnd, halfcwnd; in tcp_cwnd_test() local
1801 in_flight = tcp_packets_in_flight(tp); in tcp_cwnd_test()
1803 if (in_flight >= cwnd) in tcp_cwnd_test()
1810 return min(halfcwnd, cwnd - in_flight); in tcp_cwnd_test()
1937 u32 send_win, cong_win, limit, in_flight; in tcp_tso_should_defer() local
1955 in_flight = tcp_packets_in_flight(tp); in tcp_tso_should_defer()
1958 BUG_ON(tp->snd_cwnd <= in_flight); in tcp_tso_should_defer()
1963 cong_win = (tp->snd_cwnd - in_flight) * tp->mss_cache; in tcp_tso_should_defer()
/Linux-v5.4/drivers/crypto/
Dpicoxcell_crypto.c106 int in_flight; member
614 engine->in_flight + 1 <= engine->fifo_sz) { in spacc_push()
616 ++engine->in_flight; in spacc_push()
655 engine->in_flight + 1 > engine->fifo_sz) { in spacc_aead_setup()
985 engine->in_flight + 1 > engine->fifo_sz) { in spacc_ablk_setup()
1080 --engine->in_flight; in spacc_process_done()
1156 if (engine->in_flight) in spacc_spacc_complete()
1714 engine->in_flight = 0; in spacc_probe()
/Linux-v5.4/drivers/scsi/
Dst.h100 atomic64_t in_flight; /* Number of I/Os in flight */ member
/Linux-v5.4/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()
509 INIT_LIST_HEAD(&ring->in_flight); in tb_ring_alloc()
/Linux-v5.4/drivers/md/bcache/
Dwriteback.c304 up(&dc->in_flight); in write_dirty_finish()
482 down(&dc->in_flight); in read_dirty()
809 sema_init(&dc->in_flight, 64); in bch_cached_dev_writeback_init()
/Linux-v5.4/drivers/misc/genwqe/
Dcard_ddcb.c1334 int i, rc = 0, in_flight; in genwqe_finish_queue() local
1352 in_flight = genwqe_ddcbs_in_flight(cd); in genwqe_finish_queue()
1354 if (in_flight == 0) in genwqe_finish_queue()
1359 i, waitmax, in_flight); in genwqe_finish_queue()
/Linux-v5.4/drivers/scsi/fnic/
Dfnic_scsi.c218 while (atomic_read(&fnic->in_flight)) in fnic_fw_reset_handler()
486 atomic_inc(&fnic->in_flight); in fnic_queuecommand_lck()
580 atomic_dec(&fnic->in_flight); in fnic_queuecommand_lck()
610 atomic_dec(&fnic->in_flight); in fnic_queuecommand_lck()
1524 atomic_inc(&fnic->in_flight); in fnic_queue_abort_io_req()
1534 atomic_dec(&fnic->in_flight); in fnic_queue_abort_io_req()
1551 atomic_dec(&fnic->in_flight); in fnic_queue_abort_io_req()
2080 atomic_inc(&fnic->in_flight); in fnic_queue_dr_io_req()
2112 atomic_dec(&fnic->in_flight); in fnic_queue_dr_io_req()
Dfnic.h251 atomic_t in_flight; /* io counter */ member
/Linux-v5.4/net/tipc/
Dgroup.c741 u16 remitted, in_flight; in tipc_group_proto_rcv() local
818 in_flight = m->advertised - remitted; in tipc_group_proto_rcv()
819 m->advertised = ADV_IDLE + in_flight; in tipc_group_proto_rcv()
/Linux-v5.4/Documentation/ABI/testing/
Dsysfs-class-scsi_tape1 What: /sys/class/scsi_tape/*/stats/in_flight

12