Comments
Patch
@@ -10,6 +10,7 @@
import struct
from . import (
+ node,
util,
)
@@ -125,3 +126,41 @@
def _deserializecachekey(self, data):
"""read the cachekey from bytes"""
return self._cachekeystruct.unpack(data)
+
+class changelogsourcebase(incrementalcachebase):
+ """an abstract class for cache sourcing data from the changelog
+
+ For this purpose it use a cache key covering changelog content.
+ The cache key parts are: (tiprev, tipnode)
+ """
+
+ __metaclass__ = abc.ABCMeta
+
+ # default key used for an empty cache
+ emptykey = (0, node.nullid)
+ _cachekeyspec = 'i20s'
+ _cachename = None # used for debug message
+
+ # Useful "public" function (no need to override them)
+
+ def _fetchchangelogdata(self, cachekey, cl):
+ """use a cachekey to fetch incremental data
+
+ Exists as its own method to help subclass to reuse it."""
+ tiprev = len(cl) - 1
+ tipnode = cl.node(tiprev)
+ newkey = (tiprev, tipnode)
+ tiprev = len(cl) - 1
+ if newkey == cachekey:
+ return False, [], newkey
+ keyrev, keynode = cachekey
+ if tiprev < keyrev or cl.node(keyrev) != keynode:
+ revs = ()
+ if len(cl):
+ revs = list(cl.revs(stop=tiprev))
+ return True, revs, newkey
+ else:
+ return False, list(cl.revs(start=keyrev + 1, stop=tiprev)), newkey
+
+ def _fetchupdatedata(self, repo):
+ return self._fetchchangelogdata(self._cachekey, repo.changelog)