Home
last modified time | relevance | path

Searched refs:is_dead (Results 1 – 25 of 56) sorted by relevance

123

/external/tensorflow/tensorflow/core/framework/
Drendezvous_test.cc123 bool is_dead = false; in TEST_F() local
124 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
135 bool is_dead = false; in TEST_F() local
137 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
144 bool is_dead = false; in TEST_F() local
146 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &t, &is_dead)); in TEST_F()
147 TF_ASSERT_OK(rendez_->Send(KeyBar(), args, t, is_dead)); in TEST_F()
161 bool is_dead = false; in TEST_F() local
165 auto s = rendez_->Recv(KeyFoo(), args, &val, &is_dead); in TEST_F()
181 bool is_dead = false; in TEST_F() local
[all …]
Drendezvous.cc120 Tensor* val, bool* is_dead, int64 timeout_ms) { in Recv() argument
124 [&ret, &n, val, is_dead](const Status& s, const Args& send_args, in Recv()
129 *is_dead = dead; in Recv()
146 Tensor* val, bool* is_dead) { in Recv() argument
148 return Recv(key, args, val, is_dead, no_timeout); in Recv()
157 const bool is_dead) override { in Send() argument
158 return impl_.Send(key, send_args, val, is_dead); in Send()
Dlocal_rendezvous.cc36 Item(Rendezvous::Args send_args, const Tensor& value, bool is_dead) in Item()
39 send_state.is_dead = is_dead; in Item()
71 bool is_dead; member
111 const Tensor& val, const bool is_dead) { in Send() argument
115 if (is_dead) { in Send()
141 queue->push_back(new Item(send_args, val, is_dead)); in Send()
162 (*item->recv_state.waiter)(Status::OK(), send_args, item->args, val, is_dead); in Send()
310 item->send_state.is_dead); in RecvAsync()
Drendezvous.h92 const bool is_dead) = 0;
109 bool* is_dead, int64 timeout_ms);
111 bool* is_dead);
/external/tensorflow/tensorflow/core/common_runtime/
Dpropagator_state.cc82 const bool is_dead = tagged_node.is_dead; in PropagateOutputs() local
97 item, is_dead, output_iter, outputs, ready); in PropagateOutputs()
108 item, is_dead, output_iter, outputs, ready); in PropagateOutputs()
115 if (is_dead) { in PropagateOutputs()
129 item, is_dead, output_iter, outputs, ready); in PropagateOutputs()
137 if (is_dead) { in PropagateOutputs()
160 item, is_dead, output_iter, outputs, ready); in PropagateOutputs()
388 const NodeItem* item, const bool is_dead, IterationState* iter_state, in ActivateNodesFastPathInternal() argument
408 t.is_dead = adjust_result.any_dead; \ in ActivateNodesFastPathInternal()
421 (is_dead || ((*outputs)[src_slot].state == Entry::State::NO_VALUE)); in ActivateNodesFastPathInternal()
[all …]
Dpropagator_state.h66 bool is_dead; member
74 is_dead(dead) {} in TaggedNode()
78 bool get_is_dead() const { return is_dead; } in get_is_dead()
359 const bool is_dead,
365 int ActivateNodesLocked(const NodeItem* item, const bool is_dead,
395 int ActivateNodesFastPathLocked(const NodeItem* item, const bool is_dead, in ActivateNodesFastPathLocked()
399 return ActivateNodesFastPathInternal<false>(item, is_dead, iter_state, in ActivateNodesFastPathLocked()
405 int ActivateNodesFastPathShared(const NodeItem* item, const bool is_dead, in ActivateNodesFastPathShared()
409 return ActivateNodesFastPathInternal<true>(item, is_dead, iter_state, in ActivateNodesFastPathShared()
414 int ActivateNodesFastPathInternal(const NodeItem* item, const bool is_dead,
[all …]
Drendezvous_mgr.cc129 bool is_dead) mutable { in IntraProcessRecvAsyncImpl() argument
135 auto final_callback = [send_args, recv_args, out, is_dead, in IntraProcessRecvAsyncImpl()
137 done(s, send_args, recv_args, *out, is_dead); in IntraProcessRecvAsyncImpl()
161 const bool is_dead) { in Send() argument
163 return local_.Send(key, args, val, is_dead); in Send()
186 const bool is_dead) { in Send() argument
188 return local_.Send(key, args, val, is_dead); in Send()
Dexecutor_test.cc172 bool is_dead = false; in TEST_F() local
174 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "c"), args, &out, &is_dead)); in TEST_F()
202 bool is_dead = false; in TEST_F() local
204 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
252 bool is_dead = false; in TEST_F() local
254 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
285 bool is_dead; in TEST_F() local
287 &is_dead)); in TEST_F()
307 bool is_dead = false; in TEST_F() local
309 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "c"), args, &out, &is_dead)); in TEST_F()
[all …]
Drendezvous_util.cc105 const Tensor& v, const bool is_dead) { in RecvOutputsFromRendezvousAsync() argument
109 if (is_dead) { in RecvOutputsFromRendezvousAsync()
129 bool is_dead = false; in RecvOutputsFromRendezvous() local
131 TF_RETURN_IF_ERROR(rendezvous->Recv(parsed, args, val, &is_dead)); in RecvOutputsFromRendezvous()
132 if (is_dead) { in RecvOutputsFromRendezvous()
Dkernel_benchmark_testlib.cc170 bool is_dead; in RunWithRendezvousArgs() local
189 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
207 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
222 bool is_dead; in RunWithRendezvousArgs() local
241 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
258 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
Dgraph_runner.cc55 const bool is_dead) override { in Send() argument
56 if (is_dead) { in Send()
198 bool is_dead; in Run() local
201 rendez.Recv(parsed, Rendezvous::Args(), &output_tensor, &is_dead)); in Run()
Drendezvous_mgr.h49 const Tensor& val, const bool is_dead) override;
78 const Tensor& val, const bool is_dead) override;
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_response_cache.h44 const Tensor& tensor, bool is_dead, const Status& status)>;
58 void OnRequestFinished(int64 request_id, const Tensor& tensor, bool is_dead,
78 bool is_dead = false; member
82 cb(tensor, is_dead, response_status); in FinishResponse()
Dgrpc_tensor_coding_test.cc31 void Validate(const Tensor& t, bool is_dead) { in Validate() argument
34 grpc::EncodeTensorToByteBuffer(is_dead, t, false, &buf); in Validate()
46 EXPECT_EQ(response.is_dead(), is_dead); in Validate()
Dgrpc_response_cache.cc60 const Tensor& tensor, bool is_dead, in OnRequestFinished() argument
80 entry.is_dead = is_dead; in OnRequestFinished()
Dgrpc_worker_service.cc451 bool is_dead, in GrpcRecvTensorAsync()
454 grpc::EncodeTensorToByteBuffer(is_dead, tensor, cache_enabled, response); in GrpcRecvTensorAsync()
469 const Tensor& tensor, bool is_dead, in GrpcRecvTensorAsync() argument
473 response_cache_->OnRequestFinished(request_id, tensor, is_dead, status); in GrpcRecvTensorAsync()
475 do_response(tensor, is_dead, status); in GrpcRecvTensorAsync()
516 const bool is_dead) { in GrpcRecvTensorAsync() argument
541 is_dead](const Status& s) { in GrpcRecvTensorAsync()
543 rendezvous_done(*copy, is_dead, s); in GrpcRecvTensorAsync()
554 rendezvous_done(val, is_dead, status); in GrpcRecvTensorAsync()
593 const Tensor& tensor, bool is_dead, in RecvBufAsync()
Dgrpc_tensor_coding.cc140 void EncodeTensorToByteBuffer(bool is_dead, const Tensor& val, bool require_ack, in EncodeTensorToByteBuffer() argument
153 if (is_dead) { in EncodeTensorToByteBuffer()
154 response.set_is_dead(is_dead); in EncodeTensorToByteBuffer()
Drpc_rendezvous_mgr.cc128 bool is_dead() const { return resp_.metadata().is_dead(); } in is_dead() function in tensorflow::__anona9090a8f0111::RpcRecvTensorCall
302 call->done()(s, Args(), call->recv_args(), call->tensor(), call->is_dead()); in RecvFromRemoteAsync()
/external/llvm-project/compiler-rt/lib/tsan/rtl/
Dtsan_interceptors_mac.cpp187 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
197 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
209 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
219 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
229 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
241 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
251 if (!cur_thread()->is_inited || cur_thread()->is_dead) { in TSAN_INTERCEPTOR()
261 if (!cur_thread()->is_inited || cur_thread()->is_dead) { in TSAN_INTERCEPTOR()
270 if (!cur_thread()->is_inited || cur_thread()->is_dead) { in TSAN_INTERCEPTOR()
281 if (!cur_thread()->is_inited || cur_thread()->is_dead) { in TSAN_INTERCEPTOR()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dbase_rendezvous_mgr.cc87 Tensor* val, bool* is_dead) { in RecvLocal() argument
91 [val, is_dead, &ret, &n](const Status& s, in RecvLocal()
97 *is_dead = dead; in RecvLocal()
175 const Tensor& val, const bool is_dead) { in Send() argument
192 return local_->Send(parsed, args, val, is_dead); in Send()
320 const Rendezvous::Args& recv_args, const Tensor& in, bool is_dead) { in RecvAsync() argument
325 is_dead](const Status& s) { in RecvAsync()
326 done(s, send_args, recv_args, *out, is_dead); in RecvAsync()
Dtensor_coding_test.cc77 void Validate(const Tensor& src, bool is_dead, bool use_tensor_content) { in Validate() argument
79 proto.set_is_dead(is_dead); in Validate()
99 EXPECT_EQ(meta.is_dead(), is_dead); in Validate()
Dbase_rendezvous_mgr.h83 Tensor* val, bool* is_dead) override;
126 const Tensor& val, const bool is_dead) override;
/external/compiler-rt/lib/tsan/rtl/
Dtsan_interceptors_mac.cc176 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
186 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
198 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
208 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
218 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
230 CHECK(!cur_thread()->is_dead); in TSAN_INTERCEPTOR()
/external/mesa3d/src/amd/compiler/
Daco_dead_code_analysis.cpp60 if (!is_dead(ctx.uses, instr.get())) { in process_block()
80 bool is_dead(const std::vector<uint16_t>& uses, Instruction *instr) in is_dead() function
/external/mesa3d/src/gallium/drivers/r600/sb/
Dsb_dce_cleanup.cpp153 if (v->gvn_source && v->gvn_source->is_dead()) in cleanup_dst_vec()
156 if (v->is_dead() || (remove_unused && !v->is_rel() && !v->uses.size())) in cleanup_dst_vec()

123