File: //opt/alt/python37/lib/python3.7/site-packages/pyroute2/netlink/__pycache__/buffer.cpython-37.pyc
B
��f� � @ sJ yd dl mZ W n ek
r( dZY nX G dd� d�ZG dd� d�ZdS )� )�
shared_memoryNc @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �Pagez
Memory page.
c C s || _ || _d| _d S )NT)�view�offset�is_free)�selfr r � r �H/opt/alt/python37/lib/python3.7/site-packages/pyroute2/netlink/buffer.py�__init__ s z
Page.__init__c C s
d| _ d S )NF)r )r r r r �use s zPage.usec C s
d| _ d S )NT)r )r r r r �free s z Page.freec C s | j �� d S )N)r �release)r r r r �close s z
Page.closeN)�__name__�
__module__� __qualname__�__doc__r
r r r r r r r r s
r c @ sB e Zd ZdZddd�Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dS )�Bufferz?
Manage the buffer memory to receive raw netlink data.
�internal� � � � c C s� || _ || _|| _| j dkr0d | _t| j�| _n6| j dkrftd krJtd��tjd| jd�| _| jj| _t | j�| _
i | _ x<t || �D ],}|| }t
| j
||| j � |�| j |< q�W d S )Nr �sharedz"shared memory buffer not supportedT)�create�size)�moder � page_size�mem� bytearray�bufr �ModuleNotFoundErrorZ SharedMemory�
memoryviewr � directory�ranger )r r r r �indexr r r r r
s"
zBuffer.__init__c C s | S )Nr )r r r r � __enter__4 s zBuffer.__enter__c C s | � � d S )N)r )r �exc_type� exc_value� tracebackr r r �__exit__7 s zBuffer.__exit__c C s6 x(| j �� D ]\}}|jr |�� |S q W td��d S )Nz no free memory pages available)r! �itemsr r � MemoryError)r r# �pager r r �
get_free_page: s
zBuffer.get_free_pagec C sH x| j �� D ] }|�� q W | j�� | jdkrD| j�� | j�� d S )Nr )r! �valuesr r r
r r �unlink)r r+ r r r r A s
z Buffer.closec C s
| j | S )N)r! )r �keyr r r � __getitem__I s zBuffer.__getitem__N)r r r )
r r r r r
r$ r( r, r r0 r r r r r s
r )�multiprocessingr � ImportErrorr r r r r r �<module> s