diff options
author | Andy Grover <andy.grover@oracle.com> | 2010-01-12 15:15:02 -0500 |
---|---|---|
committer | Andy Grover <andy.grover@oracle.com> | 2010-09-08 21:11:33 -0400 |
commit | e779137aa76d38d5c33a98ed887092ae4e4f016f (patch) | |
tree | af0a34f9334bd11ca507d4e63a963c561ff981ae /net/rds/tcp_send.c | |
parent | 8690bfa17aea4c42da1bcf90a7af93d161eca624 (diff) |
RDS: break out rdma and data ops into nested structs in rds_message
Clearly separate rdma-related variables in rm from data-related ones.
This is in anticipation of adding atomic support.
Signed-off-by: Andy Grover <andy.grover@oracle.com>
Diffstat (limited to 'net/rds/tcp_send.c')
-rw-r--r-- | net/rds/tcp_send.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/net/rds/tcp_send.c b/net/rds/tcp_send.c index e5f6ccef79ef..d63aa35ac673 100644 --- a/net/rds/tcp_send.c +++ b/net/rds/tcp_send.c | |||
@@ -166,21 +166,21 @@ int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, | |||
166 | goto out; | 166 | goto out; |
167 | } | 167 | } |
168 | 168 | ||
169 | while (sg < rm->m_nents) { | 169 | while (sg < rm->data.m_nents) { |
170 | ret = tc->t_sock->ops->sendpage(tc->t_sock, | 170 | ret = tc->t_sock->ops->sendpage(tc->t_sock, |
171 | sg_page(&rm->m_sg[sg]), | 171 | sg_page(&rm->data.m_sg[sg]), |
172 | rm->m_sg[sg].offset + off, | 172 | rm->data.m_sg[sg].offset + off, |
173 | rm->m_sg[sg].length - off, | 173 | rm->data.m_sg[sg].length - off, |
174 | MSG_DONTWAIT|MSG_NOSIGNAL); | 174 | MSG_DONTWAIT|MSG_NOSIGNAL); |
175 | rdsdebug("tcp sendpage %p:%u:%u ret %d\n", (void *)sg_page(&rm->m_sg[sg]), | 175 | rdsdebug("tcp sendpage %p:%u:%u ret %d\n", (void *)sg_page(&rm->data.m_sg[sg]), |
176 | rm->m_sg[sg].offset + off, rm->m_sg[sg].length - off, | 176 | rm->data.m_sg[sg].offset + off, rm->data.m_sg[sg].length - off, |
177 | ret); | 177 | ret); |
178 | if (ret <= 0) | 178 | if (ret <= 0) |
179 | break; | 179 | break; |
180 | 180 | ||
181 | off += ret; | 181 | off += ret; |
182 | done += ret; | 182 | done += ret; |
183 | if (off == rm->m_sg[sg].length) { | 183 | if (off == rm->data.m_sg[sg].length) { |
184 | off = 0; | 184 | off = 0; |
185 | sg++; | 185 | sg++; |
186 | } | 186 | } |