]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
Rename interval_set::begin and end
authorColin Patrick McCabe <cmccabe@alumni.cmu.edu>
Mon, 27 Sep 2010 19:06:06 +0000 (12:06 -0700)
committerColin Patrick McCabe <cmccabe@alumni.cmu.edu>
Mon, 27 Sep 2010 19:48:57 +0000 (12:48 -0700)
Rename interval_set::begin and end to interval_set::range_begin and
interval_set::range_end, respectively.

src/client/Client.h
src/include/interval_set.h
src/mds/InoTable.cc
src/mds/SessionMap.h
src/osd/OSD.cc
src/osd/ReplicatedPG.cc

index 31903dc3fa895a500ee6874ec77b78e3a7e317a2..b173a803aed85c111a437c5c4a8422772f0fa289 100644 (file)
@@ -907,7 +907,7 @@ protected:
   hash_map<int, Fh*> fd_map;
   
   int get_fd() {
-    int fd = free_fd_set.start();
+    int fd = free_fd_set.range_start();
     free_fd_set.erase(fd, 1);
     return fd;
   }
index 39c0d34930ed118b394d12a895e8225150714ded..a8e7fc53e41e32435dc177227ed2ed0bbf138137 100644 (file)
@@ -151,12 +151,12 @@ class interval_set {
   bool empty() const {
     return m.empty();
   }
-  T start() const {
+  T range_start() const {
     assert(!empty());
     typename map<T,T>::const_iterator p = m.begin();
     return p->first;
   }
-  T end() const {
+  T range_end() const {
     assert(!empty());
     typename map<T,T>::const_iterator p = m.end();
     p--;
index 1e305117d4f866f513462029ff1b7e68d751c209..7f3cf4d5481a1afbb9e15482e2ed571d466310af 100644 (file)
@@ -45,7 +45,7 @@ inodeno_t InoTable::project_alloc_id(inodeno_t id)
   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;
@@ -61,7 +61,7 @@ void InoTable::project_alloc_ids(interval_set<inodeno_t>& ids, int want)
 {
   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)
index 661a6bd61b473d4499bb5ea216dd709711ee45af..375136755eb7440440cbdae498564a3eb392cad3 100644 (file)
@@ -95,7 +95,7 @@ public:
   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());
@@ -107,7 +107,7 @@ public:
        ino = 0;
     }
     if (!ino) {
-      ino = prealloc_inos.start();
+      ino = prealloc_inos.range_start();
       prealloc_inos.erase(ino);
     }
     used_inos.insert(ino, 1);
index 0c6371b878755282db74e33801f13c8a64c15a4e..dab596a81a2ca66e552a025b9e6339b4ecd35e4e 100644 (file)
@@ -3722,7 +3722,7 @@ void OSD::_process_pg_info(epoch_t epoch, int from,
            dout(10) << " purged_snaps " << pg->info.purged_snaps
                     << " -> " << info.purged_snaps
                     << " removed " << p << dendl;
-           snapid_t sn = p.start();
+           snapid_t sn = p.range_start();
            coll_t c = coll_t::build_snap_pg_coll(info.pgid, sn);
            t->remove_collection(c);
            
index 77e14e54c6400f22e6dcd12b6241ba51ba17c4cc..db7c0ecc5b8b70b41b77ecc2d53705036b933981 100644 (file)
@@ -11,7 +11,6 @@
  * 
  */
 
-
 #include "ReplicatedPG.h"
 #include "OSD.h"
 #include "PGLS.h"
@@ -494,7 +493,7 @@ bool ReplicatedPG::snap_trimmer()
         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);
@@ -2963,15 +2962,15 @@ void ReplicatedPG::sub_op_push_reply(MOSDSubOpReply *reply)
 
     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!
@@ -3032,7 +3031,7 @@ void ReplicatedPG::sub_op_pull(MOSDSubOp *op)
     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.
@@ -3205,7 +3204,7 @@ void ReplicatedPG::sub_op_push(MOSDSubOp *op)
       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) {
@@ -3362,7 +3361,7 @@ void ReplicatedPG::sub_op_push(MOSDSubOp *op)
        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);
     }