Searched defs:rs (Results 1 - 11 of 11) sorted by relevance

/net/rds/
H A Dbind.c54 struct rds_sock *rs; local
60 hlist_for_each_entry_rcu(rs, head, rs_bound_node) {
61 cmp = ((u64)be32_to_cpu(rs->rs_bound_addr) << 32) |
62 be16_to_cpu(rs->rs_bound_port);
66 return rs;
91 * marked this socket and don't return a rs ref to the rx path.
95 struct rds_sock *rs; local
97 rs = rds_bind_lookup(addr, port, NULL);
99 if (rs && !sock_flag(rds_rs_to_sk(rs), SOCK_DEA
110 rds_add_bound(struct rds_sock *rs, __be32 addr, __be16 *port) argument
143 rds_remove_bound(struct rds_sock *rs) argument
166 struct rds_sock *rs = rds_sk_to_rs(sk); local
[all...]
H A Dcong.c244 struct rds_sock *rs; local
247 list_for_each_entry(rs, &rds_cong_monitor, rs_cong_list) {
248 spin_lock(&rs->rs_lock);
249 rs->rs_cong_notify |= (rs->rs_cong_mask & portmask);
250 rs->rs_cong_mask &= ~portmask;
251 spin_unlock(&rs->rs_lock);
252 if (rs->rs_cong_notify)
253 rds_wake_sk_sleep(rs);
316 void rds_cong_add_socket(struct rds_sock *rs) argument
326 rds_cong_remove_socket(struct rds_sock *rs) argument
346 rds_cong_wait(struct rds_cong_map *map, __be16 port, int nonblock, struct rds_sock *rs) argument
[all...]
H A Daf_rds.c70 struct rds_sock *rs; local
75 rs = rds_sk_to_rs(sk);
81 rds_clear_recv_queue(rs);
82 rds_cong_remove_socket(rs);
89 rds_remove_bound(rs);
92 rds_send_drop_to(rs, NULL);
93 rds_rdma_drop_keys(rs);
94 rds_notify_queue_get(rs, NULL);
97 list_del_init(&rs->rs_item);
101 rds_trans_put(rs
118 rds_wake_sk_sleep(struct rds_sock *rs) argument
131 struct rds_sock *rs = rds_sk_to_rs(sock->sk); local
174 struct rds_sock *rs = rds_sk_to_rs(sk); local
215 rds_cancel_sent_to(struct rds_sock *rs, char __user *optval, int len) argument
255 rds_cong_monitor(struct rds_sock *rs, char __user *optval, int optlen) argument
276 struct rds_sock *rs = rds_sk_to_rs(sock->sk); local
313 struct rds_sock *rs = rds_sk_to_rs(sock->sk); local
354 struct rds_sock *rs = rds_sk_to_rs(sk); local
411 struct rds_sock *rs; local
450 rds_sock_addref(struct rds_sock *rs) argument
455 rds_sock_put(struct rds_sock *rs) argument
470 struct rds_sock *rs; local
503 struct rds_sock *rs; local
[all...]
H A Drecv.c69 static void rds_recv_rcvbuf_delta(struct rds_sock *rs, struct sock *sk, argument
78 rs->rs_rcv_bytes += delta;
79 now_congested = rs->rs_rcv_bytes > rds_sk_rcvbuf(rs);
81 rdsdebug("rs %p (%pI4:%u) recv bytes %d buf %d "
83 rs, &rs->rs_bound_addr,
84 ntohs(rs->rs_bound_port), rs->rs_rcv_bytes,
85 rds_sk_rcvbuf(rs), now_congeste
108 rds_recv_incoming_exthdrs(struct rds_incoming *inc, struct rds_sock *rs) argument
160 struct rds_sock *rs = NULL; local
249 rds_next_incoming(struct rds_sock *rs, struct rds_incoming **inc) argument
267 rds_still_queued(struct rds_sock *rs, struct rds_incoming *inc, int drop) argument
296 rds_notify_queue_get(struct rds_sock *rs, struct msghdr *msghdr) argument
363 rds_notify_cong(struct rds_sock *rs, struct msghdr *msghdr) argument
402 struct rds_sock *rs = rds_sk_to_rs(sk); local
504 rds_clear_recv_queue(struct rds_sock *rs) argument
[all...]
H A Dsend.c395 static void rds_send_sndbuf_remove(struct rds_sock *rs, struct rds_message *rm) argument
399 assert_spin_locked(&rs->rs_lock);
401 BUG_ON(rs->rs_snd_bytes < len);
402 rs->rs_snd_bytes -= len;
404 if (rs->rs_snd_bytes == 0)
424 struct rds_sock *rs = NULL; local
435 rs = rm->m_rs;
436 sock_hold(rds_rs_to_sk(rs));
439 spin_lock(&rs->rs_lock);
440 list_add_tail(&notifier->n_list, &rs
460 struct rds_sock *rs = NULL; local
497 __rds_send_complete(struct rds_sock *rs, struct rds_message *rm, int status) argument
566 struct rds_sock *rs = NULL; local
673 rds_send_drop_to(struct rds_sock *rs, struct sockaddr_in *dest) argument
754 rds_send_queue_rm(struct rds_sock *rs, struct rds_connection *conn, struct rds_message *rm, __be16 sport, __be16 dport, int *queued) argument
875 rds_cmsg_send(struct rds_sock *rs, struct rds_message *rm, struct msghdr *msg, int *allocated_mr) argument
927 struct rds_sock *rs = rds_sk_to_rs(sk); local
[all...]
H A Drdma.c98 struct rds_sock *rs = mr->r_sock; local
108 spin_lock_irqsave(&rs->rs_rdma_lock, flags);
110 rb_erase(&mr->r_rb_node, &rs->rs_rdma_keys);
113 spin_unlock_irqrestore(&rs->rs_rdma_lock, flags);
129 void rds_rdma_drop_keys(struct rds_sock *rs) argument
136 spin_lock_irqsave(&rs->rs_rdma_lock, flags);
137 while ((node = rb_first(&rs->rs_rdma_keys))) {
139 if (mr->r_trans == rs->rs_transport)
141 rb_erase(&mr->r_rb_node, &rs->rs_rdma_keys);
143 spin_unlock_irqrestore(&rs
173 __rds_rdma_map(struct rds_sock *rs, struct rds_get_mr_args *args, u64 *cookie_ret, struct rds_mr **mr_ret) argument
315 rds_get_mr(struct rds_sock *rs, char __user *optval, int optlen) argument
329 rds_get_mr_for_dest(struct rds_sock *rs, char __user *optval, int optlen) argument
356 rds_free_mr(struct rds_sock *rs, char __user *optval, int optlen) argument
409 rds_rdma_unuse(struct rds_sock *rs, u32 r_key, int force) argument
546 rds_cmsg_rdma_args(struct rds_sock *rs, struct rds_message *rm, struct cmsghdr *cmsg) argument
712 rds_cmsg_rdma_dest(struct rds_sock *rs, struct rds_message *rm, struct cmsghdr *cmsg) argument
754 rds_cmsg_rdma_map(struct rds_sock *rs, struct rds_message *rm, struct cmsghdr *cmsg) argument
767 rds_cmsg_atomic(struct rds_sock *rs, struct rds_message *rm, struct cmsghdr *cmsg) argument
[all...]
H A Dib_rdma.c744 struct rds_sock *rs, u32 *key_ret)
750 rds_ibdev = rds_ib_get_device(rs->rs_bound_addr);
743 rds_ib_get_mr(struct scatterlist *sg, unsigned long nents, struct rds_sock *rs, u32 *key_ret) argument
H A Diw_rdma.c91 static int rds_iw_get_device(struct rds_sock *rs, struct rds_iw_device **rds_iwdev, struct rdma_cm_id **cm_id) argument
115 rs->rs_bound_addr,
116 rs->rs_bound_port,
117 rs->rs_conn_addr,
118 rs->rs_conn_port);
120 if (src_addr->sin_addr.s_addr == rs->rs_bound_addr &&
121 src_addr->sin_port == rs->rs_bound_port &&
122 dst_addr->sin_addr.s_addr == rs->rs_conn_addr &&
123 dst_addr->sin_port == rs->rs_conn_port) {
131 if (src_addr->sin_addr.s_addr == rs
183 struct rds_sock rs; local
595 rds_iw_get_mr(struct scatterlist *sg, unsigned long nents, struct rds_sock *rs, u32 *key_ret) argument
[all...]
H A Drds.h300 * -> rs->rs_lock
448 struct rds_sock *rs, u32 *key_ret);
522 static inline struct sock *rds_rs_to_sk(struct rds_sock *rs) argument
524 return &rs->rs_sk;
532 static inline int rds_sk_sndbuf(struct rds_sock *rs) argument
534 return rds_rs_to_sk(rs)->sk_sndbuf / 2;
536 static inline int rds_sk_rcvbuf(struct rds_sock *rs) argument
538 return rds_rs_to_sk(rs)->sk_rcvbuf / 2;
579 void rds_sock_addref(struct rds_sock *rs);
580 void rds_sock_put(struct rds_sock *rs);
[all...]
/net/decnet/
H A Ddn_neigh.c485 unsigned char *rs; member in struct:elist_cb_state
502 s->rs = dn_find_slot(s->ptr, s->n, dn->priority);
505 if (s->rs == NULL)
508 dn_dn2eth(s->rs, dn->addr);
509 s->rs += 6;
510 *(s->rs) = neigh->nud_state & NUD_CONNECTED ? 0x80 : 0x0;
511 *(s->rs) |= dn->priority;
512 s->rs++;
523 state.rs = ptr;
/net/xfrm/
H A Dxfrm_user.c121 struct xfrm_replay_state_esn *rs; local
127 rs = nla_data(rt);
129 if (rs->bmp_len > XFRMA_REPLAY_ESN_MAX / sizeof(rs->bmp[0]) / 8)
132 if (nla_len(rt) < xfrm_replay_state_esn_len(rs) &&
133 nla_len(rt) != sizeof(*rs))

Completed in 394 milliseconds