Home
last modified time | relevance | path

Searched refs:send_done (Results 1 – 17 of 17) sorted by relevance

/external/tensorflow/tensorflow/compiler/xla/service/
Dhlo_module_group_metadata.cc358 TF_RET_CHECK(channel.send_done == nullptr) in RecordInstructions()
361 channel.send_done = hlo; in RecordInstructions()
436 if (channel.send_done == nullptr) { in VerifyChannelInstructions()
453 auto send_done_device = GetInstructionDevice(*channel.send_done); in VerifyChannelInstructions()
460 channel.send_done->ToString()); in VerifyChannelInstructions()
489 TF_RETURN_IF_ERROR(CheckCommunicatingInstruction(channel.send_done)); in VerifyChannelInstructions()
497 path, GetCompanionsPath(channel.send_done)) || in VerifyChannelInstructions()
527 << " send_done=" << channel.send_done->name() in DumpCollectedStats()
Ddfs_hlo_visitor_with_default.h203 Status HandleSendDone(HloInstructionPtr send_done) override { in HandleSendDone() argument
204 return DefaultAction(send_done); in HandleSendDone()
Dhlo_reachability_test.cc195 auto send_done = builder.AddInstruction(HloInstruction::CreateSendDone(send)); in TEST_F() local
206 EXPECT_FALSE(reachability->IsReachable(send_done, recv)); in TEST_F()
Dhlo_verifier.cc702 Status ShapeVerifier::HandleSendDone(HloInstruction* send_done) { in HandleSendDone() argument
703 return CheckShape(send_done, ShapeUtil::MakeTokenShape()); in HandleSendDone()
1147 const HloInstruction* send_done = instruction->users().front(); in VerifySendsAndRecvs() local
1148 TF_RET_CHECK(send_done->opcode() == HloOpcode::kSendDone); in VerifySendsAndRecvs()
1149 TF_RETURN_IF_ERROR(CheckSameChannel(instruction, send_done)); in VerifySendsAndRecvs()
1150 TF_RETURN_IF_ERROR(CheckSameIsHostTransfer(instruction, send_done)); in VerifySendsAndRecvs()
Dhlo_module_group_metadata.h109 HloInstruction* send_done = nullptr; member
Dtuple_points_to_analysis_test.cc339 auto send_done = builder.AddInstruction(HloInstruction::CreateSendDone(send)); in TEST_F() local
345 EXPECT_FALSE(points_to_analysis_->GetPointsToSet(send_done).IsAmbiguous()); in TEST_F()
346 EXPECT_TRUE(points_to_analysis_->GetPointsToSet(send_done).IsDistinct()); in TEST_F()
353 points_to_analysis_->GetPointsToSet(send_done).CreateFlattenedSet(), in TEST_F()
354 {send_done}); in TEST_F()
Dhlo_cost_analysis.h65 Status HandleSendDone(const HloInstruction* send_done) override;
Dhlo_verifier.h90 Status HandleSendDone(HloInstruction* send_done) override;
Dbuffer_liveness_test.cc337 auto send_done = builder.AddInstruction(HloInstruction::CreateSendDone(send)); in TEST_F() local
344 {param, add, token, recv, recv_done, send, send_done}); in TEST_F()
Ddfs_hlo_visitor.h252 virtual Status HandleSendDone(HloInstructionPtr send_done) = 0;
Dhlo_dataflow_analysis_test.cc1181 auto send_done = builder.AddInstruction(HloInstruction::CreateSendDone(send)); in TEST_P() local
1195 EXPECT_TRUE(analysis.ValueIsDefinedAt(send_done)); in TEST_P()
/external/blktrace/btreplay/
Dbtreplay.c107 volatile int send_wait, reap_wait, send_done, reap_done; member
267 return signal_done || tip->send_done; in is_send_done()
276 return signal_done || (tip->send_done && tip->naios_out == 0); in is_reap_done()
790 tip->send_done = tip->reap_done = 0; in tip_init()
838 assert(tip->send_done); in tip_release()
1116 assert(tip->send_done); in replay_rec()
1374 tip->send_done = 1; in replay_sub()
/external/libchrome/ipc/
Dipc_sync_channel.cc660 bool send_done = false; in WaitForReply() local
662 base::Closure on_send_done_callback = base::Bind(&OnEventReady, &send_done); in WaitForReply()
672 const bool* stop_flags[] = { &dispatch, &send_done, &should_pump_messages }; in WaitForReply()
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dir_emitter.h88 Status HandleSendDone(HloInstruction* send_done) override;
/external/perfetto/src/base/
Dunix_socket_unittest.cc542 auto send_done = tx_task_runner.CreateCheckpoint("send_done"); in TEST_F() local
546 tx_task_runner.PostTask([&cli, &buf, send_done] { in TEST_F()
549 send_done(); in TEST_F()
/external/tensorflow/tensorflow/compiler/xla/service/cpu/
Dir_emitter.h166 Status HandleSendDone(HloInstruction* send_done) override;
Dir_emitter.cc1909 Status IrEmitter::HandleSendDone(HloInstruction* send_done) { in HandleSendDone() argument