Docserver: Gitiles auth and cron refactoring.

chrome/common/extensions/docs/server2/content_providers.py

 # Copyright 2013 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 import logging
 import os
 import traceback
 
 from chroot_file_system import ChrootFileSystem
 from content_provider import ContentProvider
@@ skipping 152 matching lines @@
       return None
 
     return ContentProvider(name,
                            self._compiled_fs_factory,
                            file_system,
                            self._object_store_creator,
                            default_extensions=default_extensions,
                            supports_templates=supports_templates,
                            supports_zip=supports_zip)
 
-  def Cron(self):
+  def GetRefreshPaths(self):
+    return self._GetConfig().keys()
+
+  def Refresh(self, path):
     def safe(name, action, callback):
       '''Safely runs |callback| for a ContentProvider called |name| by
       swallowing exceptions and turning them into a None return value. It's
-      important to run all ContentProvider Crons even if some of them fail.
+      important to run all ContentProvider Refreshes even if some of them fail.
       '''
       try:
         return callback()
       except:
         if not _IGNORE_MISSING_CONTENT_PROVIDERS[0]:
-          logging.error('Error %s Cron for ContentProvider "%s":\n%s' %
+          logging.error('Error %s Refresh for ContentProvider "%s":\n%s' %
                         (action, name, traceback.format_exc()))
         return None
 
-    futures = [(name, safe(name,
-                           'initializing',
-                           self._CreateContentProvider(name, config).Cron))
-               for name, config in self._GetConfig().iteritems()]
-    return Future(callback=
-        lambda: [safe(name, 'resolving', f.Get) for name, f in futures if f])
+    config = self._GetConfig()[path]
+    provider = self._CreateContentProvider(path, config)
+    future = safe(path,
+                  'initializing',
+                  self._CreateContentProvider(path, config).Refresh)
+    if future is None:
+      return Future(callback=lambda: True)
+    return Future(callback=lambda: safe(path, 'resolving', future.Get))