File: //lib/python3/dist-packages/landscape/lib/__pycache__/sysstats.cpython-38.pyc
U
y)�]� � @ s� d dl m Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
G dd� de �Z G dd � d e
�Zd
d � Zdd
d�Zddd�ZG dd� de
�ZG dd� de
�ZG dd� de
�ZG dd� de
�ZdS )� )�datetimeN)�getProcessOutputAndValue)�
encode_values)� to_timestampc @ s e Zd ZdZdS )� CommandErrorz:Raised when an external command returns a non-zero status.N)�__name__�
__module__� __qualname__�__doc__� r r �8/usr/lib/python3/dist-packages/landscape/lib/sysstats.pyr
s r c @ s^ e Zd Zddd�Zedd� �Zedd� �Zedd � �Zed
d � �Zed d
� �Z edd� �Z
dS )� MemoryStats�
/proc/meminfoc C s� i }t |�D ]8}d|kr |�dd�\}}|dkr t|�� d �||< q |d d | _|d |d |d d | _|d
d | _|d d | _d S ) N�:� )�MemTotal�SwapFree� SwapTotal�MemFree�Buffers�Cachedr r i r r r r r )�open�split�int� total_memory� free_memory�
total_swap� free_swap)�self�filename�data�line�key�valuer r r �__init__ s ��zMemoryStats.__init__c C s | j | j S �N)r r �r r r r � used_memory" s zMemoryStats.used_memoryc C s | j | j S r% )r r r& r r r � used_swap& s zMemoryStats.used_swapc C s | j t| j� d S �N�d )r �floatr r& r r r �free_memory_percentage* s z"MemoryStats.free_memory_percentagec C s& | j dkrdS | jt| j � d S d S �Nr g r* )r r r+ r& r r r �free_swap_percentage. s
z MemoryStats.free_swap_percentagec C s
d| j S r) )r, r& r r r �used_memory_percentage5 s z"MemoryStats.used_memory_percentagec C s | j dkrdS d| j S d S r- )r r. r& r r r �used_swap_percentage9 s
z MemoryStats.used_swap_percentageN)r ) r r r r$ �propertyr' r( r, r. r/ r0 r r r r r
s
r
c C s, t tj�} tddg| d�}dd� }|�|�S )NZwhoz-q)�envc S sJ | \}}}|dkr t |�d���|�dd�d }|�d�}tt|�� ��S )Nr �ascii�
r )r �decoder �sorted�set)�argsZ stdout_dataZ stderr_data�status�
first_liner r r � parse_outputE s
z)get_logged_in_users.<locals>.parse_output)r �os�environr � addCallback)r= �resultr; r r r �get_logged_in_usersA s
r@ � /proc/uptimec C s2 t | d��}|�� }W 5 Q R X |�� \}}t|�S )z�
This parses a file in /proc/uptime format and returns a floating point
version of the first value (the actual uptime).
�r)r �readliner r+ )Z uptime_fileZufiler Zup�idler r r �
get_uptimeO s rE c c sN | d kr t j�d�rd} nd} t j�| �rJtt �| ��D ]}t| |�V q8d S )Nz/sys/class/thermalz/proc/acpi/thermal_zone)r< �path�isdirr6 �listdir� ThermalZone)Zthermal_zone_pathZ zone_namer r r �get_thermal_zonesZ s rJ c @ s e Zd ZdZdZdZdd� ZdS )rI Nc C s4 || _ tj�||�| _tj�| jd�}tj�|�r�zdt|��R}|�� }z.t|�� �d | _ d| _
d� | j | j
�| _ W n t
k
r� Y nX W 5 Q R X W n tk
r� Y nX n�tj�| jd�}tj�|��r0t|�D ]Z}|�d�r�|dd � �� | _ z"| j �� \}}t|�| _ || _
W q� t
k
�r, Y q�X q�d S )NZtempg @�@�Cz {:.1f} {}� temperaturez temperature:� )�namer< rF �join�isfiler rC r �strip�temperature_value�temperature_unit�formatrL �
ValueError�EnvironmentError�
startswithr )r � base_pathrN Ztemperature_path�fr! r# Zunitr r r r$ k s:
�
zThermalZone.__init__)r r r rL rR rS r$ r r r r rI e s rI c @ s$ e Zd ZdZdZdd� Zdd� ZdS )� LoginInfoz=Information about a login session gathered from wtmp or utmp.Zhi32s4s32s256shhiiiiiii20sc C s� t �| j|�}|d | _|d | _| �|d �| _| �|d �| _| �|d �| _| �|d �| _ |d | _
|d | _ |d | _ t
�|d
�| _|d | _d S ) Nr r � � � � � � � � � )�struct�unpack�
RAW_FORMATZ
login_type�pid�_strip_and_decode�
tty_device�id�username�hostnameZtermination_statusZ exit_statusZ
session_idr �utcfromtimestamp�
entry_timeZremote_ip_address)r �raw_data�infor r r r$ � s
zLoginInfo.__init__c C s |� d��d�S )z>Helper method to strip b" " and return a utf-8 decoded string.� zutf-8)rQ r5 )r Z
bytestringr r r rh � s zLoginInfo._strip_and_decodeN)r r r r
rf r$ rh r r r r rZ � s rZ c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �LoginInfoReaderzwReader parses C{/var/log/wtmp} and/or C{/var/run/utmp} files.
@file: Initialize the reader with an open file.
c C s || _ t�tj�| _d S r% )�_filerd �calcsizerZ rf �_struct_length)r �filer r r r$ � s zLoginInfoReader.__init__c c s | � � }|sq|V q dS )z2Returns a generator that yields LoginInfo objects.N)� read_next)r rp r r r �
login_info� s zLoginInfoReader.login_infoc C s, | j �| j�}|r(t|�| jkr(t|�S dS )z9Returns login data or None if no login data is available.N)rs �readru �lenrZ )r r r r r rw � s zLoginInfoReader.read_nextN)r r r r
r$ rx rw r r r r rr � s
rr c @ s. e Zd ZdZdZd
dd�Zdd� Zdd � ZdS ) � BootTimesN�
/var/log/wtmpr c C s || _ || _|| _d S r% )� _filename�_boots_newer_than�_shutdowns_newer_than)r r Zboots_newer_thanZshutdowns_newer_thanr r r r$ � s zBootTimes.__init__c C s� g }g }t | jd���}t|�}| j| _| j| _|�� D ]d}|j� d�r6t
|j �}|j dkrv|| jkrv|�
|� || _q6|j dkr6|| jkr6|�
|� || _q6W 5 Q R X ||fS )N�rb�~Zreboot�shutdown)r r} rr r~ �
_last_bootr �_last_shutdownrx ri rW r rn rk �append)r Z reboot_timesZshutdown_timesZlogin_info_file�readerrp � timestampr r r � get_times� s(
�
�
zBootTimes.get_timesc C s$ | j d kr tt�� t� �| _ | j S r% )r� r �timerE r& r r r �get_last_boot_time� s
z BootTimes.get_last_boot_time)r| r r )r r r r� r� r$ r� r� r r r r r{ � s �
r{ )rA )N)r r< Zos.pathrd r� Ztwisted.internet.utilsr �landscape.lib.encodingr Zlandscape.lib.timestampr � Exceptionr �objectr
r@ rE rJ rI rZ rr r{ r r r r �<module> s 0
%