Edit File: scan_queue.cpython-311.pyc
� ���hC � �| � 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 � �� K � t ||�� � }|t _ |t _ |t _ |� t j � � � � � d {V �� d S )N)r �sink)r r � supervisorr r �process_messager �MalwareScanQueueRecheck)r r r r s r � create_sourcez QueueSupervisor.create_source+ se � � � �(�d��>�>�>� �%/��"� #�� � #�� ��"�"�;�#F�#H�#H�I�I�I�I�I�I�I�I�I�I�Ir c � �P K � | j j |j fi |j ��� d {V �� d S r )r �put�paths� scan_args�r �messages r r zQueueSupervisor.put3 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.remove7 s% � � � � �� � �w� /�0�0�0�0�0r c � �< K � | j � � � d S r )r �recheckr s r �nextzQueueSupervisor.next; 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_statusC sR � � � ��o�0�0� � �g�n� � � � � � � � � � � r )�__name__� __module__� __qualname__r r r r r r r �MalwareScanQueuePutr �MalwareScanQueueRemover r r" � MalwareScanQueueStopBackgroundr% � MalwareScanQueueUpdateStatusr' � r r r r % s � � � � � � #�#�J�#���� � �J� J� 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 r0 r r �<module>r8 s� ��� �* ���� :� :� :� :� :� :�� � � � � � � � � � � � � � � � �� �8� $� $��" � " � " � " � " �k�=� " � " � " � " � " r
Back to File Manager