Cond cond;
bool done;
- int r;
+ int r = 0;
object_t oid;
memset(&oid, 0, sizeof(oid));
ceph_object_layout layout;
retry:
int pg_num = objecter->osdmap->get_pg_num(pool.poolid);
-
+
for (;op.seed <pg_num; op.seed++) {
- int response_size;
- int req_size;
-
- do {
- lock.Lock();
- int num = objecter->osdmap->get_pg_layout(pool.poolid, op.seed, layout);
- lock.Unlock();
- if (num != pg_num) /* ahh.. race! */
+ int response_size;
+ int req_size;
+
+ do {
+ lock.Lock();
+ int num = objecter->osdmap->get_pg_layout(pool.poolid, op.seed, layout);
+ lock.Unlock();
+ if (num != pg_num) /* ahh.. race! */
goto retry;
-
+
ObjectRead rd;
bufferlist bl;
#define MAX_REQ_SIZE 1024
op.cookie = 0;
}
} while ((response_size == req_size) && op.cookie);
- }
-
+ }
+
return r;
}
Rados::ListCtx ctx;
while (1) {
list<object_t> vec;
- int r = rados.list(p, 2, vec, ctx);
+ int r = rados.list(p, 1 << 10, vec, ctx);
cout << "list result=" << r << " entries=" << vec.size() << std::endl;
if (r < 0) {
cerr << "got error: " << strerror(-r) << std::endl;