H/\c@@swddlmZmZddlZddlZddlmZgZejZej Z ddl m Z ddl mZeZejddejZe jdfe jd fgZd Zd efd YZd efdYZdefdYZde j fdYZ de je fdYZdefdYZdee j e fdYZ!dee j"e fdYZ#de j$e fdYZ%e%e&dR@RERHRJR tonly_if_watcherRLRNRORPRSRUtpropertyR?RZ(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRZs"  *        tiocB@s eZdZdZeZejejBej BZ dZ e ddZdZejdZdZdZeeeZdZejjdrejjZnd efd YZ d Z!d Z"d Z#dZ$dZ%dZ&dZ'dZ(RS(tpollt_gevent_poll_callback2c C@sPtt|j|||d|d|d|f||_||_g|_dS(NR?tpriorityRY(tsuperRaRt_fdR t_multiplex_watchers(RRBtfdR R?Rd((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs1  cC@s|jS(N(Rf(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt_get_fdscC@s||_|j|fdS(N(RfRE(RRh((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt_set_fds cC@s|jS(N(R (R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt _get_eventsscC@s]||jkrdS||_|jrY|jdk s:t|j|j|j|jndS(N(R tactivet_handleRR/RFRDRG(RR ((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt _set_eventss   cC@s |j|j|j|jdS(N(RFRDR RG(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRHstwin32t_multiplexwatchercB@seZd Zd ZeZeZdZ e de j dZ dZdZdZe dZe dZe dd ZRS( cC@s||_||_dS(N(R t _watcher_ref(RR R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR,s cC@s|jS(N(R (R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt7scC@st|d|S(NR (R*(Rtnv((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRr8scO@s`|jd|_||_||_|j}|dk r\|jsO|jq\|jndS(Nt pass_events( tgetRttcallbackR"RqRRlt _io_startt_calc_and_update_events(RRvR"R#R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pytstart:s      cC@sAd|_d|_d|_|j}|dk r=|jndS(N(RRvRtR"Rqt_io_maybe_stop(RR((s3lib/python2.7/site-packages/gevent/libuv/watcher.pytstopGs      cC@s/|jdk r"|jj|nd|_dS(N(RqRt_multiplex_closed(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pytcloseOscC@s |jdk S(N(RvR(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRlTscC@s |jjS(N(RqRD(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRDXscC@st|jddS(NRfi(R'Rq(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRr_scC@s|jj|S(N(RqRj(RRs((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRr`sN((RRRRvR"tFalseRttTrueR?RR`R tnot_while_activeR RyR{R}RlRDRh(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRp%s    cC@s?|jx$|jD]}|jdk rdSqW|jdS(N(RxRgRvRR{(Rtw((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRzbs  cC@s$|j|j|jdtdS(NRt(RxRyt _io_callbackR(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRwms cC@sJd}x0|jD]%}|jdk r||jO}qqW|j|dS(Ni(RgRvRR Rn(RR R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRxqs cC@s0|j||}|jj||j|S(N(RpRgtappendRx(RR R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt multiplexzs cC@stt|j|`dS(N(ReRaR}Rg(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR}scC@sH|jj||js:|j|j|jn |jdS(N(RgtremoveR{t_no_more_watchersR}Rx(RR((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR|s    cC@sdS(N((R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRscC@s|dkrItd|jtjtj|tjtj|nx|jD]}|jshqSn|j |kst ||j f||j @p|dk}|rS|j s|j|j q|j||j qSqSWdS(NisCallback error on(RRfRRRRR RgRvRqR/R RtR"(RR Rt send_event((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs   $ (N()RRt _watcher_typet_watcher_callback_nameR~t&_watcher_registers_with_loop_on_createRt UV_READABLEt UV_WRITABLEt UV_DISCONNECTt EVENT_MASKRgRRRRiR RRjRkRnR`R RHtsystplatformt startswithRR[tuv_poll_init_socketRAtobjectRpRzRwRxRR}R|RR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRas."    =     t_SimulatedWithAsyncMixincB@s}eZeZdZdZedZdZdZ edZ dZ dZ dZ d Zd ZRS( cO@sM|j|_y tt|j|||Wn|jjnXdS(N(tasync_t_asyncReRRR}(RRBR"R#((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs   cC@sdS(N((RRY((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt_watcher_createscC@sdS(N(R(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt_watcher_handlescC@sdS(N((RRY((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyREscC@s||j_dS(N(RR?(RR?((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR@scC@s |jjS(N(RRl(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRlscG@s3|j||_||_|jj||dS(N(t_register_loop_callbackRvR"RRy(RtcbR"((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRys   cC@s-|jd|_d|_|jjdS(N(t_unregister_loop_callbackRRvR"RR{(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR{s   cC@s)|jdk r%|j}|jndS(N(RRR}(Rta((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR}s cC@s tdS(N(tNotImplementedError(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRscC@s tdS(N(R(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs(RRRt_watcher_skip_ffiRRR`RRER@RlRyR{R}RR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs        tforkcB@s)eZeZdZdZdZRS(cC@s|jjj|dS(N(RBt_fork_watchersR7(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRscC@s/y|jjj|Wntk r*nXdS(N(RBRRtKeyError(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs cC@s|jjdS(N(Rtsend(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt_on_forks(RRR~RRRR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs  tchildcB@s)eZeZdZdZdZRS(cC@s|jj|dS(N(RBt_register_child_watcher(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRscC@s|jj|dS(N(RBt_unregister_child_watcher(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRscC@s#||_||_|jjdS(N(t_rpidt_rstatusRR(Rtpidtstatus((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt_set_waitpid_statuss  (RRRRRRR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR s  RcB@sAeZdZdZdZdZdZedZRS(t_gevent_async_callback0cC@s|j|jj|jtjS(N(RARBRCRDRR9(RR"((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRE'scC@s|j|j_dS(N(RGRDtasync_cb(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRH1scC@stj|j_|jdS(N(RR9RDRRN(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRJ8scC@s5tj|jr!tdntj|jdS(NsClosing handle(RR5RDRVt uv_async_send(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRAscC@sdS(N(R(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pytpendingFs( RRRRERHRJRR`R(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyR$s   tasyncttimercB@s/eZdZeZdZdZdZRS(t_gevent_timer_callback0cC@s|j|jj|j|\|_|_|jrn|jdkrnddl}|jdddd|_n|jr|jdkrddl}|jdddd|_ndS(NgMbP?isTlibuv only supports millisecond timer resolution; all times less will be set to 1 mst stackleveli(RARBt_ptrRDt_aftert_repeattwarningstwarn(RR"R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyREds     cC@sw|jrtj|jnWy:|j|j|jt|jdt|jdWnt k rrt nXdS(Ni( t_againRtuv_timer_againRDRFRGtintRRt ValueErrort TypeError(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRHxs  cO@sN|js |j|||dSt|_z|j|||Wd|`XdS(N(RlRyRR(RRvR"tkw((s3lib/python2.7/site-packages/gevent/libuv/watcher.pytagains  (RRRR~RRERHR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRLs   tstatcB@sheZdZdZdZdZdZdZdZe dZ e dZ e d Z RS( tfs_polltgevent_fs_poll_tt_gevent_fs_poll_callback3cC@s||j_|S(N(thandleR:(Rt the_watcherR:((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt_watcher_set_datas cC@s|j|jj|jS(N(RARBRRD(RR"((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyREsg`--g?cC@sQ|j|jkr!|j|_n|j|j|j|jt|jddS(Ni(t _intervaltMIN_STAT_INTERVALRFRDRGt_cpathR(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRHs cC@s |jjjS(N(RDRR:(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRscC@s|jjjsdS|jjS(N(RDtcurrtst_nlink(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pytattrscC@s|jjjsdS|jjS(N(RDtprevR(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs( RRRt_watcher_struct_nameRRRERRHR`RRR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs   tsignalcB@s eZdZdZdZRS(t_gevent_signal_callback1cC@s&|j|jj|jt|_dS(N(RARBRRDR~R?(RR"((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyREscC@s |j|j|j|jdS(N(RFRDRGt _signalnum(R((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRHs(RRRRERH(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs tidlecB@seZdZRS(t_gevent_idle_callback0(RRR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRstcheckcB@seZdZRS(t_gevent_check_callback0(RRR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRst OneShotCheckcB@s eZeZdZdZRS(c@s.|jtjfd}|S(Nc@s|S(N((R"(tfuncR{(s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs(R{R(R)(RRR((RR{s3lib/python2.7/site-packages/gevent/libuv/watcher.pyt __make_cbs !cG@stj||j||S(N(RRyt_OneShotCheck__make_cb(RRvR"((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRys(RRRRRRy(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs tpreparecB@seZdZRS(t_gevent_prepare_callback0(RRR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pyRs(4t __future__RRR(Rt gevent.libuvRt__all__RR1Rt gevent._ffiRR RtsetR6t def_externRRRRR R RRRRR,tIoMixinRaRt ForkMixinRt ChildMixinRt AsyncMixinRtlocalst TimerMixinRt StatMixinRt SignalMixinRt IdleMixinRt CheckMixinRRt PrepareMixinR(((s3lib/python2.7/site-packages/gevent/libuv/watcher.pytsD       !d7& F'