|
@@ -88,7 +88,9 @@ static unsigned int rds_iw_unmap_fastreg_list(struct rds_iw_mr_pool *pool,
|
|
int *unpinned);
|
|
int *unpinned);
|
|
static void rds_iw_destroy_fastreg(struct rds_iw_mr_pool *pool, struct rds_iw_mr *ibmr);
|
|
static void rds_iw_destroy_fastreg(struct rds_iw_mr_pool *pool, struct rds_iw_mr *ibmr);
|
|
|
|
|
|
-static int rds_iw_get_device(struct rds_sock *rs, struct rds_iw_device **rds_iwdev, struct rdma_cm_id **cm_id)
|
|
|
|
|
|
+static int rds_iw_get_device(struct sockaddr_in *src, struct sockaddr_in *dst,
|
|
|
|
+ struct rds_iw_device **rds_iwdev,
|
|
|
|
+ struct rdma_cm_id **cm_id)
|
|
{
|
|
{
|
|
struct rds_iw_device *iwdev;
|
|
struct rds_iw_device *iwdev;
|
|
struct rds_iw_cm_id *i_cm_id;
|
|
struct rds_iw_cm_id *i_cm_id;
|
|
@@ -112,15 +114,15 @@ static int rds_iw_get_device(struct rds_sock *rs, struct rds_iw_device **rds_iwd
|
|
src_addr->sin_port,
|
|
src_addr->sin_port,
|
|
dst_addr->sin_addr.s_addr,
|
|
dst_addr->sin_addr.s_addr,
|
|
dst_addr->sin_port,
|
|
dst_addr->sin_port,
|
|
- rs->rs_bound_addr,
|
|
|
|
- rs->rs_bound_port,
|
|
|
|
- rs->rs_conn_addr,
|
|
|
|
- rs->rs_conn_port);
|
|
|
|
|
|
+ src->sin_addr.s_addr,
|
|
|
|
+ src->sin_port,
|
|
|
|
+ dst->sin_addr.s_addr,
|
|
|
|
+ dst->sin_port);
|
|
#ifdef WORKING_TUPLE_DETECTION
|
|
#ifdef WORKING_TUPLE_DETECTION
|
|
- if (src_addr->sin_addr.s_addr == rs->rs_bound_addr &&
|
|
|
|
- src_addr->sin_port == rs->rs_bound_port &&
|
|
|
|
- dst_addr->sin_addr.s_addr == rs->rs_conn_addr &&
|
|
|
|
- dst_addr->sin_port == rs->rs_conn_port) {
|
|
|
|
|
|
+ if (src_addr->sin_addr.s_addr == src->sin_addr.s_addr &&
|
|
|
|
+ src_addr->sin_port == src->sin_port &&
|
|
|
|
+ dst_addr->sin_addr.s_addr == dst->sin_addr.s_addr &&
|
|
|
|
+ dst_addr->sin_port == dst->sin_port) {
|
|
#else
|
|
#else
|
|
/* FIXME - needs to compare the local and remote
|
|
/* FIXME - needs to compare the local and remote
|
|
* ipaddr/port tuple, but the ipaddr is the only
|
|
* ipaddr/port tuple, but the ipaddr is the only
|
|
@@ -128,7 +130,7 @@ static int rds_iw_get_device(struct rds_sock *rs, struct rds_iw_device **rds_iwd
|
|
* zero'ed. It doesn't appear to be properly populated
|
|
* zero'ed. It doesn't appear to be properly populated
|
|
* during connection setup...
|
|
* during connection setup...
|
|
*/
|
|
*/
|
|
- if (src_addr->sin_addr.s_addr == rs->rs_bound_addr) {
|
|
|
|
|
|
+ if (src_addr->sin_addr.s_addr == src->sin_addr.s_addr) {
|
|
#endif
|
|
#endif
|
|
spin_unlock_irq(&iwdev->spinlock);
|
|
spin_unlock_irq(&iwdev->spinlock);
|
|
*rds_iwdev = iwdev;
|
|
*rds_iwdev = iwdev;
|
|
@@ -180,19 +182,13 @@ int rds_iw_update_cm_id(struct rds_iw_device *rds_iwdev, struct rdma_cm_id *cm_i
|
|
{
|
|
{
|
|
struct sockaddr_in *src_addr, *dst_addr;
|
|
struct sockaddr_in *src_addr, *dst_addr;
|
|
struct rds_iw_device *rds_iwdev_old;
|
|
struct rds_iw_device *rds_iwdev_old;
|
|
- struct rds_sock rs;
|
|
|
|
struct rdma_cm_id *pcm_id;
|
|
struct rdma_cm_id *pcm_id;
|
|
int rc;
|
|
int rc;
|
|
|
|
|
|
src_addr = (struct sockaddr_in *)&cm_id->route.addr.src_addr;
|
|
src_addr = (struct sockaddr_in *)&cm_id->route.addr.src_addr;
|
|
dst_addr = (struct sockaddr_in *)&cm_id->route.addr.dst_addr;
|
|
dst_addr = (struct sockaddr_in *)&cm_id->route.addr.dst_addr;
|
|
|
|
|
|
- rs.rs_bound_addr = src_addr->sin_addr.s_addr;
|
|
|
|
- rs.rs_bound_port = src_addr->sin_port;
|
|
|
|
- rs.rs_conn_addr = dst_addr->sin_addr.s_addr;
|
|
|
|
- rs.rs_conn_port = dst_addr->sin_port;
|
|
|
|
-
|
|
|
|
- rc = rds_iw_get_device(&rs, &rds_iwdev_old, &pcm_id);
|
|
|
|
|
|
+ rc = rds_iw_get_device(src_addr, dst_addr, &rds_iwdev_old, &pcm_id);
|
|
if (rc)
|
|
if (rc)
|
|
rds_iw_remove_cm_id(rds_iwdev, cm_id);
|
|
rds_iw_remove_cm_id(rds_iwdev, cm_id);
|
|
|
|
|
|
@@ -598,9 +594,17 @@ void *rds_iw_get_mr(struct scatterlist *sg, unsigned long nents,
|
|
struct rds_iw_device *rds_iwdev;
|
|
struct rds_iw_device *rds_iwdev;
|
|
struct rds_iw_mr *ibmr = NULL;
|
|
struct rds_iw_mr *ibmr = NULL;
|
|
struct rdma_cm_id *cm_id;
|
|
struct rdma_cm_id *cm_id;
|
|
|
|
+ struct sockaddr_in src = {
|
|
|
|
+ .sin_addr.s_addr = rs->rs_bound_addr,
|
|
|
|
+ .sin_port = rs->rs_bound_port,
|
|
|
|
+ };
|
|
|
|
+ struct sockaddr_in dst = {
|
|
|
|
+ .sin_addr.s_addr = rs->rs_conn_addr,
|
|
|
|
+ .sin_port = rs->rs_conn_port,
|
|
|
|
+ };
|
|
int ret;
|
|
int ret;
|
|
|
|
|
|
- ret = rds_iw_get_device(rs, &rds_iwdev, &cm_id);
|
|
|
|
|
|
+ ret = rds_iw_get_device(&src, &dst, &rds_iwdev, &cm_id);
|
|
if (ret || !cm_id) {
|
|
if (ret || !cm_id) {
|
|
ret = -ENODEV;
|
|
ret = -ENODEV;
|
|
goto out;
|
|
goto out;
|