Name	Size	Mode	Actions
engines/	-	0755	rm
hacks/	-	0755	rm
account.py	2546	0755	editdlrm
account.pyc	3432	0644	editdlrm
client.py	10814	0755	editdlrm
client.pyc	13822	0644	editdlrm
config.py	9167	0755	editdlrm
config.pyc	8665	0644	editdlrm
digest.py	5879	0755	editdlrm
digest.pyc	6826	0644	editdlrm
forwarder.py	2568	0755	editdlrm
forwarder.pyc	3115	0644	editdlrm
message.py	4023	0755	editdlrm
message.pyc	9641	0644	editdlrm
server.py	15777	0755	editdlrm
server.pyc	17319	0644	editdlrm
__init__.py	1410	0755	editdlrm
__init__.pyc	2653	0644	editdlrm

Ñò H<Vc @sjdZd
dk
Z
d
dkZyd
dkZWnej o



d
dkZn
Xdef
d„ƒYZdS(sManage the forwarder process.iÿÿÿÿNt ForwardercBsAeZ
dZd
d„
Zd„Zed„
Zd„Zd„ZRS(s'Forwards digest to remote pyzor serversi'cCs:ti
d
ƒ
|_|
|_ti|ƒ
|_||_dS(s
forward_client: a pyzor.client.Client instance to use as forwarding client remote_servers: a list of (hostname,port) tuples where digests should be forwarded to max_queue_size: max amount of queued digests tpyzordN(tloggingt getLoggertlogtforwarding_clienttQueuet forward_queuetremote_servers(tselfRRtmax_queue_size((sI/usr/lib/python2.6/site-packages/pyzor-1.0.0-py2.6.egg/pyzor/forwarder.pyt__init__s 


c
 CsãxÜtoÔ
y%|i
id
tddƒ\}
}Wn.tij o



|idjo
dS
qn
Xxw|iD]l}y5|o
|ii|
|ƒ
n
|ii |
|ƒ
Wqjt j o"

}
|iid|
||ƒ
qj
XqjWq
WdS(s'read forwarding requests from the queuetblockttimeoutiNs%Forwarding digest %s to %s failed: %s( tTrueRtgetRtEmptyRtNoneRt whitelisttreportt ExceptionRtwarn(R tdigestRtservertex((sI/usr/lib/python2.6/site-packages/pyzor-1.0.0-py2.6.egg/pyzor/forwarder.pyt _forward_loops$




 





cCsL|id
jo
d
S
y|ii|
|fƒ

Wntij o



n
Xd
S(sÐIf forwarding is enabled, insert a digest into the forwarding queue if whitelist is True, the digest will be forwarded as whitelist request if the queue is full, the digest is dropped N(RRRt put_nowaitRtFull(R RR((sI/usr/lib/python2.6/site-packages/pyzor-1.0.0-py2.6.egg/pyzor/forwarder.pytqueue_forward_request5s



c

Csti
d
|iƒ
iƒ
dS(sstart the forwarding threadttargetN(t threadingtThreadRtstart(
R ((sI/usr/lib/python2.6/site-packages/pyzor-1.0.0-py2.6.egg/pyzor/forwarder.pytstart_forwardingBsc

Cs d
|_
d
S(s?disable forwarding and tell the forwarding thread to end itselfN(RR(
R ((sI/usr/lib/python2.6/site-packages/pyzor-1.0.0-py2.6.egg/pyzor/forwarder.pytstop_forwardingFs( t__name__t __module__t__doc__RRtFalseRR!R"(((sI/usr/lib/python2.6/site-packages/pyzor-1.0.0-py2.6.egg/pyzor/forwarder.pyRs
  (R%RRRtImportErrortqueuetobjectR(((sI/usr/lib/python2.6/site-packages/pyzor-1.0.0-py2.6.egg/pyzor/forwarder.pyt
s