File "unix_socket_exporter.cpython-36.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/lib/python3.6/site-packages/tuned/exports/__pycache__/unix_socket_exporter.cpython-36.pyc
File size: 8.59 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
3
<e @ s d dl Z d dlZd dlZd dlZddlmZ d dlZd dlj Z d dl
m Z d dl Z d dl
Z
d dlZejj ZG dd dejZdS ) N )
interfaces)ismethodc @ s e Zd ZdZejejejejej fddZ
dd Z dd Z dd Z
d
d Zd d
Zdd Zdd Zdd Zdd Zd$ddZd%ddZd d Zd d Zd d! Zd"d# ZdS )&UnixSocketExportera9
Export method calls through Unix Domain Socket Interface.
We take a method to be exported and create a simple wrapper function
to call it. This is required as we need the original function to be
bound to the original object instance. While the wrapper will be bound
to an object we dynamically construct.
c C s || _ d | _|r tjd|ng | _g | _dd g| _|r|j }xt|d d D ]\}}yt|| j|< W qP t k
r y2|dkrt
j |j | j|< nt
j|j| j|< W n2 tk
r tjd|dkrdnd|f Y nX Y qPX qPW || _|| _i | _t | _d | _d | _d S )
Nz,;r r z(%s '%s' does not exists, leaving defaultZUserZGroupr ) _socket_path_socket_objectresplit_socket_signal_pathsZ_socket_signal_objects
_ownership enumerateint
ValueErrorpwdgetpwnamZpw_uidgrpZgetgrnamZgr_gidKeyErrorlogerror _permissions_connections_backlog_unix_socket_methodsset_signalsZ_connZ_channel)selfZ socket_pathZ signal_pathsZ ownershipZ permissionsZconnections_backlogio r */usr/lib/python3.6/unix_socket_exporter.py__init__ s.
.zUnixSocketExporter.__init__c C s
| j d k S )N)r )r r r r running; s zUnixSocketExporter.runningc sT t std j}|| jkr,td| G fdddt}|||| j|< d S )Nz#Only bound methods can be exported.z/Method with this name (%s) is already exported.c s e Zd Zdd Z fddZdS )z*UnixSocketExporter.export.<locals>.wrapperc S s || _ || _d S )N)Z
_in_signature_out_signature)r in_signature
out_signaturer r r r! G s z3UnixSocketExporter.export.<locals>.wrapper.__init__c s
||S )Nr )r argskwargs)methodr r __call__K s z3UnixSocketExporter.export.<locals>.wrapper.__call__N)__name__
__module__ __qualname__r! r) r )r( r r wrapperF s r- )r Exceptionr* r object)r r( r$ r% method_namer- r )r( r export> s
zUnixSocketExporter.exportc s^ t std j}|| jkr,td| G fdddt}||| j|< | jj| d S )Nz#Only bound methods can be exported.z/Method with this name (%s) is already exported.c s e Zd Zdd Z fddZdS )z*UnixSocketExporter.signal.<locals>.wrapperc S s
|| _ d S )N)r# )r r% r r r r! Y s z3UnixSocketExporter.signal.<locals>.wrapper.__init__c s
||S )Nr )r r& r' )r( r r r) \ s z3UnixSocketExporter.signal.<locals>.wrapper.__call__N)r* r+ r, r! r) r )r( r r r- X s r- )r r. r* r r/ r add)r r( r% r0 r- r )r( r signalP s
zUnixSocketExporter.signalc O s || j krtd| x| jD ]}tjd| yDtjtjtj}|jd |j | | j
|d||d |j W q t k
r } ztj
d|||f W Y d d }~X q X q W d S )NzSignal '%s' doesn't exist.zSending signal on socket %sFz2.0)jsonrpcr( paramsz2Error while sending signal '%s' to socket '%s': %s)r r. r r debugsocketAF_UNIX SOCK_STREAMZ setblockingZconnect
_send_datacloseOSErrorwarning)r r3 r& r' pser r r send_signalb s
z UnixSocketExporter.send_signalc C s | j j| d S )N)r append)r pathr r r register_signal_pathp s z'UnixSocketExporter.register_signal_pathc C s | j rtjj| j r tj| j tjtjtj| _| jj | j | jj
| j tj | j | j
d | j
d | jrtj| j | j d S )Nr r )r osrC existsunlinkr7 r8 r9 r ZbindZlistenr chownr
r chmod)r r r r _construct_socket_objects s z+UnixSocketExporter._construct_socket_objectc C s | j r d S | j | j d S )N)r" stoprJ )r r r r start~ s zUnixSocketExporter.startc C s | j r| j j d S )N)r r; )r r r r rK s zUnixSocketExporter.stopc C sb t jd| y|jtj|jd W n4 tk
r\ } zt jd||f W Y d d }~X nX d S )NzSending socket data: %s)zutf-8z Failed to send data '%s': %s)r r6 sendjsondumpsencoder. r= )r r? datar@ r r r r: s
z UnixSocketExporter._send_dataFc C s$ d|d}|r||d< n||d< |S )Nz2.0)r4 idr resultr )r rQ rR r resr r r _create_response s
z#UnixSocketExporter._create_responseNc C s | j |||dd|dS )N)codemessagerQ T)r rR )rU )r rV rW rR rQ r r r _create_error_responce s
z)UnixSocketExporter._create_error_responcec C s | j ||S )N)rU )r rS rR r r r _create_result_response s z*UnixSocketExporter._create_result_responsec C s |j dr|S d S )NrR )get)r rQ r r r _check_id s
z UnixSocketExporter._check_idc C sn t |tks&|jddks&|jd r2| jddS |jd}d }|d | jkrb| j| jdd|S y|jd s| j|d }njt |d ttfkr| j|d |d }n>t |d tkr| j|d f |d }n| j| jdd|S W nn tk
r$ } z| j| jdd |t |S d }~X n8 t
k
rZ } z| j| jd d
|t |S d }~X nX | j| j ||S )Nr4 z2.0r( iX zInvalid RequestrR iY zMethod not foundr5 iZ zInvalid paramsr Erroriiii) typedictrZ rX r r[ listtuple TypeErrorstrr. rY )r reqrR retr@ r r r _process_request s& &
$&z#UnixSocketExporter._process_requestc # C s | j s dS xtj| jgf f d\}}}|r| jj \}}y*d}x |jdj }|sZP ||7 }qFW W n2 tk
r } ztjd| wW Y dd}~X nX |ryt j
|}W nR tk
r } z4tjd||f | j || j d dt
| wW Y dd}~X nX t|tttfkr>tjd | j || j d
dt
| qt|ttfkrt|dkrz| j || j dd t
| qg }x(|D ] }| j|}|r|j| qW |r| j || n | j|}|r| j || qdS qW dS )a
Periodically checks socket object for new calls. This allows to function without special thread.
Interface is according JSON-RPC 2.0 Specification (see https://www.jsonrpc.org/specification)
Example calls:
printf '[{"jsonrpc": "2.0", "method": "active_profile", "id": 1}, {"jsonrpc": "2.0", "method": "profiles", "id": 2}]' | nc -U /run/tuned/tuned.sock
printf '{"jsonrpc": "2.0", "method": "switch_profile", "params": {"profile_name": "balanced"}, "id": 1}' | nc -U /run/tuned/tuned.sock
Nr i z"Failed to load data of message: %sz!Failed to load json data '%s': %si z Parse errorzWrong format of calliX zInvalid RequestiDiDi)r" selectr ZacceptZrecvdecoder. r r rN loadsr: rX rb r] r` r_ r^ lenre rB ) r r_ZconnrQ Zrec_datar@ rT rc r r r period_check sT
z UnixSocketExporter.period_check)F)NN)r* r+ r, __doc__constsZCFG_DEF_UNIX_SOCKET_PATHZ CFG_DEF_UNIX_SOCKET_SIGNAL_PATHSZ CFG_DEF_UNIX_SOCKET_OWNERSHIPZ CFG_DEF_UNIX_SOCKET_PERMISIONSZ'CFG_DEF_UNIX_SOCKET_CONNECTIONS_BACKLOGr! r" r1 r3 rA rD rJ rL rK r: rU rX rY r[ re rm r r r r r s*
r )rE r
r r rf r Z
tuned.logsZtunedZ tuned.constsro inspectr r7 rN rg ZlogsrZ r ZExporterInterfacer r r r r <module> s