Home
last modified time | relevance | path

Searched refs:ChannelOption (Results 1 – 25 of 30) sorted by relevance

12

/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DChannelOptionsTest.cs33 var option = new ChannelOption("somename", 1); in IntOption()
35 Assert.AreEqual(ChannelOption.OptionType.Integer, option.Type); in IntOption()
44 var option = new ChannelOption("somename", "ABCDEF"); in StringOption()
46 Assert.AreEqual(ChannelOption.OptionType.String, option.Type); in StringOption()
55 Assert.Throws(typeof(ArgumentNullException), () => { new ChannelOption(null, "abc"); }); in ConstructorPreconditions()
56 Assert.Throws(typeof(ArgumentNullException), () => { new ChannelOption(null, 1); }); in ConstructorPreconditions()
57 Assert.Throws(typeof(ArgumentNullException), () => { new ChannelOption("abc", null); }); in ConstructorPreconditions()
70 var options = new List<ChannelOption>(); in CreateChannelArgsEmpty()
78 var options = new List<ChannelOption> in CreateChannelArgs()
80 new ChannelOption("ABC", "XYZ"), in CreateChannelArgs()
[all …]
DChannelTest.cs39 var options = new ChannelOption[] in Constructor_RejectsDuplicateOptions()
41 new ChannelOption(ChannelOptions.PrimaryUserAgentString, "ABC"), in Constructor_RejectsDuplicateOptions()
42 new ChannelOption(ChannelOptions.PrimaryUserAgentString, "XYZ") in Constructor_RejectsDuplicateOptions()
DMockServiceHelper.cs40 readonly IEnumerable<ChannelOption> channelOptions;
55 …string host = null, Marshaller<string> marshaller = null, IEnumerable<ChannelOption> channelOption… in MockServiceHelper()
131 server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in GetServer()
DUserAgentStringTest.cs71 … channelOptions: new[] { new ChannelOption(ChannelOptions.PrimaryUserAgentString, "XYZ") }); in ApplicationUserAgentString()
DServerTest.cs73 Server server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in StartThrowsWithUnboundPorts()
/external/grpc-grpc/src/csharp/Grpc.Core/
DChannel.cs45 readonly Dictionary<string, ChannelOption> options;
67 … public Channel(string target, ChannelCredentials credentials, IEnumerable<ChannelOption> options) in Channel()
108 …hannel(string host, int port, ChannelCredentials credentials, IEnumerable<ChannelOption> options) : in Channel()
321 private static void EnsureUserAgentChannelOption(Dictionary<string, ChannelOption> options) in EnsureUserAgentChannelOption()
326 ChannelOption option; in EnsureUserAgentChannelOption()
336 … options[ChannelOptions.PrimaryUserAgentString] = new ChannelOption(key, userAgentString); in EnsureUserAgentChannelOption()
339 …private static Dictionary<string, ChannelOption> CreateOptionsDictionary(IEnumerable<ChannelOption… in CreateOptionsDictionary()
341 var dict = new Dictionary<string, ChannelOption>(); in CreateOptionsDictionary()
DChannelOptions.cs30 public sealed class ChannelOption class
58 public ChannelOption(string name, string stringValue) in ChannelOption() method in Grpc.Core.ChannelOption
70 public ChannelOption(string name, int intValue) in ChannelOption() method in Grpc.Core.ChannelOption
167 internal static ChannelArgsSafeHandle CreateChannelArgs(ICollection<ChannelOption> options) in CreateChannelArgs()
180 if (option.Type == ChannelOption.OptionType.Integer) in CreateChannelArgs()
184 else if (option.Type == ChannelOption.OptionType.String) in CreateChannelArgs()
DServer.cs44 readonly List<ChannelOption> options;
68 public Server(IEnumerable<ChannelOption> options) in Server()
73 … this.options = options != null ? new List<ChannelOption>(options) : new List<ChannelOption>(); in Server()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerTest.java36 import io.netty.channel.ChannelOption;
60 new HashMap<ChannelOption<?>, Object>(), in getPort()
98 new HashMap<ChannelOption<?>, Object>(), in getPort_notStarted()
122 Map<ChannelOption<?>, Object> channelOptions = new HashMap<ChannelOption<?>, Object>(); in childChannelOptions()
124 channelOptions.put(ChannelOption.WRITE_BUFFER_WATER_MARK, in childChannelOptions()
156 .getOption(ChannelOption.WRITE_BUFFER_WATER_MARK); in childChannelOptions()
186 new HashMap<ChannelOption<?>, Object>(), in channelzListenSocket()
DUtilsTest.java31 import io.netty.channel.ChannelOption;
133 assertNull(channel.config().getOption(ChannelOption.SO_LINGER)); in channelOptionsTest_noLinger()
153 channel.config().setOption(ChannelOption.SO_LINGER, 3); in setAndValidateGeneric()
155 channel.config().setOption(ChannelOption.SO_TIMEOUT, 250); in setAndValidateGeneric()
157 channel.config().setOption(ChannelOption.SO_KEEPALIVE, true); in setAndValidateGeneric()
159 channel.config().setOption(ChannelOption.WRITE_BUFFER_WATER_MARK, writeBufWaterMark); in setAndValidateGeneric()
166 socketOptions.others.get(ChannelOption.WRITE_BUFFER_WATER_MARK.toString())); in setAndValidateGeneric()
DNettyClientTransportTest.java66 import io.netty.channel.ChannelOption;
176 Map<ChannelOption<?>, Object> channelOptions = new HashMap<ChannelOption<?>, Object>(); in setSoLingerChannelOption()
179 channelOptions.put(ChannelOption.SO_LINGER, soLinger); in setSoLingerChannelOption()
421 address, CantConstructChannel.class, new HashMap<ChannelOption<?>, Object>(), group, in failingToConstructChannelShouldFailGracefully()
603 address, NioSocketChannel.class, new HashMap<ChannelOption<?>, Object>(), group, negotiator, in newTransport()
620 new HashMap<ChannelOption<?>, Object>(), in startServer()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DControlExtensions.cs30 public static ChannelOption ToChannelOption(this ChannelArg channelArgument) in ToChannelOption()
35 return new ChannelOption(channelArgument.Name, channelArgument.StrValue); in ToChannelOption()
37 return new ChannelOption(channelArgument.Name, channelArgument.IntValue); in ToChannelOption()
DInteropClientServerTest.cs45 server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in Init()
52 var options = new List<ChannelOption> in Init()
54 … new ChannelOption(ChannelOptions.SslTargetNameOverride, TestCredentials.DefaultHostOverride) in Init()
DSslCredentialsTest.cs56 server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in Init()
63 var options = new List<ChannelOption> in Init()
65 … new ChannelOption(ChannelOptions.SslTargetNameOverride, TestCredentials.DefaultHostOverride) in Init()
DMetadataCredentialsTest.cs38 List<ChannelOption> options;
45 server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in Init()
52 options = new List<ChannelOption> in Init()
54 … new ChannelOption(ChannelOptions.SslTargetNameOverride, TestCredentials.DefaultHostOverride) in Init()
DGeneratedServiceBaseTest.cs43 server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in Init()
DClientRunners.cs93 var channelOptions = new List<ChannelOption>(); in CreateChannels()
96 …channelOptions.Add(new ChannelOption(ChannelOptions.SslTargetNameOverride, securityParams.ServerHo… in CreateChannels()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServer.java21 import static io.netty.channel.ChannelOption.SO_BACKLOG;
22 import static io.netty.channel.ChannelOption.SO_KEEPALIVE;
45 import io.netty.channel.ChannelOption;
73 private final Map<ChannelOption<?>, ?> channelOptions;
103 Map<ChannelOption<?>, ?> channelOptions, in NettyServer() argument
116 this.channelOptions = new HashMap<ChannelOption<?>, Object>(channelOptions); in NettyServer()
171 for (Map.Entry<ChannelOption<?>, ?> entry : channelOptions.entrySet()) { in start()
173 ChannelOption<Object> key = (ChannelOption<Object>) entry.getKey(); in start()
DNettyChannelBuilder.java43 import io.netty.channel.ChannelOption;
68 private final Map<ChannelOption<?>, Object> channelOptions =
69 new HashMap<ChannelOption<?>, Object>();
151 public <T> NettyChannelBuilder withOption(ChannelOption<T> option, T value) { in withOption()
487 private final Map<ChannelOption<?>, ?> channelOptions;
502 Class<? extends Channel> channelType, Map<ChannelOption<?>, ?> channelOptions, in NettyTransportFactory() argument
508 this.channelOptions = new HashMap<ChannelOption<?>, Object>(channelOptions); in NettyTransportFactory()
DNettyClientTransport.java20 import static io.netty.channel.ChannelOption.SO_KEEPALIVE;
48 import io.netty.channel.ChannelOption;
67 private final Map<ChannelOption<?>, ?> channelOptions;
99 Map<ChannelOption<?>, ?> channelOptions, EventLoopGroup group, in NettyClientTransport() argument
216 for (Map.Entry<ChannelOption<?>, ?> entry : channelOptions.entrySet()) {
220 b.option((ChannelOption<Object>) entry.getKey(), entry.getValue());
DUtils.java22 import static io.netty.channel.ChannelOption.SO_LINGER;
23 import static io.netty.channel.ChannelOption.SO_TIMEOUT;
38 import io.netty.channel.ChannelOption;
229 for (Entry<ChannelOption<?>, Object> opt : config.getOptions().entrySet()) { in getSocketOptions()
230 ChannelOption<?> key = opt.getKey(); in getSocketOptions()
DNettyServerBuilder.java35 import io.netty.channel.ChannelOption;
72 private final Map<ChannelOption<?>, Object> channelOptions =
73 new HashMap<ChannelOption<?>, Object>();
138 public <T> NettyServerBuilder withChildOption(ChannelOption<T> option, T value) { in withChildOption()
/external/rust/crates/grpcio-sys/grpc/test/distrib/csharp/DistribTest/
DProgram.cs32 Server server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in Main()
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DNettyHttpClient.java26 import io.netty.channel.ChannelOption;
86 .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT) in prepare()
/external/grpc-grpc/src/csharp/Grpc.HealthCheck.Tests/
DHealthClientServerTest.cs46 server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) }) in Init()

12