clients/rdsv3/bind.c

141  * marked this socket and don't return a rs ref to the rx path.
146 	struct rdsv3_sock *rs;
153 	rs = conn->c_bucketp->port[ntohs(port)];
154 	if (rs && !rdsv3_sk_sock_flag(rdsv3_rs_to_sk(rs), SOCK_DEAD))
155 		rdsv3_sk_sock_hold(rdsv3_rs_to_sk(rs));
157 		rs = NULL;
160 	RDSV3_DPRINTF5("rdsv3_find_bound", "returning rs %p for %u.%u.%u.%u:%d",
161 	    rs, NIPQUAD(conn->c_laddr), ntohs(port));
163 	return (rs);
168 rdsv3_add_bound(struct rdsv3_sock *rs, uint32_be_t addr, uint16_be_t *port)
187 	bucketp = rdsv3_find_ip_bucket(ntohl(addr), rs->rs_zoneid);
204 		rs->rs_bound_addr = addr;
205 		rs->rs_bound_port = *port;
206 		bucketp->port[rover] = rs;
208 		rdsv3_sock_addref(rs);
211 		    "rs %p binding to %u.%u.%u.%u:%d",
212 		    rs, NIPQUAD(addr), rover);
225 rdsv3_remove_bound(struct rdsv3_sock *rs)
227 	RDSV3_DPRINTF4("rdsv3_remove_bound", "Enter(rs: %p)", rs);
229 	if (rs->rs_bound_addr) {
233 		    "rs %p unbinding from %u.%u.%u.%u:%x",
234 		    rs, NIPQUAD(htonl(rs->rs_bound_addr)), rs->rs_bound_port);
236 		bucketp = rdsv3_find_ip_bucket(ntohl(rs->rs_bound_addr),
237 		    rs->rs_zoneid);
240 		bucketp->port[ntohs(rs->rs_bound_port)] = NULL;
242 		rs->rs_bound_addr = 0;
245 		rdsv3_sock_put(rs);
248 	RDSV3_DPRINTF4("rdsv3_remove_bound", "Return(rs: %p)", rs);
258 	struct rdsv3_sock	*rs = rdsv3_sk_to_rs(sk);
267 	RDSV3_DPRINTF4("rdsv3_bind", "Enter(rs: %p, addr: 0x%x, port: %x)",
268 	    rs, ntohl(sin->sin_addr.s_addr), htons(sin->sin_port));
276 	if (rs->rs_bound_addr) {
281 	ret = rdsv3_add_bound(rs, sin->sin_addr.s_addr, &sin->sin_port);
286 	rs->rs_transport = rdsv3_trans_get_preferred(sin->sin_addr.s_addr);
287 	if (!rs->rs_transport) {
288 		rdsv3_remove_bound(rs);
297 	    sin->sin_port, rs);