Home
last modified time | relevance | path

Searched +full:new +full:- +full:client (Results 1 – 25 of 1394) sorted by relevance

12345678910>>...56

/external/aws-sdk-java-v2/codegen/src/test/java/software/amazon/awssdk/codegen/poet/
DClientTestModels.java38 …File serviceModel = new File(ClientTestModels.class.getResource("client/c2j/json/service-2.json").… in awsJsonServiceModels()
39 …File customizationModel = new File(ClientTestModels.class.getResource("client/c2j/json/customizati… in awsJsonServiceModels()
40 …File paginatorsModel = new File(ClientTestModels.class.getResource("client/c2j/json/paginators.jso… in awsJsonServiceModels()
47 return new IntermediateModelBuilder(models).build(); in awsJsonServiceModels()
51 …File serviceModel = new File(ClientTestModels.class.getResource("client/c2j/query-to-json-errorcod… in awsQueryCompatibleJsonServiceModels()
52 …File customizationModel = new File(ClientTestModels.class.getResource("client/c2j/query-to-json-er… in awsQueryCompatibleJsonServiceModels()
53 …File paginatorsModel = new File(ClientTestModels.class.getResource("client/c2j/query-to-json-error… in awsQueryCompatibleJsonServiceModels()
60 return new IntermediateModelBuilder(models).build(); in awsQueryCompatibleJsonServiceModels()
64 …File serviceModel = new File(ClientTestModels.class.getResource("client/c2j/json-bearer-auth/servi… in bearerAuthServiceModels()
65 …File customizationModel = new File(ClientTestModels.class.getResource("client/c2j/json-bearer-auth… in bearerAuthServiceModels()
[all …]
/external/rust/android-crates-io/crates/axum/src/routing/tests/
Dfallback.rs8 let app = Router::new() in basic()
12 let client = TestClient::new(app); in basic() localVariable
14 assert_eq!(client.get("/foo").send().await.status(), StatusCode::OK); in basic()
16 let res = client.get("/does-not-exist").send().await; in basic()
23 let app = Router::new() in nest()
24 .nest("/foo", Router::new().route("/bar", get(|| async {}))) in nest()
27 let client = TestClient::new(app); in nest() localVariable
29 assert_eq!(client.get("/foo/bar").send().await.status(), StatusCode::OK); in nest()
31 let res = client.get("/does-not-exist").send().await; in nest()
38 let one = Router::new().route("/one", get(|| async {})); in or()
[all …]
Dmod.rs47 async fn root(_: Request<Body>) -> &'static str { in hello_world()
51 async fn foo(_: Request<Body>) -> &'static str { in hello_world()
55 async fn users_create(_: Request<Body>) -> &'static str { in hello_world()
59 let app = Router::new() in hello_world()
63 let client = TestClient::new(app); in hello_world() localVariable
65 let res = client.get("/").send().await; in hello_world()
69 let res = client.post("/").send().await; in hello_world()
73 let res = client.post("/users").send().await; in hello_world()
80 let app = Router::new() in routing()
92 let client = TestClient::new(app); in routing() localVariable
[all …]
Dnest.rs8 let api_routes = Router::new() in nesting_apps()
38 let app = Router::new() in nesting_apps()
42 let client = TestClient::new(app); in nesting_apps() localVariable
44 let res = client.get("/").send().await; in nesting_apps()
48 let res = client.get("/v0/api/users").send().await; in nesting_apps()
52 let res = client.get("/v0/api/users/123").send().await; in nesting_apps()
56 let res = client.get("/v0/api/games/123").send().await; in nesting_apps()
63 let nested_app = Router::new().route("/", get(|| async {})); in wrong_method_nest()
64 let app = Router::new().nest("/", nested_app); in wrong_method_nest()
66 let client = TestClient::new(app); in wrong_method_nest() localVariable
[all …]
Dmerge.rs8 let one = Router::new() in basic()
11 let two = Router::new().route("/baz", get(|| async {})); in basic()
14 let client = TestClient::new(app); in basic() localVariable
16 let res = client.get("/foo").send().await; in basic()
19 let res = client.get("/bar").send().await; in basic()
22 let res = client.get("/baz").send().await; in basic()
25 let res = client.get("/qux").send().await; in basic()
31 let one = Router::new().route("/one", get(|| async { "one" })); in multiple_ors_balanced_differently()
32 let two = Router::new().route("/two", get(|| async { "two" })); in multiple_ors_balanced_differently()
33 let three = Router::new().route("/three", get(|| async { "three" })); in multiple_ors_balanced_differently()
[all …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DURLConnectionTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
105 @Rule public final MockWebServer server = new MockWebServer();
106 @Rule public final MockWebServer server2 = new MockWebServer();
107 @Rule public final TemporaryFolder tempDir = new TemporaryFolder();
109 // Android-added: Use TLS 1.3 and 1.2 for testing
111 new ConnectionSpec.Builder(ConnectionSpec.MODERN_TLS)
116 new ConnectionSpec.Builder(ConnectionSpec.MODERN_TLS)
124 private OkUrlFactory client; field in URLConnectionTest
130 client = new OkUrlFactory(new OkHttpClient()); in setUp()
148 server.enqueue(new MockResponse()); in requestHeaders()
[all …]
DInterceptorTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
48 @Rule public MockWebServer server = new MockWebServer();
50 private OkHttpClient client = new OkHttpClient(); field in InterceptorTest
51 private RecordingCallback callback = new RecordingCallback();
56 Request request = new Request.Builder() in applicationInterceptorsCanShortCircuitResponses()
60 final Response interceptorResponse = new Response.Builder() in applicationInterceptorsCanShortCircuitResponses()
65 .body(ResponseBody.create(MediaType.parse("text/plain; charset=utf-8"), "abc")) in applicationInterceptorsCanShortCircuitResponses()
68 client.interceptors().add(new Interceptor() { in applicationInterceptorsCanShortCircuitResponses()
74 Response response = client.newCall(request).execute(); in applicationInterceptorsCanShortCircuitResponses()
79 server.enqueue(new MockResponse().setResponseCode(500)); in networkInterceptorsCannotShortCircuitResponses()
[all …]
DCallTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
89 @Rule public final TestRule timeout = new Timeout(30_000);
90 @Rule public final MockWebServer server = new MockWebServer();
91 @Rule public final MockWebServer server2 = new MockWebServer();
92 @Rule public final InMemoryFileSystem fileSystem = new InMemoryFileSystem();
94 // Android-added: Use TLS 1.3 and 1.2 for testing
96 new ConnectionSpec.Builder(ConnectionSpec.MODERN_TLS)
101 new ConnectionSpec.Builder(ConnectionSpec.MODERN_TLS)
109 private OkHttpClient client = new OkHttpClient(); field in CallTest
110 private RecordingCallback callback = new RecordingCallback();
[all …]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DStressTestClientTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
52 StressTestClient client = new StressTestClient(); in ipv6AddressesShouldBeSupported() local
53 client.parseArgs(new String[] {"--server_addresses=[0:0:0:0:0:0:0:1]:8080," in ipv6AddressesShouldBeSupported()
56 assertEquals(2, client.addresses().size()); in ipv6AddressesShouldBeSupported()
57 assertEquals(new InetSocketAddress("0:0:0:0:0:0:0:1", 8080), client.addresses().get(0)); in ipv6AddressesShouldBeSupported()
58 assertEquals(new InetSocketAddress("1:2:3:4:f:e:a:b", 8083), client.addresses().get(1)); in ipv6AddressesShouldBeSupported()
63 StressTestClient client = new StressTestClient(); in defaults() local
64 assertEquals(singletonList(new InetSocketAddress("localhost", 8080)), client.addresses()); in defaults()
65 assertTrue(client.testCaseWeightPairs().isEmpty()); in defaults()
66 assertEquals(-1, client.durationSecs()); in defaults()
[all …]
/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/testutils/src/test/java/com/google/android/exoplayer2/testutil/
DWebServerDispatcherTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
33 // We use the OkHttp client library for these tests because it's generally nicer to use than Java's
37 // cases of the WebServerDispatcher's Accept-Encoding header handling. If passed a request with no
38 // Accept-Encoding header, the OkHttp client library will silently add one that accepts gzip and
39 // then silently unzip the response data (and remove the Content-Coding header) before returning it.
42 // a request with *no* Accept-Encoding header (since it's impossible to send this using OkHttp).
59 private static final String RANGE_SUPPORTED_PATH = "range/requests-supported";
63 "range/requests-supported-length-unknown";
66 private static final String RANGE_UNSUPPORTED_PATH = "/range/requests/not-supported";
70 "/range/requests/not-supported-length-unknown";
[all …]
/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/testutils/src/test/java/com/google/android/exoplayer2/testutil/
DWebServerDispatcherTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
33 // We use the OkHttp client library for these tests because it's generally nicer to use than Java's
37 // cases of the WebServerDispatcher's Accept-Encoding header handling. If passed a request with no
38 // Accept-Encoding header, the OkHttp client library will silently add one that accepts gzip and
39 // then silently unzip the response data (and remove the Content-Coding header) before returning it.
42 // a request with *no* Accept-Encoding header (since it's impossible to send this using OkHttp).
59 private static final String RANGE_SUPPORTED_PATH = "range/requests-supported";
63 "range/requests-supported-length-unknown";
66 private static final String RANGE_UNSUPPORTED_PATH = "/range/requests/not-supported";
70 "/range/requests/not-supported-length-unknown";
[all …]
/external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/
DUrlConnectionCacheTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
75 private static final HostnameVerifier NULL_HOSTNAME_VERIFIER = new HostnameVerifier() {
81 @Rule public MockWebServer server = new MockWebServer();
82 @Rule public MockWebServer server2 = new MockWebServer();
83 @Rule public InMemoryFileSystem fileSystem = new InMemoryFileSystem();
86 private final OkUrlFactory client = new OkUrlFactory(new OkHttpClient()); field in UrlConnectionCacheTest
88 private final CookieManager cookieManager = new CookieManager();
92 cache = new Cache(new File("/cache/"), Integer.MAX_VALUE, fileSystem); in setUp()
93 client.client().setCache(cache); in setUp()
104 assertSame(cache, client.client().getCache()); in responseCacheAccessWithOkHttpMember()
[all …]
/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/
DMqtt5ClientTest.java70 Mqtt5ClientOptionsBuilder builder = new Mqtt5ClientOptionsBuilder( in New_UC1()
73 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in New_UC1() argument
74 assertNotNull(client); in New_UC1()
92 EventLoopGroup elg = new EventLoopGroup(1); in New_UC2()
93 HostResolver hr = new HostResolver(elg); in New_UC2()
94 ClientBootstrap bootstrap = new ClientBootstrap(elg, hr); in New_UC2()
95 SocketOptions socketOptions = new SocketOptions(); in New_UC2()
98 PublishPacketBuilder willPacketBuilder = new PublishPacketBuilder(); in New_UC2()
101 ConnectPacketBuilder connectBuilder = new ConnectPacketBuilder(); in New_UC2()
114 ArrayList<UserProperty> userProperties = new ArrayList<UserProperty>(); in New_UC2()
[all …]
DMqtt5to3AdapterConnectionTest.java3 * SPDX-License-Identifier: Apache-2.0.
57 …zon.awssdk.crt.mqtt.OnConnectionSuccessReturn> onConnectionSuccessFuture = new CompletableFuture<s…
58 …zon.awssdk.crt.mqtt.OnConnectionFailureReturn> onConnectionFailureFuture = new CompletableFuture<s…
59 …mazon.awssdk.crt.mqtt.OnConnectionClosedReturn> onConnectionClosedFuture = new CompletableFuture<s…
63 private MqttClientConnectionEvents events = new MqttClientConnectionEvents() {
121 boolean Mqtt3Connect(Mqtt5Client client) throws Exception { in Mqtt3Connect() argument
123 connection = new MqttClientConnection(client, events); in Mqtt3Connect()
141 Mqtt5ClientOptionsBuilder builder = new Mqtt5ClientOptionsBuilder( in TestCreationMinimal()
144 ConnectPacketBuilder connectBuilder = new ConnectPacketBuilder(); in TestCreationMinimal()
147 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in TestCreationMinimal() argument
[all …]
/external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/
DSSLSocketVersionCompatibilityTest.java9 * http://www.apache.org/licenses/LICENSE-2.0
139 @Parameterized.Parameters(name = "{index}: {0} client, {1} server")
141 return Arrays.asList(new Object[][] { in data()
161 threadGroup = new ThreadGroup("SSLSocketVersionedTest"); in setup()
162 executor = Executors.newCachedThreadPool(r -> new Thread(threadGroup, r)); in setup()
173 final TestSSLContext c = new TestSSLContext.Builder() in test_SSLSocket_startHandshake()
176 SSLSocket client = in test_SSLSocket_startHandshake() local
179 Future<Void> future = runAsync(() -> { in test_SSLSocket_startHandshake()
197 client.startHandshake(); in test_SSLSocket_startHandshake()
198 assertNotNull(client.getSession()); in test_SSLSocket_startHandshake()
[all …]
/external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/
DSSLSocketVersionCompatibilityTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
132 @Parameterized.Parameters(name = "{index}: {0} client, {1} server")
134 return Arrays.asList(new Object[][] { in data()
154 threadGroup = new ThreadGroup("SSLSocketVersionedTest"); in setup()
155 executor = Executors.newCachedThreadPool(r -> new Thread(threadGroup, r)); in setup()
166 final TestSSLContext c = new TestSSLContext.Builder() in test_SSLSocket_startHandshake()
169 SSLSocket client = in test_SSLSocket_startHandshake() local
172 Future<Void> future = runAsync(() -> { in test_SSLSocket_startHandshake()
191 client.startHandshake(); in test_SSLSocket_startHandshake()
192 assertNotNull(client.getSession()); in test_SSLSocket_startHandshake()
[all …]
/external/grpc-grpc-java/core/src/testFixtures/java/io/grpc/internal/
DAbstractTransportTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
99 Attributes.Key.create("additional-attr");
102 Attributes.Key.create("eag-attr");
107 protected final TransportTracer.Factory fakeClockTransportTracer = new TransportTracer.Factory(
108 new TimeProvider() {
116 * Returns a new server that when started will be able to be connected to from the client. Each
117 * returned instance should be new and yet be accessible by new client transports.
123 * Builds a new server that is listening on the same port as the given server instance does.
129 * Returns a new transport that when started will be able to connect to {@code server}.
134 * Returns the authority string used by a client to connect to {@code server}.
[all …]
/external/rust/android-crates-io/crates/tokio/tests/
Dnet_named_pipe.rs12 async fn test_named_pipe_client_drop() -> io::Result<()> { in test_named_pipe_client_drop()
13 const PIPE_NAME: &str = r"\\.\pipe\test-named-pipe-client-drop"; in test_named_pipe_client_drop()
15 let mut server = ServerOptions::new().create(PIPE_NAME)?; in test_named_pipe_client_drop()
17 let client = ClientOptions::new().open(PIPE_NAME)?; in test_named_pipe_client_drop() localVariable
20 drop(client); in test_named_pipe_client_drop()
22 // instance will be broken because client is gone in test_named_pipe_client_drop()
32 async fn test_named_pipe_single_client() -> io::Result<()> { in test_named_pipe_single_client()
35 const PIPE_NAME: &str = r"\\.\pipe\test-named-pipe-single-client"; in test_named_pipe_single_client()
37 let server = ServerOptions::new().create(PIPE_NAME)?; in test_named_pipe_single_client()
40 // Note: we wait for a client to connect. in test_named_pipe_single_client()
[all …]
/external/elfutils/debuginfod/
DChangeLog1 2023-04-21 Frank Ch. Eigler <fche@redhat.com>
3 * debuginfod.cxx (groom): Fix -r / -X logic.
5 2023-04-13 Frank Ch. Eigler <fche@redhat.com>
10 2023-03-30 Jan Alexander Steffens (heftig) <heftig@archlinux.org>
12 * debuginfod-client.c (update_atime): New function.
15 2023-03-30 Jan Alexander Steffens (heftig) <heftig@archlinux.org>
17 * debuginfod-client.c (debuginfod_query_server): Don't modify
21 2023-03-30 Aaron Merey <amerey@redhat.com>
23 * debuginfod-client.c (debuginfod_query_server): Avoid sscanf on
24 mixed-case component of string.
[all …]
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/client/config/
DSdkClientOption.java16 package software.amazon.awssdk.core.client.config;
52 new SdkClientOption<>(new UnsafeValueType(Map.class));
57 …public static final SdkClientOption<RetryPolicy> RETRY_POLICY = new SdkClientOption<>(RetryPolicy.…
63 new SdkClientOption<>(new UnsafeValueType(List.class));
66 …* The effective endpoint the client is configured to make requests to. If the client has been conf…
69 public static final SdkClientOption<URI> ENDPOINT = new SdkClientOption<>(URI.class);
73 * supplied value and not generated by the client based on Region metadata.
75 …public static final SdkClientOption<Boolean> ENDPOINT_OVERRIDDEN = new SdkClientOption<>(Boolean.c…
78 * Service-specific configuration used by some services, like S3.
81 new SdkClientOption<>(ServiceConfiguration.class);
[all …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DHttpOverSpdyTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
67 @Rule public final TemporaryFolder tempDir = new TemporaryFolder();
68 @Rule public final MockWebServer server = new MockWebServer();
75 protected HostnameVerifier hostnameVerifier = new RecordingHostnameVerifier();
76 protected final OkUrlFactory client = new OkUrlFactory(new OkHttpClient()); field in HttpOverSpdyTest
86 client.client().setProtocols(Arrays.asList(protocol, Protocol.HTTP_1_1)); in setUp()
87 client.client().setSslSocketFactory(sslContext.getSocketFactory()); in setUp()
88 client.client().setHostnameVerifier(hostnameVerifier); in setUp()
89 cache = new Cache(tempDir.getRoot(), Integer.MAX_VALUE); in setUp()
97 MockResponse response = new MockResponse().setBody("ABCDE").setStatus("HTTP/1.1 200 Sweet"); in get()
[all …]
/external/autotest/frontend/client/src/autotest/afe/
DHostSelectorDisplay.java6 import com.google.gwt.event.dom.client.HasClickHandlers;
7 import com.google.gwt.user.client.ui.Button;
8 import com.google.gwt.user.client.ui.CheckBox;
9 import com.google.gwt.user.client.ui.Composite;
10 import com.google.gwt.user.client.ui.HasText;
11 import com.google.gwt.user.client.ui.HasValue;
12 import com.google.gwt.user.client.ui.HorizontalPanel;
13 import com.google.gwt.user.client.ui.Label;
14 import com.google.gwt.user.client.ui.Panel;
15 import com.google.gwt.user.client.ui.SimplePanel;
[all …]
/external/google-cloud-java/java-monitoring/google-cloud-monitoring/src/test/java/com/google/cloud/monitoring/v3/
DITVPCServiceControlTest.java8 * https://www.apache.org/licenses/LICENSE-2.0
17 // DO NOT MODIFY! THIS FILE IS AUTO-GENERATED.
18 // This file is auto-generated on 28 Jan 20 00:11 UTC.
102 "https://www.googleapis.com/auth/cloud-platform")); in postJSON()
108 conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8"); in postJSON()
113 body.write(payload.getBytes("UTF-8")); in postJSON()
119 new BufferedReader(new InputStreamReader((InputStream) conn.getErrorStream())); in postJSON()
120 StringBuilder response = new StringBuilder(); in postJSON()
127 throw new PermissionDeniedException( in postJSON()
133 throw new RuntimeException(response.toString()); in postJSON()
[all …]
/external/okhttp/okhttp-apache/src/test/java/com/squareup/okhttp/apache/
DOkApacheClientTest.java17 import org.apache.http.client.methods.HttpGet;
18 import org.apache.http.client.methods.HttpPost;
19 import org.apache.http.client.methods.HttpPut;
35 private OkApacheClient client; field in OkApacheClientTest
38 client = new OkApacheClient(); in setUp()
39 server = new MockWebServer(); in setUp()
48 server.enqueue(new MockResponse().setBody("Hello, World!")); in success()
50 HttpGet request = new HttpGet(server.getUrl("/").toURI()); in success()
51 HttpResponse response = client.execute(request); in success()
57 server.enqueue(new MockResponse().setResponseCode(302).addHeader("Location", "/foo")); in redirect()
[all …]
/external/apache-http/src/org/apache/http/impl/client/
DDefaultHttpClient.java2 …org/repos/asf/httpcomponents/httpclient/trunk/module-client/src/main/java/org/apache/http/impl/cli…
4 * $Date: 2008-07-16 04:45:47 -0700 (Wed, 16 Jul 2008) $
15 * http://www.apache.org/licenses/LICENSE-2.0
32 package org.apache.http.impl.client;
37 import org.apache.http.client.AuthenticationHandler;
38 import org.apache.http.client.CookieStore;
39 import org.apache.http.client.CredentialsProvider;
40 import org.apache.http.client.HttpRequestRetryHandler;
41 import org.apache.http.client.RedirectHandler;
42 import org.apache.http.client.UserTokenHandler;
[all …]

12345678910>>...56