sergey-chugunov-1985 commented on code in PR #13238:
URL: https://github.com/apache/ignite/pull/13238#discussion_r3504787191
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java:
##########
@@ -2594,6 +2601,35 @@ private void updateDurationHistogram(long duration) {
cctx.exchange().blockingDurationHistogram().value(duration);
}
+ /**
+ * Updates metric for a partition distribution across data centers for a
given cache group.
+ *
+ * @param grp Cache group the metric should be recalculated for.
+ * @param assignment New assignment for the cache group.
+ */
+ private void updateMdcMetrics(CacheGroupContext grp, AffinityAssignment
assignment) {
+ BaselineTopology top =
cctx.discovery().discoCache().state().baselineTopology();
+ if (top != null) {
+ int numberOfDataCenters = top.numberOfDatacenters();
Review Comment:
This code was moved to CacheMetricsImpl itself, I took into account this
idea there.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
