Hgf< FdZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z m Z ddlmZmZmZddlmZdd lmZdd lmZmZmZmZmZmZmZmZmZdd lm Z m!Z!d Z"d Z#dZ$ dde%dee%dee%de&fdZ'Gdde(Z)Gdde(Z*dS)z Copyright (C) 2015 Red Hat This is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License version 2, as published by the Free Software Foundation. See file COPYING. N) OrderedDict)ioctlfnmatch) PrettyTableHEADER)signalSignalsSIGWINCH) TIOCGWINSZ) FrameType) AnyCallableDictListOptionalSequenceTextIOTupleUnion)parse_json_funcsigsvalidate_commandi asok_pathcmdformatreturncdtdtdtfd} ||d}n1#t$r$}tdt|zd}~wwxYwt |dd }t ||}|std |r||d < ||tj| d}n1#t$r$}td t|zd}~wwxYw|S) a Send a daemon (--admin-daemon) command 'cmd'. asok_path is the path to the admin socket; cmd is a list of strings; format may be set to one of the formatted forms to get output in that form (daemon commands don't support 'plain' output). path cmd_bytesrc\tjtjtj}|| ||dz|d}t |dkrtdtj d|\}d}d}||krJt||z t}||}||z }|t |z }||kJn1#t$r$} tdt| zd} ~ wwxYw|S) z0 helper: do all the actual low-level stream I/O rz"no data returned from admin socketz>Ir exception: N)socketAF_UNIX SOCK_STREAMconnectsendallrecvlen RuntimeErrorstructunpackminREAD_CHUNK_SIZE Exceptionstr) r!r"socklen_strlsock_retgotwantbitsock_es -/usr/lib/python3/dist-packages/ceph_daemon.py do_sockiozadmin_socket..do_sockio,s"}V^V-?@@ T < LLU* + + +iillG7||a"#GHHHtW--BAHC''1s7O44iiooCs3xx '' < < <}s6{{:;; ; <sB:C;; D)D$$D)s&{"prefix": "get_command_descriptions"}z(exception getting command descriptions: Nutf-8clizinvalid commandrr&) r4bytesr3r.rdecoderjsondumpsencode) rrrr>cmd_jsonesigdict valid_dictrets r= admin_socketrK"sL%2P9YFHH PPPEANOOOP"(//'":":EBBG!'3//J .,--- &% 83i 4:j#9#9#@#@#I#IJJ 333=3q6612223 Js, ( AAA%1C D!DDc^eZdZdZd dZdeeeffdZd dZd dZ de fdZ de fd Z dS) Termsize)PrNcV|\|_|_d|_dSNF) _gettermsizerowscolschangedselfs r=__init__zTermsize.__init__^s'#0022 49 r%c tj}tjddddd}tjdt |t|dd\}}||fS#t$r |j cYSwxYw)Nhhhhr) sysstdinfilenor/packr0rr IOError DEFAULT_SIZE)rWfdszrSrTs r=rRzTermsize._gettermsizebs %!!##BVQ1a00BvuRR/H/HII"1"MJD$:  % % %$ $ $ $ %sA-A00BBc|\}}|js|j|jf||fk|_||c|_|_dSN)rRrUrSrT)rWrSrTs r=updatezTermsize.updateksO&&(( d| B Ity1dD\ADL#T 4999r%cd|_dSrQ)rUrVs r= reset_changedzTermsize.reset_changedqs  r%c<d|j|j|j|jfzS)Nz%s(%dx%d, changed %s) __class__rSrTrUrVs r=__str__zTermsize.__str__ts(&$.*.)TY *NN Nr%c<d|j|j|j|jfzS)Nz %s(%d,%d,%s)rjrVs r=__repr__zTermsize.__repr__xs(!%DIt|!EE Er%rN) __name__ __module__ __qualname__rarXrintrRrfrhr4rlrnr%r=rMrM[sL%eCHo%%%%**** NNNNNE#EEEEEEr%rMc eZdZdZed\ZZZZZ Z Z Z dZ dZdZdZdZ d-d ed eeed ed dfdZded efdZ d.dededed efdZded efdZdeded efdZded efdZd eeee feffdZ!ded dfdZ"dedeee#fdeee#fd dfd Z$d!ed"ed#ed efd$Z%d/d%Z&d&e'ee(fd'ee)d dfd(Z*de+j,fd)ed*eeded dfd+Z-e+j,fded dfd,Z.dS)0 DaemonWatcherz Given a Ceph daemon's admin socket path, poll its performance counters and output a series of output lines showing the momentary values of counters of interest (those with the 'nick' property in Ceph's schema) rzz[1;%dmz[0;%dmzzNrasokstatpatsmin_priorc||_d|_d|_d|_||_t |_||_t|_ dSrQ) r_colored_stats_schema _statpatsr_stats_that_fit _min_priorMtermsize)rWrwrxrys r=rXzDaemonWatcher.__init__sI 15  !0; !  r%ostrcvtjdv}t|do|}|s|sdSdS)zl Returns True if the running system's terminal supports color, and False otherwise. )win32z Pocket PCisattyFT)r\platformhasattrr)rWrunsupported_platformis_a_ttys r=supports_colorzDaemonWatcher.supports_colorsG !$ 0F F4**>s5zzA~%% AID$#a&&T4Z0122UQY>> !88#qFdN';zJKG!,/ :5A&|4Y?FG#Gnn-V \*95A4..s1vv/3~~i/H/HJJJ3admG t}}S$)44 4GG!SsDI!>!>????@ 7>>'**+++++r%sectrprioc|jr:d|ftfd|jDsdS|j | ||jkSdS)a boolean: should we output this stat? 1) If self._statpats exists and the name filename-glob-matches anything in the list, and prio is high enough, or 2) If self._statpats doesn't exist and prio is high enough then yes. rcTg|]$}t|st|"|%Srtr)rprsectnames r=rz1DaemonWatcher._should_include..PsK4##'.x';';r%FNT)r~joinanyr)rWrrrrs ` @r=_should_includezDaemonWatcher._should_includeDs > xxt --H> u > %$*:DN* +tr%cJtjt|jddgdt |_t |_|jJ|jD]\}}|D]g\}}| dd}| |||r5||jvrt |j|<|d|j||<ht|jstd dS) z Populate our instance-local copy of the daemon's performance counter schema, and work out which stats we will display. perfschemar?)object_pairs_hookNpriorityrrzno stats selected by filters) rCloadsrKrrBrr}r|rgetrr-r.)rWr section_statsr schema_datars r= _load_schemazDaemonWatcher._load_schema[s7 z &(); < < C CG L L)+++ "mm |'''+/<+=+=+?+? J J 'L-%2%8%8%:%: J J!k"z155'' dDAAJ#4;664?MM L16A&6IDK -d3  J 4; ?=>> > ? ?r%signoframec8|jdSre)rrf)rWrrs r=_handle_sigwinchzDaemonWatcher._handle_sigwinchqs r%intervalcountc`||||_||t jt |jddgd}d} tt|j  t jt |jddgd}||j j dz kr||d}||||| |dz}|dkrdS|dz }|}tj|z}tj|kr?tj|tjz tj|k?#t"$rYdSwxYw) z{ Print output at regular intervals until interrupted. :param ostr: Stream to which to send output rrr?rTr[Nr)rrr{rrCrrKrrBr r rrrSrtimesleepKeyboardInterrupt)rWrrrrrows_since_headerrends r=runzDaemonWatcher.runvs ++D11  D!!!J|DNVV>>''---()%  tY777$QJEzz!Q&! ikkH,ikkC''JsTY[[0111ikkC'' 2$!    FF sB%F*A5F F-,F-ctd}d|jd<d|jd<d|jd<d|jd<||jJ|jJ|jD]`\}}|D]F\}}|j||d pd }|||||fGa|| t d zdS) zQ Show all selected stats with section, full name, nick, and prio )sectionrrrr7rrrrrNrr)hrulesr) ralignrr|r}rradd_rowr get_stringr)rWrtablerrrrrs r=listzDaemonWatcher.lists-?@@!$ I! F! F! F {&&&|'''+/;+<+<+>+> @ @ 'L-+1133 @ @ d|L1$7;;JGGL1 |T4>???? @ 5##6#22T9:::::r%)Nr)Fro)/rprqrr__doc__rangerREDGREENrrMAGENTACYANGRAYrrrrrr4rrrsrXrrrrrrrrrdictrrrrrrrr r rr\stdoutrrrtr%r=rvrv}s a       II!NHM6:!" # # ##HSM2 # #(, # # # # 6 d    $&&&&&),&&&&444444 CC<!c!c!!!!-E$sDy/4*?$@----46d<&, &,sCx.&, $CH~&,37&,&,&,&,PCs#$.????, %c7l 3 ( 38<$(:'''C=''+/''''R#&*;;;;;;;;;r%rv)r)+r r\rCr'r/r collectionsrfcntlrr prettytablerrr r r termiosr typesr typingrrrrrrrrr ceph_argparserrrrr2r4rArKobjectrMrvrtr%r=rs ######++++++++,,,,,,,,,,VVVVVVVVVVVVVVVVVVVVVV????????  *,66C63i6!#6056666rEEEEEvEEEDr;r;r;r;r;Fr;r;r;r;r;r%