-í Û„?cs­dkZdkZdkZdkZdkZeidjo deifd„ƒYZn8~dZdZ €dZ ‚dei fd„ƒYZdS(NsposixstriggercsƒtZdZ7d„ZEd„ZMd„ZPd„ZSd„ZVd„ZYd„Z \e d„Z ed „Z RS( s5Wake up a call to select() running in the main threadcso78tiƒ\}}|_9||_:tii ||ƒ;t i ƒ|_ <g|_ =d|_dS(Ni(sosspipesrswsselfs_fdsstriggersasyncoresfile_dispatchers__init__sthreads allocate_lockslocksthunkss_closed(sselfsrsw((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys__init__7s   cshEF|i oSGd|_H|iƒIx$|iDI]}Jti|ƒq7WKg|_ndS(Ni(sselfs_closeds del_channels_fdssfdsossclose(sselfsfd((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyscloseEs   csMNdt|ƒSdS(Ns(sidsself(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys__repr__MscsPQdSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pysreadablePscsSTdSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyswritableSscs VWdS(N((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyshandle_connectVscsYZ|iƒdS(N(sselfsclose(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys handle_closeYscsl\]|oE^|iiƒ_z`|ii|ƒWdab|iiƒXncti|i dƒdS(Nsx( sthunksselfslocksacquiresthunkssappendsreleasesosswritestrigger(sselfsthunk((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys pull_trigger\s csãefyg|idƒWn htij oidSnXj|iiƒkzxlxb|iDl]T}myn|ƒWn:opti ƒ\}}}}qd|||fGHnXq`Wsg|_Wdtu|iiƒXdS(Ni s&exception in trigger thunk: (%s:%s %s)(sselfsrecvssocketserrorslocksacquiresthunkssthunksasyncorescompact_tracebacksnilstsvstbinfosrelease(sselfstbinfosthunksnilsvst((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys handle_reades   ( s__name__s __module__s__doc__s__init__scloses__repr__sreadableswritableshandle_connects handle_closesNones pull_triggers handle_read(((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pystriggers        s 127.0.0.1iîMi2csw‚tZ„dZ†d„Z¬d„Z´d„Z·d„Zºd„Z½d„ZÀe d„Z Éd „Z RS( NicsƇtititiƒ}ˆtititiƒ}‹|itiddƒŽx–ttƒDŽ]y}t i dtt _ t t i }‘t|f}’y“|i|ƒWn”tij o •qbnX—PqbW™td‚›|idƒœ|idƒyž|i|ƒWn Ÿ nX¡|iƒ\}}¢|iƒ£|idƒ¤||_ ¦tii||ƒ§tiƒ|_ ¨g|_!©d|_"ªd|_#dS(NisCannot bind trigger!i($ssocketsAF_INETs SOCK_STREAMsasws setsockopts IPPROTO_TCPsrangesNPORTSsistriggers portoffsetsMINPORTsportsHOSTsaddresssbindserrors RuntimeErrorslistens setblockingsconnectsacceptsrsaddrsclosesselfsasyncores dispatchers__init__sthreads allocate_lockslocksthunkss_trigger_connecteds_closed(sselfsasiswsaddresssrsportsaddr((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys__init__†s:       csR¬­|i o=®d|_¯|iƒ±|iiƒ²|iiƒndS(Ni(sselfs_closeds del_channelssocketsclosestrigger(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pysclose¬s   cs´µdt|ƒSdS(Ns!(sidsself(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys__repr__´scs·¸dSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pysreadable·scsº»dSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyswritableºscs ½¾dS(N((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyshandle_connect½scsiÀÁ|oEÂ|iiƒÃzÄ|ii|ƒWdÅÆ|iiƒXnÇ|iidƒdS(Nsx( sthunksselfslocksacquiresthunkssappendsreleasestriggerssend(sselfsthunk((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys pull_triggerÀs csãÉÊyË|idƒWn Ìtij oÍdSnXÎ|iiƒÏzxÐxb|iDÐ]T}ÑyÒ|ƒWn:ÓÔti ƒ\}}}}Õd|||fGHnXq`W×g|_WdØÙ|iiƒXdS(Ni s&exception in trigger thunk: (%s:%s %s)(sselfsrecvssocketserrorslocksacquiresthunkssthunksasyncorescompact_tracebacksnilstsvstbinfosrelease(sselfstbinfosthunksnilsvst((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys handle_readÉs   ( s__name__s __module__s portoffsets__init__scloses__repr__sreadableswritableshandle_connectsNones pull_triggers handle_read(((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pystrigger‚s   &      ( sasyncoresosssocketsthreadserrnosnamesfile_dispatcherstriggersHOSTsMINPORTsNPORTSs dispatcher( sNPORTSsHOSTstriggersasyncoressocketsthreadserrnosMINPORTsos((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys?s     g