/openbmc/linux/drivers/md/ |
H A D | dm-io-tracker.h | 19 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 D | dm-stats.c | 37 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[idx]); in dm_stat_for_entry() [all …]
|
/openbmc/linux/drivers/mmc/core/ |
H A D | queue.h | 81 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 D | queue.c | 29 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()
|
/openbmc/openbmc-tools/dbus-vis/ |
H A D | dbus_pcap_loader.js | 194 let in_flight = {}; 310 in_flight[serial] = (entry); 315 if (reply_serial in in_flight) { 316 let x = in_flight[reply_serial]; 317 delete in_flight[reply_serial]; 335 if (reply_serial in in_flight) { 336 let x = in_flight[reply_serial]; 337 delete in_flight[reply_serial];
|
H A D | ipmi_parse.js | 173 function munchLegacyMessageEnd(lines, i, in_flight, parsed_entries) { argument 184 if (serial in in_flight) { 185 entry = in_flight[serial]; 186 delete in_flight[serial]; 238 function munchNewMessageStart(lines, i, in_flight) { argument 286 function munchNewMessageEnd(lines, i, in_flight, parsed_entries) { argument 291 if (reply_serial in in_flight) { 292 entry = in_flight[reply_serial]; 293 delete in_flight[reply_serial];
|
/openbmc/qemu/block/ |
H A D | io_uring.c | 47 unsigned int in_flight; member 162 s->io_q.in_flight--; in luring_process_completions() 258 s->io_q.in_flight += ret; in ioq_submit() 263 if (s->io_q.in_flight) { in ioq_submit() 312 io_q->in_flight = 0; in ioq_init() 320 s->io_q.in_flight); in luring_deferred_fn() 369 s->io_q.in_flight); in luring_do_submit() 371 if (s->io_q.in_flight + s->io_q.in_queue >= MAX_ENTRIES) { in luring_do_submit()
|
H A D | linux-aio.c | 52 unsigned int in_flight; member 223 s->io_q.in_flight--; in qemu_laio_process_completions() 286 io_q->in_flight = 0; in ioq_init() 298 if (s->io_q.in_flight >= MAX_EVENTS) { in ioq_submit() 304 if (s->io_q.in_flight + len >= MAX_EVENTS) { in ioq_submit() 323 s->io_q.in_flight += ret; in ioq_submit() 330 if (s->io_q.in_flight) { in ioq_submit() 356 max_batch = MIN_NON_ZERO(MAX_EVENTS - s->io_q.in_flight, max_batch); in laio_max_batch()
|
H A D | mirror.c | 84 unsigned in_flight; member 206 s->in_flight--; in mirror_iteration_done() 378 trace_mirror_yield_in_flight(s, op->offset, s->in_flight); in mirror_co_read() 396 s->in_flight++; in mirror_co_read() 413 op->s->in_flight++; in mirror_co_zero() 428 op->s->in_flight++; in mirror_co_discard() 603 while (s->in_flight >= MAX_IN_FLIGHT) { in mirror_iteration() 604 trace_mirror_yield_in_flight(s, offset, s->in_flight); in mirror_iteration() 655 while (s->in_flight > 0) { in mirror_wait_for_all_io() 869 if (s->in_flight >= MAX_IN_FLIGHT) { in mirror_dirty_init() [all …]
|
H A D | trace-events | 37 …id *s, int64_t cnt, int buf_free_count, int in_flight) "s %p dirty count %"PRId64" free buffers %d… 38 mirror_yield_in_flight(void *s, int64_t offset, int in_flight) "s %p offset %" PRId64 " in_flight %… 174 nbd_reconnect_attempt(unsigned in_flight) "in_flight %u" 175 nbd_reconnect_attempt_result(int ret, unsigned in_flight) "ret %d in_flight %u"
|
H A D | nbd.c | 79 unsigned in_flight; member 222 assert(!s->in_flight); in nbd_teardown_connection() 383 assert(s->in_flight == 1); in nbd_reconnect_attempt() 385 trace_nbd_reconnect_attempt(s->bs->in_flight); in nbd_reconnect_attempt() 408 trace_nbd_reconnect_attempt_result(ret, s->bs->in_flight); in nbd_reconnect_attempt() 498 while (s->in_flight == MAX_NBD_REQUESTS || in nbd_co_send_request() 499 (s->state != NBD_CLIENT_CONNECTED && s->in_flight > 0)) { in nbd_co_send_request() 503 s->in_flight++; in nbd_co_send_request() 553 s->in_flight--; in nbd_co_send_request() 1063 s->in_flight--; in nbd_reply_chunk_iter_receive()
|
/openbmc/linux/fs/smb/client/ |
H A D | transport.c | 494 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() 580 server->in_flight > 2 * MAX_COMPOUND && in wait_for_free_credits() 594 in_flight = server->in_flight; in wait_for_free_credits() [all …]
|
H A D | smb2ops.c | 72 int scredits, in_flight; in smb2_add_credits() local 95 add, server->in_flight); in smb2_add_credits() 97 WARN_ON_ONCE(server->in_flight == 0); in smb2_add_credits() 98 server->in_flight--; in smb2_add_credits() 99 if (server->in_flight == 0 && in smb2_add_credits() 107 else if (server->in_flight > 0 && server->oplock_credits == 0 && in smb2_add_credits() 113 } else if ((server->in_flight > 0) && (server->oplock_credits > 3) && in smb2_add_credits() 119 in_flight = server->in_flight; in smb2_add_credits() 125 server->conn_id, server->hostname, scredits, add, in_flight); in smb2_add_credits() 133 server->conn_id, server->hostname, scredits, add, in_flight); in smb2_add_credits() [all …]
|
H A D | trace.h | 1142 int in_flight), 1143 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight), 1150 __field(int, in_flight) 1158 __entry->in_flight = in_flight; 1167 __entry->in_flight) 1177 int in_flight), \ 1178 TP_ARGS(currmid, conn_id, hostname, credits, credits_to_add, in_flight))
|
/openbmc/linux/fs/fuse/ |
H A D | virtio_fs.c | 51 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() 423 bool in_flight) in send_forget_request() argument 433 if (in_flight) in send_forget_request() [all …]
|
/openbmc/linux/drivers/usb/serial/ |
H A D | usb_wwan.c | 185 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 D | sierra.c | 56 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 D | usb-wwan.h | 38 int in_flight; member
|
/openbmc/qemu/util/ |
H A D | vhost-user-server.c | 93 qatomic_inc(&server->in_flight); in vhost_user_server_inc_in_flight() 98 if (qatomic_fetch_dec(&server->in_flight) == 1) { in vhost_user_server_dec_in_flight() 107 return qatomic_load_acquire(&server->in_flight) > 0; in vhost_user_server_has_in_flight()
|
/openbmc/qemu/include/qemu/ |
H A D | vhost-user-server.h | 43 unsigned int in_flight; /* atomic */ member
|
/openbmc/linux/drivers/block/drbd/ |
H A D | drbd_bitmap.c | 970 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()
|
/openbmc/qemu/block/export/ |
H A D | fuse.c | 53 unsigned int in_flight; /* atomic */ member 109 return qatomic_read(&exp->in_flight) > 0; in fuse_export_drained_poll() 295 qatomic_inc(&exp->in_flight); in read_from_fuse_export() 307 if (qatomic_fetch_dec(&exp->in_flight) == 1) { in read_from_fuse_export()
|
/openbmc/linux/drivers/firmware/arm_scmi/ |
H A D | notify.c | 302 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()
|
/openbmc/linux/include/linux/ |
H A D | part_stat.h | 14 local_t in_flight[2]; member
|
/openbmc/linux/net/ipv4/ |
H A D | tcp_nv.c | 268 if (sample->in_flight == 0) in tcpnv_acked() 287 rate64 = ((u64)sample->in_flight) * 80000; in tcpnv_acked()
|