3
M]W% @ s" d dl Z d dlZd dlZy d dlZW n ek
rB d dljZY nX y d dlZW n ek
rl d dlZY nX d dl m
Z
m Z m Z m
Z
mZmZ e je je je jdZG dd de
Zedkr d dlZedZejjdje ejjd ejd
ej ejjd jej d ej dS )
N)
SerialBaseSerialExceptionto_bytes iterbyteswriteTimeoutErrorportNotOpenError)debuginfoZwarningerrorc s e Zd ZdZd6Z fddZdd Z fddZdd Zdd Z e
d d Z d7d d!Z d"d# Z
d$d% Zd&d' Zd(d) Zd*d+ Zd,d- Ze
d.d/ Ze
d0d1 Ze
d2d3 Ze
d4d5 Z ZS )8SerialzSSerial port implementation that simulates a loop back connection in plain software.2 K n , X ` % K c s( t t| j|| d| _d | _d | _d S )Ni )superr __init__ buffer_sizequeuelogger)selfargskwargs) __class__ #/usr/lib/python3.6/protocol_loop.pyr - s zSerial.__init__c C s~ | j rtdd| _tj| j| _| jdkr4td| j| j | j d| _ | j
s\| j | j sj| j
| j | j 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_portfrom_urlZport_reconfigure_portZ_dsrdtr_update_dtr_stateZ_rtscts_update_rts_statereset_input_bufferreset_output_buffer)r" r& r& r' open3 s
z Serial.openc sF | j r4d| _ y| jjd W n tjk
r2 Y nX tt| j d S )NF)r( r Z
put_nowaitZFullr r close)r" )r% r& r' r1 N s z Serial.closec C sR t | jtj s,d| j k o$dk n r {:d})r( r r! r r8 r qsize)r" r& r& r'
in_waiting{ s
zSerial.in_waiting c C s | j s
t| jdk r.| jdkr.tj | j }nd}t }x|dkr| j ry| jj| jd}W n" tjk
r~ | jdkrzP Y n X |dk r||7 }|d8 }nP |r:tj |kr:| jr| jj d P q:W 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 )timeoutrC z read timeout) r( r Z_timeouttime bytearrayr getEmptyr! r bytes)r" sizerD databr& r& r' read s*
z Serial.readc C st | j s
tt|}dt| | j }| jdk rH|| jkrHtj| j tx"t |D ]}| j
j || jd qRW 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.
g $@N)rD ) r( r r lenr5 Z_write_timeoutrE Zsleepr r r Zput)r" rK Ztime_used_to_sendZbyter& r& r' write s z Serial.writec C sV | j s
t| jr | jjd y x| jj r6| jj q W W n tjk
rP Y nX dS )z9Clear input buffer, discarding all that is in the buffer.zreset_input_buffer()N)r( r r! r r rA
get_nowaitrH )r" r& r& r' r. s zSerial.reset_input_bufferc C sV | j s
t| jr | jjd y x| jj r6| jj q W W n tjk
rP Y nX dS )zs Clear output buffer, aborting the current output and
discarding all that is in the buffer.
zreset_output_buffer()N)r( r r! r r rA rP rH )r" r& r& r' r/ s zSerial.reset_output_bufferc C s | j r| j jdj| j dS )z[ Set break: Controls TXD. When active, to transmitting is
possible.
z_update_break_state({!r})N)r! r r8 Z _break_state)r" r& r& r' _update_break_state s zSerial._update_break_statec C s | j r| j jdj| j dS )z)Set terminal status line: Request To Sendz'_update_rts_state({!r}) -> state of CTSN)r! r r8
_rts_state)r" r& r& r' r- s zSerial._update_rts_statec C s | j r| j jdj| j dS )z-Set terminal status line: Data Terminal Readyz'_update_dtr_state({!r}) -> state of DSRN)r! r r8
_dtr_state)r" r& r& r' r, s zSerial._update_dtr_statec C s* | j s
t| jr$| jjdj| j | jS )z(Read terminal status line: Clear To SendzCTS -> state of RTS ({!r}))r( r r! r r8 rR )r" r& r& r' cts s
z
Serial.ctsc C s | j r| j jdj| j | jS )z)Read terminal status line: Data Set ReadyzDSR -> state of DTR ({!r}))r! r r8 rS )r" r& r& r' dsr s z
Serial.dsrc C s | j s
t| jr | jjd 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 | jjd dS )z)Read terminal status line: Carrier Detectzreturning dummy for CDT)r( r r! r )r" r& r& r' cd s
z Serial.cd)r r
r r r r r r r r r r r r r r r )rC )__name__
__module__ __qualname____doc__Z BAUDRATESr r0 r1 r+ r* propertyrB rM rO r. r/ rQ r- r, rT rU rV rW
__classcell__r& r& )r% r' r ' s(
! r __main__zloop://z{}
z write...
zhello
z read: {!r}
) r9 r6 rE r: ImportErrorZ urllib.parseparser r) Zserial.serialutilr r r r r r DEBUGINFOZWARNINGZERRORr= r rX syssstdoutrO r8 flushrM r1 r& r& r& r' s4
i