Home
last modified time | relevance | path

Searched refs:rs (Results 1 – 25 of 157) sorted by relevance

1234567

/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/
H A Daf_rds.c90 struct rdsv3_sock *rs; in rdsv3_release() local
95 rs = rdsv3_sk_to_rs(sk); in rdsv3_release()
96 RDSV3_DPRINTF4("rdsv3_release", "Enter(rs: %p, sk: %p)", rs, sk); in rdsv3_release()
99 rdsv3_cong_remove_socket(rs); in rdsv3_release()
100 rdsv3_remove_bound(rs); in rdsv3_release()
111 rdsv3_clear_recv_queue(rs); in rdsv3_release()
112 rdsv3_send_drop_to(rs, NULL); in rdsv3_release()
113 rdsv3_rdma_drop_keys(rs); in rdsv3_release()
114 (void) rdsv3_notify_queue_get(rs, NULL); in rdsv3_release()
117 list_remove_node(&rs->rs_item); in rdsv3_release()
[all …]
H A Drds_recv.c85 rdsv3_recv_rcvbuf_delta(struct rdsv3_sock *rs, struct rsock *sk, in rdsv3_recv_rcvbuf_delta() argument
93 rs, map, delta, port); in rdsv3_recv_rcvbuf_delta()
98 rs->rs_rcv_bytes += delta; in rdsv3_recv_rcvbuf_delta()
99 now_congested = rs->rs_rcv_bytes > rdsv3_sk_rcvbuf(rs); in rdsv3_recv_rcvbuf_delta()
104 rs, NIPQUAD(rs->rs_bound_addr), in rdsv3_recv_rcvbuf_delta()
105 (int)ntohs(rs->rs_bound_port), rs->rs_rcv_bytes, in rdsv3_recv_rcvbuf_delta()
106 rdsv3_sk_rcvbuf(rs), now_congested, delta); in rdsv3_recv_rcvbuf_delta()
109 if (!rs->rs_congested && now_congested) { in rdsv3_recv_rcvbuf_delta()
110 rs->rs_congested = 1; in rdsv3_recv_rcvbuf_delta()
119 else if (rs->rs_congested && in rdsv3_recv_rcvbuf_delta()
[all …]
H A Dbind.c146 struct rdsv3_sock *rs; in rdsv3_find_bound() local
153 rs = conn->c_bucketp->port[ntohs(port)]; in rdsv3_find_bound()
154 if (rs && !rdsv3_sk_sock_flag(rdsv3_rs_to_sk(rs), SOCK_DEAD)) in rdsv3_find_bound()
155 rdsv3_sk_sock_hold(rdsv3_rs_to_sk(rs)); in rdsv3_find_bound()
157 rs = NULL; in rdsv3_find_bound()
161 rs, NIPQUAD(conn->c_laddr), ntohs(port)); in rdsv3_find_bound()
163 return (rs); in rdsv3_find_bound()
168 rdsv3_add_bound(struct rdsv3_sock *rs, uint32_be_t addr, uint16_be_t *port) in rdsv3_add_bound() argument
187 bucketp = rdsv3_find_ip_bucket(ntohl(addr), rs->rs_zoneid); in rdsv3_add_bound()
204 rs->rs_bound_addr = addr; in rdsv3_add_bound()
[all …]
H A Dsend.c421 rdsv3_send_sndbuf_remove(struct rdsv3_sock *rs, struct rdsv3_message *rm) in rdsv3_send_sndbuf_remove() argument
425 ASSERT(mutex_owned(&rs->rs_lock)); in rdsv3_send_sndbuf_remove()
427 ASSERT(rs->rs_snd_bytes >= len); in rdsv3_send_sndbuf_remove()
428 rs->rs_snd_bytes -= len; in rdsv3_send_sndbuf_remove()
430 if (rs->rs_snd_bytes == 0) in rdsv3_send_sndbuf_remove()
484 struct rdsv3_sock *rs = NULL; in rdsv3_rdma_send_complete() local
496 rs = rm->m_rs; in rdsv3_rdma_send_complete()
497 rdsv3_sk_sock_hold(rdsv3_rs_to_sk(rs)); in rdsv3_rdma_send_complete()
500 mutex_enter(&rs->rs_lock); in rdsv3_rdma_send_complete()
501 list_insert_tail(&rs->rs_notify_queue, notifier); in rdsv3_rdma_send_complete()
[all …]
H A Drdma.c108 struct rdsv3_sock *rs = mr->r_sock; in rdsv3_destroy_mr() local
119 mutex_enter(&rs->rs_rdma_lock); in rdsv3_destroy_mr()
122 avl_remove(&rs->rs_rdma_keys, mr); in rdsv3_destroy_mr()
125 mutex_exit(&rs->rs_rdma_lock); in rdsv3_destroy_mr()
143 rdsv3_rdma_drop_keys(struct rdsv3_sock *rs) in rdsv3_rdma_drop_keys() argument
149 mutex_enter(&rs->rs_rdma_lock); in rdsv3_rdma_drop_keys()
150 while ((node = avl_first(&rs->rs_rdma_keys))) { in rdsv3_rdma_drop_keys()
152 if (mr->r_trans == rs->rs_transport) in rdsv3_rdma_drop_keys()
154 avl_remove(&rs->rs_rdma_keys, &mr->r_rb_node); in rdsv3_rdma_drop_keys()
156 mutex_exit(&rs->rs_rdma_lock); in rdsv3_rdma_drop_keys()
[all …]
H A Dcong.c270 struct rdsv3_sock *rs; in rdsv3_cong_map_updated() local
273 RDSV3_FOR_EACH_LIST_NODE(rs, &rdsv3_cong_monitor, in rdsv3_cong_map_updated()
275 mutex_enter(&rs->rs_lock); in rdsv3_cong_map_updated()
276 rs->rs_cong_notify |= (rs->rs_cong_mask & portmask); in rdsv3_cong_map_updated()
277 rs->rs_cong_mask &= ~portmask; in rdsv3_cong_map_updated()
278 mutex_exit(&rs->rs_lock); in rdsv3_cong_map_updated()
279 if (rs->rs_cong_notify) in rdsv3_cong_map_updated()
280 rdsv3_wake_sk_sleep(rs); in rdsv3_cong_map_updated()
352 rdsv3_cong_add_socket(struct rdsv3_sock *rs) in rdsv3_cong_add_socket() argument
354 RDSV3_DPRINTF4("rdsv3_cong_add_socket", "Enter(rs: %p)", rs); in rdsv3_cong_add_socket()
[all …]
H A Drdsv3_debug.c373 struct ratelimit_state *rs = &rdsv3_printk_ratelimit_state; in rdsv3_printk_ratelimit() local
377 if (rs->interval) { in rdsv3_printk_ratelimit()
380 mutex_enter(&rs->lock); in rdsv3_printk_ratelimit()
381 if (!rs->begin) { in rdsv3_printk_ratelimit()
382 rs->begin = current; in rdsv3_printk_ratelimit()
384 if (current < rs->begin + TICK_TO_NSEC(rs->interval)) { in rdsv3_printk_ratelimit()
385 if (rs->missed) { in rdsv3_printk_ratelimit()
387 "%d callbacks suppressed\n", rs->missed); in rdsv3_printk_ratelimit()
388 rs->begin = 0; in rdsv3_printk_ratelimit()
389 rs->printed = 0; in rdsv3_printk_ratelimit()
[all …]
/illumos-gate/usr/src/uts/common/fs/zfs/
H A Drange_tree.c101 range_seg_t *rs; in range_tree_stat_verify() local
106 for (rs = zfs_btree_first(&rt->rt_root, &where); rs != NULL; in range_tree_stat_verify()
107 rs = zfs_btree_next(&rt->rt_root, &where, &where)) { in range_tree_stat_verify()
108 uint64_t size = rs_get_end(rs, rt) - rs_get_start(rs, rt); in range_tree_stat_verify()
125 range_tree_stat_incr(range_tree_t *rt, range_seg_t *rs) in range_tree_stat_incr() argument
127 uint64_t size = rs_get_end(rs, rt) - rs_get_start(rs, rt); in range_tree_stat_incr()
139 range_tree_stat_decr(range_tree_t *rt, range_seg_t *rs) in range_tree_stat_decr() argument
141 uint64_t size = rs_get_end(rs, rt) - rs_get_start(rs, rt); in range_tree_stat_decr()
252 range_tree_adjust_fill(range_tree_t *rt, range_seg_t *rs, int64_t delta) in range_tree_adjust_fill() argument
254 ASSERT3U(rs_get_fill(rs, rt) + delta, !=, 0); in range_tree_adjust_fill()
[all …]
/illumos-gate/usr/src/uts/common/fs/zfs/sys/
H A Drange_tree.h118 void (*rtop_add)(range_tree_t *rt, void *rs, void *arg);
119 void (*rtop_remove)(range_tree_t *rt, void *rs, void *arg);
124 rs_get_start_raw(const range_seg_t *rs, const range_tree_t *rt) in rs_get_start_raw() argument
129 return (((const range_seg32_t *)rs)->rs_start); in rs_get_start_raw()
131 return (((const range_seg64_t *)rs)->rs_start); in rs_get_start_raw()
133 return (((const range_seg_gap_t *)rs)->rs_start); in rs_get_start_raw()
141 rs_get_end_raw(const range_seg_t *rs, const range_tree_t *rt) in rs_get_end_raw() argument
146 return (((const range_seg32_t *)rs)->rs_end); in rs_get_end_raw()
148 return (((const range_seg64_t *)rs)->rs_end); in rs_get_end_raw()
150 return (((const range_seg_gap_t *)rs)->rs_end); in rs_get_end_raw()
[all …]
/illumos-gate/usr/src/lib/libc/amd64/threads/
H A Dmachdep.c129 getgregs(ulwp_t *ulwp, gregset_t rs) in getgregs() argument
134 rs[REG_RBX] = status.pr_reg[REG_RBX]; in getgregs()
135 rs[REG_R12] = status.pr_reg[REG_R12]; in getgregs()
136 rs[REG_R13] = status.pr_reg[REG_R13]; in getgregs()
137 rs[REG_R14] = status.pr_reg[REG_R14]; in getgregs()
138 rs[REG_R15] = status.pr_reg[REG_R15]; in getgregs()
139 rs[REG_RBP] = status.pr_reg[REG_RBP]; in getgregs()
140 rs[REG_RSP] = status.pr_reg[REG_RSP]; in getgregs()
141 rs[REG_RIP] = status.pr_reg[REG_RIP]; in getgregs()
143 rs[REG_RBX] = 0; in getgregs()
[all …]
/illumos-gate/usr/src/uts/common/io/hxge/
H A Dhxge_fzc.c70 hpi_status_t rs = HPI_SUCCESS; in hxge_fzc_intr_ldg_num_set() local
92 rs = hpi_fzc_ldg_num_set(handle, ldvp->ldv, in hxge_fzc_intr_ldg_num_set()
94 if (rs != HPI_SUCCESS) { in hxge_fzc_intr_ldg_num_set()
98 rs, ldvp->ldv, ldvp->ldg_assigned)); in hxge_fzc_intr_ldg_num_set()
99 return (HXGE_ERROR | rs); in hxge_fzc_intr_ldg_num_set()
115 hpi_status_t rs = HPI_SUCCESS; in hxge_fzc_intr_tmres_set() local
123 if ((rs = hpi_fzc_ldg_timer_res_set(handle, hxgep->ldgvp->tmres))) { in hxge_fzc_intr_tmres_set()
124 return (HXGE_ERROR | rs); in hxge_fzc_intr_tmres_set()
138 hpi_status_t rs = HPI_SUCCESS; in hxge_fzc_intr_sid_set() local
157 rs = hpi_fzc_sid_set(handle, sid); in hxge_fzc_intr_sid_set()
[all …]
/illumos-gate/usr/src/uts/common/io/nxge/
H A Dnxge_fzc.c55 npi_status_t rs = NPI_SUCCESS; in nxge_test_and_set() local
58 if ((rs = npi_dev_func_sr_sr_get_set_clear(handle, tas)) in nxge_test_and_set()
60 return (NXGE_ERROR | rs); in nxge_test_and_set()
70 npi_status_t rs = NPI_SUCCESS; in nxge_set_fzc_multi_part_ctl() local
84 if ((rs = npi_fzc_mpc_set(handle, mpc)) != NPI_SUCCESS) { in nxge_set_fzc_multi_part_ctl()
87 return (NXGE_ERROR | rs); in nxge_set_fzc_multi_part_ctl()
99 npi_status_t rs = NPI_SUCCESS; in nxge_get_fzc_multi_part_ctl() local
104 if ((rs = npi_fzc_mpc_get(handle, mpc_p)) != NPI_SUCCESS) { in nxge_get_fzc_multi_part_ctl()
107 return (NXGE_ERROR | rs); in nxge_get_fzc_multi_part_ctl()
157 npi_status_t rs = NPI_SUCCESS; in nxge_fzc_intr_ldg_num_set() local
[all …]
H A Dnxge_ipp.c40 npi_status_t rs = NPI_SUCCESS; in nxge_ipp_init() local
64 if ((rs = npi_ipp_write_dfifo(handle, in nxge_ipp_init()
67 if ((rs = npi_ipp_read_dfifo(handle, portn, in nxge_ipp_init()
73 if ((rs = npi_ipp_get_status(handle, portn, &istatus)) != NPI_SUCCESS) in nxge_ipp_init()
75 if ((rs = npi_ipp_get_status(handle, portn, &istatus)) != NPI_SUCCESS) in nxge_ipp_init()
82 if ((rs = npi_ipp_reset(handle, portn)) != NPI_SUCCESS) in nxge_ipp_init()
90 if ((rs = npi_ipp_get_status(handle, portn, &istatus)) != NPI_SUCCESS) in nxge_ipp_init()
94 if ((rs = npi_ipp_iconfig(handle, INIT, portn, ICFG_IPP_ALL)) in nxge_ipp_init()
101 if ((rs = npi_ipp_config(handle, INIT, portn, config)) != NPI_SUCCESS) in nxge_ipp_init()
107 if ((rs = npi_ipp_set_max_pktsize(handle, portn, in nxge_ipp_init()
[all …]
H A Dnxge_fflp.c164 npi_status_t rs = NPI_SUCCESS; in nxge_fflp_vlan_tbl_clear_all() local
170 rs = npi_fflp_cfg_vlan_table_clear(handle, vlan_id); in nxge_fflp_vlan_tbl_clear_all()
171 if (rs != NPI_SUCCESS) { in nxge_fflp_vlan_tbl_clear_all()
175 return (NXGE_ERROR | rs); in nxge_fflp_vlan_tbl_clear_all()
196 npi_status_t rs = NPI_SUCCESS; in nxge_fflp_tcam_init() local
202 rs = npi_fflp_cfg_tcam_disable(handle); in nxge_fflp_tcam_init()
203 if (rs != NPI_SUCCESS) { in nxge_fflp_tcam_init()
205 return (NXGE_ERROR | rs); in nxge_fflp_tcam_init()
209 rs = npi_fflp_cfg_tcam_access(handle, access_ratio); in nxge_fflp_tcam_init()
210 if (rs != NPI_SUCCESS) { in nxge_fflp_tcam_init()
[all …]
H A Dnxge_txc.c41 npi_status_t rs = NPI_SUCCESS; in nxge_txc_init() local
51 if ((rs = npi_txc_global_enable(handle)) != NPI_SUCCESS) { in nxge_txc_init()
56 if ((rs = npi_txc_port_enable(handle, port)) != NPI_SUCCESS) { in nxge_txc_init()
61 if ((rs = npi_txc_port_dma_enable(handle, port, in nxge_txc_init()
77 return (NXGE_ERROR | rs); in nxge_txc_init()
85 npi_status_t rs = NPI_SUCCESS; in nxge_txc_uninit() local
95 if ((rs = npi_txc_global_disable(handle)) != NPI_SUCCESS) { in nxge_txc_uninit()
100 if ((rs = npi_txc_port_disable(handle, port)) != NPI_SUCCESS) { in nxge_txc_uninit()
105 if ((rs = npi_txc_port_dma_enable(handle, port, 0)) != NPI_SUCCESS) { in nxge_txc_uninit()
117 return (NXGE_ERROR | rs); in nxge_txc_uninit()
[all …]
/illumos-gate/usr/src/lib/libc/sparc/threads/
H A Dmachdep.c141 getgregs(ulwp_t *ulwp, gregset_t rs) in getgregs() argument
146 rs[REG_PC] = status.pr_reg[R_PC]; in getgregs()
147 rs[REG_O6] = status.pr_reg[R_O6]; in getgregs()
148 rs[REG_O7] = status.pr_reg[R_O7]; in getgregs()
149 rs[REG_G1] = status.pr_reg[R_G1]; in getgregs()
150 rs[REG_G2] = status.pr_reg[R_G2]; in getgregs()
151 rs[REG_G3] = status.pr_reg[R_G3]; in getgregs()
152 rs[REG_G4] = status.pr_reg[R_G4]; in getgregs()
154 rs[REG_PC] = 0; in getgregs()
155 rs[REG_O6] = 0; in getgregs()
[all …]
/illumos-gate/usr/src/uts/common/inet/ipf/netinet/
H A Dip_rpcb_pxy.c176 rpcb_session_t *rs; local
181 KMALLOC(rs, rpcb_session_t *);
182 if (rs == NULL)
185 bzero((char *)rs, sizeof(*rs));
186 MUTEX_INIT(&rs->rs_rxlock, "ipf Sun RPCB proxy session lock");
188 aps->aps_data = rs;
207 rpcb_session_t *rs; local
208 rs = (rpcb_session_t *)aps->aps_data;
212 MUTEX_ENTER(&rs->rs_rxlock);
213 ippr_rpcb_flush(rs);
[all …]
/illumos-gate/usr/src/lib/libc/i386/threads/
H A Dmachdep.c174 getgregs(ulwp_t *ulwp, gregset_t rs) in getgregs() argument
179 rs[EIP] = status.pr_reg[EIP]; in getgregs()
180 rs[EDI] = status.pr_reg[EDI]; in getgregs()
181 rs[ESI] = status.pr_reg[ESI]; in getgregs()
182 rs[EBP] = status.pr_reg[EBP]; in getgregs()
183 rs[EBX] = status.pr_reg[EBX]; in getgregs()
184 rs[UESP] = status.pr_reg[UESP]; in getgregs()
186 rs[EIP] = 0; in getgregs()
187 rs[EDI] = 0; in getgregs()
188 rs[ESI] = 0; in getgregs()
[all …]
/illumos-gate/usr/src/lib/krb5/plugins/preauth/pkinit/
H A Dpkinit_matching.c176 rule_set *rs) in free_rule_set() argument
180 if (rs == NULL) in free_rule_set()
182 for (rc = rs->crs; rc != NULL;) { in free_rule_set()
188 free(rs); in free_rule_set()
398 rule_set *rs; in parse_rule_set() local
407 rs = calloc(1, sizeof(*rs)); in parse_rule_set()
408 if (rs == NULL) { in parse_rule_set()
413 rs->relation = relation_none; in parse_rule_set()
416 rs->relation = relation_and; in parse_rule_set()
420 rs->relation = relation_or; in parse_rule_set()
[all …]
/illumos-gate/usr/src/lib/libpool/common/
H A Dpool.c335 pool_resource_t **rs; in pool_base_info() local
384 if ((rs = pool_query_pool_resources(conf, pool_elem_pool(pe), in pool_base_info()
392 elem = TO_ELEM(rs[i]); in pool_base_info()
396 free(rs); in pool_base_info()
402 free(rs); in pool_base_info()
408 free(rs); in pool_base_info()
412 free(rs); in pool_base_info()
437 if ((rs = pool_query_resources(conf, &nelem, NULL)) != in pool_base_info()
440 elem = TO_ELEM(rs[i]); in pool_base_info()
443 free(rs); in pool_base_info()
[all …]
/illumos-gate/usr/src/cmd/cmd-inet/usr.lib/in.chargend/
H A Din.chargend.c70 char *rs = ring; in chargen_stream() local
75 if (rs >= endring) in chargen_stream()
76 rs = ring; in chargen_stream()
77 rp = rs++; in chargen_stream()
108 static char *rs = ring; in chargen_dg() local
110 rp = rs; in chargen_dg()
111 if (rs++ >= endring) in chargen_dg()
112 rs = ring; in chargen_dg()
/illumos-gate/usr/src/uts/common/sys/ib/clients/rdsv3/
H A Drdma.h87 int rdsv3_get_mr(struct rdsv3_sock *rs, const void *optval, int optlen);
88 int rdsv3_get_mr_for_dest(struct rdsv3_sock *rs, const void *optval,
90 int rdsv3_free_mr(struct rdsv3_sock *rs, const void *optval, int optlen);
91 void rdsv3_rdma_drop_keys(struct rdsv3_sock *rs);
92 int rdsv3_cmsg_rdma_args(struct rdsv3_sock *rs, struct rdsv3_message *rm,
94 int rdsv3_cmsg_rdma_dest(struct rdsv3_sock *rs, struct rdsv3_message *rm,
96 int rdsv3_cmsg_rdma_map(struct rdsv3_sock *rs, struct rdsv3_message *rm,
H A Drdsv3.h387 struct rdsv3_sock *rs, uint32_t *key_ret);
477 rdsv3_rs_to_sk(const struct rdsv3_sock *rs) in rdsv3_rs_to_sk() argument
479 return ((struct rsock *)rs->rs_sk); in rdsv3_rs_to_sk()
488 rdsv3_sk_sndbuf(struct rdsv3_sock *rs) in rdsv3_sk_sndbuf() argument
491 return (rdsv3_rs_to_sk(rs)->sk_sndbuf); in rdsv3_sk_sndbuf()
495 rdsv3_sk_rcvbuf(struct rdsv3_sock *rs) in rdsv3_sk_rcvbuf() argument
498 return (rdsv3_rs_to_sk(rs)->sk_rcvbuf); in rdsv3_sk_rcvbuf()
538 void rdsv3_sock_addref(struct rdsv3_sock *rs);
539 void rdsv3_sock_put(struct rdsv3_sock *rs);
540 void rdsv3_wake_sk_sleep(struct rdsv3_sock *rs);
[all …]
/illumos-gate/usr/src/lib/libc/amd64/unwind/
H A Dcall_frame_inst.c143 fix_cfa(struct _Unwind_Context *ctx, struct register_state *rs) in fix_cfa() argument
145 switch (rs[CF_ADDR].rule) { in fix_cfa()
150 ctx->cfa = (ctx->current_regs)[rs[CF_ADDR].source_reg] + in fix_cfa()
151 rs[CF_ADDR].offset; in fix_cfa()
154 ctx->cfa = rs[CF_ADDR].offset; in fix_cfa()
158 (ctx->current_regs[rs[CF_ADDR].source_reg] + in fix_cfa()
159 rs[CF_ADDR].offset); in fix_cfa()
166 fix_ra(struct _Unwind_Context *ctx, struct register_state *rs) in fix_ra() argument
168 switch (rs[RET_ADD].rule) { in fix_ra()
174 ctx->ra = *(uint64_t *)(ctx->cfa + rs[RET_ADD].offset); in fix_ra()
[all …]
/illumos-gate/usr/src/lib/libcurses/screen/
H A Dmbinch.c46 static char rs[CSMAX + 1]; in wmbinch() local
62 rs[k++] = (char)wc; in wmbinch()
66 rs[k++] = (char)wc; in wmbinch()
71 rs[k] = '\0'; in wmbinch()
72 return (rs); in wmbinch()

1234567