leandrof/linux
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[PATCH] IB: Fix a couple of MAD code paths

Browse Source 
Fixed locking to handle error posting MAD send work requests.  Fixed handling
canceling a MAD with an active work request.

Signed-off-by: Sean Hefty <sean.hefty@intel.com>
Signed-off-by: Hal Rosenstock <halr@voltaire.com>
Cc: Roland Dreier <rolandd@cisco.com>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
This commit is contained in:
Hal Rosenstock 2005-07-27 11:45:33 -07:00 committed by Linus Torvalds
parent 29bb33dd87
commit cabe3cbcbb
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
drivers/infiniband/core/mad.c
View File

@ -841,6 +841,7 @@ static int ib_send_mad(struct ib_mad_send_wr_private *mad_send_wr)
{ {
struct ib_mad_qp_info *qp_info; struct ib_mad_qp_info *qp_info;
struct ib_send_wr *bad_send_wr; struct ib_send_wr *bad_send_wr;
struct list_head *list;
unsigned long flags; unsigned long flags;
int ret; int ret;
@ -850,22 +851,20 @@ static int ib_send_mad(struct ib_mad_send_wr_private *mad_send_wr)
mad_send_wr->mad_list.mad_queue = &qp_info->send_queue; mad_send_wr->mad_list.mad_queue = &qp_info->send_queue;
spin_lock_irqsave(&qp_info->send_queue.lock, flags); spin_lock_irqsave(&qp_info->send_queue.lock, flags);
if (qp_info->send_queue.count++ < qp_info->send_queue.max_active) { if (qp_info->send_queue.count < qp_info->send_queue.max_active) {
list_add_tail(&mad_send_wr->mad_list.list,
&qp_info->send_queue.list);
spin_unlock_irqrestore(&qp_info->send_queue.lock, flags);
ret = ib_post_send(mad_send_wr->mad_agent_priv->agent.qp, ret = ib_post_send(mad_send_wr->mad_agent_priv->agent.qp,
&mad_send_wr->send_wr, &bad_send_wr); &mad_send_wr->send_wr, &bad_send_wr);
if (ret) { list = &qp_info->send_queue.list;
printk(KERN_ERR PFX "ib_post_send failed: %d\n", ret);
dequeue_mad(&mad_send_wr->mad_list);
}
} else { } else {
list_add_tail(&mad_send_wr->mad_list.list,
&qp_info->overflow_list);
spin_unlock_irqrestore(&qp_info->send_queue.lock, flags);
ret = 0; ret = 0;
list = &qp_info->overflow_list;
} }
if (!ret) {
qp_info->send_queue.count++;
list_add_tail(&mad_send_wr->mad_list.list, list);
}
spin_unlock_irqrestore(&qp_info->send_queue.lock, flags);
return ret; return ret;
} }
@ -2023,8 +2022,7 @@ static void cancel_mads(struct ib_mad_agent_private *mad_agent_priv)
} }
static struct ib_mad_send_wr_private* static struct ib_mad_send_wr_private*
find_send_by_wr_id(struct ib_mad_agent_private *mad_agent_priv, find_send_by_wr_id(struct ib_mad_agent_private *mad_agent_priv, u64 wr_id)
u64 wr_id)
{ {
struct ib_mad_send_wr_private *mad_send_wr; struct ib_mad_send_wr_private *mad_send_wr;
@ -2047,6 +2045,7 @@ int ib_modify_mad(struct ib_mad_agent *mad_agent, u64 wr_id, u32 timeout_ms)
struct ib_mad_agent_private *mad_agent_priv; struct ib_mad_agent_private *mad_agent_priv;
struct ib_mad_send_wr_private *mad_send_wr; struct ib_mad_send_wr_private *mad_send_wr;
unsigned long flags; unsigned long flags;
int active;
mad_agent_priv = container_of(mad_agent, struct ib_mad_agent_private, mad_agent_priv = container_of(mad_agent, struct ib_mad_agent_private,
agent); agent);
@ -2057,13 +2056,14 @@ int ib_modify_mad(struct ib_mad_agent *mad_agent, u64 wr_id, u32 timeout_ms)
return -EINVAL; return -EINVAL;
} }
active = (!mad_send_wr->timeout || mad_send_wr->refcount > 1);
if (!timeout_ms) { if (!timeout_ms) {
mad_send_wr->status = IB_WC_WR_FLUSH_ERR; mad_send_wr->status = IB_WC_WR_FLUSH_ERR;
mad_send_wr->refcount -= (mad_send_wr->timeout > 0); mad_send_wr->refcount -= (mad_send_wr->timeout > 0);
} }
mad_send_wr->send_wr.wr.ud.timeout_ms = timeout_ms; mad_send_wr->send_wr.wr.ud.timeout_ms = timeout_ms;
if (!mad_send_wr->timeout || mad_send_wr->refcount > 1) if (active)
mad_send_wr->timeout = msecs_to_jiffies(timeout_ms); mad_send_wr->timeout = msecs_to_jiffies(timeout_ms);
else else
ib_reset_mad_timeout(mad_send_wr, timeout_ms); ib_reset_mad_timeout(mad_send_wr, timeout_ms);