423974 - Optimize flow control.
Made the buffering flow control strategy the default.
This commit is contained in:
parent
9765ab1f3a
commit
560ec6301e
|
@ -23,10 +23,10 @@ import java.util.Collections;
|
|||
import java.util.Map;
|
||||
import java.util.concurrent.Executor;
|
||||
|
||||
import org.eclipse.jetty.http2.BufferingFlowControlStrategy;
|
||||
import org.eclipse.jetty.http2.FlowControlStrategy;
|
||||
import org.eclipse.jetty.http2.HTTP2Connection;
|
||||
import org.eclipse.jetty.http2.ISession;
|
||||
import org.eclipse.jetty.http2.SimpleFlowControlStrategy;
|
||||
import org.eclipse.jetty.http2.api.Session;
|
||||
import org.eclipse.jetty.http2.frames.PrefaceFrame;
|
||||
import org.eclipse.jetty.http2.frames.SettingsFrame;
|
||||
|
@ -72,7 +72,7 @@ public class HTTP2ClientConnectionFactory implements ClientConnectionFactory
|
|||
|
||||
protected FlowControlStrategy newFlowControlStrategy()
|
||||
{
|
||||
return new SimpleFlowControlStrategy();
|
||||
return new BufferingFlowControlStrategy(0.5F);
|
||||
}
|
||||
|
||||
public int getInitialSessionRecvWindow()
|
||||
|
|
|
@ -20,9 +20,9 @@ package org.eclipse.jetty.http2.server;
|
|||
|
||||
import java.util.Objects;
|
||||
|
||||
import org.eclipse.jetty.http2.BufferingFlowControlStrategy;
|
||||
import org.eclipse.jetty.http2.FlowControlStrategy;
|
||||
import org.eclipse.jetty.http2.HTTP2Connection;
|
||||
import org.eclipse.jetty.http2.SimpleFlowControlStrategy;
|
||||
import org.eclipse.jetty.http2.api.server.ServerSessionListener;
|
||||
import org.eclipse.jetty.http2.generator.Generator;
|
||||
import org.eclipse.jetty.http2.parser.Parser;
|
||||
|
@ -112,7 +112,7 @@ public abstract class AbstractHTTP2ServerConnectionFactory extends AbstractConne
|
|||
|
||||
protected FlowControlStrategy newFlowControlStrategy()
|
||||
{
|
||||
return new SimpleFlowControlStrategy(getInitialStreamSendWindow());
|
||||
return new BufferingFlowControlStrategy(getInitialStreamSendWindow(), 0.5F);
|
||||
}
|
||||
|
||||
protected abstract ServerSessionListener newSessionListener(Connector connector, EndPoint endPoint);
|
||||
|
|
Loading…
Reference in New Issue