ó #A]dc@sŒdZddlZddlZddlmZddlmZddlmZdZ dZ dZ d Z d Z d Zd efd „ƒYZdS(s;Bare-bones implementation of statsD's protocol, client-sideiÿÿÿÿN(tsub(tLogger(tsixtmetrictvaluetmtypetgaugetcountert histogramtStatsdcBs’eZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d d „Z d d „Zd„Zd„ZRS(s:statsD-based instrumentation, that passes as a logger cCs“tj||ƒtdd|jƒ|_yJ|j\}}tjtjtjƒ|_ |j j |t |ƒfƒWnt k rŽd|_ nXdS(s"host, port: statsD server s^(.+[^.]+)\.*$s\g<1>.N(Rt__init__Rt statsd_prefixtprefixt statsd_hosttsockettAF_INETt SOCK_DGRAMtsocktconnecttintt ExceptiontNone(tselftcfgthosttport((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR s  cOs*tj||||Ž|jddƒdS(Nsgunicorn.log.criticali(Rtcriticalt increment(Rtmsgtargstkwargs((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR'scOs*tj||||Ž|jddƒdS(Nsgunicorn.log.errori(RterrorR(RRRR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR+scOs*tj||||Ž|jddƒdS(Nsgunicorn.log.warningi(RtwarningR(RRRR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR /scOs*tj||||Ž|jddƒdS(Nsgunicorn.log.exceptioni(Rt exceptionR(RRRR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR!3scOs|jtj|||ŽdS(N(tlogtloggingtINFO(RRRR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pytinfo8scOs|jtj|||ŽdS(N(R"R#tDEBUG(RRRR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pytdebug<sc Osyï|jddƒ}|dk rÌ|jtdƒ}|jtdƒ}|jtdƒ}|rÌ|rÌ|rÌ|tkrˆ|j||ƒqÉ|tkr§|j||ƒqÉ|t krÉ|j ||ƒqÉqÌn|rît j |||||ŽnWn't k rt j|ddtƒnXdS(sDLog a given statistic if metric, value and type are present textrasFailed to log to statsdtexc_infoN(tgetRt METRIC_VARt VALUE_VARt MTYPE_VARt GAUGE_TYPERt COUNTER_TYPERtHISTOGRAM_TYPERRR"RR tTrue( RtlvlRRRR(RRttyp((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR"?s$      cCs¦tj|||||ƒ|jdt|jƒd }|j}t|tƒrnt|j d dƒdƒ}n|j d|ƒ|j ddƒ|j d|dƒd S( sNMeasure request duration request_time is a datetime.timedelta ièi iiisgunicorn.request.durationsgunicorn.requestssgunicorn.request.status.%dNiè( Rtaccesstsecondstfloatt microsecondststatust isinstancetstrRtsplitRRR(Rtresptreqtenviront request_timetduration_in_msR8((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR4Ys cCs#|jdj|j||ƒƒdS(Ns {0}{1}:{2}|g(t _sock_sendtformatR (RtnameR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyRhsgð?cCs&|jdj|j|||ƒƒdS(Ns{0}{1}:{2}|c|@{3}(RARBR (RRCRt sampling_rate((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyRkscCs&|jdj|j|||ƒƒdS(Ns{0}{1}:-{2}|c|@{3}(RARBR (RRCRRD((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyt decrementnscCs#|jdj|j||ƒƒdS(Ns {0}{1}:{2}|ms(RARBR (RRCR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyRqscCsryDt|tjƒr'|jdƒ}n|jrC|jj|ƒnWn'tk rmtj|ddt ƒnXdS(NtasciisError sending message to statsdR)( R9Rt text_typetencodeRtsendRRR R1(RR((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyRAts  (t__name__t __module__t__doc__R RRR R!R%R'R"R4RRRERRA(((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyR s            (RLRR#treRtgunicorn.gloggingRtgunicornRR+R,R-R.R/R0R (((sh/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/gunicorn/instrument/statsd.pyts