tornado 思维导图模板_ProcessOn思维导图、流程图

platform

asyncio.py

class BaseAsyncIOLoop

继承IOLoop，实现df,event,handlers之间绑定

class AsyncIOMainLoop

继承BaseAsyncIOLoop

class AsyncIOLoop

继承BaseAsyncIOLoop，实现asynio event loop

to_tornado_future

将asyncio.Future转换成tornado.concurrent.Future

to_asyncio_future

将Tornado yieldable转换成asyncio.Future

auto.py

引入monotonic_time以及根据os的类型，引入不同的Waker和set_close_exec函数

caresresolver.py

class CaresResolver

基于c语言库的dns解析，非阻塞，非线程级

common.py

try_close

尝试关闭文件

class Waker

创建os依赖的pipe，并实现waker接口

epoll.py

class EPollIOLoop

继承PollIOLoop类，实现initialize方法

interface.py

interface

set_close_exec

给文件描述符设置close_on_exec位

class Waker

socket对象，当有object需要进行select(epoll或kqueue)操作的时候调用

monotonic_time

获取monotonic_time

kqueue.py

class KQueueIOLoop

继承PollIOLoop类，实现initialize方法

class _KQueue

A kqueue-based event loop for BSD/Mac systems.

posix.py

set_close_exec(fd)

设置关闭fd时采取的动作和执行内容

_set_nonblocking

设置非阻塞方式

class Waker

设置waker对象

select.py

class SelectIOLoop

继承PollIOLoop对象，实现initialized方法

class _Select

A simple, select()-based IOLoop implementation for non-Linux systems

twisted.py

class TornadoDelayedCall

tornado延迟调用

class TornadoReactor

通过实现twisted接口实现ioloop

class _TestReactor

单元测试

class install

安装io_loop作为twisted reactor

class _FD

实现IReadDescriptor, IWriteDescriptor两个接口

class TwistedIOLoop

继承salt.ext.tornado.ioloop.IOLoop，实现twisted的方式

class TwistedResolver

异步解析twisted的dns信息

windows.py

set_close_exec

关闭fd时执行的内容

test

_locale_data.py

定义各种语言的名称/英文名等

auth.py

_auth_future_to_callback

调用callback函数，处理future的返回结果

_auth_return_future

装饰器，与return_future方式相同，使用的时auth 模块

class OpenIdMixin

实现OpenID的验证方式

class OAuthMixin

实现OAuth 1.0的方式

class OAuth2Mixin

实现OAuth 2.0的方式

class TwitterMixin

实现twitter auth方式

class GoogleOAuth2Mixin

实现google auth2方式

class FacebookGraphMixin

实现facebook graph api和auth2方式

_oauth_signature

计算HMAC-SHA1 OAuth签名方式

_oauth10a_signature

计算HMAC-SHA1 OAuth 1.0a签名方式

_oauth_escape

对val进行quote操作

_oauth_parse_response

获取token

autoreload.py

_reload

调用reload hook执行重新加载

add_reload_hook

reload process之前添加function调用

_check_file

检查文件st_mtime是否已经修改

_reload_on_update

检查是否需要reload

watch

添加文件到watch list

wait

等待文件改变，重启process

start

启动文件监控

concurrent.py

class _TracebackLogger

追踪exception信息

class Future

处理asynchronous 结果

is_future

判断是否为future类型

class DummyExecutor

空执行

run_on_executor

装饰器运行在executor上异步运行同步方法，并返回future对象

return_future

装饰器，使得func通过callback返回Future对象

chain_future

链接两个futures到一起，保证两个同时完成

curl_httpclient.py

class CurlAsyncHTTPClient

异步HTTP client处理程序

escape.py

xhtml_escape

使得xml或者html合法化

def xhtml_unescape(value):

xml变回原有信息

json_encode

json dumps

json_decode

json loads

squeeze

连续空格变成一个

url_escape

url quote

url_unescape

url unquote

utf8

encode utf8

to_unicode

decode utf8

to_basestring

decode utf8

recursive_unicode

递归进行unicode转换

linkify

Converts plain text into HTML with links

gen.py

_value_from_stopiteration

返回stopiteration的信息

engine

装饰器实现func的future和callback

coroutine

装饰器实现异步调用

_make_coroutine_wrapper

真正实现coroutine内部调用的函数

is_coroutine_function

判断func是不是coroutine函数

class Return

指定coroutine返回的exception

class WaitIterator

提供iterator，在future结束后提供yield result

class YieldPoint

基础类，用于适应那些需要yield操作的对象

class Callback

返回一个callable对象，允许匹配wait去调用

class Wait

获取之前callback返回的result

class WaitAll

获取之前所有callback返回的result

Task

调用任务并返回结果

class YieldFuture

yield Point的future动作，并取回结果

_contains_yieldpoint

如果children包含yieldPoints点

multi

运行多重异步并行操作

class MultiYieldPoint

与multi类似，但是总是创建stack context方法，不兼容原声coroutines

multi_future

等待并行调用future执行结果

maybe_future

如果时future类则返回，否则创建future对象返回

with_timeout

future timeout调用方式

sleep

gen的sleep方式

class Runner

内部实现gen engine，管理callbacks的信息和result结果

_argument_adapter

根据参数个数，调用callback函数并传输不同类型的参数

convert_yielded

将yielded对象转换成Future

http1connection.py

class _QuietException

异常退出基类

class _ExceptionLoggingContext

提供with方法输出异常信息

class HTTP1ConnectionParameters

HTTP1Connection和HTTP1ServerConnection的参数类

class HTTP1Connection

实现http 1.x protocal

class _GzipMessageDelegate

包装HTTPMessage，生成Content-Encoding: gzip类型数据

class HTTP1ServerConnection

HTTP 1.x Server

httpclient.py

class HTTPClient

阻塞的http client对象

class AsyncHTTPClient

非阻塞的HTTP client

class HTTPRequest

HTTPRequest对象

class HTTPResponse

HTTPResponse对象

class HTTPError

HTTP请求异常处理

class _RequestProxy

获取request的属性

httpserver.py

class HTTPServer

非阻塞的单线程http-server

class _CallableAdapter

继承httputil.HTTPMessageDelegate实现HTTP消息处理

class _HTTPRequestContext

保留socket address或header相关信息，在stream close后恢复

class _ProxyAdapter

proxy adapter处理

httputil.py

class _NormalizedHeaderCache

将http header的名称替换成大写字母开头内容

class HTTPHeaders

定义http header处理方法

class HTTPServerRequest

生成http request单一请求

class HTTPInputError

管理http request和response的异常请求

class HTTPOutputError

http输出异常处理

class HTTPServerConnectionDelegate

实现httpServer处理程序的接口

class HTTPMessageDelegate

实现http request或response处理接口

class HTTPConnection

应用程序使用此接口写response信息

url_concat

连接url和参数，形成完整url

class HTTPFile

代表文件上传form对象

_parse_request_range

获取header范围

_get_content_range

返回可用的content range

_int_or_none

将val转换成数字或者返回NOne

parse_body_arguments

生成form 请求实体

parse_multipart_form_data

生成multipart/form-data实体

format_timestamp

返回timestamp

parse_request_start_line

Returns a (method, path, version) tuple for an HTTP 1.x request line.（method='GET', path='/foo', version='HTTP/1.1'）

parse_response_start_line

Returns a (version, code, reason) tuple for an HTTP 1.x response line(version='HTTP/1.1', code=200, reason='OK')

_parseparam

yield方式输出所有的param

_parse_header

将Content-type类型的header转换成key value形式

_encode_header

将header类型数据转换成字符串

split_host_and_port

去除host，port列表

_unquote_cookie

去除cookie双引号

parse_cookie

将Cookie http header信息转换成字典类型

ioloop.py

class IOLoop

定义epoll，kqueue，等的io事件/handler/fd等关系

class PollIOLoop

建立select的handler等处理内容

class _Timeout

ioloop timeout对象

class PeriodicCallback

callback周期性调用内容

iostream.py

class StreamClosedError

当stream关闭时产生IOStream close error

class UnsatisfiableReadError

当read操作不满足时产生exception

class StreamBufferFullError

当buffer满后产生exception

class BaseIOStream

基础工具类，用于写入或者读取文件或socket内容

class IOStream

基于BaseIOStream同时增加connect信息

class SSLIOStream

基于IOStream类，增加ssl和certify方式

class PipeIOStream

基于BaseIOStream，增加对fd的操作

locale.py

get

获取给定locale codes最接近的内容

set_default_locale

设置supported locales

locks.py

class _TimeoutGarbageCollector

基础类周期性清理未完成对象

class Condition

按条件等待其他coroutines调用

class Event

事件阻塞协程直到flag被设置成True

class _ReleasingContextManager

with指令后释放lock和semaphore

class Semaphore

一种可以同时容纳多个lock的锁机制

class BoundedSemaphore

继承Semaphore，保证release的次数不超过initial_value

class Lock

对coroutines加锁

log.py

_stderr_supports_color

stderr是否支持颜色

class LogFormatter

定义log 模式

enable_pretty_logging

开始完美日志输出

define_logging_options

定义日志参数

load_translations

从csv文件中加载内容

load_gettext_translations

通过gettext方式获取类似/usr/share/locale下的translations

get_supported_locales

获取locales的列表

class Locale

创建locale对象

class CSVLocale

使用tornado CSV转换方式定位信息

class GettextLocale

使用gettext模块定位信息

netutil.py

bind_sockets

绑定端口和地址，返回sockets对象

bind_unix_socket

绑定unix socket到文件

add_accept_handler

添加event到ioloop handler，接收sock新请求

is_valid_ip

检查ip地址是否格式正确

class Resolver

配置dns解析interface

class ExecutorResolver

继承Resolver，做执行解析

class BlockingResolver

ioloop在解析过程中将要阻断

class ThreadedResolver

多线程非阻塞方式resolver实现

class OverrideResolver

本地DNS解析对照表，这种方法可以用于修改内存中存储的本地DNS配置

ssl_options_to_context

将ssl_options字典转换成对象

ssl_wrap_socket

根据ssl_options，生成socket对象

options.py

class OptionParser

参数定制管理

class _Mockable

兼容OptionParser，将字典类型转换成getter setter类型

class _Option

对格式进行转化

define

调用optionParser.define

parse_command_line

调用OptionParser.parse_command_line

parse_config_file

调用OptionParser.parse_config_file

print_help

调用OptionParser.print_help

add_parse_callback

调用OptionParser.add_parse_callback

process.py

cpu_count

统计cpu颗数

_reseed_random

产生随机变量

_pipe_cloexec

产生读写文件符

fork_processes

根据cpu颗数产生子线程

task_id

返回当前task_id信息

class Subprocess

类似于subprocess.Popen的并生成PipeIOStream处理

queues.py

class QueueEmpty

定义Empty queue,如果queue是空的则报错

class QueueFull

如果queue是满的则报错

_set_timeout

定义超时handle，以及done_callback函数

class _QueueIterator

异步生成器awailable对象

class Queue

getter队列和putter队列协作

class PriorityQueue

继承Queue，实现put，get，init功能

class LifoQueue

继承Queue，实现put,init,get功能

routing.py

class Router

router的接口

class ReversibleRouter

继承自Router类，实现将route名称转换成原始url

class _RoutingDelegate

继承httputil.HTTPMessageDelegate，实现headers_received，data_received,finish,on_connection_close等操作

class RuleRouter

继承Router,RuleRouter([
Rule(PathMatches("/handler"), Target),
# ... more rules
]) 规则加载，查找，代理等

class ReversibleRuleRouter

继承ReversibleRouter, RuleRouter，实现rule的reverse_url操作

class Rule

定义rule对象

class Matcher

匹配request请求，形成url

class AnyMatches

匹配所有请求

class HostMatches

继承Matcher，匹配host名称

class DefaultHostMatches

继承Matcher，对request的host进行匹配，如果headers中包含X-Real-Ip内容，则总是返回None

class PathMatches

继承Matcher，按照path_pattern对request进行path匹配

class URLSpec

继承Rule，对URL和handler进行mapping操作

_unquote_or_none

非安全模式的url_unescape

simple_httpclient.py

_default_ca_certs

返回certifi的位置

class SimpleAsyncHTTPClient

实现非阻塞的http client类

class _HTTPConnection

http Connection用于连接的对象

tcpclient.py

class _Connector

Happy Eyeballs算法的无状态实现，getaddrinfo首先返回的链路，作为连接链路

class TCPClient

非阻塞的TCP连接工厂

tcpserver.py

class TCPServer

定义非阻塞的单线程TCP server

template.py

filter_whitespace

根据模式对空白字符进行缩进转换

class Template

创建模板对象

class BaseLoader

template基础loader对象

class Loader

继承BaseLoader，根据path解析并加载template

class DictLoader

继承BaseLoader，根据字典加载template

...

util.py

class ObjectDict

使字典行为拥有对象的能力

class GzipDecompressor

进行gzip压缩

import_object

import对象

errno_from_exception

从exception中获取errno信息

re_unescape

替换某些特殊字符串

class Configurable

配置基类

timedelta_to_seconds

时间戳的秒数

wsgi.py

web.py

class RequestHandler

http请求handler的基类，实现请求所需的基本函数

asynchronous

装饰器，实现request handler的异步调用

removeslash

装饰器，移除url末尾的/

addslash

装饰器，url末尾添加/

class _ApplicationRouter

继承ReversibleRuleRouter，实现Application和RequestHandler之间的绑定

class Application

继承自ReversibleRouter，实现url与handler的绑定处理等动作

class_HandlerDelegate

继承自httputil.HTTPMessageDelegate，实现header,data等数据的处理

class HTTPError

http error response的exception处理

class Finish

结束请求的异常处理

class MissingArgumentError

缺失参数的异常

class ErrorHandler

对所有requests生成带status_code的error response

class RedirectHandler

重定向请求地址

class StaticFileHandler

静态文件handler处理

class FallbackHandler

继承RequestHandler，装饰器，调用callback函数

class OutputTransform

转换修正http 请求的结果集

class GZipContentEncoding

继承OutputTransform，对response内容进行gzip压缩

authenticated

装饰器，用于验证user是否登陆，如果没有登陆则跳转至登陆页面

get_signature_key_version

获取签名key_version

_create_signature_v1

创建sha256加密

_create_signature_v2

创建sha1的加密

is_absolute

是否是绝对路径

websocket.py

class WebSocketHandler

websocket 基础处理程序

class WebSocketProtocol

websocket 协议的基础类

class _PerMessageDeflateCompressor

message 压缩

class _PerMessageDeflateDecompressor

message 解压缩

class WebSocketProtocol13

继承WebSocketProtocal，实现RFC6455 websocket协议

class WebSocketClientConnection

webSocket client连接对象，不要直接调用，应该使用websocket_connect调用

websocket_connect

websocket 客户端支持

stack_context.py

class StackContext

stack context处理enter exit问题

class ExceptionStackContext

详细处理stack exception内容

class NullContext

重置stack context

_remove_deactivated

去除chain中的deactivated handlers

wrap

返回fun的可执行对象