File: //opt/alt/python37/lib/python3.7/site-packages/pyroute2/remote/__pycache__/shell.cpython-37.pyc
B
��f$ � @ sp d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
m Z e� e
�ZG dd� dee
�ZdS )� N)�RTNL_API)� MarshalRtnl)� RemoteSocket� Transportc sB e Zd Z� fdd�Zdd� Zdd� Zejfdd�Zd d
� Z � Z
S ) �ShellIPRc s� || _ d| }tj|�� dtjtjd�| _t| jj�}t| jj�}yt t
| �� ||� W n t k
rv | �
� � Y nX t�| j
� t� | _d S )Nz %s python -m pyroute2.remoter )�bufsize�stdin�stdout)�target�
subprocess�Popen�split�PIPE�shellr r r �superr �__init__� Exception�close�atexit�registerr �marshal)�selfr
�cmd�trnsp_in� trnsp_out)� __class__� �F/opt/alt/python37/lib/python3.7/site-packages/pyroute2/remote/shell.pyr s zShellIPR.__init__c C s t | �| j�S )N)�typer
)r r r r �clone# s zShellIPR.clonec C sJ t td�rt�| j� n.ytj�| jdi f� W n tk
rD Y nX d S )N�
unregisterr )�hasattrr r r Z
_exithandlers�remove�
ValueError)r r r r �_cleanup_atexit& s
zShellIPR._cleanup_atexitc C s� | � � yJ| j�ddi� |dkrPdt�ddddd|dd�d d�}| jj�|� W n tk
rf Y nX x8| jj | jj fD ]$}y
|� W qz tk
r� Y qzX qzW | j
� � | j
� � d S ) N�stage�shutdownr � broadcastZIHHQIQQ� � )r% �data�error)
r$ r �send�struct�packr Z brd_queue�putr r r �kill�wait)r �coder* r r r r r / s"
zShellIPR.closec C s d S )Nr )r r r r � post_initG s zShellIPR.post_init) �__name__�
__module__� __qualname__r r r$ �errno�
ECONNRESETr r3 �
__classcell__r r )r r r s
r )r r7 �loggingr- r Zpyroute2.iprouter Z pyroute2.netlink.rtnl.iprsocketr Zpyroute2.remote.transportr r � getLoggerr4 �logr r r r r �<module> s