--- /dev/null
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+/*
+ * Ceph - scalable distributed file system
+ *
+ * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
+ *
+ * This is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License version 2.1, as published by the Free Software
+ * Foundation. See file COPYING.
+ *
+ */
+
+#include <sys/stat.h>
+#include <sys/utsname.h>
+#include <iostream>
+#include <string>
+using namespace std;
+
+#include "common/config.h"
+#include "common/errno.h"
+
+#include "client/Client.h"
+#include "client/fuse_ll.h"
+
+#include "msg/Messenger.h"
+
+#include "mon/MonClient.h"
+
+#include "common/Timer.h"
+#include "common/ceph_argparse.h"
+#if defined(__linux__)
+#include "common/linux_version.h"
+#endif
+#include "global/global_init.h"
+#include "global/signal_handler.h"
+#include "common/Preforker.h"
+#include "common/safe_io.h"
+
+#include <sys/types.h>
+#include <fcntl.h>
+
+#include <fuse.h>
+
+#define dout_context g_ceph_context
+
+static void fuse_usage()
+{
+ const char* argv[] = {
+ "ceph-fuse",
+ "-h",
+ };
+ struct fuse_args args = FUSE_ARGS_INIT(2, (char**)argv);
+ if (fuse_parse_cmdline(&args, NULL, NULL, NULL) == -1) {
+ derr << "fuse_parse_cmdline failed." << dendl;
+ }
+ assert(args.allocated);
+ fuse_opt_free_args(&args);
+}
+
+void usage()
+{
+ cout <<
+"usage: ceph-fuse [-n client.username] [-m mon-ip-addr:mon-port] <mount point> [OPTIONS]\n"
+" --client_mountpoint/-r <sub_directory>\n"
+" use sub_directory as the mounted root, rather than the full Ceph tree.\n"
+"\n";
+ fuse_usage();
+ generic_client_usage();
+}
+
+int main(int argc, const char **argv, const char *envp[]) {
+ int filer_flags = 0;
+ //cerr << "ceph-fuse starting " << myrank << "/" << world << std::endl;
+ std::vector<const char*> args;
+ argv_to_vec(argc, argv, args);
+ if (args.empty()) {
+ usage();
+ }
+ env_to_vec(args);
+
+ std::vector<const char*> def_args{"--pid-file="};
+
+ auto cct = global_init(&def_args, args, CEPH_ENTITY_TYPE_CLIENT,
+ CODE_ENVIRONMENT_DAEMON,
+ CINIT_FLAG_UNPRIVILEGED_DAEMON_DEFAULTS);
+ for (std::vector<const char*>::iterator i = args.begin(); i != args.end(); ) {
+ if (ceph_argparse_double_dash(args, i)) {
+ break;
+ } else if (ceph_argparse_flag(args, i, "--localize-reads", (char*)NULL)) {
+ cerr << "setting CEPH_OSD_FLAG_LOCALIZE_READS" << std::endl;
+ filer_flags |= CEPH_OSD_FLAG_LOCALIZE_READS;
+ } else if (ceph_argparse_flag(args, i, "-h", "--help", (char*)NULL)) {
+ usage();
+ } else {
+ ++i;
+ }
+ }
+
+ // args for fuse
+ const char **newargv;
+ int newargc;
+ vec_to_argv(argv[0], args, &newargc, &newargv);
+
+ // FUSE will chdir("/"); be ready.
+ g_ceph_context->_conf->set_val("chdir", "/");
+ g_ceph_context->_conf->apply_changes(NULL);
+
+ // check for 32-bit arch
+#ifndef __LP64__
+ cerr << std::endl;
+ cerr << "WARNING: Ceph inode numbers are 64 bits wide, and FUSE on 32-bit kernels does" << std::endl;
+ cerr << " not cope well with that situation. Expect to crash shortly." << std::endl;
+ cerr << std::endl;
+#endif
+
+ Preforker forker;
+ if (g_conf->daemonize) {
+ global_init_prefork(g_ceph_context);
+ int r;
+ string err;
+ r = forker.prefork(err);
+ if (r < 0 || forker.is_parent()) {
+ // Start log if current process is about to exit. Otherwise, we hit an assert
+ // in the Ceph context destructor.
+ g_ceph_context->_log->start();
+ }
+ if (r < 0) {
+ cerr << "ceph-fuse " << err << std::endl;
+ return r;
+ }
+ if (forker.is_parent()) {
+ r = forker.parent_wait(err);
+ if (r < 0) {
+ cerr << "ceph-fuse " << err << std::endl;
+ }
+ return r;
+ }
+ global_init_postfork_start(cct.get());
+ }
+
+ {
+ common_init_finish(g_ceph_context);
+
+ //cout << "child, mounting" << std::endl;
+ class RemountTest : public Thread {
+ public:
+ CephFuse *cfuse;
+ Client *client;
+ RemountTest() : cfuse(NULL), client(NULL) {}
+ void init(CephFuse *cf, Client *cl) {
+ cfuse = cf;
+ client = cl;
+ }
+ ~RemountTest() override {}
+ void *entry() override {
+#if defined(__linux__)
+ int ver = get_linux_version();
+ assert(ver != 0);
+ bool can_invalidate_dentries = g_conf->client_try_dentry_invalidate &&
+ ver < KERNEL_VERSION(3, 18, 0);
+ int tr = client->test_dentry_handling(can_invalidate_dentries);
+ if (tr != 0) {
+ cerr << "ceph-fuse[" << getpid()
+ << "]: fuse failed dentry invalidate/remount test with error "
+ << cpp_strerror(tr) << ", stopping" << std::endl;
+
+ char buf[5050];
+ string mountpoint = cfuse->get_mount_point();
+ snprintf(buf, sizeof(buf), "fusermount -u -z %s", mountpoint.c_str());
+ int umount_r = system(buf);
+ if (umount_r) {
+ if (umount_r != -1) {
+ if (WIFEXITED(umount_r)) {
+ umount_r = WEXITSTATUS(umount_r);
+ cerr << "got error " << umount_r
+ << " when unmounting Ceph on failed remount test!" << std::endl;
+ } else {
+ cerr << "attempt to umount on failed remount test failed (on a signal?)" << std::endl;
+ }
+ } else {
+ cerr << "system() invocation failed during remount test" << std::endl;
+ }
+ }
+ }
+ return reinterpret_cast<void*>(tr);
+#else
+ return reinterpret_cast<void*>(0);
+#endif
+ }
+ } tester;
+
+
+ // get monmap
+ Messenger *messenger = NULL;
+ StandaloneClient *client;
+ CephFuse *cfuse;
+ UserPerm perms;
+ int tester_r = 0;
+ void *tester_rp = NULL;
+
+ MonClient *mc = new MonClient(g_ceph_context);
+ int r = mc->build_initial_monmap();
+ if (r == -EINVAL)
+ usage();
+ if (r < 0)
+ goto out_mc_start_failed;
+
+ // start up network
+ messenger = Messenger::create_client_messenger(g_ceph_context, "client");
+ messenger->set_default_policy(Messenger::Policy::lossy_client(0));
+ messenger->set_policy(entity_name_t::TYPE_MDS,
+ Messenger::Policy::lossless_client(0));
+
+ client = new StandaloneClient(messenger, mc);
+ if (filer_flags) {
+ client->set_filer_flags(filer_flags);
+ }
+
+ cfuse = new CephFuse(client, forker.get_signal_fd());
+
+ r = cfuse->init(newargc, newargv);
+ if (r != 0) {
+ cerr << "ceph-fuse[" << getpid() << "]: fuse failed to initialize" << std::endl;
+ goto out_messenger_start_failed;
+ }
+
+ cerr << "ceph-fuse[" << getpid() << "]: starting ceph client" << std::endl;
+ r = messenger->start();
+ if (r < 0) {
+ cerr << "ceph-fuse[" << getpid() << "]: ceph messenger failed with " << cpp_strerror(-r) << std::endl;
+ goto out_messenger_start_failed;
+ }
+
+ init_async_signal_handler();
+ register_async_signal_handler(SIGHUP, sighup_handler);
+
+ // start client
+ r = client->init();
+ if (r < 0) {
+ cerr << "ceph-fuse[" << getpid() << "]: ceph client failed with " << cpp_strerror(-r) << std::endl;
+ goto out_init_failed;
+ }
+
+ client->update_metadata("mount_point", cfuse->get_mount_point());
+ perms = client->pick_my_perms();
+ // start up fuse
+ // use my argc, argv (make sure you pass a mount point!)
+ r = client->mount(g_conf->client_mountpoint.c_str(), perms,
+ g_ceph_context->_conf->fuse_require_active_mds);
+ if (r < 0) {
+ if (r == CEPH_FUSE_NO_MDS_UP)
+ cerr << "ceph-fuse[" << getpid() << "]: probably no MDS server is up?" << std::endl;
+ cerr << "ceph-fuse[" << getpid() << "]: ceph mount failed with " << cpp_strerror(-r) << std::endl;
+ goto out_shutdown;
+ }
+
+ r = cfuse->start();
+ if (r != 0) {
+ cerr << "ceph-fuse[" << getpid() << "]: fuse failed to start" << std::endl;
+ goto out_client_unmount;
+ }
+
+ cerr << "ceph-fuse[" << getpid() << "]: starting fuse" << std::endl;
+ tester.init(cfuse, client);
+ tester.create("tester");
+ r = cfuse->loop();
+ tester.join(&tester_rp);
+ tester_r = static_cast<int>(reinterpret_cast<uint64_t>(tester_rp));
+ cerr << "ceph-fuse[" << getpid() << "]: fuse finished with error " << r
+ << " and tester_r " << tester_r <<std::endl;
+
+
+ out_client_unmount:
+ client->unmount();
+ cfuse->finalize();
+ out_shutdown:
+ client->shutdown();
+ out_init_failed:
+ unregister_async_signal_handler(SIGHUP, sighup_handler);
+ shutdown_async_signal_handler();
+
+ // wait for messenger to finish
+ messenger->shutdown();
+ messenger->wait();
+ out_messenger_start_failed:
+ delete cfuse;
+ delete client;
+ delete messenger;
+ out_mc_start_failed:
+ free(newargv);
+ delete mc;
+ //cout << "child done" << std::endl;
+ return forker.signal_exit(r);
+ }
+}
+
Code Review / stor4nfv.git / blobdiff