Ñò
ô†³Kc
@ s d Z d d k Z d d k Z d d k Z d d k Z d d k l Z d d k l Z d d k l
Z
d d k l Z l
Z
d d k l Z l 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 i 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.
iÿÿÿÿN( 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 ( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt __init__¹ s c C s` d | j o | d d g ƒ d g S| i d ƒ d j o | i | | ƒ S| i | | ƒ 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( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt __call__¼ s
c C s‘ | d d g ƒ t | ƒ } | i d ƒ o | d } n d } | d } | i } t i ƒ } | i i ƒ } | i d d „ ƒ g } x™ | D]‘ \ }
\ } } t ƒ }
| i |
ƒ | o t
| ƒ |
_ n
d |
_ |
|
_ t
| | ƒ |
_ t |
i ƒ |
_ | |
_ t |
ƒ |
_ qŽ Wt i d d
d | d t | i ƒ d
t | ƒ d | d d | d | i d | d t ƒ d | i ƒ ƒ
} | g S( Ns 200 OKs Content-types text/htmlR s paste.httpserver.thread_poolt keyc S s | d d S( i i ( ( t v( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt Ò s 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 nowR2 R R( t time_startedt worker_environt threadt page( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyR Å sF
c C sÌ | i p t i d ƒ } | | | ƒ St | ƒ } t | d ƒ } | d } | | i j o! t i d | ƒ } | | | ƒ S| i | ƒ | d p d } t i 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( R4 R ( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyR ï s"
( t __name__t
__module__t __doc__t FalseR R R R ( ( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyR ¬ s
*c C sc t t d ƒ p d St i ƒ } | | j o d S| | } t ƒ } t i | d | ƒ| i ƒ 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! RH R R. t print_stackt getvalue( R( t framest framet out( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyR- s
s paste.httpserver.thread_poolc C s | d j o t i d d d d ƒ Sg } xâ t | i ƒ ƒ D]Î \ } } | t j o q= n yd | i ƒ | j o t | ƒ } n | i t i d t i
t | ƒ ƒ d t i
t | ƒ ƒ ƒ ƒ Wq= t j
o; } | i t i d t i
t | ƒ ƒ d d | ƒ ƒ q= Xq= Wd i
| ƒ S( NR s ---t values- No environment registered for this thread yets Error in repr(): %st ( R! t environ_templateR0 t sortedR$ t hide_keyst uppert reprR& t cgit escapet strt Exceptiont join( R t environ_rowsR RQ t e( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt format_environ s,
c C sç | d j o7 d t | d d ƒ t | d ƒ d | d f } np | d j o" d t | d ƒ | d f } nA | d j o d | } n& | d j o d | } n d | } | d j o | S| d j o 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( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyR) , s"
c C s0 t | ƒ d j o | d d | d S| Sd S( Ni< i( s ...iöÿÿÿ( R1 ( t s( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyR+ B s c C s# d d k l } t d | | ƒ ƒ S( Niÿÿÿÿ( t asboolR ( t paste.deploy.convertersRc R ( t global_confR Rc ( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt make_watch_threadsH s i c s t ˆ ƒ ‰ ‡ f d † } | S( Nc sw d d k } ˆ o t i ˆ ƒ n9 d } x/ d | | i ƒ f GHt i d ƒ | d 7} q- | d d
g ƒ d ˆ g S( Niÿÿÿÿi s I'm alive %s (%s)i
i s 200 OKs content-types
text/plains OK, paused %s seconds( s content-types
text/plain( R8 R" t sleepR ( R R R8 t count( t pause( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt bad_appO s
( R> ( Re Ri Rj ( ( Ri s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt make_bad_appM s ( RF RK RX R" R. t cStringIOR R8 R t pasteR t
paste.requestR R t paste.util.templateR R R/ t objectR R- RU R_ R) R+ RG Rf Rk ( ( ( s< /usr/lib/python2.6/site-packages/paste/debug/watchthreads.pyt s( ›W