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()
158 if (j->seq > ja->seq[bucket_index]) in journal_read_bucket()
159 ja->seq[bucket_index] = j->seq; in journal_read_bucket()
183 struct journal_device *ja = &ca->journal; in bch_journal_read() local
270 if (ja->seq[i] > seq) { in bch_journal_read()
271 seq = ja->seq[i]; in bch_journal_read()
277 ja->cur_idx = i; in bch_journal_read()
278 ja->last_idx = ja->discard_idx = (i + 1) % in bch_journal_read()
573 struct journal_device *ja = in journal_discard_endio() local
575 struct cache *ca = container_of(ja, struct cache, journal); in journal_discard_endio()
577 atomic_set(&ja->discard_in_flight, DISCARD_DONE); in journal_discard_endio()
585 struct journal_device *ja = in journal_discard_work() local
588 submit_bio(&ja->discard_bio); in journal_discard_work()
593 struct journal_device *ja = &ca->journal; in do_journal_discard() local
594 struct bio *bio = &ja->discard_bio; in do_journal_discard()
597 ja->discard_idx = ja->last_idx; in do_journal_discard()
601 switch (atomic_read(&ja->discard_in_flight)) { in do_journal_discard()
606 ja->discard_idx = (ja->discard_idx + 1) % in do_journal_discard()
609 atomic_set(&ja->discard_in_flight, DISCARD_READY); in do_journal_discard()
613 if (ja->discard_idx == ja->last_idx) in do_journal_discard()
616 atomic_set(&ja->discard_in_flight, DISCARD_IN_FLIGHT); in do_journal_discard()
620 ca->sb.d[ja->discard_idx]); in do_journal_discard()
625 INIT_WORK(&ja->discard_work, journal_discard_work); in do_journal_discard()
626 queue_work(bch_journal_wq, &ja->discard_work); in do_journal_discard()
634 struct journal_device *ja = &c->cache->journal; in free_journal_buckets() local
638 if (ja->cur_idx >= ja->discard_idx) in free_journal_buckets()
639 n = ca->sb.njournal_buckets + ja->discard_idx - ja->cur_idx; in free_journal_buckets()
641 n = ja->discard_idx - ja->cur_idx; in free_journal_buckets()
654 struct journal_device *ja = &ca->journal; in journal_reclaim() local
666 while (ja->last_idx != ja->cur_idx && in journal_reclaim()
667 ja->seq[ja->last_idx] < last_seq) in journal_reclaim()
668 ja->last_idx = (ja->last_idx + 1) % in journal_reclaim()
679 ja->cur_idx = (ja->cur_idx + 1) % ca->sb.njournal_buckets; in journal_reclaim()
681 bucket_to_sector(c, ca->sb.d[ja->cur_idx]), in journal_reclaim()