Toggle navigation
Home
com.yahoo.pulsar.broker.loadbalance.LoadManager to java.util.concurrent.atomic.AtomicReference<com.yahoo.pulsar.broker.loadbalance.LoadManager>
No. of Instances - 9
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Add or Remove Method invocation
this.loadManager
to
this.loadManager.get()
this.loadManager.isCentralized()
to
this.loadManager.get().isCentralized()
loadManager.getLeastLoaded(serviceUnit)
to
loadManager.get().getLeastLoaded(serviceUnit)
pulsar.getOrderedExecutor().submit(safeRun(() -> { if (rc == KeeperException.Code.OK.intValue()) { try { ownershipCache.disableOwnership(bundle); bundleFactory.invalidateBundleCache(nsname); pulsar.getBrokerService().refreshTopicToStatsMaps(bundle); loadManager.setLoadReportForceUpdateFlag(); future.complete(null); } catch ( Exception e) { String msg1=format("failed to disable bundle %s under namespace [%s] with error %s",nsname.toString(),bundle.toString(),e.getMessage()); LOG.warn(msg1,e); future.completeExceptionally(new ServiceUnitNotReadyException(msg1)); } } else { String msg2=format("failed to update namespace [%s] policies due to %s",nsname.toString(),KeeperException.create(KeeperException.Code.get(rc)).getMessage()); LOG.warn(msg2); future.completeExceptionally(new ServiceUnitNotReadyException(msg2)); } } ))
to
pulsar.getOrderedExecutor().submit(safeRun(() -> { if (rc == KeeperException.Code.OK.intValue()) { try { ownershipCache.disableOwnership(bundle); bundleFactory.invalidateBundleCache(nsname); pulsar.getBrokerService().refreshTopicToStatsMaps(bundle); loadManager.get().setLoadReportForceUpdateFlag(); future.complete(null); } catch ( Exception e) { String msg1=format("failed to disable bundle %s under namespace [%s] with error %s",nsname.toString(),bundle.toString(),e.getMessage()); LOG.warn(msg1,e); future.completeExceptionally(new ServiceUnitNotReadyException(msg1)); } } else { String msg2=format("failed to update namespace [%s] policies due to %s",nsname.toString(),KeeperException.create(KeeperException.Code.get(rc)).getMessage()); LOG.warn(msg2); future.completeExceptionally(new ServiceUnitNotReadyException(msg2)); } } ))
this.loadManager
to
this.loadManager.get()
loadManager
to
loadManager.get()
loadManager
to
loadManager.get()