Warning: session_start(): Session cannot be started after headers have already been sent in /home/tvrreohg/public_html/manga.php on line 13
3
.wrapperc S s || _ || _d S )N)Z
_in_signature_out_signature)r in_signature
out_signaturer r r r! G s z3UnixSocketExporter.export..wrapper.__init__c s
||S )Nr )r argskwargs)methodr r __call__K s z3UnixSocketExporter.export..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..wrapperc S s
|| _ d S )N)r# )r r% r r r r! Y s z3UnixSocketExporter.signal..wrapper.__init__c s
||S )Nr )r r& r' )r( r r r) \ s z3UnixSocketExporter.signal..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 s