Home
last modified time | relevance | path

Searched refs:socketOptions (Results 1 – 23 of 23) sorted by relevance

/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/
DServerListenerTest.java33 SocketOptions socketOptions = new SocketOptions(); in testSetupAndTearDown() local
34 socketOptions.connectTimeoutMs = 3000; in testSetupAndTearDown()
35 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testSetupAndTearDown()
36 socketOptions.type = SocketOptions.SocketType.STREAM; in testSetupAndTearDown()
40 …ServerListener listener = new ServerListener("127.0.0.1", (short)8038, socketOptions, null, bootst… in testSetupAndTearDown()
54 socketOptions.close(); in testSetupAndTearDown()
60 SocketOptions socketOptions = new SocketOptions(); in testSetupWith0PortAndTearDown() local
61 socketOptions.connectTimeoutMs = 3000; in testSetupWith0PortAndTearDown()
62 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testSetupWith0PortAndTearDown()
63 socketOptions.type = SocketOptions.SocketType.STREAM; in testSetupWith0PortAndTearDown()
[all …]
DEventStreamClientConnectionTest.java26 SocketOptions socketOptions = new SocketOptions(); in testConnectionHandling() local
27 socketOptions.connectTimeoutMs = 3000; in testConnectionHandling()
28 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testConnectionHandling()
29 socketOptions.type = SocketOptions.SocketType.STREAM; in testConnectionHandling()
39 …ServerListener listener = new ServerListener("127.0.0.1", (short)8033, socketOptions, null, bootst… in testConnectionHandling()
70 …d> connectFuture = ClientConnection.connect("127.0.0.1", (short)8033, socketOptions, null, clientB… in testConnectionHandling()
100 socketOptions.close(); in testConnectionHandling()
105 SocketOptions socketOptions = new SocketOptions(); in testConnectionProtocolMessageHandling() local
106 socketOptions.connectTimeoutMs = 3000; in testConnectionProtocolMessageHandling()
107 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testConnectionProtocolMessageHandling()
[all …]
DHttpClientConnectionTest.java78 SocketOptions socketOptions = new SocketOptions(); in testConnectionWithAllCiphers() argument
81 socketOptions.connectTimeoutMs = 10000; in testConnectionWithAllCiphers()
82 resp = testConnection(uri, bootstrap, socketOptions, tlsCtx); in testConnectionWithAllCiphers()
130 SocketOptions socketOptions = new SocketOptions(); in testStaticDefaults() argument
135 …options.withClientBootstrap(bootstrap).withSocketOptions(socketOptions).withTlsContext(tlsCtx).wit… in testStaticDefaults()
DMqtt5ClientTest.java95 SocketOptions socketOptions = new SocketOptions(); in New_UC2() argument
153 .withSocketOptions(socketOptions); in New_UC2()
203 SocketOptions socketOptions = new SocketOptions(); in New_UC4() argument
260 .withSocketOptions(socketOptions); in New_UC4()
455 SocketOptions socketOptions = new SocketOptions(); in ConnDC_UC6() argument
497 .withSocketOptions(socketOptions); in ConnDC_UC6()
719 SocketOptions socketOptions = new SocketOptions(); in ConnWS_UC6() argument
760 .withSocketOptions(socketOptions); in ConnWS_UC6()
DMqtt5to3AdapterConnectionTest.java170 SocketOptions socketOptions = new SocketOptions();) { in TestCreationFull() argument
238 .withSocketOptions(socketOptions); in TestCreationFull()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DUtilsTest.java89 SocketOptions socketOptions = Utils.getSocketOptions(socket); in getSocketOptions() local
90 assertEquals(2, (int) socketOptions.lingerSeconds); in getSocketOptions()
91 assertEquals(3, (int) socketOptions.soTimeoutMillis); in getSocketOptions()
92 assertEquals("true", socketOptions.others.get("TCP_NODELAY")); in getSocketOptions()
93 assertEquals("true", socketOptions.others.get("SO_REUSEADDR")); in getSocketOptions()
94 assertEquals("4000", socketOptions.others.get("SO_RECVBUF")); in getSocketOptions()
95 assertEquals("5000", socketOptions.others.get("SO_SNDBUF")); in getSocketOptions()
96 assertEquals("true", socketOptions.others.get("SO_KEEPALIVE")); in getSocketOptions()
97 assertEquals("true", socketOptions.others.get("SO_OOBINLINE")); in getSocketOptions()
98 assertEquals("8", socketOptions.others.get("IP_TOS")); in getSocketOptions()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DUtilsTest.java141 InternalChannelz.SocketOptions socketOptions = Utils.getSocketOptions(channel); in channelOptionsTest_noLinger() local
142 assertNull(socketOptions.lingerSeconds); in channelOptionsTest_noLinger()
149 SocketOptions socketOptions = setAndValidateGeneric(channel); in channelOptionsTest_oio() local
150 assertEquals(250, (int) socketOptions.soTimeoutMillis); in channelOptionsTest_oio()
156 SocketOptions socketOptions = setAndValidateGeneric(channel); in channelOptionsTest_nio() local
157 assertNull(socketOptions.soTimeoutMillis); in channelOptionsTest_nio()
169 InternalChannelz.SocketOptions socketOptions = Utils.getSocketOptions(channel); in setAndValidateGeneric() local
170 assertEquals(3, (int) socketOptions.lingerSeconds); in setAndValidateGeneric()
171 assertEquals("true", socketOptions.others.get("SO_KEEPALIVE")); in setAndValidateGeneric()
174 socketOptions.others.get(ChannelOption.WRITE_BUFFER_WATER_MARK.toString())); in setAndValidateGeneric()
[all …]
DNettyServerTest.java493 assertThat(socketStats.socketOptions.others).isNotEmpty(); in channelzListenSocket()
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/http/
DHttpClientConnectionManagerOptions.java22 private SocketOptions socketOptions; field in HttpClientConnectionManagerOptions
67 public HttpClientConnectionManagerOptions withSocketOptions(SocketOptions socketOptions) { in withSocketOptions() argument
68 this.socketOptions = socketOptions; in withSocketOptions()
75 public SocketOptions getSocketOptions() { return socketOptions; } in getSocketOptions()
321 …if (socketOptions == null) { throw new IllegalArgumentException("SocketOptions must not be null");… in validateOptions()
DHttpClientConnectionManager.java53 SocketOptions socketOptions = options.getSocketOptions(); in HttpClientConnectionManager() local
116 socketOptions.getNativeHandle(), in HttpClientConnectionManager()
249 long socketOptions, in httpClientConnectionManagerNew() argument
DHttp2StreamManager.java50 SocketOptions socketOptions = connectionManagerOptions.getSocketOptions(); in Http2StreamManager() local
103 socketOptions.getNativeHandle(), in Http2StreamManager()
244 long socketOptions, in http2StreamManagerNew() argument
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/
DMqttConnectionConfig.java23 private SocketOptions socketOptions; field in MqttConnectionConfig
144 public void setSocketOptions(SocketOptions socketOptions) { in setSocketOptions() argument
145 swapReferenceTo(this.socketOptions, socketOptions); in setSocketOptions()
146 this.socketOptions = socketOptions; in setSocketOptions()
155 return socketOptions; in getSocketOptions()
DMqttClientConnection.java310 SocketOptions socketOptions = config.getSocketOptions(); in connect() local
314 socketOptions != null ? socketOptions.getNativeHandle() : 0, in connect()
482 … long socketOptions, long tlsContext, String clientId, boolean cleanSession, int keepAliveMs, in mqttClientConnectionConnect() argument
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt5/
DMqtt5ClientOptions.java30 private SocketOptions socketOptions; field in Mqtt5ClientOptions
86 return this.socketOptions; in getSocketOptions()
274 this.socketOptions = builder.socketOptions; in Mqtt5ClientOptions()
568 private SocketOptions socketOptions; field in Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder
630 public Mqtt5ClientOptionsBuilder withSocketOptions(SocketOptions socketOptions) in withSocketOptions() argument
632 this.socketOptions = socketOptions; in withSocketOptions()
DMqtt5Client.java61 SocketOptions socketOptions = options.getSocketOptions(); in Mqtt5Client() local
86 if (socketOptions != null) { in Mqtt5Client()
87 addReferenceTo(socketOptions); in Mqtt5Client()
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/eventstream/
DClientConnection.java139 …CompletableFuture<Void> connect(final String hostName, int port, final SocketOptions socketOptions, in connect() argument
171 …port, socketOptions.getNativeHandle(), tlsContextHandle, bootstrap.getNativeHandle(), handlerShim); in connect()
200 …private static native int clientConnect(byte[] hostName, int port, long socketOptions, long tlsCon… in clientConnect() argument
DServerListener.java36 public ServerListener(final String hostName, int port, final SocketOptions socketOptions, in ServerListener() argument
42 socketOptions.getNativeHandle(), tlsContextPtr, serverBootstrap.getNativeHandle(), in ServerListener()
/external/aws-sdk-java-v2/http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/
DAwsCrtHttpClientBase.java62 private final SocketOptions socketOptions; field in AwsCrtHttpClientBase
86 this.socketOptions = registerOwnedResource(clientSocketOptions); in AwsCrtHttpClientBase()
121 .withSocketOptions(socketOptions) in createConnectionPool()
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DChannelzTestHelper.java60 InternalChannelz.SocketOptions socketOptions field in ChannelzTestHelper.TestSocket
72 socketOptions, in getStats()
DChannelzProtoUtilTest.java388 socket.socketOptions in toSocket_withDataWithOptions()
414 socket.socketOptions = toBuilder(socket.socketOptions) in extractSocketData()
/external/grpc-grpc-java/api/src/main/java/io/grpc/
DInternalChannelz.java711 public final SocketOptions socketOptions; field in InternalChannelz.SocketStats
720 SocketOptions socketOptions, in SocketStats() argument
725 this.socketOptions = checkNotNull(socketOptions); in SocketStats()
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
DChannelzProtoUtil.java238 builder.addAllOption(toSocketOptionsList(socketStats.socketOptions)); in extractSocketData()
/external/grpc-grpc-java/core/src/testFixtures/java/io/grpc/internal/
DAbstractTransportTest.java1911 assertNotNull(clientSocketStats.socketOptions.lingerSeconds); in socketStats()
1912 assertTrue(clientSocketStats.socketOptions.others.containsKey("SO_SNDBUF")); in socketStats()
1920 assertNotNull(serverSocketStats.socketOptions.lingerSeconds); in socketStats()
1921 assertTrue(serverSocketStats.socketOptions.others.containsKey("SO_SNDBUF")); in socketStats()