ÿØÿà JFIF ÿþ
ÿÛ C
ÿÛ C ÿÀ ÿÄ ÿÄ " #QrÿÄ ÿÄ & 1! A"2qQaáÿÚ ? Øy,æ/3JæݹÈß²Ø5êXw²±ÉyR¾I0ó2PI ¾IÌÚiMö¯þrìN&"KgX:íµnTJnLK
@!-ý ùúmë;ºgµ&ó±hw¯Õ@Ü 9ñ-ë.²1<yà¹ïQÐUÛ?.¦èûbß±©Ö«Âw*V) `$ bØÔëXÖ-ËTÜíGÚ3ð«g §¯Jx U/ÂÅv_s(Hÿ @TñJÑãõçn!ÈgfbÓc:él[ðQe 9ÀPLbÃãCµm[5¿ç'ªjglåÛí_§Úõl-;"PkÞÞÁQâ¼_Ñ^¢S x?"¸¦ùYé¨ÒOÈ q`~~ÚtËU¹CÚêV I1Áß_ÿÙ
aNc @ s d Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m
Z
d d l m Z m
Z
d d l m Z m Z e d d d
Z d e f d YZ d
Z d g Z d Z d Z d Z e d Z e j e _ d d Z d S( sv
Watches the key ``paste.httpserver.thread_pool`` to see how many
threads there are and report on any wedged threads.
iN( t StringIO( t get_ident( t httpexceptions( t
construct_urlt parse_formvars( t HTMLTemplatet bunchsv
{{title}}
{{title}}
{{if kill_thread_id}}
Thread {{kill_thread_id}} killed
{{endif}}
Pool size: {{nworkers}}
{{if actual_workers > nworkers}}
+ {{actual_workers-nworkers}} extra
{{endif}}
({{nworkers_used}} used including current request)
idle: {{len(track_threads["idle"])}},
busy: {{len(track_threads["busy"])}},
hung: {{len(track_threads["hung"])}},
dying: {{len(track_threads["dying"])}},
zombie: {{len(track_threads["zombie"])}}
{{for thread in threads}}
|
Thread
{{if thread.thread_id == this_thread_id}}
(this request)
{{endif}} |
{{thread.thread_id}}
{{if allow_kill}}
{{endif}}
|
| Time processing request |
{{thread.time_html|html}} |
| URI |
{{if thread.uri == 'unknown'}}
unknown
{{else}}{{thread.uri_short}}
{{endif}}
|
▸ Show environ
{{if thread.environ:}}
{{for loop, item in looper(sorted(thread.environ.items()))}}
{{py:key, value=item}}
| {{key}} |
{{value}} |
{{endfor}}
{{else}}
Thread is in process of starting
{{endif}}
|
{{endfor}}
t names watchthreads.page_templatet WatchThreadsc B s5 e Z d Z e d Z d Z d Z d Z RS( si
Application that watches the threads in ``paste.httpserver``,
showing the length each thread has been working on a request.
If allow_kill is true, then you can kill errant threads through
this application.
This application can expose private information (specifically in
the environment, like cookies), so it should be protected.
c C s
| | _ d S( N( t
allow_kill( t selfR ( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt __init__ s c C s\ d | k r# | d d g d g S| j d d k rH | j | | S| j | | Sd S( Ns paste.httpserver.thread_pools
403 Forbiddens Content-types
text/plainsC You must use the threaded Paste HTTP server to use this applicationt PATH_INFOs /kill( s Content-types
text/plain( t gett killt show( R
t environt start_response( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt __call__ s c C s | d d g t | } | j d r8 | d } n d } | d } | j } t j } | j j } | j d d g } x | D] \ }
\ } } t }
| j |
| r t
| |
_ n d |
_ |
|
_ t
| | |
_ t |
j |
_ | |
_ t |
|
_ q Wt j d d
d | d t | j d
t | d | d d | d | j d | d t d | j
} | g S( Ns 200 OKs Content-types text/htmlR s paste.httpserver.thread_poolt keyc S s | d d S( Ni i ( ( t v( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt t t unknownt titles Thread Pool Worker Trackert nworkerst actual_workerst
nworkers_usedt script_namet SCRIPT_NAMEt kill_thread_idR t threadst this_thread_idt
track_threads( s Content-types text/html( R R
t NoneR t timet worker_trackert itemst sortR t appendR t urit thread_idt format_timet time_htmlt shortent uri_shortR t traceback_threadt tracebackt
page_templatet
substitutet lent workersR R R! ( R
R R t formR t thread_poolR t nowR3 R R) t time_startedt worker_environt threadt page( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyR sD
c C s | j s% t j d } | | | St | } t | d } | d } | | j k rz t j d | } | | | S| j | | d p d } t j d d | d | f g } | | | S(
Ns? Killing threads has not been enabled. Shame on you for trying!R) s paste.httpserver.thread_poolsB You tried to kill thread %s, but it is not working on any requestsR t /t headerst Locations ?kill=%s( R R t
HTTPForbiddenR t intR$ t PreconditionFailedt kill_workert HTTPFound( R
R R t exct varsR) R5 R ( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyR s"
( t __name__t
__module__t __doc__t FalseR R R R ( ( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyR s
*c C s_ t t d s d St j } | | k r/ d S| | } t } t j | d | | j S( sf
Returns a plain-text traceback of the given thread, or None if it
can't get a traceback.
t _current_framest fileN( t hasattrt sysR" RI R R/ t print_stackt getvalue( R) t framest framet out( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyR. s
s paste.httpserver.thread_poolc C s | d k r" t j d d d d Sg } x t | j D] \ } } | t k rY q; n yb | j | k r} t | } n | j t j d t j
t | d t j
t | Wq; t k
r} | j t j d t j
t | d d | q; Xq; Wd j
| S( NR s ---t values- No environment registered for this thread yets Error in repr(): %sR ( R" t environ_templateR1 t sortedR% t hide_keyst uppert reprR' t cgit escapet strt Exceptiont join( R t environ_rowsR RR t e( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt format_environ s* c C s | d k rB d t | d d t | d d | d f } ni | d k ro d t | d | d f } n< | d k r d | } n# | d k r d | } n
d | } | d k r | S| d k r d
| Sd | Sd S(
Ni< s %i:%02i:%02iix s %i:%02is %i seci s %0.1f secs %0.2f seci s# %ss; %si ( R? ( t time_lengtht time_string( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyR* , s"
c C s. t | d k r& | d d | d S| Sd S( Ni< i( s ...i( R2 ( t s( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyR, B s c C s# d d l m } t d | | S( Ni( t asboolR ( t paste.deploy.convertersRc R ( t global_confR Rc ( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt make_watch_threadsH s i c s t f d } | S( Nc sv d d l } r" t j n9 d } x0 d | | j f GHt j d | d 7} q+ W| d d
g d g S( Nii s I'm alive %s (%s)i
i s 200 OKs content-types
text/plains OK, paused %s seconds( s content-types
text/plain( R9 R# t sleepR ( R R R9 t count( t pause( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt bad_appO s
( R? ( Re Ri Rj ( ( Ri sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt make_bad_appM s ( RG RL RX R# R/ t cStringIOR R9 R t pasteR t
paste.requestR R t paste.util.templateR R R0 t objectR R. RU R_ R* R, RH Rf Rk ( ( ( sI /opt/alt/python27/lib/python2.7/site-packages/paste/debug/watchthreads.pyt s( W