diff options
author | Kun Zhang <zhangkun83@users.noreply.github.com> | 2017-09-15 10:00:12 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-09-15 10:00:12 -0700 |
commit | 8ee9fb51837a96b18664241a6875ff155843152b (patch) | |
tree | b894a699e9d029d63cdc4351dc872b264951d4cc /netty | |
parent | abea73c0af591fbfd90fc6958aa4a135d6f2b68a (diff) | |
download | grpc-grpc-java-8ee9fb51837a96b18664241a6875ff155843152b.tar.gz |
core: add internal API to disable stats and/or tracing. (#3464)
Diffstat (limited to 'netty')
4 files changed, 65 insertions, 0 deletions
diff --git a/netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java b/netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java index 6267e9922..9c1ad8983 100644 --- a/netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java +++ b/netty/src/main/java/io/grpc/netty/InternalNettyChannelBuilder.java @@ -60,5 +60,13 @@ public final class InternalNettyChannelBuilder { builder.setDynamicParamsFactory(factory); } + public static void setStatsEnabled(NettyChannelBuilder builder, boolean value) { + builder.setStatsEnabled(value); + } + + public static void setTracingEnabled(NettyChannelBuilder builder, boolean value) { + builder.setTracingEnabled(value); + } + private InternalNettyChannelBuilder() {} } diff --git a/netty/src/main/java/io/grpc/netty/InternalNettyServerBuilder.java b/netty/src/main/java/io/grpc/netty/InternalNettyServerBuilder.java new file mode 100644 index 000000000..f6a465d51 --- /dev/null +++ b/netty/src/main/java/io/grpc/netty/InternalNettyServerBuilder.java @@ -0,0 +1,37 @@ +/* + * Copyright 2016, gRPC Authors All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package io.grpc.netty; + +import io.grpc.Internal; + +/** + * Internal {@link InternalNettyServerBuilder} accessor. This is intended for usage internal to + * the gRPC team. If you *really* think you need to use this, contact the gRPC team first. + */ +@Internal +public final class InternalNettyServerBuilder { + + public static void setStatsEnabled(NettyServerBuilder builder, boolean value) { + builder.setStatsEnabled(value); + } + + public static void setTracingEnabled(NettyServerBuilder builder, boolean value) { + builder.setTracingEnabled(value); + } + + private InternalNettyServerBuilder() {} +} diff --git a/netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java b/netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java index 2fc7a3851..4563d5a1d 100644 --- a/netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java +++ b/netty/src/main/java/io/grpc/netty/NettyChannelBuilder.java @@ -407,6 +407,16 @@ public final class NettyChannelBuilder this.dynamicParamsFactory = checkNotNull(factory, "factory"); } + @Override + protected void setTracingEnabled(boolean value) { + super.setTracingEnabled(value); + } + + @Override + protected void setStatsEnabled(boolean value) { + super.setStatsEnabled(value); + } + interface TransportCreationParamsFilterFactory { @CheckReturnValue TransportCreationParamsFilter create( diff --git a/netty/src/main/java/io/grpc/netty/NettyServerBuilder.java b/netty/src/main/java/io/grpc/netty/NettyServerBuilder.java index a2e0251eb..28f715018 100644 --- a/netty/src/main/java/io/grpc/netty/NettyServerBuilder.java +++ b/netty/src/main/java/io/grpc/netty/NettyServerBuilder.java @@ -194,6 +194,16 @@ public final class NettyServerBuilder extends AbstractServerImplBuilder<NettySer return this; } + @Override + protected void setTracingEnabled(boolean value) { + super.setTracingEnabled(value); + } + + @Override + protected void setStatsEnabled(boolean value) { + super.setStatsEnabled(value); + } + /** * The maximum number of concurrent calls permitted for each incoming connection. Defaults to no * limit. |