| /kernel/linux/linux-5.10/fs/btrfs/ |
| H A D | zstd.c | 85 static struct zstd_workspace_manager wsm; variable
108 spin_lock_bh(&wsm.lock); in zstd_reclaim_timer_fn()
110 if (list_empty(&wsm.lru_list)) { in zstd_reclaim_timer_fn()
111 spin_unlock_bh(&wsm.lock); in zstd_reclaim_timer_fn()
115 list_for_each_prev_safe(pos, next, &wsm.lru_list) { in zstd_reclaim_timer_fn()
132 if (list_empty(&wsm.idle_ws[level - 1])) in zstd_reclaim_timer_fn()
133 clear_bit(level - 1, &wsm.active_map); in zstd_reclaim_timer_fn()
137 if (!list_empty(&wsm.lru_list)) in zstd_reclaim_timer_fn()
138 mod_timer(&wsm.timer, jiffies + ZSTD_BTRFS_RECLAIM_JIFFIES); in zstd_reclaim_timer_fn()
140 spin_unlock_bh(&wsm in zstd_reclaim_timer_fn()
[all...] |
| H A D | compression.c | 920 struct workspace_manager *wsm; in btrfs_init_workspace_manager() local
923 wsm = btrfs_compress_op[type]->workspace_manager; in btrfs_init_workspace_manager()
924 INIT_LIST_HEAD(&wsm->idle_ws); in btrfs_init_workspace_manager()
925 spin_lock_init(&wsm->ws_lock); in btrfs_init_workspace_manager()
926 atomic_set(&wsm->total_ws, 0); in btrfs_init_workspace_manager()
927 init_waitqueue_head(&wsm->ws_wait); in btrfs_init_workspace_manager()
938 atomic_set(&wsm->total_ws, 1); in btrfs_init_workspace_manager()
939 wsm->free_ws = 1; in btrfs_init_workspace_manager()
940 list_add(workspace, &wsm->idle_ws); in btrfs_init_workspace_manager()
966 struct workspace_manager *wsm; in btrfs_get_workspace() local
1065 struct workspace_manager *wsm; btrfs_put_workspace() local
[all...] |
| H A D | lzo.c | 64 static struct workspace_manager wsm; variable
486 .workspace_manager = &wsm,
|
| H A D | zlib.c | 34 static struct workspace_manager wsm; variable
467 .workspace_manager = &wsm,
|
| /kernel/linux/linux-6.6/fs/btrfs/ |
| H A D | zstd.c | 85 static struct zstd_workspace_manager wsm; variable
112 spin_lock(&wsm.lock); in zstd_reclaim_timer_fn()
114 if (list_empty(&wsm.lru_list)) { in zstd_reclaim_timer_fn()
115 spin_unlock(&wsm.lock); in zstd_reclaim_timer_fn()
119 list_for_each_prev_safe(pos, next, &wsm.lru_list) { in zstd_reclaim_timer_fn()
136 if (list_empty(&wsm.idle_ws[level - 1])) in zstd_reclaim_timer_fn()
137 clear_bit(level - 1, &wsm.active_map); in zstd_reclaim_timer_fn()
141 if (!list_empty(&wsm.lru_list)) in zstd_reclaim_timer_fn()
142 mod_timer(&wsm.timer, jiffies + ZSTD_BTRFS_RECLAIM_JIFFIES); in zstd_reclaim_timer_fn()
144 spin_unlock(&wsm in zstd_reclaim_timer_fn()
[all...] |
| H A D | compression.c | 678 struct workspace_manager *wsm; in btrfs_init_workspace_manager() local
681 wsm = btrfs_compress_op[type]->workspace_manager; in btrfs_init_workspace_manager()
682 INIT_LIST_HEAD(&wsm->idle_ws); in btrfs_init_workspace_manager()
683 spin_lock_init(&wsm->ws_lock); in btrfs_init_workspace_manager()
684 atomic_set(&wsm->total_ws, 0); in btrfs_init_workspace_manager()
685 init_waitqueue_head(&wsm->ws_wait); in btrfs_init_workspace_manager()
696 atomic_set(&wsm->total_ws, 1); in btrfs_init_workspace_manager()
697 wsm->free_ws = 1; in btrfs_init_workspace_manager()
698 list_add(workspace, &wsm->idle_ws); in btrfs_init_workspace_manager()
724 struct workspace_manager *wsm; in btrfs_get_workspace() local
823 struct workspace_manager *wsm; btrfs_put_workspace() local
[all...] |
| H A D | lzo.c | 71 static struct workspace_manager wsm; variable
490 .workspace_manager = &wsm,
|
| H A D | zlib.c | 34 static struct workspace_manager wsm; variable
451 .workspace_manager = &wsm,
|
| /kernel/linux/linux-5.10/arch/alpha/kernel/ |
| H A D | core_tsunami.c | 34 unsigned long wsm[4]; member
297 saved_config[index].wsm[0] = pchip->wsm[0].csr; in tsunami_init_one_pchip()
301 saved_config[index].wsm[1] = pchip->wsm[1].csr; in tsunami_init_one_pchip()
305 saved_config[index].wsm[2] = pchip->wsm[2].csr; in tsunami_init_one_pchip()
309 saved_config[index].wsm[3] = pchip->wsm[3].csr; in tsunami_init_one_pchip()
338 pchip->wsm[ in tsunami_init_one_pchip()
[all...] |
| H A D | core_titan.c | 34 unsigned long wsm[4]; member
297 saved_config[index].wsm[0] = port->wsm[0].csr; in titan_init_one_pachip_port()
301 saved_config[index].wsm[1] = port->wsm[1].csr; in titan_init_one_pachip_port()
305 saved_config[index].wsm[2] = port->wsm[2].csr; in titan_init_one_pachip_port()
309 saved_config[index].wsm[3] = port->wsm[3].csr; in titan_init_one_pachip_port()
330 port->wsm[ in titan_init_one_pachip_port()
[all...] |
| /kernel/linux/linux-6.6/arch/alpha/kernel/ |
| H A D | core_tsunami.c | 34 unsigned long wsm[4]; member
297 saved_config[index].wsm[0] = pchip->wsm[0].csr; in tsunami_init_one_pchip()
301 saved_config[index].wsm[1] = pchip->wsm[1].csr; in tsunami_init_one_pchip()
305 saved_config[index].wsm[2] = pchip->wsm[2].csr; in tsunami_init_one_pchip()
309 saved_config[index].wsm[3] = pchip->wsm[3].csr; in tsunami_init_one_pchip()
338 pchip->wsm[ in tsunami_init_one_pchip()
[all...] |
| H A D | core_titan.c | 34 unsigned long wsm[4]; member
297 saved_config[index].wsm[0] = port->wsm[0].csr; in titan_init_one_pachip_port()
301 saved_config[index].wsm[1] = port->wsm[1].csr; in titan_init_one_pachip_port()
305 saved_config[index].wsm[2] = port->wsm[2].csr; in titan_init_one_pachip_port()
309 saved_config[index].wsm[3] = port->wsm[3].csr; in titan_init_one_pachip_port()
330 port->wsm[ in titan_init_one_pachip_port()
[all...] |
| /kernel/linux/linux-5.10/drivers/net/wireless/st/cw1200/ |
| H A D | bh.c | 22 #include "wsm.h"
243 struct wsm_hdr *wsm; in cw1200_bh_rx_helper() local
296 wsm = (struct wsm_hdr *)data; in cw1200_bh_rx_helper()
297 wsm_len = __le16_to_cpu(wsm->len); in cw1200_bh_rx_helper()
306 wsm_id = __le16_to_cpu(wsm->id) & 0xFFF; in cw1200_bh_rx_helper()
307 wsm_seq = (__le16_to_cpu(wsm->id) >> 13) & 7; in cw1200_bh_rx_helper()
313 &data[sizeof(*wsm)], in cw1200_bh_rx_helper()
314 wsm_len - sizeof(*wsm)); in cw1200_bh_rx_helper()
332 if (WARN_ON(wsm_handle_rx(priv, wsm_id, wsm, &skb_rx))) in cw1200_bh_rx_helper()
357 struct wsm_hdr *wsm; in cw1200_bh_tx_helper() local
[all...] |
| H A D | txrx.c | 14 #include "wsm.h"
565 struct wsm_tx *wsm; in cw1200_tx_h_wsm() local
574 wsm = skb_push(t->skb, sizeof(struct wsm_tx)); in cw1200_tx_h_wsm()
576 memset(wsm, 0, sizeof(*wsm)); in cw1200_tx_h_wsm()
577 wsm->hdr.len = __cpu_to_le16(t->skb->len); in cw1200_tx_h_wsm()
578 wsm->hdr.id = __cpu_to_le16(0x0004); in cw1200_tx_h_wsm()
579 wsm->queue_id = wsm_queue_id_to_wsm(t->queue); in cw1200_tx_h_wsm()
580 return wsm; in cw1200_tx_h_wsm()
587 struct wsm_tx *wsm) in cw1200_tx_h_bt()
585 cw1200_tx_h_bt(struct cw1200_common *priv, struct cw1200_txinfo *t, struct wsm_tx *wsm) cw1200_tx_h_bt() argument
638 cw1200_tx_h_rate_policy(struct cw1200_common *priv, struct cw1200_txinfo *t, struct wsm_tx *wsm) cw1200_tx_h_rate_policy() argument
717 struct wsm_tx *wsm; cw1200_tx() local
[all...] |
| H A D | wsm.c | 17 #include "wsm.h"
1296 struct wsm_hdr *wsm, struct sk_buff **skb_p) in wsm_handle_rx()
1305 wsm_buf.begin = (u8 *)&wsm[0]; in wsm_handle_rx()
1306 wsm_buf.data = (u8 *)&wsm[1]; in wsm_handle_rx()
1307 wsm_buf.end = &wsm_buf.begin[__le16_to_cpu(wsm->len)]; in wsm_handle_rx()
1454 struct wsm_tx *wsm, in wsm_handle_tx_data()
1461 (struct ieee80211_hdr *)&((u8 *)wsm)[txpriv->offset]; in wsm_handle_tx_data()
1486 if (cw1200_queue_get_generation(wsm->packet_id) > in wsm_handle_tx_data()
1516 priv->bss_loss_confirm_id = wsm->packet_id; in wsm_handle_tx_data()
1517 wsm in wsm_handle_tx_data()
1295 wsm_handle_rx(struct cw1200_common *priv, u16 id, struct wsm_hdr *wsm, struct sk_buff **skb_p) wsm_handle_rx() argument
1453 wsm_handle_tx_data(struct cw1200_common *priv, struct wsm_tx *wsm, const struct ieee80211_tx_info *tx_info, const struct cw1200_txpriv *txpriv, struct cw1200_queue *queue) wsm_handle_tx_data() argument
1661 struct wsm_tx *wsm = NULL; wsm_get_tx() local
[all...] |
| H A D | Makefile | 9 wsm.o \
|
| H A D | scan.c | 359 struct wsm_tx *wsm; in cw1200_probe_work() local
402 wsm = (struct wsm_tx *)frame.skb->data; in cw1200_probe_work()
403 scan.max_tx_rate = wsm->max_tx_rate; in cw1200_probe_work()
|
| /kernel/linux/linux-6.6/drivers/net/wireless/st/cw1200/ |
| H A D | bh.c | 22 #include "wsm.h"
238 struct wsm_hdr *wsm; in cw1200_bh_rx_helper() local
291 wsm = (struct wsm_hdr *)data; in cw1200_bh_rx_helper()
292 wsm_len = __le16_to_cpu(wsm->len); in cw1200_bh_rx_helper()
301 wsm_id = __le16_to_cpu(wsm->id) & 0xFFF; in cw1200_bh_rx_helper()
302 wsm_seq = (__le16_to_cpu(wsm->id) >> 13) & 7; in cw1200_bh_rx_helper()
308 &data[sizeof(*wsm)], in cw1200_bh_rx_helper()
309 wsm_len - sizeof(*wsm)); in cw1200_bh_rx_helper()
327 if (WARN_ON(wsm_handle_rx(priv, wsm_id, wsm, &skb_rx))) in cw1200_bh_rx_helper()
346 struct wsm_hdr *wsm; in cw1200_bh_tx_helper() local
[all...] |
| H A D | txrx.c | 14 #include "wsm.h"
565 struct wsm_tx *wsm; in cw1200_tx_h_wsm() local
574 wsm = skb_push(t->skb, sizeof(struct wsm_tx)); in cw1200_tx_h_wsm()
576 memset(wsm, 0, sizeof(*wsm)); in cw1200_tx_h_wsm()
577 wsm->hdr.len = __cpu_to_le16(t->skb->len); in cw1200_tx_h_wsm()
578 wsm->hdr.id = __cpu_to_le16(0x0004); in cw1200_tx_h_wsm()
579 wsm->queue_id = wsm_queue_id_to_wsm(t->queue); in cw1200_tx_h_wsm()
580 return wsm; in cw1200_tx_h_wsm()
587 struct wsm_tx *wsm) in cw1200_tx_h_bt()
585 cw1200_tx_h_bt(struct cw1200_common *priv, struct cw1200_txinfo *t, struct wsm_tx *wsm) cw1200_tx_h_bt() argument
638 cw1200_tx_h_rate_policy(struct cw1200_common *priv, struct cw1200_txinfo *t, struct wsm_tx *wsm) cw1200_tx_h_rate_policy() argument
717 struct wsm_tx *wsm; cw1200_tx() local
[all...] |
| H A D | wsm.c | 17 #include "wsm.h"
1296 struct wsm_hdr *wsm, struct sk_buff **skb_p) in wsm_handle_rx()
1305 wsm_buf.begin = (u8 *)&wsm[0]; in wsm_handle_rx()
1306 wsm_buf.data = (u8 *)&wsm[1]; in wsm_handle_rx()
1307 wsm_buf.end = &wsm_buf.begin[__le16_to_cpu(wsm->len)]; in wsm_handle_rx()
1454 struct wsm_tx *wsm, in wsm_handle_tx_data()
1461 (struct ieee80211_hdr *)&((u8 *)wsm)[txpriv->offset]; in wsm_handle_tx_data()
1486 if (cw1200_queue_get_generation(wsm->packet_id) > in wsm_handle_tx_data()
1516 priv->bss_loss_confirm_id = wsm->packet_id; in wsm_handle_tx_data()
1517 wsm in wsm_handle_tx_data()
1295 wsm_handle_rx(struct cw1200_common *priv, u16 id, struct wsm_hdr *wsm, struct sk_buff **skb_p) wsm_handle_rx() argument
1453 wsm_handle_tx_data(struct cw1200_common *priv, struct wsm_tx *wsm, const struct ieee80211_tx_info *tx_info, const struct cw1200_txpriv *txpriv, struct cw1200_queue *queue) wsm_handle_tx_data() argument
1661 struct wsm_tx *wsm = NULL; wsm_get_tx() local
[all...] |
| H A D | Makefile | 9 wsm.o \
|
| H A D | scan.c | 359 struct wsm_tx *wsm; in cw1200_probe_work() local
402 wsm = (struct wsm_tx *)frame.skb->data; in cw1200_probe_work()
403 scan.max_tx_rate = wsm->max_tx_rate; in cw1200_probe_work()
|
| /kernel/linux/linux-5.10/net/ceph/ |
| H A D | osdmap.c | 998 static void init_workspace_manager(struct workspace_manager *wsm) in init_workspace_manager() argument
1000 INIT_LIST_HEAD(&wsm->idle_ws); in init_workspace_manager()
1001 spin_lock_init(&wsm->ws_lock); in init_workspace_manager()
1002 atomic_set(&wsm->total_ws, 0); in init_workspace_manager()
1003 wsm->free_ws = 0; in init_workspace_manager()
1004 init_waitqueue_head(&wsm->ws_wait); in init_workspace_manager()
1007 static void add_initial_workspace(struct workspace_manager *wsm, in add_initial_workspace() argument
1010 WARN_ON(!list_empty(&wsm->idle_ws)); in add_initial_workspace()
1012 list_add(&work->item, &wsm->idle_ws); in add_initial_workspace()
1013 atomic_set(&wsm in add_initial_workspace()
1017 cleanup_workspace_manager(struct workspace_manager *wsm) cleanup_workspace_manager() argument
1035 get_workspace(struct workspace_manager *wsm, const struct crush_map *c) get_workspace() argument
1085 put_workspace(struct workspace_manager *wsm, struct crush_work *work) put_workspace() argument
[all...] |
| /kernel/linux/linux-6.6/net/ceph/ |
| H A D | osdmap.c | 1014 static void init_workspace_manager(struct workspace_manager *wsm) in init_workspace_manager() argument
1016 INIT_LIST_HEAD(&wsm->idle_ws); in init_workspace_manager()
1017 spin_lock_init(&wsm->ws_lock); in init_workspace_manager()
1018 atomic_set(&wsm->total_ws, 0); in init_workspace_manager()
1019 wsm->free_ws = 0; in init_workspace_manager()
1020 init_waitqueue_head(&wsm->ws_wait); in init_workspace_manager()
1023 static void add_initial_workspace(struct workspace_manager *wsm, in add_initial_workspace() argument
1026 WARN_ON(!list_empty(&wsm->idle_ws)); in add_initial_workspace()
1028 list_add(&work->item, &wsm->idle_ws); in add_initial_workspace()
1029 atomic_set(&wsm in add_initial_workspace()
1033 cleanup_workspace_manager(struct workspace_manager *wsm) cleanup_workspace_manager() argument
1051 get_workspace(struct workspace_manager *wsm, const struct crush_map *c) get_workspace() argument
1101 put_workspace(struct workspace_manager *wsm, struct crush_work *work) put_workspace() argument
[all...] |
| /kernel/linux/linux-5.10/arch/alpha/include/asm/ |
| H A D | core_tsunami.h | 75 tsunami_64 wsm[4]; member
|