]> git.sesse.net Git - bcachefs-tools-debian/blobdiff - libbcachefs/clock.h
Move c_src dirs back to toplevel
[bcachefs-tools-debian] / libbcachefs / clock.h
index 061bf04a265e4d69da6de7477ccb73a90d7fa65a..70a0f7436c844f2f4ce2b29c35fc8a250920e9b9 100644 (file)
@@ -1,10 +1,23 @@
-#ifndef _BCACHE_CLOCK_H
-#define _BCACHE_CLOCK_H
+/* SPDX-License-Identifier: GPL-2.0 */
+#ifndef _BCACHEFS_CLOCK_H
+#define _BCACHEFS_CLOCK_H
 
 void bch2_io_timer_add(struct io_clock *, struct io_timer *);
 void bch2_io_timer_del(struct io_clock *, struct io_timer *);
-void bch2_kthread_io_clock_wait(struct io_clock *, unsigned long);
-void bch2_increment_clock(struct bch_fs *, unsigned, int);
+void bch2_kthread_io_clock_wait(struct io_clock *, unsigned long,
+                               unsigned long);
+
+void __bch2_increment_clock(struct io_clock *, unsigned);
+
+static inline void bch2_increment_clock(struct bch_fs *c, unsigned sectors,
+                                       int rw)
+{
+       struct io_clock *clock = &c->io_clock[rw];
+
+       if (unlikely(this_cpu_add_return(*clock->pcpu_buf, sectors) >=
+                  IO_CLOCK_PCPU_SECTORS))
+               __bch2_increment_clock(clock, this_cpu_xchg(*clock->pcpu_buf, 0));
+}
 
 void bch2_io_clock_schedule_timeout(struct io_clock *, unsigned long);
 
@@ -17,7 +30,9 @@ void bch2_io_clock_schedule_timeout(struct io_clock *, unsigned long);
        __ret;                                                          \
 })
 
+void bch2_io_timers_to_text(struct printbuf *, struct io_clock *);
+
 void bch2_io_clock_exit(struct io_clock *);
 int bch2_io_clock_init(struct io_clock *);
 
-#endif /* _BCACHE_CLOCK_H */
+#endif /* _BCACHEFS_CLOCK_H */