Ceph

adamcrume on irc was having trouble with this sample program only mapping to the same two osds for all objects. encoding/decoding the OSDMap makes it map to more than 2 osds.

#include "osd/OSDMap.h" 
#include "common/code_environment.h" 

int main() {
    OSDMap *osdmap = new OSDMap();
    CephContext *cct = new CephContext(CODE_ENVIRONMENT_UTILITY);
    uuid_d fsid;
    int num_osds = 10;
    osdmap->build_simple(cct, 0, fsid, num_osds, 7, 8);
    for(int i = 0; i < num_osds; i++) {
        osdmap->set_state(i, osdmap->get_state(i) | CEPH_OSD_UP | CEPH_OSD_EXISTS);
        osdmap->set_weight(i, CEPH_OSD_IN);
    }
    osdmap->calc_num_osds();
    osdmap->print(cout);
    osdmap->print_tree(cout);

    bufferlist bl;
    osdmap->encode(bl);
    osdmap = new OSDMap();
    osdmap->decode(bl);

    int i;
    for(i = 0; i < 4; i++) {
        int j;
        for(j = 0; j < 4; j++) {
            char foo[20];
            snprintf(foo, sizeof(foo), "%08x.%08x", i, j);
            object_t oid(foo);
            object_locator_t oloc(1);
            pg_t pgid = osdmap->object_locator_to_pg(oid, oloc);
            vector<int> raw, up, acting;
            osdmap->pg_to_osds(pgid, raw);
            osdmap->pg_to_up_acting_osds(pgid, up, acting);
            cout << "OID: " << oid << " RAW: " << raw << " PG: " << pgid << " UP: " << up << " ACTING: " << acting << std::endl;
        }
    }
}