Home
last modified time | relevance | path

Searched refs:in_flight (Results 1 – 25 of 42) 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
192 return atomic_read(&shared->in_flight[READ]) + in dm_stat_in_flight()
193 atomic_read(&shared->in_flight[WRITE]); in dm_stat_in_flight()
235 atomic_read(&shared->in_flight[READ]), in dm_stats_cleanup()
236 atomic_read(&shared->in_flight[WRITE])); in dm_stats_cleanup()
348 atomic_set(&s->stat_shared[ni].in_flight[READ], 0); in dm_stats_create()
349 atomic_set(&s->stat_shared[ni].in_flight[WRITE], 0); in dm_stats_create()
551 in_flight_read = (unsigned int)atomic_read(&shared->in_flight[READ]); in dm_stat_round()
552 in_flight_write = (unsigned int)atomic_read(&shared->in_flight[WRITE]); in dm_stat_round()
598 atomic_inc(&shared->in_flight[idx]); in dm_stat_for_entry()
[all …]
H A Ddm-integrity.c329 atomic_t in_flight;
346 atomic_t in_flight;
891 BUG_ON(!atomic_read(&comp->in_flight)); in complete_journal_op()
892 if (likely(atomic_dec_and_test(&comp->in_flight))) in complete_journal_op()
914 atomic_add(roundup(pl_offset + n_bytes, PAGE_SIZE) >> PAGE_SHIFT, &comp->in_flight); in xor_journal()
997 atomic_add(2, &comp->in_flight); in crypt_journal()
1025 atomic_inc(&comp->in_flight); in crypt_journal()
1031 atomic_dec(&comp->in_flight); in crypt_journal()
1125 io_comp.in_flight = (atomic_t)ATOMIC_INIT(1); in write_journal()
1129 crypt_comp_1.in_flight in write_journal()
328 atomic_t in_flight; global() member
345 atomic_t in_flight; global() member
[all...]
/linux/fs/smb/client/
H A Dtransport.c431 int scredits, in_flight; in wait_for_free_credits() local
450 server->in_flight++; in wait_for_free_credits()
451 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
452 server->max_in_flight = server->in_flight; in wait_for_free_credits()
456 in_flight = server->in_flight; in wait_for_free_credits()
460 server->conn_id, server->hostname, scredits, -1, in_flight); in wait_for_free_credits()
489 in_flight = server->in_flight; in wait_for_free_credits()
494 num_credits, in_flight); in wait_for_free_credits()
517 server->in_flight > 2 * MAX_COMPOUND && in wait_for_free_credits()
531 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()
116 * Rebalance credits when an op drains in_flight. For session setup, in smb2_add_credits()
122 if (server->in_flight == 0 && in smb2_add_credits()
126 else if (server->in_flight == 0 && in smb2_add_credits()
133 else if (server->in_flight > in smb2_add_credits()
198 int scredits, in_flight; smb2_set_credits() local
250 unsigned int scredits, in_flight; smb2_wait_mtu_credits() local
318 int scredits, in_flight; smb2_adjust_credits() local
2744 int scredits, in_flight; smb2_is_status_pending() local
[all...]
H A Dtrace.h1796 int in_flight),
1797 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight),
1804 __field(int, in_flight)
1812 __entry->in_flight = in_flight;
1821 __entry->in_flight)
1831 int in_flight), \
1832 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight))
1928 __field(int, in_flight)
1937 __entry->in_flight = server_in_flight;
1945 __entry->server_credits, __entry->in_flight)
/linux/sound/usb/usx2y/
H A Dus144mkii_midi.c325 bool in_flight = true; in tascam_midi_out_drain() local
327 while (in_flight) { in tascam_midi_out_drain()
328 in_flight = false; in tascam_midi_out_drain()
331 in_flight = true; in tascam_midi_out_drain()
335 if (in_flight) in tascam_midi_out_drain()
/linux/drivers/usb/serial/
H A Dsierra.c56 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()
H A Dusb-wwan.h38 int in_flight; member
/linux/net/rxrpc/
H A Dinput_rack.c316 unsigned int in_flight = rxrpc_tx_in_flight(call); in rxrpc_tlp_send_probe() local
336 in_flight = rxrpc_tx_in_flight(call); in rxrpc_tlp_send_probe()
348 if (in_flight != 0) { in rxrpc_tlp_send_probe()
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()
/linux/drivers/block/drbd/
H A Ddrbd_bitmap.c970 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()
/linux/block/
H A Dblk.h501 part_stat_local_inc(bdev, in_flight[rw]); in bdev_inc_in_flight()
503 part_stat_local_inc(bdev_whole(bdev), in_flight[rw]); in bdev_inc_in_flight()
511 part_stat_local_dec(bdev, in_flight[rw]); in bdev_dec_in_flight()
513 part_stat_local_dec(bdev_whole(bdev), in_flight[rw]); in bdev_dec_in_flight()
/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/drivers/scsi/
H A Dst.h99 atomic64_t in_flight; /* Number of I/Os in flight */ member
/linux/drivers/misc/genwqe/
H A Dcard_ddcb.c1341 int i, rc = 0, in_flight; in genwqe_finish_queue() local
1359 in_flight = genwqe_ddcbs_in_flight(cd); in genwqe_finish_queue()
1361 if (in_flight == 0) in genwqe_finish_queue()
1366 i, waitmax, in_flight); in genwqe_finish_queue()
/linux/drivers/scsi/fnic/
H A Dfnic_nvme.c453 atomic_inc(&fnic->in_flight); in nvfnic_fcpio_send()
473 atomic_dec(&fnic->in_flight); in nvfnic_fcpio_send()
488 atomic_dec(&fnic->in_flight); in nvfnic_fcpio_send()
1142 atomic_read(&fnic->in_flight)); in nvfnic_terminate_tport_ios()
1883 atomic_inc(&fnic->in_flight); in nvfnic_queue_abort_io_req()
1892 atomic_dec(&fnic->in_flight); in nvfnic_queue_abort_io_req()
1909 atomic_dec(&fnic->in_flight); in nvfnic_queue_abort_io_req()
1992 atomic_inc(&fnic->in_flight); in nvfnic_fcpio_abort()
2033 atomic_dec(&fnic->in_flight); in nvfnic_fcpio_abort()
/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
829 in_flight = m->advertised - remitted; in tipc_group_proto_rcv()
830 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.h98 atomic_t in_flight; member
H A Dmsm_gem_vma.c771 atomic_sub(job->prealloc.count, &vm->prealloc_throttle.in_flight); in msm_vma_job_free()
1225 atomic_read(&vm->prealloc_throttle.in_flight) <= 1024); in vm_bind_prealloc_count()
1229 atomic_add(job->prealloc.count, &vm->prealloc_throttle.in_flight); in vm_bind_prealloc_count()
/linux/net/ipv4/
H A Dtcp_output.c2326 u32 in_flight, cwnd, halfcwnd; in tcp_cwnd_test() local
2328 in_flight = tcp_packets_in_flight(tp); in tcp_cwnd_test()
2330 if (in_flight >= cwnd) in tcp_cwnd_test()
2337 return min(halfcwnd, cwnd - in_flight); in tcp_cwnd_test()
2458 u32 send_win, cong_win, limit, in_flight, threshold; in tcp_tso_should_defer() local
2477 in_flight = tcp_packets_in_flight(tp); in tcp_tso_should_defer()
2480 BUG_ON(tcp_snd_cwnd(tp) <= in_flight); in tcp_tso_should_defer()
2485 cong_win = (tcp_snd_cwnd(tp) - in_flight) * tp->mss_cache; in tcp_tso_should_defer()

12