fsync.h

Go to the documentation of this file.

/* -*- C -*- */
/*
 * Copyright (c) 2014-2020 Seagate Technology LLC and/or its Affiliates
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * For any questions about this software or licensing,
 * please email opensource@seagate.com or cortx-questions@seagate.com.
 *
 */



#include <linux/version.h>              /* LINUX_VERSION_CODE */

#include "mdservice/fsync_fops.h"       /* m0_fop_fsync_mds_fopt */
#include "fop/fop.h"                    /* m0_fop */

#pragma once

#ifndef __MOTR_M0T1FS_FSYNC_H__
#define __MOTR_M0T1FS_FSYNC_H__

/* import */
struct m0t1fs_inode;
struct m0t1fs_sb;
struct m0_reqh_service_ctx;


struct m0t1fs_fsync_fop_wrapper {
        struct m0_fop                ffw_fop;

        struct m0_reqh_service_txid *ffw_stx;

        struct m0_tlink              ffw_tlink;
        uint64_t                     ffw_tlink_magic;
};

struct m0t1fs_fsync_interactions {
#if LINUX_VERSION_CODE >= KERNEL_VERSION(3,10,0)
        int (*kernel_fsync)(struct file *file, loff_t start, loff_t end,
                            int datasync);
#else
        int (*kernel_fsync)(struct file *file, struct dentry *dentry,
                            int datasync);
#endif
        int (*post_rpc)(struct m0_rpc_item *item);
        int (*wait_for_reply)(struct m0_rpc_item *item, m0_time_t timeout);
        void (*fop_fini)(struct m0_fop *fop);
        void (*fop_put)(struct m0_fop *fop);
};

#if LINUX_VERSION_CODE >= KERNEL_VERSION(3,10,0)
int m0t1fs_fsync(struct file *file, loff_t start, loff_t end, int datasync);
#else
int m0t1fs_fsync(struct file *file, struct dentry *dentry, int datasync);
#endif


void m0t1fs_fsync_record_update(struct m0_reqh_service_ctx *service,
                                struct m0t1fs_sb           *csb,
                                struct m0t1fs_inode        *inode,
                                struct m0_be_tx_remid      *btr);


M0_INTERNAL int
m0t1fs_fsync_request_create(struct m0_reqh_service_txid      *stx,
                            struct m0t1fs_fsync_fop_wrapper **ffw,
                            enum m0_fsync_mode                mode);


M0_INTERNAL int
m0t1fs_fsync_reply_process(struct m0t1fs_sb                *csb,
                           struct m0t1fs_inode             *inode,
                           struct m0t1fs_fsync_fop_wrapper *ffw);


int m0t1fs_sync_fs(struct super_block *sb, int wait);

M0_INTERNAL int m0t1fs_fsync_core(struct m0t1fs_inode   *inode,
                                  enum m0_fsync_mode     mode);

#endif /* __MOTR_M0T1FS_FSYNC_H__ */

/*
 *  Local variables:
 *  c-indentation-style: "K&R"
 *  c-basic-offset: 8
 *  tab-width: 8
 *  fill-column: 80
 *  scroll-step: 1
 *  End:
 */