Remove PriorityStreamByteDistributor from http2 microbench

Motivation:
PriorityStreamByteDistributor has been removed but NoPriorityByteDistributionBenchmark in microbench still need it and causes compile error

Modifications:
Remove PriorityStreamByteDistributor from NoPriorityByteDistributionBenchmark

Result:
The compile error has been fixed
This commit is contained in:
zhangduo 2015-12-22 10:08:24 +08:00 committed by Norman Maurer
parent b5d90388ea
commit f22ad97cf3

View File

@ -26,7 +26,6 @@ import io.netty.handler.codec.http2.Http2FrameAdapter;
import io.netty.handler.codec.http2.Http2RemoteFlowController; import io.netty.handler.codec.http2.Http2RemoteFlowController;
import io.netty.handler.codec.http2.Http2Stream; import io.netty.handler.codec.http2.Http2Stream;
import io.netty.handler.codec.http2.Http2StreamVisitor; import io.netty.handler.codec.http2.Http2StreamVisitor;
import io.netty.handler.codec.http2.PriorityStreamByteDistributor;
import io.netty.handler.codec.http2.StreamByteDistributor; import io.netty.handler.codec.http2.StreamByteDistributor;
import io.netty.handler.codec.http2.UniformStreamByteDistributor; import io.netty.handler.codec.http2.UniformStreamByteDistributor;
import io.netty.handler.codec.http2.WeightedFairQueueByteDistributor; import io.netty.handler.codec.http2.WeightedFairQueueByteDistributor;
@ -51,7 +50,6 @@ import org.openjdk.jmh.annotations.Threads;
@State(Scope.Benchmark) @State(Scope.Benchmark)
public class NoPriorityByteDistributionBenchmark extends AbstractMicrobenchmark { public class NoPriorityByteDistributionBenchmark extends AbstractMicrobenchmark {
public enum Algorithm { public enum Algorithm {
PRIORITY,
WFQ, WFQ,
UNIFORM UNIFORM
} }
@ -125,9 +123,6 @@ public class NoPriorityByteDistributionBenchmark extends AbstractMicrobenchmark
// Create the flow controller // Create the flow controller
switch (algorithm) { switch (algorithm) {
case PRIORITY:
distributor = new PriorityStreamByteDistributor(connection);
break;
case WFQ: case WFQ:
distributor = new WeightedFairQueueByteDistributor(connection); distributor = new WeightedFairQueueByteDistributor(connection);
break; break;