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

Unified Diff: mojo/devtools/common/devtoolslib/http_server.py

Issue 1316443002: Call `gzip` in subprocess instead of gzipping in Python in http_server. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Address Piotr's comments. Created 5 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
« no previous file with comments | « no previous file | mojo/devtools/common/devtoolslib/shell_arguments.py » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/devtools/common/devtoolslib/http_server.py
diff --git a/mojo/devtools/common/devtoolslib/http_server.py b/mojo/devtools/common/devtoolslib/http_server.py
index d8a275770135205263026d3cba56a3aa733ddf77..fe2be7a66abe67161b125cdc5a5db0a1c9036d57 100644
--- a/mojo/devtools/common/devtoolslib/http_server.py
+++ b/mojo/devtools/common/devtoolslib/http_server.py
@@ -6,15 +6,14 @@ import atexit
import datetime
import email.utils
import errno
-import gzip
import hashlib
import logging
import math
import os.path
-import shutil
import socket
-import threading
+import subprocess
import tempfile
+import threading
import SimpleHTTPServer
import SocketServer
@@ -37,6 +36,24 @@ class UTC_TZINFO(datetime.tzinfo):
_UTC = UTC_TZINFO()
+def _gzip(file_path):
+ """Gzips the given file storing the result in a temporary file.
+
+ Returns:
+ Path to the resulting file.
+ """
+ gzipped_file = tempfile.NamedTemporaryFile(delete=False)
+ try:
+ subprocess.check_call(['gzip', '-c', file_path],
+ stdout=gzipped_file)
+ except Exception:
+ print ('http_server: call to gzip failed, make sure that '
+ 'gzip is installed on the host.')
+ raise
+ gzipped_file.close()
+ return gzipped_file.name
+
+
class _SilentTCPServer(SocketServer.TCPServer):
"""A TCPServer that won't display any error, unless debugging is enabled. This
is useful because the client might stop while it is fetching an URL, which
@@ -73,7 +90,7 @@ def _get_handler_class_for_path(mappings):
def __init__(self, *args, **kwargs):
self.etag = None
- self.gzipped_file = None
+ self.gzipped_file_name = None
self.original_file_name = None
SimpleHTTPServer.SimpleHTTPRequestHandler.__init__(self, *args, **kwargs)
@@ -138,7 +155,7 @@ def _get_handler_class_for_path(mappings):
return SimpleHTTPServer.SimpleHTTPRequestHandler.end_headers(self)
# pylint: disable=W0221
- def translate_path(self, path, gzipped=True):
+ def translate_path(self, path, gzip=True):
# Parent translate_path() will strip away the query string and fragment
# identifier, but also will prepend the cwd to the path. relpath() gives
# us the relative path back.
@@ -146,24 +163,22 @@ def _get_handler_class_for_path(mappings):
SimpleHTTPServer.SimpleHTTPRequestHandler.translate_path(self, path))
for prefix, local_base_path_list in mappings:
- if normalized_path.startswith(prefix):
- for local_base_path in local_base_path_list:
- candidate = os.path.join(local_base_path,
- normalized_path[len(prefix):])
- if os.path.isfile(candidate):
- if gzipped:
- if not self.gzipped_file:
- self.gzipped_file = tempfile.NamedTemporaryFile(delete=False)
- self.original_file_name = candidate
- with open(candidate, 'rb') as source:
- with gzip.GzipFile(fileobj=self.gzipped_file) as target:
- shutil.copyfileobj(source, target)
- self.gzipped_file.close()
- return self.gzipped_file.name
- return candidate
- else:
- self.send_response(404)
- return None
+ if not normalized_path.startswith(prefix):
+ continue
+
+ for local_base_path in local_base_path_list:
+ candidate = os.path.join(local_base_path,
+ normalized_path[len(prefix):])
+ if os.path.isfile(candidate):
+ if gzip:
+ if not self.gzipped_file_name:
+ self.original_file_name = candidate
+ self.gzipped_file_name = _gzip(candidate)
+ return self.gzipped_file_name
+ return candidate
+ else:
+ self.send_response(404)
+ return None
self.send_response(404)
return None
@@ -184,8 +199,8 @@ def _get_handler_class_for_path(mappings):
pass
def __del__(self):
- if self.gzipped_file:
- os.remove(self.gzipped_file.name)
+ if self.gzipped_file_name:
+ os.remove(self.gzipped_file_name)
RequestHandler.protocol_version = 'HTTP/1.1'
return RequestHandler
« no previous file with comments | « no previous file | mojo/devtools/common/devtoolslib/shell_arguments.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698