File: //lib/python3/dist-packages/serial/urlhandler/__pycache__/protocol_spy.cpython-310.pyc
o
�1�_�# � @ s� d dl mZ d dlZd dlZd dlZd dlmZ zd dlZW n ey- d dl m
Z Y nw dd� Z dd� Z G dd � d e
�ZG d
d � d e
�ZG d d
� d
ej�Zedkr`ed�Zde_ee� dS dS )� )�absolute_importN)�to_bytesc c s� � d}t �| �D ]2}d�t|��d| krdk r!n n|�d�ndfV |d7 }|dkr1d V q|d
kr:d V d}q|dkrZ|d
k rU|d7 }|dkrNd V d V |d
k sCd V d
S d
S )z� yield tuples of hex and ASCII display in multiples of 16. Includes a
space after 8 bytes and (None, None) after 16 bytes and at the end.
r z{:02X} � � �ascii�.� � )� � � )NN)z r
N)�serial� iterbytes�format�ord�decode)�data�n�b� r �@/usr/lib/python3/dist-packages/serial/urlhandler/protocol_spy.py�sixteen% s( �6��
�r c c s~ � g }g }d}t | �D ]1\}}|du r2|d�d�|�d�|�g�fV |dd�= |dd�= |d7 }q |�|� |�|� q dS )z yield lines with hexdump of datar Nr
r r )r �join�append)r �valuesr �offset�h�ar r r �hexdump< s �
�r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) � FormatRawz&Forward only RX and TX data to output.c C s || _ || _d| _d| _d S )N�[32m�[31m)�output�color�rx_color�tx_color��selfr" r# r r r �__init__O s
zFormatRaw.__init__c C �. | j r
| j�| j� | j�|� | j�� dS )zshow received dataN)r# r" �writer$ �flush�r' r r r r �rxU � z FormatRaw.rxc C r) )zshow transmitted dataN)r# r" r* r% r+ r, r r r �tx\ r. z FormatRaw.txc C s dS )z(do not) show control callsNr �r' �name�valuer r r �controlc s zFormatRaw.controlN)�__name__�
__module__� __qualname__�__doc__r( r- r/ r3 r r r r r L s r c @ s: e Zd ZdZdd� Zddd�Zdd� Zd d
� Zd d � Zd
S )�
FormatHexdumpax Create a hex dump of RX ad TX data, show when control lines are read or
written.
output example::
000000.000 Q-RX flushInput
000002.469 RTS inactive
000002.773 RTS active
000003.001 TX 48 45 4C 4C 4F HELLO
000003.102 RX 48 45 4C 4C 4F HELLO
c C s, t � � | _|| _|| _d| _d| _d| _d S )Nr r! z[37m)�time�
start_timer" r# r$ r% �
control_colorr& r r r r( w s
zFormatHexdump.__init__r c C s& | j �d�||||�� | j �� d S )Nz{:010.3f} {:4} {}{}
)r" r* r r+ )r' � timestamp�labelr2 �value2r r r �
write_line s zFormatHexdump.write_linec C sj | j r
| j�| j� |r't|�D ]\}}| �t�� | j dd�|�|� qdS | �t�� | j dd� dS )z show received data as hex dump�RX�{:04X} z<empty>N) r# r" r* r$ r r? r9 r: r �r' r r �rowr r r r- � s "� zFormatHexdump.rxc C sJ | j r
| j�| j� t|�D ]\}}| �t�� | j dd�|�|� qdS )z!show transmitted data as hex dump�TXrA N) r# r" r* r% r r? r9 r: r rB r r r r/ � s
"�zFormatHexdump.txc C s0 | j r
| j�| j� | �t�� | j ||� dS )zshow control callsN)r# r" r* r; r? r9 r: r0 r r r r3 � s zFormatHexdump.controlN)r ) r4 r5 r6 r7 r( r? r- r/ r3 r r r r r8 h s
r8 c sT e Zd ZdZ� fdd�Zejjjdd� �Zdd� Z � fdd �Z
d,� fd d � Z e ejd
�r2� fdd�Z
e ejd�r>� fdd�Ze� fdd��Z� fdd�Z� fdd�Z� fdd�Zd-� fd d � Zejjjd d � �Zejjjd d!� �Zejjjd"d#� �Zejjj� fd$d%��Zejjj� fd&d'��Zejjj� fd(d)��Zejj j� fd*d+��Z � Z S ).�Serialzc Inherit the native Serial port implementation and wrap all the methods and
attributes.
c s& t t| �j|i |�� d | _d| _d S )NF)�superrE r( � formatter�show_all)r' �args�kwargs�� __class__r r r( � s
zSerial.__init__c C s& |d urt jj�| | �|�� d S d S �N)r
rE �port�__set__�from_url)r' r2 r r r rN � s �z Serial.portc
C s� t �|�}|jdkrt�d�|j���t}d}tj}z8t � |j
d�� � D ],\}}|dkr4t |d d�}q$|dkr;d}q$|d krBt
}q$|d
krJd| _q$td �|���W n tyf } zt�d �|���d
}~ww |||�| _d�|j|jg�S )z(extract host and port from an URL string�spyzmexpected a string in the form "spy://port[?option[=value][&option[=value]]]": not starting with spy:// ({!r})FT�filer �wr# �raw�allzunknown option: {!r}zPexpected a string in the form "spy://port[?option[=value][&option[=value]]]": {}Nr )�urlparse�urlsplit�schemer
�SerialExceptionr r8 �sys�stderr�parse_qs�query�items�openr rH �
ValueErrorrG r �netloc�path) r' �url�partsrG r# r" �optionr �er r r rP � s<
�� ��� zSerial.from_urlc s$ t |�}| j�|� tt| ��|�S rM )r rG r/ rF rE r* )r' r/ rK r r r* � s z Serial.writer c s* t t| ��|�}|s
| jr| j�|� |S rM )rF rE �readrH rG r- )r' �sizer- rK r r rg � s
z Serial.read� cancel_readc � | j �dd� tt| ��� d S )N�Q-RXri )rG r3 rF rE ri �r' rK r r ri � � zSerial.cancel_read� cancel_writec rj )N�Q-TXrn )rG r3 rF rE rn rl rK r r rn � rm zSerial.cancel_writec s* t t| �j}| jr| j�dd�|�� |S )Nrk zin_waiting -> {})rF rE �
in_waitingrH rG r3 r )r' r rK r r rp � s zSerial.in_waitingc rj )Nro r+ )rG r3 rF rE r+ rl rK r r r+ � rm z Serial.flushc rj )Nrk �reset_input_buffer)rG r3 rF rE rq rl rK r r rq � rm zSerial.reset_input_bufferc rj )Nro �reset_output_buffer)rG r3 rF rE rr rl rK r r rr � rm zSerial.reset_output_buffer� �?c s( | j �dd�|�� tt| ��|� d S )N�BRKzsend_break {}s)rG r3 r rF rE �
send_break)r' �durationrK r r ru � s zSerial.send_breakc C �* | j �d|rdnd� tjj�| |� d S )Nrt �active�inactive)rG r3 r
rE �break_conditionrO �r' �levelr r r rz � � zSerial.break_conditionc C rw )N�RTSrx ry )rG r3 r
rE �rtsrO r{ r r r r � r} z
Serial.rtsc C rw )N�DTRrx ry )rG r3 r
rE �dtrrO r{ r r r r� r} z
Serial.dtrc �, t t| �j}| j�d|rd� |S d� |S )N�CTSrx ry )rF rE �ctsrG r3 r{ rK r r r� �
�z
Serial.ctsc r� )N�DSRrx ry )rF rE �dsrrG r3 r{ rK r r r� r� z
Serial.dsrc r� )N�RIrx ry )rF rE �rirG r3 r{ rK r r r� r� z Serial.ric r� )N�CDrx ry )rF rE �cdrG r3 r{ rK r r r� r� z Serial.cd)r )rs ) r4 r5 r6 r7 r( r
rE rN �setterrP r* rg �hasattrri rn �propertyrp r+ rq rr ru rz r r� r� �getterr� r� r� �
__classcell__r r rK r rE � s@
rE �__main__zspy:///dev/ttyS0)�
__future__r rZ r9 r
�serial.serialutilr rV � ImportError� urllib.parse�parser r �objectr r8 rE r4 �serrN �printr r r r �<module> s* � 3 �