Searched refs:futures (Results 1 – 6 of 6) sorted by relevance
| /device/google/cuttlefish/guest/monitoring/cuttlefish_service/java/com/android/google/gce/gceservice/ |
| D | JobExecutor.java | 43 public void schedule(JobBase job, GceFuture<?>... futures) { in schedule() argument
44 schedule(job, -1, futures); in schedule()
58 List<GceFuture<?>> futures = Arrays.asList(futuresVarargs); in schedule()
62 while (!futures.isEmpty()) { in schedule()
65 for (GceFuture<?> future : futures) { in schedule()
88 futures = stragglers; in schedule()
89 if (!futures.isEmpty()) { in schedule()
93 attemptNum, GceFuture.toString(futures)); in schedule()
97 job.onDependencyStraggling(futures); in schedule()
|
| D | GceFuture.java | 93 public static String toString(List<GceFuture<?>> futures) { in toString() argument
95 for (GceFuture<?> dep : futures) { in toString()
|
| /device/google/cuttlefish/host/frontend/webrtc_operator/assets/js/ |
| D | server_connector.js | 197 #futures = {}; field in WebsocketConnector
216 this.#futures.onDeviceAvailable = (device) => resolve(device);
217 this.#futures.onConnectionFailed = (error) => reject(error);
233 this.#futures.onConnectionFailed(message.error);
238 this.#futures.infraConfig = message;
241 if (this.#futures.onDeviceAvailable) {
242 this.#futures.onDeviceAvailable({
244 infraConfig: this.#futures.infraConfig,
246 delete this.#futures.onDeviceAvailable;
256 this.#futures.onConnectionFailed(
|
| /device/google/cuttlefish_vmm/x86_64-linux-gnu/ |
| D | Cargo.lock | 180 "futures",
616 "futures",
617 "futures-executor",
618 "futures-util",
743 "futures",
944 "futures",
1002 "futures",
1193 name = "futures"
1198 "futures-channel",
1199 "futures-core",
[all …]
|
| /device/google/cuttlefish_vmm/aarch64-linux-gnu/ |
| D | Cargo.lock | 180 "futures",
616 "futures",
617 "futures-executor",
618 "futures-util",
743 "futures",
944 "futures",
1002 "futures",
1193 name = "futures"
1198 "futures-channel",
1199 "futures-core",
[all …]
|
| /device/google/cuttlefish/tests/reliability/src/com/android/cuttlefish/tests/ |
| D | CuttlefishReliabilityTest.java | 91 List<Future<?>> futures = new ArrayList<>(); in testCuttlefishBootReliability() local
93 futures.add(executorService.submit(() -> { in testCuttlefishBootReliability()
106 for (Future<?> future : futures) { in testCuttlefishBootReliability()
|