| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | collective_param_resolver_local_test.cc | 179 cp->is_source = false; in TEST_F()
204 EXPECT_FALSE(cps[i]->is_source); in TEST_F()
212 bool is_source, in InitializeCollectiveParamsForBroadcast() argument
223 cp->is_source = is_source; in InitializeCollectiveParamsForBroadcast()
258 EXPECT_EQ(cps[i]->is_source, (i == 1)); in TEST_F()
304 bool is_source) { in MakeCollectiveParams() argument
314 cp->is_source = is_source; in MakeCollectiveParams()
|
| D | collective_param_resolver_local.h | 150 CollectiveParams* cp, bool is_source,
159 InstanceRec* ir, bool is_source,
165 void WaitForGroup(InstanceRec* ir, CollectiveParams* cp, bool is_source,
|
| D | collective_param_resolver_local.cc | 648 CompleteInstanceLocal(device.name(), gr, cp, cp->is_source, done); in CompleteParamsAsync()
687 bool is_source, const StatusCallback& done) { in CompleteInstanceLocal() argument
716 CompleteInstanceFromInitializedIRec(device, gr, cp, ir, is_source, done); in CompleteInstanceLocal()
721 InstanceRec* ir, bool is_source, const StatusCallback& done) { in CompleteInstanceFromInitializedIRec() argument
763 WaitForGroup(ir, cp, is_source, in CompleteInstanceFromInitializedIRec()
786 bool is_source, in WaitForGroup() argument
799 if (is_source) { in WaitForGroup()
|
| D | hierarchical_tree_broadcaster_test.cc | 68 cp->is_source = (S == R); \
604 col_params_->is_source = in DeviceInstance()
652 if (col_params_->is_source) { in DoBroadcast()
658 col_params_->is_source in DoBroadcast()
667 if (col_params_->is_source) { in DoBroadcast()
676 col_params_->is_source ? &tensor_ : nullptr; in DoBroadcast()
|
| D | graph_view.h | 71 bool is_source : 1; // True iff IsSource(node) member
|
| D | hierarchical_tree_broadcaster.cc | 201 is_source_ = col_params_->is_source; in Run()
262 if (cp.is_source && source_rank != 0) { in TreeSendTo()
|
| D | immutable_executor_state.cc | 190 item->is_source = IsSource(n); in Initialize()
|
| D | graph_view.cc | 40 if (is_source) { in DebugString()
|
| D | base_collective_executor.cc | 304 col_params->is_source)) in ExecuteAsync()
|
| D | ring_gatherer_test.cc | 553 cp->is_source = false; in SetUpCollectiveParams()
|
| D | ring_reducer_test.cc | 585 cp->is_source = false; in SetUpCollectiveParams()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_param_resolver_distributed.cc | 61 bool is_source, CancellationManager* cancel_mgr, in CompleteInstanceCall() argument
76 req_.set_is_source(is_source); in CompleteInstanceCall()
383 return CompleteInstanceLocal(device, gr, cp, cp->is_source, done); in CompleteInstanceDistributed()
385 return CompleteInstanceLocal(device, gr, cp, cp->is_source, done); in CompleteInstanceDistributed()
388 cp->group, cp->instance, cp->name, device, cp->is_source, cancel_mgr, in CompleteInstanceDistributed()
405 CompleteInstanceLocal(device, gr, cp, cp->is_source, done); in CompleteInstanceDistributed()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-sources.hpp | 23 class is_source class
|
| D | rx-observable.hpp | 78 …typename std::conditional<rxs::is_source<SOF>::value || rxo::is_operator<SOF>::value, rxs::tag_sou… in dynamic_observable()
536 …static_assert(rxo::is_operator<source_operator_type>::value || rxs::is_source<source_operator_type…
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | collective_ops.cc | 340 col_params_->is_source = true; in CollectiveBcastSendOpKernel()
344 strings::StrCat(name(), ": Broadcast(", col_params_->is_source, ")"); in CollectiveBcastSendOpKernel()
417 col_params_->is_source = false; in CollectiveBcastRecvOpKernel()
421 strings::StrCat(name(), ": Broadcast(", col_params_->is_source, ")"); in CollectiveBcastRecvOpKernel()
758 const bool is_source = true; in CollectiveBcastSendV2OpKernel() local
759 name_ = strings::StrCat(name(), ": Broadcast(", is_source, ")"); in CollectiveBcastSendV2OpKernel()
795 col_params->is_source = true; in ComputeAsync()
884 const bool is_source = false; in CollectiveBcastRecvV2OpKernel() local
885 name_ = strings::StrCat(name(), ": Broadcast(", is_source, ")"); in CollectiveBcastRecvV2OpKernel()
929 col_params->is_source = false; in ComputeAsync()
|
| D | collective_nccl_test.cc | 365 /*input=*/col_params_->is_source ? &input_ : nullptr, in RunBroadcast()
505 di->col_params_->is_source = di->col_params_->default_rank == source_rank_; in InitDevice()
|
| /external/tensorflow/third_party/systemlibs/ |
| D | grpc.bazel.generate_cc.bzl | 23 if not file.is_source and file.path.startswith(file.root.path):
34 if not file.is_source and file.path.startswith(file.root.path):
|
| D | grpc.bazel.protobuf.bzl | 83 if not source_file.is_source and directory.startswith(source_file.root.path):
244 return not source_file.is_source and virtual_folder in source_file.path
|
| /external/rust/crates/grpcio-sys/grpc/bazel/ |
| D | generate_cc.bzl | 24 if not file.is_source and file.path.startswith(file.root.path):
35 if not file.is_source and file.path.startswith(file.root.path):
|
| D | protobuf.bzl | 84 if not source_file.is_source and directory.startswith(source_file.root.path):
253 return not source_file.is_source and virtual_folder in source_file.path
|
| D | generate_objc.bzl | 130 if not file.is_source:
|
| /external/tensorflow/tensorflow/core/nccl/ |
| D | collective_communicator.cc | 153 if (col_params->is_source) { in Enqueue()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | collective.cc | 155 " is_source=", is_source, " source_rank=", source_rank, in ToString()
|
| D | collective.h | 142 bool is_source = false; // broadcast only member
|
| /external/deqp/external/openglcts/modules/common/ |
| D | glcRobustBufferAccessBehaviorTests.hpp | 425 void prepareTexture(const glw::Functions& gl, bool is_source, glw::GLuint texture_id);
|