/opt/cloudlinux/venv/lib/python3.11/site-packages/ssa/__pycache__
Edit: /opt/cloudlinux/venv/lib/python3.11/site-packages/ssa/__pycache__/agent.cpython-311.pyc (3835B)
§
HIehŸ ã ót — d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl
mZ ddlm
Z
G d „ d
¦ « ZdS )zH
This module contains contains classes implementing SSA Agent behaviour
é N)ÚThreadÚcurrent_threadé )Ú
agent_sock)ÚSSAError)Ú
create_socket)ÚRequestProcessorc ó8 — e Zd ZdZd„ Zdd„Zd
d„Zd d
defd„ZdS )ÚSimpleAgentz
SSA Simple Agent class
c ó† — t j d¦ « | _ t ¦ « | _ | ¦ « d S )NÚagent)ÚloggingÚ getLoggerÚloggerr Úrequest_processorÚlisten)Úselfs ú@/opt/cloudlinux/venv/lib64/python3.11/site-packages/ssa/agent.pyÚ__init__zSimpleAgent.__init__ s3 € ÝÔ'¨Ñ0Ô0ˆŒÝ!1Ñ!3Ô!3ˆÔà�Љ
Œ
ˆ
ˆ
ˆ
ó ÚreturnNc óò — t t ¦ « } | ¦ « \ }}t | j |f¬¦ « }| ¦ « | j d|j ¦ « Œc)z(
Start listening socket
T)ÚtargetÚargsz[%s] Started) r r Úacceptr ÚhandleÚstartr ÚdebugÚname)r Ú_socketÚ
connectionÚaddressÚts r r zSimpleAgent.listen sl € õ ¥
Ñ+Ô+ˆð 6Ø")§.¢.Ñ"2Ô"2шJ˜Ý˜dœk°°
Ð>Ñ>Ô>ˆAØ
�GŠG‰IŒIˆIØŒK×Ò˜n¨a¬fÑ5Ô5Ð5ð 6r r! ú
socket objectc ó^ — | d¬¦ « } | |¦ « }| j |¦ « nQ# t $ rD}| j dt ¦ « j t |¦ « ¦ « Y d}~nd}~ww xY w|
¦ « dS )z�
Handle incoming connection
:param connection: socket object usable to
send and receive data on the connection
Úignore)ÚerrorszHandled exception in [%s]: %sN)ÚmakefileÚ
read_inputr r r r Úerrorr r ÚstrÚclose)r r! ÚfileobjÚ
input_dataÚes r r zSimpleAgent.handle* s¿ € ð ×%Ò%¨XÐ%Ñ6Ô6ˆð ØŸš¨Ñ1Ô1ˆJØÔ"×)Ò)¨*Ñ5Ô5Ð5Ð5øÝð ð ð ØŒK×ÒÐ=Ý,Ñ.Ô.Ô3µS¸±V´Vñ
=ô
=ð
=àˆDˆDˆDˆDøøøøð øøøð ×ÒÑÔÐÐÐs ˜/A Á
BÁ:BÂBÚfileiozfile objectc ó — | ¦ « }| j dt ¦ « j t | ¦ « ¦ « |¦ « |r(t j | ¦ « d¬¦ « S i S )zy
Read input data and return decoded json
:param fileio: a file-like object providing read method
z[%s] I received %i bytes: %sF)Ústrict)
Úreadr Úinfor r ÚlenÚencodeÚjsonÚloadsÚstrip)r r0 Údatas r r) zSimpleAgent.read_input: s{ € ð
�{Š{‰}Œ}ˆØŒ×ÒÐ7Ý'Ñ)Ô)Ô.µ°D·K²K±M´MÑ0BÔ0BØñ ô ð ð ð Ý”:˜dŸjšj™lœl°5Ð9Ñ9Ô9Ð9àˆIr )r N)r! r$ r N) Ú__name__Ú
__module__Ú__qualname__Ú__doc__r r r Údictr) © r r r r sw € € € € € ðð ðð ð ð 6ð 6ð 6ð 6ðð ð ð ð ð °4ð ð ð ð ð ð r r )r> r7 r Ú threadingr r Úinternal.constantsr Úinternal.exceptionsr Úinternal.utilsr Úmodules.processorr r r@ r r ú
rF sµ ððð ð €€€Ø €€€Ø ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ø *Ð *Ð *Ð *Ð *Ð *Ø )Ð )Ð )Ð )Ð )Ð )Ø )Ð )Ð )Ð )Ð )Ð )Ø /Ð /Ð /Ð /Ð /Ð /ð2ð 2ð 2ð 2ð 2ñ 2ô 2ð 2ð 2ð 2r