kfs_fuse_main.cc

nandflash文件系统源代码

//---------------------------------------------------------- -*- Mode: C++ -*-
// $Id: kfs_fuse_main.cc 223 2008-11-25 22:27:35Z sriramsrao $ 
//
// Created 2006/11/01
// Author: Blake Lewis (Kosmix Corp.)
//
// Copyright 2006 Kosmix Corp.
//
// This file is part of Kosmos File System (KFS).
//
// 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.
// 
//----------------------------------------------------------------------------

#include "libkfsClient/KfsClient.h"

extern "C" {
#define FUSE_USE_VERSION	25
#define _FILE_OFFSET_BITS	64
#include <fuse.h>
#include <sys/stat.h>
#include <string.h>
}

using std::vector;
using namespace KFS;

static char *FUSE_KFS_PROPERTIES = "./kfs.prp";
static KFS::KfsClientPtr client;

void *
fuse_init()
{
	client = getKfsClientFactory()->GetClient(FUSE_KFS_PROPERTIES);
	return client->IsInitialized() ? client.get() : NULL;
}

void
fuse_destroy(void *cookie)
{
	client.reset();
}

static int
fuse_getattr(const char *path, struct stat *s)
{
	return client->Stat(path, *s);
}

static int
fuse_mkdir(const char *path, mode_t mode)
{
	return client->Mkdir(path);
}

static int
fuse_unlink(const char *path)
{
	return client->Remove(path);
}

static int
fuse_rmdir(const char *path)
{
	return client->Rmdir(path);
}

static int
fuse_rename(const char *src, const char *dst)
{
	return client->Rename(src, dst, false);
}

static int
fuse_truncate(const char *path, off_t size)
{
	int fd = client->Open(path, O_WRONLY);
	if (fd < 0)
		return fd;
	int status = client->Truncate(fd, size);
	client->Close(fd);
	return status;
}

static int
fuse_open(const char *path, struct fuse_file_info *finfo)
{
	int res = client->Open(path, finfo->flags);
	if (res < 0)
		return res;
	finfo->fh = res;
	return 0;
}

static int
fuse_release(const char *path, struct fuse_file_info *finfo)
{
	int res = finfo->fh;
	client->Close(res);
	finfo->fh = -1;
	return 0;
}

static int
fuse_create(const char *path, mode_t mode, struct fuse_file_info *finfo)
{
	int res = client->Open(path, finfo->flags);
	if (res < 0)
		return res;
	finfo->fh = res;
	return 0;
}

static int
fuse_read(const char *path, char *buf, size_t nread, off_t off,
		struct fuse_file_info *finfo)
{
	int fd = finfo->fh;
	if (fd < 0)
		return fd;
	client->Seek(fd, off);
	int status = client->Read(fd, buf, nread);
	return status;
}

static int
fuse_write(const char *path, const char *buf, size_t nwrite, off_t off,
		struct fuse_file_info *finfo)
{
	int fd = finfo->fh;
	if (fd < 0)
		return fd;
	client->Seek(fd, off);
	int status = client->Write(fd, buf, nwrite);
	return status;
}

static int
fuse_flush(const char *path, struct fuse_file_info *finfo)
{
	int fd = finfo->fh;
	//int fd = client->Fileno(path);
	if (fd < 0)
		return fd;
	return client->Sync(fd);
}

static int
fuse_fsync(const char *path, int flags, struct fuse_file_info *finfo)
{
	int fd = finfo->fh;
	//int fd = client->Fileno(path);
	if (fd < 0)
		return fd;
	return client->Sync(fd);
}

static int
fuse_readdir(const char *path, void *buf,
		fuse_fill_dir_t filler, off_t offset,
		struct fuse_file_info *finfo)
{
	vector <KfsFileAttr> contents;
	int status = client->ReaddirPlus(path, contents);
	if (status < 0)
		return status;
	int n = contents.size();
	for (int i = 0; i != n; i++) {
		struct stat s;
		memset(&s, 0, sizeof s);
		s.st_ino = contents[i].fileId;
		s.st_mode = contents[i].isDirectory ? S_IFDIR : S_IFREG;
		if (filler(buf, contents[i].filename.c_str(), &s, 0) != 0)
			break;
	}
	return 0;
}

struct fuse_operations ops = {
	fuse_getattr,
	NULL,			/* readlink */
	NULL,			/* getdir */
	NULL,			/* mknod */
	fuse_mkdir,
	fuse_unlink,
	fuse_rmdir,
	NULL,			/* symlink */
	fuse_rename,
	NULL,			/* link */
	NULL,			/* chmod */
	NULL,			/* chown */
	fuse_truncate,
	NULL,			/* utime */
	fuse_open,
	fuse_read,
	fuse_write,
	NULL,			/* statfs */
	fuse_flush,		/* flush */
	fuse_release,		/* release */
	fuse_fsync,		/* fsync */
	NULL,			/* setxattr */
	NULL,			/* getxattr */
	NULL,			/* listxattr */
	NULL,			/* removexattr */
	NULL,			/* opendir */
	fuse_readdir,
	NULL,			/* releasedir */
	NULL,			/* fsyncdir */
	fuse_init,
	fuse_destroy,
	NULL,			/* access */
	fuse_create,		/* create */
	NULL,			/* ftruncate */
	NULL			/* fgetattr */
};

int
main(int argc, char **argv)
{
	return fuse_main(argc, argv, &ops);
}