-ν Ϋ„?cs‰dkZdkZdkZdkZdkZeidjodeifd„ƒYZn,dZdZ dZ dei fd„ƒYZdS(NsposixstriggercsbtZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z e d„Z d „Z RS( s5Wake up a call to select() running in the main threadcsZtiƒ\}}|_||_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   csP|i oAd|_|iƒx|iD]}ti|ƒq(Wg|_ndS(Ni(sselfs_closeds del_channels_fdssfdsossclose(sselfsfd((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyscloseEs    csdt|ƒSdS(Ns(sidsself(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys__repr__MscsdSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pysreadablePscsdSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyswritableSscsdS(N((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyshandle_connectVscs|iƒdS(N(sselfsclose(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys handle_closeYscsT|o6|iiƒz|ii|ƒWd|iiƒXnti|i dƒdS(Nsx( sthunksselfslocksacquiresthunkssappendsreleasesosswritestrigger(sselfsthunk((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys pull_trigger\s cs°y|idƒWntij o dSnX|iiƒz`xP|iD]E}y |ƒWn1ti ƒ\}}}}d|||fGHnXqHWg|_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_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ξMi2csYtZdZd„Zd„Zd„Zd„Zd„Zd„Ze d„Z d „Z RS( Nicsitititiƒ}tititiƒ}|itiddƒxxttƒD]a}t i dtt _ t t i }t|f}y|i|ƒWntij o qSnXPqSWtd‚|idƒ|idƒy|i|ƒWnnX|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:           cs@|i o1d|_|iƒ|iiƒ|iiƒndS(Ni(sselfs_closeds del_channelssocketsclosestrigger(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pysclose¬s     csdt|ƒSdS(Ns!(sidsself(sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys__repr__΄scsdSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pysreadable·scsdSdS(Ni((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyswritableΊscsdS(N((sself((s8/usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pyshandle_connect½scsQ|o6|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ƒWntij o dSnX|iiƒz`xP|iD]E}y |ƒWn1ti ƒ\}}}}d|||fGHnXqHWg|_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