return true;
}
-void PG::build_prior(std::auto_ptr<PriorSet> &prior_set)
+void PG::build_prior(std::unique_ptr<PriorSet> &prior_set)
{
if (1) {
// sanity check
PG *pg = context< RecoveryMachine >().pg;
pg->generate_past_intervals();
- auto_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
+ unique_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
assert(pg->blocked_by.empty());
void PG::RecoveryState::GetInfo::get_infos()
{
PG *pg = context< RecoveryMachine >().pg;
- auto_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
+ unique_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
pg->blocked_by.clear();
for (set<pg_shard_t>::const_iterator it = prior_set->probe.begin();
epoch_t old_start = pg->info.history.last_epoch_started;
if (pg->proc_replica_info(infoevt.from, infoevt.notify.info)) {
// we got something new ...
- auto_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
+ unique_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
if (old_start < pg->info.history.last_epoch_started) {
dout(10) << " last_epoch_started moved forward, rebuilding prior" << dendl;
pg->build_prior(prior_set);
pg->state_clear(PG_STATE_PEERING);
pg->state_set(PG_STATE_INCOMPLETE);
- auto_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
+ unique_ptr<PriorSet> &prior_set = context< Peering >().prior_set;
assert(pg->blocked_by.empty());
pg->blocked_by.insert(prior_set->down.begin(), prior_set->down.end());
pg->publish_stats_to_osd();
bool _calc_past_interval_range(epoch_t *start, epoch_t *end, epoch_t oldest_map);
void generate_past_intervals();
void trim_past_intervals();
- void build_prior(std::auto_ptr<PriorSet> &prior_set);
+ void build_prior(std::unique_ptr<PriorSet> &prior_set);
void remove_down_peer_info(const OSDMapRef osdmap);
struct Active;
struct Peering : boost::statechart::state< Peering, Primary, GetInfo >, NamedState {
- std::auto_ptr< PriorSet > prior_set;
+ std::unique_ptr< PriorSet > prior_set;
Peering(my_context ctx);
void exit();
};
TEST(AdminSocket, Teardown) {
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketTest asoct(asokc.get());
ASSERT_EQ(true, asoct.shutdown());
}
TEST(AdminSocket, TeardownSetup) {
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketTest asoct(asokc.get());
ASSERT_EQ(true, asoct.shutdown());
}
TEST(AdminSocket, SendHelp) {
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketTest asoct(asokc.get());
ASSERT_EQ(true, asoct.shutdown());
}
TEST(AdminSocket, SendNoOp) {
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketTest asoct(asokc.get());
ASSERT_EQ(true, asoct.shutdown());
};
TEST(AdminSocket, RegisterCommand) {
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketTest asoct(asokc.get());
ASSERT_EQ(true, asoct.shutdown());
};
TEST(AdminSocket, RegisterCommandPrefixes) {
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketTest asoct(asokc.get());
ASSERT_EQ(true, asoct.shutdown());
TEST(AdminSocketClient, Ping) {
string path = get_rand_socket_path();
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketClient client(path);
// no socket
TEST(AdminSocket, bind_and_listen) {
string path = get_rand_socket_path();
- std::auto_ptr<AdminSocket>
+ std::unique_ptr<AdminSocket>
asokc(new AdminSocket(g_ceph_context));
AdminSocketTest asoct(asokc.get());