File: //proc/self/root/usr/lib/python3.6/site-packages/ipalib/__pycache__/backend.cpython-36.pyc
3
�d[e� � @ s� d Z ddlZddlZddlZddlmZ ddlmZmZm Z ddl
m Z m Z m
Z
eje�ZG dd� dej�ZG dd � d e�ZG d
d � d e�ZdS ) z*
Base classes for all backed-end plugins.
� N)�plugable)� PublicError�
InternalError� CommandError)�context�
Connection�destroy_contextc @ s e Zd ZdZdS )�Backendz-
Base class for all backend plugins.
N)�__name__�
__module__� __qualname__�__doc__� r r � /usr/lib/python3.6/backend.pyr # s r c @ sR e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
e e
�Z dS )� Connectiblea$
Base class for backend plugins that create connections.
In addition to the nicety of providing a standard connection API, all
backend plugins that create connections should use this base class so that
`request.destroy_context()` can properly close all open connections.
Fc C s6 t j| |� |r| j| _nd| jtt| ��f | _d S )Nz%s_%s)r �__init__�name�id�str)�selfZapiZshared_instancer r r r 2 s
zConnectible.__init__c O sj t t| j�r(tdj| j| jtj� j���| j||�}t t| jt
|| j �� | j |ksXt
�tjd| j� dS )z1
Create thread-local connection.
z%{0} is already connected ({1} in {2})z Created connection context.%sN)�hasattrr r � Exception�formatr � threading�current_thread�create_connection�setattrr �
disconnect�conn�AssertionError�logger�debug)r �args�kwr r r r �connect9 s zConnectible.connectc O s t d| j ��d S )Nz%s.create_connection())�NotImplementedErrorr )r r" r# r r r r J s z Connectible.create_connectionc C sN t t| j�s(tdj| j| jtj� j���| j� t t| j� t
j d| j� d S )Nz!{0} is not connected ({1} in {2})z Destroyed connection context.%s) r r r r r r r r �destroy_connection�delattrr r! )r r r r r M s zConnectible.disconnectc C s t d| j ��d S )Nz%s.destroy_connection())r% r )r r r r r& Z s z Connectible.destroy_connectionc C s t t| j�S )zY
Return ``True`` if thread-local connection on `request.context` exists.
)r r r )r r r r � isconnected] s zConnectible.isconnectedc C s6 t t| j�s(tdj| j| jtj� j���tt| j�j S )z1
Return thread-local connection.
z!{0} is not connected ({1} in {2}))
r r r �AttributeErrorr r r r �getattrr )r r r r Z
__get_connc s zConnectible.__get_connN)F)
r
r r r
r r$ r r r& r( Z_Connectible__get_conn�propertyr r r r r r ) s
r c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) � ExecutionerNc C sT |dk r|t jd< | jjr0| jjj|ddd� n | jjj� |dk rPtt d|� dS )zA
client_ip: The IP address of the remote client.
NZ
KRB5CCNAME)�ccacheZ
size_limitZ
time_limit� client_ip)
�os�environ�envZ in_serverr Zldap2r$ Z rpcclientr r )r r- r. r r r �create_contextu s
zExecutioner.create_contextc C s
t � d S )N)r )r r r r r � s zExecutioner.destroy_contextc O s� z|y$|| j krt|d��| j | ||�S tk
r< � Y n> tk
rx } z"tjd|jjt|�� t � �W Y d d }~X nX W d t
� X d S )N)r znon-public: %s: %s) ZCommandr r r r Z exception� __class__r
r r r )r �_namer" Zoptions�er r r �execute� s
zExecutioner.execute)NN)r
r r r2 r r6 r r r r r, s s
r, )r
Zloggingr r/ Zipalibr Z
ipalib.errorsr r r Zipalib.requestr r r Z getLoggerr
r ZPluginr r r, r r r r �<module> s
J