Searched defs:rm (Results 1 - 12 of 12) sorted by relevance

/net/rds/
H A Dloop.c60 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 Dtcp_send.c80 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 Dcong.c399 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 Dconnection.c328 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 Dib_cm.c710 struct rds_message *rm; local
712 rm = container_of(ic->i_data_op, struct rds_message, data);
713 rds_message_put(rm);
H A Dmessage.c47 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 Dsend.c66 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 Dib_send.c80 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 Diw_send.c42 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 Drdma.c546 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 Dcore.h210 } rm; member in union:cfg80211_event::__anon176
/net/ipv4/
H A Dipconfig.c412 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) {

Completed in 147 milliseconds