| /external/tensorflow/tensorflow/core/kernels/ |
| qr_op_impl.h | 139 void ComputeAsync(OpKernelContext* context, DoneCallback done) final {
152 done);
161 done);
166 done);
169 done();
186 done);
193 done);
199 context, DoMatrixTranspose(device, input, &input_transposed), done);
214 done);
222 context, DoMatrixTranspose(device, input_transposed, r), done);
[all...] |
| crop_and_resize_op.cc | 80 // [0, batch_size) then calls done.
84 int batch_size, const Callback& compute, const Callback& done);
90 int batch_size, const Callback& compute, const Callback& done) {
96 done);
101 if (done) {
102 done();
121 void ComputeAsync(OpKernelContext* context, DoneCallback done) override {
136 done);
143 errors::InvalidArgument("image dimensions must be positive"), done);
146 context, ParseAndCheckBoxSizes(boxes, box_index, &num_boxes), done);
[all...] |
| dynamic_partition_op_gpu.cu.cc | 199 DoneCallback done) {
204 c, c->allocate_temp(DT_INT32, TensorShape({M}), indices_in), done);
206 c, c->allocate_temp(DT_INT32, TensorShape({N}), partitions_out), done);
208 c, c->allocate_temp(DT_INT32, TensorShape({N}), indices_out), done);
213 OpOutputList* Tout, DoneCallback done) {
216 OP_REQUIRES_OK_ASYNC(c, c->output_list("outputs", Tout), done);
224 OP_REQUIRES_OK_ASYNC(c, Tout->allocate(p, shape, &out), done);
228 void ComputeAsync(OpKernelContext* c, DoneCallback done) {
238 done);
251 done);
[all...] |
| stack.cc | 220 void StackPushOp::ComputeAsync(OpKernelContext* ctx, DoneCallback done) {
223 OP_REQUIRES_OK_ASYNC(ctx, GetStack(ctx, &stack), done);
230 done();
260 [cpu_tensor, stack, ctx, done](const Status& s) {
269 done();
277 OP_REQUIRES_OK_ASYNC(ctx, stack->Push({tensor, alloc_attrs, false}), done);
279 done();
289 void StackPopOp::ComputeAsync(OpKernelContext* ctx, DoneCallback done) {
292 OP_REQUIRES_OK_ASYNC(ctx, GetStack(ctx, &stack), done);
298 OP_REQUIRES_OK_ASYNC(ctx, stack->Pop(&value), done);
[all...] |
| functional_ops.cc | 138 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
141 errors::Internal("No function library"), done);
152 OP_REQUIRES_OK_ASYNC(ctx, Instantiate(lib, then_func_, &then_handle), done);
153 OP_REQUIRES_OK_ASYNC(ctx, Instantiate(lib, else_func_, &else_handle), done);
157 (new State(this, ctx, cond, then_handle, else_handle, done))->Start();
167 FHandle else_handle, DoneCallback done)
173 done_(std::move(done)),
189 // Done callback
225 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
228 errors::Internal("No function library"), 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/openssh/ |
| dispatch.c | 92 ssh_dispatch_run(struct ssh *ssh, int mode, volatile sig_atomic_t *done,
129 if (done != NULL && *done)
135 ssh_dispatch_run_fatal(struct ssh *ssh, int mode, volatile sig_atomic_t *done,
140 if ((r = ssh_dispatch_run(ssh, mode, done, ctxt)) != 0)
|
| /external/python/cpython3/Python/ |
| formatter_unicode.c | 775 goto done;
783 goto done;
791 goto done;
818 goto done;
823 goto done;
833 done:
869 goto done;
879 goto done;
886 goto done;
893 goto done;
[all...] |
| /external/tensorflow/tensorflow/compiler/tf2xla/kernels/ |
| function_ops.cc | 66 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
70 done);
74 done);
87 opts, handle_, args, rets, [ctx, done, rets](const Status& status) {
100 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);
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| parse_address.cc | 80 goto done;
85 goto done;
90 goto done;
94 done:
139 goto done;
148 goto done;
156 goto done;
163 goto done;
169 goto done;
174 goto done;
[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...] |
| /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...] |
| /external/tensorflow/tensorflow/core/common_runtime/ |
| buf_rendezvous.cc | 68 const ProducerCallback& done) {
94 h->prod_cb = done;
107 done(providebuf_status);
112 const ConsumerCallback& done) {
131 existing_hook->cons_cb = done;
136 h->cons_cb = done;
145 done(consumebuf_status, nullptr);
|
| collective_param_resolver_local.h | 49 const StatusCallback& done) override;
54 const StatusCallback& done) override;
59 const StatusCallback& done) override;
80 // calling done. Callback GroupRec* arg is only valid if status is ok.
86 const GroupRecCallback& done)
95 // initialization can be done without holding the instance_mu_
131 // needs to be done at a higher level.
164 const InstanceRecCallback& done)
173 InstanceRec* ir, const StatusCallback& done)
178 const InstanceRecCallback& done)
[all...] |
| /external/curl/lib/ |
| asyn-thread.c | 161 int done; member in struct:thread_sync_data
216 /* Treat the request as done until the thread actually starts so any early
217 * cleanup gets done properly.
219 tsd->done = 1;
294 if(tsd->done) {
301 tsd->done = 1;
327 if(tsd->done) {
334 tsd->done = 1;
350 int done; local
357 done = td->tsd.done
546 int done = 0; local
[all...] |
| /external/ltp/testcases/kernel/sched/cfs-scheduler/ |
| hackbench.c | 140 int ret, done = 0; local
144 write(ctx->out_fds[j], data + done,
145 sizeof(data) - done);
148 done += ret;
149 if (done < sizeof(data))
171 int ret, done = 0; local
174 ret = read(ctx->in_fds[0], data + done, DATASIZE - done);
177 done += ret;
178 if (done < DATASIZE
[all...] |
| /external/syzkaller/pkg/osutil/ |
| fileutil_test.go | 40 done := make(chan error)
47 done <- fmt.Errorf("failed to create temp dir: %v", err)
55 done <- fmt.Errorf("duplicate dir %v", dir)
58 done <- nil
62 if err := <-done; err != nil {
|
| /art/tools/dexfuzz/src/dexfuzz/rawdex/ |
| DexRandomAccessFile.java | 102 boolean done = false;
103 while (!done) {
108 // Check the 8th bit - if it's 0, we're done.
111 done = true;
182 boolean done = false;
184 while (!done) {
189 // Check the 8th bit - if it's 0, we're done.
196 done = true;
235 // When it's all 1s (0xffffffff), we're done!
|
| /build/make/core/ |
| local_vndk.mk | 19 $(error done)
25 $(error done)
30 $(error done)
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| rx-all.hpp | 65 mutable bool done; member in struct:rxcpp::operators::detail::all::all_observer
70 done(false)
80 if (filtered.get() && !done) {
81 done = true;
90 if(!done) {
91 done = true;
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| tcp_client_custom.cc | 64 int done; local
78 done = (--connect->refs == 0);
79 if (done) {
88 int done; local
95 done = (--connect->refs == 0);
96 if (done) {
|
| /external/grpc-grpc/src/objective-c/RxLibrary/ |
| GRXWriteable.m | 32 __block GRXEventHandler eventHandler = ^(BOOL done, id value, NSError *error) {
62 return [self writeableWithEventHandler:^(BOOL done, id value, NSError *error) {
64 eventHandler(done, value, error);
|
