git.sesse.net Git - bcachefs-tools-debian/blob - libbcachefs/journal_reclaim.h

   1 /* SPDX-License-Identifier: GPL-2.0 */
   2 #ifndef _BCACHEFS_JOURNAL_RECLAIM_H
   3 #define _BCACHEFS_JOURNAL_RECLAIM_H
   4
   5 #define JOURNAL_PIN     (32 * 1024)
   6
   7 enum journal_space_from {
   8         journal_space_discarded,
   9         journal_space_clean_ondisk,
  10         journal_space_clean,
  11 };
  12
  13 static inline void journal_reclaim_kick(struct journal *j)
  14 {
  15         struct task_struct *p = READ_ONCE(j->reclaim_thread);
  16
  17         if (p && !j->reclaim_kicked) {
  18                 j->reclaim_kicked = true;
  19                 if (p)
  20                         wake_up_process(p);
  21         }
  22 }
  23
  24 unsigned bch2_journal_dev_buckets_available(struct journal *,
  25                                             struct journal_device *,
  26                                             enum journal_space_from);
  27 void bch2_journal_space_available(struct journal *);
  28
  29 static inline bool journal_pin_active(struct journal_entry_pin *pin)
  30 {
  31         return pin->seq != 0;
  32 }
  33
  34 static inline struct journal_entry_pin_list *
  35 journal_seq_pin(struct journal *j, u64 seq)
  36 {
  37         EBUG_ON(seq < j->pin.front || seq >= j->pin.back);
  38
  39         return &j->pin.data[seq & j->pin.mask];
  40 }
  41
  42 void bch2_journal_pin_put(struct journal *, u64);
  43 void bch2_journal_pin_drop(struct journal *, struct journal_entry_pin *);
  44
  45 void bch2_journal_pin_set(struct journal *, u64, struct journal_entry_pin *,
  46                           journal_pin_flush_fn);
  47
  48 static inline void bch2_journal_pin_add(struct journal *j, u64 seq,
  49                                         struct journal_entry_pin *pin,
  50                                         journal_pin_flush_fn flush_fn)
  51 {
  52         if (unlikely(!journal_pin_active(pin) || pin->seq > seq))
  53                 bch2_journal_pin_set(j, seq, pin, flush_fn);
  54 }
  55
  56 static inline void bch2_journal_pin_copy(struct journal *j,
  57                                          struct journal_entry_pin *dst,
  58                                          struct journal_entry_pin *src,
  59                                          journal_pin_flush_fn flush_fn)
  60 {
  61         if (journal_pin_active(src))
  62                 bch2_journal_pin_add(j, src->seq, dst, flush_fn);
  63 }
  64
  65 static inline void bch2_journal_pin_update(struct journal *j, u64 seq,
  66                                            struct journal_entry_pin *pin,
  67                                            journal_pin_flush_fn flush_fn)
  68 {
  69         if (unlikely(!journal_pin_active(pin) || pin->seq < seq))
  70                 bch2_journal_pin_set(j, seq, pin, flush_fn);
  71 }
  72
  73 void bch2_journal_pin_flush(struct journal *, struct journal_entry_pin *);
  74
  75 void bch2_journal_do_discards(struct journal *);
  76 void bch2_journal_reclaim(struct journal *);
  77
  78 void bch2_journal_reclaim_stop(struct journal *);
  79 int bch2_journal_reclaim_start(struct journal *);
  80
  81 bool bch2_journal_flush_pins(struct journal *, u64);
  82
  83 static inline bool bch2_journal_flush_all_pins(struct journal *j)
  84 {
  85         return bch2_journal_flush_pins(j, U64_MAX);
  86 }
  87
  88 int bch2_journal_flush_device_pins(struct journal *, int);
  89
  90 #endif /* _BCACHEFS_JOURNAL_RECLAIM_H */