o •Û_åã@s´ddlmZmZmZmZmZmZmZddlm Z ddl Zddl m Z ddl m Z ddlZddlZddlZddlZddlZddlmZddlmZej ¡ZdgZGd d„deƒZdS) é)ÚstorageÚunitsÚmonitorsÚpluginsÚprofilesÚexportsÚhardware)ÚTunedExceptionNé)Ú controller)Údaemon)Ú GlobalConfigÚ Applicationc@s‚eZdZddd„Zdd„Zdd„Zdd „Zd d „Zej fd d „Z dd„Z dd„Z ej fdd„Z edd„ƒZedd„ƒZdd„ZdS)rNc CsLd|_t ¡}t |¡}|durtƒn||_|j tj¡r#t   d¡nt   d¡t   ¡}|j  dtj¡}tj|d}t ¡}t ¡} tj ¡} tj ¡|_t  ||||| | |j|j¡} t|j tjtj¡ƒ} t | || ||j¡} t ¡}t ¡}t tj ¡}t !||||j|j¡}t" #| |||j|¡|_$t% &|j$|j¡|_'| (¡d|_)dS)Nz8dynamic tuning is enabled (can be overridden in plugins)z#dynamic tuning is globally disabledÚudev_buffer_size)Ú buffer_size)*Ú_dbus_exporterrÚPickleProviderÚFactoryr ÚconfigÚget_boolÚconstsÚCFG_DYNAMIC_TUNINGÚlogÚinforÚ RepositoryÚget_sizeÚCFG_DEF_UDEV_BUFFER_SIZErÚ InventoryÚ DeviceMatcherÚDeviceMatcherUdevrÚinstancerÚ variablesÚ VariablesÚintÚgetÚCFG_DEFAULT_INSTANCE_PRIORITYÚ!CFG_DEF_DEFAULT_INSTANCE_PRIORITYrÚManagerÚMergerÚLocatorÚLOAD_DIRECTORIESÚLoaderr ÚDaemonÚ_daemonr Ú ControllerÚ _controllerÚ _init_signalsÚ _pid_file)ÚselfÚ profile_namerÚstorage_providerÚstorage_factoryÚmonitors_repositoryrÚhardware_inventoryÚdevice_matcherÚdevice_matcher_udevÚplugin_instance_factoryÚplugins_repositoryÚdef_instance_priorityÚ unit_managerÚprofile_factoryÚprofile_mergerÚprofile_locatorÚprofile_loader©rBú:/usr/lib/python3/dist-packages/tuned/daemon/application.pyÚ__init__s<       ÿþ  zApplication.__init__cs‡‡fdd„}t ˆ|¡dS)Ncsˆ|kr ˆƒdSdS©NrB)Ú_signal_numberÚ_frame©ÚhandlerÚ signal_numberrBrCÚhandler_wrapper;s ÿz3Application._handle_signal..handler_wrapper)Úsignal)r2rJrIrKrBrHrCÚ_handle_signal:szApplication._handle_signalcCs:| tj|jj¡| tj|jj¡| tj|jj¡dSrE)rMrLÚSIGHUPr/ÚreloadÚSIGINTÚ terminateÚSIGTERM©r2rBrBrCr0@szApplication._init_signalscCs@|jdur tdƒ‚tj |||¡|_t |j¡t |j¡dS)Nz&DBus interface is already initialized.)rr rÚdbusÚ DBusExporterÚregister_exporterÚregister_objectr/)r2Úbus_nameÚ object_nameÚinterface_namerBrBrCÚattach_to_dbusEs  zApplication.attach_to_dbuscCs®t |¡t |gggtj¡\}}}t|ƒdkr!t |¡tdƒ‚t |d¡}t |¡t|ƒdkr6tdƒ‚z t  d|¡d}Wn tj yLtdƒ‚w|dkrUtd ƒ‚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.érz:Cannot daemonize, no response from child process received.ú?z?Cannot daemonize, invalid response from child process received.Tz0Cannot daemonize, child process reports failure.N) ÚosÚcloseÚselectrÚDAEMONIZE_PARENT_TIMEOUTÚlenr ÚreadÚstructÚunpackÚerror)r2Ú parent_in_fdÚ child_out_fdÚ read_readyÚdropÚresponseÚvalrBrBrCÚ_daemonize_parentMs"      ÿÿzApplication._daemonize_parentc CsØ||_| ¡zCtj |j¡}tj |¡st |¡t t |jtj tj Btj Bd¡d¡}|  dt  ¡¡WdƒWdS1sCwYWdSttfyk}zt d|jt|ƒf¡WYd}~dSd}~ww)Ni¤Úwz%dzcannot write the PID to %s: %s)r1Ú_delete_pid_filer^ÚpathÚdirnameÚexistsÚmakedirsÚfdopenÚopenÚO_CREATÚO_TRUNCÚO_WRONLYÚwriteÚgetpidÚOSErrorÚIOErrorrÚcriticalÚstr)r2Úpid_fileÚdir_nameÚfrfrBrBrCÚwrite_pid_filefs  (&ÿ&€ÿzApplication.write_pid_filec Csdtj |j¡r0z t |j¡WdSty/}zt d|jt|ƒf¡WYd}~dSd}~wwdS)Nz&cannot remove existing PID file %s, %s) r^rprrr1Úunlinkr{rÚwarningr~)r2rfrBrBrCross&€ÿýzApplication._delete_pid_filec Cs t |¡t d¡t ¡t d¡zt ¡}|dkr!t d¡Wn*tyL}zt   dt |ƒ¡t   dd¡}t ||¡t |¡tdƒ‚d}~wwtdd ƒ}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. ú/rz"cannot daemonize, fork() error: %sr]Fz'Cannot daemonize, second fork() failed.Nz /dev/nullzw+zsuccessfully daemonizedT)r^r_ÚchdirÚsetsidÚumaskÚforkÚsysÚexitr{rr}r~rdÚpackryr ruÚdup2ÚfilenoÚstdinÚstdoutÚstderrr‚Údebug)r2rrgrhÚpidrfrlÚfdrBrBrCÚ_daemonize_childzs4    €   €û     zApplication._daemonize_childc Cs®t ¡}zt ¡}Wnty(}zt |d¡t |d¡tdƒ‚d}~wwz|dkr;|j|Žt d¡WdS|j |g|¢RŽWdS|dkrO‚t d¡YdS)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. rr z Cannot daemonize, fork() failed.N) r^Úpiper‰r{r_r rmrŠr‹r•)r2rÚparent_child_fdsÚ child_pidrfrBrBrCÚ daemonizeœs$ €ý zApplication.daemonizecCó|jSrE)r-rSrBrBrCr ·ózApplication.daemoncCršrE)r/rSrBrBrCr »r›zApplication.controllercCsj|r |j tjd¡|j tjtj¡st d¡|j  ¡}|j tjtj¡r*t   ¡|j dur3|  ¡|S)NTzrUsing one shot no deamon mode, most of the functionality will be not available, it can be changed in global config)rÚsetrÚ CFG_DAEMONrÚCFG_DEF_DAEMONrÚwarnr/ÚrunrÚstopr1ro)r2r ÚresultrBrBrCr ¿s   zApplication.run)NN)Ú__name__Ú __module__Ú __qualname__rDrMr0r[rmrÚPID_FILEr‚ror•r™Úpropertyr r r rBrBrBrCrs ' "   )ÚtunedrrrrrrrÚtuned.exceptionsr Ú tuned.logsÚr r rLr^rŠr`rdÚ tuned.constsrÚtuned.utils.global_configr Úlogsr$rÚ__all__ÚobjectrrBrBrBrCÚs$