if (failure != null) {
LOG.debug("Resolution of cookie {} shard {} failed, removing state", cookie, shardName, failure);
backends.remove(cookie, toInsert);
+
+ // Remove cache state in case someone else forgot to invalidate it
+ flushCache(shardName);
}
});
LOG.debug("Invalidating backend information {}", staleInfo);
flushCache(staleInfo.getShardName());
- LOG.trace("Invalidated cache %s", staleInfo);
+ LOG.trace("Invalidated cache {}", staleInfo);
backends.remove(cookie, existing);
}