// FUSE will chdir("/"); be ready.
g_conf.chdir = strdup("/");
- if (g_conf.clock_tare) g_clock.tare();
-
// check for 32-bit arch
if (sizeof(long) == 4) {
cerr << std::endl;
usage();
}
- if (g_conf.clock_tare) g_clock.tare();
-
// get monmap
RotatingKeyRing rkeys(CEPH_ENTITY_TYPE_MDS, &g_keyring);
MonClient mc(&rkeys);
return 0;
}
- if (g_conf.clock_tare) g_clock.tare();
-
CompatSet mon_features(ceph_mon_feature_compat,
ceph_mon_feature_ro_compat,
ceph_mon_feature_incompat);
Mutex lock;
public:
- Clock() : lock("Clock::lock") {
- // set offset
- //tare();
- }
+ Clock() : lock("Clock::lock") { }
// real time.
utime_t real_now() {
return realnow;
}
- // relative time (from startup)
- void tare() {
- struct timeval tv;
- gettimeofday(&tv, NULL);
- zero.set_from_timeval(&tv);
- }
- void tare(utime_t z) {
- zero = z;
- }
utime_t now() {
//lock.Lock();
struct timeval tv;
OPTION(key, 0, OPT_STR, ""),
OPTION(keyfile, 'K', OPT_STR, ""),
OPTION(keyring, 'k', OPT_STR, "/etc/ceph/keyring,/etc/ceph/keyring.bin"),
- OPTION(clock_tare, 0, OPT_BOOL, false),
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),
int debug_auth;
int debug_finisher;
- // clock
- bool clock_tare;
-
// auth
char *key;
char *keyfile;
#endif //HAVE_LIBTCMALLOC
common_init(args, "osd", should_authenticate);
- if (g_conf.clock_tare) g_clock.tare();
-
// osd specific args
bool mkfs = false;
bool mkjournal = false;
vec_to_argv(args, argc, argv);
- if (g_conf.clock_tare) g_clock.tare();
-
// get monmap
MonClient mc;
if (mc.build_initial_monmap() < 0)
// FUSE will chdir("/"); be ready.
g_conf.use_abspaths = true;
- if (g_conf.clock_tare) g_clock.tare();
-
MonMap *monmap = new MonMap(g_conf.num_mon);
entity_addr_t a;
a.nonce = getpid();
//if (g_conf.kill_after)
//g_timer.add_event_after(g_conf.kill_after, new C_Die);
- if (g_conf.clock_tare) g_clock.tare();
-
MonMap *monmap = new MonMap(g_conf.num_mon);
entity_addr_t a;
argv_to_vec(argc, argv, args);
common_set_defaults(false);
common_init(args, "libceph", true);
- if (g_conf.clock_tare) g_clock.tare();
//monmap
monclient = new MonClient();
if (monclient->build_initial_monmap() < 0) {
common_set_defaults(false);
common_init(args, "librados", true);
- if (g_conf.clock_tare) g_clock.tare();
-
client = new RadosClient();
return client->init();
}
}
common_set_defaults(false);
common_init(args, "librados", true);
-
- if (g_conf.clock_tare) g_clock.tare();
}
static Mutex rados_init_mutex("rados_init");
RGWUserInfo info;
RGWAccess *store;
- if (g_conf.clock_tare) g_clock.tare();
-
FOR_EACH_ARG(args) {
if (CONF_ARG_EQ("user-gen", 'g')) {
gen_user = true;