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()
187 struct journal_device *ja = &ca->journal; in bch_journal_read() local
277 if (ja->seq[i] > seq) { in bch_journal_read()
278 seq = ja->seq[i]; in bch_journal_read()
284 ja->cur_idx = i; in bch_journal_read()
285 ja->last_idx = ja->discard_idx = (i + 1) % in bch_journal_read()
509 struct journal_device *ja = in journal_discard_endio() local
511 struct cache *ca = container_of(ja, struct cache, journal); in journal_discard_endio()
513 atomic_set(&ja->discard_in_flight, DISCARD_DONE); in journal_discard_endio()
521 struct journal_device *ja = in journal_discard_work() local
524 submit_bio(&ja->discard_bio); in journal_discard_work()
529 struct journal_device *ja = &ca->journal; in do_journal_discard() local
530 struct bio *bio = &ja->discard_bio; in do_journal_discard()
533 ja->discard_idx = ja->last_idx; in do_journal_discard()
537 switch (atomic_read(&ja->discard_in_flight)) { in do_journal_discard()
542 ja->discard_idx = (ja->discard_idx + 1) % in do_journal_discard()
545 atomic_set(&ja->discard_in_flight, DISCARD_READY); in do_journal_discard()
549 if (ja->discard_idx == ja->last_idx) in do_journal_discard()
552 atomic_set(&ja->discard_in_flight, DISCARD_IN_FLIGHT); in do_journal_discard()
557 ca->sb.d[ja->discard_idx]); in do_journal_discard()
563 INIT_WORK(&ja->discard_work, journal_discard_work); in do_journal_discard()
564 queue_work(bch_journal_wq, &ja->discard_work); in do_journal_discard()
586 struct journal_device *ja = &ca->journal; in journal_reclaim() local
588 while (ja->last_idx != ja->cur_idx && in journal_reclaim()
589 ja->seq[ja->last_idx] < last_seq) in journal_reclaim()
590 ja->last_idx = (ja->last_idx + 1) % in journal_reclaim()
606 struct journal_device *ja = &ca->journal; in journal_reclaim() local
607 unsigned int next = (ja->cur_idx + 1) % ca->sb.njournal_buckets; in journal_reclaim()
610 if (next == ja->discard_idx) in journal_reclaim()
613 ja->cur_idx = next; in journal_reclaim()
615 bucket_to_sector(c, ca->sb.d[ja->cur_idx]), in journal_reclaim()