| Server IP : 182.53.201.61 / Your IP : 216.73.217.175 Web Server : Apache/2.2.15 (Fedora) System : Linux km10.dyndns.org 2.6.31.5-127.fc12.i686.PAE #1 SMP Sat Nov 7 21:25:57 EST 2009 i686 User : apache ( 48) PHP Version : 5.3.3 Disable Function : NONE MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /proc/11490/root/usr/lib/python2.6/site-packages/BitTorrent/ |
Upload File : |
Cc @ s d d k Z d d k 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 l Z d d k l Z d d k l Z l Z l Z d d k l Z y8 d d k l Z l Z l Z l Z l Z l Z d
Z WnG e j
o; d d k! l Z l Z l Z l Z l Z l Z d Z n Xe i" d d d
Z# d e$ f d YZ% d e$ f d YZ& d Z' d e$ f d YZ( d S( iN( t insort( t StringIO( t print_exc( t EWOULDBLOCKt ENOBUFSt EINTR( t bttime( t WARNINGt CRITICALt FAQ_URL( t Deferred( t pollt errort POLLINt POLLOUTt POLLERRt POLLHUPi i t iii t Handlerc B s> e Z d Z d Z d Z d Z d Z d Z RS( c C s | i | d S( N( t connection_made( t selft s( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt connection_started* s c C s d S( N( ( R R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR , s c C s d S( N( ( R R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt connection_lost/ s c C s d S( N( ( R t addrt exception( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt connection_failed3 s c C s d S( N( ( R R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt connection_flushed6 s c C s d S( N( ( R R t datagram( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt data_came_in8 s ( t __name__t
__module__R R R R R R ( ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR & s t SingleSocketc B sA e Z d d Z d Z d Z d Z d Z d Z RS( c C s# | | _ | | _ | | _ g | _ t | _ | i | _ t | _ | | _ d | _ d | _ t
| t o
| | _ n d } y | i i } Wnh t i j
oY } | d d j o? | d j o2 y | i i } Wq t i j
o } q Xqn Xt | | \ | _ | _ d S( Ni ik ( NN( t rawservert sockett handlert bufferR t last_hitt filenot Falset connectedt contextt Nonet ipt portt
isinstancet
basestringt getpeernameR t getsocknamet max( R R! t sockR# R) R t peernamet e( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt __init__> s,
c C s | i } d | _ g | _ | i i | i =| i i i | d | _ | i i d o | i
t i t i t
n | i d S( Nt close_with_rst( R" R* R$ R! t single_socketsR& R t
unregisterR# t configt
setsockoptt
SOL_SOCKETt SO_LINGERt NOLINGERt close( R R2 ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR> g s c C s | i i | d S( N( R" t shutdown( R t val( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR? r s c C s t | i d j S( Ni ( t lenR$ ( R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt
is_flushedu s c C sO | i d j p t | i i | t | i d j o | i n d S( Ni ( R" R* t AssertionErrorR$ t appendRA t try_write( R R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt writex s c C s/ | i o y x | i g j oo | i i | i d } | t | i d j o. | d j o | i d | | i d <n Pn | i d =q WWq t i j
o: } | \ } } | t j o | i i i | d Sq Xn | i g j o | i i
i | i t n | i i
i | i t t
B d S( Ni ( R( R$ R" t sendRA R R R! t dead_from_writeRD R t registerR
R ( R t amountR4 t codet msg( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyRE ~ s$
N( R R R* R5 R> R? RB RF RE ( ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR < s ) c C s | GHd S( N( ( t levelt message( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt default_error_handler s t RawServerc B s e Z e e d d Z d Z d Z d Z d d! d Z d" d! d Z
d Z d Z e
e Z d e d d
Z e
e Z d e d d Z e
e Z d! d Z d! d
Z d Z d Z d! d! e d Z d Z d Z d! d! e d Z d Z d! d! d! d Z d Z d Z d Z d Z d Z d d Z d! d! d Z! d Z" d Z# RS(# i c C s | | _ | | _ t | _ h | _ h | _ g | _ | | _ | | _ | | _ g | _ g | _
h | _ h | _ h t
d 6| _ t i | _ g | _ | i | i | d t i i d o d | _ | i n* t i | _ | i i | i d t d S( Nt timeout_check_intervalt wini ( NN( R9 t tosR R7 t udp_socketsRH t doneflagt noisyt errorfunct funcst externally_added_taskst listening_handlerst
serversocketst TrueR* t
live_contextst threadt get_identt identt to_startt add_taskt scan_for_timeoutst syst platformt
startswitht wakeupfdst _wakeupt ost pipeRI R
( R RU R9 RV RW RS ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR5 s, c C s | i | i d d S( Ni ( Rb Rh ( R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyRh s c C s t | i | <d S( N( R\ R] ( R R) ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt add_context s c C sJ | i | =g } | i D]" } | d | j o | | q q ~ | _ d S( Ni ( R] RX ( R R) t _[1]t x( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt remove_context s
c C s t i | i j p t t | t j p t | t j p t | | i j o' t | i t
| | | | f n d S( N( R^ R_ R` RC t typet listt tupleR] R RX R ( R t funct delayt argsR) ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyRb s -c C s| t | t j p t | t j p t | i i | | | | f | i d d j o t i | i d d n d S( Ni t X(
Ro Rp Rq RC RY RD Rg R* Ri RF ( R Rr Rs Rt R) ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt external_add_task s - c C s | i | i | i d t | i d } g } xm g } | i i D]' } | | i i j o | | qK qK ~ D]' } | i | j o | i | qy qy Wx/ | D]' } | i
d j o | i | q q Wd S( NRQ t socket_timeout(
Rb Rc R9 R R7 t valuesRT t keysR% RD R" R* t
_close_socket( R t tt tokillRl R t k( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyRc s E c C sC t i t i t i } | i d | i | | i d | S( Ni i ( R" t AF_UNIXt SOCK_STREAMt setblockingt bindt listen( t filenamet server( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt create_unixserversocket s
t c C s t i t i t i } | o- t i d j o | i t i t i d n | i d | d j o+ y | i t i t i
| Wq q Xn | i | | f | i d | S( Nt nti i i (
R" t AF_INETR Ri t nameR: R; t SO_REUSEADDRR t
IPPROTO_IPt IP_TOSR R ( R, R t reuseRS R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt create_serversocket s
c C s t i t i t i } | o- t i d j o | i t i t i d n | i d | d j o+ y | i t i t i
| Wq q Xn | i | | f | S( NR i i ( R" R t
SOCK_DGRAMRi R R: R; R R R R R ( R, R R RS R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt create_udpsocket s
c C sC | | f | i | i <| | i | i <| i i | t d S( N( RZ R& R[ R RI R
( R t serversocketR# R) ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt start_listening s c C se | | f | i | i <t | | | | } | | i | i <d | i | <| i i | t d S( Ni ( RZ R& R R7 RT R RI R
( R R R# R) t nss( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt start_listening_udp s
c C s4 | i | i =| i | i =| i i | d S( N( RZ R& R[ R R8 ( R R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt stop_listening s c C s | i | i =| i | i =g } | i i D]! } | i | j o | | q4 q4 ~ } | i | d =| i i | d S( Ni ( RZ R& R7 RT Ry R" R R8 ( R R Rl R t l( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt stop_listening_udp s
>c C sA t i t i t i } | i d | o | i d } | o | i | d f n | i d j o. y | i t i t i | i Wq q Xn y | i
| WnV t i j
o | i n5 t
j
o( } | i t i t | n X| i i | t t | | | | | } | | i | i <| S( Ni R ( R" R R R R9 R RS R: R R t
connect_exR R> t Exceptiont strR RI R
R R7 R& ( R t dnsR# R) t do_bindR2 t bindaddrR4 R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt start_connection s,
c C s d S( N( ( R R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt _add_pending_connection- s c C s d S( N( ( R R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt _remove_pending_connection0 s c C s- | i i d | | | | f | i t S( Ni ( Ra t insertt _start_connectionR\ ( R R R# R) R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt async_start_connection3 s
c C sp | i i \ } } } } y | i | | | | } Wn% t j
o } | i | | n X| i | d S( N( Ra t popR R R R ( R R R# R) R R R4 ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR 8 s c C sU | i d | i i | t t | | | | | | f } | | i | i <| S( Ni ( R R RI R
R R7 R& ( R R2 R# R) R+ R, R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt wrap_socketA s
c C s t i t i | i d S( N( t signalt SIGINTt _handler( R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt install_sigint_handlerI s c C s0 | i | i i d t i t i t i d S( Ni ( Rv RU t setR R t default_int_handler( R t signumt frame( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR L s c
C s x| D]x\ } } | | i j o| i | } | t t B@d j os y | i i | | i Wn8 t i j
o) } | i t t
d t | n X| i t t
d q| i
| \ } } y | i \ } } Wn t i j
o } q n Xyk | i d t | | | | | }
|
| i | i <| i i | t | i | i |
f d | Wqt i j
o) } | i t t
d t | qXq | i i | } | d j o/ | | i d j o t i | d q q n t | _ | t @o | i | q n | t t B@o t | _ y | i i! d \ } } WnE t i j
o6 } | \ } }
| t" j o | i | q q n X| d j o% | i# i$ | o | i | q)| i# i$ | p# | i | i% i& | | f | q)| i | i% i& | | f | n | t' @oK | i d j o; | i( | i) o | i | i% i* | f | qq q Wd S( Ni s/ failed to unregister or close server socket: %ss lost server socketR) s$ Error handling accepted connection: i i R (+ R[ R R R R8 R> R" R RW R t _R R RZ t acceptR R R7 R& RI R
t _make_wrapped_callR t getR* Rg Ri t readR\ R( Rz R R% t recvfromR RT t has_keyR# R R RE RB R ( R t eventsR2 t eventR R4 R# R) t newsockR R t dataRK RL ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt _handle_eventsR sr
%
!
c C s5 x. | i o# | i i d } | i | q Wd S( Ni ( RY R Rb ( R t task( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt _pop_externally_added s
c C sF d } t i | _ x* | i i o | o | i } q Wd S( Ni ( R^ R_ R` RU t isSett listen_once( R t ret( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt listen_forever s
g eAc
C s y
| i | i o | i d d t } n | d j o
d } n | i i | t } | i i o d Sx^ | i oS | i d d t j o8 | i i d \ } } } } | i | | d | qx W| i | i
| | i i o d S| i Wnt j
o } | i i o d Sd } t
| d o | d } n | } | t j o/ t d t i | i t t d t d S| t f j o n | i t t | d St j
o t d St } t d | | i t | i d SXd S( Ni R) t __getitem__t filesG Have to exit due to the TCP stack flaking out. Please see the FAQ at %si( R RX R R t timemultRU R R R t _close_deadR R R* t hasattrR R Rd t stderrRW R R R R R t KeyboardInterruptR t getvalue(
R t periodR t garbageRr Rt R) R4 RK R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR sV
%
c C s y | | Wn t j
o
n t j
o } | d j o
| i } n | i o= | d j o0 t } t d | | i t | i n | d j o | i
| q n Xd S( NR ( R R R* R) RV R R RW R R t
got_exception( R t functionRt R" R) R4 R ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR s
c C sf x_ t | i d j oH | i } g | _ x/ | D]' } | i d j o | i | q2 q2 Wq Wd S( Ni ( RA RH R" R* Rz ( R t oldR ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyR s c C s | i i } | i d o | i i t i t i t n | i i | i i | | i
| =d | _ | i | i
i | f | d | _
d S( NR6 ( R" R& R9 R: R; R< R= R> R R8 R7 R* R R# R ( R R R2 ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyRz s
( N( ($ R R R\ RO R5 Rh Rk Rn R* Rb Rv Rc R t staticmethodR' R R R R R R R R R R R R R R R R R R R R Rz ( ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyRP sB
A 3 () Ri Rd R" R t structR^ t bisectR t cStringIOR t tracebackR t errnoR R R t BitTorrent.platformR t
BitTorrentR R R t BitTorrent.deferR
t selectR R R
R R R R t ImportErrort BitTorrent.selectpollt packR= t objectR R RO RP ( ( ( s8 /usr/lib/python2.6/site-packages/BitTorrent/RawServer.pyt <module>
s. .
. W