aboutsummaryrefslogtreecommitdiffstats
path: root/net/rds/send.c
diff options
context:
space:
mode:
authorAndy Grover <andy.grover@oracle.com>2010-03-22 18:22:04 -0400
committerAndy Grover <andy.grover@oracle.com>2010-09-08 21:12:10 -0400
commit77dd550e5547846604ff6f90c4dc6bba4414e485 (patch)
treeea37afea7f0d857e01f214f703018426f6d8b920 /net/rds/send.c
parente32b4a70495aac6a612e13f4c21db09dd756ff2c (diff)
RDS: Stop supporting old cong map sending method
We now ask the transport to give us a rm for the congestion map, and then we handle it normally. Previously, the transport defined a function that we would call to send a congestion map. Convert TCP and loop transports to new cong map method. Signed-off-by: Andy Grover <andy.grover@oracle.com>
Diffstat (limited to 'net/rds/send.c')
-rw-r--r--net/rds/send.c39
1 files changed, 7 insertions, 32 deletions
diff --git a/net/rds/send.c b/net/rds/send.c
index d1f364e44e36..8a0647af5d95 100644
--- a/net/rds/send.c
+++ b/net/rds/send.c
@@ -147,41 +147,16 @@ int rds_send_xmit(struct rds_connection *conn)
147 /* 147 /*
148 * If between sending messages, we can send a pending congestion 148 * If between sending messages, we can send a pending congestion
149 * map update. 149 * map update.
150 *
151 * Transports either define a special xmit_cong_map function,
152 * or we allocate a cong_map message and treat it just like any
153 * other send.
154 */ 150 */
155 if (!rm && test_and_clear_bit(0, &conn->c_map_queued)) { 151 if (!rm && test_and_clear_bit(0, &conn->c_map_queued)) {
156 if (conn->c_trans->xmit_cong_map) { 152 rm = rds_cong_update_alloc(conn);
157 unsigned long map_offset = 0; 153 if (IS_ERR(rm)) {
158 unsigned long map_bytes = sizeof(struct rds_header) + 154 ret = PTR_ERR(rm);
159 RDS_CONG_MAP_BYTES; 155 break;
160
161 while (map_bytes) {
162 ret = conn->c_trans->xmit_cong_map(conn, conn->c_lcong,
163 map_offset);
164 if (ret <= 0) {
165 /* too far down the rabbithole! */
166 mutex_unlock(&conn->c_send_lock);
167 rds_conn_error(conn, "Cong map xmit failed\n");
168 goto out;
169 }
170
171 map_offset += ret;
172 map_bytes -= ret;
173 }
174 } else {
175 /* send cong update like a normal rm */
176 rm = rds_cong_update_alloc(conn);
177 if (IS_ERR(rm)) {
178 ret = PTR_ERR(rm);
179 break;
180 }
181 rm->data.op_active = 1;
182
183 conn->c_xmit_rm = rm;
184 } 156 }
157 rm->data.op_active = 1;
158
159 conn->c_xmit_rm = rm;
185 } 160 }
186 161
187 /* 162 /*