/* SPDX-License-Identifier: GPL-2.0-only */
/*
* Copyright 2023 Red Hat
*/
#ifndef VDO_FLUSH_H
#define VDO_FLUSH_H
#include "funnel-workqueue.h"
#include "types.h"
#include "vio.h"
#include "wait-queue.h"
/* A marker for tracking which journal entries are affected by a flush request. */
struct vdo_flush {
/* The completion for enqueueing this flush request. */
struct vdo_completion completion;
/* The flush bios covered by this request */
struct bio_list bios;
/* The wait queue entry for this flush */
struct vdo_waiter waiter;
/* Which flush this struct represents */
sequence_number_t flush_generation;
};
struct flusher;
int __must_check vdo_make_flusher(struct vdo *vdo);
void vdo_free_flusher(struct flusher *flusher);
thread_id_t __must_check vdo_get_flusher_thread_id(struct flusher *flusher);
void vdo_complete_flushes(struct flusher *flusher);
void vdo_dump_flusher(const struct flusher *flusher);
void vdo_launch_flush(struct vdo *vdo, struct bio *bio);
void vdo_drain_flusher(struct flusher *flusher, struct vdo_completion *completion);
void vdo_resume_flusher(struct flusher *flusher, struct vdo_completion *parent);
#endif /* VDO_FLUSH_H */