Lines Matching refs:ja
38 struct journal_device *ja = &ca->journal; in journal_read_bucket() local
39 struct bio *bio = &ja->bio; in journal_read_bucket()
159 if (j->seq > ja->seq[bucket_index]) in journal_read_bucket()
160 ja->seq[bucket_index] = j->seq; in journal_read_bucket()
184 struct journal_device *ja = &ca->journal; in bch_journal_read() local
271 if (ja->seq[i] > seq) { in bch_journal_read()
272 seq = ja->seq[i]; in bch_journal_read()
278 ja->cur_idx = i; in bch_journal_read()
279 ja->last_idx = ja->discard_idx = (i + 1) % in bch_journal_read()
574 struct journal_device *ja = in journal_discard_endio() local
576 struct cache *ca = container_of(ja, struct cache, journal); in journal_discard_endio()
578 atomic_set(&ja->discard_in_flight, DISCARD_DONE); in journal_discard_endio()
586 struct journal_device *ja = in journal_discard_work() local
589 submit_bio(&ja->discard_bio); in journal_discard_work()
594 struct journal_device *ja = &ca->journal; in do_journal_discard() local
595 struct bio *bio = &ja->discard_bio; in do_journal_discard()
598 ja->discard_idx = ja->last_idx; in do_journal_discard()
602 switch (atomic_read(&ja->discard_in_flight)) { in do_journal_discard()
607 ja->discard_idx = (ja->discard_idx + 1) % in do_journal_discard()
610 atomic_set(&ja->discard_in_flight, DISCARD_READY); in do_journal_discard()
614 if (ja->discard_idx == ja->last_idx) in do_journal_discard()
617 atomic_set(&ja->discard_in_flight, DISCARD_IN_FLIGHT); in do_journal_discard()
622 ca->sb.d[ja->discard_idx]); in do_journal_discard()
628 INIT_WORK(&ja->discard_work, journal_discard_work); in do_journal_discard()
629 queue_work(bch_journal_wq, &ja->discard_work); in do_journal_discard()
637 struct journal_device *ja = &c->cache->journal; in free_journal_buckets() local
641 if (ja->cur_idx >= ja->discard_idx) in free_journal_buckets()
642 n = ca->sb.njournal_buckets + ja->discard_idx - ja->cur_idx; in free_journal_buckets()
644 n = ja->discard_idx - ja->cur_idx; in free_journal_buckets()
657 struct journal_device *ja = &ca->journal; in journal_reclaim() local
669 while (ja->last_idx != ja->cur_idx && in journal_reclaim()
670 ja->seq[ja->last_idx] < last_seq) in journal_reclaim()
671 ja->last_idx = (ja->last_idx + 1) % in journal_reclaim()
682 ja->cur_idx = (ja->cur_idx + 1) % ca->sb.njournal_buckets; in journal_reclaim()
684 bucket_to_sector(c, ca->sb.d[ja->cur_idx]), in journal_reclaim()