fs/hmdfs/file_cloud.c

// SPDX-License-Identifier: GPL-2.0
/*
 * fs/hmdfs/file_cloud.c
 *
 * Copyright (c) 2023-2023 Huawei Device Co., Ltd.
 */

#include <linux/backing-dev.h>
#include <linux/file.h>
#include <linux/fs.h>
#include <linux/namei.h>
#include <linux/page-flags.h>
#include <linux/pagemap.h>
#include <linux/pagevec.h>
#include <linux/sched/signal.h>
#include <linux/slab.h>
#include <linux/wait.h>

#include "file_remote.h"

#include "comm/socket_adapter.h"
#include "hmdfs.h"
#include "hmdfs_client.h"
#include "hmdfs_dentryfile.h"
#include "hmdfs_dentryfile_cloud.h"
#include "hmdfs_trace.h"

static const struct vm_operations_struct hmdfs_cloud_vm_ops = {
	.fault = filemap_fault,
	.map_pages = filemap_map_pages,
	.page_mkwrite = NULL,
};

int hmdfs_file_open_cloud(struct inode *inode, struct file *file)
{
	const char *dir_path;
	struct hmdfs_sb_info *sbi = inode->i_sb->s_fs_info;
	struct path root_path;
	struct file *lower_file;
	int err = 0;

	struct hmdfs_file_info *gfi = kzalloc(sizeof(*gfi), GFP_KERNEL);
	if (!gfi)
		return -ENOMEM;

	if (!sbi->cloud_dir) {
		hmdfs_info("no cloud_dir");
		kfree(gfi);
		return -EPERM;
	}

	err = kern_path(sbi->cloud_dir, 0, &root_path);
	if (err) {
		hmdfs_info("kern_path failed: %d", err);
		kfree(gfi);
		return err;
	}

	dir_path = hmdfs_get_dentry_relative_path(file->f_path.dentry);
	if(!dir_path) {
		hmdfs_err("get cloud path failed");
		kfree(gfi);
		return -ENOENT;
	}

	lower_file = file_open_root(&root_path, dir_path,
			      file->f_flags | O_DIRECT, file->f_mode);
	path_put(&root_path);
	if (IS_ERR(lower_file)) {
		hmdfs_info("file_open_root failed: %ld", PTR_ERR(lower_file));
		err = PTR_ERR(lower_file);
		kfree(gfi);
	} else {
		gfi->lower_file = lower_file;
		file->private_data = gfi;
	}
	kfree(dir_path);
	return err;
}

int hmdfs_file_release_cloud(struct inode *inode, struct file *file)
{
	struct hmdfs_file_info *gfi = hmdfs_f(file);

	file->private_data = NULL;
	fput(gfi->lower_file);
	kfree(gfi);
	return 0;
}

static int hmdfs_file_flush_cloud(struct file *file, fl_owner_t id)
{
	struct hmdfs_file_info *gfi = hmdfs_f(file);

	if(!gfi || !gfi->lower_file)
		return 0;

	if (gfi->lower_file->f_op->flush)
		return gfi->lower_file->f_op->flush(gfi->lower_file, id);
	return 0;
}

int hmdfs_file_mmap_cloud(struct file *file, struct vm_area_struct *vma)
{
	struct hmdfs_file_info *private_data = file->private_data;
	struct file *realfile = NULL;
	int ret;

	if (!private_data)
		return -EINVAL;

	realfile = private_data->lower_file;
	if (!realfile)
		return -EINVAL;

	if (!realfile->f_op->mmap)
		return -ENODEV;

	if (WARN_ON(file != vma->vm_file))
		return -EIO;

	vma->vm_file = get_file(realfile);
	ret = call_mmap(vma->vm_file, vma);
	if (ret)
		fput(realfile);
	else
		fput(file);

	file_accessed(file);

	return ret;
}

static int hmdfs_do_readpages_cloud(struct file *filp, int cnt,
				    struct page **vec)
{
	struct hmdfs_file_info *gfi = filp->private_data;
	struct file *lower_filp;
	loff_t pos = (loff_t)(vec[0]->index) << HMDFS_PAGE_OFFSET;
	void *pages_buf = NULL;
	int idx, ret;

	if (gfi) {
		lower_filp = gfi->lower_file;
	}
	else {
		ret = -EINVAL;
		goto out_err;
	}

	pages_buf = vmap(vec, cnt, VM_MAP, PAGE_KERNEL);
	if (!pages_buf) {
		ret = -ENOMEM;
		goto out_err;
	}

	trace_hmdfs_do_readpages_cloud_begin(cnt, pos);
	ret = kernel_read(lower_filp, pages_buf, cnt * HMDFS_PAGE_SIZE, &pos);
	trace_hmdfs_do_readpages_cloud_end(cnt, pos, ret);

	if (ret >= 0)
		memset(pages_buf + ret, 0, cnt * HMDFS_PAGE_SIZE - ret);
	else
		goto out_err;

	vunmap(pages_buf);
	for (idx = 0; idx < cnt; ++idx) {
		SetPageUptodate(vec[idx]);
		unlock_page(vec[idx]);
	}
	goto out;

out_err:
	if (pages_buf)
		vunmap(pages_buf);
	for (idx = 0; idx < cnt; ++idx) {
		folio_clear_uptodate((struct folio *)vec[idx]);
		filemap_remove_folio((struct folio *)vec[idx]);
		unlock_page(vec[idx]);
		put_page(vec[idx]);
	}
out:
	return ret;
}

static void hmdfs_readahead(struct readahead_control *ractl)
{
	struct file *filp = ractl->file;
	struct address_space *mapping = ractl->mapping;
	unsigned int nr_pages = readahead_count(ractl);
	struct hmdfs_sb_info *sbi = hmdfs_sb(file_inode(filp)->i_sb);
	unsigned int ret = 0, idx, cnt, limit;
	unsigned long next_index;
	gfp_t gfp = readahead_gfp_mask(mapping);
	struct page **vec = NULL;

	limit = sbi->s_readpages_nr;
	vec = kmalloc(limit * sizeof(*vec), GFP_KERNEL);
	if (!vec) {
		hmdfs_warning("cannot alloc vec (%u pages)", limit);
		return;
	}

	cnt = 0;
	next_index = 0;
	for (idx = 0; idx < nr_pages; ++idx) {
		struct page *page = readahead_page(ractl);

		if (add_to_page_cache_lru(page, mapping, page->index, gfp)) {
			unlock_page(page);
			put_page(page);
			continue;
		}

		if (cnt && (cnt >= limit || page->index != next_index)) {
			ret = hmdfs_do_readpages_cloud(filp, cnt, vec);
			cnt = 0;
			if (ret)
				break;
		}
		next_index = page->index + 1;
		vec[cnt++] = page;
	}

	if (cnt)
		ret = hmdfs_do_readpages_cloud(filp, cnt, vec);

	kfree(vec);
	trace_hmdfs_readpages_cloud(nr_pages, ret);
	return;
}

static int hmdfs_readpage(struct file *file, struct page *page)
{
	loff_t offset = page_file_offset(page);
	int ret = -EACCES;
	char *page_buf;
	struct hmdfs_file_info *gfi = file->private_data;
	struct file *lower_file;

	if (gfi)
		lower_file = gfi->lower_file;
	else
		goto out;

	page_buf = kmap(page);
	if (!page_buf)
		goto out;
	ret = kernel_read(lower_file, page_buf, PAGE_SIZE, &offset);

	if (ret >= 0 && ret <= PAGE_SIZE) {
		ret = 0;
		memset(page_buf + ret, 0, PAGE_SIZE - ret);
	}

	kunmap(page);
	if (ret == 0)
		SetPageUptodate(page);
out:
	unlock_page(page);
	return ret;
}

static int hmdfs_read_folio(struct file *file, struct folio *folio)
{
	struct page *page = &folio->page;
	return hmdfs_readpage(file, page);
}

const struct file_operations hmdfs_dev_file_fops_cloud = {
	.owner = THIS_MODULE,
	.llseek = generic_file_llseek,
	.read_iter = generic_file_read_iter,
	.write_iter = NULL,
	.mmap = hmdfs_file_mmap_cloud,
	.open = hmdfs_file_open_cloud,
	.release = hmdfs_file_release_cloud,
	.flush = hmdfs_file_flush_cloud,
	.fsync = NULL,
	.splice_read = NULL,
	.splice_write = NULL,
};


const struct address_space_operations hmdfs_dev_file_aops_cloud = {
	.read_folio = hmdfs_read_folio,
	.readahead = hmdfs_readahead,
	.write_begin = NULL,
	.write_end = NULL,
	.writepage = NULL,
	.dirty_folio = NULL,
};

const struct address_space_operations hmdfs_aops_cloud = {
	.read_folio = hmdfs_read_folio,
	.readahead = hmdfs_readahead,
};

int analysis_dentry_file_from_cloud(struct hmdfs_sb_info *sbi,
				    struct file *file, struct file *handler,
				    struct dir_context *ctx)
{
	struct hmdfs_dentry_group_cloud *dentry_group = NULL;
	loff_t pos = ctx->pos;
	unsigned long dev_id = (unsigned long)((pos << 1) >> (POS_BIT_NUM - DEV_ID_BIT_NUM));
	unsigned long group_id = (unsigned long)((pos << (1 + DEV_ID_BIT_NUM)) >>
				 (POS_BIT_NUM - GROUP_ID_BIT_NUM));
	loff_t offset = pos & OFFSET_BIT_MASK;
	int group_num = 0;
	char *dentry_name = NULL;
	int iterate_result = 0;
	int i, j;

	dentry_group = kzalloc(sizeof(*dentry_group), GFP_KERNEL);

	if (!dentry_group)
		return -ENOMEM;

	if (IS_ERR_OR_NULL(handler)) {
		kfree(dentry_group);
		return -ENOENT;
	}

	group_num = get_dentry_group_cnt(file_inode(handler));
	dentry_name = kzalloc(DENTRY_NAME_MAX_LEN, GFP_KERNEL);
	if (!dentry_name) {
		kfree(dentry_group);
		return -ENOMEM;
	}

	for (i = group_id; i < group_num; i++) {
		int ret = hmdfs_metainfo_read_nocred(handler, dentry_group,
					      sizeof(struct hmdfs_dentry_group_cloud),
					      i);
		if (ret != sizeof(struct hmdfs_dentry_group_cloud)) {
			hmdfs_err("read dentry group failed ret:%d", ret);
			goto done;
		}

		for (j = offset; j < DENTRY_PER_GROUP_CLOUD; j++) {
			int len;
			int file_type = DT_UNKNOWN;
			bool is_continue;

			len = le16_to_cpu(dentry_group->nsl[j].namelen);
			if (!test_bit_le(j, dentry_group->bitmap) || len == 0)
				continue;

			memset(dentry_name, 0, DENTRY_NAME_MAX_LEN);
			if (S_ISDIR(le16_to_cpu(dentry_group->nsl[j].i_mode)))
				file_type = DT_DIR;
			else if (S_ISREG(le16_to_cpu(
					 dentry_group->nsl[j].i_mode)))
				file_type = DT_REG;

			strncat(dentry_name, dentry_group->filename[j], len);
			pos = hmdfs_set_pos(dev_id, i, j);
			is_continue =
				dir_emit(ctx, dentry_name, len,
					 pos + INUNUMBER_START, file_type);
			if (!is_continue) {
				ctx->pos = pos;
				iterate_result = 1;
				goto done;
			}
		}
		offset = 0;
	}

done:
	kfree(dentry_name);
	kfree(dentry_group);
	return iterate_result;
}

static int hmdfs_iterate_cloud(struct file *file, struct dir_context *ctx)
{
	int err = 0;
	loff_t start_pos = ctx->pos;

	if (ctx->pos == -1)
		return 0;
	err = analysis_dentry_file_from_cloud(
		file->f_inode->i_sb->s_fs_info, file, file->private_data, ctx);

	if (err <= 0)
		ctx->pos = -1;

	trace_hmdfs_iterate_remote(file->f_path.dentry, start_pos, ctx->pos,
				   err);
	return err;
}

int hmdfs_dir_open_cloud(struct inode *inode, struct file *file)
{
	struct clearcache_item *cache_item = NULL;

	get_cloud_cache_file(file->f_path.dentry, file->f_inode->i_sb->s_fs_info);
	cache_item = hmdfs_find_cache_item(CLOUD_DEVICE,
					   file->f_path.dentry);
	if (cache_item) {
		file->private_data = cache_item->filp;
		get_file(file->private_data);
		kref_put(&cache_item->ref, release_cache_item);
		return 0;
	}

	return -ENOENT;
}

static int hmdfs_dir_release_cloud(struct inode *inode, struct file *file)
{
	if (file->private_data)
		fput(file->private_data);
	file->private_data = NULL;
	return 0;
}

const struct file_operations hmdfs_dev_dir_ops_cloud = {
	.owner = THIS_MODULE,
	.iterate_shared = hmdfs_iterate_cloud,
	.open = hmdfs_dir_open_cloud,
	.release = hmdfs_dir_release_cloud,
	.fsync = __generic_file_fsync,
};