Home
last modified time | relevance | path

Searched refs:WorkerEntry (Results 1 – 25 of 41) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Dcache_lookup_op.cc37 …tree_->LaunchWorkers(num_workers_, std::bind(&CacheLookupOp::WorkerEntry, this, std::placeholders:… in operator ()()
45 Status CacheLookupOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::CacheLookupOp
Dcache_op.cc51 …tree_->LaunchWorkers(num_workers_, std::bind(&CacheOp::WorkerEntry, this, std::placeholders::_1), … in operator ()()
163 Status CacheOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::CacheOp
Dcache_op.h67 Status WorkerEntry(int32_t worker_id) override;
Dcache_lookup_op.h42 Status WorkerEntry(int32_t worker_id) override;
Dparallel_op.h97 virtual Status WorkerEntry(int32_t workerId) = 0;
Dfilter_op.cc48 …tree_->LaunchWorkers(num_workers_, std::bind(&FilterOp::WorkerEntry, this, std::placeholders::_1),… in LaunchThreadsAndInitOp()
119 Status FilterOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::FilterOp
Dfilter_op.h93 Status WorkerEntry(int32_t worker_id) override; // In: workerId assigned by tree_
Dbuild_vocab_op.cc47 Status BuildVocabOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::BuildVocabOp
88 …tree_->LaunchWorkers(num_workers_, std::bind(&BuildVocabOp::WorkerEntry, this, std::placeholders::… in operator ()()
Dbuild_vocab_op.h58 Status WorkerEntry(int32_t worker_id) override;
Dcache_merge_op.cc57 …num_workers_, std::bind(&CacheMergeOp::WorkerEntry, this, std::placeholders::_1), Name() + "::Work… in operator ()()
72 Status CacheMergeOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::CacheMergeOp
Dcache_merge_op.h98 Status WorkerEntry(int32_t workerId) override;
Ddevice_queue_op.h150 Status WorkerEntry(int32_t worker_id);
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_grpc_client.cc106 Status CacheClientGreeter::WorkerEntry() { in WorkerEntry() function in mindspore::dataset::CacheClientGreeter
152 auto f = std::bind(&CacheClientGreeter::WorkerEntry, this); in DispatchWorkers()
Dcache_grpc_client.h77 Status WorkerEntry();
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/
Dmappable_leaf_op.h83 Status WorkerEntry(int32_t workerId) override;
Dnonmappable_leaf_op.cc62 … num_workers_, std::bind(&NonMappableLeafOp::WorkerEntry, this, std::placeholders::_1), "", id())); in operator ()()
131 Status NonMappableLeafOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::NonMappableLeafOp
Drandom_data_op.h115 Status WorkerEntry(int32_t worker_id) override;
Drandom_data_op.cc161 …tree_->LaunchWorkers(num_workers_, std::bind(&RandomDataOp::WorkerEntry, this, std::placeholders::… in operator ()()
229 Status RandomDataOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::RandomDataOp
Dnonmappable_leaf_op.h87 Status WorkerEntry(int32_t worker_id) override;
Dmappable_leaf_op.cc91 Status MappableLeafOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::MappableLeafOp
Dmindrecord_op.h91 Status WorkerEntry(int32_t worker_id) override;
Dmindrecord_op.cc146 Status MindRecordOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::MindRecordOp
311 …tree_->LaunchWorkers(num_workers_, std::bind(&MindRecordOp::WorkerEntry, this, std::placeholders::… in LaunchThreadsAndInitOp()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/map_op/
Dmap_op.h158 Status WorkerEntry(int32_t worker_id) override; // In: workerId assigned by tree_
Dmap_op.cc132 …tree_->LaunchWorkers(num_workers_, std::bind(&MapOp::WorkerEntry, this, std::placeholders::_1), Na… in operator ()()
200 Status MapOp::WorkerEntry(int32_t worker_id) { in WorkerEntry() function in mindspore::dataset::MapOp
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/
Dgraph_loader.h77 Status WorkerEntry(int32_t worker_id);

12