Searched refs:oc_queue_size_ (Results 1 – 6 of 6) sorted by relevance
41 : oc_queue_size_(op_connector_size), in DatasetOp()215 if (oc_queue_size_ > 0) { in CreateConnector()218 oc_queue_size_); in CreateConnector()247 …out << "\nConnector queue size : " << oc_queue_size_ << "\nTotal repeats : " << op_total_repeats_ in Print()
224 bool inlined() const { return (oc_queue_size_ == 0); } in inlined()376 int32_t oc_queue_size_; // Capacity for each out_connector_ variable
39 oc_queue_size_ = std::max(1, op_connector_size * worker_limit / num_workers_); in ParallelOp()
43 filter_queues_.Init(num_workers_, oc_queue_size_); in LaunchThreadsAndInitOp()
116 image_infos.reserve(oc_queue_size_); in ParseAttrFile()122 if (image_info.size() % oc_queue_size_ == 0) { in ParseAttrFile()
120 local_queues_.Init(num_workers_, oc_queue_size_); in operator ()()