| Index: chrome/common/extensions/docs/server2/cron_servlet.py
|
| diff --git a/chrome/common/extensions/docs/server2/cron_servlet.py b/chrome/common/extensions/docs/server2/cron_servlet.py
|
| index b4676f5b4a1091bdbd74fee8221349607bc97732..dfd766f0a2497061bd239f7d82a327204eca1a15 100644
|
| --- a/chrome/common/extensions/docs/server2/cron_servlet.py
|
| +++ b/chrome/common/extensions/docs/server2/cron_servlet.py
|
| @@ -96,9 +96,9 @@ class CronServlet(Servlet):
|
|
|
| def CreateHostFileSystemProvider(self,
|
| object_store_creator,
|
| - max_trunk_revision=None):
|
| + pinned_commit=None):
|
| return HostFileSystemProvider(object_store_creator,
|
| - max_trunk_revision=max_trunk_revision)
|
| + pinned_commit=pinned_commit)
|
|
|
| def CreateGithubFileSystemProvider(self, object_store_creator):
|
| return GithubFileSystemProvider(object_store_creator)
|
| @@ -140,7 +140,7 @@ class CronServlet(Servlet):
|
| # TODO(kalman): IMPORTANT. This sometimes throws an exception, breaking
|
| # everything. Need retry logic at the fetcher level.
|
| server_instance = self._GetSafeServerInstance()
|
| - trunk_fs = server_instance.host_file_system_provider.GetTrunk()
|
| + master_fs = server_instance.host_file_system_provider.GetMaster()
|
|
|
| def render(path):
|
| request = Request(path, self._request.host, self._request.headers)
|
| @@ -158,7 +158,7 @@ class CronServlet(Servlet):
|
| base, ext = posixpath.splitext(name)
|
| return base if ext in strip_ext else name
|
| files = [maybe_strip_ext(name)
|
| - for name, _ in CreateURLsFromPaths(trunk_fs, path, prefix)]
|
| + for name, _ in CreateURLsFromPaths(master_fs, path, prefix)]
|
| return _RequestEachItem(path, files, render)
|
|
|
| results = []
|
| @@ -233,19 +233,19 @@ class CronServlet(Servlet):
|
| Response.InternalError('Failure'))
|
|
|
| def _GetSafeServerInstance(self):
|
| - '''Returns a ServerInstance with a host file system at a safe revision,
|
| - meaning the last revision that the current running version of the server
|
| + '''Returns a ServerInstance with a host file system at a safe commit,
|
| + meaning the last commit that the current running version of the server
|
| existed.
|
| '''
|
| delegate = self._delegate
|
|
|
| - # IMPORTANT: Get a ServerInstance pinned to the most recent revision, not
|
| + # IMPORTANT: Get a ServerInstance pinned to the most recent commit, not
|
| # HEAD. These cron jobs take a while and run very frequently such that
|
| # there is usually one running at any given time, and eventually a file
|
| # that we're dealing with will change underneath it, putting the server in
|
| # an undefined state.
|
| server_instance_near_head = self._CreateServerInstance(
|
| - self._GetMostRecentRevision())
|
| + self._GetMostRecentCommit())
|
|
|
| app_yaml_handler = AppYamlHelper(
|
| server_instance_near_head.object_store_creator,
|
| @@ -264,24 +264,24 @@ class CronServlet(Servlet):
|
|
|
| return self._CreateServerInstance(safe_revision)
|
|
|
| - def _GetMostRecentRevision(self):
|
| - '''Gets the revision of the most recent patch submitted to the host file
|
| - system. This is similar to HEAD but it's a concrete revision so won't
|
| + def _GetMostRecentCommit(self):
|
| + '''Gets the commit of the most recent patch submitted to the host file
|
| + system. This is similar to HEAD but it's a concrete commit so won't
|
| change as the cron runs.
|
| '''
|
| head_fs = (
|
| - self._CreateServerInstance(None).host_file_system_provider.GetTrunk())
|
| - return head_fs.Stat('').version
|
| + self._CreateServerInstance(None).host_file_system_provider.GetMaster())
|
| + return head_fs.GetCommitID().Get()
|
|
|
| - def _CreateServerInstance(self, revision):
|
| - '''Creates a ServerInstance pinned to |revision|, or HEAD if None.
|
| + def _CreateServerInstance(self, commit):
|
| + '''Creates a ServerInstance pinned to |commit|, or HEAD if None.
|
| NOTE: If passed None it's likely that during the cron run patches will be
|
| submitted at HEAD, which may change data underneath the cron run.
|
| '''
|
| object_store_creator = ObjectStoreCreator(start_empty=True)
|
| branch_utility = self._delegate.CreateBranchUtility(object_store_creator)
|
| host_file_system_provider = self._delegate.CreateHostFileSystemProvider(
|
| - object_store_creator, max_trunk_revision=revision)
|
| + object_store_creator, pinned_commit=commit)
|
| github_file_system_provider = self._delegate.CreateGithubFileSystemProvider(
|
| object_store_creator)
|
| gcs_file_system_provider = self._delegate.CreateGCSFileSystemProvider(
|
|
|