OwlCyberSecurity - MANAGER
Edit File: dashboard_service.pyc
� �t�ac @ s� d d l m Z d d l m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l Z d e f d � � YZ d e f d � � YZ d S( i����( t JobItem( t inlineCallbackst succeedt returnValue( t ConnectError( t Factory( t LineReceiver( t config( t TestWork( t DirectoryService( t CachingDirectoryService( t WorkerConnectionPoolNt DashboardProtocolc B s� e Z d Z e j i d d 6� Z e j i d d 6� Z d � Z e d � � Z d � Z d � Z d � Z e d � � Z d � Z e d � � Z d � Z RS( s� A protocol that receives a line containing a JSON object representing a request, and returns a line containing a JSON object as a response. s unknown commandt results bad commandc s� | d k r* � j d � � j j � d S� f d � } y2 t j | � } t | t � rj � j | � n Wn$ t t f k r� | � j � n Xd S( s� Process a request which is expected to be a JSON object. @param line: The line which was received with the delimiter removed. @type line: C{bytes} t exitt quitt DoneNc s � j | � d S( N( t sendLine( R ( t self( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt _writeA s ( R R ( R t transportt loseConnectiont jsont loadst isinstancet listt process_datat ValueErrort KeyErrort bad_cmd( R t lineR t j( ( R s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt lineReceived3 s c c s� i } x� | D]� } t | d j | � � rJ t | d j | � � � V} n; | j d � r | j � V} | j | d d � } n d } | | | <q W| j t j | � � d S( Ns data_{}t stats_i t ( t hasattrt formatt getattrt startswitht data_statst getR R t dumps( R R t resultst dataR ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyR K s c C s t | j j j � � S( s� Return the logging protocol statistics. @return: a string containing the JSON result. @rtype: L{str} ( R t factoryt loggert getStats( R ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyR' Z s c C s� | j j d k r* t | j j j j � n d } g } xA | D]9 \ } } i | d 6} | j | j � � | j | � q= Wt i | d 6| j j d k r� | j j j n t d 6� S( s� Return the logging protocol statistics. @return: a string containing the JSON result. @rtype: L{str} t slott slotst overloadedN( ( R, t limitert Nonet tuplet dispatchert slavestatest updatet itemst appendR R1 t False( R t statesR* t numt statusR ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt data_slotsc s 0 c C s t t j � � S( sh Return a count of job types. @return: the JSON result. @rtype: L{int} ( R R t numberOfWorkTypes( R ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt data_jobcountr s c c sS | j j r? | j j j d � } t j | � V} | j � Vn i } t | � d S( s� Return a summary of the job queue. @return: a string containing the JSON result. @rtype: L{str} s DashboardProtocol.data_jobsN( R, t storet newTransactionR t histogramt commitR ( R t txnt records( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt data_jobs| s c C s` | j j r< | j j j } | j j � } | j j � } n g } d } t i | d 6| d 6� S( s� Return a summary of the job assignments to workers. @return: a string containing the JSON result. @rtype: L{str} i t workerst level( R, RA t poolt workerPoolt eachWorkerLoadt loadLevelR ( R RJ R RI ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt data_job_assignments� s c c s� i } | j j r� | j j j � } t j | � V| d <t j | d t j d k �V| d <t j j t j � d � | d <| j � Vn d | d <d | d <d | d <t | � d S( s� Return the number of TEST_WORK items in the job queue. @return: a string containing the JSON result. @rtype: L{str} t queuedt wheret assignedi t completedN( R, RA RB R t countR RQ R3 R RR R( t workTypeRD R ( R R* RE ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt data_test_work� s # c C sU y0 | j j d k r% | j j j � St i � SWn t t f k rP t i � SXd S( sx Return a summary of directory service calls. @return: the JSON result. @rtype: L{str} N( R, t directoryR3 t statsR t AttributeErrorR ( R ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt data_directory� s 0( t __name__t __module__t __doc__R R) t unknown_cmdR R R R R' R> R@ RG RN RU RY ( ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyR * s t DashboardServerc B s e Z e Z d � Z d � Z RS( c C s7 | | _ | | _ | j | j _ d | _ d | _ d S( N( R- R2 R3 RA RV ( R t logObserverR2 ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt __init__� s c C sj t j j rf t t j � | _ t j j rf t | j d t j j d t j j d t j j �| _ qf n d S( Nt expireSecondst lookupsBetweenPurgest negativeCaching( R t DirectoryProxyt Enabledt DirectoryProxyClientServicet DirectoryRealmNameRV t DirectoryCachingt CachingSecondsR t LookupsBetweenPurgest NegativeCachingEnabled( R ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt makeDirectoryProxyClient� s ( RZ R[ R t protocolR` Rl ( ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyR^ � s ( t twext.enterprise.jobs.jobitemR t twisted.internet.deferR R R t twisted.internet.errorR t twisted.internet.protocolR t twisted.protocols.basicR t twistedcaldav.configR t% txdav.common.datastore.work.load_workR t txdav.dps.clientR Rf t txdav.who.cacheR t twext.enterprise.jobs.queueR R R R^ ( ( ( s3 /opt/cpanel-ccs/calendarserver/dashboard_service.pyt <module> s �