| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| ShadowContentProviderOperationBuilderTest.java | 34 final ContentRequest request = new ContentRequest(); local
65 request.uri = uri;
66 request.values = values;
67 request.selection = selection;
68 request.selectionArgs = selectionArgs;
76 assertThat(request.uri).isEqualTo(uri);
77 assertThat(request.selection).isEqualTo("a=?");
78 assertThat(request.selectionArgs).isEqualTo(new String[] {"a"});
80 assertThat(request.values.containsKey("k1")).isTrue();
81 assertThat(request.values.containsKey("k2")).isTrue()
[all...] |
| /cts/tests/tests/shortcutmanager/src/android/content/pm/cts/shortcutmanager/ |
| ShortcutManagerConfigActivityTest.java | 89 PinItemRequest request = getShortcutRequestForPackage1(); local
91 assertTrue(request.isValid());
92 assertTrue(request.accept());
98 PinItemRequest request = getShortcutRequestForPackage1(); local
101 // Launcher1 can still access the request
103 assertTrue(request.isValid());
104 assertTrue(request.accept());
110 PinItemRequest request = getShortcutRequestForPackage1(); local
112 // Launcher1 can still access the request
114 assertFalse(request.isValid())
[all...] |
| /development/samples/USB/AdbTest/src/com/android/adb/ |
| AdbMessage.java | 108 UsbRequest request = device.getOutRequest(); local
109 request.setClientData(this);
110 if (request.queue(mMessageBuffer, 24)) {
113 request = device.getOutRequest();
114 request.setClientData(this);
115 if (request.queue(mDataBuffer, length)) {
118 device.releaseOutRequest(request);
124 device.releaseOutRequest(request);
130 public boolean readCommand(UsbRequest request) {
131 request.setClientData(this)
[all...] |
| /external/grpc-grpc/examples/python/multiplex/ |
| multiplex_server.py | 62 def SayHello(self, request, context):
64 message='Hello, {}!'.format(request.name))
73 def GetFeature(self, request, context):
74 feature = _get_feature(self.db, request)
76 return route_guide_pb2.Feature(name="", location=request)
80 def ListFeatures(self, request, context):
81 left = min(request.lo.longitude, request.hi.longitude)
82 right = max(request.lo.longitude, request.hi.longitude
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| grpc_eager_service.cc | 71 ::grpc::ClientContext* context, const CreateContextRequest& request,
74 channel_.get(), rpcmethod_CreateContext_, context, request, response);
78 const EnqueueRequest& request,
81 context, request, response);
85 ::grpc::ClientContext* context, const WaitQueueDoneRequest& request,
88 channel_.get(), rpcmethod_WaitQueueDone_, context, request, response);
92 const KeepAliveRequest& request,
95 channel_.get(), rpcmethod_KeepAlive_, context, request, response);
99 ::grpc::ClientContext* context, const CloseContextRequest& request,
102 channel_.get(), rpcmethod_CloseContext_, context, request, response)
[all...] |
| /external/apache-http/android/src/android/net/http/ |
| ConnectionThread.java | 73 // next request starts.
82 Request request; local
84 /* Get a request to process */
85 request = mRequestFeeder.getRequest();
88 if (request == null) {
103 if (HttpLog.LOGV) HttpLog.v("ConnectionThread: new request " +
104 request.mHost + " " + request );
107 request.mHost)
[all...] |
| /external/nanohttpd/core/src/test/java/fi/iki/elonen/ |
| HttpKeepAliveTest.java | 50 String request = "GET " + HttpServerTest.URI + " HTTP/1.1\r\n\r\n"; local
59 testManyRequests(request, expected);
65 String request = "PUT " + HttpServerTest.URI + " HTTP/1.1\r\nContent-Length: " + data.length() + "\r\n\r\n" + data; local
74 testManyRequests(request, expected);
78 * Issue the given request many times to check whether an error occurs. For
82 * @param request
83 * The request to issue
87 public void testManyRequests(final String request, final String[] expected) throws Exception {
100 requestStream.write(request.getBytes());
108 String closeReq = request.replaceAll("HTTP/1.1", "HTTP/1.1\r\nConnection: Close")
[all...] |
| /external/protobuf/conformance/ |
| conformance_ruby.rb | 38 def do_test(request)
43 case request.payload
47 Conformance::TestAllTypes.decode(request.protobuf_payload)
55 test_message = Conformance::TestAllTypes.decode_json(request.json_payload)
62 fail "Request didn't have payload"
65 case request.requested_output_format
76 fail "Request didn't have requested output format"
97 request = Conformance::ConformanceRequest.decode(serialized_request)
99 response = do_test(request)
107 STDERR.puts("conformance_ruby: request=#{request.to_json}, "
[all...] |
| /external/okhttp/okhttp-apache/src/main/java/com/squareup/okhttp/apache/ |
| OkApacheClient.java | 6 import com.squareup.okhttp.Request;
42 private static Request transformRequest(HttpRequest request) {
43 Request.Builder builder = new Request.Builder();
45 RequestLine requestLine = request.getRequestLine();
50 for (Header header : request.getAllHeaders()) {
60 if (request instanceof HttpEntityEnclosingRequest) {
61 HttpEntity entity = ((HttpEntityEnclosingRequest) request).getEntity();
156 @Override public HttpResponse execute(HttpUriRequest request) throws IOException
[all...] |
| /external/python/httplib2/tests/ |
| test_cache.py | 15 http.request(uri, "GET")
16 response, content = http.request(
27 response, content = http.request(
41 response, content = http.request(
55 # response, content = http.request(uri, 'GET', headers={'Accept': 'text/plain'})
59 # response, content = http.request(uri, 'GET', headers={'Accept': 'text/plain'})
63 # response, content = http.request(uri, 'GET', headers={'Accept': 'text/html'})
76 response, content = http.request(uri, "GET", headers={"accept": "text/plain"})
81 # request is the same as the request
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| ConnectionReuseTest.java | 44 Request request = new Request.Builder() local
47 assertConnectionReused(request, request);
55 Request request = new Request.Builder() local
58 assertConnectionReused(request, request);
97 Request request = new Request.Builder() local
108 Request request = new Request.Builder() local
122 Request request = new Request.Builder() local
140 Request request = new Request.Builder() local
154 Request request = new Request.Builder() local
194 Request request = new Request.Builder() local
210 Request request = new Request.Builder() local
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| eager_service_impl.cc | 84 Status EagerServiceImpl::CreateContext(const CreateContextRequest* request,
97 request->server_def().job_name().data(),
98 request->server_def().task_index()),
108 auto* r = env_->rendezvous_mgr->Find(request->rendezvous_id());
109 auto session_name = strings::StrCat("eager_", request->rendezvous_id());
111 session_name, request->server_def(), true));
123 request->async(), std::move(device_mgr), r));
133 new ServerContext(std::move(ctx), request->keep_alive_secs(), env_));
202 Status EagerServiceImpl::Enqueue(const EnqueueRequest* request,
205 TF_RETURN_IF_ERROR(GetServerContext(request->context_id(), &context))
[all...] |
| /external/python/apitools/samples/servicemanagement_sample/servicemanagement_v1/ |
| servicemanagement_v1.py | 219 request = messages.ServicemanagementOperationsGetRequest(
223 request, global_params=global_params)
274 request = messages.ConvertConfigRequest(
277 request.configSpec = apitools_base.JsonToMessage(messages.ConvertConfigRequest.ConfigSpecValue, FLAGS.configSpec)
279 request.openApiSpec = apitools_base.JsonToMessage(messages.OpenApiSpec, FLAGS.openApiSpec)
281 request.serviceName = FLAGS.serviceName.decode('utf8')
283 request.swaggerSpec = apitools_base.JsonToMessage(messages.SwaggerSpec, FLAGS.swaggerSpec)
285 request, global_params=global_params)
369 request = messages.ManagedService(
372 request.configSource = apitools_base.JsonToMessage(messages.ConfigSource, FLAGS.configSource
[all...] |
| servicemanagement_v1_client.py | 55 def Get(self, request, global_params=None):
61 request: (ServicemanagementOperationsGetRequest) input message
68 config, request, global_params=global_params)
93 def Query(self, request, global_params=None):
104 request: (ServicemanagementServicesAccessPolicyQueryRequest) input message
111 config, request, global_params=global_params)
136 def Create(self, request, global_params=None):
142 request: (ServicemanagementServicesConfigsCreateRequest) input message
149 config, request, global_params=global_params)
164 def Get(self, request, global_params=None)
[all...] |
| /external/grpc-grpc/test/cpp/end2end/ |
| channelz_service_test.cc | 56 // request->backend_channel_idx().
65 Status Echo(ServerContext* server_context, const EchoRequest* request,
69 size_t idx = request->param().backend_channel_idx();
71 return stubs_[idx]->Echo(client_context.get(), *request, response);
142 EchoRequest request; local
144 request.set_message("Hello channelz");
145 request.mutable_param()->set_backend_channel_idx(channel_idx);
147 Status s = echo_stub_->Echo(&context, request, &response);
148 EXPECT_EQ(response.message(), request.message());
153 EchoRequest request; local
168 GetTopChannelsRequest request; local
207 GetTopChannelsRequest request; local
219 GetTopChannelsRequest request; local
232 GetChannelRequest request; local
247 GetChannelRequest request; local
270 GetChannelRequest request; local
286 GetTopChannelsRequest request; local
312 GetChannelRequest request; local
325 GetChannelRequest request; local
338 GetChannelRequest request; local
352 GetChannelRequest request; local
415 GetServersRequest request; local
435 GetServersRequest request; local
[all...] |
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| ChannelzService.java | 67 GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver) {
69 = channelz.getRootChannels(request.getStartChannelId(), maxPageSize);
78 GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver) {
79 InternalInstrumented<ChannelStats> s = channelz.getRootChannel(request.getChannelId());
96 GetServersRequest request, StreamObserver<GetServersResponse> responseObserver) {
97 ServerList servers = channelz.getServers(request.getStartServerId(), maxPageSize);
106 GetSubchannelRequest request, StreamObserver<GetSubchannelResponse> responseObserver) {
107 InternalInstrumented<ChannelStats> s = channelz.getSubchannel(request.getSubchannelId());
124 GetSocketRequest request, StreamObserver<GetSocketResponse> responseObserver) {
125 InternalInstrumented<SocketStats> s = channelz.getSocket(request.getSocketId())
[all...] |
| /external/oauth/core/src/main/java/net/oauth/client/httpclient4/ |
| HttpMethodResponse.java | 51 public HttpMethodResponse(HttpRequestBase request, HttpResponse response, byte[] requestBody,
54 super(request.getMethod(), new URL(request.getURI().toString()));
55 this.httpRequest = request;
97 StringBuilder request = new StringBuilder(httpRequest.getMethod()); local
98 request.append(" ").append(httpRequest.getURI().getPath());
101 request.append("?").append(query);
103 request.append(EOL);
105 request.append(header.getName()).append(": ").append(header.getValue()).append(EOL);
111 request.append("Content-Length: ").append(contentLength).append(EOL)
[all...] |
| /device/generic/goldfish/wifi/ipv6proxy/ |
| address.cpp | 92 struct ifreq request; local
93 memset(&request, 0, sizeof(request));
94 strncpy(request.ifr_name, interfaceName.c_str(), sizeof(request.ifr_name));
95 request.ifr_name[sizeof(request.ifr_name) - 1] = '\0';
102 int status = ::ioctl(socket.get(), SIOCGIFHWADDR, &request);
106 memcpy(addr->sll_addr, request.ifr_addr.sa_data, 6);
|
| /external/apache-http/src/org/apache/http/impl/client/ |
| RequestWrapper.java | 48 * properties of the current request without modifying the original
51 * This class is also capable of resetting the request headers to
52 * the state of the original request.
74 public RequestWrapper(final HttpRequest request) throws ProtocolException {
76 if (request == null) {
77 throw new IllegalArgumentException("HTTP request may not be null");
79 this.original = request;
80 setParams(request.getParams());
82 if (request instanceof HttpUriRequest) {
83 this.uri = ((HttpUriRequest) request).getURI()
[all...] |
| /external/ltp/testcases/kernel/syscalls/ptrace/ |
| spawn_ptrace_child.h | 32 # define maybe_swap(request, addr, data) \
34 if (request == PTRACE_GETREGS || request == PTRACE_SETREGS) { \
43 #define vptrace(request, pid, addr, data) \
49 maybe_swap(request, __addr, __data); \
50 __ret = ptrace(request, pid, __addr, __data); \
52 perror("ptrace(" #request ", " #pid ", " #addr ", " #data ")"); \
133 static inline char *strptrace(enum __ptrace_request request)
135 return strings[request];
|
| /external/apache-http/src/org/apache/http/client/protocol/ |
| RequestProxyAuthentication.java | 68 public void process(final HttpRequest request, final HttpContext context)
70 if (request == null) {
71 throw new IllegalArgumentException("HTTP request may not be null");
77 if (request.containsHeader(AUTH.PROXY_AUTH_RESP)) {
100 request.addHeader(authScheme.authenticate(creds, request));
|
| RequestTargetAuthentication.java | 68 public void process(final HttpRequest request, final HttpContext context)
70 if (request == null) {
71 throw new IllegalArgumentException("HTTP request may not be null");
77 if (request.containsHeader(AUTH.WWW_AUTH_RESP)) {
101 request.addHeader(authScheme.authenticate(creds, request));
|
| /external/apache-http/src/org/apache/http/impl/conn/ |
| DefaultHttpRoutePlanner.java | 84 HttpRequest request,
88 if (request == null) {
90 ("Request must not be null.");
95 ConnRouteParams.getForcedRoute(request.getParams());
108 ConnRouteParams.getLocalAddress(request.getParams());
110 ConnRouteParams.getDefaultProxy(request.getParams());
|
| /external/apache-http/src/org/apache/http/protocol/ |
| RequestTargetHost.java | 48 * A request interceptor that sets the Host header for HTTP/1.1 requests.
67 public void process(final HttpRequest request, final HttpContext context)
69 if (request == null) {
70 throw new IllegalArgumentException("HTTP request may not be null");
75 if (!request.containsHeader(HTTP.TARGET_HOST)) {
91 ProtocolVersion ver = request.getRequestLine().getProtocolVersion();
99 request.addHeader(HTTP.TARGET_HOST, targethost.toHostString());
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| ThumbnailRequestCoordinator.java | 1 package com.bumptech.glide.request;
4 * A coordinator that coordinates two individual {@link Request}s that load a small thumbnail version of an image and
7 public class ThumbnailRequestCoordinator implements RequestCoordinator, Request {
8 private Request full;
9 private Request thumb;
20 public void setRequests(Request full, Request thumb) {
27 * Returns true if the request is either the request loading the fullsize image or if the request loading th
[all...] |
