|
@@ -1095,12 +1095,11 @@ __releases(fiq->waitq.lock)
|
|
int err;
|
|
int err;
|
|
|
|
|
|
list_del_init(&req->intr_entry);
|
|
list_del_init(&req->intr_entry);
|
|
- req->intr_unique = (req->in.h.unique | FUSE_INT_REQ_BIT);
|
|
|
|
memset(&ih, 0, sizeof(ih));
|
|
memset(&ih, 0, sizeof(ih));
|
|
memset(&arg, 0, sizeof(arg));
|
|
memset(&arg, 0, sizeof(arg));
|
|
ih.len = reqsize;
|
|
ih.len = reqsize;
|
|
ih.opcode = FUSE_INTERRUPT;
|
|
ih.opcode = FUSE_INTERRUPT;
|
|
- ih.unique = req->intr_unique;
|
|
|
|
|
|
+ ih.unique = (req->in.h.unique | FUSE_INT_REQ_BIT);
|
|
arg.unique = req->in.h.unique;
|
|
arg.unique = req->in.h.unique;
|
|
|
|
|
|
spin_unlock(&fiq->waitq.lock);
|
|
spin_unlock(&fiq->waitq.lock);
|
|
@@ -1808,7 +1807,7 @@ static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)
|
|
struct fuse_req *req;
|
|
struct fuse_req *req;
|
|
|
|
|
|
list_for_each_entry(req, &fpq->processing, list) {
|
|
list_for_each_entry(req, &fpq->processing, list) {
|
|
- if (req->in.h.unique == unique || req->intr_unique == unique)
|
|
|
|
|
|
+ if (req->in.h.unique == unique)
|
|
return req;
|
|
return req;
|
|
}
|
|
}
|
|
return NULL;
|
|
return NULL;
|
|
@@ -1882,12 +1881,12 @@ static ssize_t fuse_dev_do_write(struct fuse_dev *fud,
|
|
if (!fpq->connected)
|
|
if (!fpq->connected)
|
|
goto err_unlock_pq;
|
|
goto err_unlock_pq;
|
|
|
|
|
|
- req = request_find(fpq, oh.unique);
|
|
|
|
|
|
+ req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT);
|
|
if (!req)
|
|
if (!req)
|
|
goto err_unlock_pq;
|
|
goto err_unlock_pq;
|
|
|
|
|
|
- /* Is it an interrupt reply? */
|
|
|
|
- if (req->intr_unique == oh.unique) {
|
|
|
|
|
|
+ /* Is it an interrupt reply ID? */
|
|
|
|
+ if (oh.unique & FUSE_INT_REQ_BIT) {
|
|
__fuse_get_request(req);
|
|
__fuse_get_request(req);
|
|
spin_unlock(&fpq->lock);
|
|
spin_unlock(&fpq->lock);
|
|
|
|
|