| 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 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
d d k Td d k l
Z
d d k l Z d d k Td d k l Z d Z d Z d
e i f d „ ƒ YZ d e f d „ ƒ YZ d e i f d „ ƒ YZ d S( iÿÿÿÿN( t *( t newID( t KRPCProtocolErrort KRPCFailSilently( t Cache( t sha( t Thread( t
gethostbyname( t samplei i< i2 t UTNodec B s# e Z d „ Z d „ Z d „ Z RS( c C sd t | ƒ t d ƒ j p t ‚ t | ƒ t d ƒ j p t ‚ t | ƒ t d ƒ j p t ‚ t | ƒ d j p t ‚ t | ƒ d j p t ‚ y | i i | i } Wn
d } n X| or t | ƒ t d ƒ j p t ‚ t | ƒ d j p t ‚ | i ƒ i d h | d 6| d 6| d 6| d 6ƒ } n
t d ƒ ‚ | i
| i ƒ | i | i
ƒ | S(
Ni t i t
announce_peert info_hasht portt idt tokens no write token for node( t typet AssertionErrort lent tablet tcacheR t Nonet connt sendRequestR t
addErrbackt errBackt addCallbackt checkSender( t selfR R
t khashmir_idR t df( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt announcePeer s(
c C sJ | i ƒ i d h | d 6| d 6ƒ } | i | i ƒ | i | i ƒ | S( Nt get_peersR R ( R R R R R R ( R R R R ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt getPeers3 s &c C sS t i i | | ƒ } y$ | d d | i i | d d <Wn t j
o n X| S( Nt rspR R ( t knodet KNodeBaseR R R t KeyError( R t dictt d( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR 9 s $( t __name__t
__module__R R! R ( ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR s t UTStoreValuec B s e Z d „ Z RS( c C s% | | i | i | i | i i i ƒ S( N( t targett valueR R t nodeR ( R R- t f( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt callNodeB s ( R( R) R/ ( ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR* A s t
UTKhashmirc B s¡ e Z e Z e d „ Z e d „ Z e d „ Z d „ Z d „ Z
d d „ Z d „ Z
d „ Z d d „ Z d „ Z d
„ Z d d „ Z d d
„ Z d „ Z RS( c C se t i i | | | | | | ƒ t d ƒ | _ | _ t ƒ | _ | i d t ƒ | i
d t ƒ d S( NR
t loop( t khashmirt KhashmirBaset setupR t cur_tokent
last_tokenR R t gen_tokent Truet expire_cached_tokens( R t hostR
t data_dirt rlcountt
checkpoint( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR4 H s
c C sB | i i t ƒ t ƒ | o | i i | i t t f ƒ n d S( N( R t expiret timet TOKEN_UPDATE_INTERVALt rawservert external_add_taskR9 R8 ( R R1 ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR9 O s c C sI | i | _ t t ƒ ƒ | _ | o | i i | i t t f ƒ n d S( N( R5 R6 R R RA RB R7 R@ R8 ( R R1 ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR7 T s c C s6 | i i ƒ } | i d | | f ƒ | i ƒ } | S( Ns %s%s( R5 t copyt updatet digest( R R: R
t xt h( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt get_tokenZ s c C sŒ | i i ƒ } | i d | | f ƒ | i ƒ } | | j o t S| i i ƒ } | i d | | f ƒ | i ƒ } | | j o t St S( Ns %s%s( R5 RC RD RE R8 R6 t False( R R R: R
RF t at b( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt val_tokena s
c C s) t d | i d | | | g ƒ i ƒ d S( NR+ t args( R t _get_hostt start( R R: R
t callback( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt
addContactp s c C sz y t | ƒ } WnA t j
o5 } t t | ƒ d t | ƒ t | ƒ f ƒ ‚ n X| i i | i d | | | f ƒ d S( Ns : host(%s) port(%s)i ( R t TypeErrort strt reprRA RB t _got_host( R R: R
RP t ipt e( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyRN t s
1c C s t i i | | | | ƒ d S( N( R2 R3 RQ ( R R: R
RP ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyRU ~ s 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 s[ | p d „ } | } n t ˆ | | | ˆ i i d ƒ } ˆ i i | i d | f ƒ d S( Nc S s d S( N( ( t sender( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt _storedValueHandler‰ s R i ( R* RA t add_taskRB t goWithNodes( t nodest keyR, t responseR RY t action( R ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt _storeValueForKey† s
!N( R t findNode( R R R
RP R` ( ( R s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR s
c C s° h | d 6} | d | d <| d | d <| i | | d | d ƒ p t d ƒ ‚ n t | d | ƒ } | | i | <| i ƒ i | ƒ } | i | d d ƒh | i i d 6S( NR i R: i R
s Invalid Write Tokent contacted( RL R t compact_peer_infot storet Nodet initWithDictt
insertNodeR- R ( R R R
R R t _krpc_senderRX R, t n( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt krpc_announce_peer’ s
c C s9 y | i i | t ƒ } Wn t j
o
g } n X| S( N( Rd R t NUM_PEERSR% ( R R] t l( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt retrieveValuesž s
i 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 | oL | i | ƒ } t | ƒ d j o& | i i | d t
| ƒ g f ƒ qà n g } t | | | | i i d ƒ } | 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
t invalidi i R! N( R t findNodesR8 Rn R R RI Rm RA RB t reducePeerst GetValueRZ R[ ( R R RP t searchlocalR\ t _[1]RF Rl t state( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR! ¥ s /-* c C sà | i i | d t ƒ} | | i i | d t ƒ7} | oL | i | ƒ } t | ƒ d j o& | i i | d t | ƒ g f ƒ q n g } d „ } t | | | | | | i i
d d ƒ } | 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
Rn i c S s | S( ( ( RJ ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt <lambda>Ê s R! R N( R Ro RI R8 Rm R RA RB Rp t GetAndStoreRZ R[ ( R R R
RP Rr R\ Rl RF Rt ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt getPeersAndAnnounceº s * 'c
C s, h | d 6} | d | d <| d | d <| i ƒ i | ƒ } | i | d d ƒ| i | ƒ } t | ƒ d j o= h t | ƒ g d 6| i i d 6| i | d | d ƒ d 6S| i i
| d t ƒ} g } | D] } | | i ƒ qÓ ~ } h t
| ƒ d
6| i i d 6| i | d | d ƒ d 6Sd S( NR i R: i R
Rb t valuesR Rn R\ ( Re Rf Rg Rm R Rp R- R RH R Ro RI t
senderDictt packNodes(
R R R Rh RX Ri Rl R\ Rs R- ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt krpc_get_peersÎ s
'
N( R( R) R t _NodeR8 R4 RI R9 R7 RH RL R RQ RN RU R Rj Rm R! Rw R{ ( ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyR0 E s
i, ( R2 R# t actionst khashR t krpcR R t cacheR R t utilt threadingR t socketR t constt kstoreR R@ Rk R$ R t
StoreValueR* R3 R0 ( ( ( s7 /usr/lib/python2.6/site-packages/khashmir/utkhashmir.pyt <module> s
'