| Server IP : 172.24.0.40 / Your IP : 216.73.216.10 Web Server : Apache System : Linux dbweb26.ust.edu.ph 4.18.0-513.5.1.el8_9.x86_64 #1 SMP Fri Sep 29 05:21:10 EDT 2023 x86_64 User : apache ( 48) PHP Version : 8.2.18 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /proc/self/root/usr/lib64/python3.6/site-packages/rhsmlib/dbus/__pycache__/ |
Upload File : |
3
a�e6 � @ s d dl mZmZmZ d dlZd dlZd dlZd dlZd dl Z d dl
m Z d dl m
Z
e
j� d dlmZ d dlmZ d dlmZ d dlmZ d d lmZmZ d d
lmZmZm Z m Z m Z d d l m Z d d l!m"Z" ej#e$�Z%e� Z&ej'e&�Z(G d
d� de)�Z*G dd� de)�Z+dS )� )�print_function�division�absolute_importN)� constants)� ga_loader)�GLib)�partial)�config)�get_config_parser)�create_filesystem_watcher�DirectoryWatch)�CONSUMER_WATCHER�ENTITLEMENT_WATCHER�CONFIG_WATCHER�PRODUCT_WATCHER�SYSPURPOSE_WATCHER)� injection)� init_loggerc @ sl e Zd ZdZdZdd� Zddd�Zddd�Zd d
� Zd d � Z e
de dd
�dd��Z e
de dd
�dd��Z
dS )�Serverz9
Class used for rhsm.service providing D-Bus API
Nc O s t j| �| _| jS )zK
Function called, when new instance of Server is requested
)�object�__new__�INSTANCE)�cls�args�kwargs� r � /usr/lib64/python3.6/server.pyr 2 s zServer.__new__c C s� t t� tj� tjjj� |p$tj| _ |p0tj
}|p8i }|p@g }g | _ i | _ y|f |�| _
W n$ tjjk
r� tjd� � Y nX tjtj�| _d}td d }td d }d}tjj| j | j
�| _tj� | _xv|D ]n} y| d | d }
} W n tk
�r | }
i } Y nX |
f |
j | jd �| ��} | j j | � | | j t |
j �< q�W g }
g }g }g }g }d
| j k�r�|j | j d
j � |
j | j d
j � |j | j d
j � |j | j d
j � |j | j d
j!� d | j k�r�|
j | j d j"� d | j k�r|j | j d j � |j | j d j#� d
| j k�r.|j | j d
j$� d| j k�rL|j | j d j%� t&| jj'|
�}t&||�}t&||�}t&||�}t&||�}t(t)|t*|t+|t,|t-|i�| _.t/j0| j.j1dd�| _2| j2j3� dS )a�
Create a connection to a bus defined by bus_class and bus_kwargs; instantiate objects in
object_classes; expose them under bus_name and enter a GLib mainloop. bus_kwargs are generally
only necessary if you're using dbus.bus.BusConnection
The object_classes argument is a list. The list can contain either a class or a tuple consisting
of a class and a dictionary of arguments to send that class's constructor.
zCould not create bus classz/etc/rhsm/rhsm.confZrhsmZproductCertDirZentitlementCertDirz$/etc/rhsm/syspurpose/syspurpose.jsonr � )Z object_path�bus_nameZEntitlementDBusObjectZConsumerDBusObjectZConfigDBusObjectZProductsDBusObjectZSyspurposeDBusObjectzThread-FileSystemWatcher)�target�nameN)4r �parserr Z threads_init�dbus�mainloopZglibr ZBUS_NAMEr Z SystemBus�objectsZ
object_map�bus�
exceptionsZ
DBusException�log� exception�injZrequireZIDENTITYZidentity�confZserviceZBusNameZconnection_nameZMainLoop� TypeErrorZdefault_dbus_path�append�str�__name__�reloadZEntitlementChangedZConsumerChangedZ
ConfigChangedZInstalledProductsChangedZSyspurposeChangedr Z
cert_dir_pathr r
r r r r �filesystem_watcher� threadingZThreadZloop�_thread�start)�selfZ bus_classr �object_classesZ
bus_kwargsZconfig_cert_dir_pathZproducts_cert_dir_pathZentitlement_cert_dir_pathZsyspurpose_cert_dir_path�item�clazzr Zclazz_instanceZconsumer_dir_listZentitlement_dir_listZconfig_dir_listZproducts_dir_listZsyspurpose_dir_listZconsumer_dir_watchZentitlement_dir_watchZconfig_dir_watchZproducts_dir_watchZsyspurpose_dir_watchr r r �__init__9 s�
zServer.__init__c C s� z�y t j| j|� | jj� W n� tk
rJ } ztj|� W Y dd}~X nV tk
rt } ztj|� W Y dd}~X n, t k
r� } ztj|� W Y dd}~X nX W d| j
j � |r�|j � X dS )z�
The two arguments, started_event and stopped_event, should be instances of threading.
Event that will be set when the mainloop has finished starting and stopping.
N)
r Zidle_add�notify_startedr# �run�KeyboardInterruptr' r( �
SystemExit� Exceptionr0 �stop�set)r4 �
started_eventZ
stopped_event�er r r r: � s
z
Server.runc C s t jd� |r|j� dS )z�
This callback will be run once the mainloop is up and running. It's only purpose is to alert
other blocked threads that the mainloop is ready.
zStart notification sentF)r' �debugr? )r4 r@ r r r r9 � s
zServer.notify_startedc C sJ | j j� | jj� | jjd� x| jD ] }|j� q(W | jj | j
� dS )z�
This method is primarily intended for uses of Server in a thread such as during testing since
in a single-threaded program, the execution would be blocked on the mainloop and therefore
preclude even calling this method.
� N) r# �quitr0 r> r2 �joinr$ �remove_from_connectionr% Z release_namer )r4 �or r r �shutdown� s
zServer.shutdown)� watcher_set�returnc C sZ | j }|dkrdS xB|jjj� D ]2\}}|dk r:||kr:q tjd|� �� |j� q W dS )z�
This function temporary disables file system directory watchers
:param watcher_set: Set of watchers. If the watcher is None, then all watchers are disabled
:return: None
Nz Disabling directory watcher: )r r0 � dir_watches�itemsr' rB Ztemporary_disable)r rI �server_instance�dir_watcher_id� dir_watcherr r r � temporary_disable_dir_watchers� s z%Server.temporary_disable_dir_watchersc C sZ | j }|dkrdS xB|jjj� D ]2\}}|dk r:||kr:q tjd|� �� |j� q W dS )z�
This function enables file system directory watchers
:param watcher_set: Set of watcher. If the watcher is None, then all watchers are enabled
:return: None
Nz Enabling directory watcher: )r r0 rK rL r' rB �enable)r rI rM rN rO r r r �enable_dir_watchers� s zServer.enable_dir_watchers)NNNN)NN)N)N)r. �
__module__� __qualname__�__doc__r r r8 r: r9 rH � classmethodr? rP rR r r r r r + s
g
r c @ sl e Zd ZU dZdZedZeedd� �Ze dd� �Z
e dd � �Z ed
d � �Z dd
d�Z
dd� Zdd� Zd S )�DomainSocketServera� This class sets up a DBus server on a domain socket. That server can then be used to perform
registration. The issue is that we can't send registration credentials over the regular system or
session bus since those aren't really locked down. The work-around is the client asks our service
to open another server on a domain socket, gets socket information back, and then connects and sends
the register command (with the credentials) to the server on the domain socket.z unix:tmpdir=z/runc C s | j | j S )N)�_server_socket_iface�_server_socket_path)r4 r r r �_server_socket s z!DomainSocketServer._server_socketc
C s^ ||| j | jd�}tjd||f � |j|� | j� | jd7 _W d Q R X tjd|� d S )N)�conn�sender�cmd_linezInstance: %s of %s createdr zNew connection: %s)r\ r] r' rB r, �lock�connection_count)�domain_socket_serverZ
service_classZ object_listr[ �objr r r �connection_added
s
z#DomainSocketServer.connection_addedc
C sl t jd|� | j�P | jd8 _| jdkr8t jd� n&| jdkrNt jd� nt jd| j � W d Q R X d S )NzClosed connection: %sr r zNo connections remainz Server still has one connectionz Server still has %d connections)r' rB r^ r_ )r` r[ r r r �connection_removed s
z%DomainSocketServer.connection_removedc C s | j r| j jS d S d S )N)�_server�address)r4 r r r re ' s zDomainSocketServer.addressNc C sH |pg | _ g | _d| _|| _|| _tj� | _| j� d| _W dQ R X dS )a� Create a connection to a bus defined by bus_class and bus_kwargs; instantiate objects in
object_classes; expose them under bus_name and enter a GLib mainloop. bus_kwargs are generally
only necessary if you're using dbus.bus.BusConnection
The object_classes argument is a list. The list can contain either a class or a tuple consisting
of a class and a dictionary of arguments to send that class's constructor.
Nr ) r5 r$ rd r\ r] r1 ZLockr^ r_ )r4 r5 r\ r] r r r r8 . s
zDomainSocketServer.__init__c C s> x| j D ] }|j� qW | jj� d | _ d | _d | _d | _d S )N)r$ rF rd Z
disconnectr\ r] )r4 rG r r r rH @ s
zDomainSocketServer.shutdownc C s� yXt jj| j�| _x*| jD ] }| jjjtt j
| || j �� qW | jj jtt j
| �� | jS tk
r� } ztj|� W Y d d }~X nX d S )N)r" Zserverr rZ rd r5 Zon_connection_addedr, r rW rb r$ Zon_connection_removedrc re r= r' r( )r4 r7 rA r r r r: K s zDomainSocketServer.run)NNN)r. rS rT rU rX r- rY �propertyrZ � staticmethodrb rc re r8 rH r: r r r r rW � s
rW ),Z
__future__r r r ZloggingZ dbus.servicer" Z dbus.serverZdbus.mainloop.glibr1 Z rhsmlib.dbusr Zsubscription_managerr Zinit_gaZsubscription_manager.gar � functoolsr Zrhsmlib.servicesr Z rhsm.configr
Zrhsmlib.file_monitorr r r
r r r r r r) Z rhsm.logutilr Z getLoggerr. r' r! ZConfigr* r r rW r r r r �<module> s,
Q