set_start(pos, ceph_clock_now(g_ceph_context));
ObjectStore::Transaction *t = new ObjectStore::Transaction;
- t->write(coll_t(), hobject_t(poid), pos, bytes, bl);
+ t->write(coll_t(), ghobject_t(hobject_t(poid)), pos, bytes, bl);
fs->queue_transaction(NULL, t, new C_Ack(pos), new C_Commit(pos));
pos += bytes;
char f[30];
snprintf(f, sizeof(f), "foo%d\n", i);
sobject_t soid(f, CEPH_NOSNAP);
- t.write(coll_t(), hobject_t(soid), 0, bl.length(), bl);
+ t.write(coll_t(), ghobject_t(hobject_t(soid)), 0, bl.length(), bl);
}
dout(0) << "starting thread" << dendl;
stringstream obj_str;
obj_str << i;
t.touch(coll,
- hobject_t(sobject_t(obj_str.str(), CEPH_NOSNAP)));
+ ghobject_t(hobject_t(sobject_t(obj_str.str(), CEPH_NOSNAP))));
objects.insert(obj_str.str());
}
collections[coll] = make_pair(objects, new ObjectStore::Sequencer(coll.to_str()));
stringstream ss;
ss << i << ", " << j << ", " << *obj;
t->setattr(iter->first,
- hobject_t(sobject_t(*obj, CEPH_NOSNAP)),
+ ghobject_t(hobject_t(sobject_t(*obj, CEPH_NOSNAP))),
ss.str().c_str(),
bl);
}