kallithea Changeset - aa1891074dd6

Changeset - aa1891074dd6

Parent rev.

Child rev.

[Not reviewed]

default

0 5 0

Mads Kiilerich - 10 years ago 2015-10-08 23:21:58
madski@unity3d.com

cache: when invalidating a cache, always just delete all 'live cache' records instead of marking them inactive

Keep it simple. Adding the record again might be slightly more expensive than
just updating the active flag but instead we get get a simpler model and
automatic cleanup without using the cache-keys paster command.

5 files changed with 10 insertions and 15 deletions:

kallithea/controllers/admin/repos.py

kallithea/controllers/admin/settings.py

kallithea/model/db.py

kallithea/model/scm.py

kallithea/tests/other/manual_test_vcs_operations.py

0 comments (0 inline, 0 general)

kallithea/controllers/admin/repos.py

➞

Show inline comments

@@ @@ -577,7 +577,7 @@ class ReposController(BaseRepoController @@
         c.active = 'caches'
         if request.POST:
             try:
-                ScmModel().mark_for_invalidation(repo_name, delete=True)
                 ScmModel().mark_for_invalidation(repo_name)
                 Session().commit()
                 h.flash(_('Cache invalidation successful'),
                         category='success')

kallithea/controllers/admin/settings.py

➞

Show inline comments

@@ @@ -206,7 +206,7 @@ class SettingsController(BaseController) @@
             if invalidate_cache:
                 log.debug('invalidating all repositories cache')
                 for repo in Repository.get_all():
-                    ScmModel().mark_for_invalidation(repo.repo_name, delete=True)
                     ScmModel().mark_for_invalidation(repo.repo_name)
             filesystem_repos = ScmModel().repo_scan()
             added, removed = repo2db_mapper(filesystem_repos, rm_obsolete,

kallithea/model/db.py

➞

Show inline comments

@@ @@ -2103,7 +2103,7 @@ class CacheInvalidation(Base, BaseModel) @@
         return "%s%s" % (prefix, key)
     @classmethod
-    def set_invalidate(cls, repo_name, delete=False):
     def set_invalidate(cls, repo_name):
         """
         Mark all caches of a repo as invalid in the database.
         """
@@ @@ -2114,11 +2114,7 @@ class CacheInvalidation(Base, BaseModel) @@
         for inv_obj in inv_objs:
             log.debug('marking %s key for invalidation based on repo_name=%s',
                       inv_obj, safe_str(repo_name))
             if delete:
                 Session().delete(inv_obj)
             else:
                 inv_obj.cache_active = False
                 Session().add(inv_obj)
             Session().delete(inv_obj)
         Session().commit()
     @classmethod

kallithea/model/scm.py

➞

Show inline comments

@@ @@ -331,13 +331,13 @@ class ScmModel(BaseModel): @@
                 .filter(RepoGroup.group_parent_id == None).all()
         return [x for x in RepoGroupList(all_groups)]
-    def mark_for_invalidation(self, repo_name, delete=False):
     def mark_for_invalidation(self, repo_name):
         """
         Mark caches of this repo invalid in the database.
         :param repo_name: the repo for which caches should be marked invalid
         """
-        CacheInvalidation.set_invalidate(repo_name, delete=delete)
         CacheInvalidation.set_invalidate(repo_name)
         repo = Repository.get_by_repo_name(repo_name)
         if repo is not None:
             repo.update_changeset_cache()

kallithea/tests/other/manual_test_vcs_operations.py

➞

Show inline comments

@@ @@ -273,8 +273,8 @@ class TestVCSOperations(BaseTestCase): @@
         stdout, stderr = _add_files_and_push('hg', DEST, files_no=1)
         key = CacheInvalidation.query().filter(CacheInvalidation.cache_key
                                                ==HG_REPO).one()
         self.assertEqual(key.cache_active, False)
                                                ==HG_REPO).all()
         self.assertEqual(key, [])
     def test_push_invalidates_cache_git(self):
         key = CacheInvalidation.query().filter(CacheInvalidation.cache_key
@@ @@ -295,9 +295,8 @@ class TestVCSOperations(BaseTestCase): @@
         _check_proper_git_push(stdout, stderr)
         key = CacheInvalidation.query().filter(CacheInvalidation.cache_key
                                                ==GIT_REPO).one()
         print CacheInvalidation.get_all()
         self.assertEqual(key.cache_active, False)
                                                ==GIT_REPO).all()
         self.assertEqual(key, [])
     def test_push_wrong_credentials_hg(self):
         DEST = _get_tmp_dir()

0 comments (0 inline, 0 general)