/net/rds/ |
H A D | loop.c | 60 static int rds_loop_xmit(struct rds_connection *conn, struct rds_message *rm, argument 64 struct scatterlist *sgp = &rm->data.op_sg[sg]; 66 be32_to_cpu(rm->m_inc.i_hdr.h_len); 69 if (rm->m_inc.i_hdr.h_flags & RDS_FLAG_CONG_BITMAP) { 77 rds_inc_init(&rm->m_inc, conn, conn->c_laddr); 79 rds_message_addref(rm); 81 rds_recv_incoming(conn, conn->c_laddr, conn->c_faddr, &rm->m_inc, 84 rds_send_drop_acked(conn, be64_to_cpu(rm->m_inc.i_hdr.h_sequence), 87 rds_inc_put(&rm->m_inc); 93 * See rds_loop_xmit(). Since our inc is embedded in the rm, w 98 struct rds_message *rm = container_of(inc, struct rds_message, m_inc); local [all...] |
H A D | tcp_send.c | 80 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, argument 93 rm->m_ack_seq = tc->t_last_sent_nxt + 95 be32_to_cpu(rm->m_inc.i_hdr.h_len) - 1; 97 set_bit(RDS_MSG_HAS_ACK_SEQ, &rm->m_flags); 98 tc->t_last_expected_una = rm->m_ack_seq + 1; 100 rdsdebug("rm %p tcp nxt %u ack_seq %llu\n", 101 rm, rds_tcp_snd_nxt(tc), 102 (unsigned long long)rm->m_ack_seq); 110 (void *)&rm->m_inc.i_hdr + hdr_off, 111 sizeof(rm 164 rds_tcp_is_acked(struct rds_message *rm, uint64_t ack) argument [all...] |
H A D | cong.c | 399 struct rds_message *rm; local 401 rm = rds_message_map_pages(map->m_page_addrs, RDS_CONG_MAP_BYTES); 402 if (!IS_ERR(rm)) 403 rm->m_inc.i_hdr.h_flags = RDS_FLAG_CONG_BITMAP; 405 return rm;
|
H A D | connection.c | 328 struct rds_message *rm, *rtmp; local 350 list_for_each_entry_safe(rm, rtmp, 353 list_del_init(&rm->m_conn_item); 354 BUG_ON(!list_empty(&rm->m_sock_item)); 355 rds_message_put(rm); 386 struct rds_message *rm; local 406 list_for_each_entry(rm, list, m_conn_item) { 409 rds_inc_info_copy(&rm->m_inc, iter,
|
H A D | ib_cm.c | 710 struct rds_message *rm; local 712 rm = container_of(ic->i_data_op, struct rds_message, data); 713 rds_message_put(rm);
|
H A D | message.c | 47 void rds_message_addref(struct rds_message *rm) argument 49 rdsdebug("addref rm %p ref %d\n", rm, atomic_read(&rm->m_refcount)); 50 atomic_inc(&rm->m_refcount); 57 static void rds_message_purge(struct rds_message *rm) argument 61 if (unlikely(test_bit(RDS_MSG_PAGEVEC, &rm->m_flags))) 64 for (i = 0; i < rm->data.op_nents; i++) { 65 rdsdebug("putting data page %p\n", (void *)sg_page(&rm->data.op_sg[i])); 67 __free_page(sg_page(&rm 82 rds_message_put(struct rds_message *rm) argument 195 struct rds_message *rm; local 220 rds_message_alloc_sgs(struct rds_message *rm, int nents) argument 240 struct rds_message *rm; local 267 rds_message_copy_from_user(struct rds_message *rm, struct iovec *first_iov, size_t total_len) argument 331 struct rds_message *rm; local 390 rds_message_wait(struct rds_message *rm) argument 396 rds_message_unmapped(struct rds_message *rm) argument [all...] |
H A D | send.c | 66 struct rds_message *rm, *tmp; local 70 rm = conn->c_xmit_rm; 76 rds_message_unmapped(rm); 77 rds_message_put(rm); 94 list_for_each_entry_safe(rm, tmp, &conn->c_retrans, m_conn_item) { 95 set_bit(RDS_MSG_ACK_REQUIRED, &rm->m_flags); 96 set_bit(RDS_MSG_RETRANSMITTED, &rm->m_flags); 137 struct rds_message *rm; local 178 rm = conn->c_xmit_rm; 184 if (!rm 395 rds_send_sndbuf_remove(struct rds_sock *rs, struct rds_message *rm) argument 408 rds_send_is_acked(struct rds_message *rm, u64 ack, is_acked_func is_acked) argument 422 rds_rdma_send_complete(struct rds_message *rm, int status) argument 458 rds_atomic_send_complete(struct rds_message *rm, int status) argument 497 __rds_send_complete(struct rds_sock *rs, struct rds_message *rm, int status) argument 527 struct rds_message *rm, *tmp, *found = NULL; local 567 struct rds_message *rm; local 648 struct rds_message *rm, *tmp; local 675 struct rds_message *rm, *tmp; local 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 931 struct rds_message *rm = NULL; local 1094 struct rds_message *rm; local [all...] |
H A D | ib_send.c | 80 static void rds_ib_send_complete(struct rds_message *rm, argument 82 void (*complete)(struct rds_message *rm, int status)) 102 complete(rm, notify_status); 178 * Returns the rm for no good reason other than it is unobtainable 186 struct rds_message *rm = NULL; local 192 rm = container_of(send->s_op, struct rds_message, data); 199 rm = container_of(send->s_op, struct rds_message, rdma); 206 rm = container_of(send->s_op, struct rds_message, atomic); 219 return rm; 278 struct rds_message *rm local 525 rds_ib_xmit(struct rds_connection *conn, struct rds_message *rm, unsigned int hdr_off, unsigned int sg, unsigned int off) argument [all...] |
H A D | iw_send.c | 42 static void rds_iw_send_rdma_complete(struct rds_message *rm, argument 63 rds_rdma_send_complete(rm, notify_status); 81 struct rds_message *rm = send->s_rm; local 83 rdsdebug("ic %p send %p rm %p\n", ic, send, rm); 86 rm->data.op_sg, rm->data.op_nents, 89 if (rm->rdma.op_active) { 90 rds_iw_send_unmap_rdma(ic, &rm->rdma); 112 rds_iw_send_rdma_complete(rm, wc_statu 278 struct rds_message *rm; local 496 rds_iw_xmit(struct rds_connection *conn, struct rds_message *rm, unsigned int hdr_off, unsigned int sg, unsigned int off) argument [all...] |
H A D | rdma.c | 546 int rds_cmsg_rdma_args(struct rds_sock *rs, struct rds_message *rm, argument 550 struct rm_rdma_op *op = &rm->rdma; 560 || rm->rdma.op_active) 609 op->op_sg = rds_message_alloc_sgs(rm, nr_pages); 712 int rds_cmsg_rdma_dest(struct rds_sock *rs, struct rds_message *rm, argument 721 rm->m_rdma_cookie != 0) 724 memcpy(&rm->m_rdma_cookie, CMSG_DATA(cmsg), sizeof(rm->m_rdma_cookie)); 731 r_key = rds_rdma_cookie_key(rm->m_rdma_cookie); 743 rm 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...] |
/net/wireless/ |
H A D | core.h | 210 } rm; member in union:cfg80211_event::__anon176
|
/net/ipv4/ |
H A D | ipconfig.c | 412 struct rtentry rm; local 415 memset(&rm, 0, sizeof(rm)); 420 set_sockaddr((struct sockaddr_in *) &rm.rt_dst, 0, 0); 421 set_sockaddr((struct sockaddr_in *) &rm.rt_genmask, 0, 0); 422 set_sockaddr((struct sockaddr_in *) &rm.rt_gateway, ic_gateway, 0); 423 rm.rt_flags = RTF_UP | RTF_GATEWAY; 424 if ((err = ic_route_ioctl(SIOCADDRT, &rm)) < 0) {
|