관리-도구
편집 파일: wsgi-loader.pyo
� Bi�fc @ s# d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z e j d d k r� e j d d k r� d d l m Z n d d l Z i a d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e j d d k r�d � Z d � Z d � Z n d � Z d � Z d � Z d d# d � � YZ! e" d k r e � e d d � e d d � y e � Wn! e# k r e d d � � n Xe d d � e d! d � y e � Z$ Wn! e# k rXe d! d � � n Xe d! d � e d" d � yB e � Z% e% \ Z& Z' e � e! e' e j( e$ j) � Z* e e& � Wn! e# k r�e d" d � � n Xe d" d � e � e* j+ � y e j, e& � Wq e- k rq Xn d S($ i����Ni i i i ( t utilc C s% t j j | d � t j d � d S( Ns i ( t syst stderrt writet exit( t message( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt abort# s c C s_ y) t | d � � } | j | � Wd QXWn/ t k rZ } t j d | d | j � n Xd S( Nt ws Warning: unable to write to s : ( t openR t IOErrort loggingt warnt strerror( t patht contentst ft e( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt try_write_file' s c C s< t j d t j d d � t t d � r8 t j t � n d S( Nt levelt formats2 [ pid=%(process)d, time=%(asctime)s ]: %(message)st captureWarnings( R t basicConfigt WARNINGt hasattrR t True( ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt initialize_logging. s c C sD t j d � } | d } t | d � � } t j | � a Wd QXd S( Nt PASSENGER_SPAWN_WORK_DIRs /args.jsont r( t ost getenvR t jsont loadt options( t work_dirR R ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt read_startup_arguments5 s c C sU t j d � } | d | j � } t | d | � t | d t t j � � � d S( NR s /response/steps/s /states /begin_time( R R t lowerR t strt time( t stept stateR! t step_dir( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt record_journey_step_begin> s c C s� t j d � } | d | j � } t | d | � t j j | d � r� t j j | d � r� t | d t t j � � � n t | d t t j � � � d S( NR s /response/steps/s /states /begin_times /begin_time_monotonics /end_time( R R R# R R t existsR$ R% ( R& R' R! R( ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt record_journey_step_endE s . c C s� t j j d t j � � t j d d � } t j d d k r� t j d d k r� t j d | � } t j | � } | j j | � | St j d | � Sd S( Ni t startup_files passenger_wsgi.pyi i i t passenger_wsgi( R R t insertR t getcwdR t gett version_infoR t spec_from_file_locationt module_from_spect loadert exec_modulet impt load_source( R, t spect app_module( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt load_appN s &c C s� t t j d d � � } d t k r7 t d } d } n t j � } d } d } xw | d k r� y t | | | � SWqR t j k r� } | j t j k r� | d 7} | d k r� | � q� q� | � qR XqR Wd S( Nt UNIX_PATH_MAXid t socket_dirt wsgit PsgWsgiAppi i� i ( t intR R0 t tempfilet gettempdirt make_sockett sockett errort errnot EADDRINUSE( R; R< t socket_prefixt iR ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt create_server_socket] s c C s� t j t j t j � } t t j d t j d � � d d � } | d | d | } | d | !} | j | � | j d � | | f S( Nt Qi i t xt /t .i� ( RC t AF_UNIXt SOCK_STREAMR t structt unpackR t urandomt bindt listen( R< RG R; t st socket_suffixt filename( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyRB t s ( c s/ d � � � f d � } t j t j | � d S( Nc S s� t g t j � D] } | j | j f ^ q � } g } x� t j � j � D]� \ } } | j d | j | d � | f � x] t j | � D]L \ } } } } | j d | | | f � | r� | j d | j � � q� q� WqJ Wd j | � GHd S( Ns # Thread: %s(%d)t s File: "%s", line %d, in %ss %ss ( t dictt threadingt enumeratet identt nameR t _current_framest itemst appendR0 t tracebackt extract_stackt stript join( t sigt framet tht id2namet codet thread_idt stackRW t linenoR] t line( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt debug~ s 1 #""c s � | | � t j d � d S( Ni ( R R ( Re Rf ( Rn ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt debug_and_exit� s ( t signalt SIGABRT( Ro ( ( Rn sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt install_signal_handlers} s c C s| t j d � } | d } i i d d 6d | d 6d d 6d d 6t d 6g d 6} t | d � � } t j | | � Wd QXd S( NR s /response/properties.jsont mainR] s unix:t addresst sessiont protocoli t concurrencyt accept_http_requestst socketsR ( R R R R R t dump( t socket_filenameR! R t docR ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt advertise_sockets� s c C sB t j d � } | d } t | d � � } | j d � Wd QXd S( NR s /response/finishR t 1( R R R R ( R! R R ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt advertise_readiness� s c C s" | d j | d | d � � d S( Ni i i ( t with_traceback( t exc_info( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt reraise_exception� s c C s | j d � S( Ns latin-1( t decode( t b( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt bytes_to_str� s c C s$ t | t � r | S| j d � Sd S( Ns latin-1( t isinstancet bytest encode( RU ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt str_to_bytes� s c B s d d Ud S( Ns+ raise exc_info[0], exc_info[1], exc_info[2]( ( R� ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� � s c C s | S( N( ( R� ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� � s c C s | S( N( ( RU ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� � s t RequestHandlerc B sb e Z d � Z d � Z d � Z d � Z e e d � rE d � Z n d � Z d � Z d � Z RS( c C s | | _ | | _ | | _ d S( N( t servert owner_pipet app( t selft server_socketR� R� ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt __init__� s c C ss t } yUxN| sY| j � \ } } | s4 t } Pn t } z� yW | j | � \ } } | r� | d d k r{ | j | � q� | j | | | � } n Wn{ t k r� t } ne t k r� } t | d t � s� | j t j k rt j d � qn t k rt j d � n XWd | sUy | j t j � Wn n Xy | j � WqUqUXn Xq WWn t k rnn Xd S( Nt REQUEST_METHODt pingt passengers) WSGI application raised an I/O exception!s% WSGI application raised an exception!( t Falset accept_connectionR t parse_requestt process_pingt process_requestt KeyboardInterruptR t getattrRE t EPIPER t exceptiont Exceptiont shutdownRC t SHUT_WRt close( R� t donet clientRt t socket_hijackedt envt input_streamR ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt main_loop� sB % c C sU t j | j | j j � g g g � d } | j j � | k rM | j j � Sd Sd S( Ni ( NN( t selectR� R� t filenot acceptt None( R� t result( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� � s + c C s: d } xO t | � d k rW | j d t | � � } t | � d k rJ d S| | 7} q Wt j d | � d } d } xO t | � | k r� | j | t | � � } t | � d k r� d S| | 7} qw W| j d � } | j � i } d } xB | t | � k r/t | | d � | t | | � <| d 7} q� W| | f S( NRX i i s >Is i i ( NN( NN( t lent recvR� RP RQ t splitt popR� ( R� R� t buft tmpt header_sizet headersR� RH ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� � s* "t _fileobjectc C s t j | d d � S( Nt rbi ( RC R� ( R� t sock( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt wrap_input_socket s c C s t j j | d d � S( NR� i ( RC t makefile( R� R� ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� s c sc | j | � � d <t j � d <d � d <t � d <t � d <t � d <� j d d � d k rm d � d <n d � d <g � g � � d d k � � � � � f d � � d � � � f d � } t � � f d � } | � d <| j � | � } d � k rt Sz; x! | D] } | r� | � qqW� s>� d � n Wd t | d � r^| j � n Xt S( Ns wsgi.inputs wsgi.errorsi i s wsgi.versions wsgi.multithreads wsgi.multiprocesss wsgi.run_oncet HTTPSt offt onR~ t truet yest httpss wsgi.url_schemet httpR� t HEADc s� y� � s t d � � nl � s� � \ } } � (� j t d | | f � � x% | D] } � j t d | � � qS W� j d � n � s� � j t | � � n Wn) t k r� } t | d t � | � n Xd S( Ns write() before start_response()s, HTTP/1.1 %s Status: %s Connection: close s %s: %s s R� ( t AssertionErrort sendallR� R t setattrR ( t datat statust response_headerst headerR ( t headers_sentt headers_sett is_headt output_stream( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR . s c sP | r* z � r t | � n Wd d } Xn � r? t d � � n | | g � (� S( Ns Headers already set!( R� R� R� ( R� R� R� ( R� R� R ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt start_responseC s c s | r � � d <� Sd S( Ns passenger.hijacked_socket( ( t do_it( R� R� ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt hijackU s s passenger.hijacks passenger.hijacked_socketRX R� ( i i ( R� R~ R� R� ( R� R R R� R R0 R� R� R R� ( R� R� R� R� R� R� R� R� ( ( R� R� R� R� R� R sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� s8 c C s | j d � d S( Nt pong( R� ( R� R� ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� m s ( t __name__t __module__R� R� R� R� R RC R� R� R� ( ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyR� � s ' Vt __main__t SUBPROCESS_EXEC_WRAPPERt STEP_PERFORMEDt SUBPROCESS_WRAPPER_PREPARATIONt STEP_IN_PROGRESSt STEP_ERROREDt SUBPROCESS_APP_LOAD_OR_EXECt SUBPROCESS_LISTEN( (. R R RZ Rp Ra RC R� RP R RE R@ R R% R1 t importlibR R6 R R R R R" R) R+ R: RI RB Rr R} R R� R� R� R� R� R� R9 t tupleR{ R� t stdint applicationt handlerR� t removet OSError( ( ( sT /opt/cpanel/ea-ruby27/src/passenger-release-6.0.23/src/helper-scripts/wsgi-loader.pyt <module> sv x$& �