| /external/junit/src/main/java/org/junit/internal/requests/ |
| package-info.java | 6 package org.junit.internal.requests
|
| ClassRequest.java | 1 package org.junit.internal.requests;
|
| FilterRequest.java | 1 package org.junit.internal.requests;
|
| SortingRequest.java | 1 package org.junit.internal.requests;
|
| /prebuilts/go/darwin-x86/src/sync/atomic/ |
| value_test.go | 151 // Create worker goroutines that handle incoming requests
155 for r := range requests() {
168 func requests() chan int { func
|
| /prebuilts/go/linux-x86/src/sync/atomic/ |
| value_test.go | 151 // Create worker goroutines that handle incoming requests
155 for r := range requests() {
168 func requests() chan int { func
|
| /external/bouncycastle/bcpkix/src/main/java/org/bouncycastle/cert/ocsp/ |
| OCSPReqBuilder.java | 113 ASN1EncodableVector requests = new ASN1EncodableVector(); local
119 requests.add(((RequestObject)it.next()).toRequest());
127 TBSRequest tbsReq = new TBSRequest(requestorName, new DERSequence(requests), requestExtensions);
|
| OCSPReq.java | 117 Req[] requests = new Req[seq.size()]; local
119 for (int i = 0; i != requests.length; i++)
121 requests[i] = new Req(Request.getInstance(seq.getObjectAt(i)));
124 return requests;
|
| /external/glide/library/src/main/java/com/bumptech/glide/manager/ |
| RequestTracker.java | 10 * A class for tracking, canceling, and restarting in progress, completed, and failed requests.
13 // Most requests will be for views and will therefore be held strongly (and safely) by the view via the tag.
17 // can always make repeated requests into targets other than views, or use an activity manager in a fragment pager
19 private final Set<Request> requests = Collections.newSetFromMap(new WeakHashMap<Request, Boolean>()); field in class:RequestTracker
26 requests.add(request);
34 requests.add(request);
41 requests.remove(request);
45 * Returns {@code true} if requests are currently paused, and {@code false} otherwise.
52 * Stops any in progress requests.
56 for (Request request : requests) {
[all...] |
| /external/e2fsprogs/lib/ss/ |
| ss.h | 47 ss_request_entry *requests; member in struct:_ss_request_table
|
| /external/guava/guava-tests/benchmark/com/google/common/cache/ |
| LoadingCacheSingleThreadBenchmark.java | 48 static AtomicLong requests = new AtomicLong(0); field in class:LoadingCacheSingleThreadBenchmark
72 requests.set(0);
81 requests.addAndGet(reps);
98 double req = requests.get();
|
| /external/guava/guava-tests/benchmark/com/google/common/collect/ |
| MapMakerSingleThreadBenchmark.java | 51 static AtomicLong requests = new AtomicLong(0); field in class:MapMakerSingleThreadBenchmark
75 requests.set(0);
84 requests.addAndGet(reps);
101 double req = requests.get();
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/storage/ |
| CacheQuotaStrategyTest.java | 61 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
62 requests.add(buildCacheQuotaHint("uuid", 0, 100));
64 CacheQuotaStrategy.saveToXml(mOut, requests, 1000);
76 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
77 requests.add(buildCacheQuotaHint("uuid", 0, 100));
78 requests.add(buildCacheQuotaHint("uuid2", 10, 250));
80 CacheQuotaStrategy.saveToXml(mOut, requests, 1000);
93 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
94 requests.add(buildCacheQuotaHint(null, 0, 100));
95 requests.add(buildCacheQuotaHint(null, 10, 250))
[all...] |
| /system/core/libappfuse/tests/ |
| FuseAppLoopTest.cc | 42 std::vector<CallbackRequest> requests; member in class:android::fuse::__anon106757::Callback
56 requests.push_back({.code = FUSE_FSYNC, .inode = inode});
62 requests.push_back({.code = FUSE_WRITE, .inode = inode});
68 requests.push_back({.code = FUSE_READ, .inode = inode});
73 requests.push_back({.code = FUSE_OPEN, .inode = inode});
78 requests.push_back({.code = FUSE_RELEASE, .inode = inode});
115 ASSERT_EQ(1u, callback_.requests.size());
116 EXPECT_EQ(code, callback_.requests[0].code);
117 EXPECT_EQ(10u, callback_.requests[0].inode);
|
| /art/runtime/gc/space/ |
| large_object_space_test.cc | 48 std::vector<std::pair<mirror::Object*, size_t>> requests; local
51 while (requests.size() < num_allocations) {
64 requests.push_back(std::make_pair(obj, request_size));
67 // "Randomly" shuffle the requests.
69 for (size_t j = 0; j < requests.size(); ++j) {
70 std::swap(requests[j], requests[test_rand(&rand_seed) % requests.size()]);
76 for (const auto& pair : requests) {
81 for (const auto& pair : requests) {
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| stunrequest.cc | 77 std::vector<StunRequest*> requests; local
79 requests.push_back(i->second);
81 for (uint32_t i = 0; i < requests.size(); ++i) {
82 // StunRequest destructor calls Remove() which deletes requests
84 delete requests[i];
|
| /external/wpa_supplicant_8/src/radius/ |
| radius_client.h | 62 * requests - radiusAuthClientAccessRequests or radiusAccClientRequests
64 u32 requests; member in struct:hostapd_radius_server
157 * requests. If this interval is set (non-zero), the primary server
|
| /frameworks/base/packages/ExtServices/tests/src/android/ext/services/storage/ |
| CacheQuotaServiceImplTest.java | 81 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
83 requests.add(request);
85 List<CacheQuotaHint> output = getService().onComputeCacheQuotaHints(requests);
93 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
94 requests.add(makeNewRequest("com.test", sTestVolUuid, 1001, 100L));
95 requests.add(makeNewRequest("com.test2", sTestVolUuid, 1002, 99L));
97 List<CacheQuotaHint> output = getService().onComputeCacheQuotaHints(requests);
107 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
108 requests.add(makeNewRequest("com.test", sTestVolUuid, 1001, 100L));
109 requests.add(makeNewRequest("com.test2", sSecondTestVolUuid, 1002, 99L))
120 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
132 ArrayList<CacheQuotaHint> requests = new ArrayList<>(); local
[all...] |
| /system/chre/core/ |
| sensor_request_manager.cc | 124 SensorRequests& requests = mSensorRequests[sensorIndex]; local
125 const Sensor& sensor = requests.sensor;
136 bool nanoappHasRequest = (requests.find(nanoapp, &requestIndex) != nullptr);
145 success = requests.remove(requestIndex, &requestChanged);
161 success = requests.add(sensorRequest, &requestChanged);
176 success = requests.update(requestIndex, sensorRequest, &requestChanged);
225 LOGW("Attempting to remove all requests of an invalid sensor type");
228 SensorRequests& requests = mSensorRequests[sensorIndex]; local
231 for (const SensorRequest& request : requests.multiplexer.getRequests()) {
236 success = requests.removeAll()
256 const auto& requests = multiplexer.getRequests(); local
[all...] |
| /libcore/ojluni/src/main/java/java/net/ |
| URLConnection.java | 284 private MessageHeader requests; field in class:URLConnection
[all...] |
| /frameworks/base/services/core/java/com/android/server/storage/ |
| CacheQuotaStrategy.java | 137 List<CacheQuotaHint> requests = getUnfulfilledRequests();
141 mRemoteService.computeCacheQuotaHints(remoteCallback, requests);
171 List<CacheQuotaHint> requests = new ArrayList<>(); local
192 requests.add(
205 return requests;
324 List<CacheQuotaHint> requests, long bytesWhenCalculated) throws IOException {
327 int requestSize = requests.size();
331 CacheQuotaHint request = requests.get(i);
|
| /cts/tests/tests/webkit/src/android/webkit/cts/ |
| ServiceWorkerClientTest.java | 86 // Only return content for INDEX_URL, deny all other requests.
102 // Records intercepted requests and only return content for SW_URL.
170 List<WebResourceRequest> requests = mInterceptServiceWorkerClient.getInterceptedRequests(); local
171 assertEquals(2, requests.size());
172 assertEquals(SW_URL, requests.get(0).getUrl().toString());
173 assertEquals(FETCH_URL, requests.get(1).getUrl().toString());
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_urllib2_localnet.py | 303 requests = []
variable in class:GetRequestHandler.FakeHTTPRequestHandler
316 self.requests.append(post_data)
320 self.requests.append(self.path)
375 self.assertEqual(handler.requests, ['/', '/somewhere_else'])
396 self.assertEqual(handler.requests, ['/weeble'])
411 self.assertEqual(handler.requests, ['/bizarre'])
425 self.assertEqual(handler.requests, ['/bizarre', 'get=with_feeling'])
487 # domain name requests in an attempt to boost traffic
500 # requests. The real solution would be to be able to
|
| /external/dagger2/compiler/src/main/java/dagger/internal/codegen/ |
| SourceFiles.java | 70 * to requests. This is used when generating component's initialize()
100 * Allows dependency requests to be grouped by the key they're requesting.
103 * unresolved dependency requests, otherwise we may generate factories based on
121 * <li>Choosing a name that associates the binding with all of the dependency requests for this
140 Collection<DependencyRequest> requests = entry.getValue(); local
142 dependencyRequestMapper.getFrameworkClass(requests.iterator().next());
145 FluentIterable.from(requests).transform(new DependencyVariableNamer()).toSet();
|
| /external/wpa_supplicant_8/src/wps/ |
| http_server.c | 36 struct http_request *requests; member in struct:http_server
67 wpa_printf(MSG_DEBUG, "HTTP: Too many concurrent requests");
101 r = srv->requests;
107 srv->requests = r->next;
222 req->next = srv->requests;
223 srv->requests = req;
305 http_request_free_all(srv->requests);
|
