rdma_transport.c revision c0dd49bdd68c0d758a67d56f07826f3b45cfc664
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * CDDL HEADER START
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * The contents of this file are subject to the terms of the
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * Common Development and Distribution License (the "License").
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * You may not use this file except in compliance with the License.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * See the License for the specific language governing permissions
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * and limitations under the License.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * When distributing Covered Code, include this CDDL HEADER in each
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * If applicable, add the following below this CDDL HEADER, with the
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * fields enclosed by brackets "[]" replaced with your own identifying
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * information: Portions Copyright [yyyy] [name of copyright owner]
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * CDDL HEADER END
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * Copyright (c) 2010, Oracle and/or its affiliates. All rights reserved.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * Copyright (c) 2009 Oracle. All rights reserved.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * This software is available to you under a choice of one of two
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * licenses. You may choose to be licensed under the terms of the GNU
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * General Public License (GPL) Version 2, available from the file
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * COPYING in the main directory of this source tree, or the
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * OpenIB.org BSD license below:
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * Redistribution and use in source and binary forms, with or
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * without modification, are permitted provided that the following
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * conditions are met:
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * - Redistributions of source code must retain the above
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * copyright notice, this list of conditions and the following
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * disclaimer.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * - Redistributions in binary form must reproduce the above
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * copyright notice, this list of conditions and the following
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * disclaimer in the documentation and/or other materials
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * provided with the distribution.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * SOFTWARE.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Otardsv3_rdma_cm_event_handler(struct rdma_cm_id *cm_id,
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota /* this can be null in the listening path */
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "conn %p id %p handling event %u", conn, cm_id, event->event);
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * Prevent shutdown from tearing down the connection
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * while we're executing.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * If the connection is being shut down, bail out
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * right away. We return 0 so cm_id doesn't get
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * destroyed prematurely
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota if (rdsv3_conn_state(conn) == RDSV3_CONN_DISCONNECTING) {
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * Reject incoming connections while we're tearing
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * down an existing one.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "conn %p id %p incoming event %u when "
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota /* XXX do we need to clean up if this fails? */
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota /* XXX worry about racing with listen acceptance */
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "RDS/RDMA: DISCONNECT event - dropping connection "
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "RDS/RDMA: DISCONNECT event - dropping connection "
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "%u.%u.%u.%u ->%u.%u.%u.%u", NIPQUAD(conn->c_laddr),
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota /* things like device disconnect? */
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota // struct rds_iw_connection *ic = conn->c_transport_data;
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota /* If we return non-zero, we must to hang on to the cm_id */
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota // BUG_ON(ic->i_cm_id == cm_id && ret);
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "id %p event %u handling ret %d", cm_id, event->event, ret);
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota cm_id = rdma_create_id(rdsv3_rdma_cm_event_handler, NULL, RDMA_PS_TCP);
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "RDS/RDMA: failed to setup listener, "
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * XXX I bet this binds the cm_id to a device. If we want to support
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * fail-over we'll have to take this into consideration.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota ret = rdma_bind_addr(cm_id, (struct sockaddr *)&sin);
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "RDS/RDMA: failed to setup listener, "
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "RDS/RDMA: failed to setup listener, "
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "Return: rdsv3_rdma_listen_id: %p", rdsv3_rdma_listen_id);
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Otastatic void rdsv3_rdma_listen_stop(void)
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota RDSV3_DPRINTF2("rdsv3_rdma_listen_stop", "cm %p", rdsv3_rdma_listen_id);
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota RDSV3_DPRINTF2("rdsv3_rdma_listen_stop", "Return");
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * This function can be called via two routes.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * 1. During attach on a worker thread.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota * 2. From rdsv3_create() for 1st socket.
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota "rdsv3_rdma_listen_id is already initialized: %p",
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota/*ARGSUSED*/
c0dd49bdd68c0d758a67d56f07826f3b45cfc664Eiji Ota /* stop listening first to ensure no new connections are attempted */