ÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂ 3 \‚iã@sdZddlZddlZddlZddlZddlZyddlZWnek rTddlZYnXddl m Z ddlmZddddd d ddd g Z eedƒrže jdddgƒeedƒrºe jddddgƒeedƒrÌejZnejZGdd„dƒZGdd„deƒZGdd„deƒZeedƒrGdd„dƒZGdd „d ƒZeedƒrXGdd„deeƒZGdd„deeƒZGdd„deeƒZGd d „d eeƒZeedƒrÌGd!d„deƒZGd"d„deƒZGd#d„deeƒZGd$d„deeƒZGd%d „d ƒZ Gd&d„de ƒZ!Gd'd(„d(e ƒZ"Gd)d„de ƒZ#dS)*z0.4éN)ÚBufferedIOBase)Ú monotonicÚ BaseServerÚ TCPServerÚ UDPServerÚThreadingUDPServerÚThreadingTCPServerÚBaseRequestHandlerÚStreamRequestHandlerÚDatagramRequestHandlerÚThreadingMixInÚforkÚForkingUDPServerÚForkingTCPServerÚForkingMixInÚAF_UNIXÚUnixStreamServerÚUnixDatagramServerÚThreadingUnixStreamServerÚThreadingUnixDatagramServerÚPollSelectorc@sšeZdZdZdd„Zdd„Zd%dd„Zd d „Zdd„Zd d„Z dd„Z dd„Zdd„Zdd„Z dd„Zdd„Zdd„Zdd„Zdd „Zd!d"„Zd#d$„ZdS)&rNcCs ||_||_tjƒ|_d|_dS)NF)Úserver_addressÚRequestHandlerClassÚ threadingZEventÚ_BaseServer__is_shut_downÚ_BaseServer__shutdown_request)Úselfrr©rú$/usr/lib64/python3.6/socketserver.pyÚ__init__Ìs zBaseServer.__init__cCsdS)Nr)rrrrÚserver_activateÓszBaseServer.server_activateçà?cCsx|jjƒzVtƒF}|j|tjƒx0|jsR|j|ƒ}|jrrrrr8QszBaseServer.verify_requestcCs|j||ƒ|j|ƒdS)N)Úfinish_requestr<)rr=r>rrrr9YszBaseServer.process_requestcCsdS)Nr)rrrrÚserver_closebszBaseServer.server_closecCs|j|||ƒdS)N)r)rr=r>rrrr?jszBaseServer.finish_requestcCs|j|ƒdS)N)Ú close_request)rr=rrrr<nszBaseServer.shutdown_requestcCsdS)Nr)rr=rrrrArszBaseServer.close_requestcCsHtddtjdtd|tjdddl}|jƒtddtjddS)Nú-é()Úfilez4Exception happened during processing of request fromr)ÚprintÚsysÚstderrÚ tracebackÚ print_exc)rr=r>rHrrrr;vszBaseServer.handle_errorcCs|S)Nr)rrrrÚ __enter__ƒszBaseServer.__enter__cGs|jƒdS)N)r@)rÚargsrrrÚ__exit__†szBaseServer.__exit__)r!)Ú__name__Ú __module__Ú__qualname__r1rr r-r/r)r5r(r4r8r9r@r?r<rAr;rJrLrrrrrs$- c@sbeZdZejZejZdZdZ ddd„Z dd„Zdd „Zd d„Z dd „Zdd„Zdd„Zdd„ZdS)réFTc CsTtj|||ƒtj|j|jƒ|_|rPy|jƒ|jƒWn|jƒ‚YnXdS)N)rrr0Úaddress_familyÚsocket_typeÚserver_bindr r@)rrrZbind_and_activaterrrrÁs zTCPServer.__init__cCs8|jr|jjtjtjdƒ|jj|jƒ|jjƒ|_dS)Né)Úallow_reuse_addressr0Ú setsockoptZ SOL_SOCKETZSO_REUSEADDRZbindrZgetsockname)rrrrrSÎszTCPServer.server_bindcCs|jj|jƒdS)N)r0ZlistenÚrequest_queue_size)rrrrr ÙszTCPServer.server_activatecCs|jjƒdS)N)r0Úclose)rrrrr@ászTCPServer.server_closecCs |jjƒS)N)r0Úfileno)rrrrrYészTCPServer.filenocCs |jjƒS)N)r0Zaccept)rrrrr6ñszTCPServer.get_requestcCs4y|jtjƒWntk r$YnX|j|ƒdS)N)r/r0ZSHUT_WRr7rA)rr=rrrr<ùs zTCPServer.shutdown_requestcCs|jƒdS)N)rX)rr=rrrrAszTCPServer.close_requestN)T)rMrNrOr0ZAF_INETrQZSOCK_STREAMrRrWrUrrSr r@rYr6r<rArrrrrŠs/ c@s:eZdZdZejZdZdd„Zdd„Z dd„Z d d „ZdS)rFi cCs |jj|jƒ\}}||jf|fS)N)r0ZrecvfromÚmax_packet_size)rÚdataZclient_addrrrrr6szUDPServer.get_requestcCsdS)Nr)rrrrr szUDPServer.server_activatecCs|j|ƒdS)N)rA)rr=rrrr<szUDPServer.shutdown_requestcCsdS)Nr)rr=rrrrAszUDPServer.close_requestN)rMrNrOrUr0Z SOCK_DGRAMrRrZr6r r<rArrrrrscsReZdZdZdZdZdZddœdd„Zdd „Zd d„Z dd „Z ‡fdd„Z‡ZS)ri,NrCF)ÚblockingcCsò|jdkrdSxht|jƒ|jkrvy tjddƒ\}}|jj|ƒWqtk r^|jjƒYqtk rrPYqXqWxt|jj ƒD]f}y.|r’dntj }tj||ƒ\}}|jj|ƒWq„tk rÖ|jj|ƒYq„tk rèYq„Xq„WdS)NrTréÿÿÿÿ)Úactive_childrenÚlenÚmax_childrenÚosÚwaitpidÚdiscardÚChildProcessErrorr"r7ÚcopyÚWNOHANG)rr\ÚpidÚ_ÚflagsrrrÚcollect_children,s& zForkingMixIn.collect_childrencCs|jƒdS)N)rj)rrrrr4OszForkingMixIn.handle_timeoutcCs|jƒdS)N)rj)rrrrr)VszForkingMixIn.service_actionscCsštjƒ}|r8|jdkrtƒ|_|jj|ƒ|j|ƒdSd}z:y|j||ƒd}Wn tk rr|j||ƒYnXWdz|j |ƒWdtj |ƒXXdS)NrTr)rar r^r*ÚaddrAr?r:r;r<Ú_exit)rr=r>rgZstatusrrrr9]s zForkingMixIn.process_requestcstƒjƒ|j|jddS)N)r\)Úsuperr@rjÚ_block_on_close)r)Ú __class__rrr@vs zForkingMixIn.server_close) rMrNrOr1r^r`rnrjr4r)r9r@Ú __classcell__rr)rorr#s#cs8eZdZdZdZdZdd„Zdd„Z‡fdd„Z‡Z S) rFNcCsHz6y|j||ƒWn tk r2|j||ƒYnXWd|j|ƒXdS)N)r?r:r;r<)rr=r>rrrÚprocess_request_thread‡s z%ThreadingMixIn.process_request_threadcCsRtj|j||fd}|j|_|jrF|jrF|jdkr:g|_|jj|ƒ|jƒdS)N)ÚtargetrK) rZThreadrqÚdaemon_threadsZdaemonrnÚ_threadsÚappendÚstart)rr=r>Útrrrr9”s zThreadingMixIn.process_requestcs:tƒjƒ|jr6|j}d|_|r6x|D]}|jƒq&WdS)N)rmr@rnrtÚjoin)rZthreadsZthread)rorrr@Ÿs zThreadingMixIn.server_close) rMrNrOrsrnrtrqr9r@rprr)rorr{s c@seZdZdS)rN)rMrNrOrrrrrªsc@seZdZdS)rN)rMrNrOrrrrr«sc@seZdZdS)rN)rMrNrOrrrrrsc@seZdZdS)rN)rMrNrOrrrrr®sc@seZdZejZdS)rN)rMrNrOr0rrQrrrrr²sc@seZdZejZdS)rN)rMrNrOr0rrQrrrrrµsc@seZdZdS)rN)rMrNrOrrrrr¸sc@seZdZdS)rN)rMrNrOrrrrrºsc@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) r c Cs6||_||_||_|jƒz|jƒWd|jƒXdS)N)r=r>ÚserverÚsetupÚhandleÚfinish)rr=r>ryrrrrÎszBaseRequestHandler.__init__cCsdS)Nr)rrrrrzØszBaseRequestHandler.setupcCsdS)Nr)rrrrr{ÛszBaseRequestHandler.handlecCsdS)Nr)rrrrr|ÞszBaseRequestHandler.finishN)rMrNrOrrzr{r|rrrrr ¼s c@s,eZdZd ZdZdZdZdd„Zdd„ZdS) r rTrNFcCsz|j|_|jdk r |jj|jƒ|jr:|jjtjtjdƒ|jj d|j ƒ|_|jdkrdt |jƒ|_n|jj d|jƒ|_dS)NTÚrbrÚwb)r=Z connectionr1Z settimeoutÚdisable_nagle_algorithmrVr0ZIPPROTO_TCPZTCP_NODELAYÚmakefileÚrbufsizeÚrfileÚwbufsizeÚ _SocketWriterÚwfile)rrrrrzÿs zStreamRequestHandler.setupcCsF|jjs.y|jjƒWntjk r,YnX|jjƒ|jjƒdS)N)r…ÚclosedÚflushr0ÚerrorrXr‚)rrrrr|s zStreamRequestHandler.finishr]) rMrNrOrrƒr1rrzr|rrrrr ês c@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) r„cCs ||_dS)N)Ú_sock)rZsockrrrrsz_SocketWriter.__init__cCsdS)NTr)rrrrÚwritablesz_SocketWriter.writablec Cs&|jj|ƒt|ƒ}|jSQRXdS)N)r‰ZsendallÚ memoryviewÚnbytes)rÚbZviewrrrÚwrite"s z_SocketWriter.writecCs |jjƒS)N)r‰rY)rrrrrY'sz_SocketWriter.filenoN)rMrNrOrrŠrŽrYrrrrr„sr„c@seZdZdd„Zdd„ZdS)rcCs2ddlm}|j\|_|_||jƒ|_|ƒ|_dS)Nr)ÚBytesIO)Úiorr=Zpacketr0r‚r…)rrrrrrz.szDatagramRequestHandler.setupcCs|jj|jjƒ|jƒdS)N)r0Zsendtor…Úgetvaluer>)rrrrr|4szDatagramRequestHandler.finishN)rMrNrOrzr|rrrrr*s)$Ú__version__r0r%raÚerrnorFrÚImportErrorZdummy_threadingrrr3rÚ__all__ÚhasattrÚextendrr#ZSelectSelectorrrrrrrrrrrrrrr r r„rrrrrÚ{sZ n~X..-