Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/__pycache__/source.cpython-39.pyc
Ðазад
a ]�h?B � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlmZ ddlmZ ddlmZ ddlmZ d d lmZmZ d d lmZmZm Z ej � d �r�dd l m Z ddl!m"Z" ddl#m$Z$ ndZ$dZ"d Z%dZ&G dd� de'�Z(G dd� de)�Z*dS )aa Local RTNL ---------- Local RTNL source is a simple `IPRoute` instance. By default NDB starts with one local RTNL source names `localhost`:: >>> ndb = NDB() >>> ndb.sources.summary().format("json") [ { "name": "localhost", "spec": "{'target': 'localhost', 'nlm_generator': 1}", "state": "running" }, { "name": "localhost/nsmanager", "spec": "{'target': 'localhost/nsmanager'}", "state": "running" } ] >>> ndb.sources['localhost'] [running] <IPRoute {'target: 'localhost', 'nlm_generator': 1}> The `localhost` RTNL source starts an additional async cache thread. The `nlm_generator` option means that instead of collections the `IPRoute` object returns generators, so `IPRoute` responses will not consume memory regardless of the RTNL objects number:: >>> ndb.sources['localhost'].nl.link('dump') <generator object RTNL_API.filter_messages at 0x7f61a99a34a0> See also: :ref:`iproute` Network namespaces ------------------ There are two ways to connect additional sources to an NDB instance. One is to specify sources when creating an NDB object:: ndb = NDB(sources=[{'target': 'localhost'}, {'netns': 'test01'}]) Another way is to call `ndb.sources.add()` method:: ndb.sources.add(netns='test01') This syntax: `{target': 'localhost'}` and `{'netns': 'test01'}` is the short form. The full form would be:: {'target': 'localhost', # the label for the DB 'kind': 'local', # use IPRoute class to start the source 'nlm_generator': 1} # {'target': 'test01', # the label 'kind': 'netns', # use NetNS class 'netns': 'test01'} # See also: :ref:`netns` Remote systems -------------- It is possible also to connect to remote systems using SSH. In order to use this kind of sources it is required to install the `mitogen <https://github.com/dw/mitogen>`_ module. The `remote` kind of sources uses the `RemoteIPRoute` class. The short form:: ndb.sources.add(hostname='worker1.example.com') In some more extended form:: ndb.sources.add(**{'target': 'worker1.example.com', 'kind': 'remote', 'hostname': 'worker1.example.com', 'username': 'jenkins', 'check_host_keys': False}) See also: :ref:`remote` � N)� basestring)�IPRoute)� NetlinkError)�NetlinkSocketBase)�ifinfmsg)� RemoteIPRoute� )�ShutdownException�State)� cmsg_event� cmsg_failed� cmsg_sstart�linux)�netns)� NetNSManager)�NetNS� c @ s e Zd Zdd� Zdd� ZdS )� SourceProxyc C s || _ t�� | _|| _d S �N)�ndb�queue�Queue�events�target)�selfr r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/source.py�__init__t s zSourceProxy.__init__c O s� t t�� j�}t�� | jj|< }|�� | jj � d| j ||||d�� |� � | jj� |�}d|v rn|d S d|v r~|d �d S )N�api)�typer �call_id�name�argv�kwarg�return� exception)�str�uuid�uuid4�hex� threading�Eventr Z_call_registry�clear� messenger�emitr �wait�pop)r r! r" r# r �event�responser r r r y s& ��� zSourceProxy.apiN)�__name__� __module__� __qualname__r r r r r r r s s r c @ s e Zd ZdZdZdZdZdZdZe e e e d�Z dd� Zedd � �Zed d � �Zed d � �Zdd� Zedd� �Zdd� Zedd� �Zedd� �Zedd� �Zedd� �Zed d � �Zd d � Z d d!� Z d"d#� Z d$d%� Z d&d'� Z d(d)� Z!e"j#d*fd+d,�Z$d6d.d/�Z%d0d1� Z&d2d3� Z'd4d5� Z(dS )7�Sourcez� The RNTL source. The source that is used to init the object must comply to IPRoute API, must support the async_cache. If the source starts additional threads, they must be joined in the source.close() �srcN�sources)�localr �remote� nsmanagerc K s d | _ d | _|| _| jj| _|d | _|�dd�| _|�dt�| _ |�d�| _ | � | j�| _ || _ | jjd ur�| jjj�| j� d| _t�� | _t�� | _t�� | _t�� | _| j�� |j�d| j �| _t | jdgd �| _ | j � d � | jj � | j| j|� | �!� d S ) Nr �kindr9 � max_errorsr1 r z sources.%s�running)�logZ wait_list�init)"�th�nlr Z _event_queue�evqr r0 r< �SOURCE_MAX_ERRORSr= r1 � get_prime�nl_prime�nl_kwargr- �targets�add�errors_counterr* r+ �shutdown�started�RLock�lock� shutdown_lockr, r? Zchannelr �state�set� task_managerZdb_add_nl_source�load_sql)r r �specr r r r � s. zSource.__init__c C s |j j�d|j �S )NzSELECT count(*) FROM %s)r rR � db_fetchone�table��cls�viewr r r �_count� s �z Source._countc C s | j dk s| j| j krdS dS )Nr TF)r= rJ �r r r r � must_restart� s zSource.must_restartc C s$ t tdd� ddd| j�d�ff��S )Nc S s | d d uS )Nr r )�xr r r �<lambda>� � z'Source.bind_arguments.<locals>.<lambda>)Z async_cacheT)Z clone_socketT�groups)�dict�filterrG �getr[ r r r �bind_arguments� s ���zSource.bind_argumentsc C sn zH| j d ur,| jjt| j| j �f| jd� n| jjt| j�f| jd� W n tyh | j�d� Y dS 0 dS )N��source�stopFT) r1 rC �putr r r r rP rQ r[ r r r � set_ready� s � zSource.set_readyc C s� t |�}i }d|v r0d|d< d|d< |d |d< d|v r^d|d< |d |d< t�|d �|d< |D ]}||vrb|| ||< qb|S )N�hostnamer: r< �ssh�protocolr r )ra r Z_get_netnspath)rX rT �ret�defaults�keyr r r rn � s zSource.defaultsc C sB t | jt�r| jjj}nt | jt�r,| jj}d| j�� || jf S )Nz [%s] <%s %s>) � isinstancerF r � __class__r3 r rP rc rG �r r! r r r �__repr__� s zSource.__repr__c C s |S r r �rX r! r r r �nla2name s zSource.nla2namec C s |S r r rt r r r �name2nla s zSource.name2nlac c s: dV |� � D ]&}|| j�� |d|| jf fV qd S )N)rP r! rT z%s)�keysrP rc rG )rX rY ro r r r �summary s zSource.summaryc C s | � |�S r )rx rW r r r �dump s z Source.dumpc C s t |t�r||d kS d S )Nr! )rp r )r �left�rightr r r �compare_record s zSource.compare_recordc C s" | j �| jd �p tt�d�| j�S )N�pyroute2)�vmaprc r< �getattr� importlib� import_modulerr r r r rE s �zSource.get_primec O s� t d�D ]�}| j�� zH| j�d|� d|� d|� �� t| j|�|i |��W W d � S tttt t t j t j fy� � Y nP ty� } z8| jd7 _| j�d|� d�� t�d� W Y d }~n d }~0 0 W d � q1 s�0 Y qtd��d S )N�d zsource api run � r zsource api error: <�>zapi call failed)�rangerN r? �debugr rB r �AttributeError� ValueError�KeyError� TypeError�socket�error�struct� ExceptionrJ �time�sleep� RuntimeError)r r! r" r# �_�er r r r s( *� @z Source.apic C s� d}t � }d|d< d|d< d|d< d|d d< d |d d < | j|d d < d |d< d|fdg|d< |�� | jj|g| jd� d S )Nz.https://github.com/svinota/pyroute2/issues/737r �index�uprP r �flags� �header� r r Z RTM_NEWLINKr1 Z IFLA_IFNAME)Z IFLA_ADDRESSz00:00:00:00:00:00�attrsre )r r �encoderC rh )r �urlZzero_ifr r r � fake_zero_if6 s �zSource.fake_zero_ifc C s� | j �� dk�r~| j�� r �q~| j��� | jd urzz| jjdd� W n4 tyx } z | j� d| � W Y d }~n d }~0 0 z�| j � d� t | j t �r�i }|�| j� | jdv r�| jj|d< | j f i |��| _ntd��| j � d � | jjf i | j�� z@| jj�| j� | jd v �r | �� | jj| j� � | jd � W n0 d| _ W �nr t�y� } �zV| j d 7 _ | j � � | j � d | j � �� | j� dt |�� d|� �� z | jjt | j�f| jd � W n< t!�y� | j � d� Y W Y d }~W d � �q~Y n0 | j"�rh| j�#d� | j � d� | j�$t%� | j�� �r�| j�#d� | j � d� W Y d }~W d � �q~n"| �&� W Y d }~W d � S W Y d }~W d � q W Y d }~n d }~0 0 W d � n1 �s�0 Y | j�Z | j �� d k�r*| �&� �s W d � �q~| j � � | j�'� | j � d� W d � n1 �s@0 Y | j �� dvr zt(| j�� �}W n~ t�y� } zd| j d 7 _ | j� dt |�|f � d }| j"�r�| j � d� n | j � d� W Y d }~q W Y d }~n d }~0 0 d}|�r|d d d �r|d d d j)}|d u �s.|t*j+k�r<| j � d� q z| jj|| jd � W n$ t!�yv | j � d� Y q Y n0 �qJq z(| �,� | j�#d� | jj�| j� W n t!�y� | j�#d� Y n0 | j � d� d S )Nrg r ��codezsource restart: %sZ connecting)r; �libcz source channel not supportedZloading)r9 r r: re r zfailed, counter zsource error: r� zsleeping before restart�restart�source shutdownr> )rg r� zsource error: %s %sr� r� zflush DB for the targetz#shutdown handled by the main thread�stopped)-rP rc rK �is_setrN rB �closer� r? �warningrQ rp rF r �updaterG r< r r� r� �bindrd rR Zdb_flushr r� rC rh ry rJ rL r� r r r\ r� r/ �SOURCE_FAIL_PAUSEri r, �tupler� �errno� ECONNRESET�sync)r r� rT �msgr� r r r �receiverG s� & � " "N , " zSource.receiverc C s< | j �d� t�� }| jjt| j|�f| jd� |�� d S )Nr� re ) r? r� r* r+ rC rh r r r/ )r r� r r r r� � s z Source.syncc C sx | j �^ | j�d� | jd ur0| j�� r0td��tj| jd| j d�| _| j� � | W d � S 1 sj0 Y d S )Nzstarting the sourcezsource is runningzNDB event source: %s)r r! ) rN r? r� rA �is_aliver� r* �Threadr� r �startr[ r r r r� � s � z Source.startTc C s� | j �� | j�� r.| j�d� W d � d S | j�d� | j�� | jd ur�z| jj|d� W n4 ty� } z | j� d| � W Y d }~n d }~0 0 W d � n1 s�0 Y |r�| j d ur�| j � � d | _ n | j�d� d S )Nzalready stoppedr� r� zsource close: %szreceiver thread missing) rO rK r� r? r� rQ rB r� r� r� rA �join)r r� r� r� r r r r� � s D z Source.close�unknownc C s� | j �� | j�\ | j�d| � | j�� z.| �� | jrD| j�� | j �� | � � W n0 W d � n1 sp0 Y W d � n1 s�0 Y | j� � d S )Nz"restarting the source, reason <%s>) rN rO r? r� rL r, r� rA r� rK r� r/ )r �reasonr r r r� � s @zSource.restartc C s | S r r r[ r r r � __enter__� s zSource.__enter__c C s | � � d S r )r� )r �exc_type� exc_value� tracebackr r r �__exit__� s zSource.__exit__c C sz | j j�d| j jj | jf�}|\| d< | d< | j j�d| j jj | jf�D ](}|\}}}}|dkrlt|�n|| |< qLd S )Nz� SELECT * FROM sources WHERE f_target = %s r r< z� SELECT * FROM sources_options WHERE f_target = %s �int)r rR rU ZschemaZplchr Zdb_fetchr� )r rT Zf_target�f_nameZf_typeZf_valuer r r rS � s ���� zSource.load_sql)r� ))r3 r4 r5 �__doc__Z table_aliasZ dump_headerZsummary_headerrY rV r r r r r~ r � classmethodrZ �propertyr\ rd ri rn rs ru rv rx ry r| rE r r� r� r� r� r� r� r� r� r� r� rS r r r r r6 � sV � p r6 )+r� r� r� r r� r� �sysr* r� r' Zpyroute2.commonr Zpyroute2.iprouter Zpyroute2.netlink.exceptionsr Zpyroute2.netlink.nlsocketr Z pyroute2.netlink.rtnl.ifinfmsgr Zpyroute2.remoter r r r �messagesr r r �platform� startswithr} r Zpyroute2.netns.managerr Zpyroute2.nslink.nslinkr r� rD �objectr ra r6 r r r r �<module> s6 R
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка