| 45 | explicit MPIUtils(const std::string& worker_name); |
| 46 | |
| 47 | const int GetSourceID(const std::string& task_id) const { |
| 48 | auto it = name_to_id_.find(task_id); |
| 49 | if (it == name_to_id_.end()) { |
| 50 | LOG(FATAL) << "Failed to convert worker name to MPI index: " << task_id; |
| 51 | } |
| 52 | return it->second; |
| 53 | } |
| 54 | |
| 55 | private: |
| 56 | void InitMPI(); |
no test coverage detected