+++ /dev/null
-// -*- mode:C++; tab-width:8; c-basic-offset:4; indent-tabs-mode:t -*-
-// vim: ts=8 sw=4 smarttab
-
-/*
- FUSE: Filesystem in Userspace
- Copyright (C) 2001-2007 Miklos Szeredi <miklos@szeredi.hu>
-
- This program can be distributed under the terms of the GNU GPL.
- See the file COPYING.
-
- gcc -Wall `pkg-config fuse --cflags --libs` -lulockmgr fusexmp_fh.c -o fusexmp_fh
-*/
-
-#define FUSE_USE_VERSION 26
-
-#ifdef HAVE_CONFIG_H
-#include <config.h>
-#endif
-
-#define _GNU_SOURCE
-
-#include <fuse.h>
-#include <ulockmgr.h>
-#include <stdio.h>
-#include <string.h>
-#include <unistd.h>
-#include <fcntl.h>
-#include <dirent.h>
-#include <errno.h>
-#include <sys/time.h>
-#ifdef HAVE_SETXATTR
-#include <sys/xattr.h>
-#endif
-
-
-#include <ext/hash_map>
-using namespace __gnu_cxx;
-
-#include <iostream>
-#include <fstream>
-using namespace std;
-
-#include "common/Mutex.h"
-
-Mutex trace_lock;
-fstream traceout;
-
-const char *basedir = 0;
-
-
-static int ft_getattr(const char *path, struct stat *stbuf)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "getattr" << endl << path << endl;
- trace_lock.Unlock();
-
- res = lstat(path, stbuf);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_fgetattr(const char *path, struct stat *stbuf,
- struct fuse_file_info *fi)
-{
- int res;
-
- (void) path;
-
- trace_lock.Lock();
- traceout << "fgetattr" << endl << fi->fh << endl;
- trace_lock.Unlock();
-
- res = fstat(fi->fh, stbuf);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_access(const char *path, int mask)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "access" << endl << path << endl;
- trace_lock.Unlock();
-
- res = access(path, mask);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_readlink(const char *path, char *buf, size_t size)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "readlink" << endl << path << endl;
- trace_lock.Unlock();
-
- res = readlink(path, buf, size - 1);
- if (res == -1)
- return -errno;
-
- buf[res] = '\0';
- return 0;
-}
-
-static int ft_opendir(const char *path, struct fuse_file_info *fi)
-{
- DIR *dp = opendir(path);
- if (dp == NULL)
- return -errno;
-
- fi->fh = (unsigned long) dp;
-
- trace_lock.Lock();
- traceout << "opendir" << endl << path << endl << fi->fh << endl;
- trace_lock.Unlock();
-
- return 0;
-}
-
-static inline DIR *get_dirp(struct fuse_file_info *fi)
-{
- return (DIR *) (uintptr_t) fi->fh;
-}
-
-static int ft_readdir(const char *path, void *buf, fuse_fill_dir_t filler,
- off_t offset, struct fuse_file_info *fi)
-{
- DIR *dp = get_dirp(fi);
- struct dirent *de;
-
- (void) path;
- seekdir(dp, offset);
- while ((de = readdir(dp)) != NULL) {
- struct stat st;
- memset(&st, 0, sizeof(st));
- st.st_ino = de->d_ino;
- st.st_mode = de->d_type << 12;
- if (filler(buf, de->d_name, &st, telldir(dp)))
- break;
- }
-
- trace_lock.Lock();
- traceout << "readdir" << endl << fi->fh << endl;
- trace_lock.Unlock();
-
- return 0;
-}
-
-static int ft_releasedir(const char *path, struct fuse_file_info *fi)
-{
- DIR *dp = get_dirp(fi);
- (void) path;
- closedir(dp);
-
- trace_lock.Lock();
- traceout << "releasedir" << endl << fi->fh << endl;
- trace_lock.Unlock();
-
- return 0;
-}
-
-static int ft_mknod(const char *path, mode_t mode, dev_t rdev)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "mknod" << endl << path << endl << mode << endl << rdev << endl;
- trace_lock.Unlock();
-
- if (S_ISFIFO(mode))
- res = mkfifo(path, mode);
- else
- res = mknod(path, mode, rdev);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_mkdir(const char *path, mode_t mode)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "mkdir" << endl << path << endl << mode << endl;
- trace_lock.Unlock();
-
- res = mkdir(path, mode);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_unlink(const char *path)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "unlink" << endl << path << endl;
- trace_lock.Unlock();
-
- res = unlink(path);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_rmdir(const char *path)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "rmdir" << endl << path << endl;
- trace_lock.Unlock();
-
- res = rmdir(path);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_symlink(const char *from, const char *to)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "symlink" << endl << from << endl << to << endl;
- trace_lock.Unlock();
-
- res = symlink(from, to);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_rename(const char *from, const char *to)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "rename" << endl << from << endl << to << endl;
- trace_lock.Unlock();
-
- res = rename(from, to);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_link(const char *from, const char *to)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "link" << endl << from << endl << to << endl;
- trace_lock.Unlock();
-
- res = link(from, to);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_chmod(const char *path, mode_t mode)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "chmod" << endl << path << endl << mode << endl;
- trace_lock.Unlock();
-
- res = chmod(path, mode);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_chown(const char *path, uid_t uid, gid_t gid)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "chown" << endl << path << endl << uid << endl << gid << endl;
- trace_lock.Unlock();
-
- res = lchown(path, uid, gid);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_truncate(const char *path, off_t size)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "truncate" << endl << path << endl << size << endl;
- trace_lock.Unlock();
-
- res = truncate(path, size);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_ftruncate(const char *path, off_t size,
- struct fuse_file_info *fi)
-{
- int res;
-
- (void) path;
-
- trace_lock.Lock();
- traceout << "ftruncate" << endl << fi->fh << endl << size << endl;
- trace_lock.Unlock();
-
- res = ftruncate(fi->fh, size);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_utimens(const char *path, const struct timespec ts[2])
-{
- int res;
- struct timeval tv[2];
-
- trace_lock.Lock();
- traceout << "utimens" << endl << path
- << tv[0].tv_sec << endl << tv[0].tv_usec << endl
- << tv[1].tv_sec << endl << tv[1].tv_usec << endl;
- trace_lock.Unlock();
-
- tv[0].tv_sec = ts[0].tv_sec;
- tv[0].tv_usec = ts[0].tv_nsec / 1000;
- tv[1].tv_sec = ts[1].tv_sec;
- tv[1].tv_usec = ts[1].tv_nsec / 1000;
-
- res = utimes(path, tv);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_create(const char *path, mode_t mode, struct fuse_file_info *fi)
-{
- int fd;
-
- trace_lock.Lock();
- traceout << "create" << endl << path << endl << mode << endl << fi->flags << endl;
- trace_lock.Unlock();
-
- fd = open(path, fi->flags, mode);
- if (fd == -1)
- return -errno;
-
- fi->fh = fd;
- return 0;
-}
-
-static int ft_open(const char *path, struct fuse_file_info *fi)
-{
- int fd;
-
- fd = open(path, fi->flags);
-
- trace_lock.Lock();
- traceout << "open" << endl << path << endl << fi->flags << endl << (fd > 0 ? fd:0) << endl;
- trace_lock.Unlock();
-
- if (fd == -1)
- return -errno;
-
- fi->fh = fd;
- return 0;
-}
-
-static int ft_read(const char *path, char *buf, size_t size, off_t offset,
- struct fuse_file_info *fi)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "read" << endl << fi->fh << endl << offset << endl << size << endl;
- trace_lock.Unlock();
-
- (void) path;
- res = pread(fi->fh, buf, size, offset);
- if (res == -1)
- res = -errno;
-
- return res;
-}
-
-static int ft_write(const char *path, const char *buf, size_t size,
- off_t offset, struct fuse_file_info *fi)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "write" << endl << fi->fh << endl << offset << endl << size << endl;
- trace_lock.Unlock();
-
- (void) path;
- res = pwrite(fi->fh, buf, size, offset);
- if (res == -1)
- res = -errno;
-
- return res;
-}
-
-static int ft_statfs(const char *path, struct statvfs *stbuf)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "statfs" << endl << path << endl;
- trace_lock.Unlock();
-
- res = statvfs(path, stbuf);
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_flush(const char *path, struct fuse_file_info *fi)
-{
- int res;
-
- trace_lock.Lock();
- traceout << "flush" << endl << fi->fh << endl;
- trace_lock.Unlock();
-
- (void) path;
- /* This is called from every close on an open file, so call the
- close on the underlying filesystem. But since flush may be
- called multiple times for an open file, this must not really
- close the file. This is important if used on a network
- filesystem like NFS which flush the data/metadata on close() */
- res = close(dup(fi->fh));
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-static int ft_release(const char *path, struct fuse_file_info *fi)
-{
- (void) path;
- close(fi->fh);
-
- trace_lock.Lock();
- traceout << "release" << endl << fi->fh << endl;
- trace_lock.Unlock();
-
- return 0;
-}
-
-static int ft_fsync(const char *path, int isdatasync,
- struct fuse_file_info *fi)
-{
- int res;
- (void) path;
-
-#ifndef HAVE_FDATASYNC
- (void) isdatasync;
-#else
- if (isdatasync)
- res = fdatasync(fi->fh);
- else
-#endif
- res = fsync(fi->fh);
-
- trace_lock.Lock();
- traceout << "fsync" << endl << fi->fh << endl << isdatasync << endl;
- trace_lock.Unlock();
-
- if (res == -1)
- return -errno;
-
- return 0;
-}
-
-#ifdef HAVE_SETXATTR
-/* xattr operations are optional and can safely be left unimplemented */
-static int ft_setxattr(const char *path, const char *name, const char *value,
- size_t size, int flags)
-{
- int res = lsetxattr(path, name, value, size, flags);
- if (res == -1)
- return -errno;
- return 0;
-}
-
-static int ft_getxattr(const char *path, const char *name, char *value,
- size_t size)
-{
- int res = lgetxattr(path, name, value, size);
- if (res == -1)
- return -errno;
- return res;
-}
-
-static int ft_listxattr(const char *path, char *list, size_t size)
-{
- int res = llistxattr(path, list, size);
- if (res == -1)
- return -errno;
- return res;
-}
-
-static int ft_removexattr(const char *path, const char *name)
-{
- int res = lremovexattr(path, name);
- if (res == -1)
- return -errno;
- return 0;
-}
-#endif /* HAVE_SETXATTR */
-
-static int ft_lock(const char *path, struct fuse_file_info *fi, int cmd,
- struct flock *lock)
-{
- (void) path;
-
- /*
- trace_lock.Lock();
- traceout << "fsync" << endl << fi->fh << endl << isdatasync << endl;
- trace_lock.Unlock();
- */
- return ulockmgr_op(fi->fh, cmd, lock, &fi->lock_owner,
- sizeof(fi->lock_owner));
-}
-
-static struct fuse_operations ft_oper = {
- .getattr = ft_getattr,
- .fgetattr = ft_fgetattr,
- //.access = ft_access,
- .readlink = ft_readlink,
- .opendir = ft_opendir,
- .readdir = ft_readdir,
- .releasedir = ft_releasedir,
- .mknod = ft_mknod,
- .mkdir = ft_mkdir,
- .symlink = ft_symlink,
- .unlink = ft_unlink,
- .rmdir = ft_rmdir,
- .rename = ft_rename,
- .link = ft_link,
- .chmod = ft_chmod,
- .chown = ft_chown,
- .truncate = ft_truncate,
- .ftruncate = ft_ftruncate,
- .utimens = ft_utimens,
- .create = ft_create,
- .open = ft_open,
- .read = ft_read,
- .write = ft_write,
- .statfs = ft_statfs,
- .flush = ft_flush,
- .release = ft_release,
- .fsync = ft_fsync,
-#ifdef HAVE_SETXATTR
- .setxattr = ft_setxattr,
- .getxattr = ft_getxattr,
- .listxattr = ft_listxattr,
- .removexattr= ft_removexattr,
-#endif
- .lock = ft_lock,
-};
-
-int main(int argc, char *argv[])
-{
- // open trace
-
-
- umask(0);
- return fuse_main(argc, argv, &ft_oper, NULL);
-}
projects / ceph.git / commitdiff