3 Z_])@s<ddlZddlZddlZddlZddlZddlZddlmZmZmZm Z m Z ddl Z ddddgZ e e jfZeeefZdZe jdZe jd Ze jre jd Ze jre jd ZejZejZd Zdaeej j!d da"da#a$da%a&da'gZ(ddZ)ddZ*ddZ+ddZ,Gddde-Z.ddZ/ej0ddZ1ddZ2dS)N)eventgreenio greenthreadpatchertimeoutexecuteProxykillallset_num_threadsTsocket threadingQueuequeue ZEVENTLET_THREADPOOL_SIZEFcCsx|ytjd}|stWntk r.PYnXxHtjsxy&tjdd\}}|j|d}}Wq2tk rtYq2Xq2WqWdS)NF)block) _rsockrecvAssertionError ValueError_rspqemptygetsendEmpty)Z_cervr2/tmp/pip-build-yz_zf6az/eventlet/eventlet/tpool.pytpool_trampoline5s     r cCsxy tj}Wntk r"dSX|dkr0dS|\}}}}d}y|||}WnJtk rdYn6tk rtj}tjdkrtj |dj YnXt j rtj tj||fd}}}}}}tjtqWdS)Nr)r!r")_reqqrAttributeErrorSYS_EXCS EXC_CLASSESsysexc_info version_info traceback clear_frames __traceback__sixPY2Z exc_clearrput_wsocksendall _bytetosend)msgrmethargskwargsrrrrtworkerGs,   r7cOsttj}|tks&tjs&tdkr0|||Stj}t j ||||f|j }t |t rt|dkrt |dtr|\}}}tstj|||tjtj||||S)a Execute *meth* in a Python thread, blocking the current coroutine/ greenthread until the method completes. The primary use case for this is to wrap an object or module that is not amenable to monkeypatching or any of the other tricks that Eventlet uses to achieve cooperative yielding. With tpool, you can force such objects to cooperate with green threads by sticking them in native threads, at the cost of some overhead. rr!r)setupr currentThread_threadsimp lock_held _nthreadsrEventr#r/wait isinstancetuplelenr&QUIETr*print_exception print_stackr-reraise)r4r5r6Z my_threadrrctbrrrrcs     cOsD|jddr|||}nt|f||}t||r.doit)getattrrMhasattrr@rNrOr)rPrUrVr)rUrKrPr __getattr__s   zProxy.__getattr__cCst|j|jj|S)N)rLrNrM __getitem__)rPkeyrrrrZszProxy.__getitem__cCst|j|jj||S)N)rLrNrM __setitem__)rPr[valuerrrr\szProxy.__setitem__NcCst|j|jj|S)N)rLrNrM __deepcopy__)rPmemorrrr^szProxy.__deepcopy__cCst|j|jj|S)N)rLrNrM__copy__)rPr_rrrr`szProxy.__copy__cOs>d|jkr$tt|j|jf||St|j|jf||SdS)NrS)rOrrLrNrM)rPakwrrrrSs zProxy.__call__cCst|j|jjS)N)rLrNrM __enter__)rPrrrrcszProxy.__enter__cGst|j|jjf|S)N)rLrNrM__exit__)rPexcrrrrdszProxy.__exit__cCs |j|kS)N)rM)rPrhsrrr__eq__sz Proxy.__eq__cCs |jjS)N)rM__hash__)rPrrrrhszProxy.__hash__cCs |jjS)N)rM__repr__)rPrrrriszProxy.__repr__cCs |jjS)N)rM__str__)rPrrrrjsz Proxy.__str__cCs t|jS)N)rBrM)rPrrr__len__sz Proxy.__len__cCs t|jS)N)boolrM)rPrrr __nonzero__szProxy.__nonzero__cCs$t|j}||jkr|St|SdS)N)iterrMr)rPitrrr__iter__s  zProxy.__iter__cCst|jt|jS)N)rLrNnextrM)rPrrrrqsz Proxy.next)N)N)__name__ __module__ __qualname____doc__rRrYrZr\r^r`rSrcrdrgrhrirjrkrm__bool__rprq__next__rrrrrs(  cCs@trdSdatdkstdtdkr8ddl}|jdttd datd dat j t j t j }|j d |j dt j t j t j }|j|j|jt jt jd|j\a}tjdtjt jt jd|jtj|atjdxBtjjtD]2}tjtd|d }|j d|j!t"j#|qWt$j%t&a't(j)ddS) NTrz(Can't specify negative number of threadszZero threads in tpool. All tpool.execute calls will execute in main thread. Check the value of the environment variable EVENTLET_THREADPOOL_SIZE.r)maxsize 127.0.0.1ztpool_thread_%s)targetnamer|)ryr)*_setup_alreadyr=rwarningswarnRuntimeWarningr r#rr AF_INET SOCK_STREAMbindlistenconnect getsockname setsockopt IPPROTO_TCP TCP_NODELAYacceptr0 settimeoutcloserZ GreenSocketrr-movesranger Threadr7 setDaemonstartr:appendrZspawn_nr _coroeventletsleep)r~sockZcsockZ_addritrrrr8s<           r8c CstsdStjdxtD]}tjdqWxtD] }|jq0Wtdd=xRtdk rtj ry&tj dd\}}|j |d}}WqLt k rYqLXqLWt dk rt jt tdk rtjdatdk rtjdadadadS)NrF)r)r}rrr:r#r/joinrrrrrrrkillrrr0)Zthrrrrrrr .s2         cCs|adS)N)r=)Znthreadsrrrr Rs)3atexitr;osr'r*rrrrrrr-__all__ ExceptionTimeoutr& GeneratorExitKeyboardInterrupt SystemExitr%rCoriginalr r r.Z Queue_modulePY3rr r2rintenvironrr=r#rrr0r}r:r r7rrLobjectrr8registerr r rrrrsD       "h+$