def set(self, *args, **kwargs):
return self._connection.set(*args, **kwargs)
+
+ def delete(self, *args, **kwargs):
+ return self._connection.delete(*args, **kwargs)
def db(self):
return Databases().webapp
- def reload(self):
+ def reload(self, force=False):
memcached = Memcached()
mem_id = "mirror-%s" % self.id
+ if force:
+ memcached.delete(mem_id)
+
self._info = memcached.get(mem_id)
if not self._info:
self._info = self.db.get("SELECT * FROM mirrors WHERE id=%s", self.id)
state, self.id)
# Reload changed settings
- self.reload()
+ self.reload(force=True)
def check(self):
logging.info("Running check for mirror %s" % self.hostname)
timestamp, self.id)
# Reload changed settings
- self.reload()
+ self.reload(force=True)
self.check_state()