Searched refs:fpq (Results 1 – 2 of 2) sorted by relevance
1272 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_read() local1328 spin_lock(&fpq->lock); in fuse_dev_do_read()1333 if (!fpq->connected) { in fuse_dev_do_read()1338 list_add(&req->list, &fpq->io); in fuse_dev_do_read()1339 spin_unlock(&fpq->lock); in fuse_dev_do_read()1346 spin_lock(&fpq->lock); in fuse_dev_do_read()1348 if (!fpq->connected) { in fuse_dev_do_read()1360 list_move_tail(&req->list, &fpq->processing); in fuse_dev_do_read()1363 spin_unlock(&fpq->lock); in fuse_dev_do_read()1375 spin_unlock(&fpq->lock); in fuse_dev_do_read()[all …]
602 static void fuse_pqueue_init(struct fuse_pqueue *fpq) in fuse_pqueue_init() argument604 memset(fpq, 0, sizeof(struct fuse_pqueue)); in fuse_pqueue_init()605 spin_lock_init(&fpq->lock); in fuse_pqueue_init()606 INIT_LIST_HEAD(&fpq->processing); in fuse_pqueue_init()607 INIT_LIST_HEAD(&fpq->io); in fuse_pqueue_init()608 fpq->connected = 1; in fuse_pqueue_init()