kallithea Changeset - 04c4e5f94cee

Changeset - 04c4e5f94cee

Parent rev.

Child rev.

[Not reviewed]

beta

0 1 0

Marcin Kuzminski - 15 years ago 2010-11-19 03:00:05
marcin@python-works.com

cache list speed improvement

1 file changed with 13 insertions and 2 deletions:

rhodecode/model/scm.py

0 comments (0 inline, 0 general)

rhodecode/model/scm.py

➞

Show inline comments

@@ @@ -103,15 +103,20 @@ class ScmModel(object): @@
         :param all_repos: give specific repositories list, good for filtering
         """
         if not all_repos:
             all_repos = self.sa.query(Repository)\
                 .order_by(Repository.repo_name).all()
         invalidation_list = [str(x.cache_key) for x in \
                              self.sa.query(CacheInvalidation.cache_key)\
                              .filter(CacheInvalidation.cache_active == False)\
                              .all()]
         for r in all_repos:
             repo = self.get(r.repo_name)
+            repo = self.get(r.repo_name, invalidation_list)
             if repo is not None:
                 last_change = repo.last_change
                 tip = h.get_changeset_safe(repo, 'tip')
                 tmp_d = {}
@@ @@ -131,13 +136,13 @@ class ScmModel(object): @@
                 tmp_d['repo'] = repo
                 yield tmp_d
     def get_repo(self, repo_name):
         return self.get(repo_name)
     def get(self, repo_name):
+    def get(self, repo_name, invalidation_list=None):
         """
         Get's repository from given name, creates BackendInstance and
         propagates it's data from database with all additional information
         :param repo_name:
         """
         if not HasRepoPermissionAny('repository.read', 'repository.write',
@@ @@ -169,13 +174,19 @@ class ScmModel(object): @@
                 .filter(Repository.repo_name == repo_name)\
                 .scalar()
             make_transient(dbrepo)
             repo.dbrepo = dbrepo
             return repo
         pre_invalidate = True
         if invalidation_list:
             pre_invalidate = repo_name in invalidation_list
         if pre_invalidate:
         invalidate = self._should_invalidate(repo_name)
         if invalidate:
             log.info('invalidating cache for repository %s', repo_name)
             region_invalidate(_get_repo, None, repo_name)
             self._mark_invalidated(invalidate)
         return _get_repo(repo_name)

0 comments (0 inline, 0 general)