Linux tsuru-no-tsurugi 5.15.0-186-generic #196-Ubuntu SMP Sat Jun 20 16:09:34 UTC 2026 x86_64
Apache/2.4.52 (Ubuntu)
Server IP : 192.168.0.18 & Your IP : 216.73.216.68
Domains :
Cant Read [ /etc/named.conf ]
User : www-data
Terminal
Auto Root
Create File
Create Folder
Localroot Suggester
Backdoor Destroyer
Readme
/
usr /
lib /
python3 /
dist-packages /
ovs /
__pycache__ /
Delete
Unzip
Name
Size
Permission
Date
Action
__init__.cpython-310.pyc
139
B
-rw-r--r--
2026-06-23 20:31
daemon.cpython-310.pyc
14.42
KB
-rw-r--r--
2026-06-23 20:31
dirs.cpython-310.pyc
581
B
-rw-r--r--
2026-06-23 20:31
fatal_signal.cpython-310.pyc
4.62
KB
-rw-r--r--
2026-06-23 20:31
fcntl_win.cpython-310.pyc
904
B
-rw-r--r--
2026-06-23 20:31
json.cpython-310.pyc
14.95
KB
-rw-r--r--
2026-06-23 20:31
jsonrpc.cpython-310.pyc
15.69
KB
-rw-r--r--
2026-06-23 20:31
ovsuuid.cpython-310.pyc
1.73
KB
-rw-r--r--
2026-06-23 20:31
poller.cpython-310.pyc
7.85
KB
-rw-r--r--
2026-06-23 20:31
process.cpython-310.pyc
1020
B
-rw-r--r--
2026-06-23 20:31
reconnect.cpython-310.pyc
22.23
KB
-rw-r--r--
2026-06-23 20:31
socket_util.cpython-310.pyc
8.29
KB
-rw-r--r--
2026-06-23 20:31
stream.cpython-310.pyc
22.2
KB
-rw-r--r--
2026-06-23 20:31
timeval.cpython-310.pyc
1.48
KB
-rw-r--r--
2026-06-23 20:31
util.cpython-310.pyc
2.61
KB
-rw-r--r--
2026-06-23 20:31
version.cpython-310.pyc
156
B
-rw-r--r--
2026-06-23 20:31
vlog.cpython-310.pyc
12.88
KB
-rw-r--r--
2026-06-23 20:31
winutils.cpython-310.pyc
4.87
KB
-rw-r--r--
2026-06-23 20:31
Save
Rename
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& =