| /linux/drivers/md/ |
| H A D | dm-raid.c | 60 * Bits for establishing rs->ctr_flags
89 * Flags for rs->ctr_flags field.
200 * Flags for rs->runtime_flags field
261 static void rs_config_backup(struct raid_set *rs, struct rs_layout *l) in rs_config_backup() argument
263 struct mddev *mddev = &rs->md; in rs_config_backup()
270 static void rs_config_restore(struct raid_set *rs, struct rs_layout *l) in rs_config_restore() argument
272 struct mddev *mddev = &rs->md; in rs_config_restore()
400 /* Return true, if raid set in @rs is raid0 */
401 static bool rs_is_raid0(struct raid_set *rs) in rs_is_raid0() argument
403 return !rs in rs_is_raid0()
407 rs_is_raid1(struct raid_set * rs) rs_is_raid1() argument
413 rs_is_raid10(struct raid_set * rs) rs_is_raid10() argument
419 rs_is_raid6(struct raid_set * rs) rs_is_raid6() argument
425 rs_is_raid456(struct raid_set * rs) rs_is_raid456() argument
432 rs_is_reshapable(struct raid_set * rs) rs_is_reshapable() argument
439 rs_is_recovering(struct raid_set * rs) rs_is_recovering() argument
445 rs_is_reshaping(struct raid_set * rs) rs_is_reshaping() argument
492 __valid_flags(struct raid_set * rs) __valid_flags() argument
513 rs_check_for_valid_flags(struct raid_set * rs) rs_check_for_valid_flags() argument
600 raid10_format_to_md_layout(struct raid_set * rs,unsigned int algorithm,unsigned int copies) raid10_format_to_md_layout() argument
684 rs_set_rdev_sectors(struct raid_set * rs) rs_set_rdev_sectors() argument
701 rs_set_capacity(struct raid_set * rs) rs_set_capacity() argument
712 rs_set_cur(struct raid_set * rs) rs_set_cur() argument
725 rs_set_new(struct raid_set * rs) rs_set_new() argument
740 struct raid_set *rs; raid_set_alloc() local
789 raid_set_free(struct raid_set * rs) raid_set_free() argument
826 parse_dev_params(struct raid_set * rs,struct dm_arg_set * as) parse_dev_params() argument
944 validate_region_size(struct raid_set * rs,unsigned long region_size) validate_region_size() argument
1008 validate_raid_redundancy(struct raid_set * rs) validate_raid_redundancy() argument
1130 parse_raid_params(struct raid_set * rs,struct dm_arg_set * as,unsigned int num_raid_params) parse_raid_params() argument
1537 rs_set_raid456_stripe_cache(struct raid_set * rs) rs_set_raid456_stripe_cache() argument
1577 mddev_data_stripes(struct raid_set * rs) mddev_data_stripes() argument
1583 rs_data_stripes(struct raid_set * rs) rs_data_stripes() argument
1592 __rdev_sectors(struct raid_set * rs) __rdev_sectors() argument
1608 _check_data_dev_sectors(struct raid_set * rs) _check_data_dev_sectors() argument
1626 _get_reshape_sectors(struct raid_set * rs) _get_reshape_sectors() argument
1643 rs_set_dev_and_array_sectors(struct raid_set * rs,sector_t sectors,bool use_mddev) rs_set_dev_and_array_sectors() argument
1694 rs_setup_recovery(struct raid_set * rs,sector_t dev_sectors) rs_setup_recovery() argument
1717 struct raid_set *rs = container_of(ws, struct raid_set, md.event_work); do_table_event() local
1743 rs_check_takeover(struct raid_set * rs) rs_check_takeover() argument
1898 rs_takeover_requested(struct raid_set * rs) rs_takeover_requested() argument
1904 rs_is_layout_change(struct raid_set * rs,bool use_mddev) rs_is_layout_change() argument
1912 rs_reshape_requested(struct raid_set * rs) rs_reshape_requested() argument
2041 rs_check_reshape(struct raid_set * rs) rs_check_reshape() argument
2116 struct raid_set *rs = container_of(mddev, struct raid_set, md); super_sync() local
2237 super_init_validation(struct raid_set * rs,struct md_rdev * rdev) super_init_validation() argument
2457 super_validate(struct raid_set * rs,struct md_rdev * rdev) super_validate() argument
2528 analyse_superblocks(struct dm_target * ti,struct raid_set * rs) analyse_superblocks() argument
2628 rs_adjust_data_offsets(struct raid_set * rs) rs_adjust_data_offsets() argument
2721 __reorder_raid_disk_indexes(struct raid_set * rs) __reorder_raid_disk_indexes() argument
2737 rs_setup_takeover(struct raid_set * rs) rs_setup_takeover() argument
2782 rs_prepare_reshape(struct raid_set * rs) rs_prepare_reshape() argument
2847 rs_setup_reshape(struct raid_set * rs) rs_setup_reshape() argument
2955 rs_reset_inconclusive_reshape(struct raid_set * rs) rs_reset_inconclusive_reshape() argument
2968 configure_discard_support(struct raid_set * rs) configure_discard_support() argument
3016 struct raid_set *rs = NULL; raid_ctr() local
3327 struct raid_set *rs = ti->private; raid_dtr() local
3341 struct raid_set *rs = ti->private; raid_map() local
3420 __raid_dev_status(struct raid_set * rs,struct md_rdev * rdev) __raid_dev_status() argument
3437 rs_get_progress(struct raid_set * rs,unsigned long recovery,enum sync_state state,sector_t resync_max_sectors) rs_get_progress() argument
3527 struct raid_set *rs = ti->private; raid_status() local
3733 struct raid_set *rs = ti->private; raid_message() local
3796 struct raid_set *rs = ti->private; raid_iterate_devices() local
3813 struct raid_set *rs = ti->private; raid_io_hints() local
3822 struct raid_set *rs = ti->private; raid_presuspend() local
3845 struct raid_set *rs = ti->private; raid_presuspend_undo() local
3852 struct raid_set *rs = ti->private; raid_postsuspend() local
3864 attempt_restore_of_faulty_devices(struct raid_set * rs) attempt_restore_of_faulty_devices() argument
3947 __load_dirty_region_bitmap(struct raid_set * rs) __load_dirty_region_bitmap() argument
3965 rs_update_sbs(struct raid_set * rs) rs_update_sbs() argument
3983 rs_start_reshape(struct raid_set * rs) rs_start_reshape() argument
4032 struct raid_set *rs = ti->private; raid_preresume() local
4104 struct raid_set *rs = ti->private; raid_resume() local
[all...] |
| /linux/drivers/spi/ |
| H A D | spi-rockchip.c | 201 static inline void spi_enable_chip(struct rockchip_spi *rs, bool enable) in spi_enable_chip() argument
203 writel_relaxed((enable ? 1U : 0U), rs->regs + ROCKCHIP_SPI_SSIENR); in spi_enable_chip()
206 static inline void wait_for_tx_idle(struct rockchip_spi *rs, bool target_mode) in wait_for_tx_idle() argument
212 if (!(readl_relaxed(rs->regs + ROCKCHIP_SPI_SR) & SR_TARGET_TX_BUSY) && in wait_for_tx_idle()
213 !((readl_relaxed(rs->regs + ROCKCHIP_SPI_SR) & SR_BUSY))) in wait_for_tx_idle()
216 if (!(readl_relaxed(rs->regs + ROCKCHIP_SPI_SR) & SR_BUSY)) in wait_for_tx_idle()
221 dev_warn(rs->dev, "spi controller is in busy state!\n"); in wait_for_tx_idle()
224 static u32 get_fifo_len(struct rockchip_spi *rs) in get_fifo_len() argument
228 ver = readl_relaxed(rs->regs + ROCKCHIP_SPI_VERSION); in get_fifo_len()
242 struct rockchip_spi *rs in rockchip_spi_set_cs() local
283 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_handle_err() local
301 rockchip_spi_pio_writer(struct rockchip_spi * rs) rockchip_spi_pio_writer() argument
320 rockchip_spi_pio_reader(struct rockchip_spi * rs) rockchip_spi_pio_reader() argument
357 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_isr() local
382 rockchip_spi_prepare_irq(struct rockchip_spi * rs,struct spi_controller * ctlr,struct spi_transfer * xfer) rockchip_spi_prepare_irq() argument
410 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_dma_rxcb() local
426 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_dma_txcb() local
452 rockchip_spi_prepare_dma(struct rockchip_spi * rs,struct spi_controller * ctlr,struct spi_transfer * xfer) rockchip_spi_prepare_dma() argument
531 rockchip_spi_config(struct rockchip_spi * rs,struct spi_device * spi,struct spi_transfer * xfer,bool use_dma,bool target_mode) rockchip_spi_config() argument
624 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_target_abort() local
678 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_transfer_one() local
719 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_can_dma() local
731 struct rockchip_spi *rs = spi_controller_get_devdata(spi->controller); rockchip_spi_setup() local
761 struct rockchip_spi *rs; rockchip_spi_probe() local
992 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_runtime_suspend() local
1004 struct rockchip_spi *rs = spi_controller_get_devdata(ctlr); rockchip_spi_runtime_resume() local
[all...] |
| H A D | spi-mt7621.c | 70 static inline u32 mt7621_spi_read(struct mt7621_spi *rs, u32 reg) in mt7621_spi_read() argument
72 return ioread32(rs->base + reg); in mt7621_spi_read()
75 static inline void mt7621_spi_write(struct mt7621_spi *rs, u32 reg, u32 val) in mt7621_spi_write() argument
77 iowrite32(val, rs->base + reg); in mt7621_spi_write()
82 struct mt7621_spi *rs = spidev_to_mt7621_spi(spi); in mt7621_spi_set_native_cs() local
93 host = mt7621_spi_read(rs, MT7621_SPI_MASTER); in mt7621_spi_set_native_cs()
96 mt7621_spi_write(rs, MT7621_SPI_MASTER, host); in mt7621_spi_set_native_cs()
98 rs->pending_write = 0; in mt7621_spi_set_native_cs()
102 mt7621_spi_write(rs, MT7621_SPI_POLAR, polar); in mt7621_spi_set_native_cs()
107 struct mt7621_spi *rs in mt7621_spi_prepare() local
143 mt7621_spi_wait_till_ready(struct mt7621_spi * rs) mt7621_spi_wait_till_ready() argument
163 struct mt7621_spi *rs = spi_controller_get_devdata(host); mt7621_spi_prepare_message() local
177 mt7621_spi_read_half_duplex(struct mt7621_spi * rs,int rx_len,u8 * buf) mt7621_spi_read_half_duplex() argument
219 mt7621_spi_flush(struct mt7621_spi * rs) mt7621_spi_flush() argument
224 mt7621_spi_write_half_duplex(struct mt7621_spi * rs,int tx_len,const u8 * buf) mt7621_spi_write_half_duplex() argument
273 struct mt7621_spi *rs = spi_controller_get_devdata(host); mt7621_spi_transfer_one() local
295 struct mt7621_spi *rs = spidev_to_mt7621_spi(spi); mt7621_spi_setup() local
320 struct mt7621_spi *rs; mt7621_spi_probe() local
[all...] |
| /linux/lib/reed_solomon/ |
| H A D | reed_solomon.c | 16 * for the given rs parameters. The control struct is unique per instance.
52 /* This list holds all currently allocated rs codec structures */
74 struct rs_codec *rs; in codec_init() local
76 rs = kzalloc(sizeof(*rs), gfp); in codec_init()
77 if (!rs) in codec_init()
80 INIT_LIST_HEAD(&rs->list); in codec_init()
82 rs->mm = symsize; in codec_init()
83 rs->nn = (1 << symsize) - 1; in codec_init()
84 rs in codec_init()
176 free_rs(struct rs_control * rs) free_rs() argument
218 struct rs_control *rs; init_rs_internal() local
[all...] |
| H A D | test_rslib.c | 108 static struct wspace *alloc_ws(struct rs_codec *rs) in alloc_ws() argument
110 int nroots = rs->nroots; in alloc_ws()
112 int nn = rs->nn; in alloc_ws()
151 static int get_rcw_we(struct rs_control *rs, struct wspace *ws, in get_rcw_we() argument
154 int nroots = rs->codec->nroots; in get_rcw_we()
158 int nn = rs->codec->nn; in get_rcw_we()
170 encode_rs16(rs, c, dlen, c + dlen, 0); in get_rcw_we()
232 struct rs_codec *rs = rsc->codec; in compute_syndrome() local
233 uint16_t *alpha_to = rs->alpha_to; in compute_syndrome()
234 uint16_t *index_of = rs in compute_syndrome()
260 test_uc(struct rs_control * rs,int len,int errs,int eras,int trials,struct estat * stat,struct wspace * ws,int method) test_uc() argument
313 ex_rs_helper(struct rs_control * rs,struct wspace * ws,int len,int trials,int method) ex_rs_helper() argument
349 exercise_rs(struct rs_control * rs,struct wspace * ws,int len,int trials) exercise_rs() argument
366 test_bc(struct rs_control * rs,int len,int errs,int eras,int trials,struct bcstat * stat,struct wspace * ws) test_bc() argument
407 exercise_rs_bc(struct rs_control * rs,struct wspace * ws,int len,int trials) exercise_rs_bc() argument
[all...] |
| H A D | decode_rs.c | 13 struct rs_codec *rs = rsc->codec; variable
16 int nn = rs->nn;
17 int nroots = rs->nroots;
18 int fcr = rs->fcr;
19 int prim = rs->prim;
20 int iprim = rs->iprim;
21 uint16_t *alpha_to = rs->alpha_to;
22 uint16_t *index_of = rs->index_of;
26 uint16_t msk = (uint16_t) rs->nn;
29 * The decoder buffers are in the rs contro
[all...] |
| H A D | encode_rs.c | 13 struct rs_codec *rs = rsc->codec; variable
15 int nn = rs->nn;
16 int nroots = rs->nroots;
17 uint16_t *alpha_to = rs->alpha_to;
18 uint16_t *index_of = rs->index_of;
19 uint16_t *genpoly = rs->genpoly;
21 uint16_t msk = (uint16_t) rs->nn;
33 par[j] ^= alpha_to[rs_modnn(rs, fb +
40 par[nroots - 1] = alpha_to[rs_modnn(rs,
|
| /linux/net/rds/ |
| H A D | af_rds.c | 62 struct rds_sock *rs; in rds_release() local
67 rs = rds_sk_to_rs(sk); in rds_release()
73 rds_clear_recv_queue(rs); in rds_release()
74 rds_cong_remove_socket(rs); in rds_release()
76 rds_remove_bound(rs); in rds_release()
78 rds_send_drop_to(rs, NULL); in rds_release()
79 rds_rdma_drop_keys(rs); in rds_release()
80 rds_notify_queue_get(rs, NULL); in rds_release()
81 rds_notify_msg_zcopy_purge(&rs->rs_zcookie_queue); in rds_release()
84 list_del_init(&rs in rds_release()
105 rds_wake_sk_sleep(struct rds_sock * rs) rds_wake_sk_sleep() argument
117 struct rds_sock *rs = rds_sk_to_rs(sock->sk); rds_getname() local
216 struct rds_sock *rs = rds_sk_to_rs(sk); rds_poll() local
257 struct rds_sock *rs = rds_sk_to_rs(sock->sk); rds_ioctl() local
293 rds_cancel_sent_to(struct rds_sock * rs,sockptr_t optval,int len) rds_cancel_sent_to() argument
343 rds_cong_monitor(struct rds_sock * rs,sockptr_t optval,int optlen) rds_cong_monitor() argument
360 rds_set_transport(struct rds_sock * rs,sockptr_t optval,int optlen) rds_set_transport() argument
405 rds_recv_track_latency(struct rds_sock * rs,sockptr_t optval,int optlen) rds_recv_track_latency() argument
435 struct rds_sock *rs = rds_sk_to_rs(sock->sk); rds_setsockopt() local
486 struct rds_sock *rs = rds_sk_to_rs(sock->sk); rds_getsockopt() local
541 struct rds_sock *rs = rds_sk_to_rs(sk); rds_connect() local
660 struct rds_sock *rs = rds_sk_to_rs(sk); rds_sock_destruct() local
668 struct rds_sock *rs; __rds_create() local
712 rds_sock_addref(struct rds_sock * rs) rds_sock_addref() argument
717 rds_sock_put(struct rds_sock * rs) rds_sock_put() argument
732 struct rds_sock *rs; rds_sock_inc_info() local
773 struct rds_sock *rs; rds6_sock_inc_info() local
805 struct rds_sock *rs; rds_sock_info() local
845 struct rds_sock *rs; rds6_sock_info() local
[all...] |
| H A D | bind.c | 70 * marked this socket and don't return a rs ref to the rx path.
76 struct rds_sock *rs; in rds_find_bound() local
80 rs = rhashtable_lookup(&bind_hash_table, key, ht_parms); in rds_find_bound()
81 if (rs && (sock_flag(rds_rs_to_sk(rs), SOCK_DEAD) || in rds_find_bound()
82 !refcount_inc_not_zero(&rds_rs_to_sk(rs)->sk_refcnt))) in rds_find_bound()
83 rs = NULL; in rds_find_bound()
87 rdsdebug("returning rs %p for %pI6c:%u\n", rs, addr, in rds_find_bound()
90 return rs; in rds_find_bound()
94 rds_add_bound(struct rds_sock * rs,const struct in6_addr * addr,__be16 * port,__u32 scope_id) rds_add_bound() argument
148 rds_remove_bound(struct rds_sock * rs) rds_remove_bound() argument
166 struct rds_sock *rs = rds_sk_to_rs(sk); rds_bind() local
[all...] |
| H A D | recv.c | 88 static void rds_recv_rcvbuf_delta(struct rds_sock *rs, struct sock *sk, in rds_recv_rcvbuf_delta() argument
97 rs->rs_rcv_bytes += delta; in rds_recv_rcvbuf_delta()
104 if (rs->rs_transport->t_type == RDS_TRANS_LOOP) in rds_recv_rcvbuf_delta()
107 now_congested = rs->rs_rcv_bytes > rds_sk_rcvbuf(rs); in rds_recv_rcvbuf_delta()
109 rdsdebug("rs %p (%pI6c:%u) recv bytes %d buf %d " in rds_recv_rcvbuf_delta()
111 rs, &rs->rs_bound_addr, in rds_recv_rcvbuf_delta()
112 ntohs(rs->rs_bound_port), rs in rds_recv_rcvbuf_delta()
166 rds_recv_incoming_exthdrs(struct rds_incoming * inc,struct rds_sock * rs) rds_recv_incoming_exthdrs() argument
287 struct rds_sock *rs = NULL; rds_recv_incoming() local
404 rds_next_incoming(struct rds_sock * rs,struct rds_incoming ** inc) rds_next_incoming() argument
422 rds_still_queued(struct rds_sock * rs,struct rds_incoming * inc,int drop) rds_still_queued() argument
455 rds_notify_queue_get(struct rds_sock * rs,struct msghdr * msghdr) rds_notify_queue_get() argument
523 rds_notify_cong(struct rds_sock * rs,struct msghdr * msghdr) rds_notify_cong() argument
545 rds_cmsg_recv(struct rds_incoming * inc,struct msghdr * msg,struct rds_sock * rs) rds_cmsg_recv() argument
603 rds_recvmsg_zcookie(struct rds_sock * rs,struct msghdr * msg) rds_recvmsg_zcookie() argument
642 struct rds_sock *rs = rds_sk_to_rs(sk); rds_recvmsg() local
760 rds_clear_recv_queue(struct rds_sock * rs) rds_clear_recv_queue() argument
[all...] |
| H A D | send.c | 472 static void rds_send_sndbuf_remove(struct rds_sock *rs, struct rds_message *rm) in rds_send_sndbuf_remove() argument
476 assert_spin_locked(&rs->rs_lock); in rds_send_sndbuf_remove()
478 BUG_ON(rs->rs_snd_bytes < len); in rds_send_sndbuf_remove()
479 rs->rs_snd_bytes -= len; in rds_send_sndbuf_remove()
481 if (rs->rs_snd_bytes == 0) in rds_send_sndbuf_remove()
501 struct rds_sock *rs = NULL; in rds_rdma_send_complete() local
512 rs = rm->m_rs; in rds_rdma_send_complete()
513 sock_hold(rds_rs_to_sk(rs)); in rds_rdma_send_complete()
516 spin_lock(&rs->rs_lock); in rds_rdma_send_complete()
517 list_add_tail(¬ifier->n_list, &rs in rds_rdma_send_complete()
537 struct rds_sock *rs = NULL; rds_atomic_send_complete() local
574 __rds_send_complete(struct rds_sock * rs,struct rds_message * rm,int status) __rds_send_complete() argument
607 struct rds_sock *rs = NULL; rds_send_remove_from_sock() local
721 rds_send_drop_to(struct rds_sock * rs,struct sockaddr_in6 * dest) rds_send_drop_to() argument
817 rds_send_queue_rm(struct rds_sock * rs,struct rds_connection * conn,struct rds_conn_path * cp,struct rds_message * rm,__be16 sport,__be16 dport,int * queued) rds_send_queue_rm() argument
970 rds_cmsg_zcopy(struct rds_sock * rs,struct rds_message * rm,struct cmsghdr * cmsg) rds_cmsg_zcopy() argument
983 rds_cmsg_send(struct rds_sock * rs,struct rds_message * rm,struct msghdr * msg,int * allocated_mr,struct rds_iov_vector_arr * vct) rds_cmsg_send() argument
1044 rds_send_mprds_hash(struct rds_sock * rs,struct rds_connection * conn,int nonblock) rds_send_mprds_hash() argument
1103 struct rds_sock *rs = rds_sk_to_rs(sk); rds_sendmsg() local
[all...] |
| H A D | cong.c | 266 struct rds_sock *rs; in rds_cong_map_updated() local
269 list_for_each_entry(rs, &rds_cong_monitor, rs_cong_list) { in rds_cong_map_updated()
270 spin_lock(&rs->rs_lock); in rds_cong_map_updated()
271 rs->rs_cong_notify |= (rs->rs_cong_mask & portmask); in rds_cong_map_updated()
272 rs->rs_cong_mask &= ~portmask; in rds_cong_map_updated()
273 spin_unlock(&rs->rs_lock); in rds_cong_map_updated()
274 if (rs->rs_cong_notify) in rds_cong_map_updated()
275 rds_wake_sk_sleep(rs); in rds_cong_map_updated()
338 void rds_cong_add_socket(struct rds_sock *rs) in rds_cong_add_socket() argument
348 rds_cong_remove_socket(struct rds_sock * rs) rds_cong_remove_socket() argument
369 rds_cong_wait(struct rds_cong_map * map,__be16 port,int nonblock,struct rds_sock * rs) rds_cong_wait() argument
[all...] |
| /linux/fs/jffs2/ |
| H A D | compr_rubin.c | 88 static void init_rubin(struct rubin_state *rs, int div, int *bits) in init_rubin() argument
92 rs->q = 0; in init_rubin()
93 rs->p = (long) (2 * UPPER_BIT_RUBIN); in init_rubin()
94 rs->bit_number = (long) 0; in init_rubin()
95 rs->bit_divider = div; in init_rubin()
98 rs->bits[c] = bits[c]; in init_rubin()
102 static int encode(struct rubin_state *rs, long A, long B, int symbol) in encode() argument
108 while ((rs->q >= UPPER_BIT_RUBIN) || in encode()
109 ((rs->p + rs in encode()
138 end_rubin(struct rubin_state * rs) end_rubin() argument
151 init_decode(struct rubin_state * rs,int div,int * bits) init_decode() argument
163 __do_decode(struct rubin_state * rs,unsigned long p,unsigned long q) __do_decode() argument
200 decode(struct rubin_state * rs,long A,long B) decode() argument
230 out_byte(struct rubin_state * rs,unsigned char byte) out_byte() argument
249 in_byte(struct rubin_state * rs) in_byte() argument
268 struct rubin_state rs; rubin_do_compress() local
369 struct rubin_state rs; rubin_do_decompress() local
[all...] |
| /linux/include/linux/ |
| H A D | ratelimit.h | 9 static inline void ratelimit_state_init(struct ratelimit_state *rs, in ratelimit_state_init() argument
12 memset(rs, 0, sizeof(*rs)); in ratelimit_state_init()
14 raw_spin_lock_init(&rs->lock); in ratelimit_state_init()
15 rs->interval = interval; in ratelimit_state_init()
16 rs->burst = burst; in ratelimit_state_init()
19 static inline void ratelimit_default_init(struct ratelimit_state *rs) in ratelimit_default_init() argument
21 return ratelimit_state_init(rs, DEFAULT_RATELIMIT_INTERVAL, in ratelimit_default_init()
25 static inline void ratelimit_state_inc_miss(struct ratelimit_state *rs) in ratelimit_state_inc_miss() argument
27 atomic_inc(&rs in ratelimit_state_inc_miss()
30 ratelimit_state_get_miss(struct ratelimit_state * rs) ratelimit_state_get_miss() argument
35 ratelimit_state_reset_miss(struct ratelimit_state * rs) ratelimit_state_reset_miss() argument
40 ratelimit_state_reset_interval(struct ratelimit_state * rs,int interval_init) ratelimit_state_reset_interval() argument
52 ratelimit_state_exit(struct ratelimit_state * rs) ratelimit_state_exit() argument
65 ratelimit_set_flags(struct ratelimit_state * rs,unsigned long flags) ratelimit_set_flags() argument
[all...] |
| /linux/lib/ |
| H A D | ratelimit.c | 17 * @rs: ratelimit_state data
20 * This enforces a rate limit: not more than @rs->burst callbacks
21 * in every @rs->interval
27 int ___ratelimit(struct ratelimit_state *rs, const char *func) in ___ratelimit() argument
33 int interval = READ_ONCE(rs->interval); in ___ratelimit()
34 int burst = READ_ONCE(rs->burst); in ___ratelimit()
45 if (!(READ_ONCE(rs->flags) & RATELIMIT_INITIALIZED) || (!interval && !burst) || in ___ratelimit()
46 !raw_spin_trylock_irqsave(&rs->lock, flags)) in ___ratelimit()
50 rs->flags &= ~RATELIMIT_INITIALIZED; in ___ratelimit()
60 if (!raw_spin_trylock_irqsave(&rs in ___ratelimit()
[all...] |
| /linux/net/ipv4/ |
| H A D | tcp_rate.c | 81 struct rate_sample *rs) in tcp_rate_skb_delivered() argument
91 if (!rs->prior_delivered || in tcp_rate_skb_delivered()
93 scb->end_seq, rs->last_end_seq)) { in tcp_rate_skb_delivered()
94 rs->prior_delivered_ce = scb->tx.delivered_ce; in tcp_rate_skb_delivered()
95 rs->prior_delivered = scb->tx.delivered; in tcp_rate_skb_delivered()
96 rs->prior_mstamp = scb->tx.delivered_mstamp; in tcp_rate_skb_delivered()
97 rs->is_app_limited = scb->tx.is_app_limited; in tcp_rate_skb_delivered()
98 rs->is_retrans = scb->sacked & TCPCB_RETRANS; in tcp_rate_skb_delivered()
99 rs->last_end_seq = scb->end_seq; in tcp_rate_skb_delivered()
104 rs in tcp_rate_skb_delivered()
118 tcp_rate_gen(struct sock * sk,u32 delivered,u32 lost,bool is_sack_reneg,struct rate_sample * rs) tcp_rate_gen() argument
[all...] |
| /linux/fs/isofs/ |
| H A D | rock.c | 54 struct inode *inode, struct rock_state *rs) in setup_rock_ridge() argument
56 rs->len = sizeof(struct iso_directory_record) + de->name_len[0]; in setup_rock_ridge()
57 if (rs->len & 1) in setup_rock_ridge()
58 (rs->len)++; in setup_rock_ridge()
59 rs->chr = (unsigned char *)de + rs->len; in setup_rock_ridge()
60 rs->len = *((unsigned char *)de) - rs->len; in setup_rock_ridge()
61 if (rs->len < 0) in setup_rock_ridge()
62 rs in setup_rock_ridge()
72 init_rock_state(struct rock_state * rs,struct inode * inode) init_rock_state() argument
85 rock_continue(struct rock_state * rs) rock_continue() argument
139 rock_check_overflow(struct rock_state * rs,int sig) rock_check_overflow() argument
201 struct rock_state rs; get_rock_ridge_filename() local
318 struct rock_state rs; parse_rock_ridge_inode_internal() local
709 struct rock_state rs; rock_ridge_symlink_read_folio() local
[all...] |
| /linux/fs/xfs/scrub/ |
| H A D | reap.c | 151 static inline bool xreap_dirty(const struct xreap_state *rs) in xreap_dirty() argument
153 if (rs->force_roll) in xreap_dirty()
155 if (rs->deferred) in xreap_dirty()
157 if (rs->invalidated) in xreap_dirty()
159 if (rs->total_deferred) in xreap_dirty()
172 static inline bool xreap_want_roll(const struct xreap_state *rs) in xreap_want_roll() argument
174 if (rs->force_roll) in xreap_want_roll()
176 if (rs->deferred > XREP_MAX_ITRUNCATE_EFIS) in xreap_want_roll()
178 if (rs->invalidated > XREAP_MAX_BINVAL) in xreap_want_roll()
183 static inline void xreap_reset(struct xreap_state *rs) in xreap_reset() argument
201 xreap_want_defer_finish(const struct xreap_state * rs) xreap_want_defer_finish() argument
210 xreap_defer_finish_reset(struct xreap_state * rs) xreap_defer_finish_reset() argument
263 xreap_agextent_binval(struct xreap_state * rs,xfs_agblock_t agbno,xfs_extlen_t * aglenp) xreap_agextent_binval() argument
328 xreap_agextent_select(struct xreap_state * rs,xfs_agblock_t agbno,xfs_agblock_t agbno_next,bool * crosslinked,xfs_extlen_t * aglenp) xreap_agextent_select() argument
389 xreap_agextent_iter(struct xreap_state * rs,xfs_agblock_t agbno,xfs_extlen_t * aglenp,bool crosslinked) xreap_agextent_iter() argument
508 struct xreap_state *rs = priv; xreap_agmeta_extent() local
555 struct xreap_state rs = { xrep_reap_agblocks() local
586 struct xreap_state *rs = priv; xreap_fsmeta_extent() local
667 struct xreap_state rs = { xrep_reap_fsblocks() local
695 xreap_rgextent_select(struct xreap_state * rs,xfs_rgblock_t rgbno,xfs_rgblock_t rgbno_next,bool * crosslinked,xfs_extlen_t * rglenp) xreap_rgextent_select() argument
750 xreap_rgextent_iter(struct xreap_state * rs,xfs_rgblock_t rgbno,xfs_extlen_t * rglenp,bool crosslinked) xreap_rgextent_iter() argument
821 struct xreap_state *rs = priv; xreap_rtmeta_extent() local
885 struct xreap_state rs = { xrep_reap_rtblocks() local
921 struct xreap_state rs = { xrep_reap_metadir_fsblocks() local
[all...] |
| /linux/arch/mips/include/asm/ |
| H A D | uasm.h | 199 void UASM_i_LA_mostly(u32 **buf, unsigned int rs, long addr);
200 void UASM_i_LA(u32 **buf, unsigned int rs, long addr);
210 # define UASM_i_ADDIU(buf, rs, rt, val) uasm_i_daddiu(buf, rs, rt, val) argument
211 # define UASM_i_ADDU(buf, rs, rt, rd) uasm_i_daddu(buf, rs, rt, rd) argument
212 # define UASM_i_LL(buf, rs, rt, off) uasm_i_lld(buf, rs, rt, off) argument
213 # define UASM_i_LW(buf, rs, rt, off) uasm_i_ld(buf, rs, r argument
214 UASM_i_LWX(buf,rs,rt,rd) global() argument
217 UASM_i_ROTR(buf,rs,rt,sh) global() argument
218 UASM_i_SC(buf,rs,rt,off) global() argument
219 UASM_i_SLL(buf,rs,rt,sh) global() argument
220 UASM_i_SRA(buf,rs,rt,sh) global() argument
221 UASM_i_SRL(buf,rs,rt,sh) global() argument
222 UASM_i_SRL_SAFE(buf,rs,rt,sh) global() argument
223 UASM_i_SUBU(buf,rs,rt,rd) global() argument
224 UASM_i_SW(buf,rs,rt,off) global() argument
226 UASM_i_ADDIU(buf,rs,rt,val) global() argument
227 UASM_i_ADDU(buf,rs,rt,rd) global() argument
228 UASM_i_LL(buf,rs,rt,off) global() argument
229 UASM_i_LW(buf,rs,rt,off) global() argument
230 UASM_i_LWX(buf,rs,rt,rd) global() argument
233 UASM_i_ROTR(buf,rs,rt,sh) global() argument
234 UASM_i_SC(buf,rs,rt,off) global() argument
235 UASM_i_SLL(buf,rs,rt,sh) global() argument
236 UASM_i_SRA(buf,rs,rt,sh) global() argument
237 UASM_i_SRL(buf,rs,rt,sh) global() argument
238 UASM_i_SRL_SAFE(buf,rs,rt,sh) global() argument
239 UASM_i_SUBU(buf,rs,rt,rd) global() argument
240 UASM_i_SW(buf,rs,rt,off) global() argument
244 uasm_i_beqz(buf,rs,off) global() argument
245 uasm_i_beqzl(buf,rs,off) global() argument
246 uasm_i_bnez(buf,rs,off) global() argument
247 uasm_i_bnezl(buf,rs,off) global() argument
[all...] |
| /linux/arch/riscv/net/ |
| H A D | bpf_jit_comp64.c | 280 static void emit_bcc(u8 cond, u8 rd, u8 rs, int rvoff, in emit_bcc() argument
285 emit(rv_beq(rd, rs, rvoff >> 1), ctx); in emit_bcc()
288 emit(rv_bltu(rs, rd, rvoff >> 1), ctx); in emit_bcc()
291 emit(rv_bltu(rd, rs, rvoff >> 1), ctx); in emit_bcc()
294 emit(rv_bgeu(rd, rs, rvoff >> 1), ctx); in emit_bcc()
297 emit(rv_bgeu(rs, rd, rvoff >> 1), ctx); in emit_bcc()
300 emit(rv_bne(rd, rs, rvoff >> 1), ctx); in emit_bcc()
303 emit(rv_blt(rs, rd, rvoff >> 1), ctx); in emit_bcc()
306 emit(rv_blt(rd, rs, rvoff >> 1), ctx); in emit_bcc()
309 emit(rv_bge(rd, rs, rvof in emit_bcc()
316 emit_branch(u8 cond,u8 rd,u8 rs,int rvoff,struct rv_jit_context * ctx) emit_branch() argument
406 init_regs(u8 * rd,u8 * rs,const struct bpf_insn * insn,struct rv_jit_context * ctx) init_regs() argument
476 emit_load_8(bool sign_ext,u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_load_8() argument
499 emit_load_16(bool sign_ext,u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_load_16() argument
522 emit_load_32(bool sign_ext,u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_load_32() argument
545 emit_load_64(bool sign_ext,u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_load_64() argument
562 emit_store_8(u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_store_8() argument
574 emit_store_16(u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_store_16() argument
586 emit_store_32(u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_store_32() argument
598 emit_store_64(u8 rd,s32 off,u8 rs,struct rv_jit_context * ctx) emit_store_64() argument
610 emit_atomic_ld_st(u8 rd,u8 rs,const struct bpf_insn * insn,struct rv_jit_context * ctx) emit_atomic_ld_st() argument
668 emit_atomic_rmw(u8 rd,u8 rs,const struct bpf_insn * insn,struct rv_jit_context * ctx) emit_atomic_rmw() argument
1336 u8 rd = -1, rs = -1, code = insn->code; bpf_jit_emit_insn() local
[all...] |
| /linux/arch/arc/net/ |
| H A D | bpf_jit.h | 44 u8 mov_r32(u8 *buf, u8 rd, u8 rs, u8 sign_ext);
46 u8 mov_r64(u8 *buf, u8 rd, u8 rs, u8 sign_ext);
50 u8 load_r(u8 *buf, u8 rd, u8 rs, s16 off, u8 size, bool sign_ext);
51 u8 store_r(u8 *buf, u8 rd, u8 rs, s16 off, u8 size);
54 u8 add_r32(u8 *buf, u8 rd, u8 rs);
56 u8 add_r64(u8 *buf, u8 rd, u8 rs);
59 u8 sub_r32(u8 *buf, u8 rd, u8 rs);
61 u8 sub_r64(u8 *buf, u8 rd, u8 rs);
64 u8 mul_r32(u8 *buf, u8 rd, u8 rs);
66 u8 mul_r64(u8 *buf, u8 rd, u8 rs);
[all...] |
| /linux/arch/mips/kernel/ |
| H A D | mips-r2-to-r6-emul.c | 405 s32 rt, rs; in mult_func() local
408 rs = regs->regs[MIPSInst_RS(ir)]; in mult_func()
409 res = (s64)rt * (s64)rs; in mult_func()
411 rs = res; in mult_func()
412 regs->lo = (s64)rs; in mult_func()
432 u32 rt, rs; in multu_func() local
435 rs = regs->regs[MIPSInst_RS(ir)]; in multu_func()
436 res = (u64)rt * (u64)rs; in multu_func()
455 s32 rt, rs; in div_func() local
458 rs in div_func()
477 u32 rt, rs; divu_func() local
500 s64 rt, rs; dmult_func() local
532 u64 rt, rs; dmultu_func() local
563 s64 rt, rs; ddiv_func() local
588 u64 rt, rs; ddivu_func() local
636 s32 rt, rs; madd_func() local
665 u32 rt, rs; maddu_func() local
694 s32 rt, rs; msub_func() local
723 u32 rt, rs; msubu_func() local
752 s32 rt, rs; mul_func() local
778 u32 rs; clz_func() local
803 u32 rs; clo_func() local
827 u64 rs; dclz_func() local
854 u64 rs; dclo_func() local
911 unsigned long cpc, epc, nepc, r31, res, rs, rt; mipsr2_decoder() local
[all...] |
| /linux/drivers/platform/chrome/wilco_ec/ |
| H A D | properties.c | 36 struct ec_property_response *rs) in send_property_msg() argument
45 ec_msg.response_data = rs; in send_property_msg()
46 ec_msg.response_size = sizeof(*rs); in send_property_msg()
51 if (rs->op != rq->op) in send_property_msg()
53 if (memcmp(rq->property_id, rs->property_id, sizeof(rs->property_id))) in send_property_msg()
63 struct ec_property_response rs; in wilco_ec_get_property() local
70 ret = send_property_msg(ec, &rq, &rs); in wilco_ec_get_property()
74 prop_msg->length = rs.length; in wilco_ec_get_property()
75 memcpy(prop_msg->data, rs in wilco_ec_get_property()
85 struct ec_property_response rs; wilco_ec_set_property() local
[all...] |
| /linux/drivers/net/wireless/ath/ath5k/ |
| H A D | desc.c | 592 * @rs: The &struct ath5k_rx_status
603 struct ath5k_rx_status *rs) in ath5k_hw_proc_5210_rx_status() argument
614 memset(rs, 0, sizeof(struct ath5k_rx_status)); in ath5k_hw_proc_5210_rx_status()
619 rs->rs_datalen = rx_status->rx_status_0 & in ath5k_hw_proc_5210_rx_status()
621 rs->rs_rssi = AR5K_REG_MS(rx_status->rx_status_0, in ath5k_hw_proc_5210_rx_status()
623 rs->rs_rate = AR5K_REG_MS(rx_status->rx_status_0, in ath5k_hw_proc_5210_rx_status()
625 rs->rs_more = !!(rx_status->rx_status_0 & in ath5k_hw_proc_5210_rx_status()
632 rs->rs_tstamp = AR5K_REG_MS(rx_status->rx_status_1, in ath5k_hw_proc_5210_rx_status()
636 rs->rs_antenna = AR5K_REG_MS(rx_status->rx_status_0, in ath5k_hw_proc_5210_rx_status()
639 rs in ath5k_hw_proc_5210_rx_status()
697 ath5k_hw_proc_5212_rx_status(struct ath5k_hw * ah,struct ath5k_desc * desc,struct ath5k_rx_status * rs) ath5k_hw_proc_5212_rx_status() argument
[all...] |
| /linux/tools/testing/selftests/kvm/x86/ |
| H A D | xen_shinfo_test.c | 191 struct vcpu_runstate_info *rs = (void *)RUNSTATE_VADDR; in guest_code() local
203 GUEST_ASSERT(rs->time[RUNSTATE_runnable] != 0); in guest_code()
204 GUEST_ASSERT(rs->state == 0); in guest_code()
207 GUEST_ASSERT(rs->time[RUNSTATE_blocked] != 0); in guest_code()
208 GUEST_ASSERT(rs->state == 0); in guest_code()
211 GUEST_ASSERT(rs->time[RUNSTATE_offline] != 0); in guest_code()
212 GUEST_ASSERT(rs->state == 0); in guest_code()
216 GUEST_ASSERT(rs->time[RUNSTATE_blocked] == 0x5a); in guest_code()
217 GUEST_ASSERT(rs->time[RUNSTATE_offline] == 0x6b6b); in guest_code()
221 GUEST_ASSERT(rs in guest_code()
612 struct vcpu_runstate_info *rs = addr_gpa2hva(vm, RUNSTATE_ADDR); main() local
[all...] |