Google
Edit File: _pluginrunner.cpython-39.pyc
a V��d � @ s| d dl Z d dlZd dlZd dlmZmZmZ d dlmZ d dl Z d dl Z d dl m Z d dlmZ dd� ZG dd � d e�ZdS ) � N)�LsmError�error� ErrorNumber)�cmd_line_wrapper)� SocketEOF)� TransPortc s$ � du r | S t � �fdd�| D ��S )z{ This method does not check whether lsm_obj contain requested property. The method caller should do the check. Nc 3 s | ]}t |� ��kr|V qd S )N)�getattr)�.0Zlsm_obj�� search_key� search_value� �7/usr/lib64/python3.9/site-packages/lsm/_pluginrunner.py� <genexpr> s �z"search_property.<locals>.<genexpr>)�list)Zlsm_objsr r r r r �search_property s r c @ s, e Zd ZdZedd� �Zdd� Zdd� ZdS ) � PluginRunnerz] Plug-in side common code which uses the passed in plugin to do meaningful work. c C s( zt | � W dS ty" Y dS 0 dS )z4 Returns True if val is an integer. TFN)�int� ValueError)�valr r r � _is_number$ s zPluginRunner._is_numberc C s� d| _ t|�dkr�t�|d �r�z�t|d �}tt�|tjtj ��| _ z |� | _ W nN t y� } z6t �� }| j �dddt|� � tj|� �W Y d }~n d }~0 0 W q� t y� tt�� � td� t �d� Y q�0 nd| _ t|� d S ) NF� � r i����z Error instantiating plug-in zPlug-in exiting.T)�cmdline�lenr r r r �socketZfromfdZAF_UNIXZ SOCK_STREAM�tp�plugin� Exception�sys�exc_info� send_error�str�sixZreraiser � traceback� format_exc�exitr )�selfr �args�fd�eZec_infor r r �__init__/ s* � �$ zPluginRunner.__init__c C s� | j r d S d}d}�z^�ztz�| j�� }|d }|d }|d }t| j|�r~|d u rbt| j|�� }q�t| j|�f i |d ��}n ttjd��| j� |� |dkr�d}|d kr�d}| j� � W �q�W q t �y } z,t t �� � | j�|d t|�� W Y d }~qd }~0 t�yJ } z,t t �� � | j�|d t|�� W Y d }~qd }~0 t�y� } z$| j�|| j| j| j� W Y d } ~ qd } ~ 0 0 qW n� t�y� |�r�t d � Y n� tj �y� } z4| jtjk�r�t d � nt d t �� � W Y d } ~ nbd } ~ 0 t�yT t d t �� � z | j�|tjdtt �� �� W n t�yN Y n0 Y n0 W |�r�| j�� t � d� n |�r�| j�� t � d� 0 d S )NFr �method�id�paramszUnsupported operationZplugin_registerT�plugin_unregisteriD���i����z!Client went away, exiting plug-inz Unhandled exception in plug-in! z Unhandled exception in plug-inr ) r r Zread_req�hasattrr r r r Z NO_SUPPORTZ send_resp�closer r r$ r% r! r" �AttributeError�code�msg�data� _SocketEOFr �errnoZEPIPEr Z PLUGIN_BUGr/ r r& ) r' Z need_shutdownZmsg_idr4 r, r. �result�veZaeZlsm_errZser r r �runK s| ��� ( (� � � � zPluginRunner.runN)�__name__� __module__� __qualname__�__doc__� staticmethodr r+ r: r r r r r s r )r r$ r Zlsmr r r Z lsm.lsmclir r# r7 Z lsm._commonr r6 Zlsm._transportr r �objectr r r r r �<module> s