Skip to content

Commit

Permalink
Refactor fuse low level implementation (baidu#654)
Browse files Browse the repository at this point in the history 
* Refactor fuse low level implementation

* Refactor fuse low level implementation

* Refactor fuse low level implementation
  • Loading branch information
@cyshi
cyshi authored and Yang Ce committed Dec 1, 2016
1 parent 1c1b3f9 commit 56a2b71
Showing 1 changed file with 101 additions and 66 deletions.
167 changes: 101 additions & 66 deletions fuse_lowlevel/bfs_ll_mount.cc
View file
Original file line number Diff line number Diff line change
@@ -1,87 +1,109 @@
#include <fuse_lowlevel.h>
// Copyright (c) 2016, Baidu.com, Inc. All Rights Reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include <stdio.h>
#include <string.h>
#include <assert.h>
#include <errno.h>
#include <fcntl.h>
#include <unistd.h>
#include <algorithm>

#include <fuse_lowlevel.h>

#include <sdk/bfs.h>

baidu::bfs::FS* g_fs;
// not used
// baidu::bfs::FS* g_fs;
std::string g_bfs_path;
std::string g_bfs_cluster;

#define BFS "\e[0;32m[BFS]\e[0m "

static void bfs_ll_getattr(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi){
static void bfs_ll_getattr(fuse_req_t req, fuse_ino_t ino,
struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s\n", __func__);
}

static void bfs_ll_lookup(fuse_req_t req, fuse_ino_t parent, const char *name){
static void bfs_ll_lookup(fuse_req_t req, fuse_ino_t parent, const char *name) {
fprintf(stderr, BFS"%s(%s)\n", __func__, name);
}

static void bfs_ll_readdir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, struct fuse_file_info *fi){
static void bfs_ll_readdir(fuse_req_t req, fuse_ino_t ino,
size_t size, off_t off, struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s\n", __func__);
}

static void bfs_ll_open(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi){
static void bfs_ll_open(fuse_req_t req, fuse_ino_t ino,
struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s\n", __func__);
}

static void bfs_ll_opendir(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi){
static void bfs_ll_opendir(fuse_req_t req, fuse_ino_t ino,
struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s\n", __func__);
}

static void bfs_ll_read(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, struct fuse_file_info *fi){
static void bfs_ll_read(fuse_req_t req, fuse_ino_t ino,
size_t size, off_t off, struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s(size:%lu, off:%ld)\n", __func__, size, off);
}

static void bfs_ll_write(fuse_req_t req, fuse_ino_t ino, const char *buf, size_t size, off_t off, struct fuse_file_info *fi){
static void bfs_ll_write(fuse_req_t req, fuse_ino_t ino, const char *buf,
size_t size, off_t off, struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s(size:%lu, off:%ld)\n", __func__, size, off);
}
static void bfs_ll_mknod(fuse_req_t req, fuse_ino_t parent, const char *name, mode_t mode, dev_t dev){

static void bfs_ll_mknod(fuse_req_t req, fuse_ino_t parent,
const char *name, mode_t mode, dev_t dev) {
fprintf(stderr, BFS"%s(%s)\n", __func__, name);
}

static void bfs_ll_mkdir(fuse_req_t req, fuse_ino_t parent, const char *name, mode_t mode){
static void bfs_ll_mkdir(fuse_req_t req, fuse_ino_t parent,
const char *name, mode_t mode) {
fprintf(stderr, BFS"%s(%s)\n", __func__, name);
}

static void bfs_ll_create(fuse_req_t req, fuse_ino_t parent, const char *name, mode_t mode, struct fuse_file_info *fi){
static void bfs_ll_create(fuse_req_t req, fuse_ino_t parent,
const char *name, mode_t mode,
struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s(%s)\n", __func__, name);
}

static void bfs_ll_statfs(fuse_req_t req, fuse_ino_t ino){
fprintf(stderr, BFS"%s\n", __func__);
}

static void bfs_ll_rename(fuse_req_t req, fuse_ino_t sparent, const char *sname, fuse_ino_t tparent, const char *tname){
static void bfs_ll_rename(fuse_req_t req, fuse_ino_t sparent,
const char *sname, fuse_ino_t tparent,
const char *tname) {
fprintf(stderr, BFS"%s(source name:%s, target name:%s)\n", __func__, sname, tname);
}

static void bfs_ll_link(fuse_req_t req, fuse_ino_t ino, fuse_ino_t tparent, const char *tname){
static void bfs_ll_link(fuse_req_t req, fuse_ino_t ino, fuse_ino_t tparent, const char *tname) {
fprintf(stderr, BFS"%s(target name:%s)\n", __func__, tname);
}

static void bfs_ll_unlink(fuse_req_t req, fuse_ino_t parent, const char *name){
static void bfs_ll_unlink(fuse_req_t req, fuse_ino_t parent, const char *name) {
fprintf(stderr, BFS"%s(%s)\n", __func__, name);
}

static void bfs_ll_rmdir(fuse_req_t req, fuse_ino_t parent, const char *name){
static void bfs_ll_rmdir(fuse_req_t req, fuse_ino_t parent, const char *name) {
fprintf(stderr, BFS"%s(%s)\n", __func__, name);
}

static void bfs_ll_fsync(fuse_req_t req, fuse_ino_t ino, int datasync, struct fuse_file_info *fi){
static void bfs_ll_fsync(fuse_req_t req, fuse_ino_t ino,
int datasync, struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s\n", __func__);
}

static void bfs_ll_fsyncdir(fuse_req_t req, fuse_ino_t ino, int datasync, struct fuse_file_info *fi){
static void bfs_ll_fsyncdir(fuse_req_t req, fuse_ino_t ino,
int datasync, struct fuse_file_info *fi) {
fprintf(stderr, BFS"%s\n", __func__);
}

static void bfs_ll_access(fuse_req_t req, fuse_ino_t ino, int mask){
static void bfs_ll_access(fuse_req_t req, fuse_ino_t ino, int mask) {
fprintf(stderr, BFS"%s\n", __func__);
}

Expand All @@ -98,7 +120,7 @@ int parse_bfs_args(int* argc, char* argv[]) {
"Example:\n"
" %s /mnt/bfs -d -c 127.0.0.1:8827 -p /\n",
argv[0]);
return 1;
return -1;
}

for (int i = 1; i + 1 < *argc; i++) {
Expand All @@ -123,55 +145,68 @@ int parse_bfs_args(int* argc, char* argv[]) {

int main(int argc, char *argv[])
{
static struct fuse_lowlevel_ops ll_oper;
ll_oper.lookup = bfs_ll_lookup;
ll_oper.getattr = bfs_ll_getattr;
ll_oper.readdir = bfs_ll_readdir;
ll_oper.open = bfs_ll_open;
ll_oper.opendir = bfs_ll_opendir;
ll_oper.read = bfs_ll_read;
ll_oper.write = bfs_ll_write;
ll_oper.mknod = bfs_ll_mknod;
ll_oper.mkdir = bfs_ll_mkdir;
ll_oper.create = bfs_ll_create;
ll_oper.statfs = bfs_ll_statfs;
ll_oper.rename = bfs_ll_rename;
ll_oper.link = bfs_ll_link;
ll_oper.unlink = bfs_ll_unlink;
ll_oper.rmdir = bfs_ll_rmdir;
ll_oper.fsync = bfs_ll_fsync;
ll_oper.fsyncdir = bfs_ll_fsyncdir;
ll_oper.access = bfs_ll_access;

if(parse_bfs_args(&argc, argv)) {
return 1;
static struct fuse_lowlevel_ops ll_oper = {
.lookup = bfs_ll_lookup;
.getattr = bfs_ll_getattr;
.readdir = bfs_ll_readdir;
.open = bfs_ll_open;
.opendir = bfs_ll_opendir;
.read = bfs_ll_read;
.write = bfs_ll_write;
.mknod = bfs_ll_mknod;
.mkdir = bfs_ll_mkdir;
.create = bfs_ll_create;
.statfs = bfs_ll_statfs;
.rename = bfs_ll_rename;
.link = bfs_ll_link;
.unlink = bfs_ll_unlink;
.rmdir = bfs_ll_rmdir;
.fsync = bfs_ll_fsync;
.fsyncdir = bfs_ll_fsyncdir;
.access = bfs_ll_access;
};

if (parse_bfs_args(&argc, argv) != 0) {
return -1;
}

struct fuse_args args = FUSE_ARGS_INIT(argc, argv);
struct fuse_chan *ch = NULL;
char *mountpoint;
int err = 1;

if (fuse_parse_cmdline(&args, &mountpoint, NULL, NULL) != -1) {
ch = fuse_mount(mountpoint, &args);
if(ch != NULL) {
struct fuse_session *se;

se = fuse_lowlevel_new(&args, &ll_oper,
sizeof(ll_oper), NULL);
if (se != NULL) {
if (fuse_set_signal_handlers(se) != -1) {
fprintf(stderr, BFS"fuse_set_signal_handlers success.");
fuse_session_add_chan(se, ch);
err = fuse_session_loop(se);
fuse_remove_signal_handlers(se);
fuse_session_remove_chan(ch);
}
fuse_session_destroy(se);
}
fuse_unmount(mountpoint, ch);
}
char *mountpoint = NULL;

int err = 0;
if ((err = fuse_parse_cmdline(&args, &mountpoint, NULL, NULL)) != 0) {
fprintf(stderr, "fuse parse command line arguments error ret=%d\n", err);
return -1;
}

struct fuse_chan* ch = fuse_mount(mountpoint, &args);
if (ch == NULL) {
fprintf(stderr, "fuse mount error\n");
return -1;
}

struct fuse_session* se =
fuse_lowlevel_new(&args, &ll_oper, sizeof(ll_oper), NULL);
if (se == NULL) {
fprintf(stderr, "fuse lowlevel new session error\n");
return -1;
}

if ((err = fuse_set_signal_handlers(se)) != 0) {
fprintf(stderr, "fuse set signal handlers error ret=%d\n", err);
return -1;
}

fprintf(stderr, BFS"fuse_set_signal_handlers success.");
fuse_session_add_chan(se, ch);

err = fuse_session_loop(se);

fuse_remove_signal_handlers(se);
fuse_session_remove_chan(ch);
fuse_session_destroy(se);
fuse_unmount(mountpoint, ch);
fuse_opt_free_args(&args);

return err ? 1 : 0;
return err;
}

0 comments on commit 56a2b71

Please sign in to comment.