| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | ServerListenerTest.java | 8 import software.amazon.awssdk.crt.io.SocketOptions;
33 SocketOptions socketOptions = new SocketOptions(); in testSetupAndTearDown()
35 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testSetupAndTearDown()
36 socketOptions.type = SocketOptions.SocketType.STREAM; in testSetupAndTearDown()
60 SocketOptions socketOptions = new SocketOptions(); in testSetupWith0PortAndTearDown()
62 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testSetupWith0PortAndTearDown()
63 socketOptions.type = SocketOptions.SocketType.STREAM; in testSetupWith0PortAndTearDown()
89 SocketOptions socketOptions = new SocketOptions(); in testBindErrorPropagates()
91 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testBindErrorPropagates()
92 socketOptions.type = SocketOptions.SocketType.STREAM; in testBindErrorPropagates()
[all …]
|
| D | HttpClientTestFixture.java | 14 import software.amazon.awssdk.crt.io.SocketOptions;
26 SocketOptions sockOpts = new SocketOptions(); in createHTTP2ConnectionPoolManager()
42 SocketOptions sockOpts = new SocketOptions(); in createHTTP1ConnectionPoolManager()
|
| D | EventStreamClientConnectionTest.java | 8 import software.amazon.awssdk.crt.io.SocketOptions;
26 SocketOptions socketOptions = new SocketOptions(); in testConnectionHandling()
28 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testConnectionHandling()
29 socketOptions.type = SocketOptions.SocketType.STREAM; in testConnectionHandling()
105 SocketOptions socketOptions = new SocketOptions(); in testConnectionProtocolMessageHandling()
107 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testConnectionProtocolMessageHandling()
108 socketOptions.type = SocketOptions.SocketType.STREAM; in testConnectionProtocolMessageHandling()
213 SocketOptions socketOptions = new SocketOptions(); in testConnectionProtocolMessageWithExtraHeadersHandling()
215 socketOptions.domain = SocketOptions.SocketDomain.IPv4; in testConnectionProtocolMessageWithExtraHeadersHandling()
216 socketOptions.type = SocketOptions.SocketType.STREAM; in testConnectionProtocolMessageWithExtraHeadersHandling()
[all …]
|
| D | HttpClientConnectionTest.java | 21 import software.amazon.awssdk.crt.io.SocketOptions;
40 …tpConnectionTestResponse testConnection(URI uri, ClientBootstrap bootstrap, SocketOptions sockOpts, in testConnection()
78 SocketOptions socketOptions = new SocketOptions(); in testConnectionWithAllCiphers()
130 SocketOptions socketOptions = new SocketOptions(); in testStaticDefaults()
|
| D | ShutdownTest.java | 14 import software.amazon.awssdk.crt.io.SocketOptions;
41 SocketOptions sockOpts = new SocketOptions(); in createConnectionManager()
|
| D | Http2StreamManagerTest.java | 24 import software.amazon.awssdk.crt.io.SocketOptions;
46 SocketOptions sockOpts = new SocketOptions(); in createStreamManager()
|
| D | HttpClientConnectionManagerTest.java | 26 import software.amazon.awssdk.crt.io.SocketOptions;
48 SocketOptions sockOpts = new SocketOptions(); in createConnectionManager()
|
| /external/pytorch/torch/csrc/distributed/c10d/ |
| D | socket.h | 22 class SocketOptions {
24 SocketOptions& prefer_ipv6(bool value) noexcept { in prefer_ipv6()
34 SocketOptions& connect_timeout(std::chrono::milliseconds value) noexcept { in connect_timeout()
45 SocketOptions& connect_backoff(std::shared_ptr<Backoff> value) noexcept { in connect_backoff()
70 static Socket listen(std::uint16_t port, const SocketOptions& opts = {});
77 const SocketOptions& opts = {});
|
| D | socket.cpp | 504 SocketListenOp(std::uint16_t port, const SocketOptions& opts);
524 const SocketOptions* opts_;
529 SocketListenOp::SocketListenOp(std::uint16_t port, const SocketOptions& opts) in SocketListenOp()
734 const SocketOptions& opts);
759 const SocketOptions* opts_;
768 const SocketOptions& opts) in SocketConnectOp()
1034 Socket Socket::listen(std::uint16_t port, const SocketOptions& opts) { in listen()
1049 const SocketOptions& opts) { in connect()
|
| /external/aws-sdk-java-v2/http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/internal/ |
| D | AwsCrtConfigurationUtils.java | 21 import software.amazon.awssdk.crt.io.SocketOptions;
35 …public static SocketOptions buildSocketOptions(TcpKeepAliveConfiguration tcpKeepAliveConfiguration, in buildSocketOptions()
37 SocketOptions clientSocketOptions = new SocketOptions(); in buildSocketOptions()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/http/ |
| D | HttpClientConnectionManagerOptions.java | 9 import software.amazon.awssdk.crt.io.SocketOptions;
22 private SocketOptions socketOptions;
67 public HttpClientConnectionManagerOptions withSocketOptions(SocketOptions socketOptions) { in withSocketOptions()
75 public SocketOptions getSocketOptions() { return socketOptions; } in getSocketOptions()
|
| D | HttpClientConnectionManager.java | 17 import software.amazon.awssdk.crt.io.SocketOptions;
53 SocketOptions socketOptions = options.getSocketOptions(); in HttpClientConnectionManager()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ChannelzTestHelper.java | 27 import io.grpc.InternalChannelz.SocketOptions;
60 InternalChannelz.SocketOptions socketOptions
61 = new InternalChannelz.SocketOptions.Builder().build();
102 new SocketOptions.Builder().addOption("listen_option", "listen_option_value").build(), in getStats()
|
| D | ChannelzProtoUtilTest.java | 43 import io.grpc.InternalChannelz.SocketOptions;
389 = new SocketOptions(null, null, null, ImmutableMap.of("test_name", "test_value")); in toSocket_withDataWithOptions()
816 new InternalChannelz.SocketOptions.Builder().build())) in toSocketOptionsList()
821 new InternalChannelz.SocketOptions.Builder().setSocketOptionLingerSeconds(10).build())) in toSocketOptionsList()
826 new InternalChannelz.SocketOptions.Builder().setSocketOptionTimeoutMillis(200).build())) in toSocketOptionsList()
831 new InternalChannelz.SocketOptions in toSocketOptionsList()
844 new InternalChannelz.SocketOptions.Builder() in toSocketOptionsList()
931 private static SocketOptions.Builder toBuilder(SocketOptions options) { in toBuilder()
932 SocketOptions.Builder builder = new SocketOptions.Builder() in toBuilder()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | UtilsTest.java | 27 import io.grpc.InternalChannelz.SocketOptions;
141 InternalChannelz.SocketOptions socketOptions = Utils.getSocketOptions(channel); in channelOptionsTest_noLinger()
149 SocketOptions socketOptions = setAndValidateGeneric(channel); in channelOptionsTest_oio()
156 SocketOptions socketOptions = setAndValidateGeneric(channel); in channelOptionsTest_nio()
160 private static InternalChannelz.SocketOptions setAndValidateGeneric(Channel channel) { in setAndValidateGeneric()
169 InternalChannelz.SocketOptions socketOptions = Utils.getSocketOptions(channel); in setAndValidateGeneric()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/ |
| D | MqttConnectionConfig.java | 13 import software.amazon.awssdk.crt.io.SocketOptions;
23 private SocketOptions socketOptions;
144 public void setSocketOptions(SocketOptions socketOptions) { in setSocketOptions()
154 public SocketOptions getSocketOptions() { in getSocketOptions()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/io/ |
| D | SocketOptions.java | 14 public final class SocketOptions extends CrtResource { class
99 public SocketOptions() { in SocketOptions() method in SocketOptions
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt5/ |
| D | Mqtt5ClientOptions.java | 9 import software.amazon.awssdk.crt.io.SocketOptions;
30 private SocketOptions socketOptions;
84 public SocketOptions getSocketOptions() in getSocketOptions()
568 private SocketOptions socketOptions;
630 public Mqtt5ClientOptionsBuilder withSocketOptions(SocketOptions socketOptions) in withSocketOptions()
|
| D | Mqtt5Client.java | 15 import software.amazon.awssdk.crt.io.SocketOptions;
61 SocketOptions socketOptions = options.getSocketOptions(); in Mqtt5Client()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | Utils.java | 101 static InternalChannelz.SocketOptions getSocketOptions(Socket socket) { in getSocketOptions()
102 InternalChannelz.SocketOptions.Builder builder = new InternalChannelz.SocketOptions.Builder(); in getSocketOptions()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/eventstream/ |
| D | ServerListener.java | 8 import software.amazon.awssdk.crt.io.SocketOptions;
36 public ServerListener(final String hostName, int port, final SocketOptions socketOptions, in ServerListener()
|
| D | ClientConnection.java | 8 import software.amazon.awssdk.crt.io.SocketOptions;
139 …CompletableFuture<Void> connect(final String hostName, int port, final SocketOptions socketOptions, in connect()
|
| /external/aws-sdk-java-v2/http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/ |
| D | AwsCrtHttpClientBase.java | 36 import software.amazon.awssdk.crt.io.SocketOptions;
62 private final SocketOptions socketOptions;
77 … SocketOptions clientSocketOptions = buildSocketOptions(builder.getTcpKeepAliveConfiguration(), in AwsCrtHttpClientBase()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | UtilsTest.java | 22 import io.grpc.InternalChannelz.SocketOptions;
89 SocketOptions socketOptions = Utils.getSocketOptions(socket); in getSocketOptions()
|
| /external/grpc-grpc-java/api/src/main/java/io/grpc/ |
| D | InternalChannelz.java | 711 public final SocketOptions socketOptions;
720 SocketOptions socketOptions, in SocketStats()
984 public static final class SocketOptions { class in InternalChannelz
992 public SocketOptions( in SocketOptions() method in InternalChannelz.SocketOptions
1045 public SocketOptions build() { in build()
1046 return new SocketOptions(timeoutMillis, lingerSeconds, tcpInfo, others); in build()
|