File: //lib/python3/dist-packages/serial/urlhandler/__pycache__/protocol_loop.cpython-310.pyc
o
��a_) � @ s. d dl mZ d dlZd dlZd dlZzd dlZW n ey' d dlmZ Y nw zd dl Z W n
ey; d dl
Z Y nw d dl m Z m
Z
mZmZmZmZ ejejejejd�ZG dd� de �Zedkr�d dlZed�Zej� d � e�� ej� d
� e� d � e� � ej� d � e� d
��� e� � dS dS )� )�absolute_importN)�
SerialBase�SerialException�to_bytes� iterbytes�SerialTimeoutException�PortNotOpenError)�debug�info�warning�errorc s� e Zd ZdZdZ� fdd�Zdd� Z� fdd�Zd d
� Zd d � Z e
d
d� �Z d,dd�Z dd� Z
dd� Zdd� Zdd� Zdd� Ze
d d � �Zd d � Zd d!� Zd"d#� Ze
d$d%� �Ze
d&d'� �Ze
d(d)� �Ze
d*d+� �Z� ZS )-�SerialzSSerial port implementation that simulates a loop back connection in plain software.)�2 �K �n � � �� i, iX i� i i` i� i�% i K i � i � i � c s2 d| _ d | _d | _d| _tt| �j|i |�� d S )Ni F)� buffer_size�queue�logger�
_cancel_write�superr
�__init__)�self�args�kwargs�� __class__� �A/usr/lib/python3/dist-packages/serial/urlhandler/protocol_loop.pyr / s
zSerial.__init__c C s~ | j rtd��d| _t�| j�| _| jdu rtd��| �| j� | � � d| _ | j
s.| � � | j s5| �
� | �� | �� dS )zx Open port with current settings. This may throw a SerialException
if the port cannot be opened.
zPort is already open.Nz.Port must be configured before it can be used.T)�is_openr r r �Queuer �_port�from_url�port�_reconfigure_port�_dsrdtr�_update_dtr_state�_rtscts�_update_rts_state�reset_input_buffer�reset_output_buffer�r r r r �open6 s
z Serial.openc sD | j rd| _ z| j�d � W n
tjy Y nw tt| ��� d S )NF)r! r �
put_nowait�Fullr r
�closer- r r r r1 Q s �z Serial.closec C sP t | jtj�rd| j k rdk sn td�| j���| jr&| j�d� dS dS )zx Set communication parameters on opened port. For the loop://
protocol all settings are ignored!
r l zinvalid baudrate: {!r}z_reconfigure_port()N)�
isinstance� _baudrate�numbers�Integral�
ValueError�formatr r
r- r r r r& Z s
&�zSerial._reconfigure_portc
C s� t �|�}|jdkrtd�|j���z6t �|jd��� D ])\}}|dkr?t� � t�
d�| _ | j � t
|d � | j �d� q td�|���W d
S ty[ } ztd �|���d
}~ww ) z(extract host and port from an URL string�loopznexpected a string in the form "loop://[?logging={debug|info|warning|error}]": not starting with loop:// ({!r})T�loggingz
pySerial.loopr zenabled loggingzunknown option: {!r}zPexpected a string in the form "loop://[?logging={debug|info|warning|error}]": {}N)�urlparse�urlsplit�schemer r7 �parse_qs�query�itemsr9 � basicConfig� getLoggerr �setLevel�
LOGGER_LEVELSr r6 )r �url�parts�option�values�er r r r$ e s,
� ����zSerial.from_urlc C �4 | j st� �| jr| j�d�| j�� �� | j�� S )z9Return the number of bytes currently in the input buffer.zin_waiting -> {:d}�r! r r r r7 r �qsizer- r r r �
in_waiting~ �
zSerial.in_waiting� c C s� | j st� �| jdur| jdkrt�� | j }nd}t� }|dkrr| j rrz
| jj| jd�}W n tjyB | jdkr@Y t
|�S Y nw |durP||7 }|d8 }n t
|�S |rkt�� |krk| jrf| j� d� t
|�S |dkrr| j s$t
|�S )z� Read size bytes from the serial port. If a timeout is set it may
return less characters as requested. With no timeout it will block
until the requested number of bytes is read.
Nr ��timeoutrN z read timeout) r! r �_timeout�time� bytearrayr �get�Emptyr r
�bytes)r �sizerP �data�br r r �read� s6
��
� �z Serial.readc C s | j �d � d S )N)r r/ r- r r r � cancel_read� s zSerial.cancel_readc C s
d| _ d S )NT)r r- r r r � cancel_write� s
zSerial.cancel_writec C s� d| _ | js t� �t|�}dt|� | j }| jdurF|| jkrF| j}|dkr=| j s=t�t |d�� |d8 }|dkr=| j r*| j rBdS t
d��t |�D ] }| j j
|| jd� qJt|�S )z� Output the given byte string over the serial port. Can block if the
connection is blocked. May raise SerialException if the connection is
closed.
Fg $@Nr g �?z
Write timeoutrO )r r! r r �lenr3 �_write_timeoutrR �sleep�minr r r �put)r rX �time_used_to_send� time_left�byter r r �write� s" � z Serial.writec C �` | j st� �| jr| j�d� z| j�� r"| j�� | j�� sW dS W dS tjy/ Y dS w )z9Clear input buffer, discarding all that is in the buffer.zreset_input_buffer()N�r! r r r
r rK �
get_nowaitrU r- r r r r+ � s
��zSerial.reset_input_bufferc C rf )zs Clear output buffer, aborting the current output and
discarding all that is in the buffer.
zreset_output_buffer()Nrg r- r r r r, � s
��zSerial.reset_output_bufferc C rI )z0Return how many bytes the in the outgoing bufferzout_waiting -> {:d}rJ r- r r r � out_waiting� rM zSerial.out_waitingc C �" | j r| j �d�| j�� dS dS )z[ Set break: Controls TXD. When active, to transmitting is
possible.
z_update_break_state({!r})N)r r
r7 � _break_stater- r r r �_update_break_state� s �zSerial._update_break_statec C rj )z)Set terminal status line: Request To Sendz'_update_rts_state({!r}) -> state of CTSN)r r
r7 �
_rts_stater- r r r r* � � �zSerial._update_rts_statec C rj )z-Set terminal status line: Data Terminal Readyz'_update_dtr_state({!r}) -> state of DSRN�r r
r7 �
_dtr_stater- r r r r( � rn zSerial._update_dtr_statec C s, | j st� �| jr| j�d�| j�� | jS )z(Read terminal status line: Clear To SendzCTS -> state of RTS ({!r}))r! r r r
r7 rm r- r r r �cts s
z
Serial.ctsc C s | j r
| j �d�| j�� | jS )z)Read terminal status line: Data Set ReadyzDSR -> state of DTR ({!r})ro r- r r r �dsr s z
Serial.dsrc C �" | j st� �| jr| j�d� dS )z)Read terminal status line: Ring Indicatorzreturning dummy for RIF�r! r r r
r- r r r �ri �
z Serial.ric C rs )z)Read terminal status line: Carrier Detectzreturning dummy for CDTrt r- r r r �cd rv z Serial.cd)rN )�__name__�
__module__� __qualname__�__doc__� BAUDRATESr r. r1 r& r$ �propertyrL rZ r[ r\ re r+ r, ri rl r* r( rq rr ru rw �
__classcell__r r r r r
) s:
!
r
�__main__zloop://z{}
z write...
zhello
z read: {!r}
� )!�
__future__r r9 r4 rR r: � ImportError� urllib.parse�parser r" �serial.serialutilr r r r r r �DEBUG�INFO�WARNING�ERRORrC r
rx �sys�s�stdoutre r7 �flushrZ r1 r r r r �<module> sB � � �
�