i d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m
Z
m Z m Z m
Z
ddlmZ ddlZddlmZmZ dZd Z G d
d ej Z G d d
ej j ZdS )z>An ISAPI extension base class implemented using a thread-pool. N)
OVERLAPPED)INFINITE) CloseHandleCreateIoCompletionPortGetQueuedCompletionStatusPostQueuedCompletionStatus)SetThreadToken)ExtensionErrorisapicon c e Zd Zd Zd Zd ZdS ) WorkerThreadc r d| _ || _ || _ t j | d d S )NFT)daemon)running io_req_port extension threadingThread__init__)selfr r s FC:\PYTHON\_runtimes\venv\Lib\site-packages\isapi/threaded_extension.pyr zWorkerThread.__init__ sJ &"!! "
c d| _ | j ryt | j t \ }}}}|t k r|d S | j j | }|t d| d ||||| | j wd S d S )NTz
Bad request '') r r r r ISAPI_SHUTDOWNr dispatch_mapget RuntimeError)r errCodebyteskey
overlapped
dispatchers r runzWorkerThread.run' s l 8.G (/ / +GUC n$$); 488==J!"#93#9#9#9::: JwsJ 7 7 7 l 8 8 8 8 8r c : | j | d S N)r Dispatch)r cblocks r call_handlerzWorkerThread.call_handler7 s '''''r N)__name__
__module__ __qualname__r r& r+ r r r r sA
8 8 8 ( ( ( ( (r r c D e Zd ZdZdZdZd Zd Zd Zd Z d Z
d Z d
Z d S ) ThreadPoolExtensionzz:ThreadPoolExtension.TerminateExtension..p s% 6661 6Q666r )
r4 r r r r timeworker_shutdown_waitsleepr r )r statusrC end_timealives r TerminateExtensionz&ThreadPoolExtension.TerminateExtensionb s l # #F "FNNl R RF &t'7ND Q Q Q Q 9;;!:T!AA 7y{{X%% JsOOO66666E 7 D$%%%%%r c |j }| }t d | | | n # | | Y nxY wt d d d S # t d d w xY wr( )rE GetImpersonationTokenr r) HandleDispatchError)r r! r" r# r$ rG
hRequestTokens r r6 z&ThreadPoolExtension.DispatchConnectionw s ")
%;;==
t]+++ '
8
m,,,,
8(( 77777
4 & & & & &N4 & & & &s A A2 A A2 2Bc t d )a Overridden by the sub-class to handle connection requests.
This class creates a thread-pool using a Windows completion port,
and dispatches requests via this port. Sub-classes can generally
implement each connection request using blocking reads and writes, and
the thread-pool will still provide decent response to the end user.
The sub-class can set a max_workers attribute (default is 20). Note
that this generally does *not* mean 20 threads will all be concurrently
running, via the magic of Windows completion ports.
There is no default implementation - sub-classes must implement this.
z$sub-classes should override Dispatch)NotImplementedError)r ecbs r r) z ThreadPoolExtension.Dispatch s ""HIIIr c & t j |_ t j \ }}}d} ddl}| ddd t | t d| t j || t j
|| z }| }t d |
d | |
| | nY# t $ r Y nM t d
t j t d t j ||| Y nxY wd}| dS # d}| w xY w) zHandles errors in the Dispatch method.
When a Dispatch method call fails, this method is called to handle
the exception. The default implementation formats the traceback
in the browser.
Nr z200 OKzContent-type: text/html
F)filez+Traceback (most recent call last):
z{}{} z#FAILED to render the error message!zORIGINAL extension error:)r HSE_STATUS_ERRORHttpStatusCodesysexc_infohtmlSendResponseHeadersprint traceback format_tbformat_exception_onlypopformatescapejoinr
print_excprint_exceptionDoneWithSession) r r\ exc_typexc_valexc_tblimitrd listbolds r rX z'ThreadPoolExtension.HandleDispatchError s & 6#&<>> &! "
D '' ? 3C#NNNN *E 3GWEEF xxzz,33 BGGDMM22 D)) "
D;<<<#%%%1222)'7FCCCCC F ! ! ! ! ! F ! ! ! !s+ CD E8
E E8 AE E8 8FN)
r, r- r. __doc__r> rP r r< rH rU r6 r) rX r/ r r r1 r1 ? s BBK
( ( (+ + + & & &* ' ' ' J J J ," ," ," ," ,"r r1 )rw rb r rO rg
pywintypesr
win32eventr win32filer r r r
win32securityr isapi.simpler9 r
r r5 r r r r: r; r1 r/ r r r} sJ D D
! ! ! ! ! ! ) ( ( ( ( ( * * * * * * * *
( ( ( ( (9# ( ( (HB" B" B" B" B"%,6 B" B" B" B" B"r