Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 116262
b: refs/heads/master
c: 7eb923b
h: refs/heads/master
v: v3
  • Loading branch information
Eric Van Hensbergen committed Oct 17, 2008
1 parent 129c049 commit a42e01f
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 8 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: f0a0ac2ee50c62cf4ad9b06cf8a12435cc5ac44d
refs/heads/master: 7eb923b80c8ce16697129fb2dcdfaeabf83f0dbc
24 changes: 17 additions & 7 deletions trunk/net/9p/trans_fd.c
Original file line number Diff line number Diff line change
Expand Up @@ -188,8 +188,16 @@ static void p9_conn_cancel(struct p9_conn *m, int err)
LIST_HEAD(cancel_list);

P9_DPRINTK(P9_DEBUG_ERROR, "mux %p err %d\n", m, err);
m->err = err;

spin_lock_irqsave(&m->client->lock, flags);

if (m->err) {
spin_unlock_irqrestore(&m->client->lock, flags);
return;
}

m->err = err;

list_for_each_entry_safe(req, rtmp, &m->req_list, req_list) {
req->status = REQ_STATUS_ERROR;
if (!req->t_err)
Expand Down Expand Up @@ -352,8 +360,9 @@ static void p9_read_work(struct work_struct *work)
/* not an else because some packets (like clunk) have no payload */
if ((m->req) && (m->rpos == m->rsize)) { /* packet is read in */
P9_DPRINTK(P9_DEBUG_TRANS, "got new packet\n");

spin_lock(&m->client->lock);
list_del(&m->req->req_list);
spin_unlock(&m->client->lock);
p9_client_cb(m->client, m->req);

m->rbuf = NULL;
Expand Down Expand Up @@ -651,9 +660,8 @@ static int p9_fd_request(struct p9_client *client, struct p9_req_t *req)
if (m->err < 0)
return m->err;

req->status = REQ_STATUS_UNSENT;

spin_lock(&client->lock);
req->status = REQ_STATUS_UNSENT;
list_add_tail(&req->req_list, &m->unsent_req_list);
spin_unlock(&client->lock);

Expand All @@ -672,19 +680,21 @@ static int p9_fd_cancel(struct p9_client *client, struct p9_req_t *req)
{
struct p9_trans_fd *ts = client->trans;
struct p9_conn *m = ts->conn;
int ret = 1;

P9_DPRINTK(P9_DEBUG_TRANS, "mux %p req %p\n", m, req);

spin_lock(&client->lock);
list_del(&req->req_list);
spin_unlock(&client->lock);

if (req->status == REQ_STATUS_UNSENT) {
req->status = REQ_STATUS_FLSHD;
return 0;
ret = 0;
}

return 1;
spin_unlock(&client->lock);

return ret;
}

/**
Expand Down

0 comments on commit a42e01f

Please sign in to comment.