File: //usr/lib/mysqlsh/plugins/debug/__pycache__/host_info.cpython-39.pyc
a
��kfh! � @ sP d dl mZmZmZ d dlZd dlZd dlZd dlZd dlm Z m
Z
d dl Z d dl Z d dl
Z
d dlZg d�Zg d�Zg d�Zee eee ee ee f d�dd �ZG d
d � d �Zd d
� Zd!eee ed�dd�Zejed�dd�Zed�dd�Zdd� Ze dk�rLe�dd ��(Z ee d d d id d ig� W d � n1 �sB0 Y dS )"� )�List�Optional�TupleN)�globals�Error) �date�uname -a�mount -v�df -hz iostat -Kz top -l4 -s1�ps aux� ulimit -a�dmesg�%egrep -i 'err|fault|mysql' /var/log/*z netstat -ln� sysctl -a)zdate /T�verZ
systeminfoz tasklist /V)!r r Z
getenforcezfree -mz swapon -szlsb_release -ar r
zcat /proc/cpuinfozcat /proc/meminfozcat /etc/fstabzmpstat -P ALL 1 4ziostat -m -x 1 4z
vmstat 1 4ztop -b -n 4 -d 1r r z�for PID in `pidof mysqld`;do echo "# numastat -p $PID";numastat -p $PID;echo "# /proc/$PID/limits";cat /proc/$PID/limits;echo;doner
r ZpvsZ pvdisplayZvgsZ vgdisplayZlvsZ lvdisplayznetstat -lnputznumactl --hardwarez numastat -mr z dmidecode -s system-product-namezlsblk -izsudo sosreport)�l�returnc C s� g }g }g }| D ]z}|� � �d�r8|�|�d�d � q|� � �d�r\|�|�d�d � q|� � �d�r�|�|�d�d � q|�|� q|||fS )Nzbefore:�:���zduring:zafter:)�lower�
startswith�append� partition)r �beforeZduringZafter�s� r �+/usr/lib/mysqlsh/plugins/debug/host_info.py� split_phasesV s r c @ sp e Zd Zg dfee ed�dd�Zejed�dd�Z ejed�dd �Z
ejee d
�d d �Z ejed�d
d�Z
dS )�
ShellExecutorT)� custom_shell� allow_phasesc C s. t |�| _|s*| jd s"| jd r*td��d S )N� � zHOption 'customShell' may not contain before:, during: or after: prefixes)r r r )�selfr r r r r �__init__g s
�zShellExecutor.__init__��zf�prefixc C s0 | j d }|r,td� t||� d�|dd� d S )Nr z Executing custom shell scriptszcustom_shell.txtF��
ignore_errors�r �print�run_shell_scripts�r# r& r' r r r r �executeo s
�zShellExecutor.executec C s0 | j d }|r,td� t||� d�|dd� d S )Nr z'Executing custom 'before' shell scriptszcustom_shell-before.txtFr( r* r- r r r �execute_beforev s
�z ShellExecutor.execute_before)r& r' � iterationc C s6 | j d }|r2td� t||� d|� d�|dd� d S )Nr! z1Executing custom 'during' iteration shell scriptszcustom_shell-iterationz.txtFr( r* )r# r& r' r0 r r r r �execute_during} s
�z ShellExecutor.execute_duringc C s0 | j d }|r,td� t||� d�|dd� d S )Nr" z&Executing custom 'after' shell scriptszcustom_shell-after.txtFr( r* r- r r r �
execute_after� s
�zShellExecutor.execute_afterN)�__name__�
__module__� __qualname__r �str�boolr$ �zipfile�ZipFiler. r/ �intr1 r2 r r r r r f s
r c C s� t j|dt jt jd�}| �d|� d��d�� | �dtj�� �� � d��d�� | �d|j � d��d�� | �|j
� | �d� |j S )NT)�shell�stdout�stderrz# �
�utf-8z
# exitcode = s
) �
subprocess�run�PIPE�STDOUT�write�encode�datetime�now� isoformat�
returncoder< )�f�cmd�rr r r �dump_shell_cmd� s �"
rM T)�fn�scriptsr) c C sr | � |d��R}|D ]<}td|� �� t||�}|dkr|std|� d|� ���qW d � n1 sd0 Y d S )N�wz -> Executing r zShell command "z" exited with code )�openr+ rM r )r& rN rO r) rJ rK �rcr r r r, � s
r, r% c C s� t j�t�� d�}dd|g}| �|� d��>}tdd�|�� t||� |�t|d�� � � W d � n1 sn0 Y t �
|� d S )Nzmysqlsh_msinfo32.txtZmsinfo32z/reportrP Z Executing� �rb) �os�path�join�tempfile�
gettempdirrQ r+ rM rD �read�remove)r& r' Z temp_path�argsrJ r r r �collect_msinfo32� s
2r] )r' c C sn g }t jdkrt}n(t jdv r.t}t| |� nt jdkr<t}tdt�� � dt j� d�� t | |� d�|� d S )N�darwin)�win32�cygwinZmsys�linuxz"Collecting system information for z (�)Z host_info)
�sys�platform�k_host_info_cmds_macos�k_host_info_cmds_win32r] �k_host_info_cmds_linuxr+ �socket� gethostnamer, )r& r' Zcmdlistr r r �collect_host_info� s
�rj c C s dd� }t j}g }g }tdt�� � d�� |D ]X}|d }|d } |�|�d }
td|
� d �� |�tj||
| |fd
�� |d � � q.|D ] } | �
� q�| � |� d �d
��\} |D ]F\} }
}
| � d| � d|
� d��
d�� | � d� | � |
� | � d� q�W d � n1 �s0 Y d S )Nc
S s~ z:t jdtjdkrdndd| gdd�}|�|| |jf� W n> tyx } z&|�|| t|��d�f� W Y d }~n
d }~0 0 d S ) N�pingr_ z/nz-c�5T)�capture_outputr? ) r@ rA rc rd r r< �FileNotFoundErrorr6 rE )�host� instance_id�timingsrL �er r r rk � s ��z collect_ping_stats.<locals>.pingzExecuting ping from z to other member hosts...�endpointrp ro z - Executing ping z
for 5s...)�targetr\ r zping.txtrP z # instance z - ping r> r? �
)r r; r+ rh ri � parse_urir � threading�Thread�startrW rQ rD rE )r& r' �
topology_datark r; �threadsrq �instancers rp ro ZthdrJ �outr r r �collect_ping_stats� s4 �
�
�
r~ �__main__ztest.ziprP �testrs � localhostzwww.oracle.com)T) �typingr r r r8 rh rw r@ �mysqlshr r rc rF rX rU re rf rg r6 r r rM r7 r, r9 r] rj r~ r3 r& r r r r �<module> s0
*'
&
�