if name:
user["name"] = name
elif name_parts:
- user["name"] = u(" ").join(name_parts)
+ user["name"] = u" ".join(name_parts)
elif email:
user["name"] = email.split("@")[0]
if email:
assert future is a
if b.done():
return
- if (isinstance(a, TracebackFuture) and isinstance(b, TracebackFuture)
- and a.exc_info() is not None):
+ if (isinstance(a, TracebackFuture) and
+ isinstance(b, TracebackFuture) and
+ a.exc_info() is not None):
b.set_exc_info(a.exc_info())
elif a.exception() is not None:
b.set_exception(a.exception())
import json
import re
-import sys
from tornado.util import PY3, unicode_type, basestring_type
'Transfer-Encoding' not in headers)
# If a 1.0 client asked for keep-alive, add the header.
if (self._request_start_line.version == 'HTTP/1.0' and
- (self._request_headers.get('Connection', '').lower()
- == 'keep-alive')):
+ (self._request_headers.get('Connection', '').lower() ==
+ 'keep-alive')):
headers['Connection'] = 'Keep-Alive'
if self._chunking_output:
headers['Transfer-Encoding'] = 'chunked'
connection_header = connection_header.lower()
if start_line.version == "HTTP/1.1":
return connection_header != "close"
- elif ("Content-Length" in headers
- or headers.get("Transfer-Encoding", "").lower() == "chunked"
- or getattr(start_line, 'method', None) in ("HEAD", "GET")):
+ elif ("Content-Length" in headers or
+ headers.get("Transfer-Encoding", "").lower() == "chunked" or
+ getattr(start_line, 'method', None) in ("HEAD", "GET")):
# start_line may be a request or reponse start line; only
# the former has a method attribute.
return connection_header == "keep-alive"
due_timeouts.append(heapq.heappop(self._timeouts))
else:
break
- if (self._cancellations > 512
- and self._cancellations > (len(self._timeouts) >> 1)):
+ if (self._cancellations > 512 and
+ self._cancellations > (len(self._timeouts) >> 1)):
# Clean up the timeout queue when it gets large and it's
# more than half cancellations.
self._cancellations = 0
from __future__ import absolute_import, division, print_function, with_statement
-__all__ = ['Condition', 'Event', 'Semaphore', 'BoundedSemaphore', 'Lock']
-
import collections
from tornado import gen, ioloop
from tornado.concurrent import Future
+__all__ = ['Condition', 'Event', 'Semaphore', 'BoundedSemaphore', 'Lock']
+
class _TimeoutGarbageCollector(object):
"""Base class for objects that periodically clean up timed-out waiters.
.. note:
- When using tornado.options.parse_command_line or
- tornado.options.parse_config_file, the only options that are set are
+ When using tornado.options.parse_command_line or
+ tornado.options.parse_config_file, the only options that are set are
ones that were previously defined with tornado.options.define.
Command line formats are what you would expect (``--myoption=myvalue``).
from __future__ import absolute_import, division, print_function, with_statement
-__all__ = ['Queue', 'PriorityQueue', 'LifoQueue', 'QueueFull', 'QueueEmpty']
-
import collections
import heapq
from tornado.concurrent import Future
from tornado.locks import Event
+__all__ = ['Queue', 'PriorityQueue', 'LifoQueue', 'QueueFull', 'QueueEmpty']
+
class QueueEmpty(Exception):
"""Raised by `.Queue.get_nowait` when the queue has no items."""
self.io_loop.add_callback(namespace["callback"])
with ExpectLog(app_log, "Exception in callback"):
self.wait()
+
def test_spawn_callback(self):
# An added callback runs in the test's stack_context, so will be
# re-arised in wait().
import threading
import warnings
-from tornado.util import PY3
+from tornado.escape import utf8
+from tornado import gen
+from tornado.httpclient import AsyncHTTPClient
+from tornado.httpserver import HTTPServer
+from tornado.ioloop import IOLoop
+from tornado.platform.auto import set_close_exec
+from tornado.platform.select import SelectIOLoop
+from tornado.testing import bind_unused_port
+from tornado.test.util import unittest
+from tornado.util import import_object, PY3
+from tornado.web import RequestHandler, Application
try:
import fcntl
else:
import thread
-from tornado.escape import utf8
-from tornado import gen
-from tornado.httpclient import AsyncHTTPClient
-from tornado.httpserver import HTTPServer
-from tornado.ioloop import IOLoop
-from tornado.platform.auto import set_close_exec
-from tornado.platform.select import SelectIOLoop
-from tornado.testing import bind_unused_port
-from tornado.test.util import unittest
-from tornado.util import import_object
-from tornado.web import RequestHandler, Application
skipIfNoTwisted = unittest.skipUnless(have_twisted,
"twisted module not present")
wsgi_safe_tests = []
-relpath = lambda *a: os.path.join(os.path.dirname(__file__), *a)
+
+def relpath(*a):
+ return os.path.join(os.path.dirname(__file__), *a)
def wsgi_safe(cls):
def test_flow_control_chunked_body(self):
chunks = [b'abcd', b'efgh', b'ijkl']
+
@gen.coroutine
def body_producer(write):
for i in chunks:
raise Finish()
def test_finish_exception(self):
- for url in ['/', '/?finish_value=1']:
- response = self.fetch(url)
+ for u in ['/', '/?finish_value=1']:
+ response = self.fetch(u)
self.assertEqual(response.code, 401)
self.assertEqual('Basic realm="something"',
response.headers.get('WWW-Authenticate'))
from tornado.web import RequestHandler, Application
from tornado.wsgi import WSGIApplication, WSGIContainer, WSGIAdapter
+from tornado.test import httpserver_test
+from tornado.test import web_test
+
class WSGIContainerTest(AsyncHTTPTestCase):
def wsgi_app(self, environ, start_response):
data = json_decode(response.body)
self.assertEqual(data, {})
-# This is kind of hacky, but run some of the HTTPServer tests through
-# WSGIContainer and WSGIApplication to make sure everything survives
-# repeated disassembly and reassembly.
-from tornado.test import httpserver_test
-from tornado.test import web_test
-
+# This is kind of hacky, but run some of the HTTPServer and web tests
+# through WSGIContainer and WSGIApplication to make sure everything
+# survives repeated disassembly and reassembly.
class WSGIConnectionTest(httpserver_test.HTTPConnectionTest):
def get_app(self):
return WSGIContainer(validator(WSGIApplication(self.get_handlers())))
match = True
else:
# Use a weak comparison when comparing entity-tags.
- val = lambda x: x[2:] if x.startswith(b'W/') else x
+ def val(x):
+ return x[2:] if x.startswith(b'W/') else x
+
for etag in etags:
if val(etag) == val(computed_etag):
match = True
result = method(self, *args, **kwargs)
if result is not None:
result = gen.convert_yielded(result)
+
# If @asynchronous is used with @gen.coroutine, (but
# not @gen.engine), we can automatically finish the
# request when the future resolves. Additionally,
projects / thirdparty / tornado.git / commitdiff
