From: Matan Breizman Date: Sun, 12 Nov 2023 08:29:50 +0000 (+0000) Subject: crimson/osd: update TODO comments X-Git-Tag: v19.0.0~4^2~2 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=8093184f13cf278d1099cb388092e0b3f1dd4b91;p=ceph-ci.git crimson/osd: update TODO comments Signed-off-by: Matan Breizman --- diff --git a/src/crimson/osd/osd.cc b/src/crimson/osd/osd.cc index cf1984d47d9..2ff907a7936 100644 --- a/src/crimson/osd/osd.cc +++ b/src/crimson/osd/osd.cc @@ -979,6 +979,8 @@ seastar::future<> OSD::_handle_osd_map(Ref m) if (!superblock.maps.empty()) { pg_shard_manager.trim_maps(t, superblock); + // TODO: once we support pg splitting, update pg_num_history here + //pg_num_history.prune(superblock.get_oldest_map()); } superblock.insert_osdmap_epochs(first, last); diff --git a/src/crimson/osd/shard_services.cc b/src/crimson/osd/shard_services.cc index 208b7fc98df..c73613dd988 100644 --- a/src/crimson/osd/shard_services.cc +++ b/src/crimson/osd/shard_services.cc @@ -358,7 +358,6 @@ void OSDSingletonState::handle_conf_change( seastar::future OSDSingletonState::get_local_map(epoch_t e) { - // TODO: use LRU cache for managing osdmap, fallback to disk if we have to if (auto found = osdmaps.find(e); found) { logger().debug("{} osdmap.{} found in cache", __func__, e); return seastar::make_ready_future(std::move(found)); @@ -398,6 +397,9 @@ seastar::future> OSDSingletonState::load_map_bls( logger().debug("{} loading maps [{},{}]", __func__, first, last); ceph_assert(first <= last); + // TODO: take osd_map_max into account + //int max = cct->_conf->osd_map_message_max; + //ssize_t max_bytes = cct->_conf->osd_map_message_max_bytes; return seastar::map_reduce(boost::make_counting_iterator(first), boost::make_counting_iterator(last + 1), [this](epoch_t e) { @@ -750,6 +752,8 @@ seastar::future<> OSDSingletonState::send_incremental_map( "superblock's oldest map: {}", __func__, first, superblock.get_oldest_map()); if (first >= superblock.get_oldest_map()) { + // TODO: osd_map_share_max_epochs + // See OSDService::build_incremental_map_msg if (first < superblock.cluster_osdmap_trim_lower_bound) { logger().info("{}: cluster osdmap lower bound: {} " " > first {}, starting with full map",