$Fi
d dl Z d dlZd dlZd dlmZmZmZ ddlmZm Z ddl
m Z e j d Z
ded dfd
Zded dfd Zded ed dfd
Zd Zdefdeeef ded dfdZdS ) N)UnionIterableCallable )switch_schedstatsno_xray_active_tasks )RequestProcessortoolssignumreturnc > t d| | dS )z/
Signal handler to log received signal
zReceived sig: %i (%s)N)loggerinfor frames I/opt/cloudlinux/venv/lib64/python3.11/site-packages/ssa/internal/tools.pylog_on_receiver s! KK'88888 c J t d| t t d| t r*t d t d t
j d dS )zO
Signal handler to dump collected statistics and switch off schedstats
zReceived sig: %iz/Dumped successfully after %i signal, exiting...z0No X-Ray tasks running, switching schedstats offF)enabledr N)r r r
flush_bufferr r sysexitr s r sigterm_receivedr s KK"F+++##%%%
KKA6JJJ ) FGGG%((((HQKKKKKr
sighandlerc t j | | t d| dS # t t f$ r'}t d| | Y d}~dS d}~ww xY w)z4
Register given sighandler for given signum
z
Registered %szSkipped %s because of %sN)signalr r OSError
ValueError)r r es r register_a_signalr" ) s ;
fj))) OV,,,,, Z ; ; ; .:::::::::;s 04 A, A''A,c D t t j t dS )z4
Register a dump handler for SIGTERM signal
N)r" r SIGTERMr r r register_sigtermr& 4 s fn&677777r signalshandlerc | !t j D ]}t || dS t | t rt | | dS | D ]}t || dS )z
Register given handler for given signal or range of signals
If no signals given, add given handler for all available signals
N)r Signalsr"
isinstanceint)r' r( sigs r register_signalsr. ; s > , ,C c7 + + + + , , gs # # 0 gw / / / / /
0
0!#w////
0
0r )loggingr r typingr r r utilsr r modules.processorr
getLoggerr r, r r r" r& r. r% r r r4 sC
, , , , , , , , , , : : : : : : : : 0 0 0 0 0 0 7 # #93 9$ 9 9 9 9 S D ;c ;x ;D ; ; ; ;8 8 8 6:)70 0eCM 2 0 &0<@0 0 0 0 0 0r