/kernel/linux/linux-5.10/net/tipc/ |
H A D | group.c | 93 u16 max_active; member 124 int max_active, active_pool, idle_pool; in tipc_group_rcvbuf_limit() local 128 max_active = min(mcnt / 8, 64); in tipc_group_rcvbuf_limit() 129 max_active = max(max_active, 16); in tipc_group_rcvbuf_limit() 130 grp->max_active = max_active; in tipc_group_rcvbuf_limit() 133 active_pool = max_active * ADV_ACTIVE; in tipc_group_rcvbuf_limit() 134 idle_pool = (mcnt - max_active) * ADV_IDLE; in tipc_group_rcvbuf_limit() 591 int max_active in tipc_group_update_rcv_win() local [all...] |
/kernel/linux/linux-6.6/net/tipc/ |
H A D | group.c | 94 u16 max_active; member 125 int max_active, active_pool, idle_pool; in tipc_group_rcvbuf_limit() local 129 max_active = min(mcnt / 8, 64); in tipc_group_rcvbuf_limit() 130 max_active = max(max_active, 16); in tipc_group_rcvbuf_limit() 131 grp->max_active = max_active; in tipc_group_rcvbuf_limit() 134 active_pool = max_active * ADV_ACTIVE; in tipc_group_rcvbuf_limit() 135 idle_pool = (mcnt - max_active) * ADV_IDLE; in tipc_group_rcvbuf_limit() 592 int max_active in tipc_group_update_rcv_win() local [all...] |
/kernel/linux/linux-5.10/drivers/scsi/snic/ |
H A D | snic_stats.h | 23 atomic64_t max_active; /* Max # active IOs */ member 113 if (atomic64_read(&io->max_active) < nr_active_ios) in snic_stats_update_active_ios() 114 atomic64_set(&io->max_active, nr_active_ios); in snic_stats_update_active_ios()
|
H A D | snic_debugfs.c | 210 (u64) atomic64_read(&stats->io.max_active), in snic_stats_show()
|
/kernel/linux/linux-6.6/drivers/scsi/snic/ |
H A D | snic_stats.h | 9 atomic64_t max_active; /* Max # active IOs */ member 99 if (atomic64_read(&io->max_active) < nr_active_ios) in snic_stats_update_active_ios() 100 atomic64_set(&io->max_active, nr_active_ios); in snic_stats_update_active_ios()
|
H A D | snic_debugfs.c | 196 (u64) atomic64_read(&stats->io.max_active), in snic_stats_show()
|
/kernel/linux/linux-5.10/sound/oss/dmasound/ |
H A D | dmasound_core.c | 481 sq->max_active = sq->numBufs ; in sq_setup() 514 /* if user has set max_active - then use it */ in sq_setup() 515 sq->max_active = (sq->max_active <= sq->max_count) ? in sq_setup() 516 sq->max_active : sq->max_count ; in sq_setup() 522 sq->max_active = sq->numBufs ; in sq_setup() 621 while (write_sq.count >= write_sq.max_active) { in sq_write() 628 if (write_sq.count < write_sq.max_active) in sq_write() 682 if (write_sq.count < write_sq.max_active || write_sq.block_size - write_sq.rear_size > 0) in sq_poll() 973 /* there is, currently, no way to specify max_active separatel in set_queue_frags() [all...] |
H A D | dmasound.h | 218 int max_active; /* in-use fragments <= max_count */ member
|
/kernel/linux/linux-6.6/sound/oss/dmasound/ |
H A D | dmasound_core.c | 481 sq->max_active = sq->numBufs ; in sq_setup() 514 /* if user has set max_active - then use it */ in sq_setup() 515 sq->max_active = (sq->max_active <= sq->max_count) ? in sq_setup() 516 sq->max_active : sq->max_count ; in sq_setup() 522 sq->max_active = sq->numBufs ; in sq_setup() 621 while (write_sq.count >= write_sq.max_active) { in sq_write() 628 if (write_sq.count < write_sq.max_active) in sq_write() 682 if (write_sq.count < write_sq.max_active || write_sq.block_size - write_sq.rear_size > 0) in sq_poll() 973 /* there is, currently, no way to specify max_active separatel in set_queue_frags() [all...] |
H A D | dmasound.h | 218 int max_active; /* in-use fragments <= max_count */ member
|
/kernel/linux/linux-5.10/kernel/ |
H A D | workqueue.c | 209 int max_active; /* L: max active works */ member 255 int saved_max_active; /* WQ: saved pwq max_active */ 1193 if (pwq->nr_active < pwq->max_active) in pwq_dec_nr_in_flight() 1495 if (likely(pwq->nr_active < pwq->max_active)) { in __queue_work() 3725 * pwq_adjust_max_active - update a pwq's max_active to the current setting 3728 * If @pwq isn't freezing, set @pwq->max_active to the associated 3730 * accordingly. If @pwq is freezing, clear @pwq->max_active to zero. 3742 if (!freezable && pwq->max_active == wq->saved_max_active) in pwq_adjust_max_active() 3756 pwq->max_active = wq->saved_max_active; in pwq_adjust_max_active() 3759 pwq->nr_active < pwq->max_active) { in pwq_adjust_max_active() 4227 wq_clamp_max_active(int max_active, unsigned int flags, const char *name) wq_clamp_max_active() argument 4271 alloc_workqueue(const char *fmt, unsigned int flags, int max_active, ...) alloc_workqueue() argument 4487 workqueue_set_max_active(struct workqueue_struct *wq, int max_active) workqueue_set_max_active() argument [all...] |
/kernel/linux/linux-6.6/kernel/ |
H A D | workqueue.c | 245 * When pwq->nr_active >= max_active, new work item is queued to 288 * Unlike in a per-cpu workqueue where max_active limits its concurrency level 289 * on each CPU, in an unbound workqueue, max_active applies to the whole system. 293 * The following struct is used to enforce per-node max_active. When a pwq wants 301 int max; /* per-node max_active */ 328 /* See alloc_workqueue() function comment for info on min/max_active */ 329 int max_active; /* WO: max active works */ member 331 int saved_max_active; /* WQ: saved max_active */ 1490 * Update @wq->node_nr_active[]->max. @wq must be unbound. max_active is 1492 * cpus. The result is always between @wq->min_active and max_active 1498 int max_active = READ_ONCE(wq->max_active); wq_update_node_max_active() local 5035 wq_clamp_max_active(int max_active, unsigned int flags, const char *name) wq_clamp_max_active() argument 5145 alloc_workqueue(const char *fmt, unsigned int flags, int max_active, ...) alloc_workqueue() argument 5371 workqueue_set_max_active(struct workqueue_struct *wq, int max_active) workqueue_set_max_active() argument [all...] |
/kernel/linux/linux-5.10/drivers/infiniband/core/ |
H A D | mad_priv.h | 183 int max_active; member
|
H A D | mad.c | 1040 if (qp_info->send_queue.count < qp_info->send_queue.max_active) { in ib_send_mad() 2316 if (send_queue->count-- > send_queue->max_active) { in ib_mad_send_done() 2732 post = (++recv_queue->count < recv_queue->max_active); in ib_mad_post_receive_mads() 2929 qp_info->send_queue.max_active = mad_sendq_size; in create_mad_qp() 2930 qp_info->recv_queue.max_active = mad_recvq_size; in create_mad_qp()
|
H A D | mad_rmpp.c | 396 return max(agent->qp_info->recv_queue.max_active >> 3, 1); in window_size()
|
/kernel/linux/linux-6.6/drivers/infiniband/core/ |
H A D | mad_priv.h | 182 int max_active; member
|
H A D | mad.c | 1032 if (qp_info->send_queue.count < qp_info->send_queue.max_active) { in ib_send_mad() 2306 if (send_queue->count-- > send_queue->max_active) { in ib_mad_send_done() 2717 post = (++recv_queue->count < recv_queue->max_active); in ib_mad_post_receive_mads() 2914 qp_info->send_queue.max_active = mad_sendq_size; in create_mad_qp() 2915 qp_info->recv_queue.max_active = mad_recvq_size; in create_mad_qp()
|
/kernel/linux/linux-5.10/include/linux/ |
H A D | workqueue.h | 354 /* unbound wq's aren't per-cpu, scale max_active according to #cpus */ 374 * executed immediately as long as max_active limit is not reached and 398 * @max_active: max in-flight work items, 0 for default 410 int max_active, ...); 420 * implemented as unbound workqueues with @max_active of one. 473 int max_active);
|
/kernel/linux/linux-6.6/include/linux/ |
H A D | workqueue.h | 411 * is set to min(max_active, WQ_DFL_MIN_ACTIVE). For more details, see 433 * executed immediately as long as max_active limit is not reached and 457 * @max_active: max in-flight work items, 0 for default 460 * For a per-cpu workqueue, @max_active limits the number of in-flight work 461 * items for each CPU. e.g. @max_active of 1 indicates that each CPU can be 464 * For unbound workqueues, @max_active limits the number of in-flight work items 465 * for the whole system. e.g. @max_active of 16 indicates that that there can be 469 * NUMA nodes can be expensive, @max_active is distributed to each NUMA node 474 * max_active which is significantly lower than @max_active, whic [all...] |
/kernel/linux/linux-5.10/fs/btrfs/ |
H A D | disk-io.c | 2172 u32 max_active = fs_info->thread_pool_size; in btrfs_init_workqueues() local 2177 flags | WQ_HIGHPRI, max_active, 16); in btrfs_init_workqueues() 2181 flags, max_active, 2); in btrfs_init_workqueues() 2185 flags, max_active, 0); in btrfs_init_workqueues() 2188 btrfs_alloc_workqueue(fs_info, "cache", flags, max_active, 0); in btrfs_init_workqueues() 2198 btrfs_alloc_workqueue(fs_info, "endio", flags, max_active, 4); in btrfs_init_workqueues() 2201 max_active, 4); in btrfs_init_workqueues() 2204 max_active, 2); in btrfs_init_workqueues() 2207 max_active, 4); in btrfs_init_workqueues() 2209 btrfs_alloc_workqueue(fs_info, "rmw", flags, max_active, in btrfs_init_workqueues() [all...] |
H A D | scrub.c | 3766 int max_active = fs_info->thread_pool_size; in scrub_workers_get() local 3773 is_dev_replace ? 1 : max_active, 4); in scrub_workers_get() 3778 max_active, 2); in scrub_workers_get() 3783 max_active, 2); in scrub_workers_get()
|
/kernel/linux/linux-6.6/fs/btrfs/ |
H A D | disk-io.c | 1948 u32 max_active = fs_info->thread_pool_size; in btrfs_init_workqueues() local 1953 btrfs_alloc_workqueue(fs_info, "worker", flags, max_active, 16); in btrfs_init_workqueues() 1957 flags, max_active, 2); in btrfs_init_workqueues() 1961 flags, max_active, 0); in btrfs_init_workqueues() 1964 btrfs_alloc_workqueue(fs_info, "cache", flags, max_active, 0); in btrfs_init_workqueues() 1970 alloc_workqueue("btrfs-endio", flags, max_active); in btrfs_init_workqueues() 1972 alloc_workqueue("btrfs-endio-meta", flags, max_active); in btrfs_init_workqueues() 1973 fs_info->rmw_workers = alloc_workqueue("btrfs-rmw", flags, max_active); in btrfs_init_workqueues() 1976 max_active, 2); in btrfs_init_workqueues() 1978 alloc_workqueue("btrfs-compressed-write", flags, max_active); in btrfs_init_workqueues() [all...] |
H A D | scrub.c | 2781 int max_active = fs_info->thread_pool_size; in scrub_workers_get() local 2787 scrub_workers = alloc_workqueue("btrfs-scrub", flags, max_active); in scrub_workers_get()
|
/kernel/linux/linux-5.10/fs/hmdfs/comm/ |
H A D | device_node.c | 1045 unsigned int max_active; in sbi_srv_req_max_active_attr_store() local 1048 ret = kstrtouint(buf, 0, &max_active); in sbi_srv_req_max_active_attr_store() 1052 sbi->async_req_max_active = max_active; in sbi_srv_req_max_active_attr_store()
|
/kernel/linux/linux-6.6/fs/hmdfs/comm/ |
H A D | device_node.c | 1045 unsigned int max_active; in sbi_srv_req_max_active_attr_store() local 1048 ret = kstrtouint(buf, 0, &max_active); in sbi_srv_req_max_active_attr_store() 1052 sbi->async_req_max_active = max_active; in sbi_srv_req_max_active_attr_store()
|