/
proc
/
self
/
root
/
proc
/
thread-self
/
root
/
lib
/
fm-agent
/
plugins
/
__pycache__
/
up file
home
3 q��ipL � @ sH d dl Z d dlZd dlZd dlmZmZ e je�ZG dd� dej�Z dS )� N)�java�javaxc ' @ s� e Zd ZdZdZdZdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhd=�!Zed>d?� �Ze d@dA� �Z e dBdC� �Z e dDdE� �Z e dFdG� �Z dS )i�TomcatJMXPluginzCTomcat Plugin for the FortiMonitor Agent using JMX to collect data.Z tomcat_jmxz Tomcat (JMX)�Heap Memory Usage Used� java.lang�MemoryN�HeapMemoryUsage�used�bytes�Heap Memory Usage Committed� committed�Heap Memory Usage Init�init�Heap Memory Usage Max�max�Non-Heap Memory Usage Used�NonHeapMemoryUsage� Non-Heap Memory Usage Committed�Non-Heap Memory Usage Init�Non-Heap Memory Usage Max� Thread Count� Threading� ThreadCount�count�OS Process CPU Load�OperatingSystem�ProcessCpuLoad�percent�OS System CPU Load� SystemCpuLoad� OS Open File Descriptor Count�OpenFileDescriptorCount�Loaded Class Count� ClassLoading�LoadedClassCount� Eden Space� MemoryPool�Usage� PS Eden Space�Par Eden Space� G1 Eden Space�Survivor Space�PS Survivor Space�Par Survivor Space�G1 Survivor Space� PS Old Gen� CMS Old Gen� G1 Old Gen�Copy�GarbageCollector�CollectionCount� PS Scavenge�ParNew�G1 Young Generation�G1 Mixed Generation�MarkSweepCompact� PS MarkSweep�ConcurrentMarkSweep�G1 Old Generation)!z memory.heapzmemory.heap.committedzmemory.heap.initzmemory.heap.maxzmemory.non_heapzmemory.non_heap.committedzmemory.non_heap.initzmemory.non_heap.maxzthreading.countzos.cpu_load.processzos.cpu_load.systemzos.open_file_descriptorsz class_loading.loaded_classeszmemory_pool.edenzmemory_pool.eden.pszmemory_pool.eden.parzmemory_pool.eden.g1zmemory_pool.survivorzmemory_pool.survivor.pszmemory_pool.survivor.parzmemory_pool.survivor.g1zmemory_pool.old.pszmemory_pool.old.cmszmemory_pool.old.g1z gc.young.copyzgc.young.ps_scavengezgc.young.par_newzgc.young.g1_generationzgc.mixed.g1_generationzgc.old.mark_sweep_compactzgc.old.ps_mark_sweepz gc.old.concurrent_mark_sweepzgc.old.g1_generationc C sP | d | d | d }}}d| }|r4|d| 7 }|rD|d| 7 }t jj|�S )a� returns a constructed ObjectName. :type tuple_: tuple (label, domain, type, bean_name, attribute_name, composite_data_key, unit) :param tuple_: A tuple with all the information for an ObjectName. A string that represents the label, a string that represents the domain, and so on and so forth. :rtype: javax.management.ObjectName :return: An ObjectName object that can be used to lookup a MBean. � � � z%s:zname=%s,ztype=%s)r � management� ObjectName)�tuple_�domain�type_Z bean_nameZcanonical_name� rE �'/usr/lib/fm-agent/plugins/tomcat_jmx.pyZ __get_object_name_from_tupleB s z,TomcatJMXPlugin.__get_object_name_from_tuplec C s dddddg}i }x`|D ]X}|j |�}| rB|d krBtd| ��q| rT|d krTqqdd� |jd �D �}|||< qW i }|d }x�t|�D ]�\} } d| i|| < xtdD ]l}t|j |g ��d kr�|| | } n:t|j |g ��d kr�|| d } n|dkr�td| ��nq�| || |< q�W q�W |S )a� Parse the config object to build a structure of connections parameters based on the number of entries that are in each key. The main parameter we base on to split off is host. :type config: dict (host, port, username, password, jvm_path) :param config: Dictionary with the information stored in the config file. :rtype: Dict :return: Dictionary with connection information split up in multiple if needed. �host�port�username�password�jvm_pathz"Missing %s information from configc S s g | ]}|j d ��qS )� )�strip)�.0�valuerE rE rF � <listcomp>q s z?TomcatJMXPlugin.get_connections_from_config.<locals>.<listcomp>�,r= r )rI rJ )rI rJ )rH rI rJ rK )rI rJ )�get� ValueError�split� enumerate�len) �cls�config�keys�data�key� key_value�values� connections�hosts�indexrG rO rE rE rF �get_connections_from_configZ s0 z+TomcatJMXPlugin.get_connections_from_configc C s� t j}d}|s$d}| jj|� t j}d|ks4d|krPd| j }| jj|� t j}|jd�}|s�y,tj� }|s�t j}d| j }| jj|� W n( t j}d| j }| jj|� Y nX y"|t jkr�tj � r�tj |� W n" t j}d}| jj|� Y nX |t jk�r�y�tj � �s tj |� t j j � }|jd ��rt|jd ��rttjt jj�|jd �|jd �g�}|jtjjjj|� d |jd�t|jd��f }tjjj|�}tjjjj||�} | j� } || dfS t k �r� d }| jj |� Y nX |d|fS ) a� returns a list of connections from the jpype library - a python interface to the Java Native Interface. Wheter there are 1 or many connections depends on the number of entries in the host, port and optionally username/password/jvm entries. :type config: dict :param config: Mapping of information under the application block for this plugin. :rtype: tuple (status, connection, error_message) :return: A tuple containing a numeric value corresponding to the agent_util status'. A MBeanServerConnection object. And, a string with an error message if any. NzNo JMX configuration foundrG rH zJMissing value in the [%s] block of the agent config file (e.g host, port).rK zYUnable to find JVM, please specify 'jvm_path' in the [%s] block of the agent config file.z;Unable to access JMX metrics because JVM cannot be started.rI rJ z*service:jmx:rmi:///jndi/rmi://%s:%s/jmxrmizBUnable to access JMX metrics, JMX is not running or not installed.) � agent_util� SUPPORTED�log�info� MISCONFIGURED�textkeyrR �jpype�getDefaultJVMPath� isJVMStarted�startJVMr �util�HashMap�JArray�lang�String�putr r@ �remote� JMXConnector� CREDENTIALS�int� JMXServiceURL�JMXConnectorFactory�connect�getMBeanServerConnection� Exception� exception) rW rX �status�msgrK Zj_hashZj_array�urlZjmx_urlZjmx_soc� connectionrE rE rF Z__get_connection� sl z TomcatJMXPlugin.__get_connectionc C s� i }| j |�}i }g }xT|j� D ]H}| j|�\}}} d|d |d f } | r`|jd| | f � q ||| < q W |j� s�| jjd� x|D ]} | jj| � q�W |S tj }d} x|D ]} | jj | � q�W x�| j j � D ]�\} } | j | �}g }xZ|j � D ]N\} }y|j|� |j| � W q� tk �r: | jjd|| f � w�Y q�X q�W t|j� �dk�rn| �rnd }tj}d | } n d} tj }| d | d }}|||| |d �|| < q�W |S )a returns a json object who's textkeys correspond to a given metric available on the JVM. :type config: dict :param config: Mapping of information under the application block for this plugin. :return: JSON Object for all metrics z%s:%srG rH z%s %sz#Unable to connect to any connection� z.Tomcat (JMX) plugin - %s bean not found at %s.r= Nz Unreachable %s at any connectionr � )�label�optionsr| � error_message�unit)ra r] � _TomcatJMXPlugin__get_connection�appendrY rd re �errorrb rc �warning� JMX_MAPPING�items�,_TomcatJMXPlugin__get_object_name_from_tuple�getObjectInstancerz r{ rV � UNSUPPORTED)rW rX �result�configsr^ �errors�entryr| r r} Zconnection_keyr� r[ rB � object_namer� r� r� rE rE rF � get_metadata� sX z TomcatJMXPlugin.get_metadatac C s | j |�}|rBx:|j� D ]$}d|d |d f }||kr|}qW n|d }| j|�\}}} | rr| jjd| � dS | jj|�} | d | d } } | j| �} yR|j| �}|j |j � | �}|j j }d |kr�|j � S |j| �s�dS |j| �}|j � S | jjd | � dS dS ) a� returns a value for the metric. :type textkey: string :param textkey: Canonical name for a metric. :type data: string :param data: Specific option to check for. :type config: dict :param config: Mapping of information under the application block for this plugin. :rtype: double :return: Value for a specific metric z%s:%srG rH r z Failed to get a connection: %sN� � ZCompositeDataSupportz(Tomcat (JMX) plugin - %s bean not found.)ra r] r� rd re r� rR r� r� � getAttributeZ getObjectName� __class__�__name__� floatValueZ containsKey)rW rg rZ rX �entriesr� Zpossible_matchr| r r} rB Zattribute_nameZcomposite_data_keyr� Zobject_instanceZattribute_valueZattribute_class_nameZ check_resultrE rE rF �check; s8 zTomcatJMXPlugin.check)r r r Nr r r )r r r Nr r r )r r r Nr r r )r r r Nr r r )r r r Nr r r )r r r Nr r r )r r r Nr r r )r r r Nr r r )r r r Nr Nr )r r r Nr Nr )r r r Nr Nr )r r r Nr! Nr )r" r r# Nr$ Nr )r% r r& r% r' r r )r( r r& r( r' r r )r) r r& r) r' r r )r* r r& r* r' r r )r+ r r& r+ r' r r )r, r r& r, r' r r )r- r r& r- r' r r )r. r r& r. r' r r )r/ r r& r/ r' r r )r0 r r& r0 r' r r )r1 r r& r1 r' r r )r2 r r3 r2 r4 Nr )r5 r r& r5 r4 Nr )r6 r r3 r6 r4 Nr )r7 r r3 r7 r4 Nr )r8 r r3 r8 r4 Nr )r9 r r3 r9 r4 Nr )r: r r3 r: r4 Nr )r; r r3 r; r4 Nr )r< r r3 r< r4 Nr )r� � __module__� __qualname__�__doc__rg r� r� � staticmethodr� � classmethodra r� r� r� rE rE rE rF r s� . k Hr ) �loggingrb rh r r � getLoggerr� �logger�Pluginr rE rE rE rF �<module> s