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()
157 if (j->seq > ja->seq[bucket_index]) in journal_read_bucket()
158 ja->seq[bucket_index] = j->seq; in journal_read_bucket()
182 struct journal_device *ja = &ca->journal; in bch_journal_read() local
269 if (ja->seq[i] > seq) { in bch_journal_read()
270 seq = ja->seq[i]; in bch_journal_read()
276 ja->cur_idx = i; in bch_journal_read()
277 ja->last_idx = ja->discard_idx = (i + 1) % in bch_journal_read()
572 struct journal_device *ja = in journal_discard_endio() local
574 struct cache *ca = container_of(ja, struct cache, journal); in journal_discard_endio()
576 atomic_set(&ja->discard_in_flight, DISCARD_DONE); in journal_discard_endio()
584 struct journal_device *ja = in journal_discard_work() local
587 submit_bio(&ja->discard_bio); in journal_discard_work()
592 struct journal_device *ja = &ca->journal; in do_journal_discard() local
593 struct bio *bio = &ja->discard_bio; in do_journal_discard()
596 ja->discard_idx = ja->last_idx; in do_journal_discard()
600 switch (atomic_read(&ja->discard_in_flight)) { in do_journal_discard()
605 ja->discard_idx = (ja->discard_idx + 1) % in do_journal_discard()
608 atomic_set(&ja->discard_in_flight, DISCARD_READY); in do_journal_discard()
612 if (ja->discard_idx == ja->last_idx) in do_journal_discard()
615 atomic_set(&ja->discard_in_flight, DISCARD_IN_FLIGHT); in do_journal_discard()
619 ca->sb.d[ja->discard_idx]); in do_journal_discard()
624 INIT_WORK(&ja->discard_work, journal_discard_work); in do_journal_discard()
625 queue_work(bch_journal_wq, &ja->discard_work); in do_journal_discard()
633 struct journal_device *ja = &c->cache->journal; in free_journal_buckets() local
637 if (ja->cur_idx >= ja->discard_idx) in free_journal_buckets()
638 n = ca->sb.njournal_buckets + ja->discard_idx - ja->cur_idx; in free_journal_buckets()
640 n = ja->discard_idx - ja->cur_idx; in free_journal_buckets()
653 struct journal_device *ja = &ca->journal; in journal_reclaim() local
665 while (ja->last_idx != ja->cur_idx && in journal_reclaim()
666 ja->seq[ja->last_idx] < last_seq) in journal_reclaim()
667 ja->last_idx = (ja->last_idx + 1) % in journal_reclaim()
678 ja->cur_idx = (ja->cur_idx + 1) % ca->sb.njournal_buckets; in journal_reclaim()
680 bucket_to_sector(c, ca->sb.d[ja->cur_idx]), in journal_reclaim()