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 :
socket_util.cpython-310.pyc
o y.�e�. � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Zzd dl Z W n e y5 dZ Y nw ej dkrEd dl mZ d dlZej�d�Zdd� Zdd� Zd"d d �Zd d � Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zda dd� Z d d � Z d d � Z d d!� Z dS )#� N�win32� socket_utilc C s� | d u rd S t j�| �} t j�| �}t �dd�}tdd�D ]I}d|t�dd�|f }zt �||� t j � |� t j� |t j� | ��W S tyf } z|jtjkr\W Y d }~ td��W Y d }~q d }~ww td��)N�TMPDIRz/tmpr i� z%s/ovs-un-py-%d-%di' z"Failed to create temporary symlink)�os�path�abspath�dirname�getenv�range�random�randint�symlink�ovs� fatal_signal�add_file_to_unlink�join�basename�OSError�errno�EEXIST� Exception)� long_name� long_dirname�tmpdir�x� link_name�e� r �1/usr/lib/python3/dist-packages/ovs/socket_util.py�make_short_name& s( � ���r c C s( | d u rd S t j�| �}tj�|� d S )N)r r r r r �unlink_file_now)� short_namer r r r �free_short_name9 s r" Fc C s z t � t j| �}W n t jy" } z t|�dfW Y d}~S d}~ww z�|r*t|� |duryzt�|� W n$ tyY } z|jtj krO|jdfW Y d}~W S W Y d}~nd}~ww t j � |� |� |� z t�|�� d� W n tyx Y nw |dur�z|�|� W n t jy� } zt|�tjkr�� W Y d}~nd}~ww d|fW S t j�y } �zY|�� |dur�tj�|�r�t j �|� t j�|�}|dk�r�t�� d dk�r�d}d} d} d} |du�r"tj�|�} tj�|�} z t�| tjtj B �} W n t�y } zt|�dfW Y d}~W Y d}~S d}~ww d| | f }|du�retj�|�} tj�|�} z t�| tjtj B �} W n t�y^ } zt|�dfW Y d}~W Y d}~S d}~ww d| | f } z)t | || |�W | du�rwt�| � | du�r�t�| � W Y d}~S W Y d}~S | du�r�t�| � | du�r�t�| � w w |dk�r�|�r�t|�dfW Y d}~S d} z t |�} t |�}W n t | � tj df Y W Y d}~S zt | || |dd�W t | � t |� W Y d}~S t | � t |� w t|�dfW Y d}~S d}~ww ) a� Creates a Unix domain socket in the given 'style' (either socket.SOCK_DGRAM or socket.SOCK_STREAM) that is bound to 'bind_path' (if 'bind_path' is not None) and connected to 'connect_path' (if 'connect_path' is not None). If 'nonblock' is true, the socket is made non-blocking. Returns (error, socket): on success 'error' is 0 and 'socket' is a new socket object, on failure 'error' is a positive errno value and 'socket' is None.Ni� r zAF_UNIX path too long�Linuxz/proc/self/fd/%d/%sT)�short)!�socket�AF_UNIX�error�get_exception_errno�set_nonblockingr �unlinkr r �ENOENTr r r �bind�fchmod�fileno�connect� EINPROGRESS�closer �existsr r �unamer r �open� O_DIRECTORY�O_RDONLY�make_unix_socketr r" � ENAMETOOLONG)�style�nonblock� bind_path� connect_pathr$ �sockr �eno�short_connect_path�short_bind_path� connect_dirfd� bind_dirfdr r �errr r r r7 @ s� �� ��� � ��� � �$��� $���� � � � �� ��r7 c C s$ t jdkr)tj�� }t�d ddd �}t�| |tj tj B tj B � |� |tjj � n tj�� }|� | tjj � |�d�}t|�dkr�|d d }|tjj@ sS|tjj@ r�z"trdt| tj�rd| �d�� � n | �d�� tj� t�d� t j W S tj y� } z t |�W Y d }~S d }~ww dS t j S )Nr FTr � � z&poll return POLLERR but send succeeded)!�sys�platformr �poller� SelectPoll�winutils� get_new_event� win32file�WSAEventSelect�FD_WRITE� FD_CONNECT�FD_CLOSE�register�POLLOUT�get_system_poll�poll�len�POLLERR�POLLHUP�ssl� isinstance� SSLSocket�send�encoder% � MSG_DONTWAIT�vlogrC r �EPROTOr' r( �EAGAIN)r= �p�event�pfds�reventsr r r r �check_connection_completion� s: ��� ��re c C sd z t �t j| � W dS ty' z t �| � W Y dS t jy& Y Y dS w t jy1 Y dS w )NFT)r% � inet_pton�AF_INET�AttributeError� inet_atonr' )�addressr r r �is_valid_ipv4_address� s ����rk c C sx | � d�}t|�dkr!d�|dd� ��d��d�}t|d �}n|r&|}ntd| ��|d }|s8td| ��||fS ) N�:� r ����[�]z!%s: port number must be specifiedz%s: bad peer name format)�splitrU r �lstrip�rstrip�int� ValueError)�target� default_portrj � host_name�portr r r �inet_parse_active� s rz c C s� z)t |d �}|rt�tj| d�}tj}nt�tj| d�}tj}W ||fS W ||fS tjyB } z t|�d fW Y d }~S d }~ww �Nr )rk r% rg �AF_INET6r' r( )r9 rj � is_addr_inetr= �familyr r r r �inet_create_socket_active� s ����r c C s| z"t | � t| ||� | �|�}|dtjtjfvr | �� |W S W dS tjy= } z| �� t |�W Y d }~S d }~ww r{ ) r) �set_dscp� connect_exr r0 � EWOULDBLOCKr1 r% r' r( )r= rj r~ �dscpr' r r r r �inet_connect_active� s ��r� c C sJ t ||�}t| |�\}}|d u r||fS t||||�}|r!|d fS d|fS r{ )rz r r� )r9 rv rw r� rj r~ r= r' r r r �inet_open_active s r� c C s t | jt�r | jd S tjS )z�A lot of methods on Python socket objects raise socket.error, but that exception is documented as having two completely different forms of arguments: either a string or a (errno, string) tuple. We only want the errno.r )rY �args�tupler r_ �r r r r r( s r( rn c C sl t dk r4z t�tjtj�a W t S ty3 } zt�dtjt�| j �f � | j W Y d} ~ S d} ~ ww t S )z�Returns a readable and writable fd for /dev/null, if successful, otherwise a negative errno value. The caller must not close the returned fd (because the same fd will be handed out to subsequent callers).r zcould not open %s: %sN) �null_fdr r4 �devnull�O_RDWRr r^ rC �strerrorr r� r r r � get_null_fd! s � ���r� c C s� d}t |�dkr dS t|t�st|d�} z6t�| |�}|dks"J �|t |�kr1d|t |� fW S |dkr@t�d� tj|fW S ||7 }|d|� }W n t yb } z |j|fW Y d}~S d}~ww q)a Returns an (error, bytes_written) tuple where 'error' is 0 on success, otherwise a positive errno value, and 'bytes_written' is the number of bytes that were written before the error occurred. 'error' is 0 if and only if 'bytes_written' is len(buf).r )r r zutf-8Tzwrite returned 0N) rU rY �bytesr �writer^ �warnr r_ r )�fd�buf� bytes_written�retvalr r r r � write_fully2 s* ���r� c C sR z| � d� W d S tjy( } zt�dt�t|�� � W Y d }~d S d }~ww )Nr z,could not set nonblocking mode on socket: %s)� setblockingr% r' r^ rC r r� r( )r= r r r r r) L s ���r) c C sh |dkr t d| ��|d> }|tjkr | �tjtj|� d S |tjkr.| �tjtj|� d S t d| ��)N�? zInvalid dscp %drm zInvalid family %d) ru r% rg � setsockopt� IPPROTO_IP�IP_TOSr| � IPPROTO_IPV6� IPV6_TCLASS)r= r~ r� �valr r r r� T s r� )F)!r r �os.pathr r% rF �ovs.fatal_signalr � ovs.poller�ovs.vlogrX � ImportErrorrG � ovs.winutilsrJ rL r^ �Vlogr r" r7 re rk rz r r� r� r( r� r� r� r) r� r r r r �<module> sB � f'