delete monc;
delete messenger;
delete fsmap;
- assert(waiting_for_mds_map == NULL);
+ ceph_assert(waiting_for_mds_map == NULL);
}
int MDSUtility::init()
{
// Initialize Messenger
- int r = messenger->bind(g_conf->public_addr);
+ int r = messenger->bind(g_conf()->public_addr);
if (r < 0)
return r;
Mutex init_lock("MDSUtility:init");
Cond cond;
bool done = false;
- assert(!fsmap->get_epoch());
+ ceph_assert(!fsmap->get_epoch());
lock.Lock();
waiting_for_mds_map = new C_SafeCond(&init_lock, &cond, &done, NULL);
lock.Unlock();
}
-bool MDSUtility::ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer,
- bool force_new)
+bool MDSUtility::ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer)
{
if (dest_type == CEPH_ENTITY_TYPE_MON)
return true;
- if (force_new) {
- if (monc->wait_auth_rotating(10) < 0)
- return false;
- }
-
*authorizer = monc->build_authorizer(dest_type);
return *authorizer != NULL;
}