/net/rds/ |
H A D | bind.c | 54 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 D | cong.c | 244 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 D | af_rds.c | 70 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 D | recv.c | 69 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 D | send.c | 395 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(¬ifier->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 D | rdma.c | 98 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 D | ib_rdma.c | 744 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 D | iw_rdma.c | 91 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 D | rds.h | 300 * -> 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 D | dn_neigh.c | 485 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 D | xfrm_user.c | 121 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))
|