OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
brokerToNamespaceToBundleRange.get(broker).computeIfAbsent(namespaceName,k -> new HashSet<>()).add(bundleRange);brokerToNamespaceToBundleRange.get(broker.get()).computeIfAbsent(namespaceName,k -> new HashSet<>()).add(bundleRange);brokerToNamespaceToBundleRange.get(broker)brokerToNamespaceToBundleRange.get(broker.get())pulsard6d4fa3a1103f650bf16e74429f82db3d33fe739org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl
_1740
_2739
_1broker
_2broker
TCIVarbroker
v0brokerToNamespaceToBundleRange
TCIVarbroker
v0brokerToNamespaceToBundleRange
UsesTrue
loadData.getBrokerData().get(broker).getPreallocatedBundleData().put(bundle,data);loadData.getBrokerData().get(broker.get()).getPreallocatedBundleData().put(bundle,data);loadData.getBrokerData().get(broker)loadData.getBrokerData().get(broker.get())pulsard6d4fa3a1103f650bf16e74429f82db3d33fe739org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl
_1740
_2739
_1broker
_2broker
TCIVarbroker
v0loadData.getBrokerData()
TCIVarbroker
v0loadData.getBrokerData()
UsesTrue
final double maxUsage=loadData.getBrokerData().get(broker).getLocalData().getMaxResourceUsage();final double maxUsage=loadData.getBrokerData().get(broker.get()).getLocalData().getMaxResourceUsage();loadData.getBrokerData().get(broker)loadData.getBrokerData().get(broker.get())pulsard6d4fa3a1103f650bf16e74429f82db3d33fe739org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl
_1740
_2739
_1broker
_2broker
TCIVarbroker
v0loadData.getBrokerData()
TCIVarbroker
v0loadData.getBrokerData()
UsesTrue