Skip to content

Commit a9de162

Browse files
committed
netty: use composite cumulator for perf flamegraph tests
1 parent 9cbea16 commit a9de162

File tree

3 files changed

+4
-1
lines changed

3 files changed

+4
-1
lines changed

alts/src/main/java/io/grpc/alts/internal/TsiFrameHandler.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@ public final class TsiFrameHandler extends ByteToMessageDecoder implements Chann
4848

4949
public TsiFrameHandler(TsiFrameProtector protector) {
5050
this.protector = checkNotNull(protector, "protector");
51+
setCumulator(COMPOSITE_CUMULATOR);
5152
}
5253

5354
@Override

alts/src/main/java/io/grpc/alts/internal/TsiHandshakeHandler.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,7 @@ public TsiHandshakeHandler(
9393
this.handshaker = checkNotNull(handshaker, "handshaker");
9494
this.handshakeValidator = checkNotNull(handshakeValidator, "handshakeValidator");
9595
this.next = checkNotNull(next, "next");
96+
setCumulator(COMPOSITE_CUMULATOR);
9697
}
9798

9899
@Override
@@ -190,4 +191,4 @@ private void sendHandshake(ChannelHandlerContext ctx) throws GeneralSecurityExce
190191
protected void handlerRemoved0(ChannelHandlerContext ctx) throws Exception {
191192
handshaker.close();
192193
}
193-
}
194+
}

netty/src/main/java/io/grpc/netty/GrpcHttp2ConnectionHandler.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ protected GrpcHttp2ConnectionHandler(
4242
Http2Settings initialSettings) {
4343
super(decoder, encoder, initialSettings);
4444
this.channelUnused = channelUnused;
45+
setCumulator(COMPOSITE_CUMULATOR);
4546
}
4647

4748
/**

0 commit comments

Comments
 (0)