| 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 : /usr/lib/python2.6/site-packages/khashmir/ |
Upload File : |
Cc @ s d d k Z d d k l Z d d k l Z d d k l Z d d k Z d d k l Z l
Z
d d k l Z d d k
l Z l Z d d k Td d k l Z d d
k l Z l Z d d k l Z d d k l Z l Z l Z l Z d d k Z d d k Z d d k Z d d k Z d d
k! l" Z" l# Z# d d k$ l% Z% d d k& l' Z' d d k l( Z( d d k) l* Z* l+ Z+ e i, d Z- d e. f d YZ/ d Z0 d f d YZ1 d e1 f d YZ2 d e2 f d YZ3 d e3 f d YZ4 d S( iN( t
gethostbyname( t bttime( t sha( t common_optionst rare_options( t RawServer( t KTablet K( t *( t KStore( t newIDt newIDInRange( t packNodes( t FindNodet GetValuet
KeyExpirert
StoreValue( t bencodet bdecode( t Deferred( t randrange( t sample( t Eventt Threads. [0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}t KhashmirDBExceptc B s e Z RS( ( t __name__t
__module__( ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR , s c C s d S( N( ( t bytes( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt foo/ s t KhashmirBasec B s e Z e Z d d e d e h e d 6d d 6d Z e d Z d Z
d Z d Z d d
Z
d Z d Z d d
Z d d Z d d Z d d Z e d Z d d Z d e d Z d d Z d Z d Z d Z RS( i t pausei t max_rate_periodc
C s | o
| | _ n[ t | _ t g }
t t D] } |
| d | d f q2 ~
} t | i | | _ | | _ d | _ | | _
| i | | | | | d S( Ni i ( t rawserverR t flagt dictR R R t max_ul_ratet Nonet sockett configt setup(
t selft hostt portt data_dirR R# t
checkpointt errfunct rlcountR& t _[1]t xt d( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt __init__5 s
9 c C s/ | | _ | | _ | | _ t | _ h | _ | i i | i | i t | _ t
i | | i | i f | i | i i | i
| i | | _ | i | i i | i | i t | _ t | i | i i | i d d | o? | i i | i d d t f | i i | i d d n d S( Nt forcei i c S s | S( ( ( t a( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt <lambda>O s i< ( i ( R) R* t ddirR t storet pingcacheR t create_udpsockett FalseR% t krpct
hostbrokert add_taskR# R& t udpt _loadt start_listening_udpt timet lastR t refreshTablet findCloseNodest TrueR, ( R( R) R* R+ R. R, ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR' A s !?
"c C s" | i | i i } | | _ | S( N( t _NodeR> t connectionForAddrt table( R( t n( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt NodeR s c C s8 | i d j o$ | i i | i | i i n d S( N( R% R$ R t stop_listening_udpt close( R( ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt __del__W s c C s t } y7 t t i i | i d d i } t | } Wn t } n X| d } t } | i
| i i i
| | i | i | _ t | i | _ | o | i | d n d S( Nt
routing_tablet rt idt rt( R: t opent ost patht joinR6 t readR R
RE RF R> RG t initR) R* t nodeR RH t _loadRoutingTable( R( t do_loadt sR" RP ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR? \ s '
-i c
C s h } | i i | d <| i | d <yB t t i i | i d d } | i t | | i
Wn$ t j
o } d Gt | GHn X| o@ | i
i | i t t t i d t t i d d n d S(
NRP RQ RN t wbs! >>> unable to dump routing table!g?g?i ( i ( RX RP t _dumpRoutingTableRR RS RT RU R6 t writeR RL t Exceptiont strR R= R, R t intt constt CHECKPOINT_INTERVAL( R( t autoR1 t ft e( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR, m s !c C sF x? | D]7 } | i i | } | i i | d d d t q Wd S( s
load routing table nodes from database
it's usually a good idea to call refreshTable(force=1) after loading the table
t contactedi t nocheckN( RJ t initWithDictRH t
insertNodeRE ( R( t nodest recRI ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyRY s c C sp g } xc | i i D]U } xL | i D]A } | i h | i d 6| i d 6| i d 6t | i d 6 q# Wq W| S( s>
save routing table nodes to the database
RP R) R* t age( RH t bucketst lt appendRP R) R* Ra Rm ( R( Ro t bucketRX ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR] s
Cc C sR | i i t i | | } y | i | d | Wn t i j
o n Xd S( sS
ping this node and add the contact info to the table on pong!
t callbackN( RJ RW Rb t NULL_IDt sendPingR; t KRPCSelfNodeError( R( R) R* Rr RI ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt _addContact s
c sV t i | o i | | n/ | | f d } t d | } | i d S( sS
ping this node and add the contact info to the table on pong!
c s/ t | } i i i d | | f d S( Ni ( R R t external_add_taskRv ( t ipR* ( R( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt go s t targetN( t ip_patt matchRv R t start( R( Rx R* Rr Ry t t( ( R( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt
addContact s
c
C s. | i i | d t } g } | D] } | i o | | q# q# ~ } t | d j o- t | d | i i | d t d } n t } | o | i | | n | i | t | d j o% | d i
| j o | i | n; t | | | i | i
i } | i
i | i d | f d S( sR returns the contact info for node, or the k closest nodes, from the global table t invalidi i i N( RH t findNodesRE R t lenR R: R t addCallbackst addCallbackRP Rr R
R R= Rw t goWithNodes(
R( RP Rr t errbackRk R/ R0 Ro R1 t state( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt findNode s /-
' i c C s | i i | d | } | o | | j o | i p | i | | | q | i i | i g } t | d j p | o' | i | | f | | i | i <q n d S( s
insert a node in our local table, pinging oldest contact in bucket, if necessary
If all you have is a host/port, then use addContact, which calls this method after
receiving the PONG from the remote node. The reason for the seperation is we can't insert
a node into the table without it's peer-ID. That means of course the node passed into this
method needs to be a properly formed Node object with a valid ID.
Rg i
N( RH Rj t inPingt checkOldNodeR8 t getRP R Rp ( R( RI Rg t oldRo ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyRj s
c s d | | | f d } | | | f d } y | i i i } Wn t i j
o n X| i | | d S( Nc S sV | d d j o | d d j o d S| d d j o | d d j o d Sd Sd S( Ni i i( ( R4 t b( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt cmp s
""c s | i d j oF i i | i g } | i | oJ | d \ } } | o. | o' | d | | f g } | } | } q n i i | | } | ob | | j oU i | | y+ i | i i | i < i | i =WqRt j
o qRXq| oG i | i =| i x* | D] } i | d | d q,Wqnj i i | i g } | o i | i =n i | | x& | D] } i | d | d qWd S( s* called if the pinged node never responds i i i N(
t failsR8 R RP t sortRH t replaceStaleNodeR t KeyErrorRj ( R" R t newRg Ro RI t nct oRX ( R( R ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt _staleNodeHandler s<
$ c s i i | t i | | i i | i g } | i x& | D] } i | d | d qO Wy i | i =Wn t j
o n Xd S( s- called when we get a pong from the old node i i N( RH Rj RE R8 R RP R R ( R" R R Rg Ro RX ( R( R ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt _notStaleNodeHandler s
( t pingRX RP R; Ru R ( R( R R Rg R R t df( ( R( R s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR s ! c sv y | i i i } Wn t i j
o nB X| i | f d } | i | d } | i | | d S( s!
ping a node
c sy | d } | d } h | d d 6} | d | d <| d | d < i i | } | i | | o | n d S( Nt _krpc_sendert rspRP i R) i R* ( RJ Ri Rj ( R" RX RH Rr R t senderRI ( R( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt _pongHandler# s
c S s | o | n d S( N( ( t errRX RH Rr ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt _defaultPong- s N( R RX RP R; Ru RH R ( R( RX Rr R R R ( ( R( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyRt s
c C s | S( ( ( R4 ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR5 3 s c C s | i d pF | i i d t t | i i d d d } | i | | n | oe | i d p | i n | i i | i t
t t i
d t t i
d d t f n d S( s
This does a findNode on the ID one away from our own.
This will allow us to populate our table with nodes on our network closest to our own.
This is called as soon as we start up with an empty table
R ii i g?g?c S s t S( ( RE ( R4 ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR5 @ s N( R& RX RP t chrt ordR RC R Rw RD R Ra Rb t FIND_CLOSE_INTERVALRE ( R( Rr Rd RP ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyRD 3 s 2"c C s d } g } | i i D]d } | pL t | i t j p6 t t d | i p t | i t i j o | | q q ~ } x3 | D]+ } t
| i | i } | i
| | q Wd S( sV
force=1 will refresh table regardless of last bucket access time
c S s d S( N( ( Rk ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyRr F s c S s | i S( ( R ( R4 ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR5 I s N( RH Rn R Ro R t filterRA t lastAccessedRb t BUCKET_STALENESSR t mint maxR ( R( R3 Rr R/ Rq t refreshRP ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyRC B s ~ c C sN t d | i i d } t i d t | i i d } h | d 6| d 6S( s
Returns (num_contacts, num_nodes)
num_contacts: number contacts in our routing table
num_nodes: number of nodes estimated in the entire dht
c S s | t | i S( ( R Ro ( R4 R ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR5 T s i i i t num_contactst num_nodes( t reduceRH Rn Rb R R ( R( R R ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt statsN s !c C sb h | d 6} | d | d <| d | d <| i i | } | i | d d h | i i d 6S( NRP i R) i R* Rg ( RJ Ri Rj RX RP ( R( RP R R RI ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt krpc_pingX s
c C s | i i | d t } t d | } h | d 6} | d | d <| d | d <| i i | } | i | d d h t | d 6| i i d 6S(
NR c S s
| i S( ( t
senderDict( RX ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR5 b s RP i R) i R* Rg Rk (
RH R R: t mapRJ Ri Rj R RX RP ( R( Rz RP R Rk R RI ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt krpc_find_node` s
N( R R t KNodeBaseRF R$ RE R R: R2 R' RJ RM R? R, RY R] Rv R R Rj R Rt RD RC R R R ( ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR 3 s( ) >
t KhashmirReadc B s, e Z e Z d Z d d Z d Z RS( c C s1 y | i | } Wn t j
o
g } n X| S( N( R7 R ( R( t keyRo ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt retrieveValueso s
i c C s | i i | } | oC | i | } t | d j o | i i | d | f qb n g } t | | | | i i } | i i | i d | | f d S( s returns the values found for key in global table
callback will be called with a list of values for each peer that returns unique values
final callback will be an empty list - probably should change to 'more coming' arg
i N( RH R R R R Rw R R= R ( R( R Rr t searchlocalRk Ro R ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt valueForKeyv s !c C s h | d 6} | d | d <| d | d <| i i | } | i | d d | i | } t | d j o h | d 6| i i d 6S| i i | d t } t
d | } h t | d
6| i i d 6Sd S( NRP i R) i R* Rg t valuesR c S s
| i S( ( R ( RX ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR5 s Rk ( RJ Ri Rj R R RX RP RH R R: R R ( R( R RP R R RI Ro Rk ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt krpc_find_value s
( R R t KNodeReadRF R R R ( ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR m s t
KhashmirWritec B s# e Z e Z d d Z d Z RS( c s2 | | | i f d } i | | d S( s stores the value for key in the global table, returns immediately, no status
in this implementation, peers respond but don't indicate status to storing values
a key can have many values
c sX | p d } | } n t | | | i i } i i | i d | f d S( Nc S s d S( N( ( R ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt _storedValueHandler s i ( R R R= Rw R ( Rk R t valuet responseRH R t action( R( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt _storeValueForKey s
N( RH R ( R( R R Rr R ( ( R( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt storeValueForKey s
c C s| d t } | | i | <h | d 6} | d | d <| d | d <| i i | } | i | d d h | i i d 6S( Ns %0.6fRP i R) i R* Rg ( RA R7 RJ Ri Rj RX RP ( R( R R RP R R~ R RI ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt krpc_store_value s
N( R R t
KNodeWriteRF R$ R R ( ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR s t Khashmirc B s e Z e Z RS( ( R R R RF ( ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyR s (5 Rb R% R t BitTorrent.platformR RA R t ret BitTorrent.defaultargsR R t BitTorrent.RawServer_magicR t ktableR R t knodet kstoreR t khashR
R t utilR t actionsR
R R R R; t sysRS t tracebackt BitTorrent.bencodeR R t BitTorrent.deferR t randomR R t threadingR R t compileR{ R_ R R R R R R ( ( ( s5 /usr/lib/python2.6/site-packages/khashmir/khashmir.pyt <module> s:
" ;-