File: //lib/python3/dist-packages/serial/urlhandler/__pycache__/protocol_loop.cpython-38.pyc
U
wW�W�' � @ s$ d dl Z d dlZd dlZz d dlZW n ek
rD d dlmZ Y nX z d dlZW n ek
rn d dlZY nX d dl m
Z
m Z m Z m
Z
mZmZ e je je je jd�ZG dd� de
�Zedk�r d dlZed�Zej�d�e�� ej�d � e�d
� e� � ej�d �e� d ��� e� � dS )
� N)�
SerialBase�SerialException�to_bytes� iterbytes�writeTimeoutError�portNotOpenError)�debug�infoZwarning�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� 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 s. d| _ d | _d | _d| _tt| �j||� 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�| _| jdkr4td��| �| j� | � � d| _ | j
s\| � � | j sj| �
� | �� | �� 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 Z_port�from_urlZport�_reconfigure_portZ_dsrdtr�_update_dtr_stateZ_rtscts�_update_rts_state�reset_input_buffer�reset_output_buffer�r r r r �open4 s
z Serial.openc sF | j r4d| _ z| j�d � W n tjk
r2 Y nX tt| ��� d S )NF)r r �
put_nowaitZFullr r �closer' r r r r* O s z Serial.closec C sL t | jtj�r&d| j k r$dk s6n td�| j���| jrH| j�d� 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�numbersZIntegral�
ValueError�formatr r r' r r r r" X s &zSerial._reconfigure_portc
C s� t �|�}|jdkr$td�|j���zlt �|jd��� D ]T\}}|dkr~t� � t�
d�| _ | j � t
|d � | j �d� q8td�|���q8W n0 tk
r� } ztd �|���W 5 d
}~X Y nX d
S ) z(extract host and port from an URL stringZloopznexpected 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)�urlparseZurlsplitZschemer r/ Zparse_qsZquery�itemsr0 Z basicConfigZ getLoggerr ZsetLevel�
LOGGER_LEVELSr r. )r Zurl�partsZoption�values�er r r r! c s*
�� ��zSerial.from_urlc C s2 | j s
t�| jr(| j�d�| j�� �� | j�� S )z9Return the number of bytes currently in the input buffer.zin_waiting -> {:d})r r r r r/ r �qsizer' r r r �
in_waiting| s
zSerial.in_waiting� c C s� | j s
t�| jdk r.| jdkr.t�� | j }nd}t� }|dkr�| j r�z| jj| jd�}W n$ tjk
r~ | jdkrzY q�Y n X |dk r�||7 }|d8 }nq�|r8t�� |kr8| jr�| j� d� q�q8t
|�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 ��timeoutr9 z read timeout) r r Z_timeout�time� bytearrayr �get�Emptyr r �bytes)r �sizer; �data�br r r �read� s*
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| _ | jst�t|�}dt|� | j }| jdk rz|| jkrz| j}|dkrl| j slt�t |d�� |d8 }qD| j rvdS t
�t |�D ]}| j j
|| jd� q�t|�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 �?r: )r r r r �lenr, Z_write_timeoutr< �sleep�minr r r Zput)r rB Ztime_used_to_sendZ time_leftZbyter r r �write� s
z Serial.writec C sR | j s
t�| jr | j�d� z| j�� r4| j�� q W n tjk
rL Y nX dS )z9Clear input buffer, discarding all that is in the buffer.zreset_input_buffer()N�r r r r r r7 Z
get_nowaitr? r' r r r r% � s
zSerial.reset_input_bufferc C sR | j s
t�| jr | j�d� z| j�� r4| j�� q W n tjk
rL Y nX dS )zs Clear output buffer, aborting the current output and
discarding all that is in the buffer.
zreset_output_buffer()NrK r' r r r r& � s
zSerial.reset_output_bufferc C s | j r| j �d�| j�� dS )z[ Set break: Controls TXD. When active, to transmitting is
possible.
z_update_break_state({!r})N)r r r/ Z _break_stater' r r r �_update_break_state� s zSerial._update_break_statec C s | j r| j �d�| j�� dS )z)Set terminal status line: Request To Sendz'_update_rts_state({!r}) -> state of CTSN)r r r/ �
_rts_stater' r r r r$ � s zSerial._update_rts_statec C s | j r| j �d�| j�� dS )z-Set terminal status line: Data Terminal Readyz'_update_dtr_state({!r}) -> state of DSRN�r r r/ Z
_dtr_stater' r r r r# � s zSerial._update_dtr_statec C s* | j s
t�| jr$| j�d�| j�� | jS )z(Read terminal status line: Clear To SendzCTS -> state of RTS ({!r}))r r r r r/ 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})rN r' r r r �dsr� s z
Serial.dsrc C s | j s
t�| jr | j�d� dS )z)Read terminal status line: Ring Indicatorzreturning dummy for RIF�r r r r r' r r r �ri s
z Serial.ric C s | j s
t�| jr | j�d� dS )z)Read terminal status line: Carrier Detectzreturning dummy for CDTrQ r' r r r �cd s
z Serial.cd)r9 )�__name__�
__module__� __qualname__�__doc__Z BAUDRATESr r( r* r" r! �propertyr8 rD rE rF rJ r% r& rL r$ r# rO rP rR rS �
__classcell__r r r r r ' s4
!
r �__main__zloop://z{}
z write...
zhello
z read: {!r}
� ) r0 r- r< r1 � ImportErrorZ urllib.parse�parser r Zserial.serialutilr r r r r r �DEBUG�INFOZWARNINGZERRORr3 r rT �sys�s�stdoutrJ r/ �flushrD r* r r r r �<module> s6 � w