FM / __pycache_

/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/

/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__

Name	Size	Mode	Actions
abc.cpython-36.pyc	8528	0644	edit dl rm
base_protocol.cpython-36.pyc	2824	0644	edit dl rm
client.cpython-36.pyc	29965	0644	edit dl rm
client_exceptions.cpython-36.pyc	11369	0644	edit dl rm
client_proto.cpython-36.pyc	6041	0644	edit dl rm
client_reqrep.cpython-36.pyc	27700	0644	edit dl rm
client_ws.cpython-36.pyc	8824	0644	edit dl rm
connector.cpython-36.pyc	35273	0644	edit dl rm
cookiejar.cpython-36.pyc	10852	0644	edit dl rm
formdata.cpython-36.pyc	4440	0644	edit dl rm
hdrs.cpython-36.pyc	4473	0644	edit dl rm
helpers.cpython-36.pyc	26037	0644	edit dl rm
http.cpython-36.pyc	1422	0644	edit dl rm
http_exceptions.cpython-36.pyc	4396	0644	edit dl rm
http_parser.cpython-36.pyc	19182	0644	edit dl rm
http_websocket.cpython-36.pyc	14942	0644	edit dl rm
http_writer.cpython-36.pyc	5493	0644	edit dl rm
locks.cpython-36.pyc	1582	0644	edit dl rm
log.cpython-36.pyc	423	0644	edit dl rm
multipart.cpython-36.pyc	26312	0644	edit dl rm
payload.cpython-36.pyc	13433	0644	edit dl rm
payload_streamer.cpython-36.pyc	3182	0644	edit dl rm
pytest_plugin.cpython-36.pyc	9870	0644	edit dl rm
resolver.cpython-36.pyc	3940	0644	edit dl rm
streams.cpython-36.pyc	18605	0644	edit dl rm
tcp_helpers.cpython-36.pyc	1076	0644	edit dl rm
test_utils.cpython-36.pyc	21667	0644	edit dl rm
tracing.cpython-36.pyc	14857	0644	edit dl rm
typedefs.cpython-36.pyc	1482	0644	edit dl rm
web.cpython-36.pyc	10744	0644	edit dl rm
web_app.cpython-36.pyc	15118	0644	edit dl rm
web_exceptions.cpython-36.pyc	12766	0644	edit dl rm
web_fileresponse.cpython-36.pyc	5935	0644	edit dl rm
web_log.cpython-36.pyc	7182	0644	edit dl rm
web_middlewares.cpython-36.pyc	3863	0644	edit dl rm
web_protocol.cpython-36.pyc	15761	0644	edit dl rm
web_request.cpython-36.pyc	23874	0644	edit dl rm
web_response.cpython-36.pyc	21093	0644	edit dl rm
web_routedef.cpython-36.pyc	7973	0644	edit dl rm
web_runner.cpython-36.pyc	11755	0644	edit dl rm
web_server.cpython-36.pyc	2681	0644	edit dl rm
web_urldispatcher.cpython-36.pyc	42230	0644	edit dl rm
web_ws.cpython-36.pyc	13281	0644	edit dl rm
worker.cpython-36.pyc	6963	0644	edit dl rm
__init__.cpython-36.pyc	4270	0644	edit dl rm

Edit: /usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/worker.cpython-36.pyc (6963B)

3 8%Eg3"�@sdZddlZddlZddlZddlZddlZddlmZddlm Z m Z mZmZm Z ddlmZddlmZddlmZdd lmZdd lmZddlmZyddlZejZWnek r�dZeZYnXdZGdd�dej �Z!Gdd �d e!�Z"Gdd�de!�Z#dS)z%Async gunicorn worker for aiohttp.web�N)� FrameType)�Any� Awaitable�Callable�Optional�Union)�AccessLogFormat)�base)�web�)� set_result)�Application)�AccessLogger�GunicornWebWorker�GunicornUVLoopWebWorker�GunicornTokioWebWorkercs�eZdZejZejZe e dd��fdd�Z dd��fdd�Zdd�dd �Zdd�d d�Z dd�d d�Zd eddd�dd�Zdd�dd�Zeedd�dd�Zeedd�dd�Zee dd�dd��Zeed�dd�Z�ZS)!rN)�args�kw�returncs$t�j||�d|_d|_d|_dS)Nr)�super�__init__�_task� exit_code�_notify_waiter)�selfrr)� __class__��:/usr/local/lib64/python3.6/site-packages/aiohttp/worker.pyr%szGunicornWebWorker.__init__)rcs0tj�j�tj�|_tj|j�t�j�dS)N)�asyncio�get_event_loop�close�new_event_loop�loop�set_event_loopr�init_process)r)rrrr$,s zGunicornWebWorker.init_processcCsr|jj|j��|_y|jj|j�Wn tk rD|jjd�YnX|jj|jj��|jj �t j|j�dS)NzException in gunicorn worker) r"�create_task�_runr�run_until_complete� Exception�log� exception�shutdown_asyncgensr �sys�exitr)rrrr�run5s zGunicornWebWorker.runc�s�d}t|jt�r|j}nHtj|j�rP|j�IdH}t|tj�rJ|}|j}q`|}ntdj |j��|dkr�|j jrx|jj nd}tj||j|j j||j|j j�d�}|j�IdH|j jr�|j|j �nd}|}|dk s�t�|j}|dk s�t�x:|jD]0}tj||||j jddd�}|j�IdHq�Wtj�} y�x�|j�r�|j�|j} |j�rp| |jk�rpd|_|jj d|�nB| tj�k�r�|j!tj"�k�r�d|_|jj d|�n|j#�IdH�q0WWnt$k �r�YnX|j%�IdHdS) NzUwsgi app should be either Application or async function returning Application, got {})�loggerZkeepalive_timeout� access_log�access_log_format�d�_)�ssl_contextZshutdown_timeoutFzMax requests, shutting down: %sz!Parent changed, shutting down: %s)&� isinstance�wsgir r�iscoroutinefunctionr Z AppRunner�app�RuntimeError�format�cfgZ accesslogr)r0� keepalive�_get_valid_log_formatr1�setupZis_ssl�_create_ssl_context�AssertionError�server�socketsZSockSiteZgraceful_timeout�start�os�getpid�alive�notifyZrequests_countZmax_requests�infoZppid�getppid�_wait_next_notify� BaseException�cleanup)r�runnerr8r6r0�ctxrA�sock�site�pidZcntrrrr&Asb zGunicornWebWorker._runzasyncio.Future[bool]cCs>|j�|j}|dk st�|j�|_}|jjd|j|�|S)Ng�?)�_notify_waiter_doner"r@� create_futurer� call_later)rr"�waiterrrrrJ�sz#GunicornWebWorker._wait_next_notify)rUrcCs4|dkr|j}|dk r t|d�||jkr0d|_dS)NT)rr)rrUrrrrR�s z%GunicornWebWorker._notify_waiter_donecCs�|jjtj|jtjd�|jjtj|jtjd�|jjtj|jtjd�|jjtj|j tjd�|jjtj |jtj d�|jjtj|j tjd�tjtjd�tjtj d�tjdkr�tjtjtj�dS)NF��)rVrW)r"�add_signal_handler�signal�SIGQUIT�handle_quit�SIGTERMZhandle_exit�SIGINT�SIGWINCHZhandle_winch�SIGUSR1Zhandle_usr1�SIGABRT�handle_abort�siginterruptr,�version_info�SIGCHLD�SIG_DFL)rrrr�init_signals�s zGunicornWebWorker.init_signals)�sig�framercCsd|_|jj|�|j�dS)NF)rFr;Z worker_intrR)rrgrhrrrr[�szGunicornWebWorker.handle_quitcCs&d|_d|_|jj|�tjd�dS)NFr)rFrr;Zworker_abortr,r-)rrgrhrrrra�szGunicornWebWorker.handle_abort� SSLContext)r;rcCs\tdkrtd��tj|j�}|j|j|j�|j|_|j rF|j |j �|jrX|j|j�|S)z~Creates SSLContext instance for usage in asyncio.create_server. See ssl.SSLSocket.__init__ for more details. NzSSL is not supported.) �sslr9ri�ssl_version�load_cert_chain�certfile�keyfile� cert_reqs�verify_mode�ca_certs�load_verify_locations�ciphers�set_ciphers)r;rNrrrr?�sz%GunicornWebWorker._create_ssl_context)� source_formatrcCs.||jkr|jStjd|�r&td��n|SdS)Nz%$[^$]+\)z�Gunicorn's style options in form of `%(name)s` are not supported for the log formatting. Please use aiohttp's format specification to configure access log formatting: http://docs.aiohttp.org/en/stable/logging.html#format-specification)�DEFAULT_GUNICORN_LOG_FORMAT�DEFAULT_AIOHTTP_LOG_FORMAT�re�search� ValueError)rrurrrr=�s z'GunicornWebWorker._get_valid_log_format)N)�__name__� __module__�__qualname__rZ LOG_FORMATrw�GunicornAccessLogFormat�defaultrvrrr$r.r&rJrrRrf�intrr[ra�staticmethodr?�strr=� __classcell__rr)rrr s B ( cs"eZdZdd��fdd�Z�ZS)rN)rcs0ddl}tj�j�tj|j��t�j�dS)Nr)�uvlooprrr �set_event_loop_policy�EventLoopPolicyrr$)rr�)rrrr$�sz$GunicornUVLoopWebWorker.init_process)r{r|r}r$r�rr)rrr�scs"eZdZdd��fdd�Z�ZS)rN)rcs0ddl}tj�j�tj|j��t�j�dS)Nr)�tokiorrr r�r�rr$)rr�)rrrr$sz#GunicornTokioWebWorker.init_process)r{r|r}r$r�rr)rrrs)rrr)$�__doc__rrDrxrYr,�typesr�typingrrrrrZgunicorn.configrr~Zgunicorn.workersr Zaiohttpr ZhelpersrZweb_appr Zweb_logrrjri�ImportError�object�__all__ZWorkerrrrrrrr�s0 Q