| Andy Grover | 7004108 | 2009-08-21 12:28:31 +0000 | [diff] [blame] | 1 | /* | 
|  | 2 | * Copyright (c) 2006 Oracle.  All rights reserved. | 
|  | 3 | * | 
|  | 4 | * This software is available to you under a choice of one of two | 
|  | 5 | * licenses.  You may choose to be licensed under the terms of the GNU | 
|  | 6 | * General Public License (GPL) Version 2, available from the file | 
|  | 7 | * COPYING in the main directory of this source tree, or the | 
|  | 8 | * OpenIB.org BSD license below: | 
|  | 9 | * | 
|  | 10 | *     Redistribution and use in source and binary forms, with or | 
|  | 11 | *     without modification, are permitted provided that the following | 
|  | 12 | *     conditions are met: | 
|  | 13 | * | 
|  | 14 | *      - Redistributions of source code must retain the above | 
|  | 15 | *        copyright notice, this list of conditions and the following | 
|  | 16 | *        disclaimer. | 
|  | 17 | * | 
|  | 18 | *      - Redistributions in binary form must reproduce the above | 
|  | 19 | *        copyright notice, this list of conditions and the following | 
|  | 20 | *        disclaimer in the documentation and/or other materials | 
|  | 21 | *        provided with the distribution. | 
|  | 22 | * | 
|  | 23 | * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, | 
|  | 24 | * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF | 
|  | 25 | * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND | 
|  | 26 | * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS | 
|  | 27 | * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN | 
|  | 28 | * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN | 
|  | 29 | * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE | 
|  | 30 | * SOFTWARE. | 
|  | 31 | * | 
|  | 32 | */ | 
|  | 33 | #include <linux/kernel.h> | 
|  | 34 | #include <linux/in.h> | 
|  | 35 | #include <net/tcp.h> | 
|  | 36 |  | 
|  | 37 | #include "rds.h" | 
|  | 38 | #include "tcp.h" | 
|  | 39 |  | 
|  | 40 | static void rds_tcp_cork(struct socket *sock, int val) | 
|  | 41 | { | 
|  | 42 | mm_segment_t oldfs; | 
|  | 43 |  | 
|  | 44 | oldfs = get_fs(); | 
|  | 45 | set_fs(KERNEL_DS); | 
|  | 46 | sock->ops->setsockopt(sock, SOL_TCP, TCP_CORK, (char __user *)&val, | 
|  | 47 | sizeof(val)); | 
|  | 48 | set_fs(oldfs); | 
|  | 49 | } | 
|  | 50 |  | 
|  | 51 | void rds_tcp_xmit_prepare(struct rds_connection *conn) | 
|  | 52 | { | 
|  | 53 | struct rds_tcp_connection *tc = conn->c_transport_data; | 
|  | 54 |  | 
|  | 55 | rds_tcp_cork(tc->t_sock, 1); | 
|  | 56 | } | 
|  | 57 |  | 
|  | 58 | void rds_tcp_xmit_complete(struct rds_connection *conn) | 
|  | 59 | { | 
|  | 60 | struct rds_tcp_connection *tc = conn->c_transport_data; | 
|  | 61 |  | 
|  | 62 | rds_tcp_cork(tc->t_sock, 0); | 
|  | 63 | } | 
|  | 64 |  | 
|  | 65 | /* the core send_sem serializes this with other xmit and shutdown */ | 
|  | 66 | int rds_tcp_sendmsg(struct socket *sock, void *data, unsigned int len) | 
|  | 67 | { | 
|  | 68 | struct kvec vec = { | 
|  | 69 | .iov_base = data, | 
|  | 70 | .iov_len = len, | 
|  | 71 | }; | 
|  | 72 | struct msghdr msg = { | 
|  | 73 | .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, | 
|  | 74 | }; | 
|  | 75 |  | 
|  | 76 | return kernel_sendmsg(sock, &msg, &vec, 1, vec.iov_len); | 
|  | 77 | } | 
|  | 78 |  | 
|  | 79 | /* the core send_sem serializes this with other xmit and shutdown */ | 
|  | 80 | int rds_tcp_xmit_cong_map(struct rds_connection *conn, | 
|  | 81 | struct rds_cong_map *map, unsigned long offset) | 
|  | 82 | { | 
|  | 83 | static struct rds_header rds_tcp_map_header = { | 
|  | 84 | .h_flags = RDS_FLAG_CONG_BITMAP, | 
|  | 85 | }; | 
|  | 86 | struct rds_tcp_connection *tc = conn->c_transport_data; | 
|  | 87 | unsigned long i; | 
|  | 88 | int ret; | 
|  | 89 | int copied = 0; | 
|  | 90 |  | 
|  | 91 | /* Some problem claims cpu_to_be32(constant) isn't a constant. */ | 
|  | 92 | rds_tcp_map_header.h_len = cpu_to_be32(RDS_CONG_MAP_BYTES); | 
|  | 93 |  | 
|  | 94 | if (offset < sizeof(struct rds_header)) { | 
|  | 95 | ret = rds_tcp_sendmsg(tc->t_sock, | 
|  | 96 | (void *)&rds_tcp_map_header + offset, | 
|  | 97 | sizeof(struct rds_header) - offset); | 
|  | 98 | if (ret <= 0) | 
|  | 99 | return ret; | 
|  | 100 | offset += ret; | 
|  | 101 | copied = ret; | 
|  | 102 | if (offset < sizeof(struct rds_header)) | 
|  | 103 | return ret; | 
|  | 104 | } | 
|  | 105 |  | 
|  | 106 | offset -= sizeof(struct rds_header); | 
|  | 107 | i = offset / PAGE_SIZE; | 
|  | 108 | offset = offset % PAGE_SIZE; | 
|  | 109 | BUG_ON(i >= RDS_CONG_MAP_PAGES); | 
|  | 110 |  | 
|  | 111 | do { | 
|  | 112 | ret = tc->t_sock->ops->sendpage(tc->t_sock, | 
|  | 113 | virt_to_page(map->m_page_addrs[i]), | 
|  | 114 | offset, PAGE_SIZE - offset, | 
|  | 115 | MSG_DONTWAIT); | 
|  | 116 | if (ret <= 0) | 
|  | 117 | break; | 
|  | 118 | copied += ret; | 
|  | 119 | offset += ret; | 
|  | 120 | if (offset == PAGE_SIZE) { | 
|  | 121 | offset = 0; | 
|  | 122 | i++; | 
|  | 123 | } | 
|  | 124 | } while (i < RDS_CONG_MAP_PAGES); | 
|  | 125 |  | 
|  | 126 | return copied ? copied : ret; | 
|  | 127 | } | 
|  | 128 |  | 
|  | 129 | /* the core send_sem serializes this with other xmit and shutdown */ | 
|  | 130 | int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, | 
|  | 131 | unsigned int hdr_off, unsigned int sg, unsigned int off) | 
|  | 132 | { | 
|  | 133 | struct rds_tcp_connection *tc = conn->c_transport_data; | 
|  | 134 | int done = 0; | 
|  | 135 | int ret = 0; | 
|  | 136 |  | 
|  | 137 | if (hdr_off == 0) { | 
|  | 138 | /* | 
|  | 139 | * m_ack_seq is set to the sequence number of the last byte of | 
|  | 140 | * header and data.  see rds_tcp_is_acked(). | 
|  | 141 | */ | 
|  | 142 | tc->t_last_sent_nxt = rds_tcp_snd_nxt(tc); | 
|  | 143 | rm->m_ack_seq = tc->t_last_sent_nxt + | 
|  | 144 | sizeof(struct rds_header) + | 
|  | 145 | be32_to_cpu(rm->m_inc.i_hdr.h_len) - 1; | 
|  | 146 | smp_mb__before_clear_bit(); | 
|  | 147 | set_bit(RDS_MSG_HAS_ACK_SEQ, &rm->m_flags); | 
|  | 148 | tc->t_last_expected_una = rm->m_ack_seq + 1; | 
|  | 149 |  | 
|  | 150 | rdsdebug("rm %p tcp nxt %u ack_seq %llu\n", | 
|  | 151 | rm, rds_tcp_snd_nxt(tc), | 
|  | 152 | (unsigned long long)rm->m_ack_seq); | 
|  | 153 | } | 
|  | 154 |  | 
|  | 155 | if (hdr_off < sizeof(struct rds_header)) { | 
|  | 156 | /* see rds_tcp_write_space() */ | 
|  | 157 | set_bit(SOCK_NOSPACE, &tc->t_sock->sk->sk_socket->flags); | 
|  | 158 |  | 
|  | 159 | ret = rds_tcp_sendmsg(tc->t_sock, | 
|  | 160 | (void *)&rm->m_inc.i_hdr + hdr_off, | 
|  | 161 | sizeof(rm->m_inc.i_hdr) - hdr_off); | 
|  | 162 | if (ret < 0) | 
|  | 163 | goto out; | 
|  | 164 | done += ret; | 
|  | 165 | if (hdr_off + done != sizeof(struct rds_header)) | 
|  | 166 | goto out; | 
|  | 167 | } | 
|  | 168 |  | 
|  | 169 | while (sg < rm->m_nents) { | 
|  | 170 | ret = tc->t_sock->ops->sendpage(tc->t_sock, | 
|  | 171 | sg_page(&rm->m_sg[sg]), | 
|  | 172 | rm->m_sg[sg].offset + off, | 
|  | 173 | rm->m_sg[sg].length - off, | 
|  | 174 | MSG_DONTWAIT|MSG_NOSIGNAL); | 
|  | 175 | rdsdebug("tcp sendpage %p:%u:%u ret %d\n", (void *)sg_page(&rm->m_sg[sg]), | 
|  | 176 | rm->m_sg[sg].offset + off, rm->m_sg[sg].length - off, | 
|  | 177 | ret); | 
|  | 178 | if (ret <= 0) | 
|  | 179 | break; | 
|  | 180 |  | 
|  | 181 | off += ret; | 
|  | 182 | done += ret; | 
|  | 183 | if (off == rm->m_sg[sg].length) { | 
|  | 184 | off = 0; | 
|  | 185 | sg++; | 
|  | 186 | } | 
|  | 187 | } | 
|  | 188 |  | 
|  | 189 | out: | 
|  | 190 | if (ret <= 0) { | 
|  | 191 | /* write_space will hit after EAGAIN, all else fatal */ | 
|  | 192 | if (ret == -EAGAIN) { | 
|  | 193 | rds_tcp_stats_inc(s_tcp_sndbuf_full); | 
|  | 194 | ret = 0; | 
|  | 195 | } else { | 
|  | 196 | printk(KERN_WARNING "RDS/tcp: send to %u.%u.%u.%u " | 
|  | 197 | "returned %d, disconnecting and reconnecting\n", | 
|  | 198 | NIPQUAD(conn->c_faddr), ret); | 
|  | 199 | rds_conn_drop(conn); | 
|  | 200 | } | 
|  | 201 | } | 
|  | 202 | if (done == 0) | 
|  | 203 | done = ret; | 
|  | 204 | return done; | 
|  | 205 | } | 
|  | 206 |  | 
|  | 207 | /* | 
|  | 208 | * rm->m_ack_seq is set to the tcp sequence number that corresponds to the | 
|  | 209 | * last byte of the message, including the header.  This means that the | 
|  | 210 | * entire message has been received if rm->m_ack_seq is "before" the next | 
|  | 211 | * unacked byte of the TCP sequence space.  We have to do very careful | 
|  | 212 | * wrapping 32bit comparisons here. | 
|  | 213 | */ | 
|  | 214 | static int rds_tcp_is_acked(struct rds_message *rm, uint64_t ack) | 
|  | 215 | { | 
|  | 216 | if (!test_bit(RDS_MSG_HAS_ACK_SEQ, &rm->m_flags)) | 
|  | 217 | return 0; | 
|  | 218 | return (__s32)((u32)rm->m_ack_seq - (u32)ack) < 0; | 
|  | 219 | } | 
|  | 220 |  | 
|  | 221 | void rds_tcp_write_space(struct sock *sk) | 
|  | 222 | { | 
|  | 223 | void (*write_space)(struct sock *sk); | 
|  | 224 | struct rds_connection *conn; | 
|  | 225 | struct rds_tcp_connection *tc; | 
|  | 226 |  | 
|  | 227 | read_lock(&sk->sk_callback_lock); | 
|  | 228 | conn = sk->sk_user_data; | 
|  | 229 | if (conn == NULL) { | 
|  | 230 | write_space = sk->sk_write_space; | 
|  | 231 | goto out; | 
|  | 232 | } | 
|  | 233 |  | 
|  | 234 | tc = conn->c_transport_data; | 
|  | 235 | rdsdebug("write_space for tc %p\n", tc); | 
|  | 236 | write_space = tc->t_orig_write_space; | 
|  | 237 | rds_tcp_stats_inc(s_tcp_write_space_calls); | 
|  | 238 |  | 
|  | 239 | rdsdebug("tcp una %u\n", rds_tcp_snd_una(tc)); | 
|  | 240 | tc->t_last_seen_una = rds_tcp_snd_una(tc); | 
|  | 241 | rds_send_drop_acked(conn, rds_tcp_snd_una(tc), rds_tcp_is_acked); | 
|  | 242 |  | 
|  | 243 | queue_delayed_work(rds_wq, &conn->c_send_w, 0); | 
|  | 244 | out: | 
|  | 245 | read_unlock(&sk->sk_callback_lock); | 
|  | 246 |  | 
|  | 247 | /* | 
|  | 248 | * write_space is only called when data leaves tcp's send queue if | 
|  | 249 | * SOCK_NOSPACE is set.  We set SOCK_NOSPACE every time we put | 
|  | 250 | * data in tcp's send queue because we use write_space to parse the | 
|  | 251 | * sequence numbers and notice that rds messages have been fully | 
|  | 252 | * received. | 
|  | 253 | * | 
|  | 254 | * tcp's write_space clears SOCK_NOSPACE if the send queue has more | 
|  | 255 | * than a certain amount of space. So we need to set it again *after* | 
|  | 256 | * we call tcp's write_space or else we might only get called on the | 
|  | 257 | * first of a series of incoming tcp acks. | 
|  | 258 | */ | 
|  | 259 | write_space(sk); | 
|  | 260 |  | 
|  | 261 | if (sk->sk_socket) | 
|  | 262 | set_bit(SOCK_NOSPACE, &sk->sk_socket->flags); | 
|  | 263 | } |