OLD | NEW |
---|---|
1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
4 | 4 |
5 import time | 5 import time |
6 | 6 |
7 from appengine_wrappers import taskqueue | 7 from appengine_wrappers import taskqueue |
8 from cron_servlet import CronServlet | 8 from cron_servlet import CronServlet |
9 from instance_servlet import InstanceServlet | 9 from instance_servlet import InstanceServlet |
10 from patch_servlet import PatchServlet | 10 from patch_servlet import PatchServlet |
(...skipping 18 matching lines...) Expand all Loading... | |
29 | 29 |
30 class Handler(Servlet): | 30 class Handler(Servlet): |
31 def Get(self): | 31 def Get(self): |
32 path = self._request.path | 32 path = self._request.path |
33 | 33 |
34 if path.startswith('_'): | 34 if path.startswith('_'): |
35 servlet_path = path[1:] | 35 servlet_path = path[1:] |
36 if not '/' in servlet_path: | 36 if not '/' in servlet_path: |
37 servlet_path += '/' | 37 servlet_path += '/' |
38 servlet_name, servlet_path = servlet_path.split('/', 1) | 38 servlet_name, servlet_path = servlet_path.split('/', 1) |
39 if servlet_name == _FORCE_CRON_TARGET: | 39 if servlet_name == _FORCE_CRON_TARGET: |
not at google - send to devlin
2014/10/20 21:06:57
Why are these servlets special-cased rather than l
Ken Rockot(use gerrit already)
2014/10/22 03:19:54
They were meant to be temporary hacks. _force_cron
| |
40 queue = taskqueue.Queue() | 40 queue = taskqueue.Queue() |
41 queue.purge() | 41 queue.purge() |
42 time.sleep(2) | 42 time.sleep(2) |
43 queue.add(taskqueue.Task(url='/_cron')) | 43 queue.add(taskqueue.Task(url='/_cron')) |
44 return Response.Ok('Cron job started.') | 44 return Response.Ok('Cron job started.') |
45 if servlet_name == 'enqueue': | 45 if servlet_name == 'enqueue': |
46 queue = taskqueue.Queue() | 46 queue = taskqueue.Queue() |
47 queue.add(taskqueue.Task(url='/%s'%servlet_path)) | 47 queue.add(taskqueue.Task(url='/%s' % servlet_path, |
48 params=self._request.arguments)) | |
48 return Response.Ok('Task enqueued.') | 49 return Response.Ok('Task enqueued.') |
49 servlet = _SERVLETS.get(servlet_name) | 50 servlet = _SERVLETS.get(servlet_name) |
50 if servlet is None: | 51 if servlet is None: |
51 return Response.NotFound('"%s" servlet not found' % servlet_path) | 52 return Response.NotFound('"%s" servlet not found' % servlet_path) |
52 else: | 53 else: |
53 servlet_path = path | 54 servlet_path = path |
54 servlet = _DEFAULT_SERVLET | 55 servlet = _DEFAULT_SERVLET |
55 | 56 |
56 return servlet(Request(servlet_path, | 57 return servlet(Request(servlet_path, |
57 self._request.host, | 58 self._request.host, |
58 self._request.headers, | 59 self._request.headers, |
59 self._request.arguments)).Get() | 60 self._request.arguments)).Get() |
OLD | NEW |