관리-도구
편집 파일: scan_queue.cpython-311.pyc
� ��g� � �| � d Z ddlZddlmZ ddlmZmZmZ ddlm Z ej e � � Z G d� dee� � Z dS )u This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program. If not, see <https://www.gnu.org/licenses/>. Copyright © 2019 Cloud Linux Software Inc. This software is also available under ImunifyAV commercial license, see <https://www.imunify360.com/legal/eula> � N)� MessageType)� MessageSink� MessageSource�expect)�QueueSupervisorSyncc � � e Zd ZdxZxZZd� Zd� Z ee j � � d� � � Z ee j � � d� � � Z ee j � � d� � � Z ee j � � d� � � Z ee j � � d� � � ZdS ) �QueueSupervisorNc � � K � || _ d S �N)�loop)�selfr s �W/opt/imunify360/venv/lib/python3.11/site-packages/imav/malwarelib/plugins/scan_queue.py� create_sinkzQueueSupervisor.create_sink( s � � � ��� � � � c � �p K � t ||�� � t _ |t _ |t _ d S )N)r �sink)r r � supervisorr r )r r r s r � create_sourcez QueueSupervisor.create_source+ s1 � � � �%8�d��%N�%N�%N��"� #�� � #�� � � r c � �P K � | j j |j fi |j ��� d {V �� d S r )r �put�paths� scan_args�r �messages r r zQueueSupervisor.put0 s@ � � � �!�d�o�!�'�-�E�E�7�3D�E�E�E�E�E�E�E�E�E�E�Er c � �H K � | j � |j � � d S r )r �remove�scan_idsr s r r zQueueSupervisor.remove4 s% � � � � �� � �w� /�0�0�0�0�0r c � �< K � | j � � � d S r )r �recheckr s r �nextzQueueSupervisor.next8 s � � � � �� � �!�!�!�!�!r c � �< K � | j � � � d S r )r �clear_backgroundr s r �stop_backgroundz QueueSupervisor.stop_background< s � � � � ��(�(�*�*�*�*�*r c � �` K � | j � |j |j � � � d {V �� d S r )r �update_scan_statusr �statusr s r r% z"QueueSupervisor.update_scan_status@ sR � � � ��o�0�0� � �g�n� � � � � � � � � � � r )�__name__� __module__� __qualname__r r r r r r r �MalwareScanQueuePutr �MalwareScanQueueRemover �MalwareScanQueueRecheckr � MalwareScanQueueStopBackgroundr# � MalwareScanQueueUpdateStatusr% � r r r r % s � � � � � � #�#�J�#���� � �$� $� $� �V�K� +�,�,�F� F� -�,�F� �V�K� .�/�/�1� 1� 0�/�1� �V�K� /�0�0�"� "� 1�0�"� �V�K� 6�7�7�+� +� 8�7�+� �V�K� 4�5�5� � � 6�5� � � r r )�__doc__�logging�"defence360agent.contracts.messagesr �!defence360agent.contracts.pluginsr r r �*imav.malwarelib.scan.queue_supervisor_syncr � getLoggerr' �loggerr r/ r r �<module>r7 s� ��� �* ���� :� :� :� :� :� :�� � � � � � � � � � � � � � � � �� �8� $� $�� � � � � �k�=� � � � � r