diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-03 12:24:44 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-03 12:24:44 +0100 |
commit | acaed07c3d10f2109935ed5d83bd5c415ab2d943 (patch) | |
tree | bce4e236700ea46ef68a1f8e997fe42b95dc849a /container-messagebus | |
parent | 11eb110513640129fc617f67d2e3322fb0fb8674 (diff) |
We have relied on dynamic throttling for 12 years or so.
Time to let the old one go.
Diffstat (limited to 'container-messagebus')
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java | 21 |
1 files changed, 0 insertions, 21 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java index baff0437b5d..16dedd0765d 100644 --- a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java +++ b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java @@ -5,7 +5,6 @@ import com.yahoo.component.annotation.Inject; import com.yahoo.component.AbstractComponent; import com.yahoo.container.jdisc.ContainerMbusConfig; import com.yahoo.document.DocumentTypeManager; -import com.yahoo.document.DocumentUtil; import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol; import com.yahoo.documentapi.messagebus.protocol.DocumentProtocolPoliciesConfig; import com.yahoo.jdisc.ReferencedResource; @@ -109,33 +108,13 @@ public final class SessionCache extends AbstractComponent { Protocol protocol) { MessageBusParams mbusParams = new MessageBusParams().addProtocol(protocol); - int maxPendingSize = DocumentUtil - .calculateMaxPendingSize(mbusConfig.maxConcurrentFactor(), mbusConfig.documentExpansionFactor(), - mbusConfig.containerCoreMemory()); - logSystemInfo(mbusConfig, maxPendingSize); - mbusParams.setMaxPendingCount(mbusConfig.maxpendingcount()); - mbusParams.setMaxPendingSize(maxPendingSize); MessageBus bus = new MessageBus(net, mbusParams); new ConfigAgent(messagebusConfig, bus); // Configure the wrapped MessageBus with a routing table. return new SharedMessageBus(bus); } - private static void logSystemInfo(ContainerMbusConfig containerMbusConfig, long maxPendingSize) { - log.log(Level.FINE, - "Running with maximum heap size of " + (Runtime.getRuntime().maxMemory() / 1024L / 1024L) + " MB"); - log.log(Level.CONFIG, - "Amount of memory reserved for container core: " + containerMbusConfig.containerCoreMemory() + " MB."); - log.log(Level.CONFIG, - "Running with document expansion factor " + containerMbusConfig.documentExpansionFactor() + ""); - - String msgLimit = - (containerMbusConfig.maxpendingcount() == 0) ? "unlimited" : "" + containerMbusConfig.maxpendingcount(); - log.log(Level.CONFIG, ("Starting message bus with max " + msgLimit + " pending messages and max " + - (((double) (maxPendingSize / 1024L)) / 1024.0d) + " pending megabytes.")); - } - ReferencedResource<SharedIntermediateSession> retainIntermediate(final IntermediateSessionParams p) { return intermediatesCreator.retain(intermediateLock, intermediates, p); } |