Blame view
net/rds/rdma_transport.c
6.58 KB
55b7ed0b5 RDS: Common RDMA ... |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 |
/* * Copyright (c) 2009 Oracle. All rights reserved. * * This software is available to you under a choice of one of two * licenses. You may choose to be licensed under the terms of the GNU * General Public License (GPL) Version 2, available from the file * COPYING in the main directory of this source tree, or the * OpenIB.org BSD license below: * * Redistribution and use in source and binary forms, with or * without modification, are permitted provided that the following * conditions are met: * * - Redistributions of source code must retain the above * copyright notice, this list of conditions and the following * disclaimer. * * - Redistributions in binary form must reproduce the above * copyright notice, this list of conditions and the following * disclaimer in the documentation and/or other materials * provided with the distribution. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE * SOFTWARE. * */ |
3a9a231d9 net: Fix files ex... |
33 |
#include <linux/module.h> |
55b7ed0b5 RDS: Common RDMA ... |
34 35 36 |
#include <rdma/rdma_cm.h> #include "rdma_transport.h" |
11bc9421d RDS: Correct some... |
37 |
static struct rdma_cm_id *rds_rdma_listen_id; |
55b7ed0b5 RDS: Common RDMA ... |
38 |
|
59f740a6a RDS/IB: print str... |
39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
static char *rds_cm_event_strings[] = { #define RDS_CM_EVENT_STRING(foo) \ [RDMA_CM_EVENT_##foo] = __stringify(RDMA_CM_EVENT_##foo) RDS_CM_EVENT_STRING(ADDR_RESOLVED), RDS_CM_EVENT_STRING(ADDR_ERROR), RDS_CM_EVENT_STRING(ROUTE_RESOLVED), RDS_CM_EVENT_STRING(ROUTE_ERROR), RDS_CM_EVENT_STRING(CONNECT_REQUEST), RDS_CM_EVENT_STRING(CONNECT_RESPONSE), RDS_CM_EVENT_STRING(CONNECT_ERROR), RDS_CM_EVENT_STRING(UNREACHABLE), RDS_CM_EVENT_STRING(REJECTED), RDS_CM_EVENT_STRING(ESTABLISHED), RDS_CM_EVENT_STRING(DISCONNECTED), RDS_CM_EVENT_STRING(DEVICE_REMOVAL), RDS_CM_EVENT_STRING(MULTICAST_JOIN), RDS_CM_EVENT_STRING(MULTICAST_ERROR), RDS_CM_EVENT_STRING(ADDR_CHANGE), RDS_CM_EVENT_STRING(TIMEWAIT_EXIT), #undef RDS_CM_EVENT_STRING }; static char *rds_cm_event_str(enum rdma_cm_event_type type) { return rds_str_array(rds_cm_event_strings, ARRAY_SIZE(rds_cm_event_strings), type); }; |
55b7ed0b5 RDS: Common RDMA ... |
66 67 68 69 70 71 72 |
int rds_rdma_cm_event_handler(struct rdma_cm_id *cm_id, struct rdma_cm_event *event) { /* this can be null in the listening path */ struct rds_connection *conn = cm_id->context; struct rds_transport *trans; int ret = 0; |
59f740a6a RDS/IB: print str... |
73 74 75 |
rdsdebug("conn %p id %p handling event %u (%s) ", conn, cm_id, event->event, rds_cm_event_str(event->event)); |
55b7ed0b5 RDS: Common RDMA ... |
76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 |
if (cm_id->device->node_type == RDMA_NODE_RNIC) trans = &rds_iw_transport; else trans = &rds_ib_transport; /* Prevent shutdown from tearing down the connection * while we're executing. */ if (conn) { mutex_lock(&conn->c_cm_lock); /* If the connection is being shut down, bail out * right away. We return 0 so cm_id doesn't get * destroyed prematurely */ if (rds_conn_state(conn) == RDS_CONN_DISCONNECTING) { /* Reject incoming connections while we're tearing * down an existing one. */ if (event->event == RDMA_CM_EVENT_CONNECT_REQUEST) ret = 1; goto out; } } switch (event->event) { case RDMA_CM_EVENT_CONNECT_REQUEST: ret = trans->cm_handle_connect(cm_id, event); break; case RDMA_CM_EVENT_ADDR_RESOLVED: /* XXX do we need to clean up if this fails? */ ret = rdma_resolve_route(cm_id, RDS_RDMA_RESOLVE_TIMEOUT_MS); break; case RDMA_CM_EVENT_ROUTE_RESOLVED: /* XXX worry about racing with listen acceptance */ ret = trans->cm_initiate_connect(cm_id); break; case RDMA_CM_EVENT_ESTABLISHED: trans->cm_connect_complete(conn, event); break; case RDMA_CM_EVENT_ADDR_ERROR: case RDMA_CM_EVENT_ROUTE_ERROR: case RDMA_CM_EVENT_CONNECT_ERROR: case RDMA_CM_EVENT_UNREACHABLE: case RDMA_CM_EVENT_REJECTED: case RDMA_CM_EVENT_DEVICE_REMOVAL: case RDMA_CM_EVENT_ADDR_CHANGE: if (conn) rds_conn_drop(conn); break; case RDMA_CM_EVENT_DISCONNECTED: |
97069788d RDS: Turn down al... |
131 |
rdsdebug("DISCONNECT event - dropping connection " |
55b7ed0b5 RDS: Common RDMA ... |
132 133 134 135 136 137 138 139 |
"%pI4->%pI4 ", &conn->c_laddr, &conn->c_faddr); rds_conn_drop(conn); break; default: /* things like device disconnect? */ |
59f740a6a RDS/IB: print str... |
140 141 142 |
printk(KERN_ERR "RDS: unknown event %u (%s)! ", event->event, rds_cm_event_str(event->event)); |
55b7ed0b5 RDS: Common RDMA ... |
143 144 145 146 147 148 |
break; } out: if (conn) mutex_unlock(&conn->c_cm_lock); |
59f740a6a RDS/IB: print str... |
149 150 151 |
rdsdebug("id %p event %u (%s) handling ret %d ", cm_id, event->event, rds_cm_event_str(event->event), ret); |
55b7ed0b5 RDS: Common RDMA ... |
152 153 154 |
return ret; } |
ef87b7ea3 RDS: remove __ini... |
155 |
static int rds_rdma_listen_init(void) |
55b7ed0b5 RDS: Common RDMA ... |
156 157 158 159 |
{ struct sockaddr_in sin; struct rdma_cm_id *cm_id; int ret; |
b26f9b994 RDMA/cma: Pass QP... |
160 161 |
cm_id = rdma_create_id(rds_rdma_cm_event_handler, NULL, RDMA_PS_TCP, IB_QPT_RC); |
55b7ed0b5 RDS: Common RDMA ... |
162 163 |
if (IS_ERR(cm_id)) { ret = PTR_ERR(cm_id); |
92c330b9e RDS/RDMA: Fix cut... |
164 |
printk(KERN_ERR "RDS/RDMA: failed to setup listener, " |
55b7ed0b5 RDS: Common RDMA ... |
165 166 |
"rdma_create_id() returned %d ", ret); |
24acc6895 rdma: potential E... |
167 |
return ret; |
55b7ed0b5 RDS: Common RDMA ... |
168 |
} |
3d7ddd540 net/rds: Use AF_I... |
169 |
sin.sin_family = AF_INET, |
55b7ed0b5 RDS: Common RDMA ... |
170 171 172 173 174 175 176 177 178 |
sin.sin_addr.s_addr = (__force u32)htonl(INADDR_ANY); sin.sin_port = (__force u16)htons(RDS_PORT); /* * XXX I bet this binds the cm_id to a device. If we want to support * fail-over we'll have to take this into consideration. */ ret = rdma_bind_addr(cm_id, (struct sockaddr *)&sin); if (ret) { |
92c330b9e RDS/RDMA: Fix cut... |
179 |
printk(KERN_ERR "RDS/RDMA: failed to setup listener, " |
55b7ed0b5 RDS: Common RDMA ... |
180 181 182 183 184 185 186 |
"rdma_bind_addr() returned %d ", ret); goto out; } ret = rdma_listen(cm_id, 128); if (ret) { |
92c330b9e RDS/RDMA: Fix cut... |
187 |
printk(KERN_ERR "RDS/RDMA: failed to setup listener, " |
55b7ed0b5 RDS: Common RDMA ... |
188 189 190 191 192 193 194 |
"rdma_listen() returned %d ", ret); goto out; } rdsdebug("cm %p listening on port %u ", cm_id, RDS_PORT); |
11bc9421d RDS: Correct some... |
195 |
rds_rdma_listen_id = cm_id; |
55b7ed0b5 RDS: Common RDMA ... |
196 197 198 199 200 201 202 203 204 |
cm_id = NULL; out: if (cm_id) rdma_destroy_id(cm_id); return ret; } static void rds_rdma_listen_stop(void) { |
11bc9421d RDS: Correct some... |
205 206 207 208 209 |
if (rds_rdma_listen_id) { rdsdebug("cm %p ", rds_rdma_listen_id); rdma_destroy_id(rds_rdma_listen_id); rds_rdma_listen_id = NULL; |
55b7ed0b5 RDS: Common RDMA ... |
210 211 |
} } |
ff51bf841 rds: make local f... |
212 |
static int rds_rdma_init(void) |
55b7ed0b5 RDS: Common RDMA ... |
213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 |
{ int ret; ret = rds_rdma_listen_init(); if (ret) goto out; ret = rds_iw_init(); if (ret) goto err_iw_init; ret = rds_ib_init(); if (ret) goto err_ib_init; goto out; err_ib_init: rds_iw_exit(); err_iw_init: rds_rdma_listen_stop(); out: return ret; } |
40d866095 RDS: Modularize R... |
237 |
module_init(rds_rdma_init); |
55b7ed0b5 RDS: Common RDMA ... |
238 |
|
ff51bf841 rds: make local f... |
239 |
static void rds_rdma_exit(void) |
55b7ed0b5 RDS: Common RDMA ... |
240 241 242 243 244 245 |
{ /* stop listening first to ensure no new connections are attempted */ rds_rdma_listen_stop(); rds_ib_exit(); rds_iw_exit(); } |
40d866095 RDS: Modularize R... |
246 247 248 249 250 |
module_exit(rds_rdma_exit); MODULE_AUTHOR("Oracle Corporation <rds-devel@oss.oracle.com>"); MODULE_DESCRIPTION("RDS: IB/iWARP transport"); MODULE_LICENSE("Dual BSD/GPL"); |
55b7ed0b5 RDS: Common RDMA ... |
251 |