OLD | NEW |
1 # coding: utf-8 | 1 # coding: utf-8 |
2 | 2 |
3 # This file is part of the Adblock Plus web scripts, | 3 # This file is part of the Adblock Plus web scripts, |
4 # Copyright (C) 2006-2015 Eyeo GmbH | 4 # Copyright (C) 2006-2015 Eyeo GmbH |
5 # | 5 # |
6 # Adblock Plus is free software: you can redistribute it and/or modify | 6 # Adblock Plus is free software: you can redistribute it and/or modify |
7 # it under the terms of the GNU General Public License version 3 as | 7 # it under the terms of the GNU General Public License version 3 as |
8 # published by the Free Software Foundation. | 8 # published by the Free Software Foundation. |
9 # | 9 # |
10 # Adblock Plus is distributed in the hope that it will be useful, | 10 # Adblock Plus is distributed in the hope that it will be useful, |
(...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
116 | 116 |
117 if __name__ == "__main__": | 117 if __name__ == "__main__": |
118 if len(sys.argv) < 2: | 118 if len(sys.argv) < 2: |
119 source = FileSource(os.curdir) | 119 source = FileSource(os.curdir) |
120 elif os.path.isdir(sys.argv[1]): | 120 elif os.path.isdir(sys.argv[1]): |
121 source = FileSource(sys.argv[1]) | 121 source = FileSource(sys.argv[1]) |
122 else: | 122 else: |
123 sys.exit("Usage: %s [source_dir]" % sys.argv[0]) | 123 sys.exit("Usage: %s [source_dir]" % sys.argv[0]) |
124 | 124 |
125 try: | 125 try: |
126 from werkzeug.serving import run_simple | 126 from werkzeug.serving import ThreadedWSGIServer, run_simple |
| 127 |
| 128 # see https://github.com/mitsuhiko/werkzeug/pull/770 |
| 129 ThreadedWSGIServer.daemon_threads = True |
| 130 |
127 def run(*args, **kwargs): | 131 def run(*args, **kwargs): |
128 # The werkzeug logger must be configured before the | 132 # The werkzeug logger must be configured before the |
129 # root logger. Also we must prevent it from propagating | 133 # root logger. Also we must prevent it from propagating |
130 # messages, otherwise messages are logged twice. | 134 # messages, otherwise messages are logged twice. |
131 import logging | 135 import logging |
132 logger = logging.getLogger("werkzeug") | 136 logger = logging.getLogger("werkzeug") |
133 logger.propagate = False | 137 logger.propagate = False |
134 logger.setLevel(logging.INFO) | 138 logger.setLevel(logging.INFO) |
135 logger.addHandler(logging.StreamHandler()) | 139 logger.addHandler(logging.StreamHandler()) |
136 | 140 |
137 run_simple(*args, **kwargs) | 141 run_simple(threaded=True, *args, **kwargs) |
138 except ImportError: | 142 except ImportError: |
139 from wsgiref.simple_server import make_server | 143 from SocketServer import ThreadingMixIn |
| 144 from wsgiref.simple_server import WSGIServer, make_server |
| 145 |
| 146 class ThreadedWSGIServer(ThreadingMixIn, WSGIServer): |
| 147 daemon_threads = True |
| 148 |
140 def run(host, port, app, **kwargs): | 149 def run(host, port, app, **kwargs): |
141 def wrapper(environ, start_response): | 150 def wrapper(environ, start_response): |
142 try: | 151 try: |
143 return app(environ, start_response) | 152 return app(environ, start_response) |
144 except Exception, e: | 153 except Exception, e: |
145 return show_error(start_response, "500 Internal Server Error", | 154 return show_error(start_response, "500 Internal Server Error", |
146 uri=environ.get("PATH_INFO"), error=e) | 155 uri=environ.get("PATH_INFO"), error=e) |
147 | 156 |
148 server = make_server(host, port, wrapper) | 157 server = make_server(host, port, wrapper, ThreadedWSGIServer) |
149 print " * Running on http://%s:%i/" % server.server_address | 158 print " * Running on http://%s:%i/" % server.server_address |
150 server.serve_forever() | 159 server.serve_forever() |
151 | 160 |
152 run("localhost", 5000, handler, use_reloader=True, use_debugger=True) | 161 run("localhost", 5000, handler, use_reloader=True, use_debugger=True) |
OLD | NEW |