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 .
Copyright © 2019 Cloud Linux Software Inc.
This software is also available under ImunifyAV commercial license,
see
N) MessageType) MessageSink
MessageSourceexpect)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#HIIIIIIIIIIIr c P K | j j |j fi |j d {V d S r )r putpaths scan_argsr
messages r r zQueueSupervisor.put3 s@ !do!'-EE73DEEEEEEEEEEEr c H K | j |j d S r )r removescan_idsr s r r zQueueSupervisor.remove7 s% w /00000r 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 o00 gn
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 VK +,,F F -,F VK .//1 1 0/1 VK /00" " 10" VK 677+ + 87+ VK 455
65
r r )__doc__logging"defence360agent.contracts.messagesr !defence360agent.contracts.pluginsr r r *imav.malwarelib.scan.queue_supervisor_syncr getLoggerr) loggerr r0 r r r8 s * : : : : : :
8 $ $"
"
"
"
"
k= "
"
"
"
"
r