+++ /dev/null
-#include <stdio.h>
-#include <string.h>
-#include <stdlib.h>
-#include <errno.h>
-#include <sys/mount.h>
-
-#include "common/module.h"
-#include "common/secret.h"
-#include "include/addr_parsing.h"
-
-#ifndef MS_RELATIME
-# define MS_RELATIME (1<<21)
-#endif
-
-#define MAX_SECRET_LEN 1000
-#define MAX_SECRET_OPTION_LEN (MAX_SECRET_LEN + 7)
-
-int verboseflag = 0;
-int skip_mtab_flag = 0;
-static const char * const EMPTY_STRING = "";
-
-/* TODO duplicates logic from kernel */
-#define CEPH_AUTH_NAME_DEFAULT "guest"
-
-#include "mtab.c"
-
-static void block_signals (int how)
-{
- sigset_t sigs;
-
- sigfillset (&sigs);
- sigdelset(&sigs, SIGTRAP);
- sigdelset(&sigs, SIGSEGV);
- sigprocmask (how, &sigs, (sigset_t *) 0);
-}
-
-static char *mount_resolve_src(const char *orig_str)
-{
- int len, pos;
- char *mount_path;
- char *src;
- char *buf = strdup(orig_str);
-
- mount_path = strstr(buf, ":/");
- if (!mount_path) {
- printf("source mount path was not specified\n");
- free(buf);
- return NULL;
- }
- if (mount_path == buf) {
- printf("server address expected\n");
- free(buf);
- return NULL;
- }
-
- *mount_path = '\0';
- mount_path++;
-
- if (!*mount_path) {
- printf("incorrect source mount path\n");
- free(buf);
- return NULL;
- }
-
- src = resolve_addrs(buf);
- if (!src) {
- free(buf);
- return NULL;
- }
-
- len = strlen(src);
- pos = safe_cat(&src, &len, len, ":");
- safe_cat(&src, &len, pos, mount_path);
-
- free(buf);
- return src;
-}
-
-/*
- * this one is partialy based on parse_options() from cifs.mount.c
- */
-static char *parse_options(const char *data, int *filesys_flags)
-{
- char * next_keyword = NULL;
- char * out = NULL;
- int out_len = 0;
- int pos = 0;
- char *name = NULL;
- int name_len = 0;
- int name_pos = 0;
- char secret[MAX_SECRET_LEN];
- char *saw_name = NULL;
- char *saw_secret = NULL;
-
- if(verboseflag)
- printf("parsing options: %s\n", data);
-
- do {
- char * value = NULL;
- /* check if ends with trailing comma */
- if(*data == 0)
- break;
- next_keyword = strchr(data,',');
-
- /* temporarily null terminate end of keyword=value pair */
- if(next_keyword)
- *next_keyword++ = 0;
-
- /* temporarily null terminate keyword to make keyword and value distinct */
- if ((value = strchr(data, '=')) != NULL) {
- *value = '\0';
- value++;
- }
-
- int skip = 1;
-
- if (strncmp(data, "ro", 2) == 0) {
- *filesys_flags |= MS_RDONLY;
- } else if (strncmp(data, "rw", 2) == 0) {
- *filesys_flags &= ~MS_RDONLY;
- } else if (strncmp(data, "nosuid", 6) == 0) {
- *filesys_flags |= MS_NOSUID;
- } else if (strncmp(data, "suid", 4) == 0) {
- *filesys_flags &= ~MS_NOSUID;
- } else if (strncmp(data, "dev", 3) == 0) {
- *filesys_flags &= ~MS_NODEV;
- } else if (strncmp(data, "nodev", 5) == 0) {
- *filesys_flags |= MS_NODEV;
- } else if (strncmp(data, "noexec", 6) == 0) {
- *filesys_flags |= MS_NOEXEC;
- } else if (strncmp(data, "exec", 4) == 0) {
- *filesys_flags &= ~MS_NOEXEC;
- } else if (strncmp(data, "sync", 4) == 0) {
- *filesys_flags |= MS_SYNCHRONOUS;
- } else if (strncmp(data, "remount", 7) == 0) {
- *filesys_flags |= MS_REMOUNT;
- } else if (strncmp(data, "mandlock", 8) == 0) {
- *filesys_flags |= MS_MANDLOCK;
- } else if ((strncmp(data, "nobrl", 5) == 0) ||
- (strncmp(data, "nolock", 6) == 0)) {
- *filesys_flags &= ~MS_MANDLOCK;
- } else if (strncmp(data, "noatime", 7) == 0) {
- *filesys_flags |= MS_NOATIME;
- } else if (strncmp(data, "nodiratime", 10) == 0) {
- *filesys_flags |= MS_NODIRATIME;
- } else if (strncmp(data, "relatime", 8) == 0) {
- *filesys_flags |= MS_RELATIME;
-
- } else if (strncmp(data, "noauto", 6) == 0) {
- skip = 1; /* ignore */
- } else if (strncmp(data, "_netdev", 7) == 0) {
- skip = 1; /* ignore */
-
- } else if (strncmp(data, "secretfile", 10) == 0) {
- if (!value || !*value) {
- printf("keyword secretfile found, but no secret file specified\n");
- free(saw_name);
- return NULL;
- }
-
- if (read_secret_from_file(value, secret, sizeof(secret)) < 0) {
- printf("error reading secret file\n");
- return NULL;
- }
-
- /* see comment for "secret" */
- saw_secret = secret;
- skip = 1;
- } else if (strncmp(data, "secret", 6) == 0) {
- if (!value || !*value) {
- printf("mount option secret requires a value.\n");
- free(saw_name);
- return NULL;
- }
-
- /* secret is only added to kernel options as
- backwards compatibility, if add_key doesn't
- recognize our keytype; hence, it is skipped
- here and appended to options on add_key
- failure */
- size_t len = sizeof(secret);
- strncpy(secret, value, len-1);
- secret[len-1] = '\0';
- saw_secret = secret;
- skip = 1;
- } else if (strncmp(data, "name", 4) == 0) {
- if (!value || !*value) {
- printf("mount option name requires a value.\n");
- return NULL;
- }
-
- /* take a copy of the name, to be used for
- naming the keys that we add to kernel; */
- free(saw_name);
- saw_name = strdup(value);
- if (!saw_name) {
- printf("out of memory.\n");
- return NULL;
- }
- skip = 0;
- } else {
- skip = 0;
- if (verboseflag) {
- fprintf(stderr, "mount.ceph: unrecognized mount option \"%s\", "
- "passing to kernel.\n", data);
- }
- }
-
- /* Copy (possibly modified) option to out */
- if (!skip) {
- if (pos)
- pos = safe_cat(&out, &out_len, pos, ",");
-
- if (value) {
- pos = safe_cat(&out, &out_len, pos, data);
- pos = safe_cat(&out, &out_len, pos, "=");
- pos = safe_cat(&out, &out_len, pos, value);
- } else {
- pos = safe_cat(&out, &out_len, pos, data);
- }
-
- }
- data = next_keyword;
- } while (data);
-
- name_pos = safe_cat(&name, &name_len, name_pos, "client.");
- if (!saw_name) {
- name_pos = safe_cat(&name, &name_len, name_pos, CEPH_AUTH_NAME_DEFAULT);
- } else {
- name_pos = safe_cat(&name, &name_len, name_pos, saw_name);
- }
- if (saw_secret || is_kernel_secret(name)) {
- int ret;
- char secret_option[MAX_SECRET_OPTION_LEN];
- ret = get_secret_option(saw_secret, name, secret_option, sizeof(secret_option));
- if (ret < 0) {
- free(saw_name);
- return NULL;
- } else {
- if (pos) {
- pos = safe_cat(&out, &out_len, pos, ",");
- }
- pos = safe_cat(&out, &out_len, pos, secret_option);
- }
- }
-
- free(saw_name);
- if (!out)
- return strdup(EMPTY_STRING);
- return out;
-}
-
-
-static int parse_arguments(int argc, char *const *const argv,
- const char **src, const char **node, const char **opts)
-{
- int i;
-
- if (argc < 2) {
- // There were no arguments. Just show the usage.
- return 1;
- }
- if ((!strcmp(argv[1], "-h")) || (!strcmp(argv[1], "--help"))) {
- // The user asked for help.
- return 1;
- }
-
- // The first two arguments are positional
- if (argc < 3)
- return -EINVAL;
- *src = argv[1];
- *node = argv[2];
-
- // Parse the remaining options
- *opts = EMPTY_STRING;
- for (i = 3; i < argc; ++i) {
- if (!strcmp("-h", argv[i]))
- return 1;
- else if (!strcmp("-n", argv[i]))
- skip_mtab_flag = 1;
- else if (!strcmp("-v", argv[i]))
- verboseflag = 1;
- else if (!strcmp("-o", argv[i])) {
- ++i;
- if (i >= argc) {
- printf("Option -o requires an argument.\n\n");
- return -EINVAL;
- }
- *opts = argv[i];
- }
- else {
- printf("Can't understand option: '%s'\n\n", argv[i]);
- return -EINVAL;
- }
- }
- return 0;
-}
-
-/* modprobe failing doesn't necessarily prevent from working, so this
- returns void */
-static void modprobe(void)
-{
- int r;
-
- r = module_load("ceph", NULL);
- if (r)
- printf("failed to load ceph kernel module (%d)\n", r);
-}
-
-static void usage(const char *prog_name)
-{
- printf("usage: %s [src] [mount-point] [-n] [-v] [-o ceph-options]\n",
- prog_name);
- printf("options:\n");
- printf("\t-h: Print this help\n");
- printf("\t-n: Do not update /etc/mtab\n");
- printf("\t-v: Verbose\n");
- printf("\tceph-options: refer to mount.ceph(8)\n");
- printf("\n");
-}
-
-int main(int argc, char *argv[])
-{
- const char *src, *node, *opts;
- char *rsrc = NULL;
- char *popts = NULL;
- int flags = 0;
- int retval = 0;
-
- retval = parse_arguments(argc, argv, &src, &node, &opts);
- if (retval) {
- usage(argv[0]);
- exit((retval > 0) ? EXIT_SUCCESS : EXIT_FAILURE);
- }
-
- rsrc = mount_resolve_src(src);
- if (!rsrc) {
- printf("failed to resolve source\n");
- exit(1);
- }
-
- modprobe();
-
- popts = parse_options(opts, &flags);
- if (!popts) {
- printf("failed to parse ceph_options\n");
- exit(1);
- }
-
- block_signals(SIG_BLOCK);
-
- if (mount(rsrc, node, "ceph", flags, popts)) {
- retval = errno;
- switch (errno) {
- case ENODEV:
- printf("mount error: ceph filesystem not supported by the system\n");
- break;
- default:
- printf("mount error %d = %s\n",errno,strerror(errno));
- }
- } else {
- if (!skip_mtab_flag) {
- update_mtab_entry(rsrc, node, "ceph", popts, flags, 0, 0);
- }
- }
-
- block_signals(SIG_UNBLOCK);
-
- free(popts);
- free(rsrc);
- exit(retval);
-}
-
Code Review / stor4nfv.git / blobdiff