mς MγΈEc@spdkZdkZdkZdklZdklZdkZdkZ e i i Z dei fd„ƒYZ dS(N(s Connection(slogt DispatchercBsJtZdZeiiZed„Zd„Zd„Z d„Z d„Z RS(s.A server that accepts incoming RPC connectionscCs*|iƒ||_||_|iƒdS(N(tselft_Dispatcher__super_inittaddrtfactoryt _open_socket(RRR((t./data/zmath/zope/lib/python/ZEO/zrpc/server.pyt__init__s   cCs‘t|iƒtijo|ititiƒn|iti tiƒ|i ƒt dt |iƒt iƒ|i|iƒ|idƒdS(Nslistening on %si(ttypeRRttypest TupleTypet create_sockettsockettAF_INETt SOCK_STREAMtAF_UNIXtset_reuse_addrtlogtstrtloggingtINFOtbindtlisten(R((RR$s cCsdS(Ni((R((Rtwritable.scCsdS(Ni((R((Rtreadable1scCssy|iƒ\}}Wn*tij o}td|ƒdSnX|i||ƒ}tdt |ƒ|fƒdS(Nsaccepted failed: %ssconnect from %s: %s( RtaccepttsockRR terrortmsgRRtctrepr(RRRRR((Rt handle_accept4s ( t__name__t __module__t__doc__tasyncoret dispatcherRRt ConnectionRRRR(((RRs     (R#R R tZEO.zrpc.connectionR%t ZEO.zrpc.logRRtThreadedAsync.LoopCallbackt ThreadedAsynct LoopCallbacktloopR$R( RR R%R)R+R#RR R((Rt?s