Home
last modified time | relevance | path

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

1234567

/titanic_50/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.c84 rdsv3_recv_rcvbuf_delta(struct rdsv3_sock *rs, struct rsock *sk, in rdsv3_recv_rcvbuf_delta() argument
92 rs, map, delta, port); in rdsv3_recv_rcvbuf_delta()
97 rs->rs_rcv_bytes += delta; in rdsv3_recv_rcvbuf_delta()
98 now_congested = rs->rs_rcv_bytes > rdsv3_sk_rcvbuf(rs); in rdsv3_recv_rcvbuf_delta()
103 rs, NIPQUAD(rs->rs_bound_addr), in rdsv3_recv_rcvbuf_delta()
104 (int)ntohs(rs->rs_bound_port), rs->rs_rcv_bytes, in rdsv3_recv_rcvbuf_delta()
105 rdsv3_sk_rcvbuf(rs), now_congested, delta); in rdsv3_recv_rcvbuf_delta()
108 if (!rs->rs_congested && now_congested) { in rdsv3_recv_rcvbuf_delta()
109 rs->rs_congested = 1; in rdsv3_recv_rcvbuf_delta()
118 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.c107 struct rdsv3_sock *rs = mr->r_sock; in rdsv3_destroy_mr() local
118 mutex_enter(&rs->rs_rdma_lock); in rdsv3_destroy_mr()
121 avl_remove(&rs->rs_rdma_keys, mr); in rdsv3_destroy_mr()
124 mutex_exit(&rs->rs_rdma_lock); in rdsv3_destroy_mr()
142 rdsv3_rdma_drop_keys(struct rdsv3_sock *rs) in rdsv3_rdma_drop_keys() argument
148 mutex_enter(&rs->rs_rdma_lock); in rdsv3_rdma_drop_keys()
149 while ((node = avl_first(&rs->rs_rdma_keys))) { in rdsv3_rdma_drop_keys()
151 if (mr->r_trans == rs->rs_transport) in rdsv3_rdma_drop_keys()
153 avl_remove(&rs->rs_rdma_keys, &mr->r_rb_node); in rdsv3_rdma_drop_keys()
155 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 …]
/titanic_50/usr/src/uts/common/fs/zfs/
H A Drange_tree.c56 range_seg_t *rs; in range_tree_stat_verify() local
60 for (rs = avl_first(&rt->rt_root); rs != NULL; in range_tree_stat_verify()
61 rs = AVL_NEXT(&rt->rt_root, rs)) { in range_tree_stat_verify()
62 uint64_t size = rs->rs_end - rs->rs_start; in range_tree_stat_verify()
79 range_tree_stat_incr(range_tree_t *rt, range_seg_t *rs) in range_tree_stat_incr() argument
81 uint64_t size = rs->rs_end - rs->rs_start; in range_tree_stat_incr()
94 range_tree_stat_decr(range_tree_t *rt, range_seg_t *rs) in range_tree_stat_decr() argument
96 uint64_t size = rs->rs_end - rs->rs_start; in range_tree_stat_decr()
167 range_seg_t rsearch, *rs_before, *rs_after, *rs; in range_tree_add() local
176 rs = avl_find(&rt->rt_root, &rsearch, &where); in range_tree_add()
[all …]
H A Dspace_reftree.c118 range_seg_t *rs; in space_reftree_add_map() local
122 for (rs = avl_first(&rt->rt_root); rs; rs = AVL_NEXT(&rt->rt_root, rs)) in space_reftree_add_map()
123 space_reftree_add_seg(t, rs->rs_start, rs->rs_end, refcnt); in space_reftree_add_map()
/titanic_50/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 …]
/titanic_50/usr/src/uts/common/io/hxge/
H A Dhxge_fzc.c72 hpi_status_t rs = HPI_SUCCESS; in hxge_fzc_intr_ldg_num_set() local
94 rs = hpi_fzc_ldg_num_set(handle, ldvp->ldv, in hxge_fzc_intr_ldg_num_set()
96 if (rs != HPI_SUCCESS) { in hxge_fzc_intr_ldg_num_set()
100 rs, ldvp->ldv, ldvp->ldg_assigned)); in hxge_fzc_intr_ldg_num_set()
101 return (HXGE_ERROR | rs); in hxge_fzc_intr_ldg_num_set()
117 hpi_status_t rs = HPI_SUCCESS; in hxge_fzc_intr_tmres_set() local
125 if ((rs = hpi_fzc_ldg_timer_res_set(handle, hxgep->ldgvp->tmres))) { in hxge_fzc_intr_tmres_set()
126 return (HXGE_ERROR | rs); in hxge_fzc_intr_tmres_set()
140 hpi_status_t rs = HPI_SUCCESS; in hxge_fzc_intr_sid_set() local
159 rs = hpi_fzc_sid_set(handle, sid); in hxge_fzc_intr_sid_set()
[all …]
/titanic_50/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.c42 npi_status_t rs = NPI_SUCCESS; in nxge_ipp_init() local
66 if ((rs = npi_ipp_write_dfifo(handle, in nxge_ipp_init()
69 if ((rs = npi_ipp_read_dfifo(handle, portn, in nxge_ipp_init()
75 if ((rs = npi_ipp_get_status(handle, portn, &istatus)) != NPI_SUCCESS) in nxge_ipp_init()
77 if ((rs = npi_ipp_get_status(handle, portn, &istatus)) != NPI_SUCCESS) in nxge_ipp_init()
84 if ((rs = npi_ipp_reset(handle, portn)) != NPI_SUCCESS) in nxge_ipp_init()
92 if ((rs = npi_ipp_get_status(handle, portn, &istatus)) != NPI_SUCCESS) in nxge_ipp_init()
96 if ((rs = npi_ipp_iconfig(handle, INIT, portn, ICFG_IPP_ALL)) in nxge_ipp_init()
103 if ((rs = npi_ipp_config(handle, INIT, portn, config)) != NPI_SUCCESS) in nxge_ipp_init()
109 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.c43 npi_status_t rs = NPI_SUCCESS; in nxge_txc_init() local
53 if ((rs = npi_txc_global_enable(handle)) != NPI_SUCCESS) { in nxge_txc_init()
58 if ((rs = npi_txc_port_enable(handle, port)) != NPI_SUCCESS) { in nxge_txc_init()
63 if ((rs = npi_txc_port_dma_enable(handle, port, in nxge_txc_init()
79 return (NXGE_ERROR | rs); in nxge_txc_init()
87 npi_status_t rs = NPI_SUCCESS; in nxge_txc_uninit() local
97 if ((rs = npi_txc_global_disable(handle)) != NPI_SUCCESS) { in nxge_txc_uninit()
102 if ((rs = npi_txc_port_disable(handle, port)) != NPI_SUCCESS) { in nxge_txc_uninit()
107 if ((rs = npi_txc_port_dma_enable(handle, port, 0)) != NPI_SUCCESS) { in nxge_txc_uninit()
119 return (NXGE_ERROR | rs); in nxge_txc_uninit()
[all …]
/titanic_50/usr/src/lib/libc/sparc/threads/
H A Dmachdep.c140 getgregs(ulwp_t *ulwp, gregset_t rs) in getgregs() argument
145 rs[REG_PC] = status.pr_reg[R_PC]; in getgregs()
146 rs[REG_O6] = status.pr_reg[R_O6]; in getgregs()
147 rs[REG_O7] = status.pr_reg[R_O7]; in getgregs()
148 rs[REG_G1] = status.pr_reg[R_G1]; in getgregs()
149 rs[REG_G2] = status.pr_reg[R_G2]; in getgregs()
150 rs[REG_G3] = status.pr_reg[R_G3]; in getgregs()
151 rs[REG_G4] = status.pr_reg[R_G4]; in getgregs()
153 rs[REG_PC] = 0; in getgregs()
154 rs[REG_O6] = 0; in getgregs()
[all …]
/titanic_50/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 …]
/titanic_50/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 …]
/titanic_50/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 …]
/titanic_50/usr/src/lib/libpool/common/
H A Dpool.c337 pool_resource_t **rs; in pool_base_info() local
386 if ((rs = pool_query_pool_resources(conf, pool_elem_pool(pe), in pool_base_info()
394 elem = TO_ELEM(rs[i]); in pool_base_info()
398 free(rs); in pool_base_info()
404 free(rs); in pool_base_info()
410 free(rs); in pool_base_info()
414 free(rs); in pool_base_info()
439 if ((rs = pool_query_resources(conf, &nelem, NULL)) != in pool_base_info()
442 elem = TO_ELEM(rs[i]); in pool_base_info()
445 free(rs); in pool_base_info()
[all …]
/titanic_50/usr/src/cmd/cmd-inet/usr.lib/in.chargend/
H A Din.chargend.c72 char *rs = ring; in chargen_stream() local
77 if (rs >= endring) in chargen_stream()
78 rs = ring; in chargen_stream()
79 rp = rs++; in chargen_stream()
110 static char *rs = ring; in chargen_dg() local
112 rp = rs; in chargen_dg()
113 if (rs++ >= endring) in chargen_dg()
114 rs = ring; in chargen_dg()
/titanic_50/usr/src/test/libc-tests/tests/
H A Dtimespec_get.c25 timespec_cmp(const struct timespec *ls, const struct timespec *rs) in timespec_cmp() argument
27 if (ls->tv_sec > rs->tv_sec) in timespec_cmp()
29 if (ls->tv_sec < rs->tv_sec) in timespec_cmp()
31 if (ls->tv_nsec > rs->tv_nsec) in timespec_cmp()
33 if (ls->tv_nsec > rs->tv_nsec) in timespec_cmp()
35 if (ls->tv_nsec < rs->tv_nsec) in timespec_cmp()
/titanic_50/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,
/titanic_50/usr/src/lib/libc/amd64/unwind/
H A Dcall_frame_inst.c142 fix_cfa(struct _Unwind_Context *ctx, struct register_state *rs) in fix_cfa() argument
144 switch (rs[CF_ADDR].rule) { in fix_cfa()
149 ctx->cfa = (ctx->current_regs)[rs[CF_ADDR].source_reg] + in fix_cfa()
150 rs[CF_ADDR].offset; in fix_cfa()
153 ctx->cfa = rs[CF_ADDR].offset; in fix_cfa()
157 (ctx->current_regs[rs[CF_ADDR].source_reg] + in fix_cfa()
158 rs[CF_ADDR].offset); in fix_cfa()
165 fix_ra(struct _Unwind_Context *ctx, struct register_state *rs) in fix_ra() argument
167 switch (rs[RET_ADD].rule) { in fix_ra()
173 ctx->ra = *(uint64_t *)(ctx->cfa + rs[RET_ADD].offset); in fix_ra()
[all …]
/titanic_50/usr/src/lib/libcurses/screen/
H A Dmbinch.c48 static char rs[CSMAX + 1]; in wmbinch() local
64 rs[k++] = (char)wc; in wmbinch()
68 rs[k++] = (char)wc; in wmbinch()
73 rs[k] = '\0'; in wmbinch()
74 return (rs); in wmbinch()

1234567