�
p��Fc@s
dd
lZdd
l
ZdZejjd�
r9dZndZdZdZdZ	dZ
d	Zd
ZdZ
dZdZdZdZdZdZdZd	Zd
Zd
�Zd
d�
Zdef
d��YZddd��YZd�Zedkr�e�
nd
S(i����NitMonitorDebugi
iiiiiiii	c
Cs
tj
�S(
N(t_gamintErrno(((s+/usr/lib64/python2.7/site-packages/gamin.pyt
GaminErrno"s
c
Cs�|dkrt
j�}n|tkr0d
}
n�|tkrEd}
no|tkrZd}
nZ|tkrod}
nE|tkr�d}
n0|tkr�d}
n|t	kr�d}
nd}
|
S(	Nsbad argument errorsfilename errorsconnection errorsauthentication errorsmemory allocation errorsunimplemented part errorsinterrupted system callt(
tNoneR
RtGAM_ARGtGAM_FILEtGAM_CONNECTtGAM_AUTHtGAM_MEMtGAM_UNIMPLEMtGAM_INTR(terrtmsg((s+/usr/lib64/python2.7/site-packages/gamin.pytGaminErrmsg%s$



	

	

	

	

	

	

	
tGaminExceptionc
BseZ
d�Zd
�ZRS(cCs&tj
|�

|
|_t�|_dS(
N(t	Exceptiont__init__tvalueRterrno(tselfR((s+/usr/lib64/python2.7/site-packages/gamin.pyR;s


	
c
Cs=t|j
�
}
|
d
kr0t|j�
d|
St|j�
S(NRs: (RRtreprR(Rtstr((s+/usr/lib64/python2.7/site-packages/gamin.pyt__str__@s



(t__name__t
__module__RR(((s+/usr/lib64/python2.7/site-packages/gamin.pyR:s
	tWatchMonitorcBs�eZ
dZd
dd��YZd�Zd�Zd�Zdd�
Zd�Z	dd�
Z
dd	�
Zd
�Zd�Z
d�Zd
�Zd�Zd�ZRS(s|
This is a wrapper for a FAM connection. It uses a single connection
       to the gamin server, over a socket. Use get_fd() to get the file
       descriptor which allows to plug it in an usual event loop. The
       watch_directory(), watch_file() and stop_watch() are direct mapping
       to the FAM API. The event raised are also a direct mapping of the
       FAM API events.tWatchObjectcBs&eZ
dd�
Zd
�Zd�ZRS(cCs
|
|_||_
||_||_||_|d
krstj|j||�}|dkr�td|�
�
q�n�|dkr�tj|j||�}|dkr�td|�
�
q�nF|dkr�tj	|j||�}|dkr�td|�
�
q�n||_
dS(Ni
isFailed to monitor directory %ssFailed to monitor file %si����sFailed to debug %s(tmonitortcallbacktdatatpatht_WatchObject__mon_noR
tMonitorDirectoryRtMonitorFileRt_WatchObject__req_no(RRtmon_noR tdirRRtret((s+/usr/lib64/python2.7/site-packages/gamin.pyROs*
	
	
	
	
	















cCs�y<|jdkr+|j|
||j�
n|j|
|�
Wn


d
dl}|j�
n
X|tkr�y|jjj|�

Wq�


dGHq�XndS(Ni����s%gamin failed to remove from cancelled(	RRRt	tracebackt	print_exctGAMAcknowledgeRt	cancelledtremove(RR teventR(((s+/usr/lib64/python2.7/site-packages/gamin.pyt_internal_callbackfs









c
Csdtj
|j|j�}
|
d
kr:td|j�
�
ny|jjj|�

Wn


dGHn
XdS(NisFailed to stop monitor on %ss)gamin cancel() failed to add to cancelled(	R
t
MonitorCancelR!R$RR RR+tappend(RR'((s+/usr/lib64/python2.7/site-packages/gamin.pytcancelys







N(RRRRR.R1(((s+/usr/lib64/python2.7/site-packages/gamin.pyRNs
	c

Cs�tj
�|_|jd
kr-td�
�
ni|_tj|j�
|_|jd
krytj|j�

td�
�
ng|_dS(NisFailed to connect to gam_serversFailed to get file descriptor(	R
tMonitorConnectt_WatchMonitor__noRtobjectstGetFdt_WatchMonitor__fdtMonitorCloseR+(
R((s+/usr/lib64/python2.7/site-packages/gamin.pyR�s



	




c


Cs|j�
dS(
N(
t
disconnect(
R((s+/usr/lib64/python2.7/site-packages/gamin.pyt__del__�s
cCstd
�
�
dS(NsAlready disconnected(
R(((s+/usr/lib64/python2.7/site-packages/gamin.pyt__raise_disconnected�s
cCs^td
krdS|j
d
kr,|j�
n|j||j
|
d||�}||jd<|S(Nii����tdebug(t
has_debug_apiR3t!_WatchMonitor__raise_disconnectedRR4(RRRRtobj((s+/usr/lib64/python2.7/site-packages/gamin.pyt
_debug_object�s




!

c

Cs/|jd
kr"t
j|j�

nd|_dS(Nii����(R3R
R7(
R((s+/usr/lib64/python2.7/site-packages/gamin.pyR8�s


cCs�|jd
kr|j
�
ntjj|
�
}
|j||j|
d||�}|jj|
�
rx|j|
j|�

n|g
|j|
<|S(Nii
(	R3R=tosR tabspathRR4thas_keyR0(Rt	directoryRRR>((s+/usr/lib64/python2.7/site-packages/gamin.pytwatch_directory�s



!


cCs�|jd
kr|j
�
ntjj|
�
}
|j||j|
d
||�}|jj|
�
rx|j|
j|�

n|g
|j|
<|S(Ni(	R3R=R@R RARR4RBR0(RtfileRRR>((s+/usr/lib64/python2.7/site-packages/gamin.pyt
watch_file�s



!


c
Cs)|jd
krdSt
j|j�
}
|
S(Ni(R3R
tMonitorNoExists(RR'((s+/usr/lib64/python2.7/site-packages/gamin.pyt	no_exists�s



cCs||jd
krdSt
jj|
�
}
y|j|
}Wn


td|
�
�
n
Xx|D]}|j�
qWWg|j|
<dS(NisResource %s is not monitored(R3R@R RAR4RR1(RR tlistR>((s+/usr/lib64/python2.7/site-packages/gamin.pyt
stop_watch�s










c

Cs#|jd
kr|j
�
n|jS(Ni(R3R=R6(
R((s+/usr/lib64/python2.7/site-packages/gamin.pytget_fd�s



c
CsM|jd
kr|j
�
ntj|j�
}
|
d
krItd�
�
n|
S(NisFailed to check pending events(R3R=R
tEventPendingR(RR'((s+/usr/lib64/python2.7/site-packages/gamin.pyt
event_pending�s






c
CsM|jd
kr|j
�
ntj|j�
}
|
d
krItd�
�
n|
S(NisFailed to process one event(R3R=R
tProcessOneEventR(RR'((s+/usr/lib64/python2.7/site-packages/gamin.pythandle_one_event�s






c
CsM|jd
kr|j
�
ntj|j�
}
|
d
krItd�
�
n|
S(NisFailed to process events(R3R=R
t
ProcessEventsR(RR'((s+/usr/lib64/python2.7/site-packages/gamin.pyt
handle_events�s






(N(RRt__doc__RRR9R=RR?R8RDRFRHRJRKRMRORQ(((s+/usr/lib64/python2.7/site-packages/gamin.pyRFs5									cCs�d
�}t�}
dGH|
j
d|�
ddl}|jd�

dG|
j�GH|
j�}dG|GH|dkr�|
j�}d	|GH|
j�}d
|GHndGH|
jd�

dGH~
dS(
NcSsd
||
fGHdS(NsGot callback: %s, %s((R R-((s+/usr/lib64/python2.7/site-packages/gamin.pyR�s
swatching current directoryt
.i����i
sfd: s	pending: isprocessed %d eventsprocessed %d remaining eventssstop watching current directoryt
disconnecting(	RRDttimetsleepRKRMRORQRJ(RtmonRUR'((s+/usr/lib64/python2.7/site-packages/gamin.pytrun_unit_tests�s$
		







	


	






t__main__((R
tos.pathR@R<t__dict__RBt
GAMChangedt
GAMDeletedtGAMStartExecutingtGAMStopExecutingt
GAMCreatedtGAMMovedR*t	GAMExiststGAMEndExisttGAM_OKRRRR	R
RRRRRRRRRXR(((s+/usr/lib64/python2.7/site-packages/gamin.pyt<module>s8


	














	�