kcssdZddlZddlZddlZddlZddlmZddlmcm Z ddl mcm Z ddlmcmZddlmcmZddlmcmZej)dZddlmZ ddlmZmZGddZGd d e j<ZGd d e j@Z!d Z"ejFdejHZ%dZ&d"dZ'dZ(ejFdZ)dZ*e+dk(re,ejZdkre.dejZdzyddl/mcm0Z0ddl1mcm2Z2ddl3mcm4Z4ddl5mcm6Z6ddl7mcm8Z8ddl9mcm:Z:e:jvdZ<ejzej|Z?e0jdddZAe2jejZdZCe4jheCZDe!deEejZde$Id: http_server.py,v 1.12 2004/04/21 15:11:44 akuchling Exp $N)as_bytes)counter)unquote splitqueryceZdZdZeZdZdZdZdZ dZ dZ dZ d Z d Zd Zded Zd ZdZej(dZdZdZdZdZdZdZdfdZdZeZdZdZ dZ!iddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;idd?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`daZ"dbjGdcZ$ddZ%y)g http_requestNc<|\|_|_|_|_|_|_g|_dtztjtjd|_ g|_ tjj|_d|_i|_y)Nz Medusa/%s)ServerDate)channelrequestcommanduriversionheaderoutgoingVERSION_STRING http_datebuild_http_datetime reply_headers _http_request__reply_header_listr request_counter incrementrequest_number _split_uri _header_cacheselfargss ?/usr/lib/python3/dist-packages/supervisor/medusa/http_server.py__init__zhttp_request.__init__9s t| tx  "-">"+";";TYY["I$& *::DDFc"||j|<yNr)r"keyvalues r$ __setitem__zhttp_request.__setitem__Ps"'3r&c |j|Sr(r)r"r*s r$ __getitem__zhttp_request.__getitem__Ss!!#&&r&c||jvSr(r)r.s r$ __contains__zhttp_request.__contains__Vd((((r&c||jvSr(r)r.s r$has_keyzhttp_request.has_keyYr2r&c|jjDcgc]}d|z }}dj|j|jg|zdz}t |Scc}w)N%s: %s  )ritemsjoinresponse reply_coder)r"item header_itemsresults r$build_reply_headerzhttp_request.build_reply_header\sh484F4F4L4L4NOD4O O ]]4?? + ,| ;=?IJPs A'c>|jj||fy)z$ Adds a header to the reply headers N)rappend)r"namer+s r$ add_headerzhttp_request.add_headerms   ''u 6r&cV|jjg|jddy)z Clears the reply header list N)rclearrr"s r$ clear_headerszhttp_request.clear_headersqs&   "&(  #r&c~d}||jvr#||j||k(r|j|=d}g}|||f|jvr5||fg}d}n-|jD]}|d|k(s |j|d} |s|d|z}n|d|}td|z|D]}|jj |y)z Removes the specified header. If a value is provided, the name and value must match to remove the header. If the value is None, removes all headers with that name.rNr z%s: zHeader '%s' not found)rrrB LookupErrorremove)r"rCr+found_itremoved_headersh search_values r$ remove_headerzhttp_request.remove_headerys D&& & ]    % .""4(H}e} 8 88$(%=/-- !Q44<#**1- H ! }#d{ +/7 5 DE E  /A  $ $ + +A . /r&c|jdd}|Dcgc]\}}| }}}|jjD].\}}||vs |j||f|j|0|Scc}}w)zP Get the tuple of headers that will be used for generating reply headersN)rrr9rB)r" header_tuplesnv header_namess r$get_reply_headerszhttp_request.get_reply_headerss003 &33ca3 3%%++- 'CAa $$$aU+##A& '4s A1c|j}|j|jg}||Dcgc]}d|z c}z }dj|dzScc}w)zE Gets the reply header (including status and additional crlf)r6r7r8)rWr;r<r:)r"rSheadersrOs r$get_reply_header_textz"http_request.get_reply_header_textsY..0 ==12-8QHqL88{{7#j009s Az#([^;?#]*)(;[^?#]*)?(\?[^#]*)?(#.*)?c|jk|jj|j}|j t |jk7r t d|j|_|jS)Nz Broken URI)r path_regexmatchrendlen ValueErrorgroups)r"ms r$ split_urizhttp_request.split_uris\ ?? "%%txx0Auuw#dhh-' .."#((*r&c|jD]B}|j|}|jt|k(s1|j |cSyN)rr]r^r_group)r"head_regrglinerbs r$get_header_with_regexz"http_request.get_header_with_regexsHKK 'D%Auuw#d)#ww& 'r&c|j}|j}||vrK|dz}t|}|jD]&}|d|j|k(s||d}|||<|cSd||<y||S)NrJ)lowerr r_r)r"rhcrOhlrirs r$ get_headerzhttp_request.get_headers      AQB  9??$)RS A!"BvJH   BvJf: r&c|jr|jj|y|jdt|zdy)Nz*Dropping %d bytes of incoming request datawarning) collectorcollect_incoming_datalog_infor_r"datas r$rtz"http_request.collect_incoming_datas6 >> NN 0 0$ 7 MM@3t9L r&cv|jr|jjy|jddy)Nz-Unexpected end-of-record for incoming requestrr)rsfound_terminatorrurGs r$ryzhttp_request.found_terminators+ >> NN + + - MMC r&ct|tr t|}t|tr t j |t |}|jj|y)N) buffer_size) isinstancestrrbytes producerssimple_producerr_rrB)r"things r$pushzhttp_request.push sI eS !UOE eU #--eULE U#r&cR|j|}||_d|j||fzS)Nz HTTP/%s %d %s) responsesr<r)r"codemessages r$r;zhttp_request.responses-..&$,,g!>>>r&c||_|j|}|j||dz}t|}t ||d<d|d<|j ||j y)N)rrContent-Lengthz text/htmlz Content-Type)r<rDEFAULT_ERROR_MESSAGErr_rdone)r"rrss r$errorzhttp_request.errorsj..&  & &"*  QK!$Q *^ !  r&ctt|jj}d}d}|jdk(r|dk(r d|vrd}nXd|d<nRd}nO|jdk(r2|d k(rd}n8d|vr4d |vr |d d k(s(d}n%|j rd |d <d}nd}n|jd}t j|j}|rd |d<|rJt jt j|j}t j||g}n;|jjd|t j|j}|jjt jt j ||j"d |j_|r|jj'y y ) z;finalize this transaction - send output to the http channelrz1.0z keep-aliverr z Keep-Alive Connectionz1.1closezTransfer-EncodingchunkedN)rp CONNECTIONrrlr use_chunkedrrrZchunked_producercomposite_producerrinsertrpush_with_producerglobbing_producerhooked_producerlogcurrent_requestclose_when_done)r" connectionclose_itwrap_in_chunkingoutgoing_headeroutgoing_producers r$rzhttp_request.done(s DKK8>>@  <<5 \)#4/ H)5D& \\U "W$!-&$. 34 A#$%%09D,-'($ H \\ ! H#33D4N4N4PQ !(D   ) : :00$--@! !* < < "34!  MM O 4 ) < zError responsezzz

Error response

z

Error code %(code)d.z

Message: %(message)s.zrfcyr()r"msglevels r$ruzhttp_request.log_info r&r()r )&__name__ __module__ __qualname__r<rrrrsr%r,r/r1r4r@rDrHrQrWrZrecompiler\rcrjrprtryrr;r reply_nowrrrrr:rrurr&r$r r &sJiOKI .(')) "7)%/P01* 2J ($? IJ+XC( & & && &  &  & 0 & & & "& #& $& $& & & & !&" #&$ #%&& '&( )&* %+&, !-&. 0/&0 #1&2 3&4 5&6 "7&8 &9&: +;&< (=&> )?&@ (A&B "C&D E&F'#-K&IR#KK   r&r creZdZdZdZeZdZdZdZ dZ dZ dZ d Z d Zd Zd Zd ZdZdZdZy) http_channeliNcztjj|_t |_t jj||||_ ||_ |jdd|_ ttj|_|j|_|j#y)Ns r&)rchannel_counterrchannel_numberrrasynchat async_chatr%rrset_terminator in_bufferintr creation_time last_usedcheck_maintenance)r"rconnrs r$r%zhttp_channel.__init__s*::DDF&y$$dD1   [) $))+.++  r&ctjj|dd}d|d|jd|jdS)Nr )rr__repr__rr)r"ars r$rzhttp_channel.__repr__s>  ) )$ /" 5##$$ r&rcX|j|jzs|jyyr()rmaintenance_interval maintenancerGs r$rzhttp_channel.check_maintenances'""T%>%>>    ?r&c$|jyr() kill_zombiesrGs r$rzhttp_channel.maintenances r&ic$ttj}ttjj D]I}|j |j k(s||jz |jkDs:|jKyr() rrlistasyncore socket_mapvalues __class__rzombie_timeoutr)r"nowrs r$rzhttp_channel.kill_zombiessi499;H//6689 $G  DNN2'+++w/E/EEMMO $r&ctjj||}|jjj t |ttj|_ |Sr() rrsendr bytes_outrr_rrr)r"rwr?s r$rzhttp_channel.sendsM$$))46 ''T3diik* r&c0 tjj||}|jjj t |ttj|_ |S#t$rtjdYywxYw)NzOut of Memory!) rrrecvrbytes_inrr_rrr MemoryErrorsysexit)r"r{r?s r$rzhttp_channel.recvsp (((--t[AF KK * *CK 8 $))+.DNM ( HH& ' (sA1A44BBctjdd\}}|tur||tjj |y)Nr)rexc_info SystemExitrr handle_error)r"trUs r$rzhttp_channel.handle_errors<||~bq!1 ?A$J    , ,d 3r&cyr(rr!s r$rzhttp_channel.log$rr&c||jr|jj|y|j|z|_yr()rrtrrvs r$rtz"http_channel.collect_incoming_data+s1     6 6 ="^^d2DNr&c B|jr|jjy|j}d|_|jd}|r|ds |dd}|r|ds |s|j y|d}t |\}}}t |dd}t|\}}d|vr|rt|dz|z}n t|}t||||||} |jj|jjj|0|jdt|zd| j!d y|jj"D].} | j%| s | |_| j'| y| j!dy#|jj(jt+j,\\} } } }}}|jd |d |d | d | d | j!dYy#YYyxYwxYw)Nr&s rr %?zBad HTTP request: %srrzServer Error: z, z: file: z line: rr)rryrsplitr crack_request join_headersrrr rrrtotal_requestsrureprrhandlersr]handle_request exceptionsrcompact_traceback)r"rlinesrrrrrpathrqueryrorOfilefunrirrUtbinfos r$ryzhttp_channel.found_terminator3s     1 1 3^^F DNLL)E a ab  a$$&AhG$17$; !GS'!59-F'sOME6e|!5/C/&8C!5/CdGWc7FKA  * * , KK & & 0 0 2 5W EwO  [[)) 77A;!/0,((!,# ( GGSM ! ..88::B:T:T:V7)sD1a UVWXY]^b(c(/1!GGSM! s%2FA!HHHHHc|jryt|jr8|jj}t |dr|j Syy)Nr stalled) ac_out_bufferr_ producer_fifofirsthasattrr)r"ps r$writable_for_proxyzhttp_channel.writable_for_proxyzsR    ## $""((*A9%99;& %r&)rrrac_out_buffer_sizerrrr%rrrrrrrrrrrtryrrr&r$rrscOiO !N$ (4 3ENr&rcTeZdZdezZeZd dZdZdZ dZ dZ dZ d d Z d Zd Zy) http_serverzHTTP Server (V%s)Nc||_||_tjj ||j t jt jg|_ |s#tjtj}|j|j||f|j!d|j j#\}}|s9|j%ddt j&t j(} t j*|d|_||_t3|_t3|_t3|_t3|_t3|_|s#tjtj}|rtj>|||_ ntj@||_ |j%dtBtEjFtEjD|j,|fzy#t j.$r|j%dd||_Y*wxYw)NizComputing default hostnamerrrzCannot do reverse lookupz2Medusa (V%s) started at %s Hostname: %s Port:%d )$ipportr dispatcherr% create_socketsocketAF_INET SOCK_STREAMr r file_loggerrstdoutset_reuse_addrbindlisten getsocknameru gethostbyname gethostname gethostbyaddr server_namer server_portr total_clientsr rrrresolving_loggerunresolving_loggerrrctime)r"r"r#resolver logger_objecthosts r$r%zhttp_server.__init__s $$d+ FNNF,>,>? ".. ;M  B: T[[,,. d MM6 B%%v'9'9';.nice_bytess77=!,- -r&gz

%s

z!
Listening on: Host: %szPort: %dz#

  • Total Clients: %szRequests: %szRequests/Client: %.1fz
  • Total Bytes In: %szBytes Out: %sz
  • Total Exceptions: %sz!

Extension List

    z
)supervisor.medusa.utilrQmap maybe_statusr r4r as_longfloatrrlines_producer SERVER_IDENTr2r#rrrr)r"rS_f handler_statsratiorQs @r$statuszhttp_server.statuss[8 .'*<&GN2N N   ''//1E$:L:L:T:T:V4WWEE++))&Z^ZkZkk;$JZJZZ)Z^ZcZcc8JNJ\J\].RVReRee7%O8:t}}OdOdOfCgh/:W[WeWeWmWmWoKpq:$//Y5    - -1:0I0I'0R/S T Os E$E$)NN)r)rrrrrZrrHr%r=r?rBrDrIrMrOr^rr&r$r r s?&7L M4l  .*. 'r&r c<t|dr|jSy)Nr^)rr^)rs r$rVrVsx ||~r&zConnection: (.*)cg}tt|D]2}||ddvr|d||ddz|d<|j||4|S)Nrz rr )ranger_rB)rYrois r$r r sb A 3w< " 1:a=E !bEGAJqrN*AbE HHgaj ! " Hr&r c|D]E}|j|}|s|jt|k(s4|j|cSyre)r]r^r_rg)rhrrgrirbs r$rprp$sF# NND ! CI%77E? "# r&cz|D]6}|j|}|s|jt|k(s4|cSyre)r]r^r_)rhrrirbs r$get_header_matchre+s= NND ! CI%H r&z%([^ ]+) ([^ ]+)(( HTTP/([0-9.]+))$|$)ctj|}|rd|jt|k(rH|j dr|j d}nd}|j d|j d|fSy)Nr r)NNN)REQUESTr]r^r_rg)rorbrs r$rr4sa qAQUUWA  771:ggajGGwwqz1771:w..r&__main__zusage: %s z 127.0.0.1fnordi'rfiU)r#r8r9iaz-pcL tjy#t$rYywxYwr()rloopKeyboardInterruptrr&r$ profile_looproXs"MMO(s  ##zprofile_loop()z profile.out)r )ORCS_IDrr&rrsupervisor.compatrsupervisor.medusa.asyncore_25medusa asyncore_25rsupervisor.medusa.asynchat_25 asynchat_25rsupervisor.medusa.http_datersupervisor.medusa.producersrsupervisor.medusa.loggerrrrsupervisor.medusa.counterrurllibrr ImportError urllib.parser rrr$r rVr IGNORECASErr rprerirrr_argvprintsupervisor.medusa.monitormonitorsupervisor.medusa.filesysfilesys!supervisor.medusa.default_handlerdefault_handlersupervisor.medusa.ftp_server ftp_serversupervisor.medusa.chat_server chat_serversupervisor.medusa.resolverr8caching_resolverrsr)r*lgsecure_monitor_serverms os_filesystemfsdhrhsrMdummy_authorizerftpcsroprofilerunrmrr&r$rsY K &10000///))"-1*e e X vH''vxA8&&AF RZZ+R]] ;   "**= >   z 388}q '388A;783333CC99;;55 &X & & 4 V   , *W * *G[$ G "W " "CHHQK 0 ,_ , ,b 1 S!-r2 6 B#j##+ ++CHHQK8  %[ $ $b$ / 388    GKK)= 9 HMMOCA1001s I)) I:9I: