/usr/lib/python3.9/site-packages/tuned/daemon/__pycache__
Edit: /usr/lib/python3.9/site-packages/tuned/daemon/__pycache__/application.cpython-39.pyc (8194B)
a
Á]›iÒ ã @ s¼ d dl mZmZmZmZmZmZmZ d dlm Z d dl
Z d dl Z ddl m
Z
ddl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dlmZ e j ¡ ZdgZG d d„ de ƒZ dS )
é )ÚstorageÚunitsÚmonitorsÚpluginsÚprofilesÚexportsÚhardware)ÚTunedExceptionNé )Ú
controller)Údaemon)Ú GlobalConfigÚ Applicationc @ s’ e Zd Zd dd„Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z e
j fdd„Z dd„ Z
dd„ Ze
j fdd„Zedd„ ƒZedd„ ƒZd d „ ZdS ) r Nc
C s| t dtjjt ¡ d f ¡ d | _d | _t
¡ }t |¡}|d u rJt ƒ n|| _
| j
tj¡rjt d¡ n
t d¡ t ¡ }| j
dtj¡}tj|d}t ¡ }t ¡ } tj ¡ }
tj ¡ | _ t ||||| |
| j
| j ¡} t | j
tj tj!¡ƒ} t" #| || || j
¡}
t ¡ }t $¡ }t %| j
&tj'tj(¡¡}t )|||| j
| j ¡}t* +|
||| j
| ¡| _,t- .| j,| j
¡| _/| 0¡ d | _1d S )NzTuneD: %s, kernel: %sé z8dynamic tuning is enabled (can be overridden in plugins)z#dynamic tuning is globally disabledÚudev_buffer_size)Z buffer_size)2ÚlogÚinfoÚtunedÚversionZTUNED_VERSION_STRÚosÚunameÚ_dbus_exporterÚ_unix_socket_exporterr ZPickleProviderZFactoryr
ÚconfigÚget_boolÚconstsZCFG_DYNAMIC_TUNINGr Z
RepositoryZget_sizeZCFG_DEF_UDEV_BUFFER_SIZEr Z InventoryZ
DeviceMatcherZDeviceMatcherUdevr Úinstancer Z variablesZ VariablesÚintÚgetZ CFG_DEFAULT_INSTANCE_PRIORITYZ!CFG_DEF_DEFAULT_INSTANCE_PRIORITYr ZManagerZMergerZLocatorÚget_listZCFG_PROFILE_DIRSZCFG_DEF_PROFILE_DIRSÚLoaderr ZDaemonÚ_daemonr Z
ControllerÚ _controllerÚ
_init_signalsÚ _pid_file)ÚselfZ profile_namer Zstorage_providerZstorage_factoryZmonitors_repositoryr Zhardware_inventoryZdevice_matcherZdevice_matcher_udevZplugin_instance_factoryZplugins_repositoryZdef_instance_priorityZ unit_managerZprofile_factoryZprofile_mergerZprofile_locatorZprofile_loader© r& ú.handler_wrapper)Úsignal)r% r, r+ r- r& r* r' Ú_handle_signal? s zApplication._handle_signalc C s: | tj| jj¡ | tj| jj¡ | tj| jj¡ d S r) )r/ r. ÚSIGHUPr" ZsighupÚSIGINTZ terminateÚSIGTERM©r% r& r& r' r# E s zApplication._init_signalsc C s6 | j d urtdƒ‚tj ||||¡| _ t | j ¡ d S )Nz&DBus interface is already initialized.)r r r ZdbusZ DBusExporterÚregister_exporter)r% Zbus_nameZ object_nameZinterface_nameÚ namespacer& r& r' Úattach_to_dbusJ s
zApplication.attach_to_dbusc C sj | j d urtdƒ‚tj | j tj¡| j tj
¡| j tj ¡| j tj
¡| j tj¡¡| _ t | j ¡ d S )Nz-Unix socket interface is already initialized.)r r r Z unix_socketZUnixSocketExporterr r r ZCFG_UNIX_SOCKET_PATHr Z CFG_UNIX_SOCKET_SIGNAL_PATHSZCFG_UNIX_SOCKET_OWNERSHIPZget_intZCFG_UNIX_SOCKET_PERMISIONSZ#CFG_UNIX_SOCKET_CONNECTIONS_BACKLOGr4 r3 r& r& r' Úattach_to_unix_socketQ s
üz!Application.attach_to_unix_socketc C s t | j¡ d S r) )r Zregister_objectr" r3 r& r& r' Úregister_controller\ s z Application.register_controllerc C s² t |¡ t |gg g tj¡\}}}t|ƒdkrBt |¡ tdƒ‚t |d¡}t |¡ t|ƒdkrltdƒ‚zt d|¡d }W n tj
yœ tdƒ‚Y n0 |dkr®td ƒ‚d
S ) z|
Wait till the child signalizes that the initialization is complete by writing
some uninteresting data into the pipe.
r
z=Cannot daemonize, timeout when waiting for the child process.é r z:Cannot daemonize, no response from child process received.ú?z?Cannot daemonize, invalid response from child process received.Tz0Cannot daemonize, child process reports failure.N) r ÚcloseÚselectr ZDAEMONIZE_PARENT_TIMEOUTÚlenr ÚreadÚstructÚunpackÚerror)r% Ú parent_in_fdÚ child_out_fdZ
read_readyZdropZresponseÚvalr& r& r' Ú_daemonize_parent_ s
z Application._daemonize_parentc
C sÔ || _ | ¡ z€tj | j ¡}tj |¡s4t |¡ t t | j tj tj
B tj B d¡d¡"}| dt
¡ ¡ W d ƒ n1 s‚0 Y W n@ ttfyÎ } z$t d| j t|ƒf ¡ W Y d }~n
d }~0 0 d S )Ni¤ Úwz%dz cannot write the PID to %s: %s)r$ Ú_delete_pid_filer ÚpathÚdirnameÚexistsÚmakedirsÚfdopenÚopenÚO_CREATÚO_TRUNCÚO_WRONLYÚwriteÚgetpidÚOSErrorÚIOErrorr ÚcriticalÚstr)r% Úpid_fileZdir_nameÚfrA r& r& r' Úwrite_pid_filex s
(4zApplication.write_pid_filec
C s` t j | j¡r\zt | j¡ W n< tyZ } z$t d| jt|ƒf ¡ W Y d }~n
d }~0 0 d S )Nz&cannot remove existing PID file %s, %s) r rH rJ r$ ÚunlinkrS r ÚwarningrV )r% rA r& r& r' rG … s
z Application._delete_pid_filec
C s, t |¡ t d¡ t ¡ t d¡ z t ¡ }|dkrBt d¡ W n` ty¤ } zHt
dt |ƒ ¡ t
dd¡}t ||¡ t |¡ tdƒ‚W Y d}~n
d}~0 0 tdd ƒ}t | ¡ tj ¡ ¡ t | ¡ tj ¡ ¡ t | ¡ tj ¡ ¡ | |¡ t d
¡ t
dd ¡}t ||¡ t |¡ dS ) zy
Finishes daemonizing process, writes a PID file and signalizes to the parent
that the initialization is complete.
ú/r z"cannot daemonize, fork() error: %sr: Fz'Cannot daemonize, second fork() failed.Nz /dev/nullzw+zsuccessfully daemonizedT)r r; ÚchdirÚsetsidÚumaskÚforkÚsysÚexitrS r rU rV r? ÚpackrQ r rM Údup2ÚfilenoÚstdinÚstdoutÚstderrrY Údebug)r% rW rB rC ÚpidrA rD Úfdr& r& r' Ú_daemonize_childŒ s.
z Application._daemonize_childc
C sº t ¡ }z t ¡ }W nH ty\ } z0t |d ¡ t |d ¡ tdƒ‚W Y d}~n
d}~0 0 z4|dkr~| j|Ž t d¡ n| j |g|¢R Ž W n" |dkr¦‚ n
t d¡ Y n0 dS )zÚ
Daemonizes the application. In case of failure, TunedException is raised
in the parent process. If the operation is successfull, the main process
is terminated and only child process returns from this method.
r r
z Cannot daemonize, fork() failed.N)
r Úpiper` rS r; r rE ra rb rl )r% rW Zparent_child_fdsZ child_pidrA r& r& r' Ú daemonize® s
zApplication.daemonizec C s | j S r) )r! r3 r& r& r' r É s zApplication.daemonc C s | j S r) )r" r3 r& r& r' r Í s zApplication.controllerc C sj |r| j tjd¡ | j tjtj¡s0t d¡ | j ¡ }| j tjtj¡rTt
¡ | j d urf|
¡ |S )NTzrUsing one shot no daemon mode, most of the functionality will be not available, it can be changed in global config)r Úsetr Z
CFG_DAEMONr ZCFG_DEF_DAEMONr r[ r" Úrunr Ústopr$ rG )r% r Úresultr& r& r' rp Ñ s
zApplication.run)NN)Ú__name__Ú
__module__Ú __qualname__r( r/ r# r6 r7 r8 rE r ZPID_FILErY rG rl rn Úpropertyr r rp r& r& r& r' r s
+
"
) r r r r r r r r Ztuned.exceptionsr Z
tuned.logsZ
tuned.versionÚ r r r. r ra r< r? Z tuned.constsr Ztuned.utils.global_configr
Zlogsr r Ú__all__Úobjectr r& r& r& r' Ú
s $