Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(375)

Unified Diff: chrome/common/extensions/docs/server2/subversion_file_system.py

Issue 10829348: Extensions Docs Server: Large performance increase (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 8 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: chrome/common/extensions/docs/server2/subversion_file_system.py
diff --git a/chrome/common/extensions/docs/server2/subversion_file_system.py b/chrome/common/extensions/docs/server2/subversion_file_system.py
index 8257d19973c9b64b49c2f92cc24db519a1a19463..001805c94a33af024adf604dd344dee2f47558d2 100644
--- a/chrome/common/extensions/docs/server2/subversion_file_system.py
+++ b/chrome/common/extensions/docs/server2/subversion_file_system.py
@@ -9,6 +9,36 @@ from xml.parsers.expat import ExpatError
import file_system
from future import Future
+class _AsyncFetchFuture(object):
+ def __init__(self, paths, fetcher, binary):
+ # A list of tuples of the form (path, Future).
+ self._fetches = [(path, fetcher.FetchAsync(path)) for path in paths]
+ self._value = {}
+ self._error = None
+ self._binary = binary
+
+ def _ListDir(self, directory):
+ dom = xml.parseString(directory)
+ files = [elem.childNodes[0].data for elem in dom.getElementsByTagName('a')]
+ if '..' in files:
+ files.remove('..')
+ return files
+
+ def Get(self):
+ for path, future in self._fetches:
+ result = future.Get()
+ if result.status_code == 404:
+ raise file_system.FileNotFoundError(path)
+ elif path.endswith('/'):
+ self._value[path] = self._ListDir(result.content)
+ elif not self._binary:
+ self._value[path] = file_system._ProcessFileData(result.content, path)
+ else:
+ self._value[path] = result.content
+ if self._error is not None:
+ raise self._error
+ return self._value
+
class SubversionFileSystem(file_system.FileSystem):
"""Class to fetch resources from src.chromium.org.
"""
@@ -58,7 +88,7 @@ class SubversionFileSystem(file_system.FileSystem):
child_revisions[name] = rev.firstChild.nodeValue
else:
child_revisions[name + '/'] = rev.firstChild.nodeValue
- return self.StatInfo(dir_revision, child_revisions)
+ return file_system.StatInfo(dir_revision, child_revisions)
def Stat(self, path):
directory = path.rsplit('/', 1)[0]
@@ -72,35 +102,3 @@ class SubversionFileSystem(file_system.FileSystem):
raise file_system.FileNotFoundError(path)
stat_info.version = stat_info.child_versions[filename]
return stat_info
-
-class _AsyncFetchFuture(object):
- def __init__(self, paths, fetcher, binary):
- # A list of tuples of the form (path, Future).
- self._fetches = []
- self._value = {}
- self._error = None
- self._fetches = [(path, fetcher.FetchAsync(path)) for path in paths]
- self._binary = binary
-
- def _ListDir(self, directory):
- dom = xml.parseString(directory)
- files = [elem.childNodes[0].data for elem in dom.getElementsByTagName('a')]
- if '..' in files:
- files.remove('..')
- return files
-
- def Get(self):
- for path, future in self._fetches:
- result = future.Get()
- if result.status_code == 404:
- raise file_system.FileNotFoundError(path)
- elif path.endswith('/'):
- self._value[path] = self._ListDir(result.content)
- elif not self._binary:
- self._value[path] = file_system._ProcessFileData(result.content, path)
- else:
- self._value[path] = result.content
- if self._error is not None:
- raise self._error
- return self._value
-

Powered by Google App Engine
This is Rietveld 408576698