| /packages/apps/StorageManager/src/com/android/storagemanager/utils/ |
| Utils.java | 27 View loading, View doneLoading, boolean done, boolean animate) {
28 setViewShown(loading, !done, animate);
29 setViewShown(doneLoading, done, animate);
|
| /packages/apps/UnifiedEmail/src/org/apache/james/mime4j/decoder/ |
| Base64InputStream.java | 41 private boolean done = false; field in class:Base64InputStream
80 // "done" is needed for the two successive '=' at the end
81 while (!done) {
84 // No more input - just return, let outputBuffer drain out, and be done
88 done = true;
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/thread/thread.threads/thread.thread.class/thread.thread.member/ |
| detach.pass.cpp | 25 std::atomic_bool done(false);
48 if (done_) done = true;
73 while (!done) {}
|
| /external/curl/lib/ |
| curl_ntlm_wb.c | 183 goto done;
189 goto done;
198 goto done;
246 done:
268 goto done;
282 goto done;
285 goto done;
303 goto done;
306 goto done;
309 goto done;
[all...] |
| asyn-thread.c | 156 int done; member in struct:thread_sync_data
213 /* Treat the request as done until the thread actually starts so any early
214 * cleanup gets done properly.
216 tsd->done = 1;
291 if(tsd->done) {
298 tsd->done = 1;
324 if(tsd->done) {
331 tsd->done = 1;
347 int done; local
354 done = td->tsd.done
512 int done = 0; local
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| qr_op_impl.h | 136 void ComputeAsync(OpKernelContext* context, DoneCallback done) final {
149 done);
158 done);
163 done);
166 done();
183 done);
190 done);
196 context, DoMatrixTranspose(device, input, &input_transposed), done);
211 done);
219 context, DoMatrixTranspose(device, input_transposed, r), done);
[all...] |
| crop_and_resize_op.cc | 81 // [0, batch_size) then calls done.
85 int batch_size, const Callback& compute, const Callback& done);
91 int batch_size, const Callback& compute, const Callback& done) {
97 done);
102 if (done) {
103 done();
122 void ComputeAsync(OpKernelContext* context, DoneCallback done) override {
137 done);
144 errors::InvalidArgument("image dimensions must be positive"), done);
147 context, ParseAndCheckBoxSizes(boxes, box_index, &num_boxes), done);
[all...] |
| dynamic_partition_op_gpu.cu.cc | 198 DoneCallback done) {
203 c, c->allocate_temp(DT_INT32, TensorShape({M}), indices_in), done);
205 c, c->allocate_temp(DT_INT32, TensorShape({N}), partitions_out), done);
207 c, c->allocate_temp(DT_INT32, TensorShape({N}), indices_out), done);
212 OpOutputList* Tout, DoneCallback done) {
215 OP_REQUIRES_OK_ASYNC(c, c->output_list("outputs", Tout), done);
223 OP_REQUIRES_OK_ASYNC(c, Tout->allocate(p, shape, &out), done);
227 void ComputeAsync(OpKernelContext* c, DoneCallback done) {
237 done);
250 done);
[all...] |
| /external/boringssl/src/crypto/hkdf/ |
| hkdf.c | 65 size_t n, done = 0; local
97 if (done + todo > out_len) {
98 todo = out_len - done;
100 OPENSSL_memcpy(out_key + done, previous, todo);
101 done += todo;
|
| /external/e2fsprogs/lib/ext2fs/ |
| expanddir.c | 24 int done; member in struct:expand_dir_struct
67 es->done = 1;
81 if (es->done)
109 es.done = 0;
122 if (!es.done)
|
| /external/tensorflow/tensorflow/compiler/tf2xla/kernels/ |
| function_ops.cc | 65 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
69 done);
73 done);
86 opts, handle_, args, rets, [ctx, done, rets](const Status& status) {
99 done();
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| remote_device.cc | 58 const string& worker_name, NewRemoteDevicesDone done) {
62 done(errors::NotFound("Device ", worker_name, " is not found."), &empty);
70 auto cb = [env, worker_cache, worker_name, done, wi,
75 [&worker_cache, &worker_name, &wi, &done, &remote_devices, &s, call] {
77 done(s, &remote_devices);
|
| master.cc | 308 CreateSessionResponse* resp, MyClosure done) {
309 SchedClosure([this, req, resp, done]() {
314 auto call_done = gtl::MakeCleanup([&status, &done] { done(status); });
443 ExtendSessionResponse* resp, MyClosure done) {
446 done(errors::Aborted("Session ", req->session_handle(), " is not found."));
450 SchedClosure([session, req, resp, done]() {
456 done(status);
461 PartialRunSetupResponse* resp, MyClosure done) {
464 done(errors::Aborted("Session ", req->session_handle(), " is not found."))
[all...] |
| /external/tensorflow/tensorflow/core/framework/ |
| cancellation_test.cc | 101 std::vector<Notification> done(8);
102 for (size_t i = 0; i < done.size(); ++i) {
103 Notification* n = &done[i];
112 for (size_t i = 0; i < done.size(); ++i) {
113 done[i].WaitForNotification();
|
| /external/syslinux/com32/lua/src/ |
| dhcp.c | 117 for (int done = 0; done < loop; done++){
118 sprintf(op_name, "%u.%d", option, done+1);
120 sprintf(op_value, "%u.%u.%u.%u", value[0+(done*4)], value[1+(done*4)], value[2+(done*4)], value[3+(done*4)]);
145 int done = 0; local
240 done = 1
[all...] |
| /external/vboot_reference/futility/ |
| futility.c | 37 int len, done, n; local
47 for (done = 0; done < len; done += n) {
48 n = write(log_fd, prefix + done, len - done);
60 for (done = 0; done < len; done += n) {
61 n = write(log_fd, str + done, len - done)
[all...] |
| /prebuilts/go/darwin-x86/src/log/syslog/ |
| syslog_test.go | 23 func runPktSyslog(c net.PacketConn, done chan<- string) {
45 done <- rcvd
66 func runStreamSyslog(l net.Listener, done chan<- string, wg *sync.WaitGroup) {
75 defer wg.Done()
83 done <- s
90 func startServer(n, la string, done chan<- string) (addr string, sock io.Closer, wg *sync.WaitGroup) {
117 defer wg.Done()
118 runPktSyslog(l, done)
129 defer wg.Done()
130 runStreamSyslog(l, done, wg
[all...] |
| /prebuilts/go/linux-x86/src/log/syslog/ |
| syslog_test.go | 23 func runPktSyslog(c net.PacketConn, done chan<- string) {
45 done <- rcvd
66 func runStreamSyslog(l net.Listener, done chan<- string, wg *sync.WaitGroup) {
75 defer wg.Done()
83 done <- s
90 func startServer(n, la string, done chan<- string) (addr string, sock io.Closer, wg *sync.WaitGroup) {
117 defer wg.Done()
118 runPktSyslog(l, done)
129 defer wg.Done()
130 runStreamSyslog(l, done, wg
[all...] |
| /external/boringssl/src/decrepit/cfb/ |
| cfb_test.cc | 62 size_t done = 0; local
63 while (done < input_len) {
65 if (todo > input_len - done) {
66 todo = input_len - done;
70 ASSERT_TRUE(EVP_EncryptUpdate(ctx.get(), out.get() + done, &out_bytes,
71 test.plaintext + done, todo));
74 done += todo;
|
| /external/libevent/ |
| bufferevent_sock.c | 177 goto done;
185 goto done;
197 goto done;
214 goto done;
217 goto done;
223 done:
257 goto done;
264 goto done;
274 goto done;
282 goto done;
[all...] |
| /system/core/libusbhost/ |
| usbhost.c | 104 int done = 0; local
109 while ((de = readdir(devdir)) && !done) {
113 done = added_cb(devname, client_data);
117 return done;
120 /* returns true if one of the callbacks indicates we are done */
127 int done = 0; local
132 while ((de = readdir(busdir)) != 0 && !done) {
136 done = find_existing_devices_bus(busname, added_cb,
141 return done;
196 int done = 0 local
234 int i, ret, done = 0; local
313 int done; local
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ThreadPoolExecutorTest.java | 96 final CountDownLatch done = new CountDownLatch(1); local
98 public void realRun() { done.countDown(); }};
100 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS));
109 final CountDownLatch done = new CountDownLatch(1); local
114 try (PoolCleaner cleaner = cleaner(p, done)) {
121 await(done);
336 final CountDownLatch done = new CountDownLatch(1); local
341 try (PoolCleaner cleaner = cleaner(p, done)) {
348 await(done);
380 final CountDownLatch done = new CountDownLatch(1) local
404 final CountDownLatch done = new CountDownLatch(1); local
494 final CountDownLatch done = new CountDownLatch(1); local
522 final CountDownLatch done = new CountDownLatch(1); local
544 final CountDownLatch done = new CountDownLatch(1); local
576 final CountDownLatch done = new CountDownLatch(1); local
611 final CountDownLatch done = new CountDownLatch(1); local
1029 final CountDownLatch done = new CountDownLatch(1); local
1058 final CountDownLatch done = new CountDownLatch(1); local
1084 final CountDownLatch done = new CountDownLatch(1); local
1110 final CountDownLatch done = new CountDownLatch(1); local
1143 final CountDownLatch done = new CountDownLatch(1); local
1165 final CountDownLatch done = new CountDownLatch(1); local
1191 final CountDownLatch done = new CountDownLatch(1); local
1422 final CountDownLatch done = new CountDownLatch(1); local
[all...] |
| ThreadPoolExecutorSubclassTest.java | 57 boolean done; field in class:ThreadPoolExecutorSubclassTest.CustomTask
72 lock.lock(); try { return done; } finally { lock.unlock() ; }
80 if (!done) {
82 done = true;
94 if (done)
109 if (!done) {
112 done = true;
122 while (!done)
137 while (!done) {
243 final CountDownLatch done = new CountDownLatch(1) local
256 final CountDownLatch done = new CountDownLatch(1); local
483 final CountDownLatch done = new CountDownLatch(1); local
527 final CountDownLatch done = new CountDownLatch(1); local
551 final CountDownLatch done = new CountDownLatch(1); local
609 final CountDownLatch done = new CountDownLatch(1); local
637 final CountDownLatch done = new CountDownLatch(1); local
659 final CountDownLatch done = new CountDownLatch(1); local
691 final CountDownLatch done = new CountDownLatch(1); local
726 final CountDownLatch done = new CountDownLatch(1); local
1141 final CountDownLatch done = new CountDownLatch(1); local
1167 final CountDownLatch done = new CountDownLatch(1); local
1197 final CountDownLatch done = new CountDownLatch(1); local
1220 final CountDownLatch done = new CountDownLatch(1); local
1415 final CountDownLatch done = new CountDownLatch(1); local
[all...] |
| /external/python/cpython3/Python/ |
| formatter_unicode.c | 778 goto done;
786 goto done;
794 goto done;
821 goto done;
826 goto done;
836 done:
872 goto done;
882 goto done;
889 goto done;
896 goto done;
[all...] |
| /prebuilts/go/darwin-x86/src/sync/ |
| cond_test.go | 134 done := make(chan bool)
145 done <- true
160 done <- true
180 done <- true
182 <-done
183 <-done
184 <-done
216 done := false
223 for !done {
239 done = tru
[all...] |
