|
@@ -575,8 +575,11 @@ void ipoib_mcast_join_task(struct work_struct *work)
|
|
|
if (!test_bit(IPOIB_FLAG_OPER_UP, &priv->flags))
|
|
|
return;
|
|
|
|
|
|
- if (ib_query_port(priv->ca, priv->port, &port_attr) ||
|
|
|
- port_attr.state != IB_PORT_ACTIVE) {
|
|
|
+ if (ib_query_port(priv->ca, priv->port, &port_attr)) {
|
|
|
+ ipoib_dbg(priv, "ib_query_port() failed\n");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if (port_attr.state != IB_PORT_ACTIVE) {
|
|
|
ipoib_dbg(priv, "port state is not ACTIVE (state = %d) suspending join task\n",
|
|
|
port_attr.state);
|
|
|
return;
|