# Path: torext/utils.py
# def generate_cookie_secret():
# def timesince(t):
# def pprint(o):
#     def instance(cls, *args, **kwgs):
# def split_kwargs(kwgs_tuple, kwgs):
#     def __getattr__(self, key):
#     def __setattr__(self, key, value):
#     def __delattr__(self, key):
#     def __str__(self):
# def _resolve_name(name, package, level):
# def import_module(name, package=None):
# def add_to_syspath(pth, relative_to=None):
# def start_shell(extra_vars=None):
#         def complete(self, text, state):
# def fix_request_arguments(arguments):
#     def __init__(self, local, name=None):
#     def get_current_object(self):
#     def __dict__(self):
#     def __repr__(self):
#     def __bool__(self):
#     def __unicode__(self):
#     def __dir__(self):
#     def __getattr__(self, name):
#     def __setitem__(self, key, value):
#     def __delitem__(self, key):
#     def __setslice__(self, i, j, seq):
#     def __delslice__(self, i, j):
# class SingletonMixin(object):
# class ObjectDict(dict):
#     class CustomCompleter(rlcompleter.Completer):
# class LocalProxy(object):
# 
# Path: torext/compat.py
# PY3 = sys.version_info.major == 3
# PY2 = sys.version_info.major == 2
#     def unicode_(s, *args):
#     def decode_(s, *args):
#     def bytes_(s):
#     def str_(s):
#     def unicode_(s, *args):
#     def decode_(s, *args):
#     def bytes_(s):
#     def str_(s):


import sys
import time
import unittest
import logging
import mimetypes
from tornado.httpclient import AsyncHTTPClient
from tornado.ioloop import IOLoop
from tornado.stack_context import NullContext
from tornado.escape import json_encode
from tornado import web
from tornado.web import HTTPError
from torext.utils import raise_exc_info
from torext.compat import SimpleCookie, quote, urlencode, httplib
                        raise self.failureException(
                            'Async operation timed out after %s seconds' %
                            timeout)
                    except Exception:
                        self.__failure = sys.exc_info()
                    self.stop()
                if self.__timeout is not None:
                    self.io_loop.remove_timeout(self.__timeout)
                self.__timeout = self.io_loop.add_timeout(time.time() + timeout, timeout_func)
            while True:
                self.__running = True
                with NullContext():
                    # Wipe out the StackContext that was established in
                    # self.run() so that all callbacks executed inside the
                    # IOLoop will re-run it.
                    self.io_loop.start()
                if (self.__failure is not None or
                        condition is None or condition()):
                    break
        assert self.__stopped
        self.__stopped = False
        self.__rethrow()
        result = self.__stop_args
        self.__stop_args = None
        return result

    def __rethrow(self):
        if self.__failure is not None:
            failure = self.__failure
            self.__failure = None

# Path: torext/utils.py
# def generate_cookie_secret():
# def timesince(t):
# def pprint(o):
#     def instance(cls, *args, **kwgs):
# def split_kwargs(kwgs_tuple, kwgs):
#     def __getattr__(self, key):
#     def __setattr__(self, key, value):
#     def __delattr__(self, key):
#     def __str__(self):
# def _resolve_name(name, package, level):
# def import_module(name, package=None):
# def add_to_syspath(pth, relative_to=None):
# def start_shell(extra_vars=None):
#         def complete(self, text, state):
# def fix_request_arguments(arguments):
#     def __init__(self, local, name=None):
#     def get_current_object(self):
#     def __dict__(self):
#     def __repr__(self):
#     def __bool__(self):
#     def __unicode__(self):
#     def __dir__(self):
#     def __getattr__(self, name):
#     def __setitem__(self, key, value):
#     def __delitem__(self, key):
#     def __setslice__(self, i, j, seq):
#     def __delslice__(self, i, j):
# class SingletonMixin(object):
# class ObjectDict(dict):
#     class CustomCompleter(rlcompleter.Completer):
# class LocalProxy(object):
# 
# Path: torext/compat.py
# PY3 = sys.version_info.major == 3
# PY2 = sys.version_info.major == 2
#     def unicode_(s, *args):
#     def decode_(s, *args):
#     def bytes_(s):
#     def str_(s):
#     def unicode_(s, *args):
#     def decode_(s, *args):
#     def bytes_(s):
#     def str_(s):


# Path: torext/testing.py
import sys
import time
import unittest
import logging
import mimetypes
from tornado.httpclient import AsyncHTTPClient
from tornado.ioloop import IOLoop
from tornado.stack_context import NullContext
from tornado.escape import json_encode
from tornado import web
from tornado.web import HTTPError
from torext.utils import raise_exc_info
from torext.compat import SimpleCookie, quote, urlencode, httplib

                        raise self.failureException(
                            'Async operation timed out after %s seconds' %
                            timeout)
                    except Exception:
                        self.__failure = sys.exc_info()
                    self.stop()
                if self.__timeout is not None:
                    self.io_loop.remove_timeout(self.__timeout)
                self.__timeout = self.io_loop.add_timeout(time.time() + timeout, timeout_func)
            while True:
                self.__running = True
                with NullContext():
                    # Wipe out the StackContext that was established in
                    # self.run() so that all callbacks executed inside the
                    # IOLoop will re-run it.
                    self.io_loop.start()
                if (self.__failure is not None or
                        condition is None or condition()):
                    break
        assert self.__stopped
        self.__stopped = False
        self.__rethrow()
        result = self.__stop_args
        self.__stop_args = None
        return result

    def __rethrow(self):
        if self.__failure is not None:
            failure = self.__failure
            self.__failure = None

            raise_exc_info(failure)