| 140 | } |
| 141 | |
| 142 | Optional<UID> StorageWiggler::getNextServerId(bool necessaryOnly) { |
| 143 | if (!wiggle_pq.empty()) { |
| 144 | auto [metadata, id] = wiggle_pq.top(); |
| 145 | if (necessaryOnly && !necessary(id, metadata)) { |
| 146 | return {}; |
| 147 | } |
| 148 | wiggle_pq.pop(); |
| 149 | pq_handles.erase(id); |
| 150 | return Optional<UID>(id); |
| 151 | } |
| 152 | return Optional<UID>(); |
| 153 | } |
| 154 | |
| 155 | Future<Void> StorageWiggler::resetStats() { |
| 156 | auto newMetrics = StorageWiggleMetrics(); |
no test coverage detected