← Back
Editing: _pluginrunner.cpython-312.pyc
� V��d � � � d dl Z d dlZd dlZd dlmZmZmZ d dlmZ d dl Z d dl Z d dl m Z d dlmZ d� Z G d� de� Zy) � N)�LsmError�error� ErrorNumber)�cmd_line_wrapper)� SocketEOF)� TransPortc �8 ��� ��| S t ��fd�| D � � S )z{ This method does not check whether lsm_obj contain requested property. The method caller should do the check. c 3 �@ �K � | ] }t |�� �k( r|�� � y �w)N)�getattr)�.0�lsm_obj� search_key� search_values ���8/usr/lib64/python3.12/site-packages/lsm/_pluginrunner.py� <genexpr>z"search_property.<locals>.<genexpr> s' �� �� � A�x�G��7�J�/�<�?� �x�s � )�list)�lsm_objsr r s ``r �search_propertyr s- �� � ���� � A�x� A� A� A� c �, � e Zd ZdZed� � Zd� Zd� Zy)� PluginRunnerz] Plug-in side common code which uses the passed in plugin to do meaningful work. c �: � t | � y# t $ r Y yw xY w)z4 Returns True if val is an integer. TF)�int� ValueError)�vals r � _is_numberzPluginRunner._is_number$ s# � � � ��H���� �� �s � � �c � � d| _ t |� dk( rvt j |d � r^ t |d � }t t j |t j t j � � | _ |� | _ y d| _ t/ |� y # t $ rT}t j � }| j j dddt! |� z � t# j$ |� �d }~ww xY w# t $ r@ t' t) j* � � t' d� t j, d� Y y w xY w) NF� � r i����z Error instantiating plug-in zPlug-in exiting.T)�cmdline�lenr r r r �socket�fromfd�AF_UNIX� SOCK_STREAM�tp�plugin� Exception�sys�exc_info� send_error�str�six�reraiser � traceback� format_exc�exitr )�selfr' �args�fd�e�ec_infos r �__init__zPluginRunner.__init__/ s � � �� � �t�9��>�l� 5� 5�d�1�g� >� ���a��\��#��M�M�"�f�n�n�f�6H�6H�I�K��� 0�"(�(�D�K� �D�L� �V� $�� !� 0� !�l�l�n�G��G�G�&�&�q�&�'E��A��'N�P� �+�+�w�/�/�� 0�� � ��i�*�*�,�-��(�)����� � �s2 �AC? �? B � C<�(AC7�7C<�<C? �?AE�Ec � � | j ry d}d} | j j � }|d }|d }|d }t | j |� r>|� t | j |� � }n: t | j |� di |d ��}nt t j d� �| j j |� |dk( rd}|d k( r d}| j j � n �� |r0| j j7 � t9 j: d� y y # t $ rM}t t j � � | j j |d t! |� � Y d }~��d }~wt" $ rM}t t j � � | j j |d t! |� � Y d }~��d }~wt $ rG} | j j || j$ | j& | j( � Y d } ~ ��(d } ~ ww xY w# t* $ r |r t d � Y ��Gt, j $ rT} | j. t. j0 k( r t d � n t d t j � z � Y d } ~ ���d } ~ wt2 $ r| t d t j � z � | j j |t j4 dt! t j � � � n# t2 $ r Y nw xY wY ��/w xY w# |r0| j j7 � t9 j: d� w w xY w)NFr T�method�id�paramszUnsupported operation�plugin_register�plugin_unregisteriD���i����z!Client went away, exiting plug-inz Unhandled exception in plug-in! z Unhandled exception in plug-inr � ) r r& �read_req�hasattrr' r r r � NO_SUPPORT� send_resp�closer r r/ r0 r+ r, �AttributeError�code�msg�data� _SocketEOFr" �errno�EPIPEr( � PLUGIN_BUGr= r) r1 ) r2 � need_shutdown�msg_idrF r9 r; �result�ve�ae�lsm_err�ses r �runzPluginRunner.runK s� � � �<�<� � � ���E ��(5� �'�'�*�*�,�C� ��]�F� ��Y�F� ��]�F� �t�{�{�F�3�!�>�%A�W�T�[�[�&�%A�%C�F�&5�W�T�[�[�-3�&5� &F�7:�8�}�&F�F� '�{�'=�'=�'>� @� @� �G�G�%�%�f�-� �!2�2�(,� � �!4�4�(-� � ��� � �� � 5�7 �> �D �� � �-�-�/����� � ��A "� @��)�.�.�0�1��G�G�&�&�v�v�s�2�w�?�?��%� @��)�.�.�0�1��G�G�&�&�v�v�s�2�w�?�?�� � 5��G�G�&�&�v�w�|�|�W�[�[�'.�|�|�5� 5��5�� � ;� ��9�:���|�|� .��x�x�5�;�;�&��9�:��9� �*�*�,�-� .���� � �5� �8L�8L�8N�N� O� ����"�"�6�;�+A�+A�#C�#&�y�';�';�'=�#>�@�� � �� �� �� �� � �-�-�/����� � �s� �H! �CD& �/H! �2L& �& H �/AE7�2H! �7 H �AG �H! � H �<H�H! �H � H! �!L#�7L& �:L#� A J�L& �,L#�AL�L#� L �L#�L � L#� L& �"L#�#L& �&4MN)�__name__� __module__� __qualname__�__doc__� staticmethodr r7 rS r> r r r r s& � �� �� ��%�8M r r )r" r/ r) �lsmr r r � lsm.lsmclir r- rI � lsm._commonr rH �lsm._transportr r �objectr r> r r �<module>r^ s9 �� � � � ,� ,� '� � � /� $�A�z �6� z r
Save File
Cancel