JezK
Edit File: iproute.cpython-311.pyc
� ��f� � � � d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlm Z ddl mZmZm Z G d� de� � Zej j d� � � Z G d � d ee� � ZdS )� N)�RTNL_API)�MarshalRtnl� )�RemoteSocket�Server� Transportc �D � e Zd Zd� Zd� Zd� Zd� Zd� Zd� Zd� Z d� Z d � Zd S )�Channelc � � || _ t j � � \ | _ | _ d | _ d| _ t j � � | _ t j � � | _ | j | _ d| _ d S )NF� )�ch�os�pipe�_pfdr�_pfdw�th�closed� threading�RLock�lock� shutdown_lock� _read_sync�read�buf)�selfr s �J/opt/alt/python311/lib/python3.11/site-packages/pyroute2/remote/iproute.py�__init__zChannel.__init__ s^ � ����!#������ �D�J��������O�%�%�� �&�_�.�.����O�� ������ c � � d S �N� �r s r �flushz Channel.flush s � ��r c �b � | j 5 | j r1| j d |� }| j |d � | _ |cd d d � � S | j � � � � � � }t |� � |k r||d � | _ |d |� cd d d � � S # 1 swxY w Y d S r )r r r �get�unpickle�len)r �size�rets r r zChannel._read_sync s � � �Y� � ��x� ��h�u��u�o���8�D�E�E�?���� � � � � � � � � �'�+�+�-�-�(�(�*�*�C��3�x�x�$����t�u�u�:����u��u�:� � � � � � � � � � � � ���� � � � � � s �,B$�AB$�$B(�+B(c �x � | j 5 t j | j |� � cd d d � � S # 1 swxY w Y d S r )r r r r )r r( s r �_read_asynczChannel._read_async'