| 204 | } |
| 205 | |
| 206 | void DatabaseContext::removeTssMapping(StorageServerInterface const& ssi) { |
| 207 | auto result = tssMapping.find(ssi.id()); |
| 208 | if (result != tssMapping.end()) { |
| 209 | tssMetrics.erase(ssi.id()); |
| 210 | tssMapping.erase(result); |
| 211 | queueModel.removeTssEndpoint(ssi.getValue.getEndpoint().token.first()); |
| 212 | queueModel.removeTssEndpoint(ssi.getKey.getEndpoint().token.first()); |
| 213 | queueModel.removeTssEndpoint(ssi.getKeyValues.getEndpoint().token.first()); |
| 214 | queueModel.removeTssEndpoint(ssi.getMappedKeyValues.getEndpoint().token.first()); |
| 215 | queueModel.removeTssEndpoint(ssi.getKeyValuesStream.getEndpoint().token.first()); |
| 216 | |
| 217 | queueModel.removeTssEndpoint(ssi.watchValue.getEndpoint().token.first()); |
| 218 | queueModel.removeTssEndpoint(ssi.splitMetrics.getEndpoint().token.first()); |
| 219 | queueModel.removeTssEndpoint(ssi.getReadHotRanges.getEndpoint().token.first()); |
| 220 | queueModel.removeTssEndpoint(ssi.getRangeSplitPoints.getEndpoint().token.first()); |
| 221 | } |
| 222 | } |
| 223 | |
| 224 | void DatabaseContext::addSSIdTagMapping(const UID& uid, const Tag& tag) { |
| 225 | ssidTagMapping[uid] = tag; |
no test coverage detected