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__
/
View File Name :
stream.cpython-310.pyc
o y.�e�} � @ s. d dl Z d dlZd dlZd dlZd dlZd dlZd dlZzd dlZW n e y- dZY nw ej dkrId dl m Z d dl Z d dlZd dlZd dlZej�d�Zdd� ZG dd� de�ZG dd � d e�Zd d � ZG d d � d e�Ze�de� G dd� de�Ze�de� G dd� de�Zer�e�de� dS dS )� N�win32�streamc C s. t �| �}|r |�� S t�| �rt�| �S dS )a True if the stream or pstream specified by 'name' needs periodic probes to verify connectivity. For [p]streams which need probes, it can take a long time to notice the connection was dropped. Returns False if probes aren't needed, and None if 'name' is invalidN)�Stream� _find_method� needs_probes� PassiveStream� is_valid_name)�name�cls� r �,/usr/lib/python3/dist-packages/ovs/stream.py� stream_or_pstream_needs_probes' s r c @ sh e Zd ZdZdZdZdZdZdZdZ i Z dZ dZ dZ dZdZdZdZdZedd� �Zed d � �Zed d � �Zd@d d�ZdZed? Zedd� �Zeefdd��Zedd� �Z edAdd��Z dd� Z dd� Z d d � Z d d � Z!d d!� Z"d"d#� Z#d$d%� Z$d&d'� Z%d(d)� Z&d*d+� Z'd,d-� Z(d.d/� Z)d0d1� Z*d2d3� Z+d4d5� Z,d6d7� Z-d8d9� Z.ed:d;� �Z/ed<d=� �Z0ed>d?� �Z1dS )Br zQBidirectional byte stream. Unix domain sockets, tcp and ssl are implemented.r � � NFc C s |t j| d < d S )N�:)r �_SOCKET_METHODS)�methodr r r r �register_methodQ � zStream.register_methodc C s* t j�� D ] \}}| �|�r| S qd S �N)r r �items� startswith)r r r r r r r U s �zStream._find_methodc C s t t�| ��S )z�Returns True if 'name' is a stream name in the form "TYPE:ARGS" and TYPE is a supported stream type ("unix:", "tcp:" and "ssl:"), otherwise False.)�boolr r �r r r r r \ s zStream.is_valid_namec C s� || _ || _tjdkrH|d ur@|| _|�dd�d }tj�tj j |�}t � |�| _ t�� | _t �� | j_t�� | _t �� | j_nt jddd�| _|| _|tjkrUtj| _n |dkr^tj| _ntj | _d| _ d S )Nr r r F)� bManualReset� bInitialStater ) �socket�pipe�sys�platform�_server�split�ovs�util� abs_file_name�dirs�RUNDIR�winutils� get_pipe_name� _pipename� pywintypes� OVERLAPPED�_read� get_new_event�hEvent�_write�_weventr �errno�EAGAINr �_Stream__S_CONNECTING�state�_Stream__S_CONNECTED�_Stream__S_DISCONNECTED�error)�selfr r �statusr � is_server�suffixr r r �__init__c s, � zStream.__init__� c C s t j�| �S r )r" � socket_util�check_connection_completion)�sockr r r r? � s z"Stream.check_connection_completionc C s� t �| �}|s tjdfS | �dd�d }| �d�r�tj�tj j |�}t j dkr�t �|�}t|�dkr7tjdfS z t|d��� W n tjdf Y S z!t �|�}z t �|tj� W n tjyj tjdf Y W S w W n5 tjy� } z(|jt jjkr�dt _d |d| tj t j d d �fW Y d}~S tjdfW Y d}~S d}~ww d |d| d |d d �fS |� ||�\}}|r�|dfS |� |�} | tj ks�| tj!kr�tj } d } n | d kr�d } n| } | ||| | �fS ) aq Attempts to connect a stream to a remote peer. 'name' is a connection name in the form "TYPE:ARGS", where TYPE is an active stream class's name and ARGS are stream class-specific. The supported TYPEs include "unix", "tcp", and "ssl". Returns (error, stream): on success 'error' is 0 and 'stream' is the new Stream, on failure 'error' is a positive errno value and 'stream' is None. Never returns errno.EAGAIN or errno.EINPROGRESS. Instead, returns 0 and a new Stream. The connect() method can be used to check for successful connection completion.Nr r zunix:r � �rTr F)r r: )"r r r1 � EAFNOSUPPORTr! r r" r# r$ r% r& r r r' r( �len�ENOENT�open�close� create_file� set_pipe_mode� win32pipe�PIPE_READMODE_BYTEr* r7 �winerror�ERROR_PIPE_BUSY� retry_connectr2 � win32file�INVALID_HANDLE_VALUE�_openr? � EINPROGRESS) r �dscpr r; �pipename�npipe�er7 r@ �errr9 r r r rF � s\ ��� ��� z Stream.openc C s t d��)Nz)This method must be overrided by subclass)�NotImplementedError)r; rS r r r rQ � s z Stream._openc C s� | \}}|skd}|dur|dkrt j�� | } |�� }tjdkr)|tjkr)tj}|tjkr/n0|dur>t j�� |kr>tj }n!|� � t j � � }|� |� |�|� |durZ|�|� |�� q|jdurk|tjkskJ �|ru|ru|�� d}||fS )a� Blocks until a Stream completes its connection attempt, either succeeding or failing, but no more than 'timeout' milliseconds. (error, stream) should be the tuple returned by Stream.open(). Negative value of 'timeout' means infinite waiting. Returns a tuple of the same form. Typical usage: error, stream = Stream.open_block(Stream.open("unix:/tmp/socket"))Nr Tr )r" �timeval�msec�connectr r r1 �WSAEWOULDBLOCKr2 � ETIMEDOUT�run�poller�Poller�run_wait� connect_wait�timer_wait_until�blockr rR rG )� error_stream�timeoutr7 r �deadliner_ r r r � open_block� s8 � zStream.open_blockc C sx | j d ur | j �� | jd ur:| jr t�| j� t�| j� t�| jt j � t�| j j t j � t�| j j t j � d S d S r )r rG r r rJ �FlushFileBuffers�DisconnectNamedPiper' � close_handle�vlog�warnr, r. r/ �r8 r r r rG � s �z Stream.closec C s� | j d ur| �| j �}|tjksJ �n=tjdkrP| jrNzt�| j �| _ d| _ d}W n& t j yM } z|jtjjkr=tj}nd| _ tj}W Y d }~nd }~ww d}|dkrZtj| _d S |tjkrhtj| _|| _ d S d S )Nr Fr )r r? r1 rR r r rN r' rH r) r �_retry_connectr* r7 rL rM r2 rE r r5 r4 r6 �r8 �retvalrV r r r �__scs_connecting s. �� �zStream.__scs_connectingc C sL | j tjkr | �� | j tjkrtjS | j tjkrdS | j tjks#J �| jS )z�Tries to complete the connection on this stream. If the connection is complete, returns 0 if the connection was successful or a positive errno value if it failed. If the connection is still in progress, returns errno.EAGAIN.r ) r4 r r3 �_Stream__scs_connectingr1 r2 r5 r6 r7 rn r r r r[ % s zStream.connectc C sD z| � |�W S tjy! } ztj�|�dfW Y d}~S d}~ww )a Tries to receive up to 'n' bytes from this stream. Returns a (error, string) tuple: - If successful, 'error' is zero and 'string' contains between 1 and 'n' bytes of data. - On error, 'error' is a positive errno value. - If the connection has been closed in the normal fashion or if 'n' is 0, the tuple is (0, ""). The recv function will not block waiting for data to arrive. If no data have been received, it returns (errno.EAGAIN, "") immediately.� N)�_recvr r7 r" r> �get_exception_errno�r8 �nrV r r r �recv6 s ��z Stream.recvc C sR | � � }|dkr |dfS |dkrdS tjdkr!| jd u r!| �|�S d| j�|�fS )Nr rt �r rt r )r[ r r r �_Stream__recv_windowsry )r8 rx rq r r r ru J s z Stream._recvc C sr | j rLzt�| j| jd�}d| _ W n� tjyK } z-|jtjjkr/d| _ t j dfW Y d }~S |jtj v r<W Y d }~dS t j dfW Y d }~S d }~ww t� | j|| j�\}| _|rs|tjjkrhd| _ t j dfS |tj v rodS |dfS zt�| j| jd�}tj�| jj� W n% tjy� } z|jtj v r�W Y d }~dS |jdfW Y d }~S d }~ww | jd |� }dt|�fS )NFTrt rz r )� _read_pendingr' �get_overlapped_resultr r, r* r7 rL �ERROR_IO_INCOMPLETEr1 r2 �pipe_disconnected_errors�EINVAL� read_file� _read_buffer�ERROR_IO_PENDING� win32event�SetEventr. �bytes)r8 rx � nBytesReadrV �errCode� recvBufferr r r �__recv_windowsV sR � �� � � �� zStream.__recv_windowsc C sB z| � |�W S tjy } z tj�|� W Y d}~S d}~ww )aa Tries to send 'buf' on this stream. If successful, returns the number of bytes sent, between 1 and len(buf). 0 is only a valid return value if len(buf) is 0. On error, returns a negative errno value. Will not block. If no bytes can be immediately accepted for transmission, returns -errno.EAGAIN immediately.N)�_sendr r7 r" r> rv �r8 �bufrV r r r �send� s ��z Stream.sendc C sd | � � }|dkr | S t|�dkrdS t|t�r |�d�}tjdkr,| jd u r,| �|�S | j� |�S )Nr zutf-8r ) r[ rD � isinstance�str�encoder r r �_Stream__send_windowsr� )r8 r� rq r r r r� � s z Stream._sendc C s� | j rNzt�| j| jd�}d| _ W |S tjyM } z.|jtjjkr/d| _ t j W Y d }~S |jtj v r?t j W Y d }~S t j W Y d }~S d }~ww t�| j|| j�\}}|rs|tjjkrhd| _ t j S |ss|tj v rst j S |S )NFT)�_write_pendingr' r} r r/ r* r7 rL r~ r| r1 r2 r � ECONNRESETr� � write_filer� )r8 r� � nBytesWrittenrV r� r r r �__send_windows� s: �� �� � zStream.__send_windowsc C � d S r r rn r r r r^ � � z Stream.runc C r� r r �r8 r_ r r r ra � r� zStream.run_waitc C s� |t jt jt jfv s J �| jt jkr|�� d S | jt jkr!t j}tj dkr.| � ||� d S |t jkr>|� | j t jj� d S |� | j t jj� d S �Nr )r � W_CONNECT�W_RECV�W_SENDr4 r6 �immediate_waker3 r r �_Stream__wait_windows�fd_waitr r" r_ �POLLIN�POLLOUT)r8 r_ �waitr r r r� � s z Stream.waitc C s | j d urU|tjkrtjtjB tjB }tjj }n tj tj B tjB }tjj }z t� | j | j|� W n tjyK } zt�d|j � W Y d }~nd }~ww |�| j|� d S |tjkrk| jri|�| jjtjj � d S d S |tjkr�| jr|�| jjtjj � d S d S |tjkr�d S d S )Nz*failed to associate events with socket: %s)r r r� rO �FD_READ� FD_ACCEPT�FD_CLOSEr" r_ r� �FD_WRITE� FD_CONNECTr� �WSAEventSelectr0 r* r7 rl rW �strerrorr� r, r. r� r/ r� )r8 r_ r� �mask�eventrV r r r �__wait_windows� sJ �� ������ � � �zStream.__wait_windowsc C � | � |tj� d S r )r� r r� r� r r r rb � � zStream.connect_waitc C r� r )r� r r� r� r r r � recv_wait r� zStream.recv_waitc C r� r )r� r r� r� r r r � send_wait r� zStream.send_waitc C sh | j d ur | j �� | jd ur0| jrt�| j� | jjr#t�| jj� | jjr2t�| jj� d S d S d S r )r rG r r' rk r, r. r/ rn r r r �__del__ s �zStream.__del__c C � | t _d S r )r �_SSL_private_key_file�� file_namer r r �ssl_set_private_key_file � z Stream.ssl_set_private_key_filec C r� r )r �_SSL_certificate_filer� r r r �ssl_set_certificate_file r� z Stream.ssl_set_certificate_filec C r� r )r �_SSL_ca_cert_filer� r r r �ssl_set_ca_cert_file r� zStream.ssl_set_ca_cert_file�NFr )2�__name__� __module__� __qualname__�__doc__r3 r5 r6 r� r� r� r r� r� r� r/ r, r� r| ro � staticmethodr r r r< �IPTOS_PREC_INTERNETCONTROL� DSCP_DEFAULTr? rF rQ rh rG rs r[ ry ru r{ r� r� r� r^ ra r� r� rb r� r� r� r� r� r� r r r r r 6 sr ! B * 1 r c @ sj e Zd ZdZdZedd� �Zedd� �Zddd�Zed d � �Z d d � Z d d� Z dd� Z dd� Z dd� ZdS )r NFc C s | � d�rdS dS )N�punix:FT�r r r r r r & r zPassiveStream.needs_probesc C s | � d�| � d�B S )z�Returns True if 'name' is a passive stream name in the form "TYPE:ARGS" and TYPE is a supported passive stream type (currently "punix:" or "ptcp"), otherwise False.r� �ptcp:r� r r r r r * s zPassiveStream.is_valid_namec C sn || _ || _|| _|d ur2t�� | _t�� | j_d| _ |� dd�d }t j � t jj|�}t�|�| _|| _d S )NFr r )r r r r* r+ r[ r' r- r. �connect_pendingr! r" r# r$ r% r& r( r) � bind_path)r8 r@ r r� r r; r r r r< 1 s zPassiveStream.__init__c C s� t �| �s tjdfS | dd� }| �d�rptj�tjj |�}t j dkr6tj � tjd|d�\}}|r5|dfS ngz t|d��� W n tjdf Y S t�|�}t|�dkrZtjdfS t�|�}|sftjdfS dt d| ||d �fS | �d �r�t�tjtj�}|�tjtjd � | �d �}|� |d t |d �f� nt d��z|� d� W n) tj y� } z t!�"d| t#�$|j �f � |�� |j dfW Y d}~S d}~ww dt || |�fS )a� Attempts to start listening for remote stream connections. 'name' is a connection name in the form "TYPE:ARGS", where TYPE is an passive stream class's name and ARGS are stream class-specific. Currently the supported values for TYPE are "punix" and "ptcp". Returns (error, pstream): on success 'error' is 0 and 'pstream' is the new PassiveStream, on failure 'error' is a positive errno value and 'pstream' is None.N� r� r T�wrA r �r r� r r r zUnknown connection string� z%s: listen: %s)%r r r1 rC r r" r# r$ r% r& r r r> �make_unix_socketr � SOCK_STREAMrF rG rE r' r( rD �create_named_pipe�AF_INET� setsockopt� SOL_SOCKET� SO_REUSEADDRr! �bind�int� Exception�listenr7 rl rW �osr� )r r� r7 r@ rT rU �remoterV r r r rF ? sL �� ��zPassiveStream.openc C sf | j dur | j �� | jdur t�| jtj� t�| jjtj� | j dur1t j � | j � d| _ dS dS )zCloses this PassiveStream.N) r rG r r' rk rl rm r[ r. r� r" � fatal_signal�unlink_file_nowrn r r r rG w s �zPassiveStream.closec C s� t jdkr| jdu r| �� S z6| j�� \}}tj�|� t jdkr3|jtj kr3dt |d| d�fW S dt |d|d t |d �f d�fW S tj y~ } z,tj� |�}t jdkra|tjkratj}|tjkrpt�dt�|� � |dfW Y d}~S d}~ww ) a� Tries to accept a new connection on this passive stream. Returns (error, stream): if successful, 'error' is 0 and 'stream' is the new Stream object, and on failure 'error' is a positive errno value and 'stream' is None. Will not block waiting for a connection. If no connection is ready to be accepted, returns (errno.EAGAIN, None) immediately.r NTr zunix:%sz ptcp:%s:%sr z accept: %s)r r r � _PassiveStream__accept_windows�acceptr" r> �set_nonblocking�family�AF_UNIXr r� r7 rv r1 r\ r2 rl �dbgr� r� )r8 r@ �addrrV r7 r r r r� � s, �� ��zPassiveStream.acceptc C sH | j rHz t�| j| jd� W n6 tjyD } z)|jtjjkr,d| _ t j d fW Y d }~S | jr5t � | j� t j d fW Y d }~S d }~ww d| _ t�| j| j�}|r~|tjjkr`d| _ t j d fS |tjjkrw| jrot � | j� d| _ t j d fS t�| jj� t�| j�}|s�t jd fS | j}|| _tj�| jj� dtd | jd|d�fS )NFTr r� )r� r' r} r r[ r* r7 rL r~ r1 r2 rJ rj r� �connect_named_piper� �ERROR_PIPE_CONNECTEDr� r� r. r� r) rE � ResetEventr r )r8 rV r7 rU �old_piper r r �__accept_windows� s> �� z PassiveStream.__accept_windowsc C sB t jdks | jd ur|�| jtjj� d S |�| jjtjj� d S r� ) r r r r� r" r_ r� r[ r. r� r r r r� � s zPassiveStream.waitc C sR | j d ur | j �� | jd ur%| jrt�| j� | jjr't�| jj� d S d S d S r )r rG r r' rk �_connectr. r, rn r r r r� � s �zPassiveStream.__del__r )r� r� r� r[ r� r� r r r< rF rG r� r� r� r� r r r r r ! s 7 % r c C s d| | f S )Na6 Active %s connection methods: unix:FILE Unix domain socket named FILE tcp:HOST:PORT TCP socket to HOST with port no of PORT ssl:HOST:PORT SSL socket to HOST with port no of PORT Passive %s connection methods: punix:FILE Listen on Unix domain socket FILEr r r r r �usage� s �r� c @ �$ e Zd Zedd� �Zedd� �ZdS )� UnixStreamc C � dS r� r r r r r r � � zUnixStream.needs_probesc C s | }t j�tjdd |�S �NT)r" r> r� r r� )r; rS � connect_pathr r r rQ � s �zUnixStream._openN�r� r� r� r� r rQ r r r r r� � � r� �unixc @ r� )� TCPStreamc C r� r� r r r r r r � r� zTCPStream.needs_probesc C s� t j�tj| d|�\}}|s<z|�tjtjd� W ||fS tjy; } z|� � t j� |�d fW Y d }~S d }~ww ||fS )Nr r ) r" r> �inet_open_activer r� r� � IPPROTO_TCP� TCP_NODELAYr7 rG rv )r; rS r7 r@ rV r r r rQ � s �� ��zTCPStream._openNr� r r r r r� � r� r� �tcpc sd e Zd Zedd� �Zedd� �Zedd� �Z� fdd�Z� fd d �Z� fd d �Z � fd d�Z � Z S )� SSLStreamc C s@ zt �| �W S tjy } z tj�|�W Y d }~S d }~ww r )r r? �ssl�SSLSyscallErrorr" r> rv )r@ rV r r r r? s ��z%SSLStream.check_connection_completionc C r� r� r r r r r r r� zSSLStream.needs_probesc C s t j�| d�}t j�tj|�\}}|d u r||fS t�tj�}tj |_ | j tj O _ | j tj O _ |�tj� |�tjtj� |j|dd�}t j�||||�}|s�z|�tjtjd� W ||fS tjy� } z|�� t j�|�d fW Y d }~S d }~ww ||fS )Nr F)�do_handshake_on_connectr ) r" r> �inet_parse_active�inet_create_socket_activer r� r� � SSLContext�PROTOCOL_SSLv23� CERT_REQUIRED� verify_mode�options� OP_NO_SSLv2� OP_NO_SSLv3�load_verify_locationsr r� �load_cert_chainr� r� � wrap_socket�inet_connect_activer� r� r� r7 rG rv ) r; rS �addressr� r@ �ctx�ssl_sockr7 rV r r r rQ s8 � � �� ��zSSLStream._openc s~ t t| ��� }|r |S z| j�� W dS tjy tj Y S tj tj tj t fy> } z t j�|�W Y d }~S d }~ww )Nr )�superr� r[ r � do_handshaker� �SSLWantReadErrorr1 r2 r� �SSLZeroReturnError� SSLEOFError�OSErrorr" r> rv rp �� __class__r r r[ 0 s � ���zSSLStream.connectc s� z t t| ��|�W S tjy tjdf Y S tjy2 } ztj � |�dfW Y d }~S d }~w tj y< Y dS t j yV } ztj � |�dfW Y d }~S d }~ww )Nrt rz )r r� ru r� r r1 r2 r� r" r> rv r r r7 rw r r r ry A s � ��zSSLStream.recvc s� z t t| ��|�W S tjy tj Y S tjy0 } z tj � |� W Y d }~S d }~w t j yI } z tj � |� W Y d }~S d }~ww r ) r r� r� r� �SSLWantWriteErrorr1 r2 r� r" r> rv r r7 r� r r r r� M s ���zSSLStream.sendc s< | j rz | j �t j� W n t jy Y nw tt| ��� S r )r �shutdown� SHUT_RDWRr7 r r� rG rn r r r rG W s �zSSLStream.close) r� r� r� r� r? r rQ r[ ry r� rG � __classcell__r r r r r� s r� r� ) r1 r� r r � ovs.pollerr" �ovs.socket_util�ovs.vlogr� � ImportErrorr � ovs.winutilsr' r* r� rO rJ rl �Vlogr �objectr r r� r� r r� r� r r r r �<module> sF � n 6 [�