Home
last modified time | relevance | path

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

123

/external/tensorflow/tensorflow/core/framework/
Drendezvous_test.cc121 bool is_dead = false; in TEST_F() local
122 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
133 bool is_dead = false; in TEST_F() local
135 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
142 bool is_dead = false; in TEST_F() local
144 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &t, &is_dead)); in TEST_F()
145 TF_ASSERT_OK(rendez_->Send(KeyBar(), args, t, is_dead)); in TEST_F()
303 const Rendezvous::Args& recv_args, const Tensor& val, bool is_dead) { in TEST_F() argument
319 bool is_dead = false; in BM_SendRecv() local
323 TF_CHECK_OK(rendez->Send(KeyFoo(), args, orig, is_dead)); in BM_SendRecv()
[all …]
Drendezvous.cc118 Tensor* val, bool* is_dead, int64 timeout_ms) { in Recv() argument
122 [&ret, &n, val, is_dead](const Status& s, const Args& send_args, in Recv()
127 *is_dead = dead; in Recv()
144 bool* is_dead) { in Recv() argument
146 return Recv(key, args, val, is_dead, no_timeout); in Recv()
154 const bool is_dead) override { in Send() argument
173 item->is_dead = is_dead; in Send()
191 item->waiter(Status::OK(), send_args, item->recv_args, val, is_dead); in Send()
234 done(Status::OK(), item->send_args, recv_args, item->value, item->is_dead); in RecvAsync()
262 bool is_dead = false; member
Drendezvous.h96 const bool is_dead) = 0;
113 bool* is_dead, int64 timeout_ms);
115 bool* is_dead);
/external/tensorflow/tensorflow/core/common_runtime/
Dexecutor_test.cc160 bool is_dead = false; in TEST_F() local
162 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "c"), args, &out, &is_dead)); in TEST_F()
190 bool is_dead = false; in TEST_F() local
192 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
240 bool is_dead = false; in TEST_F() local
242 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
273 bool is_dead; in TEST_F() local
275 &is_dead)); in TEST_F()
295 bool is_dead = false; in TEST_F() local
297 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()
128 bool is_dead = false; in RecvOutputsFromRendezvous() local
130 TF_RETURN_IF_ERROR(rendezvous->Recv(parsed, args, val, &is_dead)); in RecvOutputsFromRendezvous()
131 if (is_dead) { in RecvOutputsFromRendezvous()
Drendezvous_mgr.cc41 const Tensor& val, const bool is_dead) { in Send() argument
49 return local_->Send(parsed, args, val, is_dead); in Send()
130 bool is_dead) { in RecvAsync() argument
137 [send_args, recv_args, out, is_dead](DoneCallback done, in RecvAsync()
140 done(s, send_args, recv_args, *out, is_dead); in RecvAsync()
Dgraph_runner.cc53 const bool is_dead) override { in Send() argument
54 if (is_dead) { in Send()
197 bool is_dead; in Run() local
200 rendez->Recv(parsed, Rendezvous::Args(), &output_tensor, &is_dead)); in Run()
Dexecutor.cc1170 void ActivateNodes(const NodeItem* item, const bool is_dead, int64 iter,
1191 bool is_dead = false; member
1198 is_dead = dead; in TaggedNode()
1685 if (stats_collector_ && !tagged_node.is_dead) { in Process()
1696 << SummarizeNode(*node) << (tagged_node.is_dead ? " is dead" : "") in Process()
1710 if (tagged_node.is_dead && !IsTransferNode(node)) { in Process()
1758 << (state->tagged_node.is_dead ? " is dead" : "") in Process()
1846 << (tagged_node.is_dead ? " is dead: " : "") in Process()
2107 const bool is_dead = tagged_node.is_dead; in PropagateOutputs() local
2121 output_frame->ActivateNodes(item, is_dead, output_iter, outputs, ready); in PropagateOutputs()
[all …]
Dkernel_benchmark_testlib.cc149 bool is_dead; in RunWithArgs() local
168 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithArgs()
185 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithArgs()
/external/tensorflow/tensorflow/contrib/gdr/
Dgdr_worker.cc82 const Rendezvous::Args&, const Tensor& val, const bool is_dead) { in GrpcRecvTensorAsync() argument
92 if (val.TotalBytes() > 1024 && (!is_dead) && in GrpcRecvTensorAsync()
96 proto->set_is_dead(is_dead); in GrpcRecvTensorAsync()
129 is_dead](const Status& s) { in GrpcRecvTensorAsync()
131 grpc::EncodeTensorToByteBuffer(is_dead, *copy, response); in GrpcRecvTensorAsync()
139 grpc::EncodeTensorToByteBuffer(is_dead, val, response); in GrpcRecvTensorAsync()
Dgdr_rendezvous_mgr.cc61 if (s.ok() && tensor().TotalBytes() > 1024 && (!is_dead()) && dma_ok) { in Start()
100 bool is_dead() const { return resp_.metadata().is_dead(); } in is_dead() function in tensorflow::__anon6a33ee8b0111::GdrRecvTensorCall
191 done(s, Args(), call->recv_args(), call->tensor(), call->is_dead()); in RecvFromRemoteAsync()
/external/tensorflow/tensorflow/contrib/verbs/
Drdma.cc1007 bool is_dead) { in Start() argument
1010 RecvHandler(parsed, send_args, recv_args, in, is_dead); in Start()
1043 const Tensor& in, bool is_dead) { in RecvHandler() argument
1050 meta_data_changed_ = TensorMetaDataChanged(in, is_dead); in RecvHandler()
1080 [this, in, proto, is_dead](const Status& s) { in RecvHandler()
1081 Send(in, proto, is_dead, s); in RecvHandler()
1095 [this, copy, proto, is_dead](const Status& s) { in RecvHandler()
1096 Send(copy, proto, is_dead, s); in RecvHandler()
1100 in, src_dev_, send_args.device_context, &proto, is_dead, in RecvHandler()
1101 [this, in, proto, is_dead](const Status& s) mutable { in RecvHandler()
[all …]
Drdma.h212 bool is_dead, size_t proto_size);
259 void RecvTensorMetaData(DataType dtype, TensorShape shape, bool is_dead,
341 bool is_dead);
342 void Clone(const Tensor& in, const TensorProto& proto, bool is_dead);
343 void Send(const Tensor& in, const TensorProto& proto, bool is_dead,
345 bool TensorMetaDataChanged(const Tensor& in, bool is_dead);
348 void SendMetaData(const Tensor& in, const TensorProto& proto, bool is_dead);
349 void SendContent(const Tensor& in, const TensorProto& proto, bool is_dead);
Dpatch_notes_verbs_with_0_copies.md38 * **class RdmaTensorMetaData** - Meta-data for a tensor (type, shape, is_dead, proto_size).
52 | type | name_size | name | step_id | request_index | remote_addr | rkey | is_dead | data_type | te…
62 …* is_dead/data_type/tensor_shape/tensor_bytes - The current meta-data as stored in the receiver lo…
66 * is_dead/data_type/tensor_shape/tensor_bytes - The up-to-date meta-data.
73 …* is_dead/data_type/tensor_shape/tensor_bytes - The new meta-data. Will be removed in the next pha…
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_tensor_coding_test.cc31 void Validate(const Tensor& t, bool is_dead) { in Validate() argument
34 grpc::EncodeTensorToByteBuffer(is_dead, t, &buf); in Validate()
46 EXPECT_EQ(response.is_dead(), is_dead); in Validate()
Dgrpc_tensor_coding.cc138 void EncodeTensorToByteBuffer(bool is_dead, const Tensor& val, in EncodeTensorToByteBuffer() argument
142 if (is_dead) { in EncodeTensorToByteBuffer()
143 response.set_is_dead(is_dead); in EncodeTensorToByteBuffer()
Drpc_rendezvous_mgr.cc127 bool is_dead() const { return resp_.metadata().is_dead(); } in is_dead() function in tensorflow::__anon2b42d2c80111::RpcRecvTensorCall
282 call->done()(s, Args(), call->recv_args(), call->tensor(), call->is_dead()); in RecvFromRemoteAsync()
Dgrpc_tensor_coding.h49 void EncodeTensorToByteBuffer(bool is_dead, const Tensor& val,
/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()
189 const Tensor& val, const bool is_dead) { in Send() argument
202 return local_->Send(parsed, args, val, is_dead); in Send()
313 const Rendezvous::Args& recv_args, const Tensor& in, bool is_dead) { in RecvAsync() argument
316 is_dead](const Status& s) { in RecvAsync()
317 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;
129 const Tensor& val, const bool is_dead) override;
/external/tensorflow/tensorflow/contrib/mpi/
Dmpi_rendezvous_mgr.cc134 done(s, Args(), recv_args, val, mpi_response.response().is_dead()); in RecvFromRemoteAsync()
164 const Tensor& val, bool is_dead, in AddRequest()
201 const Rendezvous::Args& recv_args, const Tensor& val, bool is_dead) { in AddRequest() argument
214 mpi_send_call->Init(parsed, step_id, is_dead); in AddRequest()
247 is_dead, [&n, &s](const Status& s_) { in AddRequest()
259 send_cb, status, send_args, recv_args, val, is_dead, mpi_send_call); in AddRequest()
/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/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()
Dsb_liveness.cpp366 if (v->rel && v->rel->is_dead()) in update_src_vec()
369 if (src && v->is_dead()) { in update_src_vec()
392 if (n->is_dead()) in process_phi_branch()

123