include/ceph_hash.cc \
include/ceph_strings.cc \
include/ceph_frag.cc \
- config.cc \
+ common/config.cc \
common/page.cc \
common/lockdep.cc \
common/DoutStreambuf.cc \
common/dyn_snprintf.h\
common/run_cmd.h\
common/safe_io.h\
- config.h\
+ common/config.h\
crush/CrushWrapper.h\
crush/CrushWrapper.i\
crush/builder.h\
#include "Crypto.h"
#include "msg/msg_types.h"
-#include "config.h"
+#include "common/config.h"
#include <errno.h>
#define CEPH_AUTHAUTHORIZEHANDLER_H
#include "include/types.h"
-#include "config.h"
+#include "common/config.h"
#include "Auth.h"
class KeyRing;
#include "cephx/CephxServiceHandler.h"
#include "none/AuthNoneServiceHandler.h"
#include "AuthSupported.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS auth
#define CEPH_AUTHSERVICEHANDLER_H
#include "include/types.h"
-#include "config.h"
+#include "common/config.h"
#include "Auth.h"
class KeyServer;
#include "common/Mutex.h"
#include "include/str_list.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS auth
#include <cryptopp/filters.h>
#include "include/ceph_fs.h"
-#include "config.h"
+#include "common/config.h"
#include "common/armor.h"
#include "common/Clock.h"
#include "common/hex.h"
#include <errno.h>
#include <map>
-#include "config.h"
+#include "common/config.h"
#include "include/str_list.h"
#include "common/ConfUtils.h"
#ifndef CEPH_KEYRING_H
#define CEPH_KEYRING_H
-#include "config.h"
+#include "common/config.h"
#include "auth/Crypto.h"
#include "auth/Auth.h"
#include <errno.h>
#include <map>
-#include "config.h"
+#include "common/config.h"
#include "include/str_list.h"
#include "Crypto.h"
#ifndef CEPH_ROTATINGKEYRING_H
#define CEPH_ROTATINGKEYRING_H
-#include "config.h"
+#include "common/config.h"
#include "auth/Crypto.h"
#include "auth/Auth.h"
#include "../KeyRing.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS auth
#undef dout_prefix
*
*/
-#include "config.h"
+#include "common/config.h"
#include "CephxKeyServer.h"
#include "common/Timer.h"
#ifndef CEPH_KEYSSERVER_H
#define CEPH_KEYSSERVER_H
-#include "config.h"
+#include "common/config.h"
#include "auth/KeyRing.h"
#include "CephxProtocol.h"
#include "CephxProtocol.h"
#include "common/Clock.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS auth
#undef dout_prefix
#include <errno.h>
#include <sstream>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS auth
#undef dout_prefix
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "common/ConfUtils.h"
#include "common/ceph_argparse.h"
#include "common/ConfUtils.h"
#include "common/common_init.h"
#include "common/ceph_argparse.h"
-#include "config.h"
+#include "common/config.h"
#include "include/str_list.h"
const char *type = NULL;
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "client/Client.h"
#include "client/fuse_ll.h"
#include <iostream>
using namespace std;
-#include "config.h"
+#include "common/config.h"
// ceph stuff
#include "Client.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS client
#undef dout_prefix
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "SyntheticClient.h"
#include "osdc/Objecter.h"
#include "osdc/Filer.h"
#include <math.h>
#include <sys/statvfs.h>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS client
#undef dout_prefix
#include "common/Mutex.h"
-#include "config.h"
+#include "common/config.h"
#include <sys/types.h>
#include <sys/stat.h>
#include "common/safe_io.h"
#include "include/types.h"
#include "Client.h"
-#include "config.h"
+#include "common/config.h"
static Client *client;
#include "CephFSInterface.h"
#include "client/libceph.h"
-#include "config.h"
+#include "common/config.h"
#include "msg/SimpleMessenger.h"
#include "common/Timer.h"
// ceph stuff
-#include "config.h"
+#include "common/config.h"
#include "client/Client.h"
#include "msg/SimpleMessenger.h"
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "mon/MonMap.h"
#include "mds/MDS.h"
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "mon/MonMap.h"
#include "mon/Monitor.h"
#include <map>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS osd
#undef dout_prefix
#include "common/ClassVersion.h"
#include "include/ClassLibrary.h"
-#include "config.h"
+#include "common/config.h"
ClassInfo *ClassVersionMap::get(ClassVersion& ver)
{
*/
-#include "config.h"
+#include "common/config.h"
#include "Clock.h"
// public
#include <math.h>
#include "Clock.h"
-#include "config.h"
+#include "common/config.h"
/**
*
*
*/
-#include "config.h"
+#include "common/config.h"
#include "common/DoutStreambuf.h"
#include "common/errno.h"
#include "common/Mutex.h"
-#include "config.h"
+#include "common/config.h"
#include "Finisher.h"
#include "common/debug.h"
#include "common/LogClient.h"
-#include "config.h"
+#include "common/config.h"
/*
* Given a clog log_type, return the equivalent syslog priority
#include "include/types.h"
#include "MemoryModel.h"
-#include "config.h"
+#include "common/config.h"
#include "debug.h"
#include <fstream>
#include <ext/hash_map>
-#include "config.h"
+#include "common/config.h"
#undef dout
#undef derr
#include <memory>
#include "Clock.h"
-#include "config.h"
+#include "common/config.h"
#include <sys/stat.h>
#include <sys/types.h>
#define CEPH_THREAD_H
#include "common/signal.h"
-#include "config.h"
+#include "common/config.h"
#include "include/atomic.h"
#include <errno.h>
#include "Thread.h"
#include "Timer.h"
-#include "config.h"
+#include "common/config.h"
#include "include/Context.h"
#define DOUT_SUBSYS timer
#include "include/types.h"
#include "WorkQueue.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS tp
#undef dout_prefix
#include "BackTrace.h"
#include "common/debug.h"
-#include "config.h"
+#include "common/config.h"
#include "include/assert.h"
static bool dout_trylock(void)
#include "armor.h"
#include "common/errno.h"
#include "common/safe_io.h"
-#include "config.h"
+#include "common/config.h"
#include "include/Spinlock.h"
#include "include/types.h"
#include "common/common_init.h"
#include "common/ConfUtils.h"
#include "common/version.h"
-#include "config.h"
+#include "common/config.h"
#include "include/intarith.h"
#include "include/str_list.h"
#include "msg/msg_types.h"
#include "common/safe_io.h"
#include "common/signal.h"
#include "common/version.h"
-#include "config.h"
+#include "common/config.h"
#include "common/common_init.h"
#include "common/errno.h"
#include "include/color.h"
--- /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 "auth/Auth.h"
+#include "common/BackTrace.h"
+#include "common/Clock.h"
+#include "common/ConfUtils.h"
+#include "common/ProfLogger.h"
+#include "common/common_init.h"
+#include "common/dyn_snprintf.h"
+#include "common/version.h"
+#include "common/config.h"
+#include "include/atomic.h"
+#include "include/str_list.h"
+#include "include/types.h"
+#include "msg/msg_types.h"
+#include "osd/osd_types.h"
+
+#include <fcntl.h>
+#include <fstream>
+#include <stdlib.h>
+#include <string.h>
+#include <syslog.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+
+/* Don't use standard Ceph logging in this file.
+ * We can't use logging until it's initialized, and a lot of the necessary
+ * initialization happens here.
+ */
+#undef dout
+#undef pdout
+#undef derr
+#undef generic_dout
+#undef dendl
+
+/* The Ceph configuration. */
+md_config_t g_conf __attribute__((init_priority(103)));
+
+#define _STR(x) #x
+#define STRINGIFY(x) _STR(x)
+
+
+#define OPTION_OPT_STR(section, name, schar, type, def_val) \
+ { STRINGIFY(section), NULL, STRINGIFY(name), \
+ &g_conf.name, def_val, 0, 0, type, schar }
+
+#define OPTION_OPT_ADDR(section, name, schar, type, def_val) \
+ { STRINGIFY(section), NULL, STRINGIFY(name), \
+ &g_conf.name, def_val, 0, 0, type, schar }
+
+#define OPTION_OPT_LONGLONG(section, name, schar, type, def_val) \
+ { STRINGIFY(section), NULL, STRINGIFY(name), \
+ &g_conf.name, 0, def_val, 0, type, schar }
+#define OPTION_OPT_INT OPTION_OPT_LONGLONG
+#define OPTION_OPT_BOOL OPTION_OPT_INT
+
+#define OPTION_OPT_DOUBLE(section, name, schar, type, def_val) \
+ { STRINGIFY(section), NULL, STRINGIFY(name), \
+ &g_conf.name, 0, 0, def_val, type, schar }
+#define OPTION_OPT_FLOAT OPTION_OPT_DOUBLE
+
+#define OPTION(name, schar, type, def_val) OPTION_##type("global", name, schar, type, def_val)
+
+#define OPTION_ALT(section, conf_name, name, schar, type, def_val) \
+ { STRINGIFY(section), NULL, STRINGIFY(conf_name), \
+ &g_conf.name, STRINGIFY(def_val), type, schar }
+
+struct config_option config_optionsp[] = {
+ OPTION(host, 0, OPT_STR, "localhost"),
+ OPTION(public_addr, 0, OPT_ADDR, ""),
+ OPTION(cluster_addr, 0, OPT_ADDR, ""),
+ OPTION(num_client, 0, OPT_INT, 1),
+ OPTION(monmap, 'M', OPT_STR, 0),
+ OPTION(mon_host, 'm', OPT_STR, 0),
+ OPTION(daemonize, 'd', OPT_BOOL, false),
+ OPTION(tcmalloc_profiler_run, 0, OPT_BOOL, false),
+ OPTION(profiler_allocation_interval, 0, OPT_INT, 1073741824),
+ OPTION(profiler_highwater_interval, 0, OPT_INT, 104857600),
+ OPTION(profiling_logger, 0, OPT_BOOL, false),
+ OPTION(profiling_logger_interval, 0, OPT_INT, 1),
+ OPTION(profiling_logger_calc_variance, 0, OPT_BOOL, false),
+ OPTION(profiling_logger_subdir, 0, OPT_STR, 0),
+ OPTION(profiling_logger_dir, 0, OPT_STR, "/var/log/ceph/stat"),
+ OPTION(log_file, 0, OPT_STR, 0),
+ OPTION(log_dir, 0, OPT_STR, "/var/log/ceph"),
+ OPTION(log_sym_dir, 0, OPT_STR, 0),
+ OPTION(log_sym_history, 0, OPT_INT, 10),
+ OPTION(log_to_stderr, 0, OPT_INT, LOG_TO_STDERR_SOME),
+ OPTION(log_to_syslog, 0, OPT_BOOL, false),
+ OPTION(log_per_instance, 0, OPT_BOOL, false),
+ OPTION(log_to_file, 0, OPT_BOOL, true),
+ OPTION(clog_to_monitors, 0, OPT_BOOL, true),
+ OPTION(clog_to_syslog, 0, OPT_BOOL, false),
+ OPTION(pid_file, 0, OPT_STR, "/var/run/ceph/$type.$id.pid"),
+ OPTION(conf, 'c', OPT_STR, "/etc/ceph/ceph.conf, ~/.ceph/config, ceph.conf"),
+ OPTION(chdir, 0, OPT_STR, "/"),
+ OPTION(kill_after, 0, OPT_INT, 0),
+ OPTION(max_open_files, 0, OPT_LONGLONG, 0),
+ OPTION(debug, 0, OPT_INT, 0),
+ OPTION(debug_lockdep, 0, OPT_INT, 0),
+ OPTION(debug_mds, 0, OPT_INT, 1),
+ OPTION(debug_mds_balancer, 0, OPT_INT, 1),
+ OPTION(debug_mds_log, 0, OPT_INT, 1),
+ OPTION(debug_mds_log_expire, 0, OPT_INT, 1),
+ OPTION(debug_mds_migrator, 0, OPT_INT, 1),
+ OPTION(debug_buffer, 0, OPT_INT, 0),
+ OPTION(debug_timer, 0, OPT_INT, 0),
+ OPTION(debug_filer, 0, OPT_INT, 0),
+ OPTION(debug_objecter, 0, OPT_INT, 0),
+ OPTION(debug_rados, 0, OPT_INT, 0),
+ OPTION(debug_rbd, 0, OPT_INT, 0),
+ OPTION(debug_journaler, 0, OPT_INT, 0),
+ OPTION(debug_objectcacher, 0, OPT_INT, 0),
+ OPTION(debug_client, 0, OPT_INT, 0),
+ OPTION(debug_osd, 0, OPT_INT, 0),
+ OPTION(debug_ebofs, 0, OPT_INT, 1),
+ OPTION(debug_filestore, 0, OPT_INT, 1),
+ OPTION(debug_journal, 0, OPT_INT, 1),
+ OPTION(debug_bdev, 0, OPT_INT, 1), // block device
+ OPTION(debug_ms, 0, OPT_INT, 0),
+ OPTION(debug_mon, 0, OPT_INT, 1),
+ OPTION(debug_monc, 0, OPT_INT, 0),
+ OPTION(debug_paxos, 0, OPT_INT, 0),
+ OPTION(debug_tp, 0, OPT_INT, 0),
+ OPTION(debug_auth, 0, OPT_INT, 1),
+ OPTION(debug_finisher, 0, OPT_INT, 1),
+ OPTION(key, 0, OPT_STR, ""),
+ OPTION(keyfile, 'K', OPT_STR, ""),
+ OPTION(keyring, 'k', OPT_STR, "/etc/ceph/keyring,/etc/ceph/keyring.bin"),
+ OPTION(ms_tcp_nodelay, 0, OPT_BOOL, true),
+ OPTION(ms_initial_backoff, 0, OPT_DOUBLE, .2),
+ OPTION(ms_max_backoff, 0, OPT_DOUBLE, 15.0),
+ OPTION(ms_nocrc, 0, OPT_BOOL, false),
+ OPTION(ms_die_on_bad_msg, 0, OPT_BOOL, false),
+ OPTION(ms_dispatch_throttle_bytes, 0, OPT_INT, 100 << 20),
+ OPTION(ms_bind_ipv6, 0, OPT_BOOL, false),
+ OPTION(ms_rwthread_stack_bytes, 0, OPT_INT, 1024 << 10),
+ OPTION(ms_tcp_read_timeout, 0, OPT_LONGLONG, 900),
+ OPTION(ms_inject_socket_failures, 0, OPT_LONGLONG, 0),
+ OPTION(mon_data, 0, OPT_STR, ""),
+ OPTION(mon_tick_interval, 0, OPT_INT, 5),
+ OPTION(mon_subscribe_interval, 0, OPT_DOUBLE, 300),
+ OPTION(mon_osd_down_out_interval, 0, OPT_INT, 300), // seconds
+ OPTION(mon_lease, 0, OPT_FLOAT, 5), // lease interval
+ OPTION(mon_lease_renew_interval, 0, OPT_FLOAT, 3), // on leader, to renew the lease
+ OPTION(mon_lease_ack_timeout, 0, OPT_FLOAT, 10.0), // on leader, if lease isn't acked by all peons
+ OPTION(mon_clock_drift_allowed, 0, OPT_FLOAT, .010), // allowed clock drift between monitors
+ OPTION(mon_clock_drift_warn_backoff, 0, OPT_FLOAT, 5), // exponential backoff for clock drift warnings
+ OPTION(mon_accept_timeout, 0, OPT_FLOAT, 10.0), // on leader, if paxos update isn't accepted
+ OPTION(mon_pg_create_interval, 0, OPT_FLOAT, 30.0), // no more than every 30s
+ OPTION(mon_osd_full_ratio, 0, OPT_INT, 95), // what % full makes an OSD "full"
+ OPTION(mon_osd_nearfull_ratio, 0, OPT_INT, 85), // what % full makes an OSD near full
+ OPTION(mon_globalid_prealloc, 0, OPT_INT, 100), // how many globalids to prealloc
+ OPTION(mon_osd_report_timeout, 0, OPT_INT, 900), // grace period before declaring unresponsive OSDs dead
+ OPTION(paxos_propose_interval, 0, OPT_DOUBLE, 1.0), // gather updates for this long before proposing a map update
+ OPTION(paxos_min_wait, 0, OPT_DOUBLE, 0.05), // min time to gather updates for after period of inactivity
+ OPTION(paxos_observer_timeout, 0, OPT_DOUBLE, 5*60), // gather updates for this long before proposing a map update
+ OPTION(auth_supported, 0, OPT_STR, "none"),
+ OPTION(auth_mon_ticket_ttl, 0, OPT_DOUBLE, 60*60*12),
+ OPTION(auth_service_ticket_ttl, 0, OPT_DOUBLE, 60*60),
+ OPTION(mon_client_hunt_interval, 0, OPT_DOUBLE, 3.0), // try new mon every N seconds until we connect
+ OPTION(mon_client_ping_interval, 0, OPT_DOUBLE, 10.0), // ping every N seconds
+ OPTION(client_cache_size, 0, OPT_INT, 16384),
+ OPTION(client_cache_mid, 0, OPT_FLOAT, .75),
+ OPTION(client_cache_stat_ttl, 0, OPT_INT, 0), // seconds until cached stat results become invalid
+ OPTION(client_cache_readdir_ttl, 0, OPT_INT, 1), // 1 second only
+ OPTION(client_use_random_mds, 0, OPT_BOOL, false),
+ OPTION(client_mount_timeout, 0, OPT_DOUBLE, 30.0),
+ OPTION(client_unmount_timeout, 0, OPT_DOUBLE, 10.0),
+ OPTION(client_tick_interval, 0, OPT_DOUBLE, 1.0),
+ OPTION(client_trace, 0, OPT_STR, 0),
+ OPTION(client_readahead_min, 0, OPT_LONGLONG, 128*1024), // readahead at _least_ this much.
+ OPTION(client_readahead_max_bytes, 0, OPT_LONGLONG, 0), //8 * 1024*1024,
+ OPTION(client_readahead_max_periods, 0, OPT_LONGLONG, 4), // as multiple of file layout period (object size * num stripes)
+ OPTION(client_snapdir, 0, OPT_STR, ".snap"),
+ OPTION(client_mountpoint, 'r', OPT_STR, "/"),
+ OPTION(client_notify_timeout, 0, OPT_INT, 10), // in seconds
+ OPTION(client_oc, 0, OPT_BOOL, true),
+ OPTION(client_oc_size, 0, OPT_INT, 1024*1024* 200), // MB * n
+ OPTION(client_oc_max_dirty, 0, OPT_INT, 1024*1024* 100), // MB * n (dirty OR tx.. bigish)
+ OPTION(client_oc_target_dirty, 0, OPT_INT, 1024*1024* 8), // target dirty (keep this smallish)
+ // note: the max amount of "in flight" dirty data is roughly (max - target)
+ OPTION(client_oc_max_sync_write, 0, OPT_LONGLONG, 128*1024), // sync writes >= this use wrlock
+ OPTION(objecter_tick_interval, 0, OPT_DOUBLE, 5.0),
+ OPTION(objecter_mon_retry_interval, 0, OPT_DOUBLE, 5.0),
+ OPTION(objecter_timeout, 0, OPT_DOUBLE, 10.0), // before we ask for a map
+ OPTION(objecter_inflight_op_bytes, 0, OPT_LONGLONG, 1024*1024*100), //max in-flight data (both directions)
+ OPTION(journaler_allow_split_entries, 0, OPT_BOOL, true),
+ OPTION(journaler_safe, 0, OPT_BOOL, true), // wait for COMMIT on journal writes
+ OPTION(journaler_write_head_interval, 0, OPT_INT, 15),
+ OPTION(journaler_cache, 0, OPT_BOOL, false), // cache writes for later readback
+ OPTION(journaler_prefetch_periods, 0, OPT_INT, 50), // * journal object size (1~MB? see above)
+ OPTION(journaler_batch_interval, 0, OPT_DOUBLE, .001), // seconds.. max add'l latency we artificially incur
+ OPTION(journaler_batch_max, 0, OPT_LONGLONG, 0), // max bytes we'll delay flushing; disable, for now....
+ OPTION(mds_max_file_size, 0, OPT_LONGLONG, 1ULL << 40),
+ OPTION(mds_cache_size, 0, OPT_INT, 100000),
+ OPTION(mds_cache_mid, 0, OPT_FLOAT, .7),
+ OPTION(mds_mem_max, 0, OPT_INT, 1048576), // KB
+ OPTION(mds_dir_commit_ratio, 0, OPT_FLOAT, .5),
+ OPTION(mds_dir_max_commit_size, 0, OPT_INT, 90), // MB
+ OPTION(mds_decay_halflife, 0, OPT_FLOAT, 5),
+ OPTION(mds_beacon_interval, 0, OPT_FLOAT, 4),
+ OPTION(mds_beacon_grace, 0, OPT_FLOAT, 15),
+ OPTION(mds_blacklist_interval, 0, OPT_FLOAT, 24.0*60.0), // how long to blacklist failed nodes
+ OPTION(mds_session_timeout, 0, OPT_FLOAT, 60), // cap bits and leases time out if client idle
+ OPTION(mds_session_autoclose, 0, OPT_FLOAT, 300), // autoclose idle session
+ OPTION(mds_reconnect_timeout, 0, OPT_FLOAT, 45), // seconds to wait for clients during mds restart
+ // make it (mds_session_timeout - mds_beacon_grace)
+ OPTION(mds_tick_interval, 0, OPT_FLOAT, 5),
+ OPTION(mds_dirstat_min_interval, 0, OPT_FLOAT, 1), // try to avoid propagating more often than this
+ OPTION(mds_scatter_nudge_interval, 0, OPT_FLOAT, 5), // how quickly dirstat changes propagate up the hierarchy
+ OPTION(mds_client_prealloc_inos, 0, OPT_INT, 1000),
+ OPTION(mds_early_reply, 0, OPT_BOOL, true),
+ OPTION(mds_use_tmap, 0, OPT_BOOL, true), // use trivialmap for dir updates
+ OPTION(mds_default_dir_hash, 0, OPT_INT, CEPH_STR_HASH_RJENKINS),
+ OPTION(mds_log, 0, OPT_BOOL, true),
+ OPTION(mds_log_unsafe, 0, OPT_BOOL, false), // only wait for log sync, when it's mostly safe to do so
+ OPTION(mds_log_skip_corrupt_events, 0, OPT_BOOL, false),
+ OPTION(mds_log_max_events, 0, OPT_INT, -1),
+ OPTION(mds_log_max_segments, 0, OPT_INT, 30), // segment size defined by FileLayout, above
+ OPTION(mds_log_max_expiring, 0, OPT_INT, 20),
+ OPTION(mds_log_eopen_size, 0, OPT_INT, 100), // # open inodes per log entry
+ OPTION(mds_bal_sample_interval, 0, OPT_FLOAT, 3.0), // every 5 seconds
+ OPTION(mds_bal_replicate_threshold, 0, OPT_FLOAT, 8000),
+ OPTION(mds_bal_unreplicate_threshold, 0, OPT_FLOAT, 0),
+ OPTION(mds_bal_frag, 0, OPT_BOOL, false),
+ OPTION(mds_bal_split_size, 0, OPT_INT, 10000),
+ OPTION(mds_bal_split_rd, 0, OPT_FLOAT, 25000),
+ OPTION(mds_bal_split_wr, 0, OPT_FLOAT, 10000),
+ OPTION(mds_bal_split_bits, 0, OPT_INT, 3),
+ OPTION(mds_bal_merge_size, 0, OPT_INT, 50),
+ OPTION(mds_bal_merge_rd, 0, OPT_FLOAT, 1000),
+ OPTION(mds_bal_merge_wr, 0, OPT_FLOAT, 1000),
+ OPTION(mds_bal_interval, 0, OPT_INT, 10), // seconds
+ OPTION(mds_bal_fragment_interval, 0, OPT_INT, 5), // seconds
+ OPTION(mds_bal_idle_threshold, 0, OPT_FLOAT, 0),
+ OPTION(mds_bal_max, 0, OPT_INT, -1),
+ OPTION(mds_bal_max_until, 0, OPT_INT, -1),
+ OPTION(mds_bal_mode, 0, OPT_INT, 0),
+ OPTION(mds_bal_min_rebalance, 0, OPT_FLOAT, .1), // must be this much above average before we export anything
+ OPTION(mds_bal_min_start, 0, OPT_FLOAT, .2), // if we need less than this, we don't do anything
+ OPTION(mds_bal_need_min, 0, OPT_FLOAT, .8), // take within this range of what we need
+ OPTION(mds_bal_need_max, 0, OPT_FLOAT, 1.2),
+ OPTION(mds_bal_midchunk, 0, OPT_FLOAT, .3), // any sub bigger than this taken in full
+ OPTION(mds_bal_minchunk, 0, OPT_FLOAT, .001), // never take anything smaller than this
+ OPTION(mds_bal_target_removal_min, 0, OPT_INT, 5), // min balance iterations before old target is removed
+ OPTION(mds_bal_target_removal_max, 0, OPT_INT, 10), // max balance iterations before old target is removed
+ OPTION(mds_replay_interval, 0, OPT_FLOAT, 1.0), // time to wait before starting replay again
+ OPTION(mds_shutdown_check, 0, OPT_INT, 0),
+ OPTION(mds_thrash_exports, 0, OPT_INT, 0),
+ OPTION(mds_thrash_fragments, 0, OPT_INT, 0),
+ OPTION(mds_dump_cache_on_map, 0, OPT_BOOL, false),
+ OPTION(mds_dump_cache_after_rejoin, 0, OPT_BOOL, false),
+ OPTION(mds_verify_scatter, 0, OPT_BOOL, false),
+ OPTION(mds_debug_scatterstat, 0, OPT_BOOL, false),
+ OPTION(mds_debug_frag, 0, OPT_BOOL, false),
+ OPTION(mds_kill_mdstable_at, 0, OPT_INT, 0),
+ OPTION(mds_kill_export_at, 0, OPT_INT, 0),
+ OPTION(mds_kill_import_at, 0, OPT_INT, 0),
+ OPTION(mds_kill_rename_at, 0, OPT_INT, 0),
+ OPTION(mds_wipe_sessions, 0, OPT_BOOL, 0),
+ OPTION(mds_wipe_ino_prealloc, 0, OPT_BOOL, 0),
+ OPTION(mds_skip_ino, 0, OPT_INT, 0),
+ OPTION(max_mds, 0, OPT_INT, 1),
+ OPTION(mds_standby_for_name, 0, OPT_STR, ""),
+ OPTION(mds_standby_for_rank, 0, OPT_INT, -1),
+ OPTION(mds_standby_replay, 0, OPT_BOOL, false),
+ OPTION(osd_data, 0, OPT_STR, ""),
+ OPTION(osd_journal, 0, OPT_STR, ""),
+ OPTION(osd_journal_size, 0, OPT_INT, 0), // in mb
+ OPTION(osd_max_write_size, 0, OPT_INT, 90),
+ OPTION(osd_balance_reads, 0, OPT_BOOL, false),
+ OPTION(osd_flash_crowd_iat_threshold, 0, OPT_INT, 0),
+ OPTION(osd_flash_crowd_iat_alpha, 0, OPT_DOUBLE, 0.125),
+ OPTION(osd_shed_reads, 0, OPT_INT, false), // forward from primary to replica
+ OPTION(osd_shed_reads_min_latency, 0, OPT_DOUBLE, .01), // min local latency
+ OPTION(osd_shed_reads_min_latency_diff, 0, OPT_DOUBLE, .01), // min latency difference
+ OPTION(osd_shed_reads_min_latency_ratio, 0, OPT_DOUBLE, 1.5), // 1.2 == 20% higher than peer
+ OPTION(osd_client_message_size_cap, 0, OPT_LONGLONG, 500*1024L*1024L), // default to 200MB client data allowed in-memory
+ OPTION(osd_stat_refresh_interval, 0, OPT_DOUBLE, .5),
+ OPTION(osd_pg_bits, 0, OPT_INT, 9), // bits per osd
+ OPTION(osd_pgp_bits, 0, OPT_INT, 6), // bits per osd
+ OPTION(osd_lpg_bits, 0, OPT_INT, 2), // bits per osd
+ OPTION(osd_pg_layout, 0, OPT_INT, CEPH_PG_LAYOUT_CRUSH),
+ OPTION(osd_min_rep, 0, OPT_INT, 1),
+ OPTION(osd_max_rep, 0, OPT_INT, 10),
+ OPTION(osd_min_raid_width, 0, OPT_INT, 3),
+ OPTION(osd_max_raid_width, 0, OPT_INT, 2),
+ OPTION(osd_pool_default_crush_rule, 0, OPT_INT, 0),
+ OPTION(osd_pool_default_size, 0, OPT_INT, 2),
+ OPTION(osd_pool_default_pg_num, 0, OPT_INT, 8),
+ OPTION(osd_pool_default_pgp_num, 0, OPT_INT, 8),
+ OPTION(osd_op_threads, 0, OPT_INT, 2), // 0 == no threading
+ OPTION(osd_max_opq, 0, OPT_INT, 10),
+ OPTION(osd_disk_threads, 0, OPT_INT, 1),
+ OPTION(osd_recovery_threads, 0, OPT_INT, 1),
+ OPTION(osd_age, 0, OPT_FLOAT, .8),
+ OPTION(osd_age_time, 0, OPT_INT, 0),
+ OPTION(osd_heartbeat_interval, 0, OPT_INT, 1),
+ OPTION(osd_mon_heartbeat_interval, 0, OPT_INT, 30), // if no peers, ping monitor
+ OPTION(osd_heartbeat_grace, 0, OPT_INT, 20),
+ OPTION(osd_mon_report_interval_max, 0, OPT_INT, 120),
+ OPTION(osd_mon_report_interval_min, 0, OPT_INT, 5), // pg stats, failures, up_thru, boot.
+ OPTION(osd_min_down_reporters, 0, OPT_INT, 1), // number of OSDs who need to report a down OSD for it to count
+ OPTION(osd_min_down_reports, 0, OPT_INT, 3), // number of times a down OSD must be reported for it to count
+ OPTION(osd_replay_window, 0, OPT_INT, 45),
+ OPTION(osd_preserve_trimmed_log, 0, OPT_BOOL, true),
+ OPTION(osd_recovery_delay_start, 0, OPT_FLOAT, 15),
+ OPTION(osd_recovery_max_active, 0, OPT_INT, 5),
+ OPTION(osd_recovery_max_chunk, 0, OPT_LONGLONG, 1<<20), // max size of push chunk
+ OPTION(osd_recovery_forget_lost_objects, 0, OPT_BOOL, false), // off for now
+ OPTION(osd_max_scrubs, 0, OPT_INT, 1),
+ OPTION(osd_scrub_load_threshold, 0, OPT_FLOAT, 0.5),
+ OPTION(osd_scrub_min_interval, 0, OPT_FLOAT, 300),
+ OPTION(osd_scrub_max_interval, 0, OPT_FLOAT, 60*60*24), // once a day
+ OPTION(osd_auto_weight, 0, OPT_BOOL, false),
+ OPTION(osd_class_error_timeout, 0, OPT_DOUBLE, 60.0), // seconds
+ OPTION(osd_class_timeout, 0, OPT_DOUBLE, 60*60.0), // seconds
+ OPTION(osd_class_tmp, 0, OPT_STR, "/var/lib/ceph/tmp"),
+ OPTION(osd_check_for_log_corruption, 0, OPT_BOOL, false),
+ OPTION(osd_use_stale_snap, 0, OPT_BOOL, false),
+ OPTION(osd_max_notify_timeout, 0, OPT_INT, 30), // max notify timeout in seconds
+ OPTION(filestore, 0, OPT_BOOL, false),
+ OPTION(filestore_max_sync_interval, 0, OPT_DOUBLE, 5), // seconds
+ OPTION(filestore_min_sync_interval, 0, OPT_DOUBLE, .01), // seconds
+ OPTION(filestore_fake_attrs, 0, OPT_BOOL, false),
+ OPTION(filestore_fake_collections, 0, OPT_BOOL, false),
+ OPTION(filestore_dev, 0, OPT_STR, 0),
+ OPTION(filestore_btrfs_trans, 0, OPT_BOOL, false),
+ OPTION(filestore_btrfs_snap, 0, OPT_BOOL, true),
+ OPTION(filestore_btrfs_clone_range, 0, OPT_BOOL, true),
+ OPTION(filestore_fsync_flushes_journal_data, 0, OPT_BOOL, false),
+ OPTION(filestore_flusher, 0, OPT_BOOL, true),
+ OPTION(filestore_flusher_max_fds, 0, OPT_INT, 512),
+ OPTION(filestore_sync_flush, 0, OPT_BOOL, false),
+ OPTION(filestore_journal_parallel, 0, OPT_BOOL, false),
+ OPTION(filestore_journal_writeahead, 0, OPT_BOOL, false),
+ OPTION(filestore_journal_trailing, 0, OPT_BOOL, false),
+ OPTION(filestore_queue_max_ops, 0, OPT_INT, 500),
+ OPTION(filestore_queue_max_bytes, 0, OPT_INT, 100 << 20),
+ OPTION(filestore_op_threads, 0, OPT_INT, 2),
+ OPTION(filestore_commit_timeout, 0, OPT_FLOAT, 600),
+ OPTION(ebofs, 0, OPT_BOOL, false),
+ OPTION(ebofs_cloneable, 0, OPT_BOOL, true),
+ OPTION(ebofs_verify, 0, OPT_BOOL, false),
+ OPTION(ebofs_commit_ms, 0, OPT_INT, 200), // 0 = no forced commit timeout (for debugging/tracing)
+ OPTION(ebofs_oc_size, 0, OPT_INT, 10000), // onode cache
+ OPTION(ebofs_cc_size, 0, OPT_INT, 10000), // cnode cache
+ OPTION(ebofs_bc_size, 0, OPT_LONGLONG, 50*256), // 4k blocks, *256 for MB
+ OPTION(ebofs_bc_max_dirty, 0, OPT_LONGLONG, 30*256), // before write() will block
+ OPTION(ebofs_max_prefetch, 0, OPT_INT, 1000), // 4k blocks
+ OPTION(ebofs_realloc, 0, OPT_BOOL, false), // hrm, this can cause bad fragmentation, don't use!
+ OPTION(ebofs_verify_csum_on_read, 0, OPT_BOOL, true),
+ OPTION(journal_dio, 0, OPT_BOOL, true),
+ OPTION(journal_block_align, 0, OPT_BOOL, true),
+ OPTION(journal_max_write_bytes, 0, OPT_INT, 10 << 20),
+ OPTION(journal_max_write_entries, 0, OPT_INT, 100),
+ OPTION(journal_queue_max_ops, 0, OPT_INT, 500),
+ OPTION(journal_queue_max_bytes, 0, OPT_INT, 100 << 20),
+ OPTION(journal_align_min_size, 0, OPT_INT, 64 << 10), // align data payloads >= this.
+ OPTION(bdev_lock, 0, OPT_BOOL, true),
+ OPTION(bdev_iothreads, 0, OPT_INT, 1), // number of ios to queue with kernel
+ OPTION(bdev_idle_kick_after_ms, 0, OPT_INT, 100), // ms
+ OPTION(bdev_el_fw_max_ms, 0, OPT_INT, 10000), // restart elevator at least once every 1000 ms
+ OPTION(bdev_el_bw_max_ms, 0, OPT_INT, 3000), // restart elevator at least once every 300 ms
+ OPTION(bdev_el_bidir, 0, OPT_BOOL, false), // bidirectional elevator?
+ OPTION(bdev_iov_max, 0, OPT_INT, 512), // max # iov's to collect into a single readv()/writev() call
+ OPTION(bdev_debug_check_io_overlap, 0, OPT_BOOL, true), // [DEBUG] check for any pending io overlaps
+ OPTION(bdev_fake_mb, 0, OPT_INT, 0),
+ OPTION(bdev_fake_max_mb, 0, OPT_INT, 0),
+};
+
+const int num_config_options = sizeof(config_optionsp) / sizeof(config_option);
+
+bool conf_set_conf_val(void *field, opt_type_t type, const char *val)
+{
+ switch (type) {
+ case OPT_BOOL:
+ if (strcasecmp(val, "false") == 0)
+ *(bool *)field = false;
+ else if (strcasecmp(val, "true") == 0)
+ *(bool *)field = true;
+ else
+ *(bool *)field = (bool)atoi(val);
+ break;
+ case OPT_INT:
+ *(int *)field = atoi(val);
+ break;
+ case OPT_LONGLONG:
+ *(long long *)field = atoll(val);
+ break;
+ case OPT_STR:
+ if (val)
+ *(char **)field = strdup(val);
+ else
+ *(char **)field = NULL;
+ break;
+ case OPT_FLOAT:
+ *(float *)field = atof(val);
+ break;
+ case OPT_DOUBLE:
+ *(double *)field = strtod(val, NULL);
+ break;
+ case OPT_ADDR:
+ ((entity_addr_t *)field)->parse(val);
+ break;
+ default:
+ return false;
+ }
+
+ return true;
+}
+
+bool conf_set_conf_val(void *field, opt_type_t type, const char *val, long long intval, double doubleval)
+{
+ switch (type) {
+ case OPT_BOOL:
+ *(bool *)field = intval;
+ break;
+ case OPT_INT:
+ *(int *)field = intval;
+ break;
+ case OPT_LONGLONG:
+ *(long long *)field = intval;
+ break;
+ case OPT_STR:
+ if (val) {
+ *(char **)field = strdup(val);
+ } else {
+ *(char **)field = NULL;
+ }
+ break;
+ case OPT_FLOAT:
+ *(float *)field = doubleval;
+ break;
+ case OPT_DOUBLE:
+ *(double *)field = doubleval;
+ break;
+ case OPT_ADDR:
+ ((entity_addr_t *)field)->parse(val);
+ break;
+ default:
+ return false;
+ }
+
+ return true;
+}
+
+static bool conf_reset_val(void *field, opt_type_t type)
+{
+ switch (type) {
+ case OPT_BOOL:
+ *(bool *)field = 0;
+ break;
+ case OPT_INT:
+ *(int *)field = 0;
+ break;
+ case OPT_LONGLONG:
+ *(long long *)field = 0;
+ break;
+ case OPT_STR:
+ *(char **)field = NULL;
+ break;
+ case OPT_FLOAT:
+ *(float *)field = 0;
+ break;
+ case OPT_DOUBLE:
+ *(double *)field = 0;
+ break;
+ case OPT_ADDR:
+ *(entity_addr_t *)field = entity_addr_t();
+ break;
+ default:
+ return false;
+ }
+
+ return true;
+}
+
+static void set_conf_name(config_option *opt)
+{
+ char *newsection = (char *)opt->section;
+ char *newconf = (char *)opt->name;
+ int i;
+
+ if (opt->section[0] == 0) {
+ newsection = strdup("global");
+ }
+
+ if (strncmp(newsection, opt->name, strlen(newsection)) == 0) {
+ /* if key starts with the name of the section, remove name of the section
+ unless key equals to it */
+
+ if (strcmp(newsection, opt->name) == 0)
+ goto done;
+
+ newconf = strdup(&opt->name[strlen(newsection)+1]);
+ } else {
+ newconf = strdup(opt->name);
+ }
+
+ i = 0;
+ while (newconf[i]) {
+ if (newconf[i] == '_')
+ newconf[i] = ' ';
+
+ ++i;
+ }
+
+ done:
+ opt->section = newsection;
+ opt->conf_name = (const char *)newconf;
+}
+
+static int def_conf_to_str(config_option *opt, char *buf, int len)
+{
+ int ret = 0;
+
+ switch (opt->type) {
+ case OPT_INT:
+ case OPT_BOOL:
+ ret = snprintf(buf, len, "%d", (int)opt->def_longlong);
+ break;
+ case OPT_LONGLONG:
+ ret = snprintf(buf, len, "%lld", opt->def_longlong);
+ break;
+ case OPT_STR:
+ case OPT_ADDR:
+ ret = snprintf(buf, len, "%s", opt->def_str);
+ break;
+ case OPT_FLOAT:
+ case OPT_DOUBLE:
+ ret = snprintf(buf, len, "%f", opt->def_double);
+ break;
+ default:
+ break;
+ }
+ return ret;
+}
+
+int ceph_def_conf_by_name(const char *name, char *buf, int buflen)
+{
+ char *newname = strdup(name);
+ int len = strlen(name);
+ config_option *opt;
+ int ret = 0;
+ int i;
+
+ for (i = 0; i < len; i++) {
+ if (newname[i] == ' ')
+ newname[i] = '_';
+ }
+
+ len = sizeof(config_optionsp)/sizeof(config_option);
+
+ for (i = 0; i < len; i++) {
+ opt = &config_optionsp[i];
+ if (strcmp(opt->name, newname) == 0) {
+ ret = def_conf_to_str(opt, buf, buflen);
+ break;
+ }
+ }
+ free(newname);
+ return ret;
+}
+
+static bool cmd_is_char(const char *cmd)
+{
+ return ((cmd[0] == '-') &&
+ cmd[1] && !cmd[2]);
+}
+
+bool conf_cmd_equals(const char *cmd, const char *opt, char char_opt, unsigned int *val_pos)
+{
+ unsigned int i;
+ unsigned int len = strlen(opt);
+
+ *val_pos = 0;
+
+ if (!*cmd)
+ return false;
+
+ if (char_opt && cmd_is_char(cmd))
+ return (char_opt == cmd[1]);
+
+ if ((cmd[0] != '-') || (cmd[1] != '-'))
+ return false;
+
+ for (i=0; i<len; i++) {
+ if ((opt[i] == '_') || (opt[i] == '-')) {
+ switch (cmd[i+2]) {
+ case '-':
+ case '_':
+ continue;
+ default:
+ break;
+ }
+ }
+
+ if (cmd[i+2] != opt[i])
+ return false;
+ }
+
+ if (cmd[i+2] == '=')
+ *val_pos = i+3;
+ else if (cmd[i+2])
+ return false;
+
+ return true;
+}
+
+static bool get_var(const char *str, int pos, char *var_name, int len, int *new_pos)
+{
+ int bracket = (str[pos] == '{');
+ int out_pos = 0;
+
+ if (bracket) {
+ pos++;
+ }
+
+ while (str[pos] &&
+ ((bracket && str[pos] != '}') ||
+ isalnum(str[pos]) ||
+ str[pos] == '_')) {
+ var_name[out_pos] = str[pos];
+
+ out_pos ++;
+ if (out_pos == len)
+ return false;
+ pos++;
+ }
+
+ var_name[out_pos] = '\0';
+
+
+ if (bracket && (str[pos] == '}'))
+ pos++;
+
+ *new_pos = pos;
+
+ return true;
+}
+
+static const char *var_val(char *var_name)
+{
+ const char *val;
+
+ if (strcmp(var_name, "type")==0)
+ return g_conf.type;
+ if (strcmp(var_name, "id")==0)
+ return g_conf.id;
+ if (strcmp(var_name, "num")==0)
+ return g_conf.id;
+ if (strcmp(var_name, "name")==0)
+ return g_conf.name;
+ if (strcmp(var_name, "host")==0)
+ return g_conf.host;
+
+ val = getenv(var_name);
+ if (!val)
+ val = "";
+
+ return val;
+}
+
+#define MAX_LINE 256
+#define MAX_VAR_LEN 32
+
+char *conf_post_process_val(const char *val)
+{
+ char var_name[MAX_VAR_LEN];
+ char *buf;
+ int i=0;
+ size_t out_pos = 0;
+ size_t max_line = MAX_LINE;
+
+ buf = (char *)malloc(max_line);
+ *buf = 0;
+
+ while (val[i]) {
+ if (val[i] == '$') {
+ if (get_var(val, i+1, var_name, MAX_VAR_LEN, &i)) {
+ out_pos = dyn_snprintf(&buf, &max_line, 2, "%s%s", buf, var_val(var_name));
+ } else {
+ ++i;
+ }
+ } else {
+ if (out_pos == max_line - 1) {
+ max_line *= 2;
+ buf = (char *)realloc(buf, max_line);
+ }
+ buf[out_pos] = val[i];
+ buf[out_pos + 1] = '\0';
+ ++out_pos;
+ ++i;
+ }
+ }
+
+ buf[out_pos] = '\0';
+
+ return buf;
+}
+
+#define OPT_READ_TYPE(ret, section, var, type, out, def) \
+do { \
+ if (def) \
+ ret = g_conf.cf->read(section, var, (type *)out, *(type *)def); \
+ else \
+ ret = g_conf.cf->read(section, var, (type *)out, 0); \
+} while (0)
+
+int conf_read_key_ext(const char *conf_name, const char *conf_alt_name, const char *conf_type,
+ const char *alt_section, const char *key, opt_type_t type, void *out, void *def,
+ bool free_old_val)
+{
+ int s;
+ int ret;
+ char *tmp = 0;
+ for (s=0; s<5; s++) {
+ const char *section;
+
+ switch (s) {
+ case 0:
+ section = conf_name;
+ if (section)
+ break;
+ case 1:
+ section = conf_alt_name;
+ if (section)
+ break;
+ case 2:
+ s = 2;
+ section = conf_type;
+ if (section)
+ break;
+ case 3:
+ s = 3;
+ section = alt_section;
+ if (section)
+ break;
+ default:
+ s = 4;
+ section = "global";
+ }
+
+ switch (type) {
+ case OPT_STR:
+ if (free_old_val)
+ tmp = *(char **)out;
+ OPT_READ_TYPE(ret, section, key, char *, out, def);
+ if (free_old_val &&
+ *(char **)out != tmp)
+ free(tmp);
+ break;
+ case OPT_BOOL:
+ OPT_READ_TYPE(ret, section, key, bool, out, def);
+ break;
+ case OPT_LONGLONG:
+ OPT_READ_TYPE(ret, section, key, long long, out, def);
+ break;
+ case OPT_INT:
+ OPT_READ_TYPE(ret, section, key, int, out, def);
+ break;
+ case OPT_FLOAT:
+ OPT_READ_TYPE(ret, section, key, float, out, def);
+ break;
+ case OPT_DOUBLE:
+ OPT_READ_TYPE(ret, section, key, double, out, def);
+ break;
+ case OPT_ADDR:
+ ret = g_conf.cf->read(section, key, &tmp, (char *)def);
+ if (*tmp == *((char *)def)) {
+ ret = 0;
+ }
+ else {
+ ret = 1;
+ }
+ if ((1 == ret) &&!(((entity_addr_t*)out)->parse(tmp))) {
+ cerr << "Addr " << tmp << " failed to parse! Shutting down" << std::endl;
+ exit(1);
+ }
+ break;
+ case OPT_U32:
+ OPT_READ_TYPE(ret, section, key, uint32_t, out, def);
+ break;
+ default:
+ ret = 0;
+ break;
+ }
+
+ if (ret)
+ break;
+ }
+
+ return ret;
+}
+
+int conf_read_key(const char *alt_section, const char *key, opt_type_t type, void *out, void *def, bool free_old_val)
+{
+ return conf_read_key_ext(g_conf.name, g_conf.alt_name, g_conf.type,
+ alt_section, key, type, out, def, free_old_val);
+}
+
+bool parse_config_file(ConfFile *cf, bool auto_update)
+{
+ int opt_len = sizeof(config_optionsp)/sizeof(config_option);
+
+ cf->set_post_process_func(conf_post_process_val);
+ if (!cf->parse())
+ return false;
+
+ for (int i=0; i<opt_len; i++) {
+ config_option *opt = &config_optionsp[i];
+ conf_read_key(NULL, opt->conf_name, opt->type, opt->val_ptr, opt->val_ptr, true);
+ }
+ conf_read_key(NULL, "lockdep", OPT_INT, &g_lockdep, &g_lockdep, false);
+
+ return true;
+}
+
+bool is_bool_param(const char *param)
+{
+ return ((strcasecmp(param, "true")==0) || (strcasecmp(param, "false")==0));
+}
+
+bool ceph_resolve_file_search(std::string& filename_list, std::string& result)
+{
+ list<string> ls;
+ get_str_list(filename_list, ls);
+
+ list<string>::iterator iter;
+ for (iter = ls.begin(); iter != ls.end(); ++iter) {
+ int fd = ::open(iter->c_str(), O_RDONLY);
+ if (fd < 0)
+ continue;
+
+ close(fd);
+ result = *iter;
+ return true;
+ }
+
+ return false;
+}
+
+md_config_t::md_config_t()
+ : cf(NULL)
+{
+ //
+ // Note: because our md_config_t structure is a global, the memory used to
+ // store it will start out zeroed. So there is no need to manually initialize
+ // everything to 0 here.
+ //
+ // However, it's good practice to add your new config option to config_optionsp
+ // so that its default value is explicit rather than implicit.
+ //
+
+ int len = sizeof(config_optionsp)/sizeof(config_option);
+ int i;
+ config_option *opt;
+
+ for (i = 0; i<len; i++) {
+ opt = &config_optionsp[i];
+ if (opt->val_ptr) {
+ conf_reset_val(opt->val_ptr, opt->type);
+ }
+ if (!conf_set_conf_val(opt->val_ptr,
+ opt->type,
+ opt->def_str,
+ opt->def_longlong,
+ opt->def_double)) {
+ std::ostringstream oss;
+ oss << "error initializing g_conf value num " << i;
+ assert(oss.str().c_str() == 0);
+ }
+
+ set_conf_name(opt);
+ }
+
+ g_conf.id = strdup("admin");
+}
+
+md_config_t::~md_config_t()
+{
+ int len = sizeof(config_optionsp)/sizeof(config_option);
+ int i;
+ config_option *opt;
+
+ for (i = 0; i<len; i++) {
+ opt = &config_optionsp[i];
+ if (opt->type == OPT_STR) {
+ free(*(char **)opt->val_ptr);
+ }
+ free((void *)opt->conf_name);
+ }
+
+ delete cf;
+ cf = NULL;
+}
+
--- /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.
+ *
+ */
+
+#ifndef CEPH_CONFIG_H
+#define CEPH_CONFIG_H
+
+extern struct ceph_file_layout g_default_file_layout;
+
+#include <vector>
+#include <map>
+
+#include "include/assert.h"
+
+#include "common/Mutex.h"
+
+#define OSD_REP_PRIMARY 0
+#define OSD_REP_SPLAY 1
+#define OSD_REP_CHAIN 2
+
+
+#include "msg/msg_types.h"
+
+#ifdef HAVE_LIBTCMALLOC
+#include <google/heap-profiler.h>
+#endif //HAVE_LIBTCMALLOC
+
+struct EntityName;
+
+enum log_to_stderr_t {
+ LOG_TO_STDERR_NONE = 0,
+ LOG_TO_STDERR_SOME = 1,
+ LOG_TO_STDERR_ALL = 2,
+};
+
+struct ConfFile;
+
+struct md_config_t {
+ md_config_t();
+ ~md_config_t();
+
+ ConfFile *cf;
+
+ char *type;
+ char *id;
+ char *name;
+ char *alt_name;
+ char *host;
+
+ int num_client;
+
+ //bool mkfs;
+
+ const char *monmap;
+ const char *mon_host;
+ bool daemonize;
+
+ //profiling
+ bool tcmalloc_have;
+ bool tcmalloc_profiler_run;
+ void (*profiler_start)(const char*);
+ bool (*profiler_running)();
+ void (*profiler_stop)();
+ void (*profiler_dump)(const char*);
+ int profiler_allocation_interval;
+ int profiler_highwater_interval;
+
+ // profiling logger
+ bool profiling_logger;
+ int profiling_logger_interval;
+ bool profiling_logger_calc_variance;
+ const char *profiling_logger_subdir;
+ const char *profiling_logger_dir;
+
+ const char *log_file;
+ const char *log_dir;
+ const char *log_sym_dir;
+ int log_sym_history;
+
+ int log_to_stderr;
+
+ bool log_to_syslog;
+ bool log_per_instance;
+ bool log_to_file;
+
+ bool clog_to_monitors;
+ bool clog_to_syslog;
+
+ const char *pid_file;
+
+ char *conf;
+
+ const char *chdir;
+
+ int kill_after;
+
+ long long max_open_files;
+
+ int debug;
+ int debug_lockdep;
+ int debug_mds;
+ int debug_mds_balancer;
+ int debug_mds_log;
+ int debug_mds_log_expire;
+ int debug_mds_migrator;
+ int debug_buffer;
+ int debug_timer;
+ int debug_filer;
+ int debug_objecter;
+ int debug_rados;
+ int debug_rbd;
+ int debug_journaler;
+ int debug_objectcacher;
+ int debug_client;
+ int debug_osd;
+ int debug_ebofs;
+ int debug_filestore;
+ int debug_journal;
+ int debug_bdev;
+ int debug_ms;
+ int debug_mon;
+ int debug_monc;
+ int debug_paxos;
+ int debug_tp;
+ int debug_auth;
+ int debug_finisher;
+
+ // auth
+ char *key;
+ char *keyfile;
+ char *keyring;
+
+ // messenger
+
+ /*bool tcp_skip_rank0;
+ bool tcp_overlay_clients;
+ bool tcp_log;
+ bool tcp_serial_marshall;
+ bool tcp_serial_out;
+ bool tcp_multi_out;
+ bool tcp_multi_dispatch;
+ */
+ entity_addr_t public_addr;
+ entity_addr_t cluster_addr;
+
+ bool ms_tcp_nodelay;
+ double ms_initial_backoff;
+ double ms_max_backoff;
+ bool ms_nocrc;
+ bool ms_die_on_bad_msg;
+ uint64_t ms_dispatch_throttle_bytes;
+ bool ms_bind_ipv6;
+ uint64_t ms_rwthread_stack_bytes;
+ uint64_t ms_tcp_read_timeout;
+ uint64_t ms_inject_socket_failures;
+
+ // mon
+ const char *mon_data;
+ int mon_tick_interval;
+ double mon_subscribe_interval;
+ int mon_osd_down_out_interval;
+ float mon_lease;
+ float mon_lease_renew_interval;
+ float mon_clock_drift_allowed;
+ float mon_clock_drift_warn_backoff;
+ float mon_lease_ack_timeout;
+ float mon_accept_timeout;
+ float mon_pg_create_interval;
+ int mon_osd_full_ratio;
+ int mon_osd_nearfull_ratio;
+ int mon_globalid_prealloc;
+ int mon_osd_report_timeout;
+
+ double paxos_propose_interval;
+ double paxos_min_wait;
+ double paxos_observer_timeout;
+
+ // auth
+ char *auth_supported;
+ double auth_mon_ticket_ttl;
+ double auth_service_ticket_ttl;
+ EntityName *entity_name;
+
+ double mon_client_hunt_interval;
+ double mon_client_ping_interval;
+
+ // client
+ int client_cache_size;
+ float client_cache_mid;
+ int client_cache_stat_ttl;
+ int client_cache_readdir_ttl;
+ bool client_use_random_mds; // debug flag
+ double client_mount_timeout;
+ double client_unmount_timeout;
+ double client_tick_interval;
+ const char *client_trace;
+ long long client_readahead_min;
+ long long client_readahead_max_bytes;
+ long long client_readahead_max_periods;
+ const char *client_snapdir;
+ const char *client_mountpoint;
+
+ // objectcacher
+ bool client_oc;
+ int client_oc_size;
+ int client_oc_max_dirty;
+ int client_oc_target_dirty;
+ long long unsigned client_oc_max_sync_write;
+
+ int client_notify_timeout;
+
+ // objecter
+ double objecter_mon_retry_interval;
+ double objecter_tick_interval;
+ double objecter_timeout;
+ uint64_t objecter_inflight_op_bytes;
+
+ // journaler
+ bool journaler_allow_split_entries;
+ bool journaler_safe;
+ int journaler_write_head_interval;
+ bool journaler_cache;
+ int journaler_prefetch_periods;
+ double journaler_batch_interval;
+ long long unsigned journaler_batch_max;
+
+ // mds
+ uint64_t mds_max_file_size;
+ int mds_cache_size;
+ float mds_cache_mid;
+ int mds_mem_max;
+ float mds_dir_commit_ratio;
+ int mds_dir_max_commit_size;
+
+ float mds_decay_halflife;
+
+ float mds_beacon_interval;
+ float mds_beacon_grace;
+ float mds_blacklist_interval;
+
+ float mds_session_timeout;
+ float mds_session_autoclose;
+ float mds_reconnect_timeout;
+
+ float mds_tick_interval;
+ float mds_dirstat_min_interval;
+ float mds_scatter_nudge_interval;
+
+ int mds_client_prealloc_inos;
+ bool mds_early_reply;
+
+ bool mds_use_tmap;
+
+ int mds_default_dir_hash;
+
+ bool mds_log;
+ bool mds_log_unsafe;
+ bool mds_log_skip_corrupt_events;
+ int mds_log_max_events;
+ int mds_log_max_segments;
+ int mds_log_max_expiring;
+ int mds_log_eopen_size;
+
+ float mds_bal_sample_interval;
+ float mds_bal_replicate_threshold;
+ float mds_bal_unreplicate_threshold;
+ bool mds_bal_frag;
+ int mds_bal_split_size;
+ float mds_bal_split_rd;
+ float mds_bal_split_wr;
+ int mds_bal_split_bits;
+ int mds_bal_merge_size;
+ float mds_bal_merge_rd;
+ float mds_bal_merge_wr;
+ int mds_bal_interval;
+ int mds_bal_fragment_interval;
+ float mds_bal_idle_threshold;
+ int mds_bal_max;
+ int mds_bal_max_until;
+
+ int mds_bal_mode;
+ float mds_bal_min_rebalance;
+ float mds_bal_min_start;
+ float mds_bal_need_min;
+ float mds_bal_need_max;
+ float mds_bal_midchunk;
+ float mds_bal_minchunk;
+
+ int mds_bal_target_removal_min;
+ int mds_bal_target_removal_max;
+
+ float mds_replay_interval;
+
+ int mds_shutdown_check;
+
+ int mds_thrash_exports;
+ int mds_thrash_fragments;
+ bool mds_dump_cache_on_map;
+ bool mds_dump_cache_after_rejoin;
+
+ // set these to non-zero to specify kill points
+ bool mds_verify_scatter;
+ bool mds_debug_scatterstat;
+ bool mds_debug_frag;
+ int mds_kill_mdstable_at;
+ int mds_kill_export_at;
+ int mds_kill_import_at;
+ int mds_kill_rename_at;
+
+ bool mds_wipe_sessions;
+ bool mds_wipe_ino_prealloc;
+ int mds_skip_ino;
+ int max_mds;
+
+ int mds_standby_for_rank;
+ char* mds_standby_for_name;
+ bool mds_standby_replay;
+
+ // osd
+ const char *osd_data;
+ const char *osd_journal;
+ int osd_journal_size; // in mb
+ int osd_max_write_size; // in MB
+ bool osd_balance_reads;
+ int osd_flash_crowd_iat_threshold; // flash crowd interarrival time threshold in ms
+ double osd_flash_crowd_iat_alpha;
+
+ int osd_shed_reads;
+ double osd_shed_reads_min_latency;
+ double osd_shed_reads_min_latency_diff;
+ double osd_shed_reads_min_latency_ratio;
+
+ uint64_t osd_client_message_size_cap;
+
+ double osd_stat_refresh_interval;
+
+ int osd_pg_bits;
+ int osd_pgp_bits;
+ int osd_lpg_bits;
+ int osd_pg_layout;
+ int osd_min_rep;
+ int osd_max_rep;
+ int osd_min_raid_width;
+ int osd_max_raid_width;
+
+ int osd_pool_default_crush_rule;
+ int osd_pool_default_size;
+ int osd_pool_default_pg_num;
+ int osd_pool_default_pgp_num;
+
+ int osd_op_threads;
+ int osd_max_opq;
+ int osd_disk_threads;
+ int osd_recovery_threads;
+
+ float osd_age;
+ int osd_age_time;
+ int osd_heartbeat_interval;
+ int osd_mon_heartbeat_interval;
+ int osd_heartbeat_grace;
+ int osd_mon_report_interval_max;
+ int osd_mon_report_interval_min;
+ int osd_min_down_reporters;
+ int osd_min_down_reports;
+ int osd_replay_window;
+ bool osd_preserve_trimmed_log;
+
+ float osd_recovery_delay_start;
+ int osd_recovery_max_active;
+ uint64_t osd_recovery_max_chunk;
+
+ bool osd_recovery_forget_lost_objects;
+
+ bool osd_auto_weight;
+
+ double osd_class_error_timeout;
+ double osd_class_timeout;
+ const char *osd_class_tmp;
+
+ int osd_max_scrubs;
+ float osd_scrub_load_threshold;
+ float osd_scrub_min_interval;
+ float osd_scrub_max_interval;
+
+ bool osd_check_for_log_corruption; // bleh
+
+ bool osd_use_stale_snap;
+
+ uint32_t osd_max_notify_timeout;
+
+ // filestore
+ bool filestore;
+ double filestore_max_sync_interval;
+ double filestore_min_sync_interval;
+ bool filestore_fake_attrs;
+ bool filestore_fake_collections;
+ const char *filestore_dev;
+ bool filestore_btrfs_trans;
+ bool filestore_btrfs_snap;
+ bool filestore_btrfs_clone_range;
+ bool filestore_fsync_flushes_journal_data;
+ bool filestore_flusher;
+ int filestore_flusher_max_fds;
+ bool filestore_sync_flush;
+ bool filestore_journal_parallel;
+ bool filestore_journal_writeahead;
+ bool filestore_journal_trailing;
+ int filestore_queue_max_ops;
+ int filestore_queue_max_bytes;
+ int filestore_op_threads;
+ float filestore_commit_timeout;
+
+ // ebofs
+ bool ebofs;
+ bool ebofs_cloneable;
+ bool ebofs_verify;
+ int ebofs_commit_ms;
+ int ebofs_oc_size;
+ int ebofs_cc_size;
+ unsigned long long ebofs_bc_size;
+ unsigned long long ebofs_bc_max_dirty;
+ unsigned ebofs_max_prefetch;
+ bool ebofs_realloc;
+ bool ebofs_verify_csum_on_read;
+
+ // journal
+ bool journal_dio;
+ bool journal_block_align;
+ int journal_max_write_bytes;
+ int journal_max_write_entries;
+ int journal_queue_max_ops;
+ int journal_queue_max_bytes;
+ int journal_align_min_size;
+
+ // block device
+ bool bdev_lock;
+ int bdev_iothreads;
+ int bdev_idle_kick_after_ms;
+ int bdev_el_fw_max_ms;
+ int bdev_el_bw_max_ms;
+ bool bdev_el_bidir;
+ int bdev_iov_max;
+ bool bdev_debug_check_io_overlap;
+ int bdev_fake_mb;
+ int bdev_fake_max_mb;
+
+#ifdef USE_OSBDB
+ bool bdbstore;
+ int debug_bdbstore;
+ bool bdbstore_btree;
+ int bdbstore_ffactor;
+ int bdbstore_nelem;
+ int bdbstore_pagesize;
+ int bdbstore_cachesize;
+ bool bdbstore_transactional;
+#endif // USE_OSBDB
+};
+
+extern md_config_t g_conf;
+
+typedef enum {
+ OPT_NONE, OPT_INT, OPT_LONGLONG, OPT_STR, OPT_DOUBLE, OPT_FLOAT, OPT_BOOL,
+ OPT_ADDR, OPT_U32
+} opt_type_t;
+
+char *conf_post_process_val(const char *val);
+int conf_read_key(const char *alt_section, const char *key, opt_type_t type, void *out, void *def, bool free_old_val = false);
+bool conf_set_conf_val(void *field, opt_type_t type, const char *val);
+bool conf_cmd_equals(const char *cmd, const char *opt, char char_opt, unsigned int *val_pos);
+int ceph_def_conf_by_name(const char *name, char *buf, int len);
+
+bool ceph_resolve_file_search(string& filename_list, string& result);
+
+#define CONF_NEXT_VAL (val_pos ? &args[i][val_pos] : args[++i])
+
+#define CONF_SET_ARG_VAL(dest, type) \
+ conf_set_conf_val(dest, type, CONF_NEXT_VAL)
+
+#define CONF_VAL args[i]
+
+#define CONF_SAFE_SET_ARG_VAL_USAGE(dest, type, show_usage) \
+ do { \
+ __isarg = i+1 < args.size(); \
+ if (__isarg && !val_pos && \
+ args[i+1][0] == '-' && args[i+1][1] != '\0') \
+ __isarg = false; \
+ if (type == OPT_BOOL) { \
+ if (val_pos) { \
+ CONF_SET_ARG_VAL(dest, type); \
+ } else \
+ conf_set_conf_val(dest, type, "true"); \
+ } else if (__isarg || val_pos) { \
+ CONF_SET_ARG_VAL(dest, type); \
+ } else if (show_usage && args_usage) \
+ args_usage(); \
+ } while (0)
+
+#define CONF_SAFE_SET_ARG_VAL(dest, type) CONF_SAFE_SET_ARG_VAL_USAGE(dest, type, true)
+
+#define CONF_SET_BOOL_ARG_VAL(dest) \
+ conf_set_conf_val(dest, OPT_BOOL, (val_pos ? &args[i][val_pos] : "true"))
+
+#define CONF_ARG_EQ(str_cmd, char_cmd) \
+ conf_cmd_equals(args[i], str_cmd, char_cmd, &val_pos)
+
+struct config_option {
+ const char *section;
+ const char *conf_name;
+ const char *name;
+ void *val_ptr;
+
+ const char *def_str;
+ long long def_longlong;
+ double def_double;
+
+ opt_type_t type;
+ char char_option; // if any
+};
+
+extern struct config_option config_optionsp[];
+extern const int num_config_options;
+
+extern bool parse_config_file(ConfFile *cf, bool auto_update);
+
+#include "common/debug.h"
+
+#endif
#include "common/DoutStreambuf.h"
-#include "config.h"
+#include "common/config.h"
#include "debug.h"
#include <iostream>
#define CEPH_DEBUG_H
#include "common/likely.h"
-#include "config.h" // need for g_conf
+#include "common/config.h" // need for g_conf
#include "include/assert.h"
#include <iostream>
#include <ext/hash_map>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS lockdep
*
*/
-#include "config.h"
+#include "common/config.h"
#include "common/debug.h"
#include "common/errno.h"
#include "common/ProfLogger.h"
#include "common/debug.h"
#include "common/signal.h"
-#include "config.h"
+#include "common/config.h"
#include <signal.h>
#include <sstream>
*
*/
-#include "config.h"
+#include "common/config.h"
#include "ceph_ver.h"
#include "common/debug.h"
#include "common/version.h"
+++ /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 "auth/Auth.h"
-#include "common/BackTrace.h"
-#include "common/Clock.h"
-#include "common/ConfUtils.h"
-#include "common/ProfLogger.h"
-#include "common/common_init.h"
-#include "common/dyn_snprintf.h"
-#include "common/version.h"
-#include "config.h"
-#include "include/atomic.h"
-#include "include/str_list.h"
-#include "include/types.h"
-#include "msg/msg_types.h"
-#include "osd/osd_types.h"
-
-#include <fcntl.h>
-#include <fstream>
-#include <stdlib.h>
-#include <string.h>
-#include <syslog.h>
-#include <sys/stat.h>
-#include <sys/types.h>
-
-/* Don't use standard Ceph logging in this file.
- * We can't use logging until it's initialized, and a lot of the necessary
- * initialization happens here.
- */
-#undef dout
-#undef pdout
-#undef derr
-#undef generic_dout
-#undef dendl
-
-/* The Ceph configuration. */
-md_config_t g_conf __attribute__((init_priority(103)));
-
-#define _STR(x) #x
-#define STRINGIFY(x) _STR(x)
-
-
-#define OPTION_OPT_STR(section, name, schar, type, def_val) \
- { STRINGIFY(section), NULL, STRINGIFY(name), \
- &g_conf.name, def_val, 0, 0, type, schar }
-
-#define OPTION_OPT_ADDR(section, name, schar, type, def_val) \
- { STRINGIFY(section), NULL, STRINGIFY(name), \
- &g_conf.name, def_val, 0, 0, type, schar }
-
-#define OPTION_OPT_LONGLONG(section, name, schar, type, def_val) \
- { STRINGIFY(section), NULL, STRINGIFY(name), \
- &g_conf.name, 0, def_val, 0, type, schar }
-#define OPTION_OPT_INT OPTION_OPT_LONGLONG
-#define OPTION_OPT_BOOL OPTION_OPT_INT
-
-#define OPTION_OPT_DOUBLE(section, name, schar, type, def_val) \
- { STRINGIFY(section), NULL, STRINGIFY(name), \
- &g_conf.name, 0, 0, def_val, type, schar }
-#define OPTION_OPT_FLOAT OPTION_OPT_DOUBLE
-
-#define OPTION(name, schar, type, def_val) OPTION_##type("global", name, schar, type, def_val)
-
-#define OPTION_ALT(section, conf_name, name, schar, type, def_val) \
- { STRINGIFY(section), NULL, STRINGIFY(conf_name), \
- &g_conf.name, STRINGIFY(def_val), type, schar }
-
-struct config_option config_optionsp[] = {
- OPTION(host, 0, OPT_STR, "localhost"),
- OPTION(public_addr, 0, OPT_ADDR, ""),
- OPTION(cluster_addr, 0, OPT_ADDR, ""),
- OPTION(num_client, 0, OPT_INT, 1),
- OPTION(monmap, 'M', OPT_STR, 0),
- OPTION(mon_host, 'm', OPT_STR, 0),
- OPTION(daemonize, 'd', OPT_BOOL, false),
- OPTION(tcmalloc_profiler_run, 0, OPT_BOOL, false),
- OPTION(profiler_allocation_interval, 0, OPT_INT, 1073741824),
- OPTION(profiler_highwater_interval, 0, OPT_INT, 104857600),
- OPTION(profiling_logger, 0, OPT_BOOL, false),
- OPTION(profiling_logger_interval, 0, OPT_INT, 1),
- OPTION(profiling_logger_calc_variance, 0, OPT_BOOL, false),
- OPTION(profiling_logger_subdir, 0, OPT_STR, 0),
- OPTION(profiling_logger_dir, 0, OPT_STR, "/var/log/ceph/stat"),
- OPTION(log_file, 0, OPT_STR, 0),
- OPTION(log_dir, 0, OPT_STR, "/var/log/ceph"),
- OPTION(log_sym_dir, 0, OPT_STR, 0),
- OPTION(log_sym_history, 0, OPT_INT, 10),
- OPTION(log_to_stderr, 0, OPT_INT, LOG_TO_STDERR_SOME),
- OPTION(log_to_syslog, 0, OPT_BOOL, false),
- OPTION(log_per_instance, 0, OPT_BOOL, false),
- OPTION(log_to_file, 0, OPT_BOOL, true),
- OPTION(clog_to_monitors, 0, OPT_BOOL, true),
- OPTION(clog_to_syslog, 0, OPT_BOOL, false),
- OPTION(pid_file, 0, OPT_STR, "/var/run/ceph/$type.$id.pid"),
- OPTION(conf, 'c', OPT_STR, "/etc/ceph/ceph.conf, ~/.ceph/config, ceph.conf"),
- OPTION(chdir, 0, OPT_STR, "/"),
- OPTION(kill_after, 0, OPT_INT, 0),
- OPTION(max_open_files, 0, OPT_LONGLONG, 0),
- OPTION(debug, 0, OPT_INT, 0),
- OPTION(debug_lockdep, 0, OPT_INT, 0),
- OPTION(debug_mds, 0, OPT_INT, 1),
- OPTION(debug_mds_balancer, 0, OPT_INT, 1),
- OPTION(debug_mds_log, 0, OPT_INT, 1),
- OPTION(debug_mds_log_expire, 0, OPT_INT, 1),
- OPTION(debug_mds_migrator, 0, OPT_INT, 1),
- OPTION(debug_buffer, 0, OPT_INT, 0),
- OPTION(debug_timer, 0, OPT_INT, 0),
- OPTION(debug_filer, 0, OPT_INT, 0),
- OPTION(debug_objecter, 0, OPT_INT, 0),
- OPTION(debug_rados, 0, OPT_INT, 0),
- OPTION(debug_rbd, 0, OPT_INT, 0),
- OPTION(debug_journaler, 0, OPT_INT, 0),
- OPTION(debug_objectcacher, 0, OPT_INT, 0),
- OPTION(debug_client, 0, OPT_INT, 0),
- OPTION(debug_osd, 0, OPT_INT, 0),
- OPTION(debug_ebofs, 0, OPT_INT, 1),
- OPTION(debug_filestore, 0, OPT_INT, 1),
- OPTION(debug_journal, 0, OPT_INT, 1),
- OPTION(debug_bdev, 0, OPT_INT, 1), // block device
- OPTION(debug_ms, 0, OPT_INT, 0),
- OPTION(debug_mon, 0, OPT_INT, 1),
- OPTION(debug_monc, 0, OPT_INT, 0),
- OPTION(debug_paxos, 0, OPT_INT, 0),
- OPTION(debug_tp, 0, OPT_INT, 0),
- OPTION(debug_auth, 0, OPT_INT, 1),
- OPTION(debug_finisher, 0, OPT_INT, 1),
- OPTION(key, 0, OPT_STR, ""),
- OPTION(keyfile, 'K', OPT_STR, ""),
- OPTION(keyring, 'k', OPT_STR, "/etc/ceph/keyring,/etc/ceph/keyring.bin"),
- OPTION(ms_tcp_nodelay, 0, OPT_BOOL, true),
- OPTION(ms_initial_backoff, 0, OPT_DOUBLE, .2),
- OPTION(ms_max_backoff, 0, OPT_DOUBLE, 15.0),
- OPTION(ms_nocrc, 0, OPT_BOOL, false),
- OPTION(ms_die_on_bad_msg, 0, OPT_BOOL, false),
- OPTION(ms_dispatch_throttle_bytes, 0, OPT_INT, 100 << 20),
- OPTION(ms_bind_ipv6, 0, OPT_BOOL, false),
- OPTION(ms_rwthread_stack_bytes, 0, OPT_INT, 1024 << 10),
- OPTION(ms_tcp_read_timeout, 0, OPT_LONGLONG, 900),
- OPTION(ms_inject_socket_failures, 0, OPT_LONGLONG, 0),
- OPTION(mon_data, 0, OPT_STR, ""),
- OPTION(mon_tick_interval, 0, OPT_INT, 5),
- OPTION(mon_subscribe_interval, 0, OPT_DOUBLE, 300),
- OPTION(mon_osd_down_out_interval, 0, OPT_INT, 300), // seconds
- OPTION(mon_lease, 0, OPT_FLOAT, 5), // lease interval
- OPTION(mon_lease_renew_interval, 0, OPT_FLOAT, 3), // on leader, to renew the lease
- OPTION(mon_lease_ack_timeout, 0, OPT_FLOAT, 10.0), // on leader, if lease isn't acked by all peons
- OPTION(mon_clock_drift_allowed, 0, OPT_FLOAT, .010), // allowed clock drift between monitors
- OPTION(mon_clock_drift_warn_backoff, 0, OPT_FLOAT, 5), // exponential backoff for clock drift warnings
- OPTION(mon_accept_timeout, 0, OPT_FLOAT, 10.0), // on leader, if paxos update isn't accepted
- OPTION(mon_pg_create_interval, 0, OPT_FLOAT, 30.0), // no more than every 30s
- OPTION(mon_osd_full_ratio, 0, OPT_INT, 95), // what % full makes an OSD "full"
- OPTION(mon_osd_nearfull_ratio, 0, OPT_INT, 85), // what % full makes an OSD near full
- OPTION(mon_globalid_prealloc, 0, OPT_INT, 100), // how many globalids to prealloc
- OPTION(mon_osd_report_timeout, 0, OPT_INT, 900), // grace period before declaring unresponsive OSDs dead
- OPTION(paxos_propose_interval, 0, OPT_DOUBLE, 1.0), // gather updates for this long before proposing a map update
- OPTION(paxos_min_wait, 0, OPT_DOUBLE, 0.05), // min time to gather updates for after period of inactivity
- OPTION(paxos_observer_timeout, 0, OPT_DOUBLE, 5*60), // gather updates for this long before proposing a map update
- OPTION(auth_supported, 0, OPT_STR, "none"),
- OPTION(auth_mon_ticket_ttl, 0, OPT_DOUBLE, 60*60*12),
- OPTION(auth_service_ticket_ttl, 0, OPT_DOUBLE, 60*60),
- OPTION(mon_client_hunt_interval, 0, OPT_DOUBLE, 3.0), // try new mon every N seconds until we connect
- OPTION(mon_client_ping_interval, 0, OPT_DOUBLE, 10.0), // ping every N seconds
- OPTION(client_cache_size, 0, OPT_INT, 16384),
- OPTION(client_cache_mid, 0, OPT_FLOAT, .75),
- OPTION(client_cache_stat_ttl, 0, OPT_INT, 0), // seconds until cached stat results become invalid
- OPTION(client_cache_readdir_ttl, 0, OPT_INT, 1), // 1 second only
- OPTION(client_use_random_mds, 0, OPT_BOOL, false),
- OPTION(client_mount_timeout, 0, OPT_DOUBLE, 30.0),
- OPTION(client_unmount_timeout, 0, OPT_DOUBLE, 10.0),
- OPTION(client_tick_interval, 0, OPT_DOUBLE, 1.0),
- OPTION(client_trace, 0, OPT_STR, 0),
- OPTION(client_readahead_min, 0, OPT_LONGLONG, 128*1024), // readahead at _least_ this much.
- OPTION(client_readahead_max_bytes, 0, OPT_LONGLONG, 0), //8 * 1024*1024,
- OPTION(client_readahead_max_periods, 0, OPT_LONGLONG, 4), // as multiple of file layout period (object size * num stripes)
- OPTION(client_snapdir, 0, OPT_STR, ".snap"),
- OPTION(client_mountpoint, 'r', OPT_STR, "/"),
- OPTION(client_notify_timeout, 0, OPT_INT, 10), // in seconds
- OPTION(client_oc, 0, OPT_BOOL, true),
- OPTION(client_oc_size, 0, OPT_INT, 1024*1024* 200), // MB * n
- OPTION(client_oc_max_dirty, 0, OPT_INT, 1024*1024* 100), // MB * n (dirty OR tx.. bigish)
- OPTION(client_oc_target_dirty, 0, OPT_INT, 1024*1024* 8), // target dirty (keep this smallish)
- // note: the max amount of "in flight" dirty data is roughly (max - target)
- OPTION(client_oc_max_sync_write, 0, OPT_LONGLONG, 128*1024), // sync writes >= this use wrlock
- OPTION(objecter_tick_interval, 0, OPT_DOUBLE, 5.0),
- OPTION(objecter_mon_retry_interval, 0, OPT_DOUBLE, 5.0),
- OPTION(objecter_timeout, 0, OPT_DOUBLE, 10.0), // before we ask for a map
- OPTION(objecter_inflight_op_bytes, 0, OPT_LONGLONG, 1024*1024*100), //max in-flight data (both directions)
- OPTION(journaler_allow_split_entries, 0, OPT_BOOL, true),
- OPTION(journaler_safe, 0, OPT_BOOL, true), // wait for COMMIT on journal writes
- OPTION(journaler_write_head_interval, 0, OPT_INT, 15),
- OPTION(journaler_cache, 0, OPT_BOOL, false), // cache writes for later readback
- OPTION(journaler_prefetch_periods, 0, OPT_INT, 50), // * journal object size (1~MB? see above)
- OPTION(journaler_batch_interval, 0, OPT_DOUBLE, .001), // seconds.. max add'l latency we artificially incur
- OPTION(journaler_batch_max, 0, OPT_LONGLONG, 0), // max bytes we'll delay flushing; disable, for now....
- OPTION(mds_max_file_size, 0, OPT_LONGLONG, 1ULL << 40),
- OPTION(mds_cache_size, 0, OPT_INT, 100000),
- OPTION(mds_cache_mid, 0, OPT_FLOAT, .7),
- OPTION(mds_mem_max, 0, OPT_INT, 1048576), // KB
- OPTION(mds_dir_commit_ratio, 0, OPT_FLOAT, .5),
- OPTION(mds_dir_max_commit_size, 0, OPT_INT, 90), // MB
- OPTION(mds_decay_halflife, 0, OPT_FLOAT, 5),
- OPTION(mds_beacon_interval, 0, OPT_FLOAT, 4),
- OPTION(mds_beacon_grace, 0, OPT_FLOAT, 15),
- OPTION(mds_blacklist_interval, 0, OPT_FLOAT, 24.0*60.0), // how long to blacklist failed nodes
- OPTION(mds_session_timeout, 0, OPT_FLOAT, 60), // cap bits and leases time out if client idle
- OPTION(mds_session_autoclose, 0, OPT_FLOAT, 300), // autoclose idle session
- OPTION(mds_reconnect_timeout, 0, OPT_FLOAT, 45), // seconds to wait for clients during mds restart
- // make it (mds_session_timeout - mds_beacon_grace)
- OPTION(mds_tick_interval, 0, OPT_FLOAT, 5),
- OPTION(mds_dirstat_min_interval, 0, OPT_FLOAT, 1), // try to avoid propagating more often than this
- OPTION(mds_scatter_nudge_interval, 0, OPT_FLOAT, 5), // how quickly dirstat changes propagate up the hierarchy
- OPTION(mds_client_prealloc_inos, 0, OPT_INT, 1000),
- OPTION(mds_early_reply, 0, OPT_BOOL, true),
- OPTION(mds_use_tmap, 0, OPT_BOOL, true), // use trivialmap for dir updates
- OPTION(mds_default_dir_hash, 0, OPT_INT, CEPH_STR_HASH_RJENKINS),
- OPTION(mds_log, 0, OPT_BOOL, true),
- OPTION(mds_log_unsafe, 0, OPT_BOOL, false), // only wait for log sync, when it's mostly safe to do so
- OPTION(mds_log_skip_corrupt_events, 0, OPT_BOOL, false),
- OPTION(mds_log_max_events, 0, OPT_INT, -1),
- OPTION(mds_log_max_segments, 0, OPT_INT, 30), // segment size defined by FileLayout, above
- OPTION(mds_log_max_expiring, 0, OPT_INT, 20),
- OPTION(mds_log_eopen_size, 0, OPT_INT, 100), // # open inodes per log entry
- OPTION(mds_bal_sample_interval, 0, OPT_FLOAT, 3.0), // every 5 seconds
- OPTION(mds_bal_replicate_threshold, 0, OPT_FLOAT, 8000),
- OPTION(mds_bal_unreplicate_threshold, 0, OPT_FLOAT, 0),
- OPTION(mds_bal_frag, 0, OPT_BOOL, false),
- OPTION(mds_bal_split_size, 0, OPT_INT, 10000),
- OPTION(mds_bal_split_rd, 0, OPT_FLOAT, 25000),
- OPTION(mds_bal_split_wr, 0, OPT_FLOAT, 10000),
- OPTION(mds_bal_split_bits, 0, OPT_INT, 3),
- OPTION(mds_bal_merge_size, 0, OPT_INT, 50),
- OPTION(mds_bal_merge_rd, 0, OPT_FLOAT, 1000),
- OPTION(mds_bal_merge_wr, 0, OPT_FLOAT, 1000),
- OPTION(mds_bal_interval, 0, OPT_INT, 10), // seconds
- OPTION(mds_bal_fragment_interval, 0, OPT_INT, 5), // seconds
- OPTION(mds_bal_idle_threshold, 0, OPT_FLOAT, 0),
- OPTION(mds_bal_max, 0, OPT_INT, -1),
- OPTION(mds_bal_max_until, 0, OPT_INT, -1),
- OPTION(mds_bal_mode, 0, OPT_INT, 0),
- OPTION(mds_bal_min_rebalance, 0, OPT_FLOAT, .1), // must be this much above average before we export anything
- OPTION(mds_bal_min_start, 0, OPT_FLOAT, .2), // if we need less than this, we don't do anything
- OPTION(mds_bal_need_min, 0, OPT_FLOAT, .8), // take within this range of what we need
- OPTION(mds_bal_need_max, 0, OPT_FLOAT, 1.2),
- OPTION(mds_bal_midchunk, 0, OPT_FLOAT, .3), // any sub bigger than this taken in full
- OPTION(mds_bal_minchunk, 0, OPT_FLOAT, .001), // never take anything smaller than this
- OPTION(mds_bal_target_removal_min, 0, OPT_INT, 5), // min balance iterations before old target is removed
- OPTION(mds_bal_target_removal_max, 0, OPT_INT, 10), // max balance iterations before old target is removed
- OPTION(mds_replay_interval, 0, OPT_FLOAT, 1.0), // time to wait before starting replay again
- OPTION(mds_shutdown_check, 0, OPT_INT, 0),
- OPTION(mds_thrash_exports, 0, OPT_INT, 0),
- OPTION(mds_thrash_fragments, 0, OPT_INT, 0),
- OPTION(mds_dump_cache_on_map, 0, OPT_BOOL, false),
- OPTION(mds_dump_cache_after_rejoin, 0, OPT_BOOL, false),
- OPTION(mds_verify_scatter, 0, OPT_BOOL, false),
- OPTION(mds_debug_scatterstat, 0, OPT_BOOL, false),
- OPTION(mds_debug_frag, 0, OPT_BOOL, false),
- OPTION(mds_kill_mdstable_at, 0, OPT_INT, 0),
- OPTION(mds_kill_export_at, 0, OPT_INT, 0),
- OPTION(mds_kill_import_at, 0, OPT_INT, 0),
- OPTION(mds_kill_rename_at, 0, OPT_INT, 0),
- OPTION(mds_wipe_sessions, 0, OPT_BOOL, 0),
- OPTION(mds_wipe_ino_prealloc, 0, OPT_BOOL, 0),
- OPTION(mds_skip_ino, 0, OPT_INT, 0),
- OPTION(max_mds, 0, OPT_INT, 1),
- OPTION(mds_standby_for_name, 0, OPT_STR, ""),
- OPTION(mds_standby_for_rank, 0, OPT_INT, -1),
- OPTION(mds_standby_replay, 0, OPT_BOOL, false),
- OPTION(osd_data, 0, OPT_STR, ""),
- OPTION(osd_journal, 0, OPT_STR, ""),
- OPTION(osd_journal_size, 0, OPT_INT, 0), // in mb
- OPTION(osd_max_write_size, 0, OPT_INT, 90),
- OPTION(osd_balance_reads, 0, OPT_BOOL, false),
- OPTION(osd_flash_crowd_iat_threshold, 0, OPT_INT, 0),
- OPTION(osd_flash_crowd_iat_alpha, 0, OPT_DOUBLE, 0.125),
- OPTION(osd_shed_reads, 0, OPT_INT, false), // forward from primary to replica
- OPTION(osd_shed_reads_min_latency, 0, OPT_DOUBLE, .01), // min local latency
- OPTION(osd_shed_reads_min_latency_diff, 0, OPT_DOUBLE, .01), // min latency difference
- OPTION(osd_shed_reads_min_latency_ratio, 0, OPT_DOUBLE, 1.5), // 1.2 == 20% higher than peer
- OPTION(osd_client_message_size_cap, 0, OPT_LONGLONG, 500*1024L*1024L), // default to 200MB client data allowed in-memory
- OPTION(osd_stat_refresh_interval, 0, OPT_DOUBLE, .5),
- OPTION(osd_pg_bits, 0, OPT_INT, 9), // bits per osd
- OPTION(osd_pgp_bits, 0, OPT_INT, 6), // bits per osd
- OPTION(osd_lpg_bits, 0, OPT_INT, 2), // bits per osd
- OPTION(osd_pg_layout, 0, OPT_INT, CEPH_PG_LAYOUT_CRUSH),
- OPTION(osd_min_rep, 0, OPT_INT, 1),
- OPTION(osd_max_rep, 0, OPT_INT, 10),
- OPTION(osd_min_raid_width, 0, OPT_INT, 3),
- OPTION(osd_max_raid_width, 0, OPT_INT, 2),
- OPTION(osd_pool_default_crush_rule, 0, OPT_INT, 0),
- OPTION(osd_pool_default_size, 0, OPT_INT, 2),
- OPTION(osd_pool_default_pg_num, 0, OPT_INT, 8),
- OPTION(osd_pool_default_pgp_num, 0, OPT_INT, 8),
- OPTION(osd_op_threads, 0, OPT_INT, 2), // 0 == no threading
- OPTION(osd_max_opq, 0, OPT_INT, 10),
- OPTION(osd_disk_threads, 0, OPT_INT, 1),
- OPTION(osd_recovery_threads, 0, OPT_INT, 1),
- OPTION(osd_age, 0, OPT_FLOAT, .8),
- OPTION(osd_age_time, 0, OPT_INT, 0),
- OPTION(osd_heartbeat_interval, 0, OPT_INT, 1),
- OPTION(osd_mon_heartbeat_interval, 0, OPT_INT, 30), // if no peers, ping monitor
- OPTION(osd_heartbeat_grace, 0, OPT_INT, 20),
- OPTION(osd_mon_report_interval_max, 0, OPT_INT, 120),
- OPTION(osd_mon_report_interval_min, 0, OPT_INT, 5), // pg stats, failures, up_thru, boot.
- OPTION(osd_min_down_reporters, 0, OPT_INT, 1), // number of OSDs who need to report a down OSD for it to count
- OPTION(osd_min_down_reports, 0, OPT_INT, 3), // number of times a down OSD must be reported for it to count
- OPTION(osd_replay_window, 0, OPT_INT, 45),
- OPTION(osd_preserve_trimmed_log, 0, OPT_BOOL, true),
- OPTION(osd_recovery_delay_start, 0, OPT_FLOAT, 15),
- OPTION(osd_recovery_max_active, 0, OPT_INT, 5),
- OPTION(osd_recovery_max_chunk, 0, OPT_LONGLONG, 1<<20), // max size of push chunk
- OPTION(osd_recovery_forget_lost_objects, 0, OPT_BOOL, false), // off for now
- OPTION(osd_max_scrubs, 0, OPT_INT, 1),
- OPTION(osd_scrub_load_threshold, 0, OPT_FLOAT, 0.5),
- OPTION(osd_scrub_min_interval, 0, OPT_FLOAT, 300),
- OPTION(osd_scrub_max_interval, 0, OPT_FLOAT, 60*60*24), // once a day
- OPTION(osd_auto_weight, 0, OPT_BOOL, false),
- OPTION(osd_class_error_timeout, 0, OPT_DOUBLE, 60.0), // seconds
- OPTION(osd_class_timeout, 0, OPT_DOUBLE, 60*60.0), // seconds
- OPTION(osd_class_tmp, 0, OPT_STR, "/var/lib/ceph/tmp"),
- OPTION(osd_check_for_log_corruption, 0, OPT_BOOL, false),
- OPTION(osd_use_stale_snap, 0, OPT_BOOL, false),
- OPTION(osd_max_notify_timeout, 0, OPT_INT, 30), // max notify timeout in seconds
- OPTION(filestore, 0, OPT_BOOL, false),
- OPTION(filestore_max_sync_interval, 0, OPT_DOUBLE, 5), // seconds
- OPTION(filestore_min_sync_interval, 0, OPT_DOUBLE, .01), // seconds
- OPTION(filestore_fake_attrs, 0, OPT_BOOL, false),
- OPTION(filestore_fake_collections, 0, OPT_BOOL, false),
- OPTION(filestore_dev, 0, OPT_STR, 0),
- OPTION(filestore_btrfs_trans, 0, OPT_BOOL, false),
- OPTION(filestore_btrfs_snap, 0, OPT_BOOL, true),
- OPTION(filestore_btrfs_clone_range, 0, OPT_BOOL, true),
- OPTION(filestore_fsync_flushes_journal_data, 0, OPT_BOOL, false),
- OPTION(filestore_flusher, 0, OPT_BOOL, true),
- OPTION(filestore_flusher_max_fds, 0, OPT_INT, 512),
- OPTION(filestore_sync_flush, 0, OPT_BOOL, false),
- OPTION(filestore_journal_parallel, 0, OPT_BOOL, false),
- OPTION(filestore_journal_writeahead, 0, OPT_BOOL, false),
- OPTION(filestore_journal_trailing, 0, OPT_BOOL, false),
- OPTION(filestore_queue_max_ops, 0, OPT_INT, 500),
- OPTION(filestore_queue_max_bytes, 0, OPT_INT, 100 << 20),
- OPTION(filestore_op_threads, 0, OPT_INT, 2),
- OPTION(filestore_commit_timeout, 0, OPT_FLOAT, 600),
- OPTION(ebofs, 0, OPT_BOOL, false),
- OPTION(ebofs_cloneable, 0, OPT_BOOL, true),
- OPTION(ebofs_verify, 0, OPT_BOOL, false),
- OPTION(ebofs_commit_ms, 0, OPT_INT, 200), // 0 = no forced commit timeout (for debugging/tracing)
- OPTION(ebofs_oc_size, 0, OPT_INT, 10000), // onode cache
- OPTION(ebofs_cc_size, 0, OPT_INT, 10000), // cnode cache
- OPTION(ebofs_bc_size, 0, OPT_LONGLONG, 50*256), // 4k blocks, *256 for MB
- OPTION(ebofs_bc_max_dirty, 0, OPT_LONGLONG, 30*256), // before write() will block
- OPTION(ebofs_max_prefetch, 0, OPT_INT, 1000), // 4k blocks
- OPTION(ebofs_realloc, 0, OPT_BOOL, false), // hrm, this can cause bad fragmentation, don't use!
- OPTION(ebofs_verify_csum_on_read, 0, OPT_BOOL, true),
- OPTION(journal_dio, 0, OPT_BOOL, true),
- OPTION(journal_block_align, 0, OPT_BOOL, true),
- OPTION(journal_max_write_bytes, 0, OPT_INT, 10 << 20),
- OPTION(journal_max_write_entries, 0, OPT_INT, 100),
- OPTION(journal_queue_max_ops, 0, OPT_INT, 500),
- OPTION(journal_queue_max_bytes, 0, OPT_INT, 100 << 20),
- OPTION(journal_align_min_size, 0, OPT_INT, 64 << 10), // align data payloads >= this.
- OPTION(bdev_lock, 0, OPT_BOOL, true),
- OPTION(bdev_iothreads, 0, OPT_INT, 1), // number of ios to queue with kernel
- OPTION(bdev_idle_kick_after_ms, 0, OPT_INT, 100), // ms
- OPTION(bdev_el_fw_max_ms, 0, OPT_INT, 10000), // restart elevator at least once every 1000 ms
- OPTION(bdev_el_bw_max_ms, 0, OPT_INT, 3000), // restart elevator at least once every 300 ms
- OPTION(bdev_el_bidir, 0, OPT_BOOL, false), // bidirectional elevator?
- OPTION(bdev_iov_max, 0, OPT_INT, 512), // max # iov's to collect into a single readv()/writev() call
- OPTION(bdev_debug_check_io_overlap, 0, OPT_BOOL, true), // [DEBUG] check for any pending io overlaps
- OPTION(bdev_fake_mb, 0, OPT_INT, 0),
- OPTION(bdev_fake_max_mb, 0, OPT_INT, 0),
-};
-
-const int num_config_options = sizeof(config_optionsp) / sizeof(config_option);
-
-bool conf_set_conf_val(void *field, opt_type_t type, const char *val)
-{
- switch (type) {
- case OPT_BOOL:
- if (strcasecmp(val, "false") == 0)
- *(bool *)field = false;
- else if (strcasecmp(val, "true") == 0)
- *(bool *)field = true;
- else
- *(bool *)field = (bool)atoi(val);
- break;
- case OPT_INT:
- *(int *)field = atoi(val);
- break;
- case OPT_LONGLONG:
- *(long long *)field = atoll(val);
- break;
- case OPT_STR:
- if (val)
- *(char **)field = strdup(val);
- else
- *(char **)field = NULL;
- break;
- case OPT_FLOAT:
- *(float *)field = atof(val);
- break;
- case OPT_DOUBLE:
- *(double *)field = strtod(val, NULL);
- break;
- case OPT_ADDR:
- ((entity_addr_t *)field)->parse(val);
- break;
- default:
- return false;
- }
-
- return true;
-}
-
-bool conf_set_conf_val(void *field, opt_type_t type, const char *val, long long intval, double doubleval)
-{
- switch (type) {
- case OPT_BOOL:
- *(bool *)field = intval;
- break;
- case OPT_INT:
- *(int *)field = intval;
- break;
- case OPT_LONGLONG:
- *(long long *)field = intval;
- break;
- case OPT_STR:
- if (val) {
- *(char **)field = strdup(val);
- } else {
- *(char **)field = NULL;
- }
- break;
- case OPT_FLOAT:
- *(float *)field = doubleval;
- break;
- case OPT_DOUBLE:
- *(double *)field = doubleval;
- break;
- case OPT_ADDR:
- ((entity_addr_t *)field)->parse(val);
- break;
- default:
- return false;
- }
-
- return true;
-}
-
-static bool conf_reset_val(void *field, opt_type_t type)
-{
- switch (type) {
- case OPT_BOOL:
- *(bool *)field = 0;
- break;
- case OPT_INT:
- *(int *)field = 0;
- break;
- case OPT_LONGLONG:
- *(long long *)field = 0;
- break;
- case OPT_STR:
- *(char **)field = NULL;
- break;
- case OPT_FLOAT:
- *(float *)field = 0;
- break;
- case OPT_DOUBLE:
- *(double *)field = 0;
- break;
- case OPT_ADDR:
- *(entity_addr_t *)field = entity_addr_t();
- break;
- default:
- return false;
- }
-
- return true;
-}
-
-static void set_conf_name(config_option *opt)
-{
- char *newsection = (char *)opt->section;
- char *newconf = (char *)opt->name;
- int i;
-
- if (opt->section[0] == 0) {
- newsection = strdup("global");
- }
-
- if (strncmp(newsection, opt->name, strlen(newsection)) == 0) {
- /* if key starts with the name of the section, remove name of the section
- unless key equals to it */
-
- if (strcmp(newsection, opt->name) == 0)
- goto done;
-
- newconf = strdup(&opt->name[strlen(newsection)+1]);
- } else {
- newconf = strdup(opt->name);
- }
-
- i = 0;
- while (newconf[i]) {
- if (newconf[i] == '_')
- newconf[i] = ' ';
-
- ++i;
- }
-
- done:
- opt->section = newsection;
- opt->conf_name = (const char *)newconf;
-}
-
-static int def_conf_to_str(config_option *opt, char *buf, int len)
-{
- int ret = 0;
-
- switch (opt->type) {
- case OPT_INT:
- case OPT_BOOL:
- ret = snprintf(buf, len, "%d", (int)opt->def_longlong);
- break;
- case OPT_LONGLONG:
- ret = snprintf(buf, len, "%lld", opt->def_longlong);
- break;
- case OPT_STR:
- case OPT_ADDR:
- ret = snprintf(buf, len, "%s", opt->def_str);
- break;
- case OPT_FLOAT:
- case OPT_DOUBLE:
- ret = snprintf(buf, len, "%f", opt->def_double);
- break;
- default:
- break;
- }
- return ret;
-}
-
-int ceph_def_conf_by_name(const char *name, char *buf, int buflen)
-{
- char *newname = strdup(name);
- int len = strlen(name);
- config_option *opt;
- int ret = 0;
- int i;
-
- for (i = 0; i < len; i++) {
- if (newname[i] == ' ')
- newname[i] = '_';
- }
-
- len = sizeof(config_optionsp)/sizeof(config_option);
-
- for (i = 0; i < len; i++) {
- opt = &config_optionsp[i];
- if (strcmp(opt->name, newname) == 0) {
- ret = def_conf_to_str(opt, buf, buflen);
- break;
- }
- }
- free(newname);
- return ret;
-}
-
-static bool cmd_is_char(const char *cmd)
-{
- return ((cmd[0] == '-') &&
- cmd[1] && !cmd[2]);
-}
-
-bool conf_cmd_equals(const char *cmd, const char *opt, char char_opt, unsigned int *val_pos)
-{
- unsigned int i;
- unsigned int len = strlen(opt);
-
- *val_pos = 0;
-
- if (!*cmd)
- return false;
-
- if (char_opt && cmd_is_char(cmd))
- return (char_opt == cmd[1]);
-
- if ((cmd[0] != '-') || (cmd[1] != '-'))
- return false;
-
- for (i=0; i<len; i++) {
- if ((opt[i] == '_') || (opt[i] == '-')) {
- switch (cmd[i+2]) {
- case '-':
- case '_':
- continue;
- default:
- break;
- }
- }
-
- if (cmd[i+2] != opt[i])
- return false;
- }
-
- if (cmd[i+2] == '=')
- *val_pos = i+3;
- else if (cmd[i+2])
- return false;
-
- return true;
-}
-
-static bool get_var(const char *str, int pos, char *var_name, int len, int *new_pos)
-{
- int bracket = (str[pos] == '{');
- int out_pos = 0;
-
- if (bracket) {
- pos++;
- }
-
- while (str[pos] &&
- ((bracket && str[pos] != '}') ||
- isalnum(str[pos]) ||
- str[pos] == '_')) {
- var_name[out_pos] = str[pos];
-
- out_pos ++;
- if (out_pos == len)
- return false;
- pos++;
- }
-
- var_name[out_pos] = '\0';
-
-
- if (bracket && (str[pos] == '}'))
- pos++;
-
- *new_pos = pos;
-
- return true;
-}
-
-static const char *var_val(char *var_name)
-{
- const char *val;
-
- if (strcmp(var_name, "type")==0)
- return g_conf.type;
- if (strcmp(var_name, "id")==0)
- return g_conf.id;
- if (strcmp(var_name, "num")==0)
- return g_conf.id;
- if (strcmp(var_name, "name")==0)
- return g_conf.name;
- if (strcmp(var_name, "host")==0)
- return g_conf.host;
-
- val = getenv(var_name);
- if (!val)
- val = "";
-
- return val;
-}
-
-#define MAX_LINE 256
-#define MAX_VAR_LEN 32
-
-char *conf_post_process_val(const char *val)
-{
- char var_name[MAX_VAR_LEN];
- char *buf;
- int i=0;
- size_t out_pos = 0;
- size_t max_line = MAX_LINE;
-
- buf = (char *)malloc(max_line);
- *buf = 0;
-
- while (val[i]) {
- if (val[i] == '$') {
- if (get_var(val, i+1, var_name, MAX_VAR_LEN, &i)) {
- out_pos = dyn_snprintf(&buf, &max_line, 2, "%s%s", buf, var_val(var_name));
- } else {
- ++i;
- }
- } else {
- if (out_pos == max_line - 1) {
- max_line *= 2;
- buf = (char *)realloc(buf, max_line);
- }
- buf[out_pos] = val[i];
- buf[out_pos + 1] = '\0';
- ++out_pos;
- ++i;
- }
- }
-
- buf[out_pos] = '\0';
-
- return buf;
-}
-
-#define OPT_READ_TYPE(ret, section, var, type, out, def) \
-do { \
- if (def) \
- ret = g_conf.cf->read(section, var, (type *)out, *(type *)def); \
- else \
- ret = g_conf.cf->read(section, var, (type *)out, 0); \
-} while (0)
-
-int conf_read_key_ext(const char *conf_name, const char *conf_alt_name, const char *conf_type,
- const char *alt_section, const char *key, opt_type_t type, void *out, void *def,
- bool free_old_val)
-{
- int s;
- int ret;
- char *tmp = 0;
- for (s=0; s<5; s++) {
- const char *section;
-
- switch (s) {
- case 0:
- section = conf_name;
- if (section)
- break;
- case 1:
- section = conf_alt_name;
- if (section)
- break;
- case 2:
- s = 2;
- section = conf_type;
- if (section)
- break;
- case 3:
- s = 3;
- section = alt_section;
- if (section)
- break;
- default:
- s = 4;
- section = "global";
- }
-
- switch (type) {
- case OPT_STR:
- if (free_old_val)
- tmp = *(char **)out;
- OPT_READ_TYPE(ret, section, key, char *, out, def);
- if (free_old_val &&
- *(char **)out != tmp)
- free(tmp);
- break;
- case OPT_BOOL:
- OPT_READ_TYPE(ret, section, key, bool, out, def);
- break;
- case OPT_LONGLONG:
- OPT_READ_TYPE(ret, section, key, long long, out, def);
- break;
- case OPT_INT:
- OPT_READ_TYPE(ret, section, key, int, out, def);
- break;
- case OPT_FLOAT:
- OPT_READ_TYPE(ret, section, key, float, out, def);
- break;
- case OPT_DOUBLE:
- OPT_READ_TYPE(ret, section, key, double, out, def);
- break;
- case OPT_ADDR:
- ret = g_conf.cf->read(section, key, &tmp, (char *)def);
- if (*tmp == *((char *)def)) {
- ret = 0;
- }
- else {
- ret = 1;
- }
- if ((1 == ret) &&!(((entity_addr_t*)out)->parse(tmp))) {
- cerr << "Addr " << tmp << " failed to parse! Shutting down" << std::endl;
- exit(1);
- }
- break;
- case OPT_U32:
- OPT_READ_TYPE(ret, section, key, uint32_t, out, def);
- break;
- default:
- ret = 0;
- break;
- }
-
- if (ret)
- break;
- }
-
- return ret;
-}
-
-int conf_read_key(const char *alt_section, const char *key, opt_type_t type, void *out, void *def, bool free_old_val)
-{
- return conf_read_key_ext(g_conf.name, g_conf.alt_name, g_conf.type,
- alt_section, key, type, out, def, free_old_val);
-}
-
-bool parse_config_file(ConfFile *cf, bool auto_update)
-{
- int opt_len = sizeof(config_optionsp)/sizeof(config_option);
-
- cf->set_post_process_func(conf_post_process_val);
- if (!cf->parse())
- return false;
-
- for (int i=0; i<opt_len; i++) {
- config_option *opt = &config_optionsp[i];
- conf_read_key(NULL, opt->conf_name, opt->type, opt->val_ptr, opt->val_ptr, true);
- }
- conf_read_key(NULL, "lockdep", OPT_INT, &g_lockdep, &g_lockdep, false);
-
- return true;
-}
-
-bool is_bool_param(const char *param)
-{
- return ((strcasecmp(param, "true")==0) || (strcasecmp(param, "false")==0));
-}
-
-bool ceph_resolve_file_search(std::string& filename_list, std::string& result)
-{
- list<string> ls;
- get_str_list(filename_list, ls);
-
- list<string>::iterator iter;
- for (iter = ls.begin(); iter != ls.end(); ++iter) {
- int fd = ::open(iter->c_str(), O_RDONLY);
- if (fd < 0)
- continue;
-
- close(fd);
- result = *iter;
- return true;
- }
-
- return false;
-}
-
-md_config_t::md_config_t()
- : cf(NULL)
-{
- //
- // Note: because our md_config_t structure is a global, the memory used to
- // store it will start out zeroed. So there is no need to manually initialize
- // everything to 0 here.
- //
- // However, it's good practice to add your new config option to config_optionsp
- // so that its default value is explicit rather than implicit.
- //
-
- int len = sizeof(config_optionsp)/sizeof(config_option);
- int i;
- config_option *opt;
-
- for (i = 0; i<len; i++) {
- opt = &config_optionsp[i];
- if (opt->val_ptr) {
- conf_reset_val(opt->val_ptr, opt->type);
- }
- if (!conf_set_conf_val(opt->val_ptr,
- opt->type,
- opt->def_str,
- opt->def_longlong,
- opt->def_double)) {
- std::ostringstream oss;
- oss << "error initializing g_conf value num " << i;
- assert(oss.str().c_str() == 0);
- }
-
- set_conf_name(opt);
- }
-
- g_conf.id = strdup("admin");
-}
-
-md_config_t::~md_config_t()
-{
- int len = sizeof(config_optionsp)/sizeof(config_option);
- int i;
- config_option *opt;
-
- for (i = 0; i<len; i++) {
- opt = &config_optionsp[i];
- if (opt->type == OPT_STR) {
- free(*(char **)opt->val_ptr);
- }
- free((void *)opt->conf_name);
- }
-
- delete cf;
- cf = NULL;
-}
-
+++ /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.
- *
- */
-
-#ifndef CEPH_CONFIG_H
-#define CEPH_CONFIG_H
-
-extern struct ceph_file_layout g_default_file_layout;
-
-#include <vector>
-#include <map>
-
-#include "include/assert.h"
-
-#include "common/Mutex.h"
-
-#define OSD_REP_PRIMARY 0
-#define OSD_REP_SPLAY 1
-#define OSD_REP_CHAIN 2
-
-
-#include "msg/msg_types.h"
-
-#ifdef HAVE_LIBTCMALLOC
-#include <google/heap-profiler.h>
-#endif //HAVE_LIBTCMALLOC
-
-struct EntityName;
-
-enum log_to_stderr_t {
- LOG_TO_STDERR_NONE = 0,
- LOG_TO_STDERR_SOME = 1,
- LOG_TO_STDERR_ALL = 2,
-};
-
-struct ConfFile;
-
-struct md_config_t {
- md_config_t();
- ~md_config_t();
-
- ConfFile *cf;
-
- char *type;
- char *id;
- char *name;
- char *alt_name;
- char *host;
-
- int num_client;
-
- //bool mkfs;
-
- const char *monmap;
- const char *mon_host;
- bool daemonize;
-
- //profiling
- bool tcmalloc_have;
- bool tcmalloc_profiler_run;
- void (*profiler_start)(const char*);
- bool (*profiler_running)();
- void (*profiler_stop)();
- void (*profiler_dump)(const char*);
- int profiler_allocation_interval;
- int profiler_highwater_interval;
-
- // profiling logger
- bool profiling_logger;
- int profiling_logger_interval;
- bool profiling_logger_calc_variance;
- const char *profiling_logger_subdir;
- const char *profiling_logger_dir;
-
- const char *log_file;
- const char *log_dir;
- const char *log_sym_dir;
- int log_sym_history;
-
- int log_to_stderr;
-
- bool log_to_syslog;
- bool log_per_instance;
- bool log_to_file;
-
- bool clog_to_monitors;
- bool clog_to_syslog;
-
- const char *pid_file;
-
- char *conf;
-
- const char *chdir;
-
- int kill_after;
-
- long long max_open_files;
-
- int debug;
- int debug_lockdep;
- int debug_mds;
- int debug_mds_balancer;
- int debug_mds_log;
- int debug_mds_log_expire;
- int debug_mds_migrator;
- int debug_buffer;
- int debug_timer;
- int debug_filer;
- int debug_objecter;
- int debug_rados;
- int debug_rbd;
- int debug_journaler;
- int debug_objectcacher;
- int debug_client;
- int debug_osd;
- int debug_ebofs;
- int debug_filestore;
- int debug_journal;
- int debug_bdev;
- int debug_ms;
- int debug_mon;
- int debug_monc;
- int debug_paxos;
- int debug_tp;
- int debug_auth;
- int debug_finisher;
-
- // auth
- char *key;
- char *keyfile;
- char *keyring;
-
- // messenger
-
- /*bool tcp_skip_rank0;
- bool tcp_overlay_clients;
- bool tcp_log;
- bool tcp_serial_marshall;
- bool tcp_serial_out;
- bool tcp_multi_out;
- bool tcp_multi_dispatch;
- */
- entity_addr_t public_addr;
- entity_addr_t cluster_addr;
-
- bool ms_tcp_nodelay;
- double ms_initial_backoff;
- double ms_max_backoff;
- bool ms_nocrc;
- bool ms_die_on_bad_msg;
- uint64_t ms_dispatch_throttle_bytes;
- bool ms_bind_ipv6;
- uint64_t ms_rwthread_stack_bytes;
- uint64_t ms_tcp_read_timeout;
- uint64_t ms_inject_socket_failures;
-
- // mon
- const char *mon_data;
- int mon_tick_interval;
- double mon_subscribe_interval;
- int mon_osd_down_out_interval;
- float mon_lease;
- float mon_lease_renew_interval;
- float mon_clock_drift_allowed;
- float mon_clock_drift_warn_backoff;
- float mon_lease_ack_timeout;
- float mon_accept_timeout;
- float mon_pg_create_interval;
- int mon_osd_full_ratio;
- int mon_osd_nearfull_ratio;
- int mon_globalid_prealloc;
- int mon_osd_report_timeout;
-
- double paxos_propose_interval;
- double paxos_min_wait;
- double paxos_observer_timeout;
-
- // auth
- char *auth_supported;
- double auth_mon_ticket_ttl;
- double auth_service_ticket_ttl;
- EntityName *entity_name;
-
- double mon_client_hunt_interval;
- double mon_client_ping_interval;
-
- // client
- int client_cache_size;
- float client_cache_mid;
- int client_cache_stat_ttl;
- int client_cache_readdir_ttl;
- bool client_use_random_mds; // debug flag
- double client_mount_timeout;
- double client_unmount_timeout;
- double client_tick_interval;
- const char *client_trace;
- long long client_readahead_min;
- long long client_readahead_max_bytes;
- long long client_readahead_max_periods;
- const char *client_snapdir;
- const char *client_mountpoint;
-
- // objectcacher
- bool client_oc;
- int client_oc_size;
- int client_oc_max_dirty;
- int client_oc_target_dirty;
- long long unsigned client_oc_max_sync_write;
-
- int client_notify_timeout;
-
- // objecter
- double objecter_mon_retry_interval;
- double objecter_tick_interval;
- double objecter_timeout;
- uint64_t objecter_inflight_op_bytes;
-
- // journaler
- bool journaler_allow_split_entries;
- bool journaler_safe;
- int journaler_write_head_interval;
- bool journaler_cache;
- int journaler_prefetch_periods;
- double journaler_batch_interval;
- long long unsigned journaler_batch_max;
-
- // mds
- uint64_t mds_max_file_size;
- int mds_cache_size;
- float mds_cache_mid;
- int mds_mem_max;
- float mds_dir_commit_ratio;
- int mds_dir_max_commit_size;
-
- float mds_decay_halflife;
-
- float mds_beacon_interval;
- float mds_beacon_grace;
- float mds_blacklist_interval;
-
- float mds_session_timeout;
- float mds_session_autoclose;
- float mds_reconnect_timeout;
-
- float mds_tick_interval;
- float mds_dirstat_min_interval;
- float mds_scatter_nudge_interval;
-
- int mds_client_prealloc_inos;
- bool mds_early_reply;
-
- bool mds_use_tmap;
-
- int mds_default_dir_hash;
-
- bool mds_log;
- bool mds_log_unsafe;
- bool mds_log_skip_corrupt_events;
- int mds_log_max_events;
- int mds_log_max_segments;
- int mds_log_max_expiring;
- int mds_log_eopen_size;
-
- float mds_bal_sample_interval;
- float mds_bal_replicate_threshold;
- float mds_bal_unreplicate_threshold;
- bool mds_bal_frag;
- int mds_bal_split_size;
- float mds_bal_split_rd;
- float mds_bal_split_wr;
- int mds_bal_split_bits;
- int mds_bal_merge_size;
- float mds_bal_merge_rd;
- float mds_bal_merge_wr;
- int mds_bal_interval;
- int mds_bal_fragment_interval;
- float mds_bal_idle_threshold;
- int mds_bal_max;
- int mds_bal_max_until;
-
- int mds_bal_mode;
- float mds_bal_min_rebalance;
- float mds_bal_min_start;
- float mds_bal_need_min;
- float mds_bal_need_max;
- float mds_bal_midchunk;
- float mds_bal_minchunk;
-
- int mds_bal_target_removal_min;
- int mds_bal_target_removal_max;
-
- float mds_replay_interval;
-
- int mds_shutdown_check;
-
- int mds_thrash_exports;
- int mds_thrash_fragments;
- bool mds_dump_cache_on_map;
- bool mds_dump_cache_after_rejoin;
-
- // set these to non-zero to specify kill points
- bool mds_verify_scatter;
- bool mds_debug_scatterstat;
- bool mds_debug_frag;
- int mds_kill_mdstable_at;
- int mds_kill_export_at;
- int mds_kill_import_at;
- int mds_kill_rename_at;
-
- bool mds_wipe_sessions;
- bool mds_wipe_ino_prealloc;
- int mds_skip_ino;
- int max_mds;
-
- int mds_standby_for_rank;
- char* mds_standby_for_name;
- bool mds_standby_replay;
-
- // osd
- const char *osd_data;
- const char *osd_journal;
- int osd_journal_size; // in mb
- int osd_max_write_size; // in MB
- bool osd_balance_reads;
- int osd_flash_crowd_iat_threshold; // flash crowd interarrival time threshold in ms
- double osd_flash_crowd_iat_alpha;
-
- int osd_shed_reads;
- double osd_shed_reads_min_latency;
- double osd_shed_reads_min_latency_diff;
- double osd_shed_reads_min_latency_ratio;
-
- uint64_t osd_client_message_size_cap;
-
- double osd_stat_refresh_interval;
-
- int osd_pg_bits;
- int osd_pgp_bits;
- int osd_lpg_bits;
- int osd_pg_layout;
- int osd_min_rep;
- int osd_max_rep;
- int osd_min_raid_width;
- int osd_max_raid_width;
-
- int osd_pool_default_crush_rule;
- int osd_pool_default_size;
- int osd_pool_default_pg_num;
- int osd_pool_default_pgp_num;
-
- int osd_op_threads;
- int osd_max_opq;
- int osd_disk_threads;
- int osd_recovery_threads;
-
- float osd_age;
- int osd_age_time;
- int osd_heartbeat_interval;
- int osd_mon_heartbeat_interval;
- int osd_heartbeat_grace;
- int osd_mon_report_interval_max;
- int osd_mon_report_interval_min;
- int osd_min_down_reporters;
- int osd_min_down_reports;
- int osd_replay_window;
- bool osd_preserve_trimmed_log;
-
- float osd_recovery_delay_start;
- int osd_recovery_max_active;
- uint64_t osd_recovery_max_chunk;
-
- bool osd_recovery_forget_lost_objects;
-
- bool osd_auto_weight;
-
- double osd_class_error_timeout;
- double osd_class_timeout;
- const char *osd_class_tmp;
-
- int osd_max_scrubs;
- float osd_scrub_load_threshold;
- float osd_scrub_min_interval;
- float osd_scrub_max_interval;
-
- bool osd_check_for_log_corruption; // bleh
-
- bool osd_use_stale_snap;
-
- uint32_t osd_max_notify_timeout;
-
- // filestore
- bool filestore;
- double filestore_max_sync_interval;
- double filestore_min_sync_interval;
- bool filestore_fake_attrs;
- bool filestore_fake_collections;
- const char *filestore_dev;
- bool filestore_btrfs_trans;
- bool filestore_btrfs_snap;
- bool filestore_btrfs_clone_range;
- bool filestore_fsync_flushes_journal_data;
- bool filestore_flusher;
- int filestore_flusher_max_fds;
- bool filestore_sync_flush;
- bool filestore_journal_parallel;
- bool filestore_journal_writeahead;
- bool filestore_journal_trailing;
- int filestore_queue_max_ops;
- int filestore_queue_max_bytes;
- int filestore_op_threads;
- float filestore_commit_timeout;
-
- // ebofs
- bool ebofs;
- bool ebofs_cloneable;
- bool ebofs_verify;
- int ebofs_commit_ms;
- int ebofs_oc_size;
- int ebofs_cc_size;
- unsigned long long ebofs_bc_size;
- unsigned long long ebofs_bc_max_dirty;
- unsigned ebofs_max_prefetch;
- bool ebofs_realloc;
- bool ebofs_verify_csum_on_read;
-
- // journal
- bool journal_dio;
- bool journal_block_align;
- int journal_max_write_bytes;
- int journal_max_write_entries;
- int journal_queue_max_ops;
- int journal_queue_max_bytes;
- int journal_align_min_size;
-
- // block device
- bool bdev_lock;
- int bdev_iothreads;
- int bdev_idle_kick_after_ms;
- int bdev_el_fw_max_ms;
- int bdev_el_bw_max_ms;
- bool bdev_el_bidir;
- int bdev_iov_max;
- bool bdev_debug_check_io_overlap;
- int bdev_fake_mb;
- int bdev_fake_max_mb;
-
-#ifdef USE_OSBDB
- bool bdbstore;
- int debug_bdbstore;
- bool bdbstore_btree;
- int bdbstore_ffactor;
- int bdbstore_nelem;
- int bdbstore_pagesize;
- int bdbstore_cachesize;
- bool bdbstore_transactional;
-#endif // USE_OSBDB
-};
-
-extern md_config_t g_conf;
-
-typedef enum {
- OPT_NONE, OPT_INT, OPT_LONGLONG, OPT_STR, OPT_DOUBLE, OPT_FLOAT, OPT_BOOL,
- OPT_ADDR, OPT_U32
-} opt_type_t;
-
-char *conf_post_process_val(const char *val);
-int conf_read_key(const char *alt_section, const char *key, opt_type_t type, void *out, void *def, bool free_old_val = false);
-bool conf_set_conf_val(void *field, opt_type_t type, const char *val);
-bool conf_cmd_equals(const char *cmd, const char *opt, char char_opt, unsigned int *val_pos);
-int ceph_def_conf_by_name(const char *name, char *buf, int len);
-
-bool ceph_resolve_file_search(string& filename_list, string& result);
-
-#define CONF_NEXT_VAL (val_pos ? &args[i][val_pos] : args[++i])
-
-#define CONF_SET_ARG_VAL(dest, type) \
- conf_set_conf_val(dest, type, CONF_NEXT_VAL)
-
-#define CONF_VAL args[i]
-
-#define CONF_SAFE_SET_ARG_VAL_USAGE(dest, type, show_usage) \
- do { \
- __isarg = i+1 < args.size(); \
- if (__isarg && !val_pos && \
- args[i+1][0] == '-' && args[i+1][1] != '\0') \
- __isarg = false; \
- if (type == OPT_BOOL) { \
- if (val_pos) { \
- CONF_SET_ARG_VAL(dest, type); \
- } else \
- conf_set_conf_val(dest, type, "true"); \
- } else if (__isarg || val_pos) { \
- CONF_SET_ARG_VAL(dest, type); \
- } else if (show_usage && args_usage) \
- args_usage(); \
- } while (0)
-
-#define CONF_SAFE_SET_ARG_VAL(dest, type) CONF_SAFE_SET_ARG_VAL_USAGE(dest, type, true)
-
-#define CONF_SET_BOOL_ARG_VAL(dest) \
- conf_set_conf_val(dest, OPT_BOOL, (val_pos ? &args[i][val_pos] : "true"))
-
-#define CONF_ARG_EQ(str_cmd, char_cmd) \
- conf_cmd_equals(args[i], str_cmd, char_cmd, &val_pos)
-
-struct config_option {
- const char *section;
- const char *conf_name;
- const char *name;
- void *val_ptr;
-
- const char *def_str;
- long long def_longlong;
- double def_double;
-
- opt_type_t type;
- char char_option; // if any
-};
-
-extern struct config_option config_optionsp[];
-extern const int num_config_options;
-
-extern bool parse_config_file(ConfFile *cf, bool auto_update);
-
-#include "common/debug.h"
-
-#endif
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "mon/MonMap.h"
#include "mon/MonClient.h"
#include <sys/stat.h>
-#include "config.h"
+#include "common/config.h"
#include "common/ceph_argparse.h"
#include "common/common_init.h"
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "client/SyntheticClient.h"
#include "client/Client.h"
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "mon/MonMap.h"
#include "mon/MonClient.h"
-#include "config.h"
+#include "common/config.h"
#include "Allocator.h"
#include "Ebofs.h"
*
*/
-#include "config.h"
+#include "common/config.h"
#include "BlockDevice.h"
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "mon/MonMap.h"
#ifndef CEPH_CONTEXT_H
#define CEPH_CONTEXT_H
-#include "config.h"
+#include "common/config.h"
#include "assert.h"
#include <list>
#include <stdint.h>
-#include "config.h"
+#include "common/config.h"
*/
#define __STDC_FORMAT_MACROS
-#include "config.h"
+#include "common/config.h"
#include "common/ceph_argparse.h"
#include "common/common_init.h"
#include <pthread.h>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "mon/MonMap.h"
#include "mds/MDS.h"
*/
#define __STDC_FORMAT_MACROS
-#include "config.h"
+#include "common/config.h"
#include "common/common_init.h"
#include "common/ceph_argparse.h"
#include "messages/MMDSTableRequest.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#include "osdc/Objecter.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#include "include/types.h"
#include "include/buffer.h"
#include "mdstypes.h"
-#include "config.h"
+#include "common/config.h"
#include "common/DecayCounter.h"
#include <iostream>
#include <string>
#include <stdio.h>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#ifndef CEPH_CINODE_H
#define CEPH_CINODE_H
-#include "config.h"
+#include "common/config.h"
#include "include/dlist.h"
#include "include/elist.h"
#include "include/types.h"
#include "include/buffer.h"
#include "include/xlist.h"
-#include "config.h"
+#include "common/config.h"
/*
#include "include/types.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#include <errno.h>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
*
*/
-#include "config.h"
+#include "common/config.h"
#include "LogEvent.h"
#include "MDS.h"
using std::map;
using std::vector;
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef DOUT_COND
#include <map>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#include "events/ESubtreeMap.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef DOUT_COND
#include "auth/AuthAuthorizeHandler.h"
#include "auth/KeyRing.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "include/CompatSet.h"
#include "include/types.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#include "messages/MMDSTableRequest.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#include <iostream>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#include "SessionMap.h"
#include "osdc/Filer.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#include "msg/Messenger.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef dout_prefix
#ifndef CEPH_EEXPORT_H
#define CEPH_EEXPORT_H
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "../MDS.h"
#ifndef CEPH_EIMPORTFINISH_H
#define CEPH_EIMPORTFINISH_H
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "../MDS.h"
#ifndef CEPH_EIMPORTSTART_H
#define CEPH_EIMPORTSTART_H
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "../MDS.h"
#ifndef CEPH_MDS_ESESSION_H
#define CEPH_MDS_ESESSION_H
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "../LogEvent.h"
#ifndef CEPH_MDS_ESESSIONS_H
#define CEPH_MDS_ESESSIONS_H
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "../LogEvent.h"
#ifndef CEPH_MDS_ETABLECLIENT_H
#define CEPH_MDS_ETABLECLIENT_H
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "../mds_table_types.h"
#ifndef CEPH_MDS_ETABLESERVER_H
#define CEPH_MDS_ETABLESERVER_H
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "../mds_table_types.h"
*
*/
-#include "config.h"
+#include "common/config.h"
#include "osdc/Journaler.h"
#include "events/EString.h"
#include "events/ESubtreeMap.h"
#include "Locker.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mds
#undef DOUT_COND
#include <map>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "common/DecayCounter.h"
#include "include/Context.h"
#include "osd/osd_types.h"
#include "osd/PG.h" // yuck
-#include "config.h"
+#include "common/config.h"
#include <sstream>
#define DOUT_SUBSYS mon
#include "osd/osd_types.h"
#include "osd/PG.h" // yuck
-#include "config.h"
+#include "common/config.h"
#include <sstream>
#define DOUT_SUBSYS mon
#include "MonmapMonitor.h"
#include "messages/MMonElection.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mon
#undef dout_prefix
#include "osd/osd_types.h"
#include "osd/PG.h" // yuck
-#include "config.h"
+#include "common/config.h"
#include <sstream>
#define DOUT_SUBSYS mon
#include <sstream>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mon
#undef dout_prefix
#include <errno.h>
-#include "config.h"
+#include "common/config.h"
#include "MonCaps.h"
#include "mon_types.h"
#include "include/str_list.h"
#include "include/addr_parsing.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS monc
#include "msg/Message.h"
#include "include/types.h"
-//#include "config.h"
+//#include "common/config.h"
class MonMap {
public:
#include "auth/AuthSupported.h"
-#include "config.h"
+#include "common/config.h"
#include <errno.h>
#include <limits.h>
#include "common/errno.h"
#include "common/run_cmd.h"
#include "common/safe_io.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mon
#undef dout_prefix
#include "mon/PGMonitor.h"
#include <sstream>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS mon
#undef dout_prefix
#include "common/Timer.h"
-#include "config.h"
+#include "common/config.h"
#include <sstream>
#define CEPH_PGMAP_H
#include "osd/osd_types.h"
-#include "config.h"
+#include "common/config.h"
#include <sstream>
class PGMap {
#include "osd/osd_types.h"
#include "osd/PG.h" // yuck
-#include "config.h"
+#include "common/config.h"
#include <sstream>
#define DOUT_SUBSYS mon
#include "messages/MMonPaxos.h"
#include "messages/MMonObserveNotify.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS paxos
#undef dout_prefix
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS paxos
#undef dout_prefix
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "common/ceph_argparse.h"
#include "common/common_init.h"
#include "mon/MonMap.h"
#define CEPH_DISPATCHER_H
#include "Message.h"
-#include "config.h"
+#include "common/config.h"
#include "auth/Auth.h"
class Messenger;
#include "messages/MWatchNotify.h"
-#include "config.h"
+#include "common/config.h"
#define DEBUGLVL 10 // debug level of output
/* public message types */
#include "include/types.h"
-#include "config.h"
+#include "common/config.h"
// monitor internal
#define MSG_MON_ELECTION 65
#include <limits.h>
#include <sys/user.h>
-#include "config.h"
+#include "common/config.h"
#include "messages/MGenericMessage.h"
#include <poll.h>
#include "tcp.h"
-#include "config.h"
+#include "common/config.h"
/******************
* tcp crap
-#include "config.h"
+#include "common/config.h"
#include "objclass/objclass.h"
#include "osd/OSD.h"
-#include "config.h"
+#include "common/config.h"
#include "objclass/objclass.h"
*
*/
-#include "config.h"
+#include "common/config.h"
#include "common/errno.h"
#include "common/safe_io.h"
#include "FileJournal.h"
# endif
#endif
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS filestore
#undef dout_prefix
#include "JournalingObjectStore.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS journal
#undef dout_prefix
#include "ObjectStore.h"
-#include "config.h"
+#include "common/config.h"
#include "common/Clock.h"
#define dout_prefix *_dout << "ager: "
#include "Ager.h"
#include "os/ObjectStore.h"
-#include "config.h"
+#include "common/config.h"
#include "common/Clock.h"
// ick
#include "objclass/objclass.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS osd
#undef dout_prefix
#include "OSDCaps.h"
-#include "config.h"
+#include "common/config.h"
#include "OSDMap.h"
-#include "config.h"
+#include "common/config.h"
* disks, disk groups, total # osds,
*
*/
-#include "config.h"
+#include "common/config.h"
#include "include/types.h"
#include "osd_types.h"
#include "msg/Message.h"
#include "PG.h"
-#include "config.h"
+#include "common/config.h"
#include "OSD.h"
#include "common/Timer.h"
#include "messages/MOSDPGNotify.h"
#include "messages/MOSDPGRemove.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS osd
#undef dout_prefix
#include "mds/inode_backtrace.h" // Ugh
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS osd
#define DOUT_PREFIX_ARGS this, osd->whoami, osd->osdmap
#include "ReplicatedPG.h"
#include "Watch.h"
-#include "config.h"
+#include "common/config.h"
bool Watch::ack_notification(entity_name_t& watcher, Notification *notif)
{
#include <map>
#include "OSD.h"
-#include "config.h"
+#include "common/config.h"
class MWatchNotify;
#include "include/Context.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS filer
#undef dout_prefix
#include "common/ProfLogger.h"
#include "msg/Messenger.h"
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS journaler
#undef dout_prefix
#include <errno.h>
-#include "config.h"
+#include "common/config.h"
#define DOUT_SUBSYS objecter
#undef dout_prefix
* it will just loop forever.
*/
#include "include/rados/librados.h"
-#include "config.h"
+#include "common/config.h"
#include "common/common_init.h"
#include "common/Cond.h"
#include <iostream>
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "common/errno.h"
#include "osd/OSDMap.h"
#include "crush/CrushWrapper.h"
#include "osd/OSDMap.h"
-#include "config.h"
+#include "common/config.h"
#include "include/buffer.h"
int main(int argc, char **argv)
#include "osdc/rados_bencher.h"
-#include "config.h"
+#include "common/config.h"
#include "common/ceph_argparse.h"
#include "common/common_init.h"
#include "common/Cond.h"
*/
#define __STDC_FORMAT_MACROS
-#include "config.h"
+#include "common/config.h"
#include "common/errno.h"
#include "common/ceph_argparse.h"
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include <cryptopp/osrng.h>
#include "common/ceph_argparse.h"
#include "common/DoutStreambuf.h"
#include "common/ceph_argparse.h"
#include "common/common_init.h"
-#include "config.h"
+#include "common/config.h"
#include <iostream>
#include <sstream>
#include "common/ceph_argparse.h"
#include "common/common_init.h"
#include "common/errno.h"
-#include "config.h"
+#include "common/config.h"
#include <errno.h>
#include <iostream>
*/
#include "common/armor.h"
-#include "config.h"
+#include "common/config.h"
#include "include/buffer.h"
#include "include/encoding.h"
-#include "config.h"
+#include "common/config.h"
#include "include/buffer.h"
#include "include/encoding.h"
* Foundation. See file COPYING.
*
*/
-#include "config.h"
+#include "common/config.h"
#include "include/Context.h"
#include "gtest/gtest.h"
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "messages/MPing.h"
#include "common/Mutex.h"
-#include "config.h"
+#include "common/config.h"
#include "common/run_cmd.h"
#include "gtest/gtest.h"
-#include "config.h"
+#include "common/config.h"
#include "common/signal.h"
#include "gtest/gtest.h"
#include "auth/Crypto.h"
#include "common/Clock.h"
-#include "config.h"
+#include "common/config.h"
#define AES_KEY_LEN 16
#include "auth/cephx/CephxKeyServer.h"
-#include "config.h"
+#include "common/config.h"
#define AES_KEY_LEN 16
#include <string>
using namespace std;
-#include "config.h"
+#include "common/config.h"
#include "mon/MonMap.h"
#include "mon/MonClient.h"
#include "common/common_init.h"
#include "common/errno.h"
#include "common/safe_io.h"
-#include "config.h"
+#include "common/config.h"
#include "tools/common.h"
#include <limits.h>
#include "common/common_init.h"
#include "common/ceph_argparse.h"
-#include "config.h"
+#include "common/config.h"
#include "tools/common.h"
#include <iostream>
projects / ceph.git / commitdiff