�
YF�Tc@shdZd
dl
Z
d
dlZyd
dlZWnek
rM


d
dlZn
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:tj
d
�
|_|
|_tj|�
|_||_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((s3/usr/lib/python2.7/site-packages/pyzor/forwarder.pyt__init__s	
	

c
Cs�x�tr�y%|j
jd
tdd�\}
}Wn*tjk
rZ


|jdkrdSqn
Xxs|jD]h}y3|r�|jj|
|�
n|jj	|
|�
Wqet
k
r�
}
|jjd|
||�
qeXqeWqWdS(s'read forwarding requests from the queuetblockttimeoutiNs%Forwarding digest %s to %s failed: %s(
tTrueRtgetRtEmptyRtNoneRt	whitelisttreportt	ExceptionRtwarn(R	tdigestRtservertex((s3/usr/lib/python2.7/site-packages/pyzor/forwarder.pyt
_forward_loops 	










cCsH|jd
krd
Sy|jj|
|f�

Wntjk
rC


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((s3/usr/lib/python2.7/site-packages/pyzor/forwarder.pytqueue_forward_request5s



c

Cstj
d
|j�
j�
dS(sstart the forwarding threadttargetN(t	threadingtThreadRtstart(
R	((s3/usr/lib/python2.7/site-packages/pyzor/forwarder.pytstart_forwardingBsc

Cs
d
|_
d
S(s?disable forwarding and tell the forwarding thread to end itselfN(RR(
R	((s3/usr/lib/python2.7/site-packages/pyzor/forwarder.pytstop_forwardingFs(	t__name__t
__module__t__doc__RRtFalseRR!R"(((s3/usr/lib/python2.7/site-packages/pyzor/forwarder.pyRs

	
	(R%RRRtImportErrortqueuetobjectR(((s3/usr/lib/python2.7/site-packages/pyzor/forwarder.pyt<module>
s