Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
3
1Sj 8 @ sL d dl mZmZ d dlmZmZ d dlmZmZmZ d dl m
Z
m Z d dl m
Z
mZ d dlmZmZ d dlmZ d dlmZmZmZmZmZ d d lmZ d d
l m Z d d l m Z d d l m Z d d
l!m"Z" d dl#m$Z$ d dl%m&Z& y d dl'Z'W n d dl(Z'Y nX d dl)Z)d dl*Z*d dl+Z+d dl,Z,d dl-Z-d dl.Z.d dl/Z/d dl0Z0d dl1Z1d dl2Z1d dl3Z3d dl4Z4d dl5Z5d dl6Z6d dl7Z7d dl%Z%d dl8Z8d dl9Z9d dl:Z:d dl;Z;d dlZ>W n G dd dZ?e? Z>Y nX y d dl@ZAW n d dlAZAY nX y d dlBZBW n> eCk
rH y d dlDZBW n eCk
rB dZBY nX Y nX yd dlEZEeEjFZGW n d dlHZHeHjIZGY nX deJe7krdd ZKeKe7_Ly d dlMZMW n d dlNjOZMd dlPjQZRY nX d dlSZSy d dlTZTW n eCk
r d dlUjVZTY nX dZWdZXG dd deYZZdd Z[d d Z\d d Z]d!d" Z^d#d$ Z_G d%d& d&e`ZadS )' )execute_commandwhich)datetime timedelta) Inspectorget_fqdnget_server_name) DEMClient IPCClient) NoAgentSectionHeaderExceptionNoManifestFileException)ForticlientHelpercalculate_customer_key)ProcessManager)basenameexistsisdirisfilejoin)PickleDatabase)
PluginManager)pprint)ProgressPrinter) ResultQueue)Schedule)exitN)PluginBlacklisterc @ s e Zd ZdZdS )SixTN)__name__
__module__ __qualname__PY2 r" r" "/usr/lib/fm-agent/library/agent.pyr 0 s r check_outputc O s> d|krt dtj| dtji|}|j \}}|j }|S )Nstdoutz3stdout argument not allowed, it will be overridden.)
ValueError
subprocessPopenPIPE communicatepoll) popenargskwargsprocessoutputZ
unused_errretcoder" r" r# fT s r1 z https://global.fortimonitor.comz9/usr/local/FortiMonitor/agent/data/fm_agent_install_blockc @ s e Zd ZdS )ExceptionMediatorN)r r r r" r" r" r# r2 r s r2 c C s | r| t j krdS dS )z
Return wheter the installation should be delayed or not. An installation is delayed
if there is a timestamp and our current time is less than that value.
TF)time)timeoutr" r" r# defer_installationv s r5 c C s. |sd}| st j } t|d d}| | |fS )z
Calculate the next wait period until the installation can be attempted again, is the last timestamp
plus the last seconds we waited times 2, until a maximum of 12 hours have been reached.
i )r3 min) timestampZwaitedZnext_wait_secsr" r" r# get_next_wait_period s r: c C sZ t jjtsdS d\} }tt,}|j }|jd\} }t| } t|}W dQ R X | |fS )z
Load the file that contains the time to wait until trying the next install, and the
amount of seconds we have waited so far.
N r ;)NN)r; r ) ospathr AGENT_INSTALL_BLOCKopenreadsplitfloatint)r9 secondsopeneddatar" r" r# load_failed_tries_file s
rH c C s. t td}|j| d| W dQ R X dS )z
Save a file containing the next time the install is allowed to proceed and the seconds we are
waiting for that timestamp.
zw+r< N)r@ r? write)r9 rE rF r" r" r# save_failed_tries_file s rJ c C s t jjdr:tdd }|j j }|jd}W dQ R X nt}dj| }|j drb|j
dd }n |j dr||j
dd }n|}d}t j |d t
j d
}|jd | |j }|jd kr|j jd
}ntd| d|j |S )a
Pull out the URL for the customer from the global mediator api to use instead of
the default.
Args:
customer_key: identifier for the customer to pull a single regional CP url.
Returns:
regional_agg_url: URL for the aggregator that the customer should use.
z/etc/fm_mediator_urlrb
Nz/aggregator_url/{}zhttps:// zhttp://
)hostr4 contextGET zutf-8z*Failed to grab agg url using customer key z. rS )r= r> r r@ rA decodestripDEFAULT_MEDIATOR_URLformat
startswithrB httplibZHTTPSConnectionsslZ_create_unverified_contextrequestZ getresponsestatusr2 ) customer_keyrF Z mediator_urlZuriZbase_urlaggregator_urlZ
connectionZrespr" r" r# get_regional_agg_url s*
r_ c @ s~ e Zd ZdZdZdZd`ddZd d
Zd d ZdaddZ dd Z
dd Z dd Z dbddZ
dd Zdd Zdcd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd1d2 Zd3d4 Zd5d6 Z d7d8 Z d9d: Z dddd?Z dfd@dAZ!dBdC Z"dDdE Z#dFdG Z$dHdI Z%dJdK Z&dLdM Z'dNdO Z(dPdQ Z)dRdS Z*dTdU Z+dVdW Z,dXdY Z-dZd[ Z.d\d] Z/d^d_ Z0d;S )gAgentZcustomINFO r7 rN c C sV t jj| js | jjd dS y0t| jj j j d\}}t
|}t
|}W n | jj dt j
dS yt j| W n tk
r dS X yhddl}|jt jd| jd }td| d j }|| jksd
|ksd | j |k r| j dS W n Y nX |rDtj | d |krD| jj d
| t j|d dS tj } | j | \}
} |
j r| jdkr| jj d| j y^t } | j t j!d}
| j"|
| j}
| jj ddj#|
x |
D ]}t jt
|d qW W n Y nX dS |dkr>| j$d7 _$|d 8 }| jj d|||f tj%| | j&||dS | jj d| dS dS )z/Check to see if it's safe to start up the agentz-No existing PID file found, proceeding to runT:z#Error reading existing PID file: %sr Nz/proc/%dz
ps -o cmd= %drM pythonz%s_agentg N@z&Found stale agent process %s - killing rootz7Uninstalling. Killing all process from the username %s z/proczFound pids %s rN z]Found existing agent process %s, sleeping for %s and checking %s more times if safe to start.)counterzAFound existing agent process %s, exiting to wait for it to finishF)'r= r> r pid_filelogdebugr@ rA rU rB rD critical traceback
format_excgetpgidOSErrorpwdgetpwuidstatst_uidr loweruserbrandremove_pid_filer3 killoptparse OptionParserparse_arguments uninstallr Zfilter_non_pid_processlistdirZget_process_from_userr current_agent_delaysleepsafe_to_start_agent)selfr4 Z
sleep_timeri pidr9 rr ZusernameZpsoutparseroptionsargsZmanagerZpidsr" r" r# r sr
zAgent.safe_to_start_agentc C s6 t j }ttj }t| jd}|jd||f dS )z+Create a new PID file to track our instancewz%s:%sN)r= getpidrD r3 r@ rj rI )r r nowr1 r" r" r# write_pid_file' s zAgent.write_pid_filec C s t jj| jrt j| j dS )z1Remove an old PID file to clean up on the way outN)r= r> r rj remove)r r" r" r# ry . s zAgent.remove_pid_fileFc C s d}t d| j |d}|j|}|r.|j n
|jd tjdkrt d| j |d}tjd| j | j| j
f |j d}t d| j d d
}|j t d | j d S ) NrM zNotifying %s of uninstall)indentzERROR CONNECTINGdarwinzremoving %r directoryzrm -rf %s %s %sz
uninstalling %s
T)sectionz
Uninstall of %s complete
)
r rx Znotify_of_uninstallfinishsysplatformlog_dirr= systemdb_dir
config_dirpkg_dirprint)r aggregator_clientremove_instancer ppsuccessr" r" r# r~ 5 s
zAgent.uninstallc C s t j }y.|j| j}|s"td|jds4tdW n t jtfk
r | jj t
t j t
jd dkrtjdt| jdj }n tjdt| jdj jd }|j| Y n( tk
r | jjt
t j Y nX |S ) z
Get the manifest configuration if it exists. Also, throw a deprecation
warning if the the manifest does not conform to the new-style format
(It must have an [agent] section heading).
zNo manifest file foundagentzUsing a manifest file without the section heading "[agent]" is deprecated; please add this heading to the file. Example:
[agent]
customer_key = customerkey
server_group = 123
r rc z[agent]
rzutf-8) configparser ConfigParserrA
manifest_filer has_sectionr ZMissingSectionHeaderErrorrk warningstrrn ro r version_infoStringIOr@ rT Zreadfpinfo)r manifestr Zamended_manifest_filer" r" r# get_manifestJ s&
zAgent.get_manifestc C sx t j }d}tjj| jrb| jjd t| jd}|j }|j
t j }|j | j | j ||}| j ||}|j
ds|jd |jdds|jdd| j |jdd| j d|jdkr|jdd}ng }| jj|}|r|jdd| tj }|j
d r|r|jdd} yttj| }
|
jr0|
j} n|
j} tj | s|jd x8dD ]0} |j| d}
|
dk rR|jd| |
j d qRW W n2 t j d }t |}| jj!d
j"| Y nX t| jd}|j#| |j
tj$d| j |dk rdt%j& }|j'|t| jdj }t(|}dd |D }t)|rV| jjd | jj*ddj+| n | jjd n| jjd| j |S )zo
Create/update the config file with the settings from the manifest.
Return the config.
NzExisting config file foundrK r r^ versionZplugin_blacklist agent_proxyhttpshttp/rM zInstall proxy error: {}r z chmod 640 %sr c S s$ g | ] }|j d s |j dr|qS )z+ z- )rX ).0liner" r" r#
s z&Agent.write_config..zConfig file overwrittenzConfig diff:
%s zNo change to config filezCreated new config file: %s)r r ),r r r= r> r config_filerk r r@ readlinescloserA copy_config_settingsr add_section
has_optionsetagg_urlr r get _blacklisterZ update_list
urlrequestZ
getproxiesurlparseschemehostnameZ proxy_bypassrU r exc_infor errorrW rI r difflibZDifferZcomparelistlenrl r )r r Z
new_configZold_config_linesZold_config_fileZ
old_configZoriginal_pluginsZupdated_pluginsZproxiesr Zagg_url_optionZ agg_hostnamekeyZp_urlerrr Znew_config_fileZdifferZ
diff_linesZchangesr" r" r# write_configp sr
zAgent.write_configc C sP xJ|j D ]>}|j|s"|j| x$|j|D ]\}}|j||| q.W q
W |S )z
Copy settings from the original to the destination, overwriting
destination's settings if they already exist.
)Zsectionsr r itemsr )r ZoriginalZ destinationr optionvaluer" r" r# r s
zAgent.copy_config_settingsc C s& | j jd t \}}t|rTtj|p,tj }| j jdt d| d t j
d@ | j rz|dkrzt d | j jd d S | j
| j| j| jf} tjd| | j jd | | j }
| j|
} i } | jd
r| d
} tj||||| d }
td d
| jdD }| jd
r| d
|
_td| j dd}|j ddj }|dkry2| j dd}t d| | j jd| ||
_ W n Y nX n|dkry| j }||d< |d }|d }t!||}||d< t"|}t#jd| d | ||
_ ||d< | j$dd| | j%t&| j'd tj(j)tr(tj*t W n` t+k
r } zBt,||\}}t-|| | j j.d | d | d t j
dA W Y d d }~X nX nt/d | d!| jd"rtd#d
| jd"D }ni }y |
j0| j1 ||\}}}}} W nd t d$ t d% x*|j2d&D ] } t d'tj(j3| d( q W | j jd)t4j5 t j
Y nX | s^| rt d*| | j jd*| t j
| j j6d+||||| f | r| | j7d,< d-| j8dkr*| j dd-j d.kr*d/| j8dkr*xF| j dd/j2d&D ]0} t9j:t j;tj(j3| j n | j j?d4| |j>d5| |r|r| j$dd6| | j%t&| j'd |rt d7| j@| j f | j jd8 nBtAdBtB|d: } d;| | }t d<| j@| j |f | j jCd= n,t d>| j@|| j@| j | jDf | j j?d?| | jE d S )CNzBegining installationz"Agent installation block found at z. Preventing install until .rc FzAgent already installedzmkdir -p %s %s %s %sz Created directories: %s %s %s %sr ) proxy_configc s s | ]\}}||j d fV qdS )z'"N)rU )r r r r" r" r# s z Agent.install..r z
Handshaking with %s serversrM )r handshake_typeZstandard forticlientr^ z8Using manifest file aggregator for initial handshake: %sZforticlient_metadata
ems_serialforticlient_environmentr] zOverwriting agg url with z for customer key r z Mediator error grabbing agg url z". Blocking agent installation for zUnexpected handshake type z. Aborting handshakeZ
attributesc s s | ]\}}||fV qd S )Nr" )r r r r" r" r# r / s zI
There was an error in the initial handshake with the aggregator, pleasezIcheck your aggregator URL, and ensure you have connectivity to retrieve:
,z %s
zv2/helloz Error in initial handshake: %szHandshake failed: %sz%s, %s, %s, %s, %s log_levelenable_countermeasurestrue countermeasures_remote_pluginszcountermeasure.pyZinstall_pluginsz--url)shellzInstallation failed:
%szERROR CONNECTING: %s
server_keyzxInstallation of %s complete. Your server will now sync automatically with the %s ControlPanel.
z-Agent will automatically sync with aggregatorP r7 rh z Installation of %s complete. Please copy and paste the following
server key into the %s ControlPanel for your server: %sz^The server key must be manually entered into the Control Panel before agent will begin syncingz Installation of %s had an error (%s). The %s is installed but it cannot sync correctly.
Please contact %s and send them the log file at %s zAggregator sync failed:
%sr g D@)Frk r rH r5 r Z
fromtimestampr3 r r? r r is_installedr r r r custom_plugin_dirr= r r r r
aggregatorClientdictr r r rx r rv r get_fortisase_attributesr r_ loggingr rI r@ r r> r r Exceptionr: rJ exceptionr& Z handshake get_all_ipsrB r rn ro rl dbr r' run
executablebin_dirrU r rm r rD r r log_filemigrate_config) r r r r r] forceZ block_foundZ
waited_forZuntildirsr configr r Zagent_settingsr r handshake_datar environmentZexpected_customer_keyr Z block_untilrE Zserver_attributesr found_serverr r urlZpaddingr" r" r# install s
z
Agent.installc C s g }t d}|}dtjks$dtjkr,|d }dtjkrt d}|rtd| \}}|dkrx|jd D ]8}|j jd
sf| sf|d krqf|j }|j|d qfW n|odtjkrt|\}}|dkr6tjd krtj d|}dd |D }ndd tj d|D }n.t d} td| \}}dd tj d|D }dd |D }dd |D }d|krjd||j
d< |s| j j d t
j| j| j| jd}
y|
j g}W n: tk
r } z | j jd j| g }W Y d d } ~ X nX |s| j jd n| j jd | |S ) NZifconfigsunosaixz -azhp-uxnetstatz%s -inr rL namer rc freebsdr zinet6? (.+?)\sc S s g | ]}|j jd d qS )%r )rU rB )r ipr" r" r# r s z%Agent.get_all_ips..c S s g | ]}|j d qS )zaddr:)rU )r xr" r" r# r s r z %s addr showc S s g | ]}|qS r" r" )r r r" r" r# r s c S s g | ] }|r|qS r" r" )r r r" r" r# r s c S s( g | ] }|j jd d jdd qS )r r r )rU rB )r r r" r" r# r s 1z::1z@Unable to retrieve IP address(es) locally, contacting aggregator)r z IP address lookup failure: {}z"Unable to determine IP address(es)zIP addresses: %s)r r )r r r r rB rv rX appendrefindallindexrk r r r r r r Z get_local_ipr r rW rl ) r ZipsZ
ifconfig_pathZ ifconfig_cmdr coder/ lr Z ip_addr_pathr er" r" r# r sV
zAgent.get_all_ipsc C sP t jj|si S y(t|j j jd}tdd |D S td i S d S )NrL c S s" g | ]}t ttj|jd qS )=)r mapr rU rB )r r r" r" r# r s z9Agent.get_old_style_config_properties..zError reading manifest file) r= r> r r@ rA rU rB r r )r manfileZmfr" r" r# get_old_style_config_properties s z%Agent.get_old_style_config_propertiesr+c C sz t ||}d}xFtdD ]:}y tj|tjtjB d}P W q tjd Y qX qW |rv| jj d| |j
d S |S )NTrN Fg ?z Could not acquire lock on %s) r@ rangefcntlflockZLOCK_EXZLOCK_NBr3 r rk r r )r fnamemodeZofilelockedir" r" r#
_open_file s
zAgent._open_filec
C s0 t | jr(| j| j}|s i S i }y\tj|}xL|D ]D\}}}tj|d}t|}||tj |j
g|d||j df < q6W W n | j j
d i }Y nX t|j }|jdd d i }x<|D ]4\}}}||kr||gg||< q|| j||g qW |jd |j tj|tj |j |S i S d S ) Nz%Y-%m-%d %H:%M:%Sz%s:%sz
%Y%m%d%H%Mz"Unable to parse custom metric filec S s | d S )Nr7 r" )vr" r" r# s z)Agent.get_metric_values..)r r )r report_filer csvreaderr strptimerC r3 mktime timetuplestrftimerk r r valuessortr seektruncater
r LOCK_UNr )r csvfileZ
unique_valuesZ
csv_readertextkeyr r9 Z
custom_valuesr" r" r# get_metric_values s6
.
zAgent.get_metric_valuesc C s t | jr| j| j}|s i S tj|}ytdd |D }W n$ tk
rb | jjd i }Y nX |j d |j
t j |t j
|j |S i S d S )Nc S s g | ]}|d |d fqS )r rM r" )r rowr" r" r# r & s z0Agent.get_registered_metrics..z)Error reading custom metric register filer )r
register_filer r r r r rk r r r r
r r r )r r Z csvreadermetricsr" r" r# get_registered_metrics s
z Agent.get_registered_metricsc C sJ g }x@t | jd j D ]*\}}d|j|jf }||kr|j| qW |S )N schedulesz%s.%s)r r r plugin_textkeyresource_textkeyr )r Zexisting_tkeyssr_idscheduletkeyr" r" r# get_existing_metrics7 s zAgent.get_existing_metricsc C s |dkr|j drdS dS )Nzcom.pnp-hcl.dominostatszMem.PID.TF)rX )r r' r( r" r" r#
ignore_metric? s
zAgent.ignore_metricc C s( ddg}ddddg}ddddg}| j }| jjd i }i }g }| jg} |jd
d r`|jd
d pbd }
|
rx| j|
jd | j} |jd
d
r|jd
d
pd } | rt | } g }
xr| D ]j}t
|sqt |
| krP | jjd| x>t j
|D ]0}t |
| krP tt||r|
jt|| qW qW x|
D ]}t|}t j|t jsV| jjd| q&t|d}y0| jjd| tj|j }|j x2|D ]*}|t|j krt jd|| qqW |jdg }x|D ]}x8|D ]0}|t|j krt jd| t | qܐqW | j |d |d r*qyJyt |d }W n4 t k
rp t j!|d d}t"j#|j$ }Y nX W n2 t k
r | jjd|d |d wY nX |d |f}d|d |d f }||kr@||kr|| j%dg j| nJ|jdd }|d kr|d }|d |d |d ||jdd |gd||< n|j%|g j| qW |jdg }x |D ]} x8|D ]0}|t| j krxt jd | t | qxqxW yJyt | d }W n4 t k
r t j!| d d}t"j#|j$ }Y nX W n2 t k
r( | jjd | d | d wlY nX |d | d || d | d d } d | kr`| d | d < d | krv| d | d < |j| qlW t j&| W n t k
r |j'rt||j(}| jjd!| |j)d" | jj|j | jjt*j+ | jjd# |j t j&| w&Y nX q&W |||fS )$Nr' Zplugin_category_namer r unitr9 descriptionactionz Processing incoming import filesr Zmetric_incoming_directoryr Zmax_incoming_files_overridez
Looking in %sz&Can not delete %s so will not process.zr+z
Processing %sz1Can not process file %s! Missing required key: %sr$ z0Can not process metric! Missing required key: %sz%Y-%m-%d %H:%M:%Sz,Could not process timestamp %s for metric %sz%s.%s first_valueslabel)r' Z plugin_namer( r2 r. r1 incidentsz2Can not process incident! Missing required key: %sz.Could not process timestamp %s for incident %s)r' r( r9 r/ r0 Z match_keymetadatazError processing %s:r z
Deleting file),r, rk r custom_import_dirr r extendrB MAX_IMPORT_FILESrD r r r= r r r r r accessW_OKr r@ jsonloadsrA r r keysr r r- r r r calendarZtimegmr
setdefaultr closedr
r rn ro ) r r Z req_top_keysZreq_metric_keysZreq_incident_keysZexisting_metricsZ new_metricsZ
new_valuescustom_incidentsZ import_dirsZadditional_dirsZ max_filesZ max_overridefiles directoryr1 full_pathr jZreqr$ mZunix_timestampr9 Z new_valuer+ r2 r3 Zincidentobjr" r" r# process_importsE s
zAgent.process_importsc C s dt i}tjj| jr| j| j}|s,|S | j| j}|jd |j t j
|t j |j ytj
| j W n Y nX |S | jrt }|r||d< |S d S )NZfqdnr server_name)r r= r> r update_config_filer r r r r
r r r r is_fortisase_installr )r r r Z
propertiesrH r" r" r# get_update_config s(
zAgent.get_update_configc C s || _ || _|| _|| _|| _|| _|| _tj | _ d| _
t j dkpPt j
dk| _|
| _t jj| | j| _t| jd| j | _t jj| | j| _t| jd| j | _x*tjD ] }d|krt jj| jd| _P qW t jj| | j| _t| jd| j | _t jj|
| j| _t jj| jd| _t jj| jd | _ t jj| d
| j | _ t jj| | j}t jj|d | _ t jj| | jd | _ d
tj j! krt jj|d| _"t jj|d| _#n^dtj j! krt jj| jd| _"t jj| jd| _#n(t jj| | jd| _"t jj| | jd| _#d| _$d| _%d| _&d| _'d| _(d| _)d | _*d| _+d| _,d | _-yt.| js\t/dt jj.| js|t/dj0| jt1j2 }|j3| j |j4dr|d | _-tj d/kr|j5dd r|j6dd j! d k| _%|j5dd r|j6dd | _&|j5d d r|j6d d | _'|j5d d!r*|j6d d!| _(dtj kr|j5d d"rZ|j6d d"j! d k| _)|j5d d#ry|j7d d#| _+W n t8k
r t9j:d$ Y nX |j5d d%r|j6d d%| _*|j5d d&rd'|j6d d&j! krd| _,|j6d d(}|st/d)W nL t/k
rJ } z.t9j;d*| tj kr`d-t_ d| _?| j@ t9jA| jBjC| _DytE|j6d d.| _FW n t/k
r || _FY nX d | _GtH | _Id S )0Ni r z%s.dbz%s.logz--power-statuszpower_status.logz %s_agent.cfgcountermeasuresZincomingz%s-agent-manifestz agent.pidz
update-configr registerZreportr TFZ
demserviceZ
updateservicez /tmp/com.fortinet.fortimonitor zNo bin directoryzNo config file {}r linuxZdemZenabledr Z server_portr zupdateservice.portZipc_path auto_updateinterpreter_update_periodz r r db_filer r r argvr r r !countermeasures_custom_plugin_dirr5 r rj rI r rv r# r r has_demdem_portupdate_service_portipcPathrP rR rQ rJ r r r rW r r rA r r r Zgetintr& r r r stderrrI unamer set_up_logging getLogger __class__r rk rC r4 r r r )r rx r r rw r rS r r4 Zbase_config_dirZbase_custom_plugin_dirZ
base_data_dirZ base_log_dirrZ ZargumentZdata_dirr r r r" r" r# __init__ s
zAgent.__init__c C s | j d r| jjd dS tj }|j| jrd}|jdsV|jd d}| jjd |jdrx0|j dD ]"\}}|d krd
}|j
d|| qlW |j d d}| jjd |rt | jd }|j
| |j d| j d< dS )
z
Update agent configs to use "[agent]" instead of "[AgentConfig]" as
the main heading and "aggregator_url" instead of "agg_url" (in order to
match the option in the manifest file).
config_migratedz Config is in the correct formatNFr Tz Added [agent] section to configZ AgentConfigr r^ zMCopied deprecated [AgentConfig] section to [agent] and removed it from configr )r rk r r r rA r r r r r Zremove_sectionr@ rI r )r r Zconfig_has_changedr r r r" r" r# r s0
zAgent.migrate_configc C s | j d S )N)ry )r r" r" r# __del__ s z
Agent.__del__c C s t j }tjj| js(tjdj| j yt| j d}W n> t
k
rv t d| j t t
j f t d t j }Y n X |j t jj| j dd dd}|jt jd |j| |jt j | j }ytt |d
j }W n tt | j}Y nX |j| d S )
Nz mkdir -p {}az Cannot open log file %s: "%s"zLogging to stderr instead i r7 )ZmaxBytesZ backupCountzA%(process)d) %(asctime)s - %(name)s - %(levelname)s - %(message)sr i i P ) r re r= r> r r r rW r@ r IOErrorr r rn ro Z
StreamHandlerr ZhandlersZRotatingFileHandlerZ setFormatterZ FormatterZ
addHandlersetLevelZNOTSETopen_dbgetattrupperDEFAULT_LOG_LEVEL)r Z root_loggerr handlerr r r" r" r# rd s2
zAgent.set_up_loggingc C s | j r(|jdddd |jddddd |jd
dd dd |jd dd
dd |jddddd |jdddd |jddddd |jddddd |jddddd |jdddd d |jd ddd d |jd ddd!d |jd"ddd#d |jd$d%ddd& |j \}}||fS )'zJ
Return the options and arguments parsed from the parser.
z --server-keyr Zstore)destr0 z--rebuild-metadata
store_truerebuild_metadataF)r0 rs defaultz--statusr\ z--statsstatsz --from-cron from_cronz --aggregatorr )r0 rs z --installr )r0 rv rs z --uninstallr~ z--remove-instancer z--customer-keyNr] )rv r0 rs z --unpauseunpausez--list-containerslist_containersz --rebuild-container-metadatarebuild_container_metadataz--power-statussystem_power_status)rs r0 rv )r Z
add_option
parse_args)r r r r r" r" r# r} sN zAgent.parse_argumentsc ` sJ t j }d }tj }|j j yt|jdd}W n d}Y nX jr|g kry|jdd}W n d }Y nX y|jddp j _ W n d _ Y nX d j
| j f }n d j
f }t j |d} j
|\}}|jrLyR jjd j|jtj tj tj j j| jd
} d |ji}
| jd |
W n Y nX td
j j |ds fdd _ jj d t jd j d} j! _" jr j"} j# jjd |j$rt%| jt& j'd j(} t)j$ || d | |j*rt)j*| d | d | d |j+rFtj j j| jd
} j+| |j, t j sX|j-rL|jrh|j _ |j.prd }
dt j/j0 kr4 j1d f j2d f j(df j3df j4dfg}x4|D ],\}}tj5dj| |rtj6|| qW xL j7 j8gD ]<}t9|d }W d Q R X tj:j;|s jj d j| qW j- j j||
d S d d d dd!d"d#g}d}x"|D ]}t<||d rhd$}P qhW |sd% j= j| j f }t>| jj| d S |j?rt>d& d | d'< | j@ d S |jAr~d(| ks| d( i kr
t>d) d S | d( }t>d* t>d+ xV|jB D ]J\}}|jd,d-}|jd.d-}|jd/d-} t>d0|||d d1 | f q,W d S |jCrd$| d#< t>d2 jjd3 d S d} y2d} |jDrd$} |jD} t>d4| |jEdd| |jr
d$} |j} t>d5| |jEdd| | r*|jFt9 jd6 td
jGrT|jH rT jjId7 t>d7 d S |jdd}tj j j| jd
} |st>d8 td jJryTd}!tK jL jM}"|"jNd9}#|#d ksd:|#krd$}!|!sވ jO| r jP| W n Y nX t%| jt& j'd j(} tK jL}"|"jQ }$|$r4| jR|$ d;|jSdkr8|jdd;j0 d|jSdkr8t|jdd>d? }%d@| kstTjT | d@ |%kr
xL|jdd=jUdAD ]6}& jjdB|& dCt jV jW|&jX f }'tj5|' qW tTjT | d@< n.d@| kr8 jjdD| d@ |% tTjT dE t j }(g }) jY }* jZ|\}+},}-dF| kst| dF d kr|i | dF< x6t[| d jB D ] \}.}/dG|/j\|/j]f }0dH}1|/j\ j^kr|/j]|*kr|0|,kr|/j_|(t`|1dI kr jjdJ|/ qt`|/jadI}2t` jbdI}3|(|2 |3 |/__|0|,kr| jcj|0i jdKdL}4xJ|,|0 D ]>\}5}6|5d k rd|5|49 }5|5d krrqJ|)jd|.|6|5f i }7qJW q|/j\ j^k r|/j]|*krq| jcj|/j\i jdKdL}4x|*|/j] D ]>\}5}6|5d k r|5|49 }5|5d krq|)jd|.|6|5f i }7qW n|/j\| jek r8 jjdM|0 qnxt j }8tTjT }9|/jf| | dF j|/jgi \}5}7tTjT }: jjhdN|/|5|:|9 f |5d k rq|)jd|.tTji|8jj |5f qW jjdOt j |( | dP jk|) | d'
rFtTjT | d' k
r&| j@ | d' tTjT dQ }; jjdR|; d S d | d'< | j@ jjdS d S tTjT }d }?tljmd
dTd
k}@d}AdU| k
rd
| dU< tTjT | dU jnk
rd$}A|jH
rd$}AdV| k
rtTjT | dV< tj:jo j}B|B| dV k
rd$}A|B| dV< |Arv jjdW tTjT | dU< dX|jSdk r*| jp|jddX | jq }C|C sR|jH sR|@ sR| dY r| jr}|C rl jjdZ n@|jH r jjd[ n*|@ r jjd\ n| dY s jjd] ts jt|$}? ju }=g }>d;|jSdkr|jdd;j0 djd|Jj|Jj|Jj|G|Jjdf W n Y nX
q W |Ejxdg r:yt9tj:j&|D|E}KW n: jjIdhtj:j&|D|E jjItj w:Y nX |Kj }Lt}rt}|Ljdbj }Gndc}G|Kj ytj|L}MW n: tk
rb jjIdi|E jjItj w:Y nX djdkdldmg}N|Mj }Od$}Px@|ND ]8} | |Oks|Mj| r jjIdn| |Ef d}PP qW |PsȐ q:|Mjdk}Q|>jd|Q|Mjdj|Mjdm|G|Mjdodf q:W qW dp| ks | dp rZtj }R|RdqkrDd$| dp< jjdr n|RdskrZ jjdt dp| krv| dp rvd$| d#< i }Si }Tdu| kr| du rt| du |Tdu< dv| kr| dv rt| dv |Tdv< dw| kr| dw rt| dw |Tdw< dx| kr| dx rt| dx |Tdx< g }Udy| kr$| dy }Uyg }V jjdzt|)t|V |rrtd{d| t[|jB D }W jjhd}|W d}X| d d
ks| d i krd$}X|As| d~ rd$}Xtljmd jpd}YtTj|Y | d rtTjT | d k r| dP jt| d }Znd | d< | dP j }Zn | dP j }Zg }[g }\d1}]d| krj| d }^x,ttt|^|]D ]}_|[jd|^jd
qPW d| kr| d }`x&tt|`D ]}_|\jd|`jd
qW j| }ayd
t _t[|+j }+|rn| j|Z|V||>|?|[|\ j |+|- j j |U|X|T jJ|a|=d}Sd | du< d | dv< d | dw< d | dx< g | dy< d | d~< |Sjdi |Sjdi |Sjdg |Sjdi d}b j|b n jjd W n: tjk
r }c zh jj d|c ju }d|dr|dd }e|dd }ft|e|f}
j- j j||
d$d ntj d|d d S d }c~cX n tjk
rV }c z2 jj d|c d tTjT tt|c j"d'< d S d }c~cX nd | dP jk|Z x(|aj D ] }g| |g }h|hjk|a|g qtW jj|d jjhd|Z | j@ d S |Sjddrd$| dY< | d d7 < t j jd| d< W n jj|d Y n.X |Ar | j | d< jjdtTjT |< |Y d;|jSdkr|jdd;j0 dd|G }mtj:j& j|m}lt9|ld}n|njFtj|k |nj W n: tk
r jjId|G|jf jjItj Y nX jjd|G|jf |jrpt jVtj:j& jWddd|G gdd |jD }|lrp|d|l g7 }tj|dd qpW j|Sjdg |Sjdg rΈ jjdtt[|Sd j d'|Sd kr|Sd d' }otTjT |o | d'< d|Sd kr|Sd d }otTjT |o | d< du|Sd krX|Sd du }ptjddtt|p jgdd}q|q| du< d|Sd kr||Sd d }r|r| dP _d|Sd kr|Sd d }s|s| dP _dw|Sd kr*yb|Sd jdw}|jd}t|td krd}tt|t}td}utdrd|t|uf }utj|ud$d}v|v| dw< W n tj | dw< Y nX dx|Sd kry|Sd jdx}|jd}w|jd}t|td krjd}tt|t}t|wd krtj j }x|xjd krtjd j }x|xj}wdxddddt|wg}ytj|ydtj|td}z|z| dx< W n tj | dx< Y nX |Sd jd}{|{d k rv|{j }{y,t|jSdkrfxL|jdd=jUdAD ]6}& jjdB|& dCt jV jW|&jX f }'tj5|' q W tTjT | d@< d#|Sd kr|d$| d#< d|Sd krd$} d~|Sd krd$| d~< d|Sd kry j| W n Y nX jGr jjd t>d ndp| kr| dp rd(| kri | d(< d}d#| kr0| d# r0d$}d| d#< | d( }t[|j }ytj|| ||d}W nF tk
r t j d dd \}} jjI| jjId d }Y nX |rdd |D }g }xd|D ]\}|d d d
}|||< |s||kr|jd| d|kr|d r|d= |jd| qW g }\x*|jB D ] \}}||kr6|\jd| q6W x|\D ] }||= q^W d| krg | d< d| krg | d< | d j| | d j|\ jjdt| jjdt|\ j| W n jj|dƃ Y nX j| || | dǍ}| s j| || dȍ | j@ jjdjt j | jŃ d S )Nr safe_counterrc r r^ z]%%prog [options]
%s, server key: %s, aggregator endpoint: %s
zRsudo python %%prog --install [--customer-key=YOUR_CUSTOMER_KEY]
%s)usagez!Power status -> {} UID {} EUID {})r reasonZagent_power_changer )ri c s j jdS )NzPreventing pid file removal)rk r r" )r r" r# r _ s z Agent.main..z=Exiting without running - other agent process already runningrM FzActivity startedpluginsr& num_syncs last_syncr i z mkdir -p {}za+zInstaller did not create {}rx r ru ry rz r{ Tz5%s Agent v%s, server key: %s, aggregator endpoint: %sz.Unpausing agent, will run as usual on next runpauseZdocker_containerszNo monitored containerszMonitored Containers:
z$CONTAINER ID IMAGE COMMAND STATUSZImage?ZCommandZStatusz
%s %s "%s" %srb zMetadata queued for rebuildz!Container metadata rebuild queuedzSetting server key to %sz!Setting aggregator endpoint to %swbz.Linux agent should not run if executed as rootz1No server key found, please re-install the agent.zschedules-initnor r r Z countermeasures_refresh_pluginsi Z countermeasures_last_refreshr z*Refreshing CounterMeasures plugins from %sz2%s %s/countermeasure.py install_plugins --url %s &z+Waiting to refresh CM plugins in %d minutes< anomaliesz%s.%srk )rE z%r too early to checkscaleg ?z No custom value or plugin for %sz %r returned %s in %.2f secondszRunning all plugins took %s result_queueg N@zPPause command received. Processing stopped. Process will resume in %.2f minutes.z=Pause duration exceeded, unpausing the agent for the next runi Zlast_metadata_timelast_config_file_timezRebuilding plugin metadataZcustom_plugin_url has_connected_with_aggregatorzmetadata changedzrebuilding metadataz!randomly forcing metadata rebuildz%we've never pushed up metadata beforerL z.py__zUnable to import module %szutf-8r r7 ZCountermeasure)r r authorhashr/ z.jsonzUnable to open %sz+%s file is not a valid json file to be readr r Zcommandr z7%s is missing from the countermeasure declaration in %sr/ Zdocker_supportedr zDocker supportedz
no-permissionz*Missing permission to access Docker socketZ log_request diagnostics socket_statsZmtrauto_topo_scansz1Syncing with aggregator: %d results, %d anomaliesc s s* | ]"\}\}}|t t|j fV qd S )N)r r r< )r Z
plugin_key_Zplugin_metadatar" r" r# r s z Agent.main..zMetadata summary: %rsync_schedules
single_resultdiscovered_containersdeleted_containers)Z dem_enabledZdem_service_resultsfortisase_attributesicmp_server_resourcesmonitor_schedules traceroutestraceroute_checks)r r r r z"No server_key found, skipping synczFReceived a request tor reinstall the agent due to a existing conflict r r )r zKReinstall request received, forticlient data not available. Please verify. zNReceived an unauthorized response from the agg. Pausing execution of agent by z secondsz Could not sync with aggregatorzSaving results locally: %rr z%m/%d/%Y %H:%Mz Error syncing with aggregator
last_metadatazsyncing took %.2f secondsr textkeysr4 z countermeasure-metadata-%s.jsonr z1Failed parsing countermeasure metadata for %s: %sz#Queueing countermeasures for %s: %szcountermeasure.pyZexecutez --hash=%sc S s g | ] }d | qS )z
--textkeys=%sr" )r Ztkr" r" r# r @ s z Agent.main..z--metadata-file=%s)r Zcommandszgot %d agent commandstailz-nqueue_batch_sizequeue_max_resultsr4 rN zss -t -u -r 2>&1z
timeout %d %srO zhttp://z--csvz-cr z--)r rb r4 r zSet log level to "%s"z Invalid log level command: "%s"Zmetadata_resyncZrefresh_countermeasuresZ update_agentZget_logsz9Linux agent running as root, skipping container discovery)ZrebuildzDocker has been enabled but the fm-agent user needs to be added to the docker group.
You can do so with `sudo usermod -a -G docker fm-agent`c S s g | ]}|d dd qS )IdN r" )r cr" r" r# r s r r updatedz$Discovered %d new/updated containersz!Found %d newly deleted containerszError in main loop)r r
agg_clientr )r r r zActivity finished in {}sr )r r r ZRawConfigParserrA r rD r r r r r{ r| r} r| rk r rW r= rW rX r r r r callr r r4 ri r r r rn r r r\ r r rS r displayrw r~ r r r] r rv r r r] r5 r chmodr# r r@ r> r ro rx r ry saverz r r{ r r rI rY ru r r^ r r_ ra send_receive_agent_version_updated_init_dem_schedulesZget_dem_wifi_infoZadd_dem_wifi_resultsr r3 rB r r rU r! rG r r' r( CUSTOMZnext_check_timer frequencyr r r r checkidrl r r updaterandomZrandintrV getmtimeZinstall_remote_pluginsZis_metadata_staler4 r Z
get_all_factsr r r endswithrX p_importlibZ
import_moduler sha_funcsixr! encodeZ hexdigest__dict__r typetypesZ ClassTyper r r r/ rn ro r r: r; r r< container_discoveryZ check_accessr r r rZ r pop_resultsr r8 pop_getDemResultstracebacklimitr syncr% rK r _updateDEMServiceSchedulesZReinstallResponser r ZUnauthorizedResponser Zhashed_metadatarU dumpsr' r( update_schedulesr$ r r r r r r STDOUTrp rm ra AttributeErrorZWARNINGbuild_diagnostics upload_logsZdiscover_docker_containersr r6 run_auto_topo_scanscheckForUpdatecheckForInterpreterUpdate
total_seconds)r Z
activityStartr r r~ r r r r r rG r r r] Zdirs_to_createdirZpermsZrfileZrfZ
valid_optionsZ option_givenZ valid_optionmsgZ
containersZshort_idr4 Z
cont_imageZ cont_commandZ cont_statusZrequested_auto_updateZjust_set_option_and_quitr ZaggZneeds_schedules
dem_clientZschedules_receivedZ wifi_infoZ
refresh_cycler cmdZall_plugins_start_timeZresults_to_sendZcustom_metricsZnew_import_metricsZnew_import_valuesr@ r) r* Z
schedule_tkeyZ leeway_timer r r r r9 r Zplugin_start_timeZt0Zt1Z time_leftZ
start_timer Zcountermeasures_metadataZfactsZ lucky_dayru r ZstalerB Zmod_namemodr r rF ZpluginZ json_counterZ file_contentZ counter_dataZrequired_fieldsZ
existing_keysr r Zcan_access_dockerresponseZcommand_resultsr Zanomalies_to_reportZmetadata_summaryZforce_send_schedulesdelayZ result_datar r ZMAX_CONTAINERS_SYNCZcontainer_queuer Zdeleted_container_queueZ dem_resultsZ dem_updatesr r r r ZdemKeyqZcountermeasurer Z cm_metadataZ
metadata_filer r1 rE linesZ
log_outputr r r4 ss_cmdr rO Z
parsed_urlZmtr_cmdZ
mtr_outputZ
log_level_keyr levelmessager{ Zexisting_containersZexisting_container_idsZfound_containerstr Zfound_container_idsZnew_containersZ containerZ container_idupdate_startedr" )r r# main$ s
z
Agent.mainc C s> yt }|j S tk
r8 } ztj| i S d }~X nX d S )N)r
Zget_handshake_datar r r )r Zhelperr r" r" r# r 8 s
z Agent.get_fortisase_attributesc C s
dd l }dd l}|j }|j| j|dd tj }dj|jd}t j
j |d}t j | |j
t j
j d|d|}zny:dj| j} d j||| }
t j|
| jjd
j| W n. tk
r } z| jj| W Y d d } ~ X nX W d t j
j|rt j| X W d Q R X d S ) Nr T)Z
dirs_exist_okz
agent-logs-{}z %Y%m%d%H%M%Szipz/tmpz{}/v2/agent_logszHcurl -F file=@{} -H "Accept: application/json" -H "Authorization: {}" {}zUploaded log file {})shutilrT ZTemporaryDirectoryZcopytreer r r rW r r= r> r mkdirZ make_archiver r rk r r r r r ) r r r rT Z
tmpdirnamer Zzip_file_prefixZ
zip_outputZzip_nameendpointZccr r" r" r# r @ s(
" zAgent.upload_logsNc C s |r | j jd | j|ddS d}| js>||kr:|j| d S d }|sV| j jd d S |srtj| j| j || j
d}d}yht dd}||krz| j d krd d
l
m} |t|j } tj t | d ||< nyV| j jd \}
} tj } t| j| j| jt|
t| d
}
|
| k r|
| }
|
||< W n< tk
r^ } z | j jdj| j t| d S d }~X nX | j jdj|| d S || }| stj |kr| j|dd}|d krtj }|| ||< | j jdj|| |S W n6 tk
r } z| j jdj| W Y d d }~X nX d S )NzAdmin update request interpreter)r exclude_componentsnext_update_checkz checkForUpdate: no server key)r rM )Zdaysr ) randrange)rE rd )yearmonthdayZhourZminutez%Could not calculate next check {}: {}zNext update check at {})r zcheckForUpdates problem: {})r )r )rk r _onCheckUpdatesrP r r r r r r r r rR r r rD r r r rB r r r r r rW r )r r r r r db_keyr
update_periodr Z randomSechrE ZrnZctr r r" r" r# r Z sl
zAgent.checkForUpdatec C s dt jks| jdkrd S |s,| jjd d S |sHtj| j| j|| j d}d}yzt
| jd}||krj|| nd }| st j |kr| jj
d | j|d d }t j | ||< | jj
d
j|| |S W n6 tk
r } z| jjd j| W Y d d }~X nX d S )
Nr r z(checkForInterpreterUpdate: no server key)r Z next_interpreter_update_check)Zhoursz Checking for interpreter updatesr )include_componentsz#Next interpreter update check at {}z%checkForInterpreterUpdate problem: {})r )r r rQ rk r r r r r r r r r r r rW r r ) r r r r r r r r r r" r" r# r s,
z Agent.checkForInterpreterUpdatec s | j jd ydj| j}|j|dd}r>fdd|D } rT fdd|D }t|dkrt| j| j}|j d t
j |d
}|d kS W n4 t k
r } z| j j
d j| W Y d d }~X nX d
S )NzPerforming updates check...zagent_update_info/darwin/{}rQ )methodc s g | ]}|j d kr|qS )r )r )r r )r r" r# r s z)Agent._onCheckUpdates..c s g | ]}|j d kr|qS )r )r )r r )r r" r# r s r updates)payloadZackzUpdate check failure: {}F)rk r rW r r r r
r` ra r r: r r r ) r r r r r r clientr r r" )r r r# r s$
$zAgent._onCheckUpdatesc C sX | j jd g }g }xt| jd j D ]\}}| jd j|}|sR| jd |= q(xt|j D ]\}}| j jd| |j r|j|j r|j
||t j |j
j df d|_| j jd| |j o|j r`|j
||t j |j
j df d|_| j jd| q`W q(W | j jd t| | j jd
| | j jd t| | j jd | | jj || S )
Nz Gathering reportable anomaliesr r& z Threshold %sFTzCleared anomaly: %szLengthy anomaly: %sz$Found %d anomalies that have clearedzCleared anomalies: %rz5Found %d anomalies that exceed the threshold durationzLengthy anomalies: %r)rk r r r r r rl reported_as_clearedZ has_clearedZnumber_of_checksr r3 r Ztime_last_detectedr Z reported_as_exceeded_durationZexceeds_durationr r )r Zcleared_anomaliesZlengthy_anomalies schedule_idr r* threshold_idanomalyr" r" r# get_reportable_anomalies sH
z Agent.get_reportable_anomaliesc C s | j jd xvt| jd j D ]`\}}xBt|j D ]2\}}|jr6|j|}| j jd | j jd| q6W |s | jd j| q W | j jd| jd | jj d S )Nz'Checking for reported cleared anomaliesr z Removed reported cleared anomalyz Anomaly: %szRemaining anomalies: %s) rk r r r r r r rl r )r r r r r r" r" r# !remove_reported_cleared_anomalies
s
z'Agent.remove_reported_cleared_anomaliesc C s4 |g ks|d kr | j jd d S | jd }i | jd< x|D ]}|d }| j jd| |j|d }y`|r~|j| ||j= d}n|st|}d}|| jd |j< | j jd||j | j jd| W q: tk
r t j
d }t |}| j j d
j
|| Y q:X q:W | jj | j jd t| | j jd t| d S )
Nz,No schedule changes received from aggregatorr& r z$Received schedule %s from aggregatorZEditedZCreatedz%s schedule %s locallyzSchedule data: %rrM z Invalid schedule {} data: {}z Created/updated %d scheduleszDeleted %d schedules)rk r r r r r r rl r r r r r rW r r ) r Z
new_schedulesZexisting_schedulesZnew_schedule_dataZnew_schedule_idr* r0 r r r" r" r# r
s8
zAgent.update_schedulesc C s d}|d| j 7 }|dtjddd 7 }dtjkrJ|dtjd dd 7 }n|dtjd
dd 7 }|d tjd dd 7 }dtjkr|d
tjd| j dd 7 }|dtjddd 7 }|dtj|jd| j d 7 }|S )zVFunction to build a string of diagnostics data to send
back to the aggregator.zAGENT DIAGNOSTICS
zAgent version: %s
zAgent server hostname: %sr T)r r z Agent OS: %sz sw_vers | grep ProductVersionz%cat /etc/*-release | grep PRETTY_NAMEzuname output: %szuname -azPackage information: %s
z apt-cache show %s-agent || truez
ip output:
%sz ip addr showz!Local agent pickle file data:
%s
r7 )r rv )
r r' r$ r r rx r: r rG defaultprint)r r r rx stringr" r" r# r C
s"
zAgent.build_diagnosticsc C s t |tr|j S d S d S )N)
isinstancer __repr__)r rF r" r" r# r a
s
zAgent.defaultprintc C s t jj| js t jdj| j yt| j}W n
d S i dd dd d | jdd t i d d t dddt dddt dddt dddd }x(t
|j D ]\}}||kr|||< qW |S )
Nz mkdir -p {}Fr i 2 )r r d rk )r rh r r r r r r r r r& r r Z
check_resultsZserver_resource_levelsr r ) r= r> r r r rW r r[ rq r r r )r r Zdefaultsr rv r" r" r# rn g
s8
z
Agent.open_dbc C s y|j dddkS dS d S )NtopoZ auto_scanr F)r )r r r" r" r# should_run_auto_topo_scans
s z Agent.should_run_auto_topo_scansc
C s yt |jddS dS d S )Nr Zscans_per_syncr )rD r )r r r" r" r# get_num_topo_scans
s zAgent.get_num_topo_scansc
C s yt |jddS dS d S )Nr
scan_sleeprM )rD r )r r r" r" r# get_topo_scan_sleep
s zAgent.get_topo_scan_sleepc C sh d}d}t j }| jjd yttj|dd}W n tj }Y nX t j | }| jjd| |S )Nzss -t -u -r 2>&1r zStarting topo scanT)r z.Topo scan complete. Elapsed time: %.2f seconds)r3 rk r r r' r$ rn ro )r r resultr elapsedr" r" r#
run_topo_scan
s zAgent.run_topo_scanc C sz | j |sd S | j|}| j|}d| jkr6g | jd< x>t|D ]2}tj }| j }| jd j||f tj| q@W d S )Nr ) r r r r r r3 r r r )r r nr r r scanr" r" r# r
s
zAgent.run_auto_topo_scansc C s i }| j s|S t| j| j}|jd}|d kr2|S tj|}x|j D ]x}y<|| }|j rj|| ||< n|j || |j
||< W qF t k
r } z| j j
dj| wFW Y d d }~X qFX qFW |S )NZcollectz_getDemResults: {})r^ r r_ ra r r: r; r< ZisEmptyr r r rk r rW ) r r Zrvr r Z
latestResultsr r r r" r" r# r
s&
zAgent._getDemResultsc C sD d}d|kr2|d r2|d | j kr@| j |d< d}n| j |d< d}|S )NFZlast_ran_versionT)r )r r Z
has_updater" r" r# r
s
z Agent._agent_version_updatedc C s yX|j ddd}|jdg |jdg |jdg d}t| j| j}|jdtj|d W n6 tk
r } zt j
d
j t | W Y d d }~X nX d S ) Nr& rQ )r r r r )r r r Z
initSchedules)r z/schedules error: {})
r r r r_ ra r r: r r r r rW r )r r r r& r ZaggExr" r" r# r
s
&zAgent._init_dem_schedulesc C s0 | j s
d S t| j| j}|jdtj|d}d S )Nzupdate-schedules)r )r^ r r_ ra r r: r )r Z newSchedulesr r r" r" r# r
s z Agent._updateDEMServiceSchedules)r7 rN rc )F)F)r )NNF)NN)NN)1r r r r rq r7 r r ry r~ r r r r r r r r! r% r, r- rG rK rg r ri rd r} r r r r r r r r r r r rn r r r r r r r r r r" r" r" r# r` sr
U
&U
DA
) ! $)7
@
!9% - r` )bZ
agent_utilr r r r Z inspectorr r r Z
ipc_clientr r
Zagent_exceptionsr r Zforticlient_helperr
r Zprocess_managerr Zos.pathr r r r r Zpickle_databaser Zplugin_managerr r Zprogress_printerr r r r* r r r r ior r= r r r r r
r r Zlogging.handlersr{ r= r r r' rT r3 rn r Z blacklisterr r r r r r: ImportErrorZ
simplejsonZhashlibZsha1r Zshanewr r1 r$ r Z urllib.parseparseZurllib.requestr[ r rZ rY Z http.clientr rV r? r r2 r5 r: rH rJ r_ objectr` r" r" r" r# s
'