Lines Matching refs:dreq

583 static void __unhash_deferred_req(struct cache_deferred_req *dreq)  in __unhash_deferred_req()  argument
585 hlist_del_init(&dreq->hash); in __unhash_deferred_req()
586 if (!list_empty(&dreq->recent)) { in __unhash_deferred_req()
587 list_del_init(&dreq->recent); in __unhash_deferred_req()
592 static void __hash_deferred_req(struct cache_deferred_req *dreq, struct cache_head *item) in __hash_deferred_req() argument
596 INIT_LIST_HEAD(&dreq->recent); in __hash_deferred_req()
597 hlist_add_head(&dreq->hash, &cache_defer_hash[hash]); in __hash_deferred_req()
600 static void setup_deferral(struct cache_deferred_req *dreq, in setup_deferral() argument
605 dreq->item = item; in setup_deferral()
609 __hash_deferred_req(dreq, item); in setup_deferral()
613 list_add(&dreq->recent, &cache_defer_list); in setup_deferral()
625 static void cache_restart_thread(struct cache_deferred_req *dreq, int too_many) in cache_restart_thread() argument
628 container_of(dreq, struct thread_deferred_req, handle); in cache_restart_thread()
635 struct cache_deferred_req *dreq = &sleeper.handle; in cache_wait_req() local
638 dreq->revisit = cache_restart_thread; in cache_wait_req()
640 setup_deferral(dreq, item, 0); in cache_wait_req()
694 struct cache_deferred_req *dreq; in cache_defer_req() local
701 dreq = req->defer(req); in cache_defer_req()
702 if (dreq == NULL) in cache_defer_req()
704 setup_deferral(dreq, item, 1); in cache_defer_req()
717 struct cache_deferred_req *dreq; in cache_revisit_request() local
725 hlist_for_each_entry_safe(dreq, tmp, &cache_defer_hash[hash], hash) in cache_revisit_request()
726 if (dreq->item == item) { in cache_revisit_request()
727 __unhash_deferred_req(dreq); in cache_revisit_request()
728 list_add(&dreq->recent, &pending); in cache_revisit_request()
734 dreq = list_entry(pending.next, struct cache_deferred_req, recent); in cache_revisit_request()
735 list_del_init(&dreq->recent); in cache_revisit_request()
736 dreq->revisit(dreq, 0); in cache_revisit_request()
742 struct cache_deferred_req *dreq, *tmp; in cache_clean_deferred() local
749 list_for_each_entry_safe(dreq, tmp, &cache_defer_list, recent) { in cache_clean_deferred()
750 if (dreq->owner == owner) { in cache_clean_deferred()
751 __unhash_deferred_req(dreq); in cache_clean_deferred()
752 list_add(&dreq->recent, &pending); in cache_clean_deferred()
758 dreq = list_entry(pending.next, struct cache_deferred_req, recent); in cache_clean_deferred()
759 list_del_init(&dreq->recent); in cache_clean_deferred()
760 dreq->revisit(dreq, 1); in cache_clean_deferred()