| 159 | } |
| 160 | |
| 161 | std::string ExecutorBlacklist::DebugString() const { |
| 162 | std::stringstream ss; |
| 163 | ss << "ExecutorBlacklist["; |
| 164 | for (auto entry_it : executor_list_) { |
| 165 | const Entry& entry = entry_it.second; |
| 166 | DCHECK(entry.state == BLACKLISTED || entry.state == ON_PROBATION); |
| 167 | ss << entry.be_desc.address() << " (" |
| 168 | << (entry.state == BLACKLISTED ? "blacklisted" : "on probation") << ") "; |
| 169 | } |
| 170 | ss << "]"; |
| 171 | return ss.str(); |
| 172 | } |
| 173 | |
| 174 | int64_t ExecutorBlacklist::GetBlacklistTimeoutMs() const { |
| 175 | // We add some padding to the timeout to account for possible small, random delays in |