Home
last modified time | relevance | path

Searched refs:in_flight (Results 1 - 25 of 86) sorted by relevance

1234

/kernel/linux/linux-6.6/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
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()
540 in_flight_read = (unsigned int)atomic_read(&shared->in_flight[READ]); in dm_stat_round()
541 in_flight_write = (unsigned int)atomic_read(&shared->in_flight[WRITE]); in dm_stat_round()
587 atomic_inc(&shared->in_flight[id in dm_stat_for_entry()
[all...]
/kernel/linux/linux-5.10/drivers/mmc/core/
H A 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()
H A Dqueue.c29 return mq->in_flight[MMC_ISSUE_DCMD]; in mmc_cqe_dcmd_busy()
286 if (host->hsq_enabled && mq->in_flight[issue_type] > 2) { in mmc_mq_queue_rq()
306 mq->in_flight[issue_type] += 1; in mmc_mq_queue_rq()
345 mq->in_flight[issue_type] -= 1; in mmc_mq_queue_rq()
/kernel/linux/linux-6.6/drivers/mmc/core/
H A 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()
H A Dqueue.c29 return mq->in_flight[MMC_ISSUE_DCMD]; in mmc_cqe_dcmd_busy()
267 if (host->hsq_enabled && mq->in_flight[issue_type] > 2) { in mmc_mq_queue_rq()
287 mq->in_flight[issue_type] += 1; in mmc_mq_queue_rq()
326 mq->in_flight[issue_type] -= 1; in mmc_mq_queue_rq()
/kernel/linux/linux-6.6/fs/smb/client/
H A Dtransport.c494 int scredits, in_flight; in wait_for_free_credits() local
513 server->in_flight++; in wait_for_free_credits()
514 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
515 server->max_in_flight = server->in_flight; in wait_for_free_credits()
519 in_flight = server->in_flight; in wait_for_free_credits()
523 server->conn_id, server->hostname, scredits, -1, in_flight); in wait_for_free_credits()
552 in_flight = server->in_flight; in wait_for_free_credits()
557 num_credits, in_flight); in wait_for_free_credits()
652 int scredits, in_flight; wait_for_compound_request() local
[all...]
H A Dsmb2ops.c71 int scredits, in_flight; in smb2_add_credits() local
94 add, server->in_flight); in smb2_add_credits()
96 WARN_ON_ONCE(server->in_flight == 0); in smb2_add_credits()
97 server->in_flight--; in smb2_add_credits()
98 if (server->in_flight == 0 && in smb2_add_credits()
106 else if (server->in_flight > 0 && server->oplock_credits == 0 && in smb2_add_credits()
112 } else if ((server->in_flight > 0) && (server->oplock_credits > 3) && in smb2_add_credits()
118 in_flight = server->in_flight; in smb2_add_credits()
124 server->conn_id, server->hostname, scredits, add, in_flight); in smb2_add_credits()
171 int scredits, in_flight; smb2_set_credits() local
223 unsigned int scredits, in_flight; smb2_wait_mtu_credits() local
289 int scredits, in_flight; smb2_adjust_credits() local
2364 int scredits, in_flight; smb2_is_status_pending() local
[all...]
H A Dtrace.h1034 int in_flight),
1035 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight),
1042 __field(int, in_flight)
1050 __entry->in_flight = in_flight;
1053 "credits=%d credit_change=%d in_flight=%d",
1059 __entry->in_flight)
1069 int in_flight), \
1070 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight))
/kernel/linux/linux-5.10/fs/fuse/
H A Dvirtio_fs.c50 long in_flight; member
89 struct fuse_req *req, bool in_flight);
144 fsvq->in_flight++; in inc_in_flight_req()
150 WARN_ON(fsvq->in_flight <= 0); in dec_in_flight_req()
151 fsvq->in_flight--; in dec_in_flight_req()
152 if (!fsvq->in_flight) in dec_in_flight_req()
181 WARN_ON(fsvq->in_flight < 0); in virtio_fs_drain_queue()
185 if (fsvq->in_flight) { in virtio_fs_drain_queue()
405 bool in_flight) in send_forget_request()
415 if (in_flight) in send_forget_request()
403 send_forget_request(struct virtio_fs_vq *fsvq, struct virtio_fs_forget *forget, bool in_flight) send_forget_request() argument
1127 virtio_fs_enqueue_req(struct virtio_fs_vq *fsvq, struct fuse_req *req, bool in_flight) virtio_fs_enqueue_req() argument
[all...]
/kernel/linux/linux-6.6/fs/fuse/
H A Dvirtio_fs.c51 long in_flight; member
90 struct fuse_req *req, bool in_flight);
152 fsvq->in_flight++; in inc_in_flight_req()
158 WARN_ON(fsvq->in_flight <= 0); in dec_in_flight_req()
159 fsvq->in_flight--; in dec_in_flight_req()
160 if (!fsvq->in_flight) in dec_in_flight_req()
189 WARN_ON(fsvq->in_flight < 0); in virtio_fs_drain_queue()
193 if (fsvq->in_flight) { in virtio_fs_drain_queue()
413 bool in_flight) in send_forget_request()
423 if (in_flight) in send_forget_request()
411 send_forget_request(struct virtio_fs_vq *fsvq, struct virtio_fs_forget *forget, bool in_flight) send_forget_request() argument
1121 virtio_fs_enqueue_req(struct virtio_fs_vq *fsvq, struct fuse_req *req, bool in_flight) virtio_fs_enqueue_req() argument
[all...]
/kernel/linux/linux-5.10/drivers/md/
H A 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()
229 atomic_read(&shared->in_flight[READ]), in dm_stats_cleanup()
230 atomic_read(&shared->in_flight[WRITE])); in dm_stats_cleanup()
320 atomic_set(&s->stat_shared[ni].in_flight[READ], 0); in dm_stats_create()
321 atomic_set(&s->stat_shared[ni].in_flight[WRITE], 0); in dm_stats_create()
511 in_flight_read = (unsigned)atomic_read(&shared->in_flight[READ]); in dm_stat_round()
512 in_flight_write = (unsigned)atomic_read(&shared->in_flight[WRITE]); in dm_stat_round()
557 atomic_inc(&shared->in_flight[id in dm_stat_for_entry()
[all...]
H A Ddm-integrity.c299 atomic_t in_flight; member
309 atomic_t in_flight; member
794 BUG_ON(!atomic_read(&comp->in_flight)); in complete_journal_op()
795 if (likely(atomic_dec_and_test(&comp->in_flight))) in complete_journal_op()
817 atomic_add(roundup(pl_offset + n_bytes, PAGE_SIZE) >> PAGE_SHIFT, &comp->in_flight); in xor_journal()
897 atomic_add(2, &comp->in_flight); in crypt_journal()
925 atomic_inc(&comp->in_flight); in crypt_journal()
931 atomic_dec(&comp->in_flight); in crypt_journal()
1020 io_comp.in_flight = (atomic_t)ATOMIC_INIT(1); in write_journal()
1024 crypt_comp_1.in_flight in write_journal()
[all...]
/kernel/linux/linux-5.10/drivers/usb/serial/
H A Dusb_wwan.c230 intfdata->in_flight++; in usb_wwan_write()
239 intfdata->in_flight--; in usb_wwan_write()
315 intfdata->in_flight--; in usb_wwan_outdat_callback()
598 if (intfdata->in_flight) { in usb_wwan_suspend()
638 data->in_flight++; in usb_wwan_submit_delayed_urbs()
H A Dsierra.c56 int in_flight; member
408 --intfdata->in_flight; in sierra_outdat_callback()
498 intfdata->in_flight++; in sierra_write()
940 if (intfdata->in_flight) { in sierra_suspend()
970 intfdata->in_flight++; in sierra_submit_delayed_urbs()
976 intfdata->in_flight--; in sierra_submit_delayed_urbs()
H A Dusb-wwan.h42 int in_flight; member
/kernel/linux/linux-6.6/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 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
/kernel/linux/linux-5.10/fs/cifs/
H A Dtransport.c549 server->in_flight++; in wait_for_free_credits()
550 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
551 server->max_in_flight = server->in_flight; in wait_for_free_credits()
595 server->in_flight > 2 * MAX_COMPOUND && in wait_for_free_credits()
628 server->in_flight += num_credits; in wait_for_free_credits()
629 if (server->in_flight > server->max_in_flight) in wait_for_free_credits()
630 server->max_in_flight = server->in_flight; in wait_for_free_credits()
674 if (server->in_flight == 0) { in wait_for_compound_request()
/kernel/linux/linux-6.6/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 __must_hold()
1088 .in_flight = ATOMIC_INIT(1), in __must_hold()
1118 atomic_inc(&ctx->in_flight); in __must_hold()
1137 atomic_inc(&ctx->in_flight); in __must_hold()
1158 atomic_inc(&ctx->in_flight); in __must_hold()
1166 * We initialize ctx->in_flight to one to make sure drbd_bm_endio in __must_hold()
1171 * "in_flight reached zero, all done" event. in __must_hold()
1173 if (!atomic_dec_and_test(&ctx->in_flight)) in __must_hold()
1194 if (atomic_read(&ctx->in_flight)) in __must_hold()
[all...]
/kernel/linux/linux-5.10/drivers/block/drbd/
H A Ddrbd_bitmap.c970 if (atomic_dec_and_test(&ctx->in_flight)) { in drbd_bm_endio()
1056 .in_flight = ATOMIC_INIT(1), in __must_hold()
1086 atomic_inc(&ctx->in_flight); in __must_hold()
1105 atomic_inc(&ctx->in_flight); in __must_hold()
1126 atomic_inc(&ctx->in_flight); in __must_hold()
1134 * We initialize ctx->in_flight to one to make sure drbd_bm_endio in __must_hold()
1139 * "in_flight reached zero, all done" event. in __must_hold()
1141 if (!atomic_dec_and_test(&ctx->in_flight)) in __must_hold()
1162 if (atomic_read(&ctx->in_flight)) in __must_hold()
/kernel/linux/linux-5.10/drivers/firmware/arm_scmi/
H A Dnotify.c275 * @in_flight: A reference to an in flight &struct scmi_registered_event
300 void *in_flight; member
472 pd->in_flight = NULL; in scmi_process_event_payload()
549 if (!pd->in_flight) { in scmi_events_dispatcher()
553 pd->in_flight = r_evt; in scmi_events_dispatcher()
555 r_evt = pd->in_flight; in scmi_events_dispatcher()
/kernel/linux/linux-5.10/include/linux/
H A Dpart_stat.h13 local_t in_flight[2]; member
/kernel/linux/linux-6.6/include/linux/
H A Dpart_stat.h14 local_t in_flight[2]; member

Completed in 35 milliseconds

1234