dout(10) << "project_alloc_id " << id << " to " << projected_free << "/" << free << dendl;
assert(is_active());
if (!id)
- id = projected_free.start();
+ id = projected_free.range_start();
projected_free.erase(id);
++projected_version;
return id;
{
assert(is_active());
while (want > 0) {
- inodeno_t start = projected_free.start();
+ inodeno_t start = projected_free.range_start();
inodeno_t end = projected_free.end_after(start);
inodeno_t num = end - start;
if (num > (inodeno_t)want)
inodeno_t next_ino() {
if (prealloc_inos.empty())
return 0;
- return prealloc_inos.start();
+ return prealloc_inos.range_start();
}
inodeno_t take_ino(inodeno_t ino = 0) {
assert(!prealloc_inos.empty());
ino = 0;
}
if (!ino) {
- ino = prealloc_inos.start();
+ ino = prealloc_inos.range_start();
prealloc_inos.erase(ino);
}
used_inos.insert(ino, 1);
*
*/
-
#include "ReplicatedPG.h"
#include "OSD.h"
#include "PGLS.h"
is_primary() &&
is_active()) {
- snapid_t sn = snap_trimq.start();
+ snapid_t sn = snap_trimq.range_start();
coll_t c = coll_t::build_snap_pg_coll(info.pgid, sn);
vector<sobject_t> ls;
osd->store->collection_list(c, ls);
bool complete = false;
if (pi->data_subset.empty() ||
- pi->data_subset.end() == pi->data_subset_pushing.end())
+ pi->data_subset.range_end() == pi->data_subset_pushing.range_end())
complete = true;
if (!complete) {
// push more
- uint64_t from = pi->data_subset_pushing.end();
+ uint64_t from = pi->data_subset_pushing.range_end();
pi->data_subset_pushing.span_of(pi->data_subset, from, g_conf.osd_recovery_max_chunk);
dout(10) << " pushing more, " << pi->data_subset_pushing << " of " << pi->data_subset << dendl;
- complete = pi->data_subset.end() == pi->data_subset_pushing.end();
+ complete = pi->data_subset.range_end() == pi->data_subset_pushing.range_end();
send_push_op(soid, peer, pi->size, false, complete, pi->data_subset_pushing, pi->clone_subsets);
} else {
// done!
uint64_t size = st.st_size;
bool complete = false;
- if (!op->data_subset.empty() && op->data_subset.end() >= size)
+ if (!op->data_subset.empty() && op->data_subset.range_end() >= size)
complete = true;
// complete==true implies we are definitely complete.
if (pi->data_subset.empty()) {
complete = true;
} else {
- complete = pi->data_subset.end() == data_subset.end();
+ complete = pi->data_subset.range_end() == data_subset.range_end();
}
if (op->complete && !complete) {
uptodate_set.insert(osd->get_nodeid());
} else {
// pull more
- pi->data_subset_pulling.span_of(pi->data_subset, data_subset.end(), g_conf.osd_recovery_max_chunk);
+ pi->data_subset_pulling.span_of(pi->data_subset, data_subset.range_end(), g_conf.osd_recovery_max_chunk);
dout(10) << " pulling more, " << pi->data_subset_pulling << " of " << pi->data_subset << dendl;
send_pull_op(soid, v, false, pi->data_subset_pulling, pi->from);
}