25 #ifndef __MOTR_FDMI_SOURCE_DOCK_INTERNAL_H__ 26 #define __MOTR_FDMI_SOURCE_DOCK_INTERNAL_H__ M0_INTERNAL void m0_fdmi__src_dock_fom_stop(struct m0_fdmi_src_dock *src_dock)
M0_INTERNAL void m0_fdmi__record_post(struct m0_fdmi_src_rec *src_rec)
M0_INTERNAL int m0_fdmi__handle_release(struct m0_uint128 *fdmi_rec_id)
struct fdmi_sd_fom fsdc_sd_fom
struct m0_mutex fsdc_list_mutex
struct m0_tl fsdc_src_list
struct m0_sm_ast fstf_wakeup_ast
int(* ffth_handler)(struct m0_fdmi_eval_ctx *ctx, struct m0_conf_fdmi_filter *filter, struct m0_fdmi_eval_var_info *var_info)
m0_time_t fsf_last_checkpoint
M0_INTERNAL void m0_fdmi__record_init(struct m0_fdmi_src_rec *src_rec)
struct m0_semaphore fsf_shutdown
struct m0_filterc_ctx fsf_filter_ctx
M0_INTERNAL void m0_fdmi__fs_get(struct m0_fdmi_src_rec *src_rec)
M0_INTERNAL void m0_fdmi__src_dock_fom_init(void)
struct fdmi_sd_timer_fom fsdc_sd_timer_fom
struct m0_filterc_iter fsf_filter_iter
struct m0_tlink fsc_linkage
M0_INTERNAL void m0_fdmi__enqueue(struct m0_fdmi_src_rec *src_rec)
struct m0_sm_ast fsf_wakeup_ast
M0_INTERNAL void m0_fdmi__fs_end(struct m0_fdmi_src_rec *src_rec)
struct m0_semaphore fstf_shutdown
M0_INTERNAL void m0_fdmi__fs_begin(struct m0_fdmi_src_rec *src_rec)
M0_INTERNAL void m0_fdmi__src_dock_fom_wakeup(struct fdmi_sd_fom *sd_fom)
M0_INTERNAL void m0_fdmi__rec_id_gen(struct m0_fdmi_src_rec *src_rec)
static struct fdmi_ctx ctx
struct m0_mutex fsf_pending_fops_lock
M0_INTERNAL enum m0_fdmi_rec_type_id m0_fdmi__sd_rec_type_id_get(struct m0_fdmi_src_rec *src_rec)
struct m0_tl fsdc_posted_rec_list
struct m0_tl fsdc_rec_inflight
struct m0_rpc_conn_pool fsf_conn_pool
struct m0_fdmi_eval_ctx fsf_flt_eval
M0_TL_DECLARE(fdmi_record_list, M0_EXTERN, struct m0_fdmi_src_rec)
struct m0_tl fsf_pending_fops
uint64_t fsdc_instance_id
struct m0_fom_timeout fstf_timeout
M0_TL_DESCR_DECLARE(fdmi_record_list, M0_EXTERN)
struct m0_fdmi_src fsc_src
M0_INTERNAL void m0_fdmi__record_deinit(struct m0_fdmi_src_rec *src_rec)
bool fsdc_filters_defined
M0_INTERNAL struct m0_fdmi_src_ctx * m0_fdmi__src_ctx_get(enum m0_fdmi_rec_type_id src_type_id)
M0_INTERNAL void m0_fdmi__fs_put(struct m0_fdmi_src_rec *src_rec)
enum m0_fdmi_filter_type_id ffth_id
M0_INTERNAL void m0_fdmi__enqueue_locked(struct m0_fdmi_src_rec *src_rec)
M0_INTERNAL int m0_fdmi__src_dock_fom_start(struct m0_fdmi_src_dock *src_dock, const struct m0_filterc_ops *filterc_ops, struct m0_reqh *reqh)