One Hat Cyber Team
Your IP :
10.30.1.1
Server IP :
103.148.201.5
Server :
Linux web-olt 5.15.0-156-generic #166-Ubuntu SMP Sat Aug 9 00:02:46 UTC 2025 x86_64
Server Software :
Apache/2.4.52 (Ubuntu)
PHP Version :
8.1.29
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
ovs
/
db
/
__pycache__
/
View File Name :
idl.cpython-310.pyc
o y.�e�~ � @ s� d dl Z d dlZd dlZd dlZd dlm mZ d dlZd dl Zd dl Zd dl Zd dl Zd dl Zd dlmZ d dlmZ ej�d�ZdZdZdZdZd Zd Zd Zd Zd Ze � d d�Z de j _ G dd� de �Z!G dd� dej"�Z#G dd� de$�Z%G dd� de$�Z&G dd� de$�Z'G dd� de$�Z(d d � Z)ej*G d d � d e$��Z+d d!� Z,d"d#� Z-G d$d%� d%e$�Z.G d&d'� d'e$�Z/G d(d)� d)e$�Z0dS )*� N)� custom_index)�error�idlzno-classattr no-objattrs�create�update�delete� � � clustered�relay�Notice)�event�row�updates�Nc sL e Zd ZdZdZ� fdd�Zdd� Zdd� Zd d � Zd d � Z d d� Z � Z S )�ColumnDefaultDicta A column dictionary with on-demand generated default values This object acts like the Row._data column dictionary, but without the necessity of populating column default values. These values are generated on-demand and therefore only use memory once they are accessed. )�_tablec s || _ t� �� d S r )r �super�__init__��self�table�� __class__� �,/usr/lib/python3/dist-packages/ovs/db/idl.pyr ; s zColumnDefaultDict.__init__c C s | j j| }tjjj�|j�S r )r �columns�ovs�db�data�Datum�default�type�r �columnr r r � __missing__? s z ColumnDefaultDict.__missing__c C s | j j�� S r )r r �keys�r r r r r& C � zColumnDefaultDict.keysc s t � fdd�� D ��S )Nc 3 s � | ]}� | V qd S r r )�.0�kr' r r � <genexpr>G s � z+ColumnDefaultDict.values.<locals>.<genexpr>)�iterr' r r' r �valuesF � zColumnDefaultDict.valuesc C s t | �� �S r )r, r& r' r r r �__iter__I r( zColumnDefaultDict.__iter__c C s || � � v S r )r& )r �itemr r r � __contains__L r( z ColumnDefaultDict.__contains__) �__name__� __module__� __qualname__�__doc__� __slots__r r% r& r- r/ r1 � __classcell__r r r r r 2 s r c @ s e Zd ZeZeZeZdS )�MonitorN) r2 r3 r4 � OVSDB_UPDATE�monitor� OVSDB_UPDATE2� monitor_cond� OVSDB_UPDATE3�monitor_cond_sincer r r r r8 P s r8 c @ sx e Zd Zdd� Zdd� Zedd� �Zedd� �Zed d � �Zed d � �Z e d d� �Z dd� Z dd� Z dd� Zdd� ZdS )�ConditionStatec C s dg| _ d | _d | _d S �NT)� _ack_cond� _req_cond� _new_condr' r r r r W s zConditionState.__init__c C s t | j| j| jg�S r )r, rC rB rA r' r r r r/ \ � zConditionState.__iter__c C � | j S )z/The latest freshly initialized condition change�rC r' r r r �new_ � zConditionState.newc C rE )z>The last condition change that has been accepted by the server)rA r' r r r �ackedd rH zConditionState.ackedc C rE )z>A condition that's been requested, but not acked by the server)rB r' r r r � requestedi rH zConditionState.requestedc C s t dd� | D ��S )z The most recent condition changec s s � | ] }|d ur|V qd S r r )r) �condr r r r+ q s � z(ConditionState.latest.<locals>.<genexpr>)�nextr' r r r �latestn s zConditionState.latestc C s | dgkS r@ r )� conditionr r r �is_trues � zConditionState.is_truec C s || _ dS )z1Signal that a condition change is being initiatedNrF )r rK r r r �initw rP zConditionState.initc C �" | j dur| j d| _| _ dS dS )z-Signal that a condition change has been ackedN)rB rA r' r r r �ack{ � �zConditionState.ackc C rR )z1Signal that a condition change has been requestedN)rC rB r' r r r �request� rT zConditionState.requestc C s* | j dur| jdu r| j | _d| _ dS dS )z.Reset a requested condition change back to newNTF)rB rC r' r r r �reset� s zConditionState.resetN)r2 r3 r4 r r/ �propertyrG rI rJ rM � staticmethodrO rQ rS rU rV r r r r r? V s" r? c @ sN e Zd Zdd� Zdd� Zedd� �Zedd� �Zejd d� �Ze d d � �Z d S ) �IdlTablec C sT t |tjjj�s J �|| _d| _t�| �| _ || _ t � | _ dd� |j �� D �| _ d S )NFc S s i | ] \}}|t |��qS r )� IdlColumn�r) r* �vr r r � <dictcomp>� s z%IdlTable.__init__.<locals>.<dictcomp>)� isinstancer r �schema� TableSchemar � need_tabler � IndexedRows�rowsr r? �_condition_stater �items)r r r r r r r � s zIdlTable.__init__c C � t | j|�S r )�getattrr �r �attrr r r � __getattr__� r( zIdlTable.__getattr__c C rE r )rd r' r r r �condition_state� rH zIdlTable.condition_statec C s | j jS r )rk rM r' r r r rN � s zIdlTable.conditionc C s" t |t�sJ �| j�| j|� d S r )r^ �listr � cond_change�name)r rN r r r rN � s c s � �fdd�|j �� D �S )Nc s i | ] \}}|� �|��qS r r r[ ��clsr r r r] � s z*IdlTable.schema_tables.<locals>.<dictcomp>)�tablesre )rp r r_ r ro r � schema_tables� � zIdlTable.schema_tablesN) r2 r3 r4 r rj rW rk rN �setter� classmethodrr r r r r rY � s rY c @ s e Zd Zdd� Zdd� ZdS )rZ c C s || _ d| _d S r@ )�_column�alertr# r r r r � � zIdlColumn.__init__c C rf r )rg rv rh r r r rj � r( zIdlColumn.__getattr__N)r2 r3 r4 r rj r r r r rZ � s rZ c @ s� e Zd ZdZdZdZdZdZdZdZ dZ e j ee j ee je iZ dkd d �Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Z d%d&� Z d'd(� Z d)d*� Z d+d,� Z d-d.� Z!d/d0� Z"d1d2� Z#d3d4� Z$dld5d6�Z%d7d8� Z&d9d:� Z'd;d<� Z(d=d>� Z)d?d@� Z*dAdB� Z+dCdD� Z,dEdF� Z-dGdH� Z.dIdJ� Z/e jfdKdL�Z0dMdN� Z1dOdP� Z2dldQdR�Z3dSdT� Z4dUdV� Z5dWdX� Z6dYdZ� Z7d[d\� Z8d]d^� Z9d_d`� Z:dadb� Z;dcdd� Z<dedf� Z=dgdh� Z>didj� Z?d S )m�Idla Open vSwitch Database Interface Definition Language (OVSDB IDL). The OVSDB IDL maintains an in-memory replica of a database. It issues RPC requests to an OVSDB database server and parses the responses, converting raw JSON into data structures that are easier for clients to digest. The IDL also assists with issuing database transactions. The client creates a transaction, manipulates the IDL data structures, and commits or aborts the transaction. The IDL then composes and issues the necessary JSON-RPC requests and reports to the client whether the transaction completed successfully. The client is allowed to access the following attributes directly, in a read-only fashion: - 'tables': This is the 'tables' map in the ovs.db.schema.DbSchema provided to the Idl constructor. Each ovs.db.schema.TableSchema in the map is annotated with a new attribute 'rows', which is a dict from a uuid.UUID to a Row object. The client may directly read and write the Row objects referenced by the 'rows' map values. Refer to Row for more details. - 'change_seqno': A number that represents the IDL's state. When the IDL is updated (by Idl.run()), its value changes. The sequence number can occasionally change even if the database does not. This happens if the connection to the database drops and reconnects, which causes the database contents to be reloaded even if they didn't change. (It could also happen if the database server sends out a "change" that reflects what the IDL already thought was in the database. The database server is not supposed to do that, but bugs could in theory cause it to do so.) - 'lock_name': The name of the lock configured with Idl.set_lock(), or None if no lock is configured. - 'has_lock': True, if the IDL is configured to obtain a lock and owns that lock, and False otherwise. Locking and unlocking happens asynchronously from the database client's point of view, so the information is only useful for optimization (e.g. if the client doesn't have the lock then there's no point in trying to write to the database). - 'is_lock_contended': True, if the IDL is configured to obtain a lock but the database server has indicated that some other client already owns the requested lock, and False otherwise. - 'txn': The ovs.db.idl.Transaction object for the database transaction currently being constructed, if there is one, or None otherwise. r r r � � � � NTc C s t |t�sJ �|�� }t�| |�| _|j| _|| _| �|�}t j j j ||d�| _ d| _d| _d| _d| _t�� | _ttjdd��| _d| _d| _d| _d| _d| _d| _ d| _ d| _ t�� | _ || _ d| _!d| _"| j#| _$d| _%d| _&d| _'d| _(d| _)i | _*d| _+d| _,dS )a4 Creates and returns a connection to the database named 'db_name' on 'remote', which should be in a form acceptable to ovs.jsonrpc.session.open(). The connection will maintain an in-memory replica of the remote database. 'remote' can be comma separated multiple remotes and each remote should be in a form acceptable to ovs.jsonrpc.session.open(). 'schema_helper' should be an instance of the SchemaHelper class which generates schema for the remote database. The caller may have cut it down by removing tables or columns that are not of interest. The IDL will only replicate the tables and columns that remain. The caller may also add an attribute named 'alert' to selected remaining columns, setting its value to False; if so, then changes to those columns will not be considered changes to the database for the purpose of the return value of Idl.run() and Idl.change_seqno. This is useful for columns that the IDL's client will write but not read. As a convenience to users, 'schema' may also be an instance of the SchemaHelper class. The IDL uses and modifies 'schema' directly. If 'leader_only' is set to True (default value) the IDL will only monitor and transact with the leader of the cluster. If "probe_interval" is zero it disables the connection keepalive feature. If non-zero the value will be forced to at least 1000 milliseconds. If None it will just use the default value in OVS. )�probe_intervalNr ��int�_Server�DatabaseF)-r^ � SchemaHelper�get_idl_schemarY rr rq �readonly�_db�_parse_remotesr �jsonrpc�Session� open_multiple�_session� _request_id�_monitor_request_id� _last_seqno� change_seqno�uuid�uuid1�str�UUID�last_id�_server_schema_request_id�_server_monitor_request_id�_db_change_aware_request_id�_monitor_cancel_request_id�_server_db_name�_server_db_table� server_tables� _server_db�server_monitor_uuid� leader_only� cluster_id� _min_index� IDL_S_INITIAL�state� lock_name�has_lock�is_lock_contended�_lock_request_id�txn�_outstanding_txns� cond_changed� cond_seqno)r �remote� schema_helperr~ r� r_ �remotesr r r r � sH ! � z Idl.__init__c C sJ g }|� d�D ]}|r |�d�dkr |d d| 7 < q|�|� q|S )N�,�:���)�split�find�append)r r� r� �rr r r r� G s zIdl._parse_remotesc C s" || _ | j| jkr| �� dS dS )z8Set the id of the cluster that this idl must connect to.N)r� r� r� �force_reconnect)r r� r r r �set_cluster_idT s �zIdl.set_cluster_idc C s | j | j�|�S )z,Create a named multi-column index on a table)rq rc � index_create)r r rn r r r r� Z s zIdl.index_createc C s | j | jj| �||�S )z9Return items in a named index between start/end inclusive�rq rc �indexes�irange)r r rn �start�endr r r � index_irange^ rs zIdl.index_irangec C s | j | jj| �||�S )z.Return items in a named index matching a valuer� )r r rn �valuer r r � index_equalb rs zIdl.index_equalc C s | j �� dS )zNCloses the connection to the database. The IDL will no longer update.N)r� �closer' r r r r� f s z Idl.closec C s | j �� D ]}|j�� qdS )z,Mark all requested table conditions as ackedN)rq r- rk rS r r r r �ack_conditionsk s �zIdl.ack_conditionsc C sp | j ttjdd��k}|rd| _| j�� D ] }|r$|j�� |j� � q|j� � r5ttjdd��| _ d| _qdS )a� Synchronize condition state when the FSM is restarted If a non-zero last_id is available for the DB, then upon reconnect the IDL should first request acked conditions to avoid missing updates about records that were added before the transaction with txn-id == last_id. If there were requested condition changes in flight and the IDL client didn't set new conditions, then reset the requested conditions to new to trigger a follow-up monitor_cond_change request. If there were changes in flight then there are two cases: a. either the server already processed the requested monitor condition change but the FSM was restarted before the client was notified. In this case the client should clear its local cache because it's out of sync with the monitor view on the server side. b. OR the server hasn't processed the requested monitor condition change yet. As there's no easy way to differentiate between the two, and given that this condition should be rare, reset the 'last_id', essentially flushing the local cached DB contents. r r FTN) r� r� r� r� r� rq r- rk rU rS rV )r �ack_allr r r r �sync_conditionsp s ��zIdl.sync_conditionsc C s | � � | �� | j| _d S r )r� � _Idl__send_server_schema_request� IDL_S_SERVER_SCHEMA_REQUESTEDr� r' r r r � restart_fsm� s zIdl.restart_fsmc C sl | j rJ �| j}| �� | j�� d}|dk �r�|d7 }| j}| j�� s&�n�| j�� }|| jkrD|| _| �� | � � | j rB| � � �nm| j� � }|du rO�nb|j tjjjtjjjfv }|rj| jrj| j|jkrjd| _|j tjjjkr�|jdkr�t|j�dkr�| �|jd t� |jd | _�n |j tjjjkr�|jdkr�t|j�dkr�| �|jd t � �n�|j tjjjkr�|jd kr�t|j�dkr�|jd t | j �kr�| j|jd t | j d � || _| �!� s�| �"� �n̐n�| �|jd t � �n�| �#|�r��n�| �$|��r�n�|j tjjjk�r�| j%du�r�| j%|jk�r�zY| jd7 _d| _%| j&| j'k�rC|j(d �s3| �)� | �|j(d t� |j(d | _n'| j&| j*k�rV| �)� | �|j(t � n| j&| j+k�s_J �| �)� | �|j(t � | j,| _&W �n< t-j.�y� } zt/�0d | j�1� |f � | �2� W Y d}~�n d}~ww |j tjjjk�r| j3du�r| j3|jk�rz$d| _3t4d|j(�}|�5| j6� |�7� } | | _8t9�:| | �| _ | �;� W �n� t-j.�y } z)t/�0d | j�1� |f � | j<�r�| �2� W Y d}~�n�|| _| �=� W Y d}~�n�d}~ww |j tjjjk�r~| j>du�r~| j>|jk�r~z(d| _>| j|j(t | j d � || _| �!� �r=| �=� | �?� n| �"� W �nmW �nf t-j.�y} } z)t/�0d | j�1� |f � | j<�rk| �2� W Y d}~�nF|| _| �=� W Y d}~�n4d}~ww |j tjjjk�r�| j@du�r�| j@|jk�r�d| _@�n|j tjjjk�r�| jAdu�r�| jA|jk�r�| �B|j(� n�|j tjjjk�r�|jd k�r�| �C|jd� n�|j tjjjk�r�|jdk�r�| �C|jd� n�|j tjjjk�r�|jdk�r�n�|j tjjjk�r| j&| j'k�r| j%|jk�r|j-dk�r| �=tDjE� n�|j tjjjk�r<| j&| j*k�r<| j%|jk�r<|j-dk�r;| �=tDjF� nq|j tjjjk�rf| j3du�rf| j3|jk�rfd| _3| j<�r^| �"� nS|| _| �=� nG|j tjjjtjjjfv �r{| �G|��r{n2|j tjjjk�r�| j&| j,k�r�| �H� | �� | jId7 _Int/�Jd| j�1� tjj�K|j �f � |dk s|| jkS )a+ Processes a batch of messages from the database server. Returns True if the database as seen through the IDL changed, False if it did not change. The initial fetch of the entire contents of the remote database is considered to be one kind of change. If the IDL has been configured to acquire a database lock (with Idl.set_lock()), then successfully acquiring the lock is also considered to be a change. This function can return occasional false positives, that is, report that the database changed even though it didn't. This happens if the connection to the database drops and reconnects, which causes the database contents to be reloaded even if they didn't change. (It could also happen if the database server sends out a "change" that reflects what we already thought was in the database, but the database server is not supposed to do that.) As an alternative to checking the return value, the client may check for changes in self.change_seqno.r �2 r N�update3rz r �update2r )rq z&%s: parse error in received schema: %sz%%s: error receiving server schema: %s�lockedT�stolenF�echozunknown methodz"%s: received unexpected %s message)Lr� r� �send_cond_changer� �run� is_connected� get_seqnor� �_Idl__txn_abort_allr� r� �_Idl__send_lock_request�recvr" r r� �Message�T_REPLY�T_ERRORr� �id�T_NOTIFY�method�len�params�_Idl__parse_updater= r� r; r� r� r9 r� �_Idl__check_server_dbr� �handle_monitor_canceled�handle_monitor_cancel_replyr� r� �'IDL_S_DATA_MONITOR_COND_SINCE_REQUESTED�result� _Idl__clear�!IDL_S_DATA_MONITOR_COND_REQUESTED� IDL_S_DATA_MONITOR_REQUESTED�IDL_S_MONITORINGr �Error�vlog�err�get_name� _Idl__errorr� r� �register_tabler� r� r� rY rr �!_Idl__send_server_monitor_requestr� �_Idl__send_monitor_requestr� �_Idl__send_db_change_awarer� r� �_Idl__parse_lock_reply�_Idl__parse_lock_notifyr8 r< r: �_Idl__txn_process_replyr� r� �dbg�type_to_string) r �initial_change_seqno�i�previous_change_seqno�seqno�msg� is_response�e�shr_ r r r r� � st � �� � ��� ��� � � ��� � � � ���� �� ;zIdl.runc C s� |j |jkrdS |jdkrdS |jd t| j�kr t| j�g}n|jd t| j�kr1t| j�g}ndS tjj � d|�}|j | _ | � |� | �� dS )NF�monitor_canceledr �monitor_cancelT)r" r� r� r� r� r� r� r r� r� �create_requestr� r� � send_requestr� )r r� r� �mc_msgr r r r� p s zIdl.handle_monitor_canceledc C s* |j |jkrdS |j| jkrdS d | _dS )NFT)r" r� r� r� �r r� r r r r� � s z Idl.handle_monitor_cancel_replyc C s� | j sd S i }| j�� D ]}|jjd ur#d|jjig||j< |j�� q |s(d S d| _ t| j�}t� � | _|t| j�|g}t j j � d|�S )N�whereF�monitor_cond_change)r� rq r- rk rG rn rU r� r� r� r r� r� r� )r �change_requestsr �old_uuidr� r r r �compose_cond_change� s$ � � �zIdl.compose_cond_changec C s6 | j �� r | jd ur d S | �� }|r| �|� d S d S r )r� r� r� r r� r r r r r� � s �zIdl.send_cond_changec C s� | j �|�}|st�d| ��|g krdg}|jj|kr%|j�|� d| _|jjr>t dd� | j � � D ��}| j t |� d S | j t t |jj�� S )aG Sets the condition for 'table_name' to 'cond', which should be a conditional expression suitable for use directly in the OVSDB protocol, with the exception that the empty condition [] matches no rows (instead of matching every row). That is, [] is equivalent to [False], not to [True]. zUnknown table "%s"FTc s s � | ]}|j jV qd S r )rk rU )r) �tr r r r+ � s � �z"Idl.cond_change.<locals>.<genexpr>r )rq �getr r� rk rM rQ r� rG �anyr- r� r� �boolrJ )r � table_namerK r �any_reqsr r r rm � s �zIdl.cond_changec C s. | j r |�� dS | j�|� | j�|� dS )z�Arranges for poller.block() to wake up when self.run() has something to do or when activity occurs on a transaction on 'self'.N)r� �immediate_waker� �wait� recv_wait�r �pollerr r r r � s zIdl.waitc C s | j dkS )a� Returns True, if the IDL successfully connected to the remote database and retrieved its contents (even if the connection subsequently dropped and is in the process of reconnecting). If so, then the IDL contains an atomic snapshot of the database's contents (but it might be arbitrarily old if the connection dropped). Returns False if the IDL has never connected or retrieved the database's contents. If so, the IDL is empty.r )r� r' r r r �has_ever_connected� s zIdl.has_ever_connectedc C s$ | j | jkr | j�� | j�� dS )z�Forces the IDL to drop its connection to the database and reconnect. In the meantime, the contents of the IDL will not change.N)r� r� r� � reset_backoffr� r' r r r r� � s zIdl.force_reconnectc C s | j �� S r )r� r� r' r r r � session_name� s zIdl.session_namec C s` | j rJ �| jr J �| jr |r|| jkr | �� d| _d| _|r,| js.|| _| �� dS dS dS )aM If 'lock_name' is not None, configures the IDL to obtain the named lock from the database server and to avoid modifying the database when the lock cannot be acquired (that is, when another client has the same lock). If 'lock_name' is None, drops the locking requirement and releases the lock.NF)r� r� r� �_Idl__send_unlock_requestr� r� )r r� r r r �set_lock� s �z Idl.set_lockc C � dS )a� Hook for implementing create/update/delete notifications :param event: The event that was triggered :type event: ROW_CREATE, ROW_UPDATE, or ROW_DELETE :param row: The row as it is after the operation has occured :type row: Row :param updates: For updates, row with only old values of the changed columns :type updates: Row Nr )r r r r r r r �notify � z Idl.notifyc C r )aw Hook for cooperatively yielding to eventlet/gevent/asyncio/etc. When a block of code is going to spend a lot of time cpu-bound without doing any I/O, it can cause greenthread/coroutine libraries to block. This call should be added to code where this can happen, but defaults to doing nothing to avoid overhead where it is not needed. Nr r' r r r �cooperative_yield r zIdl.cooperative_yieldc C sJ d}| j �� D ] }|jrd}t�|�|_qd| _|r#| jd7 _d S d S )NFTr r )rq r- rc r rb r� r� )r �changedr r r r �__clear s ��z Idl.__clearc C s6 |r| j s| jd u r| jd7 _n d| _|| _ d S )Nr F)r� r� r� r� )r � new_has_lockr r r �__update_has_lock& s zIdl.__update_has_lockc C sL | � d� d | _| j�� r"tjj�|| jg�}|j }| j� |� |S d }|S )NF) �_Idl__update_has_lockr� r� r� r r� r� r� r� r� �send)r r� r� �msg_idr r r �__do_send_lock_request2 s �zIdl.__do_send_lock_requestc C s | � d�| _d S )N�lock)�_Idl__do_send_lock_requestr� r' r r r �__send_lock_request= s zIdl.__send_lock_requestc C s | � d� d S )N�unlock)r$ r' r r r �__send_unlock_request@ � zIdl.__send_unlock_requestc C s: d | _ t|t�o|�d�du }| �|� |sd| _d S d S )Nr� T)r� r^ �dictr r r� )r r� �got_lockr r r �__parse_lock_replyC s �zIdl.__parse_lock_replyc C sV | j d ur!t|ttf�r#|r%|d | j kr'| �|� |s)d| _d S d S d S d S d S d S )Nr T)r� r^ rl �tupler r� )r r� r r r r �__parse_lock_notifyJ s �� �zIdl.__parse_lock_notifyc C s* t jj�ddg�}|j| _| j�|� d S )N�set_db_change_awareT)r r� r� r� r� r� r� r r r r r �__send_db_change_awareS s �zIdl.__send_db_change_awarec C s" |j | _| j�� r| j�|�S d S r )r� r� r� r� r )r rU r r r r� Y s �zIdl.send_requestc C s0 | j | jkr | j| _ d}n| j | jkr!| jt|� | _ t|�j}n| j| _ d}i }| j� � D ]@}g }|j � � D ]}|j| j vsM|j| j v rR|| j |j vrR|� |� q7d|i}|dv rht�|jj�sh|jj|d< |g||j< q.| jjt| j�|g}|dkr�|� t| j�� tjj�||�} | j| _| � | � d S )Nr< r: r )r< r> r r> ) r� r� r� � IDL_S_SERVER_MONITOR_REQUESTED� monitor_mapr8 rn r� rq r- r r& r� r� r? rO rk rI r� r� r� r� r r� r� r� r� r� r� ) r � max_versionr� �monitor_requestsr r r$ �monitor_request�argsr� r r r �__send_monitor_request^ s: � � zIdl.__send_monitor_requestc C s: | j | _tjj�d| jt| j�g�}|j | _ | � |� d S )N� get_schema) r� r� r r� r� r� r� r� r� r� r� r� r r r r � __send_server_schema_request~ s �z Idl.__send_server_schema_requestc C s� | j | _i }| j| j }dd� |j�� D �}|j�� D ] }t|d�s%d|_qt � |�|_ d|_ | |_ d|i}|g||j< tjj�d| jjt| j�|g�}|j| _| �|� d S )Nc S s g | ]}|�qS r r )r) r$ r r r � <listcomp>� � z5Idl.__send_server_monitor_request.<locals>.<listcomp>rw TFr r: )r0 r� r� r� r r& r- �hasattrrw r rb rc ra r rn r r� r� r� r� r� r� r� r� r� )r r3 r r r$ r4 r� r r r � __send_server_monitor_request� s* � ��z!Idl.__send_server_monitor_requestc C sp z|s| � ||| j� W d S | � |||� W d S tjy7 } zt�d| j�� |f � W Y d }~d S d }~ww )Nz %s: error parsing update: %s)�_Idl__do_parse_updaterq r r� r� r� r� r� )r r �versionrq r� r r r �__parse_update� s ���zIdl.__parse_updatec C s� t |t�s t�d|��g }|�� D ]�\}}|�|�}|s#t�d| ��t |t�s0t�d| |��|�� D ]�\}} tj�|�sHt�d||f |��tj� |�} t | t�s\t�d||f ��| � � |t t fv r|| � || | �} | r{|�| � | jd7 _q4tjj�| d�} | �dtg�} | �d tg�}| �� | s�|s�t�d | ��| �|| | |�} | r�|�| � | jd7 _q4q|D ]}| j|� q�d S ) Nz <table-updates> is not an objectz+<table-updates> includes unknown table "%s"z.<table-update> for table "%s" is not an objectzC<table-update> for table "%s" contains bad UUID "%s" as member namezP<table-update> for table "%s" contains <row-update> for %s that is not an objectr z row-update�oldrG z,<row-update> missing "old" and "new" members)r^ r) r r� re r r �ovsuuid�is_valid_string� from_stringr r; r= �_Idl__process_update2r� r� r �parser�Parser� get_optional�finish�_Idl__process_updater )r � table_updatesr> rq �noticesr � table_updater � uuid_string� row_updater� �changesrE r@ rG �noticer r r �__do_parse_update� sj � � �� �� � � ��$ �zIdl.__do_parse_updatec C s |j �|�}d|v r!|r|j |= tt|�S t�d||jf � d S d|v s)d|v rg|r9t�d||jf � |j |= | �||�}d|v rH|d }n|d }| �||� | � |||�}||j |< |rett |�S d S d|v r�|srt � d��| � |||d �}tt|t| |||��S t � d|��) �4Returns Notice if a column changed, False otherwise.r z)cannot delete missing row %s from table%s�insert�initialz(cannot add existing row %s from table %s�modifyzModify non-existing rowz <row-update> unknown operationF)rc r r � ROW_DELETEr� �warnrn �_Idl__create_row�_Idl__add_default�_Idl__row_update� ROW_CREATEr r� �_Idl__apply_diff� ROW_UPDATE�Row)r r r� rN r r �old_rowr r r �__process_update2� sB ��� � �zIdl.__process_update2c C s" |j �|�}d}|s!|r|j |= tt|�S t�d||jf � dS |sWt}|s0| �||�}d}n t }t�d||jf � || � |||�O }|tkrN||j |< |rUtt|�S dS t }|so| �||�}d}t}t�d||jf � || � |||�O }|tkr�||j |< |r�t||t � | |||��S dS )rR Fz*cannot delete missing row %s from table %sTz&cannot add existing row %s to table %sz(cannot modify missing row %s in table %s) rc r r rV r� rW rn r[ rX r] rZ r^ � from_json)r r r� r@ rG r r �opr r r �__process_update� sN � � � � � zIdl.__process_updatec C s� | � � }| j| jvrt�d|| j| jf � dS | j| j j}d}|�� D ] }| jr:| jt dd� |j �v r9|} n q%|j | j j krE|} nq%|sUt�d|| j j f � dS |j tkr�|jsft�d| � dS |jsrt�d| � dS | jr�|js�t�d | � dS |jr�|jd | jk r�t�d | � dS |jd | _dS |j tkr�|js�t�d | � dS |js�t�d | � dS | jr�t�d| � dS dS )zAReturns True if this is a valid server database, False otherwise.z4%s: server does not have %s table in its %s databaseFNc S s t | �d d� S )Nr{ �r� )�xr r r �<lambda>< r: z'Idl.__check_server_db.<locals>.<lambda>z$%s: server does not have %s databasezO%s: clustered database server has not yet joined cluster; trying another serverzQ%s: clustered database server is disconnected from cluster; trying another serverzJ%s: clustered database server is not cluster leader; trying another serverr zC%s: clustered database server has stale data; trying another serverzZ%s: relay database server has not yet connected to the relay source; trying another serverzV%s: relay database server is disconnected from the relay source; trying another serverzC%s: relay database server cannot be a leader; trying another serverT)r r� r� r� �infor� rc r- r� �map�cidrn r� �model� CLUSTEREDr_ � connectedr� �leader�indexr� rW �RELAY)r r rc �databaser r r r �__check_server_db, s� �� ��� � ����� ����zIdl.__check_server_dbc C s4 |j jj tjjjkrtj�|j jj j�S |j jj jS r ) r" �keyr r �types�UuidTyperA �to_jsonr! r# r r r � __column_namen s zIdl.__column_namec C sn |j �� D ]/}|j|vr4|j| jvs!|j| jv r4|j| j|j vr4|jjdkr4|j�� s4| �|�||j< qd S )Nr )r r- rn r� r" �n_min�is_map�_Idl__column_name)r r rN r$ r r r � __add_defaultt s ��zIdl.__add_defaultc C s� i }|� � D ]]\}}|j�|�}|s t�d||jf � qz tj�|j |�}W n t j yE } zt�d||j| f � W Y d } ~ qd } ~ ww |j | � � ||< |j | �|�} | |j | krc| |j |< q|S )N�#unknown column %s updating table %s�'error parsing column %s in table %s: %s)re r r r� rW rn r r ra r" r r� �_data�copy�diff) r r r �row_diffr_ � column_name�datum_diff_jsonr$ � datum_diffr� �datumr r r � __apply_diff} s. � � �� �zIdl.__apply_diffc C s� d}|� � D ]S\}}|j�|�}|s t�d||jf � qz tj�|j |�}W n t j yE } zt�d||j| f � W Y d } ~ qd } ~ ww ||j | krX||j |< |j rWd}q q|S )NFr{ r| T)re r r r� rW rn r r ra r" r r� r} rw ) r r r �row_jsonr r� � datum_jsonr$ r� r� r r r � __row_update� s0 � � �� �zIdl.__row_updatec C s t | ||t|��S r )r^ r )r r r� r r r � __create_row� s zIdl.__create_rowc C s | j �� d S r )r� r� r' r r r �__error� r( z Idl.__errorc C s* | j r| j �� d }tj|_| j sd S d S )Nr )r� �popitem� Transaction� TRY_AGAIN�_status)r r� r r r �__txn_abort_all� s �zIdl.__txn_abort_allc C s& | j �|jd �}|r|�|� dS d S r@ )r� �popr� �_process_reply)r r� r� r r r �__txn_process_reply� s �zIdl.__txn_process_replyr@ r )@r2 r3 r4 r5 r� r� r0 r� r� r� r� r8 r: r< r> r1 r r� r� r� r� r� r� r� r� r� r� r� r� r r� rm r r r� r r r r r� r r$ r� r r� r� r� r� r� r� r� r� r= rD rI r� ry rY r\ rZ rX r� r� r� r r r r ry � s� 3� �N $ U 7%-B ry c C s t | t�r| jS | S r )r^ r^ r� )r� r r r � _row_to_uuid� s r� c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zd%dd�Zedd � �Zd d � Zd d � Zd!d"� Zd#d$� ZdS )&r^ a� A row within an IDL. The client may access the following attributes directly: - 'uuid': a uuid.UUID object whose value is the row's database UUID. - An attribute for each column in the Row's table, named for the column, whose values are as returned by Datum.to_python() for the column's type. If some error occurs (e.g. the database server's idea of the column is different from the IDL's idea), then the attribute values is the "default" value return by Datum.default() for the column's type. (It is important to know this because the default value may violate constraints for the column's type, e.g. the default integer value is 0 even if column contraints require the column's value to be positive.) When a transaction is active, column attributes may also be assigned new values. Committing the transaction will then cause the new value to be stored into the database. *NOTE*: In the current implementation, the value of a column is a *copy* of the value in the database. This means that modifying its value directly will have no useful effect. For example, the following: row.mycolumn["a"] = "b" # don't do this will not change anything in the database, even after commit. To modify the column, instead assign the modified column value back to the column: d = row.mycolumn d["a"] = "b" row.mycolumn = d c C sJ || j d< || j d< || j d< || j d< i | j d< i | j d< i | j d< d S )Nr� �_idlr r} �_changes� _mutations�_prereqs)�__dict__)r r r r� r r r r r � s z Row.__init__c C s& t |t�stS t| jd |jd k �S �Nr� �r^ r^ �NotImplementedr r� �r �otherr r r �__lt__" � z Row.__lt__c C s& t |t�stS t| jd |jd k�S r� r� r� r r r �__eq__' r� z Row.__eq__c C s t | jd �S r� )r� r� r' r r r �__hash__, r( z Row.__hash__c s. dj � jjd�� fdd�t� jj�D ��d�S )Nz{table}({data})z, c 3 s. � | ]}t � |�rd j|t� |�d�V qdS )z {col}={val})�col�valN)r; �formatrg �r) �cr' r r r+ 2 s � �z Row.__str__.<locals>.<genexpr>)r r )r� r rn �join�sortedr r' r r' r �__str__/ s ��z Row.__str__c C s\ |j r,z | jj|j j }W n ty% } z d�|j j�}t|�|�d }~ww |j�|�S |S )NzTable {} is not registered) � ref_tabler� rq rn �KeyErrorr� �AttributeErrorrc r )r �atom�baser r� r� r r r � _uuid_to_row6 s �� zRow._uuid_to_rowc s� | j d usJ �| jd usJ �z| jj| }W n ty' td| jj|f ��w | j �|�}d }d| j� � v r?| jd �|�}d }d| j� � v rP| jd �|�}|d u r�| j d u rq|d u rgtd| jj|f ��t j � |j|t�}n�|| j v r�| j | }|j�� r�|�� }|d ur�|�t|�� |d ur�t j � |j|t�}|�� � � fdd�|D �}t j � |j|t�}nC|j�� r�|�| j�}|d ur�|�|� |d ur�|D ]} | |p�i vr�|�| d � q�t j � |j|t�}n|d u r�td| jj|f ��|}|�| j�S )Nz!%s instance has no attribute '%s'�_inserts�_removesc s g | ]}|� vr|�qS r r )r) re �� removes_listr r r9 f s z#Row.__getattr__.<locals>.<listcomp>)r� r� r r r� r� r r2 r r& r} r r � from_pythonr" r� �is_set�as_list�extendrl rx � to_pythonr� r r� ) r r� r$ r� �inserts�removes�dlist� removes_datum�dmaprr r r� r rj A s� �� �� � � � � ���� zRow.__getattr__c C s2 | j d usJ �| jjs J �| jj| jjv r(|| jj| jj v r(t�d| � d S | jj| }z t j � |j |t �}W n tjyV } zt�d||f � W Y d }~d S d }~ww t| |�ru| jjj�� D ]}|dd� |jD �v rt|�| � qc| jj�| ||� | jjj�� D ]}|dd� |jD �v r�|�| � q�d S )Nz)attempting to write to readonly column %s�/attempting to write bad value to column %s (%s)c s � � | ]}|j V qd S r �r$ r� r r r r+ � � � z"Row.__setattr__.<locals>.<genexpr>c s r� r r� r� r r r r+ � r� )r� r� r� r rn r� r� rW r r r r� r" r� r r� r� r; rc r� r- �remove�_write�add)r r� r� r$ r� r� �idxr r r � __setattr__} s: � ��� � ��zRow.__setattr__c C � | | j jj| j< | jj| }z tj�|j |t � W n t j y6 } zt �d||f � W Y d }~d S d }~ww | j�di �}|�|t� �}|�|� d S )Nr� r� �r� r� � _txn_rowsr� r r r r r� r" r� r r� r� r� r� � setdefault�setr� )r r� rr r$ r� r� � column_valuer r r �addvalue� � ���z Row.addvaluec C r� )Nz2attempting to delete bad value from column %s (%s)r� r� )r r� rr r$ r� r� r� r r r �delvalue� r� z Row.delvaluec C s� | | j jj| j< | jj| }z tj�|j ||it � W n t j y8 } zt �d||f � W Y d }~d S d }~ww | jrT|| jv rT| j�di �}|�|t� �}|�|� | j�di �}|�|i �}|||< d S )Nr� r� r� )r� r� r� r� r r r r r� r" r� r r� r� r� r} r� r� r� r� ) r r� rr r� r$ r� r� r� r� r r r �setkey� s$ ��� z Row.setkeyNc C s� | | j jj| j< |r1z tj�| j| | j�}W n t j y" Y d S w ||vr)d S || |kr1d S | j � di �}|� |t � �}|�|� d S )Nr� )r� r� r� r� r r r� r} r� r r� r� r� r� r� )r r� rr r� � old_valuer� r� r r r �delkey� s" �� z Row.delkeyc C s� i }|� � D ]F\}}|j�|�}|s t�d||jf � qz tjjj � |j |�} W n t j yG } zt�d||j| f � W Y d } ~ qd } ~ ww | ||< q| ||||�S )Nz unknown column %s in table %sr| )re r r r� rW rn r r r r ra r" r r� ) rp r r r� r� r r� r� r$ r� r� r r r ra � s& � � �� z Row.from_jsonc C s@ | j jsJ �| jdus J �| jdu s|| jv rdS d| j|< dS )a� Causes the original contents of column 'column_name' in this row to be verified as a prerequisite to completing the transaction. That is, if 'column_name' changed in this row (or if this row was deleted) between the time that the IDL originally read its contents and the time that the transaction commits, then the transaction aborts and Transaction.commit() returns Transaction.TRY_AGAIN. The intention is that, to ensure that no transaction commits based on dirty reads, an application should call Row.verify() on each data item read as part of a read-modify-write operation. In some cases Row.verify() reduces to a no-op, because the current value of the column is already known: - If this row is a row created by the current transaction (returned by Transaction.insert()). - If the column has already been modified within the current transaction. Because of the latter property, always call Row.verify() *before* modifying the column, for a given read-modify-write. A transaction must be in progress.N)r� r� r� r} r� �r r� r r r �verify� s z Row.verifyc C s^ | j jsJ �| jdus J �| jdu r| j jj| j= n| | j jj| j< | jj| j= d| jd< dS )zLDeletes this row from its table. A transaction must be in progress.Nr� ) r� r� r� r} r� r� r rc r� r' r r r r s z Row.deletec C s | j j�| |� d S r )r� r� �_fetchr� r r r �fetch rD z Row.fetchc C s | j j�| |� dS )a� Causes the transaction, when committed, to increment the value of 'column_name' within this row by 1. 'column_name' must have an integer type. After the transaction commits successfully, the client may retrieve the final (incremented) value of 'column_name' with Transaction.get_increment_new_value(). The client could accomplish something similar by reading and writing and verify()ing columns. However, increment() will never (by itself) cause a transaction to fail because of a verify error. The intended use is for incrementing the "next_cfg" column in the Open_vSwitch table.N)r� r� � _incrementr� r r r � increment s z Row.incrementr )r2 r3 r4 r5 r r� r� r� r� r� rj r� r� r� r� r� ru ra r� r r� r� r r r r r^ � s( 7 < r^ c C s dt | ��dd� S )Nzrow%s�-�_)r� �replace�r� r r r �_uuid_name_from_uuid/ rD r� c C s dddt | �gggS )N�_uuid�==r� rd r� r r r �_where_uuid_equals3 rD r� c @ s e Zd Zdd� ZdS )� _InsertedRowc C s || _ d | _d S r )�op_index�real)r r� r r r r 8 rx z_InsertedRow.__init__N)r2 r3 r4 r r r r r r� 7 s r� c @ s� e Zd ZdZdZdZdZdZdZdZ dZ d Z e d d � �Z d d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d7d+d,�Z d-d.� Z e d/d0� �Z d1d2� Z d3d4� Z!d5d6� Z"d*S )8r� a A transaction may modify the contents of a database by modifying the values of columns, deleting rows, inserting rows, or adding checks that columns in the database have not changed ("verify" operations), through Row methods. Reading and writing columns and inserting and deleting rows are all straightforward. The reasons to verify columns are less obvious. Verification is the key to maintaining transactional integrity. Because OVSDB handles multiple clients, it can happen that between the time that OVSDB client A reads a column and writes a new value, OVSDB client B has written that column. Client A's write should not ordinarily overwrite client B's, especially if the column in question is a "map" column that contains several more or less independent data items. If client A adds a "verify" operation before it writes the column, then the transaction fails in case client B modifies it first. Client A will then see the new value of the column and compose a new transaction based on the new contents written by client B. When a transaction is complete, which must be before the next call to Idl.run(), call Transaction.commit() or Transaction.abort(). The life-cycle of a transaction looks like this: 1. Create the transaction and record the initial sequence number: seqno = idl.change_seqno(idl) txn = Transaction(idl) 2. Modify the database with Row and Transaction methods. 3. Commit the transaction by calling Transaction.commit(). The first call to this function probably returns Transaction.INCOMPLETE. The client must keep calling again along as this remains true, calling Idl.run() in between to let the IDL do protocol processing. (If the client doesn't have anything else to do in the meantime, it can use Transaction.commit_block() to avoid having to loop itself.) 4. If the final status is Transaction.TRY_AGAIN, wait for Idl.change_seqno to change from the saved 'seqno' (it's possible that it's already changed, in which case the client should not wait at all), then start over from step 1. Only a call to Idl.run() will change the return value of Idl.change_seqno. (Transaction.commit_block() calls Idl.run().)� uncommitted� unchanged� incomplete�aborted�successz try againz not lockedr c C s | S )z�Converts one of the status values that Transaction.commit() can return into a human-readable string. (The status values are in fact such strings already, so there's nothing to do.)r )�statusr r r �status_to_string s z Transaction.status_to_stringc C s\ |j du sJ �| |_ d| _|| _d| _i | _tj| _d| _g | _ d| _ d| _ g | _ i | _ dS )a[ Starts a new transaction on 'idl' (an instance of ovs.db.idl.Idl). A given Idl may only have a single active transaction at a time. A Transaction may modify the contents of a database by assigning new values to columns (attributes of Row), deleting rows (with Row.delete()), or inserting rows (with Transaction.insert()). It may also check that columns in the database have not changed with Row.verify(). When a transaction is complete (which must be before the next call to Idl.run()), call Transaction.commit() or Transaction.abort().NF)r� r� r �dry_runr� r� � UNCOMMITTEDr� �_error� _comments�_inc_row� _inc_column�_fetch_requests�_inserted_rows)r r r r r r � s zTransaction.__init__c C s | j �|� dS )a Appends 'comment' to the comments that will be passed to the OVSDB server when this transaction is committed. (The comment will be committed to the OVSDB log, which "ovsdb-tool show-log" can print in a relatively human-readable form.)N)r� r� )r �commentr r r � add_comment� s zTransaction.add_commentc C s" | j tjtjfvr|�� dS dS )zTCauses poll_block() to wake up if this transaction has completed committing.N)r� r� r� � INCOMPLETEr r r r r r � s � �zTransaction.waitc s� t |ttf�rBt|�dkr9|d dkr9tj�|d �r9tj�|d �}� j� |d �}|r7|j d u r7dt |�gS |S � fdd�|D �S |S )Nr r r� r z named-uuidc s g | ]}� � |��qS r )�_substitute_uuids)r) �elemr' r r r9 � s z1Transaction._substitute_uuids.<locals>.<listcomp>) r^ rl r, r� r rA rB rC r� r r} r� )r �jsonr� r r r' r r� � s � �z Transaction._substitute_uuidsc C s� d | j _| j�� D ]3}|jd u r"i |jd< i |jd< ||jj|j< n |j d u r-|jj|j= i |jd< i |jd< i |jd< q i | _d S )Nr� r� r� ) r r� r� r- r� r� r rc r� r} )r r r r r � __disassemble� s zTransaction.__disassemblec C s� | | j jkr | jS | j jtjkrtj| _| �� | jS | j j r.| j j s.tj | _| �� | jS | j j j g}| j j rB|�d| j j d�� | j�� D ]0}|jrwi }g }|jD ]}|�|� |j| �� ||< qS|�d|jj dt|j�d||gd�� qGd}| j�� D �]�}|jdu r�|jjr�|�d |jj t|j�d �� d }n| nz|j�rd |jj i}|jdu r�d |d< t|j�|d< d }t|�d }t|�| j |j< n d|d< t|j�|d< i } | |d< |j� � D ]*\}} |jdus�| � � �s | � | �� �| |< |�s |jdu�r |j| | k�r d }q�|jdu �s| �r|�|� |j �r2d} d |jj i}d|d< |jdu �r9| � t|j��|d< nt|j�|d< g |d< d|j �!� v �r�|j d � � D ]_\} } |jj"| }|j#�$� �rndg}|�t%| �� n5dg}g }| D ](}z t&j'�(|j#|t)�} W n t*j+�y� Y dS w |�| � | �� �� �qu|�|� | d |g}|d �|� d } �qSd|j �!� v �r(|j d � � D ]e\} }|jj"| }|j#�$� �r�t&j'�(|j#|t)�} | � | �� �}n5dg}g }|D ](}z t&j'�(|j#|t)�} W n t*j+�y Y dS w |�| � | �� �� �q�|�|� | d |g}|d �|� d } �q�| �r2|�|� d }q| j,�ra| j,D ]$}t|�d |d< |�d|d jj | � t|d j��|d gd �� �q:d }| j-�r�|�r�t|�d | _.|�d| j-jj | � t| j-j��| j/d dggd �� |�d| j-jj | � t| j-j��| j/gd �� | j0�r�|�d d �1| j0�d!�� | j2�r�|�dd"i� |�s�tj3| _n$t4j5j6�7d#|�}|j8| _9| j j:�;|��s�| | j j<| j9< tj=| _ntj| _| �� | jS )$a� Attempts to commit 'txn'. Returns the status of the commit operation, one of the following constants: Transaction.INCOMPLETE: The transaction is in progress, but not yet complete. The caller should call again later, after calling Idl.run() to let the IDL do OVSDB protocol processing. Transaction.UNCHANGED: The transaction is complete. (It didn't actually change the database, so the IDL didn't send any request to the database server.) Transaction.ABORTED: The caller previously called Transaction.abort(). Transaction.SUCCESS: The transaction was successful. The update made by the transaction (and possibly other changes made by other database clients) should already be visible in the IDL. Transaction.TRY_AGAIN: The transaction failed for some transient reason, e.g. because a "verify" operation reported an inconsistency or due to a network problem. The caller should wait for a change to the database, then compose a new transaction, and commit the new transaction. Use Idl.change_seqno to wait for a change in the database. It is important to use its value *before* the initial call to Transaction.commit() as the baseline for this purpose, because the change that one should wait for can happen after the initial call but before the call that returns Transaction.TRY_AGAIN, and using some other baseline value in that situation could cause an indefinite wait if the database rarely changes. Transaction.NOT_LOCKED: The transaction failed because the IDL has been configured to require a database lock (with Idl.set_lock()) but didn't get it yet or has already lost it. Committing a transaction rolls back all of the changes that it made to the IDL's copy of the database. If the transaction commits successfully, then the database server will send an update and, thus, the IDL will be updated with the committed changes.�assert)rb r# r r r� )rb r �timeoutr �untilr rc FNr )rb r r Tr rS rb z uuid-namer r r r �mutate� mutationsr� r� r� rn �selectr� )rb r r r z+=)rb r r r� r� � )rb r� �abort�transact)>r r� r� r� ry r� r� r� �_Transaction__disassembler� r� � NOT_LOCKEDr� rn r� r� r- r� r} ru r r� r� r� �is_rootr� r� r� r� re � is_defaultr� r� r& r r" rx rl r r r� r� r r� r� r� � _inc_indexr� r� r� r� � UNCHANGEDr r� r� r� r� r� r� r r� r� )r � operationsr rc r r� � any_updatesrb r� r� r� �addopr� �datr$ �opdat� inner_opdat�ele�mutationr� r� r� r r r �commit� sP 5 � �� � �� � � � � � � � � � � � � � �� � zTransaction.commitc C sL | � � }|tjkr |S | j�� tj�� }| j�|� | �|� |� � q)aI Attempts to commit this transaction, blocking until the commit either succeeds or fails. Returns the final commit status, which may be any Transaction.* value other than Transaction.INCOMPLETE. This function calls Idl.run() on this transaction'ss IDL, so it may cause Idl.change_seqno to change.) r r� r� r r� r r �Pollerr �block)r r� r r r r � commit_block� s �zTransaction.commit_blockc C s | j tjksJ �| jS )z�Returns the final (incremented) value of the column in this transaction that was set to be incremented by Row.increment. This transaction must have committed successfully.)r� r� �SUCCESS�_inc_new_valuer' r r r �get_increment_new_value� s z#Transaction.get_increment_new_valuec C s* | � � | jtjtjfv rtj| _dS dS )z�Aborts this transaction. If Transaction.commit() has already been called then the transaction might get committed anyhow.N)r r� r� r� r� �ABORTEDr' r r r r � s � �zTransaction.abortc C s( | j tjkr t�| j �S | jr| jS dS )zjReturns a string representing this transaction's current status, suitable for use in log messages.zno error details available)r� r� �ERRORr� r� r' r r r � get_error� s zTransaction.get_errorc C s | j d u rtj�|�| _ d S d S r )r� r r� � to_string)r r� r r r �__set_error_json� s �z Transaction.__set_error_jsonc C s0 | j tjtjfv s J �| j�|�}|r|jS dS )aX Finds and returns the permanent UUID that the database assigned to a newly inserted row, given the UUID that Transaction.insert() assigned locally to that row. Returns None if 'uuid' is not a UUID assigned by Transaction.insert() or if it was assigned by that function and then deleted by Row.delete() within the same transaction. (Rows that are inserted and then deleted within a single transaction are never sent to the database server, so it never assigns them a permanent UUID.) This transaction must have completed successfully.N)r� r� r r r� r r� )r r� � inserted_rowr r r �get_insert_uuid� s � zTransaction.get_insert_uuidc C s | j rJ �|| _ || _d S r )r� r� )r r r$ r r r r� s zTransaction._incrementc C s | j �||d�� d S )N)r r� )r� r� )r r r� r r r r� r. zTransaction._fetchc C s� |j d usJ �|jd usJ �|jj}|js4|jd ur4|j�|j�|kr4|j �|j�}|d u s2||kr4d S ||j|j < d|jv rI|jd � |jd � d|jv rX|jd � |jd � |� � |j |j< d S )Nr� r� ) r� r� r� r� rw r} r rn r� r� r� r~ )r r r$ r� r� � new_valuer r r r� s zTransaction._writeNc C sL | j tjksJ �|du rt�� }t| j||d�}||j|j< || j|j< |S )a3 Inserts and returns a new row in 'table', which must be one of the ovs.db.schema.TableSchema objects in the Idl's 'tables' dict. The new row is assigned a provisional UUID. If 'uuid' is None then one is randomly generated; otherwise 'uuid' should specify a randomly generated uuid.UUID not otherwise in use. ovsdb-server will assign a different UUID when 'txn' is committed, but the IDL will replace any uses of the provisional UUID in the data to be to be committed by the UUID assigned by ovsdb-server.N) r� r� r� r� �uuid4r^ r rc r� )r r �new_uuidr r r r rS , s zTransaction.insertc C sp |j tjjjkrtj| _d S t|j t t f�s t � d� d S d}d}d}|j }|D ]>}|d u r1d}q(t|t�rZ|�d�}|d urY|dkrFd}q(|dkrMd}q(|dkrRq(d}| �|� q(d}| �|� t � d� q(|s�|s�|s�| jrw| �|�swd}| jr�| �|�r�| j jd 7 _nd}| j�� D ] }| �||�s�d}q�|r�tj| _d S |r�tj| _d S |r�tj| _d S tj | _d S ) Nz%reply to "transact" is not JSON arrayFTr z timed outz not ownerr� z*operation reply is not JSON null or objectr ) r" r r� r� r� r� r r� r^ r� rl r, r� rW r) r � _Transaction__set_error_jsonr� � _Transaction__process_inc_replyr� �!_Transaction__process_fetch_replyr r� r� r- �"_Transaction__process_insert_replyr r� r ) r r� � hard_errors� soft_errors� lock_errors�opsrb r rS r r r r� > sX � � zTransaction._process_replyc C sB | s t �d| � dS t| t|��s t �d|t| �f � dS dS )Nz %s is missingFz%s has unexpected type %sT)r� rW r^ r, r" )r� rs rn r r r �__check_json_typex s z Transaction.__check_json_typec C s� d}| j D ]]}|d }|d }|d }|j}|| }|�d�} t�| ttfd�s+ dS t| �dkr;t� dt| � � q| d } t�| t fd �sHq|j �|�} | �|�} t j �| j| �} | |j|< d }q|S ) NFr r� rn rc �"select" reply "rows"r �2"select" reply "rows" has %d elements instead of 1r �"select" reply rowT)r� r r r� � _Transaction__check_json_typerl r, r� r� rW r) r r r ra r" r} )r r) r � fetch_requestr r� rn r r� � fetched_rows� fetched_rowr$ r� r� r r r �__process_fetch_reply� s8 � � � z!Transaction.__process_fetch_replyc C s | j d t|�krt�dt|�| j d f � || j }|�d�}t�|tfd�s+dS |dkr8t�d| � dS || j d }|�d�}t�|tt fd �sOdS t|�dkr`t�d t|� � dS |d }t�|t fd �sndS |�| j �}t�|tfd �s~dS || _ dS )Nr zIreply does not contain enough operations for increment (has %d, needs %d)�countz"mutate" reply "count"Fr z)"mutate" reply "count" is %d instead of 1rc r+ r, r r- z"select" reply inc columnT) r r� r� rW r r� r. r� rl r, r) r� r )r r) r� r3 r� rc r r$ r r r �__process_inc_reply� sH � � � � � �z Transaction.__process_inc_replyc C s� |j t|�krt�dt|�|j f � dS ||j }|�d�}t�|ttfd�s*dS zt j � |�}W n t j yB t�d� Y dS w ||_dS )NzFreply does not contain enough operations for insert (has %d, needs %d)Fr� z"insert" reply "uuid"z("insert" reply "uuid" is not a JSON UUIDT)r� r� r� rW r r� r. r, rl r rA ra r r� r� )r rS r) �reply� json_uuid�uuid_r r r �__process_insert_reply� s& � � �z"Transaction.__process_insert_replyr )#r2 r3 r4 r5 r� r r� r r r� r r rX r� r r� r r� r r r r r r r" r r� r� r� rS r� r. r$ r# r% r r r r r� = sF . q : (r� c @ sF e Zd ZdZddd�Zg fdd�Zdd� Zd d � Zd d � Zd d� Z dS )r� a� IDL Schema helper. This class encapsulates the logic required to generate schemas suitable for creating 'ovs.db.idl.Idl' objects. Clients should register columns they are interested in using register_columns(). When finished, the get_idl_schema() function may be called. The location on disk of the schema used may be found in the 'schema_location' variable.Nc C sT |r|rt d��|du r |du rdtjj }tj�|�}|| _i | _i | _d| _ dS )z�Creates a new Schema object. 'location' file path to ovs schema. None means default location 'schema_json' schema in json preresentation in memory zAboth location and schema_json can't be specified. it's ambiguous.Nz%s/vswitch.ovsschemaF) � ValueErrorr �dirs� PKGDATADIRr� � from_file� schema_json�_tables� _readonly�_all)r �locationr= r r r r � s zSchemaHelper.__init__c C sL t |t�sJ �t |t�sJ �t|�| j�|t� �B }|| j|< || j|< dS )a, Registers interest in the given 'columns' of 'table'. Future calls to get_idl_schema() will include 'table':column for each column in 'columns'. This function automatically avoids adding duplicate entries to the schema. A subset of 'columns' can be specified as 'readonly'. The readonly columns are not replicated but can be fetched on-demand by the user with Row.fetch(). 'table' must be a string. 'columns' must be a list of strings. 'readonly' must be a list of strings. N)r^ r� rl r� r> r r? )r r r r� r r r �register_columns s z SchemaHelper.register_columnsc C s t |t�sJ �t� | j|< dS )z�Registers interest in the given all columns of 'table'. Future calls to get_idl_schema() will include all columns of 'table'. 'table' must be a string N)r^ r� r� r> r r r r r� s zSchemaHelper.register_tablec C s d| _ dS )z2Registers interest in every column of every table.TN)r@ r' r r r � register_all% rP zSchemaHelper.register_allc C sZ t jjj�| j�}d| _| js'i }| j�� D ] \}}| � |||�||< q||_ | j |_ |S )z�Gets a schema appropriate for the creation of an 'ovs.db.id.IDL' object based on columns registered using the register_columns() function.N) r r r_ �DbSchemara r= r@ r> re �_keep_table_columnsrq r? r� )r r_ rr r r r r r r� ) s �zSchemaHelper.get_idl_schemac C sb ||j v sJ �|j | }|s|S i }|D ]}t|t�s J �||jv s$J �|j| ||< q||_|S r )rq r^ r� r )r r_ r r r � new_columnsr� r r r rE ; s z SchemaHelper._keep_table_columns)NN) r2 r3 r4 r5 r rB r� rC r� rE r r r r r� � s r� )1� collections�enum� functoolsr� � ovs.db.datar r � ovs.db.parserr � ovs.db.schema� ovs.jsonrpc� ovs.ovsuuid� ovs.poller�ovs.vlog�ovs.dbr r r� �Vlog� __pychecker__r[ r] rV r9 r; r= rk ro � namedtupler �__new__� __defaults__r) r �IntEnumr8 �objectr? rY rZ ry r� �total_orderingr^ r� r� r� r� r� r r r r �<module> sl 9 e 0