| /external/boringssl/src/crypto/poly1305/ |
| poly1305_test.cc | 35 size_t done = 0; local
44 done += todo;
48 if (done + 128 + excess > in.size()) {
51 CRYPTO_poly1305_update(&state, in.data() + done, 128 + excess);
52 done += 128 + excess;
55 if (done + excess > in.size()) {
58 CRYPTO_poly1305_update(&state, in.data() + done, excess);
59 done += excess;
63 CRYPTO_poly1305_update(&state, in.data() + done, in.size() - done);
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_remote_worker.cc | 75 StatusCallback done) override {
76 IssueRequest(request, response, getstatus_, std::move(done));
81 StatusCallback done) override {
82 IssueRequest(request, response, createworkersession_, std::move(done));
88 StatusCallback done) override {
89 IssueRequest(request, response, deleteworkersession_, std::move(done),
95 StatusCallback done) override {
96 IssueRequest(request, response, registergraph_, std::move(done));
101 StatusCallback done) override {
102 IssueRequest(request, response, deregistergraph_, std::move(done));
[all...] |
| grpc_worker_service.h | 46 StatusCallback done);
49 LoggingResponse* response, StatusCallback done);
52 RecvBufResponse* response, StatusCallback done);
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| to_tf_record_op.cc | 46 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
49 background_worker_.Schedule([this, ctx, done]() {
52 ctx, ParseScalarArgument<string>(ctx, "filename", &filename), done);
57 done);
60 done);
68 ctx, GetDatasetFromVariantTensor(ctx->input(0), &dataset), done);
79 done);
87 done);
91 ctx, writer->WriteRecord(components[0].scalar<string>()()), done);
95 done();
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| rpc_op.cc | 61 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
68 errors::InvalidArgument("address must be a scalar or vector."), done);
71 errors::InvalidArgument("method must be a scalar or vector."), done);
74 errors::InvalidArgument("request must be a scalar or vector."), done);
86 done);
93 ctx, ctx->allocate_output(0, output_shape, &response_t), done);
101 ctx, ctx->allocate_output(1, output_shape, &status_code_t), done);
103 ctx, ctx->allocate_output(2, output_shape, &status_message_t), done);
108 done();
116 std::move(done));
[all...] |
| collective_ops.cc | 39 const DoneCallback& done) {
45 c->env()->SchedClosure([this, c, done, col_exec]() {
52 [this, c, done](const Status& s) {
55 ComputeAsync(c, done);
58 done();
87 void ComputeAsync(OpKernelContext* c, DoneCallback done) override {
94 done);
96 // done immediately, while we're still in the executor thread. Otherwise
103 c, c->allocate_output(0, col_params_.instance.shape, &output), done);
105 if (!CanProceedWithCompute(c, col_exec, done)) return
[all...] |
| /external/iproute2/tc/ |
| p_ip6.c | 46 goto done;
52 goto done;
58 goto done;
64 goto done;
70 goto done;
76 goto done;
81 done:
|
| p_icmp.c | 42 goto done;
47 goto done;
51 done:
|
| p_udp.c | 46 goto done;
53 goto done;
58 done:
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| collective_rma_local.h | 45 const StatusCallback& done) override;
53 const StatusCallback& done) override;
57 const StatusCallback& done) override {
58 dev_resolver_->GetDeviceLocalitiesAsync(ci_params, localities, done);
63 const StatusCallback& done) override {
64 dev_resolver_->GetLocalityAsync(device, task, locality, done);
82 const StatusCallback& done);
|
| hierarchical_tree_broadcaster.h | 53 void Run(StatusCallback done) override;
69 // in `subdiv`. Calls `done` upon completion.
71 const Tensor* src_tensor, const StatusCallback& done);
74 // device from device at `src_rank` in `subdiv`. Calls `done` upon
77 const StatusCallback& done);
|
| rendezvous_mgr.cc | 65 StatusCallback done) {
74 done(Status::OK());
82 done(errors::InvalidArgument("Non-DMA-safe ", DataTypeString(in.dtype()),
90 done(s);
96 done(s);
113 0 /*dev_to_dev_stream_index*/, std::move(done));
118 DoneCallback done) {
125 [this, parsed](DoneCallback done,
137 [send_args, recv_args, out, is_dead](DoneCallback done,
140 done(s, send_args, recv_args, *out, is_dead)
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| partial_run_mgr.cc | 46 StatusCallback done; local
58 done = std::move(run_it->second->final_callback);
65 if (done != nullptr) {
66 done(callback_status);
72 void PartialRunMgr::PartialRunDone(int step_id, StatusCallback done,
84 // when the executor is completely done.
85 run_it->second->final_callback = std::move(done);
91 done(callback_status);
|
| /external/vboot_reference/futility/ |
| cmd_create.c | 92 goto done;
100 goto done;
106 goto done;
116 goto done;
125 goto done;
133 goto done;
138 goto done;
145 goto done;
151 done:
175 goto done;
[all...] |
| /external/unicode/ |
| CVTUTF7.C | 91 int shifted = 0, needshift = 0, done = 0; local
108 if (!(done = (source >= sourceEnd)))
110 needshift = (!done && ((r > 0x7f) || mustshift[r]));
154 if (verbose || ((!done) && (invbase64[r] >=0 || r == SHIFT_OUT)))
164 if (!needshift && !done)
171 while (!done);
184 int shifted = 0, first = 0, wroteone = 0, base64EOF, base64value, done; local
196 if (!(done = (source >= sourceEnd)))
200 /* We're done with a base64 string if we hit EOF, it's not a valid
203 base64EOF = done || (c > 0x7f) || (base64value = invbase64[c]) < 0
[all...] |
| /external/boringssl/src/tool/ |
| rand.cc | 67 size_t done = 0; local
68 while (forever || done < len) {
70 if (!forever && todo > len - done) {
71 todo = len - done;
88 done += todo;
|
| /external/libunwind/src/unwind/ |
| RaiseException.c | 49 goto done;
60 goto done;
66 goto done;
83 goto done;
110 done:
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| gpu_util.h | 41 StatusCallback done);
50 StatusCallback done);
91 StatusCallback done);
97 int dev_to_dev_stream_index, StatusCallback done);
107 StatusCallback done);
|
| /external/wpa_supplicant_8/src/utils/ |
| browser-system.c | 35 int done = 0; local
42 done = 1;
45 done = 1;
51 if (done)
56 if (done) {
|
| /art/test/1908-suspend-native-resume-self/ |
| native_suspend_resume.cc | 33 std::atomic<bool> done(false);
41 while (!done.load()) {
63 done.store(true);
|
| /external/compiler-rt/test/tsan/ |
| cond_race.cc | 11 bool done; member in struct:Ctx
17 c->done = true;
32 while (!c->done)
|
| /external/libcxx/test/std/experimental/language.support/support.coroutines/coroutine.handle/coroutine.handle.noop/ |
| noop_coroutine.pass.cpp | 35 // constexpr bool done() const noexcept;
56 assert(!h.done());
57 assert(!base.done());
62 static_assert(h.done() == false, "");
|
| /external/robolectric-shadows/utils/src/main/java/org/robolectric/util/ |
| SimpleFuture.java | 31 done(); method
60 done(); method
69 protected void done() { method in class:SimpleFuture
|
| /external/sl4a/ScriptingLayerForAndroid/src/com/googlecode/android_scripting/dialog/ |
| DurationPickerDialog.java | 39 final DurationPickedListener done) {
48 done.onSet(picker.getDuration());
54 done.onCancel();
|
| /external/u-boot/cmd/ |
| dfu.c | 46 goto done;
51 goto done;
58 done:
|
