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 :
jsonrpc.cpython-310.pyc
o ��ecR � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Zd dl Zd dl Zd dl Zej jZej�d�ZG dd� de�ZG dd� de�ZG dd� de�ZdS ) � N�jsonrpcc @ s� e Zd ZdZdZdZdZedededediZd d � ZdZ e d d � �Z e d d� �Z e dd� �Z e dd� �Ze dd� �Ze dd� �Zdd� Zdd� Ze dd � �Zd d � Zd d � Zd!S )"�Messager � � � �request� notification�reply�errorc C s( || _ || _|| _|| _|| _|| _d S �N)�type�method�params�resultr �id)�self�type_r r r r r � r �-/usr/lib/python3/dist-packages/ovs/jsonrpc.py�__init__+ s zMessage.__init__c C s t j} t jd7 _| S �Nr )r �_next_id)�this_idr r r � _create_id5 s zMessage._create_idc C s t t j| |d d t �� �S r )r � T_REQUESTr �r r r r r �create_request; s �zMessage.create_requestc C s t t j| |d d d �S r )r �T_NOTIFYr r r r � create_notify@ s �zMessage.create_notifyc C s t t jd d | d |�S r )r �T_REPLY)r r r r r � create_replyE � zMessage.create_replyc C s t t jd d d | |�S r )r �T_ERROR)r r r r r � create_errorI r! zMessage.create_errorc C s t j| S r )r �_Message__types)r r r r �type_to_stringM s zMessage.type_to_stringc C s< |d u|dkkr d S t �| j�}|rd}nd}d|||f S )Nr �mustzmust notz%s %s have "%s")r r% r )r �value�name� must_have� type_name�verbr r r �__validate_argQ s zMessage.__validate_argc C s� | j d ur t| j t�s dS tjdtjdtjdtjdi�| j �}|d u r(d| j S | � | j d|d@ �pY| � | j d |d @ �pY| � | j d |d @ �pY| � | j d |d@ �pY| � | jd|d@ �S )Nz"params" must be JSON arrayi i i � z invalid JSON-RPC message type %sr i r � r � r � r r )r � isinstance�listr r r r r" �getr �_Message__validate_argr r r r )r �patternr r r �is_valid\ s( �� ����zMessage.is_validc C s� t | t�sdS t| �} d| v r | �d�}t |t�sdS nd }| �dd �}| �dd �}| �dd �}| �dd �}t| �rBd| �� d S |d urJtj}n|d urRtj}n |d urZtj }ntj }t||||||�}|� � }|d urp|S |S ) Nz message is not a JSON objectr zmethod is not a JSON stringr r r r z"message has unexpected member "%s"r ) r1 �dict�pop�str�len�popitemr r r" r r r6 ) �jsonr r r r �id_�msg_type�msg�validation_errorr r r � from_jsonn s6 � zMessage.from_jsonc C s� i }| j d ur | j |d< | jd ur| j|d< | jd us!| jtjkr&| j|d< | jd us1| jtjkr6| j|d< | jd usA| jtj krF| j|d< |S )Nr r r r r ) r r r r r r" r r r r )r r< r r r �to_json� s zMessage.to_jsonc C s� t �| j�g}| jd ur|�d| j � | jd ur%|�dtj�| j� � | j d ur6|�dtj�| j � � | j d urG|�dtj�| j � � | j d urX|�dtj�| j � � d� |�S )Nz method="%s"zparams=zresult=zerror=zid=z, ) r r% r r �appendr �ovsr< � to_stringr r r �join)r �sr r r �__str__� s zMessage.__str__N)�__name__� __module__� __qualname__r r r r" r$ r r � staticmethodr r r r r# r% r4 r6 rA rB rH r r r r r s< � % r c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!S )"� Connectionc C s0 |j | _ || _d| _d| _d| _d | _d| _d S �Nr � )r( �stream�status�input�output�parser�received_bytes)r rP r r r r � s zConnection.__init__c C s | j �� d | _ d S r )rP �close�r r r r rV � s zConnection.closec C s� | j rd S t| j�rA| j�| j�}|dkr | j|d � | _n |tj kr8t�d| j t � | �f � | � | � d S t| j�s d S d S )Nr z%s: send error: %s) rQ r: rS rP �send�errno�EAGAIN�vlog�warnr( �os�strerrorr )r �retvalr r r �run� s � �zConnection.runc C s4 | j s| j�|� t| j�r| j�|� d S d S d S r )rQ rP �run_waitr: rS � send_wait�r �pollerr r r �wait� s �zConnection.waitc C � | j S r )rQ rW r r r � get_status� � zConnection.get_statusc C s | j dkrdS t| j�S �Nr )rQ r: rS rW r r r � get_backlog� s zConnection.get_backlogc C rf r )rU rW r r r �get_received_bytes� rh z Connection.get_received_bytesc C s& t �� rt �d| j||f � d S d S )Nz %s: %s %s)r[ �dbg_is_enabled�dbgr( )r �titler? r r r � __log_msg� s �zConnection.__log_msgc C sR | j r| j S | �d|� t| j�dk}| jtj�|�� �7 _|r&| �� | j S )NrX r ) rQ �_Connection__log_msgr: rS rD r< rE rB r` )r r? � was_emptyr r r rX � s zConnection.sendc C sP | � |�}|r |S | �� | �� r| �� r| jS tj�� }| �|� |� � q r ) rX r` rj rg rQ rD rd �Pollerre �block)r r? r rd r r r � send_block� s �zConnection.send_blockc C s� | j r| j d fS t�d�� } | js}| j�d�\}}|r2|s2z|�|�}W n ty1 tj }Y nw |rat j dkrA|tj krAtj }|tj krJ|d fS t�d| jt�|�f � | �|� | j d fS |sl| �t� td fS | j|7 _| jt|�7 _nG| jd u r�tj�� | _tjjtjj kr�| j� d�| j� | j�d � �� | _n | j| j� | j�d � | _| j� � r�| � � }|r�d|fS | j d fS q)Nzutf-8Tr. �win32z%s: receive error: %sr )!rQ �codecs�getincrementaldecoderrR rP �recv�decode� UnicodeErrorrY �EILSEQ�sys�platform�WSAEWOULDBLOCKrZ r[ r\ r( r] r^ r �EOFrU r: rT rD r< �Parser�PARSER�PARSER_C�encode�feed�is_done�_Connection__process_msg)r �decoderr �datar? r r r rx sV � � �� �zConnection.recvc C sP | � � \}}|tjkr||fS | �� tj�� }| �|� | �|� |� � qr ) rx rY rZ r` rD rd rr re � recv_waitrs )r r r? rd r r r � recv_block7 s �zConnection.recv_blockc C s` |j }| �|�}d }|s,| �� \}}|r*|jtjks |jtjkr*|j |kr* ||fS |r ||fS r )r rX r� r r r r" )r r r= r r r r r �transact_blockD s �zConnection.transact_blockc C s� | j �� }d | _ t|t�r t�d| j|f � | �tj � d S t � |�}t|t �s;t�d| j|f � | �tj � d S | � d|� |S )Nz %s: error parsing stream: %sz%%s: received bad JSON-RPC message: %s�received) rT �finishr1 r9 r[ r\ r( r rY �EPROTOr rA rp )r r< r? r r r � __process_msgR s � zConnection.__process_msgc C s( | j s| jr |�� d S | j�|� d S r )rQ rR �immediate_wakerP r� rc r r r r� f s zConnection.recv_waitc C s( | j dkr|| _ | j�� d| _d S d S rN )rQ rP rV rS )r r r r r r l s �zConnection.errorN)rI rJ rK r rV r` re rg rj rk rp rX rt rx r� r� r� r� r r r r r rM � s" 3 rM c @ s� e Zd ZdZdd� Zed-dd��Zed-dd��Zed d � �Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� ZdS ).�Sessionz%A JSON-RPC session with reconnection.c C sL || _ || _d | _d | _d| _t|�tur|g}|| _t� | j� d| _ d S ri ) � reconnect�rpcrP �pstream�seqnor r2 �remotes�random�shuffle� next_remote)r r� r� r� r r r r v s zSession.__init__Nc C s t j| g|d�S )a= Creates and returns a Session that maintains a JSON-RPC session to 'name', which should be a string acceptable to ovs.stream.Stream or ovs.stream.PassiveStream's initializer. If 'name' is an active connection method, e.g. "tcp:127.1.2.3", the new session connects and reconnects, with back-off, to 'name'. If 'name' is a passive connection method, e.g. "ptcp:", the new session listens for connections to 'name'. It maintains at most one connection at any given time. Any new connection causes the previous one (if any) to be dropped. If "probe_interval" is zero it disables the connection keepalive feature. If non-zero the value will be forced to at least 1000 milliseconds. If None it will just use the default value in OVS. )�probe_interval)r� � open_multiple)r( r� r r r �open� s z Session.openc C s� t j�t j�� �}t|d | �}|�� |�t j�� � |�t | �� t j j � |� � �r4|�dt j�� � t j �|� � �sC|�d� |S |d urL|�|� |S �NTr )rD r� � Reconnect�timeval�msecr� � pick_remote�enable�set_backoff_free_triesr: rP � PassiveStream� is_valid_name�get_name� set_passive� stream_or_pstream_needs_probes�set_probe_interval)r� r� r� �sessionr r r r� � s � zSession.open_multiplec C sR t j�t j�� �}t|d | jg�}|�d� |�� |� d� |� t j�� � |S r� ) rD r� r� r� r� r� r( � set_quietr� � set_max_tries� connected)r r� r� r r r �open_unreliably� s zSession.open_unreliablyc C s. | j �| j| j � | jd t| j� | _d S r )r� �set_namer� r� r: rW r r r r� � s zSession.pick_remotec C sV | j d ur | j �� d | _ | jd ur| j�� d | _| jd ur)| j�� d | _d S d S r )r� rV rP r� rW r r r rV � s �z Session.closec C sb | j d ur| j �t� | j �� d | _ n| jd ur"| j�� d | _nd S | jd7 _| �� d S r )r� r r rV rP r� r� rW r r r � __disconnect� s zSession.__disconnectc C s� | � � | j�� }| j�� s6tjj�|�\}| _|s$| j�tj � � � n;| j� tj � � |� d | _| � � n)| j d u r_tjj�|�\}| _ |sQ| j�tj � � � n| j� tj � � |� | � � | jd7 _d S r )�_Session__disconnectr� r� � is_passiverD rP �Streamr� � connectingr� r� �connect_failedr� r� r� � listeningr� )r r( r r r r � __connect� s zSession.__connectc C s$ | j d urJ| j �� \}}|dkr3| js| jr$t�d| j�� � | �� | j� t j � � � t |�| _n|tjkrJ| j�t j � � |� | j �� d | _ | jr| j�� }| j�� | j�� |k rg| j�t j � � � | j�� }|dkr~| j�t j � � |� | �� nA| jd ur�| j�� | j�� }|dkr�| j� t j � � � t | j�| _d | _n|tjkr�| j�t j � � |� | �� | j�� d | _| j�t j � � �}|t jjkr�| �� d S |t jj kr�| j�t j � � d� | �� d S |t jj k�r | j�rt � dg �}d|_ | j�!|� d S d S |d u �sJ �d S )Nr z.%s: new connection replacing active connection�echo)"r� �acceptr� rP r[ �infor� r� r� r� rD r� r� rM rY rZ � listen_errorrV rj r` �activityrg � disconnected�connectr� r� �CONNECT�_Session__connect� DISCONNECT�PROBEr r r rX )r r rP �backlog�actionr r r r r` � sb � � �z Session.runc C sh | j d ur | j �|� n| jd ur | j�|� | j�|� | jd ur(| j�|� | j�|tj� � � d S r ) r� re rP ra � connect_waitr� r� rD r� r� rc r r r re s z Session.waitc C s | j d ur | j �� S dS ri )r� rj rW r r r rj * s zSession.get_backlogc C s | j �� S r )r� r� rW r r r r� 0 � zSession.get_namec C s | j d ur | j �|�S tjS r )r� rX rY �ENOTCONN)r r? r r r rX 3 s z Session.sendc C s� | j d urS| j �� }| j �� \}}tj�� }| j�|� || j �� kr)| j�|� |sS|j t j krC|j dkrC| � t �|j|j�� d S |j t jkrQ|jdkrQ d S |S d S )Nr� )r� rk rx rD r� r� r� �receive_attemptedr� r r r r rX r r r r )r rU r r? �nowr r r rx 9 s ��z Session.recvc C s | j d ur | j �|� d S d S r )r� r� rc r r r r� S s �zSession.recv_waitc C s2 | j d us | jd ur dS | j�� }|d u p|dkS r� )r� rP r� � get_max_tries)r � max_triesr r r �is_aliveW s zSession.is_alivec C s | j d uS r )r� rW r r r � is_connected^ r� zSession.is_connectedc C rf r )r� rW r r r � get_seqnoa rh zSession.get_seqnoc C s | j �tj�� � d S r )r� �force_reconnectrD r� r� rW r r r r� d s zSession.force_reconnectc C s* t | j�}| �� r |d7 }| j�|� dS )z� Resets the reconnect backoff by allowing as many free tries as the number of configured remotes. This is to be used by upper layers before calling force_reconnect() if backoff is undesirable.r N)r: r� r� r� r� )r � free_triesr r r � reset_backoffg s zSession.reset_backoffc C s t | j�S r )r: r� rW r r r �get_num_of_remotest r� zSession.get_num_of_remotesr )rI rJ rK �__doc__r rL r� r� r� r� rV r� r� r` re rj r� rX rx r� r� r� r� r� r� r� r r r r r� s s4 < r� )rv rY r] r� r| �ovs.jsonrD � ovs.poller� ovs.reconnect� ovs.stream� ovs.timeval�ovs.util�ovs.vlog�utilr r[ �Vlog�objectr rM r� r r r r �<module> s& =