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
/
__pycache__
/
Edit File:
poller.cpython-310.pyc
o ��e*( � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZejdkr'd dl m Z zd dl Z W n e y8 dZ Y nw z d dl mZ dd� ZW n dZdd� ZY zd dlmZ W n dZY ej�d�Zd Zd Zd Zd Zd ZG dd� de�Z e Z G dd� de�Z dd� Z dS )� N�win32)�patcherc C s t �t�S �N)�eventlet_patcher�is_monkey_patched�select� r r �,/usr/lib/python3/dist-packages/ovs/poller.py� _using_eventlet_green_select$ s r c C s dS )NFr r r r r r ) s )�monkey�poller� � � � � c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � _SelectSelectzh select.poll emulation by using select.select. Only register and poll are needed at the moment. c C s g | _ g | _g | _d S r )�rlist�wlist�xlist��selfr r r �__init__D s z_SelectSelect.__init__c C s� t |tj�r |�� }trt |tj�r|�� }tjdkr"t |t�s"J �|t@ r1| j � |� |t M }|t @ r@| j � |� |t M }|rJ| j � |� d S d S )Nr )� isinstance�socket�fileno�ssl� SSLSocket�sys�platform�int�POLLINr �append�POLLOUTr r �r �fd�eventsr r r �registerI s �z_SelectSelect.registerc C s� |dkr t � r d}tjdkrr| j| j | j }|sg S t|�tjj kr't d��|dkr.d}nt |�}z tj� |d|�}W n tj jyL dtfg Y S w |tjjkrUg S || | jv r_t}n || | jv rit}nt}|| |fgS |dkryd }nt|�d }t�| j| j| j|�\}}}i }|D ] } |�| d�tB || < q�|D ] } |�| d�tB || < q�|D ]} |�| d�ttB tB B || < q�t|�� �S ) Nr g�������?r z,Cannot handle more than maximum waitobjects �d F���i� )r r r r r r �len�winutils� win32event�MAXIMUM_WAIT_OBJECTS� WindowsErrorr �WaitForMultipleObjects� pywintypes�error�POLLERR�winerror� WAIT_TIMEOUTr! r# �floatr �get�POLLHUP�POLLNVAL�list�items) r �timeoutr& �retval�reventr r r � events_dictr% r r r �poll[ s` �� � � � z_SelectSelect.pollN)�__name__� __module__� __qualname__�__doc__r r' r? r r r r r @ s r c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dS )�Pollera= High-level wrapper around the "poll" system call. Intended usage is for the program's main loop to go about its business servicing whatever events it needs to. Then, when it runs out of immediate tasks, it calls each subordinate module or object's "wait" function, which in turn calls one (or more) of the functions Poller.fd_wait(), Poller.immediate_wake(), and Poller.timer_wait() to register to be awakened when the appropriate event occurs. Then the main loop calls Poller.block(), which blocks until one of the registered events happens.c C s | � � d S r )�_Poller__resetr r r r r � s zPoller.__init__c C s | j �||� dS )aW Registers 'fd' as waiting for the specified 'events' (which should be select.POLLIN or select.POLLOUT or their bitwise-OR). The following call to self.block() will wake up when 'fd' becomes ready for one or more of the requested events. The event registration is one-shot: only the following call to self.block() is affected. The event will need to be re-registered after self.block() is called if it is to persist. 'fd' may be an integer file descriptor or an object with a fileno() method that returns an integer file descriptor.N)r? r' r$ r r r �fd_wait� s zPoller.fd_waitc C s" | j dk s || j k r|| _ d S d S )Nr �r; �r �msecr r r � __timer_wait� s �zPoller.__timer_waitc C s" |dkr | � � dS | �|� dS )a� Causes the following call to self.block() to block for no more than 'msec' milliseconds. If 'msec' is nonpositive, the following call to self.block() will not block at all. The timer registration is one-shot: only the following call to self.block() is affected. The timer will need to be re-registered after self.block() is called if it is to persist.r N)�immediate_wake�_Poller__timer_waitrH r r r � timer_wait� s zPoller.timer_waitc C s0 t j�� }||kr| �� dS | �|| � dS )a� Causes the following call to self.block() to wake up when the current time, as returned by ovs.timeval.msec(), reaches 'msec' or later. If 'msec' is earlier than the current time, the following call to self.block() will not block at all. The timer registration is one-shot: only the following call to self.block() is affected. The timer will need to be re-registered after self.block() is called if it is to persist.N)�ovs�timevalrI rK rL )r rI �nowr r r �timer_wait_until� s zPoller.timer_wait_untilc C s d| _ dS )z[Causes the following call to self.block() to wake up immediately, without blocking.r NrG r r r r rK � s zPoller.immediate_wakec C s� zlz| j � | j�}| �|� W nH ty3 } z |jtjkr)t�dt� |j� � W Y d}~n0d}~w t j yW } z|\}}|tjkrMt�d|d � W Y d}~nd}~ww W | � � dS W | � � dS W | � � dS | � � w )z�Blocks until one or more of the events registered with self.fd_wait() occurs, or until the minimum duration registered with self.timer_wait() elapses, or not at all if self.immediate_wake() has been called.zpoll: %sNr ) r? r; �_Poller__log_wakeup�OSError�errno�EINTR�vlog�err�os�strerrorr r1 rE )r r& �er1 �msgr r r �block� s* � ��� � � z Poller.blockc C s� |s t �d| j � d S |D ];\}}|dkrId}|t@ r |d7 }|t@ r(|d7 }|t@ r0|d7 }|t@ r8|d7 }|t@ r@|d7 }t �d ||f � qd S ) Nz %d-ms timeoutr � z[POLLIN]z [POLLOUT]z [POLLERR]z [POLLHUP]z [POLLNVAL]z %s on fd %d)rV �dbgr; r! r# r2 r7 r8 )r r& r% �revents�sr r r � __log_wakeup� s$ ��zPoller.__log_wakeupc C s t � | _d| _d S )Nr) )� SelectPollr? r; r r r r �__reset s zPoller.__resetN) r@ rA rB rC r rF rL rM rQ rK r\ rR rE r r r r rD � s rD c C s` z&t � rt�d�j} W | � S tr t�dd�r t�dd�} W | � S tj} W | � S t} Y | � S )a[ Returns the original select.poll() object. If select.poll is monkey patched by eventlet or gevent library, it gets the original select.poll and returns an object of it using the eventlet.patcher.original/gevent.monkey.get_original functions. As a last resort, if there is any exception it returns the SelectPoll() object. r r? ) r r �originalr? � gevent_monkey�is_object_patched� get_originalr rb )� _system_pollr r r �get_system_poll s ����ri ) rT rX r r r � ovs.timevalrN �ovs.vlogr � ovs.winutilsr+ r � ImportError�eventletr r r �geventr re rV �Vlogr! r# r2 r7 r8 �objectr rb rD ri r r r r �<module> sD � Y o
Simpan