Home
last modified time | relevance | path

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

12

/linux/drivers/md/
H A Ddm-io-tracker.h19 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()
H A Ddm-stats.c37 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 …]
H A Ddm-integrity.c324 atomic_t in_flight; member
341 atomic_t in_flight; member
884 BUG_ON(!atomic_read(&comp->in_flight)); in complete_journal_op()
885 if (likely(atomic_dec_and_test(&comp->in_flight))) in complete_journal_op()
907 atomic_add(roundup(pl_offset + n_bytes, PAGE_SIZE) >> PAGE_SHIFT, &comp->in_flight); in xor_journal()
990 atomic_add(2, &comp->in_flight); in crypt_journal()
1018 atomic_inc(&comp->in_flight); in crypt_journal()
1024 atomic_dec(&comp->in_flight); in crypt_journal()
1116 io_comp.in_flight = (atomic_t)ATOMIC_INIT(1); in write_journal()
1120 crypt_comp_1.in_flight = (atomic_t)ATOMIC_INIT(0); in write_journal()
[all …]
/linux/drivers/mmc/core/
H A Dqueue.h81 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()
H A Dqueue.c29 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/fs/smb/client/
H A Dtransport.c433 int scredits, in_flight; in wait_for_free_credits() local
452 server->in_flight++; in wait_for_free_credits()
453 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
454 server->max_in_flight = server->in_flight; in wait_for_free_credits()
458 in_flight = server->in_flight; in wait_for_free_credits()
462 server->conn_id, server->hostname, scredits, -1, in_flight); in wait_for_free_credits()
491 in_flight = server->in_flight; in wait_for_free_credits()
496 num_credits, in_flight); in wait_for_free_credits()
519 server->in_flight > 2 * MAX_COMPOUND && in wait_for_free_credits()
533 in_flight = server->in_flight; in wait_for_free_credits()
[all …]
H A Dsmb2ops.c73 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()
105 pr_warn_once("rreq R=%08x[%x] Zero in_flight\n", 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 in smb2_add_credits()
187 int scredits, in_flight; smb2_set_credits() local
239 unsigned int scredits, in_flight; smb2_wait_mtu_credits() local
307 int scredits, in_flight; smb2_adjust_credits() local
2588 int scredits, in_flight; smb2_is_status_pending() local
[all...]
H A Dtrace.h1643 int in_flight),
1644 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight),
1651 __field(int, in_flight)
1659 __entry->in_flight = in_flight;
1662 "credits=%d credit_change=%d in_flight=%d",
1668 __entry->in_flight)
1678 int in_flight), \
1679 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight))
1775 __field(int, in_flight)
[all...]
/linux/fs/fuse/
H A Dvirtio_fs.c57 long in_flight; member
100 struct fuse_req *req, bool in_flight,
163 fsvq->in_flight++; in inc_in_flight_req()
169 WARN_ON(fsvq->in_flight <= 0); in dec_in_flight_req()
170 fsvq->in_flight--; in dec_in_flight_req()
171 if (!fsvq->in_flight) in dec_in_flight_req()
298 WARN_ON(fsvq->in_flight < 0); in virtio_fs_drain_queue()
302 if (fsvq->in_flight) { in virtio_fs_drain_queue()
619 bool in_flight) in send_forget_request() argument
629 if (in_flight) in send_forget_request()
[all …]
/linux/drivers/usb/serial/
H A Dusb_wwan.c185 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()
H A Dusb-wwan.h38 int in_flight; member
/linux/drivers/scsi/fnic/
H A Dfnic_scsi.c260 while (atomic_read(&fnic->in_flight)) in fnic_fw_reset_handler()
555 atomic_inc(&fnic->in_flight); in fnic_queuecommand()
556 atomic_inc(&tport->in_flight); in fnic_queuecommand()
559 atomic_dec(&fnic->in_flight); in fnic_queuecommand()
560 atomic_dec(&tport->in_flight); in fnic_queuecommand()
677 atomic_dec(&fnic->in_flight); in fnic_queuecommand()
678 atomic_dec(&tport->in_flight); in fnic_queuecommand()
705 atomic_dec(&fnic->in_flight); in fnic_queuecommand()
706 atomic_dec(&tport->in_flight); in fnic_queuecommand()
1718 atomic_dec(&fnic->in_flight); in fnic_queue_abort_io_req()
[all …]
H A Dfnic_fdls.h203 atomic_t in_flight; /* io counter */ member
/linux/include/linux/
H A Dpart_stat.h14 local_t in_flight[2]; member
/linux/drivers/firmware/arm_scmi/
H A Dnotify.c303 void *in_flight; member
480 pd->in_flight = NULL; in scmi_process_event_payload()
557 if (!pd->in_flight) { in scmi_events_dispatcher()
561 pd->in_flight = r_evt; in scmi_events_dispatcher()
563 r_evt = pd->in_flight; in scmi_events_dispatcher()
/linux/Documentation/block/
H A Dstat.rst37 in_flight requests number of I/Os currently in flight
84 in_flight chapter
/linux/net/ipv4/
H A Dtcp_nv.c268 if (sample->in_flight == 0) in tcpnv_acked()
287 rate64 = ((u64)sample->in_flight) * 80000; in tcpnv_acked()
/linux/drivers/block/drbd/
H A 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/drivers/scsi/
H A Dst.h99 atomic64_t in_flight; /* Number of I/Os in flight */ member
/linux/drivers/thunderbolt/
H A Dnhi.c247 list_move_tail(&frame->list, &ring->in_flight); in ring_write_descriptors()
286 list_splice_tail_init(&ring->in_flight, &done); in ring_work()
296 frame = list_first_entry(&ring->in_flight, typeof(*frame), in ring_work()
364 frame = list_first_entry(&ring->in_flight, typeof(*frame), in tb_ring_poll()
596 INIT_LIST_HEAD(&ring->in_flight); in tb_ring_alloc()
/linux/drivers/usb/host/
H A Dxen-hcd.c54 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/net/tipc/
H A Dgroup.c748 u16 remitted, in_flight; in tipc_group_proto_rcv() local
825 in_flight = m->advertised - remitted; in tipc_group_proto_rcv()
826 m->advertised = ADV_IDLE + in_flight; in tipc_group_proto_rcv()
/linux/Documentation/ABI/testing/
H A Dsysfs-class-scsi_tape1 What: /sys/class/scsi_tape/*/stats/in_flight
/linux/drivers/gpu/drm/msm/
H A Dmsm_gem.h95 atomic_t in_flight; member
/linux/net/rxrpc/
H A Dinput.c36 summary->in_flight = rxrpc_tx_in_flight(call); in rxrpc_congestion_management()
40 call->cong_ssthresh = umax(summary->in_flight / 2, 2); in rxrpc_congestion_management()
104 call->cong_ssthresh = umax(summary->in_flight / 2, 2); in rxrpc_congestion_management()

12