Cross Reference: /net/ceph/osd

Lines Matching defs:osdmap
1087 	peer_addr = &osdc->osdmap->osd_addr[osd->o_osd];
1274  * based on the current osdmap and osd_client settings.
1281 	bool pauserd = ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_PAUSERD);
1282 	bool pausewr = ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_PAUSEWR) ||
1283 		ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_FULL);
1291 static int __calc_request_pg(struct ceph_osdmap *osdmap,
1311 		pi = ceph_pg_pool_by_id(osdmap, req->r_target_oloc.pool);
1323 	return ceph_oloc_oid_to_pg(osdmap, &req->r_target_oloc,
1364 	err = __calc_request_pg(osdc->osdmap, req, &pgid);
1371 	num = ceph_calc_pg_acting(osdc->osdmap, pgid, acting, &o);
1418 			      &osdc->osdmap->osd_addr[o]);
1441 	put_unaligned_le32(osdc->osdmap->epoch, req->r_request_osdmap_epoch);
1797 		 * list, waiting for the new osdmap (which can take
1891 		if (!ceph_osd_is_up(osdc->osdmap, osd->o_osd) ||
1893 			   ceph_osd_addr(osdc->osdmap,
2009 	dout("handle_map have %u\n", osdc->osdmap ? osdc->osdmap->epoch : 0);
2021 	was_full = ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_FULL);
2032 		if (osdc->osdmap && osdc->osdmap->epoch+1 == epoch) {
2036 							  osdc->osdmap,
2043 			if (newmap != osdc->osdmap) {
2044 				ceph_osdmap_destroy(osdc->osdmap);
2045 				osdc->osdmap = newmap;
2048 				ceph_osdmap_flag(osdc->osdmap,
2072 		} else if (osdc->osdmap && osdc->osdmap->epoch >= epoch) {
2075 			     osdc->osdmap->epoch);
2086 			oldmap = osdc->osdmap;
2087 			osdc->osdmap = newmap;
2094 				ceph_osdmap_flag(osdc->osdmap,
2102 	if (!osdc->osdmap)
2106 	ceph_monc_got_osdmap(&osdc->client->monc, osdc->osdmap->epoch);
2109 	 * subscribe to subsequent osdmap updates if full to ensure
2113 	if (ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_FULL) ||
2114 		ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_PAUSERD) ||
2115 		ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_PAUSEWR))
2541 	osdc->osdmap = NULL;
2604 	if (osdc->osdmap) {
2605 		ceph_osdmap_destroy(osdc->osdmap);
2606 		osdc->osdmap = NULL;