Lines Matching defs:flusher
23 struct flusher { struct
25 /* The vdo to which this flusher belongs */ argument
27 /* The administrative state of the flusher */ argument
28 struct admin_state state;
30 sequence_number_t flush_generation;
32 sequence_number_t first_unacknowledged_generation;
56 * assert_on_flusher_thread() - Check that we are on the flusher thread. argument
60 static inline void assert_on_flusher_thread(struct flusher *flusher, const char *caller) in assert_on_flusher_thread()
115 struct flusher *flusher = pool_data; in allocate_flush() local
159 void vdo_free_flusher(struct flusher *flusher) in vdo_free_flusher()
176 thread_id_t vdo_get_flusher_thread_id(struct flusher *flusher) in vdo_get_flusher_thread_id()
194 struct flusher *flusher = as_flusher(completion); in finish_notification() local
214 struct flusher *flusher = as_flusher(completion); in flush_packer_callback() local
230 struct flusher *flusher = as_flusher(completion); in increment_generation() local
249 static void notify_flush(struct flusher *flusher) in notify_flush()
270 struct flusher *flusher = completion->vdo->flusher; in flush_vdo() local
294 static void check_for_drain_complete(struct flusher *flusher) in check_for_drain_complete()
314 void vdo_complete_flushes(struct flusher *flusher) in vdo_complete_flushes()
350 void vdo_dump_flusher(const struct flusher *flusher) in vdo_dump_flusher()
399 struct flusher *flusher = vdo->flusher; in vdo_launch_flush() local
434 struct flusher *flusher = flush->completion.vdo->flusher; in release_flush() local
491 static thread_id_t select_bio_queue(struct flusher *flusher) in select_bio_queue()
543 void vdo_drain_flusher(struct flusher *flusher, struct vdo_completion *completion) in vdo_drain_flusher()
555 void vdo_resume_flusher(struct flusher *flusher, struct vdo_completion *parent) in vdo_resume_flusher()