Searched refs:instances_ (Results 1 – 8 of 8) sorted by relevance
115 for (auto i : instances_) delete i; in ~PermuterTest()221 instances_.push_back(new DeviceInstance( in Init()232 for (auto di : instances_) { in Permute()242 while (done < instances_.size()) { in Permute()254 for (int di = 0; di < instances_.size(); ++di) { in RunTest()255 DeviceInstance* instance = instances_[di]; in RunTest()272 for (int di = 0; di < instances_.size(); ++di) { in RunTest()273 if (!instances_[di]->status_.ok()) { in RunTest()276 instances_[di]->status_.error_message().find("Deliberate failure"), in RunTest()280 TF_EXPECT_OK(instances_[di]->status_); in RunTest()[all …]
134 for (auto i : instances_) delete i; in ~RingGathererTest()248 instances_.push_back(new DeviceInstance( in Init()256 for (auto di : instances_) { in Gather()266 while (done < static_cast<int>(instances_.size())) { in Gather()279 for (int di = 0; di < static_cast<int>(instances_.size()); ++di) { in RunTest()280 DeviceInstance* instance = instances_[di]; in RunTest()301 for (int di = 0; di < static_cast<int>(instances_.size()); ++di) { in RunTest()303 instances_[di]->status_.error_message().find("Deliberate failure"), in RunTest()309 for (int di = 0; di < static_cast<int>(instances_.size()); ++di) { in RunTest()310 TF_EXPECT_OK(instances_[di]->status_); in RunTest()[all …]
205 for (auto i : instances_) delete i; in ~HierarchicalTreeBroadcasterTest()348 instances_.push_back(new DeviceInstance( in Init()358 VLOG(2) << "#instances=" << instances_.size(); in Broadcast()360 for (auto di : instances_) { in Broadcast()366 while (done < instances_.size()) { in Broadcast()427 for (int di = 0; di < instances_.size(); ++di) { in RunTest()428 DeviceInstance* instance = instances_[di]; in RunTest()442 const CollectiveParams& cp = *instances_[0]->col_params_; in RunTest()446 const Tensor* t = &instances_[broadcast_dev_id]->tensor_; in RunTest()450 Device* dev = instances_[broadcast_dev_id]->device_; in RunTest()[all …]
157 for (auto i : instances_) delete i; in ~RingReducerTest()272 instances_.push_back(new DeviceInstance( in Init()280 for (auto di : instances_) { in Reduce()290 while (done < static_cast<int>(instances_.size())) { in Reduce()302 for (int di = 0; di < static_cast<int>(instances_.size()); ++di) { in RunTest()303 DeviceInstance* instance = instances_[di]; in RunTest()321 for (int di = 0; di < static_cast<int>(instances_.size()); ++di) { in RunTest()323 instances_[di]->status_.error_message().find("Deliberate failure"), in RunTest()331 for (int di = 0; di < static_cast<int>(instances_.size()); ++di) { in RunTest()332 TF_EXPECT_OK(instances_[di]->status_); in RunTest()[all …]
43 EventCollector::instances_; member in tensorflow::tracing::EventCollector47 EventCollector::instances_[static_cast<unsigned>(category)] = collector; in SetEventCollector()
61 static std::array<const EventCollector*, GetNumEventCategories()> instances_; variable71 return EventCollector::instances_[static_cast<unsigned>(category)]; in GetEventCollector()
148 instances_.push_back(absl::make_unique<DeviceInstance>( in Init()170 for (const auto& instance : instances_) { in RunCollective()182 while (done < instances_.size()) done_cv.wait(l); in RunCollective()202 DeviceInstance* instance = instances_[rank].get(); in RunTest()208 for (int rank = 0; rank < instances_.size(); ++rank) { in RunTest()209 TF_ASSERT_OK(instances_[rank]->status_); in RunTest()210 Tensor* output = &instances_[rank]->output_; in RunTest()215 Device* dev = instances_[rank]->device_; in RunTest()440 std::vector<std::unique_ptr<DeviceInstance>> instances_; member in tensorflow::NcclTestBase
86 ++instances_; in Create()101 int32_t instances() const { return instances_; } in instances()109 int32_t instances_ = 0; member in openscreen::osp::FakeMdnsResponderAdapterFactory