3
M]Ws @ sX d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
m Z m Z m
Z
mZ G dd deZejj Zedd dkrd dlZdZdZd Zd
Zd Zd Zd
ZdZ dZ G dd deZ nZedkrG dd deZ n@edd dkrd dlZdZ G dd deZ nG dd deZ e eddZ!e edd Z"e ed d Z#e ed d Z$e ed!d
Z%e ed"dZ&e ed#d$Z'e ed%d&Z(e ed'd(Z)e ed)d*Z*e ed+e(Z+e ed,e)Z,e-ed-rej.Z.n e ed.d/Z.e ed0d1Z/ej0d2d Z1ej0d2e&Z2ej0d2e%Z3e ed3d4Z4e ed5d6Z5d7Z6G d8d9 d9e
e Z7G d:d; d;e7Z8G d N)
SerialBaseSerialExceptionto_bytesportNotOpenErrorwriteTimeoutErrorc @ s e Zd Zi Zdd Zdd ZdS )PlatformSpecificBasec C s t dd S )Nz9non-standard baudrates are not supported on this platform)NotImplementedError)selfbaudrate r !/usr/lib/python3.6/serialposix.py_set_special_baudrate. s z*PlatformSpecificBase._set_special_baudratec C s t dd S )Nz$RS485 not supported on this platform)r )r rs485_settingsr r r _set_rs485_mode1 s z$PlatformSpecificBase._set_rs485_modeN)__name__
__module__ __qualname__BAUDRATE_CONSTANTSr
r r r r r r + s r linuxl *TX i+T,@i i.T i/T c @ s` e Zd Zddddddddd d
d d d
ddddddddddddddd d d d d Zd!d" Zd#d$ Zd%S )&PlatformSpecificr r r r r
i i i i i i i i i i
i i i
i i ) r 2 K n i, iX i i i` i i% i K i i i i i i i i i@B i i` i i%& i- ig5 i = c C s t j ddgd }yXtj| jt| |d tj M < |d tO < | |d< |d< tj| jt| W n2 t k
r } zt
dj ||W Y d d }~X nX d S )Nir @ r r r z'Failed to set custom baud rate ({}): {}) arrayfcntlioctlfdTCGETS2termiosZCBAUDBOTHERTCSETS2IOError
ValueErrorformat)r r
bufer r r r
l s z&PlatformSpecific._set_special_baudratec C sF t j ddgd }ytj| jt| |d tO < |d k r|jrT|d tO < n|d t M < |jr~|d t O < n|d t M < |j
r|d t O < n|d t M < |j d k rt
|j d |d< |jd k rt
|jd |d< nd|d< tj| jt| W n2 tk
r@ } ztdj|W Y d d }~X nX d S )Nr, r r i r r z Failed to set RS485 mode: {})r. r/ r0 r1
TIOCGRS485SER_RS485_ENABLEDZloopbackSER_RS485_RX_DURING_TXZrts_level_for_txSER_RS485_RTS_ON_SENDZrts_level_for_rxSER_RS485_RTS_AFTER_SENDZdelay_before_txintZdelay_before_rx
TIOCSRS485r6 r7 r8 )r r r9 r: r r r r | s,
z PlatformSpecific._set_rs485_modeN)r r r r r
r r r r r r I sB r cygwinc @ s( e Zd Zddddddddd d
d d Zd
S )r i i i i i i
i i i
i i ) i i i i i i@B i i` i i%& i- N)r r r r r r r r r s r darwinl T c @ s6 e Zd Zej d jdZeed dkr2dd ZdS )r r .r r c C s$ t j d|g}tj| jt|d d S )Nr, r )r. r/ r0 r1 IOSSIOSPEED)r r
r9 r r r r
s z&PlatformSpecific._set_special_baudrateN) r r r osunamesplitZ osx_versionr@ r
r r r r r s c @ s e Zd ZdS )r N)r r r r r r r r s TIOCMGETiT TIOCMBISiT TIOCMBICiT TIOCMSETiT TIOCM_DTR TIOCM_RTS TIOCM_CTS TIOCM_CARr- TIOCM_RNG TIOCM_DSR TIOCM_CDTIOCM_RITIOCINQZFIONREADiT TIOCOUTQiT ITIOCSBRKi'T TIOCCBRKi(T i @c @ s e Zd ZdZdd Zd7ddZdd Zed d
Zd8d d
Z dd Z
dd Z dd Z dd Z
dd Zdd Zd9dd Zd d Zd d Zd!d" Zed#d$ Zed%d& Zed'd( Zed)d* Zed+d, Zd-d. Zd:d0d1Zd;d2d3Zd4d5 Z d6S )<Serialz Serial port class POSIX implementation. Serial port configuration is
done with termios and fcntl. Runs on Linux and many other Un*x like
systems.
c , C s| | j dkrtd| jr tdd| _y"tj| jtjtjB tj B | _W n> t
k
r } z"d| _t|j dj | j |W Y dd}~X nX y| j
dd W n2 ytj| j W n Y nX d| _ Y nX d| _y | js| j | js| j W n4 tk
r& } z|j dkrn W Y dd}~X nX | j tj \| _| _tj \| _| _tj| jtjtj tj| jtjtj dS )zo Open port with current settings. This may throw a SerialException
if the port cannot be opened.Nz.Port must be configured before it can be used.zPort is already open.zcould not open port {}: {}T) force_update ) Z_portr is_openr1 rF openZportstrO_RDWRO_NOCTTY
O_NONBLOCKOSErrorerrnor8 _reconfigure_portcloseZ_dsrdtr_update_dtr_state_rtscts_update_rts_stater6 reset_input_bufferpipepipe_abort_read_rpipe_abort_read_wpipe_abort_write_rpipe_abort_write_wr/ F_SETFL)r msgr: r r r ra sD
"( z Serial.openFc , C s~ | j dkrtdd}d }}| jdk r:d}t| jd }y"tj| j }|\}}}} }
} } W n2 tjk
r }
ztdj|
W Y dd}
~
X nX |tjtj B O }| tj
tj B tj B tj
B tjB tjB tjB M } x&d D ] }tt|r| tt| M } qW |tjtjB tjB M }|tjtjB tjB tjB M }ttd rF|tj M }ttd
r^|tj M }yttd j| j }
} W n t k
r y| j | j }
} W nt t k
r ttd }
} yt| j }W n& t k
r t d
j| j Y n X |dk rt d
j| j Y nX Y nX |tj! M }| j"dkr>|tj#O }nX| j"dkrV|tj$O }n@| j"dkrn|tj%O }n(| j"dkr|tj&O }nt dj| j"| j't(j)kr|tj* M }nD| j't(j+kr|tj*O }n*| j't(j,kr|tj*O }nt dj| j'|tj-tj.B M }| j/t(j0kr*|tj1tj2B M }n| j/t(j3krP|tj2 M }|tj1O }n| j/t(j4krp|tj1tj2B O }n| j/t(j5krt6dd dkr|tj1t7B tj2B O }nL| j/t(j8krt6dd dkr|tj1t7B O }|tj2 M }nt dj| j/ttdr2| j9r|tj:tj;B O }n|tj:tj;B tjO }n |tj> M }n,ttdr| j=r|tj?O }n |tj? M }|dk s|dkrt dj||| tj@< |dk s|dkrt dj||| tjA< |s.|||| |
| | g|krNtjB| j tjC|||| |
| | g |dk rb| jD| | jEdk rz| jF| jE dS ) z,Set communication parameters on opened port.Nz+Can only operate on a valid file descriptorr r r z Could not configure port: {}ECHOCTLECHOKEIUCLCPARMRKzB{}ZB38400zInvalid baud rate: {!r}r r r r zInvalid char len: {!r}z$Invalid stop bit specification: {!r}r zInvalid parity: {!r}IXANYCRTSCTS CNEW_RTSCTS zInvalid vmin: {!r}zInvalid vtime: {!r})rt ru )Gr1 r _inter_byte_timeoutr@ r3 tcgetattrerrorr8 ZCLOCALZCREADZICANONZECHOZECHOEZECHOKZECHONLZISIGZIEXTENhasattrgetattrZOPOSTZONLCRZOCRNLZINLCRZIGNCRZICRNLZIGNBRKrv rw Z _baudrateAttributeErrorr KeyErrorr7 ZCSIZEZ _bytesizeZCS8ZCS7ZCS6ZCS5Z _stopbitsserialZ STOPBITS_ONEZCSTOPBZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWOZINPCKZISTRIPZ_parityZ PARITY_NONEZPARENBZPARODDZ PARITY_EVENZ
PARITY_ODDZ PARITY_MARKplatCMSPARZ PARITY_SPACEZ_xonxoffZIXONZIXOFFrx rj ry rz VMINVTIME tcsetattrTCSANOWr
Z _rs485_moder )r r^ Z custom_baudvminvtime orig_attriflagoflagcflaglflagispeedospeedccrs flagr r r rg s
.
zSerial._reconfigure_portc C st | j rp| jdk rjtj| j d| _tj| j tj| j tj| j tj| j d\| _| _d\| _| _d| _ dS )z
Close portNF)NN)NN)r` r1 rF rh ro rn rq rp )r r r r rh s
z Serial.closec C s t j| jtt}tjd|d S )z9Return the number of bytes currently in the input buffer.rZ r )r/ r0 r1 rX TIOCM_zero_strstructunpack)r sr r r
in_waiting s zSerial.in_waitingr c C sX | j s
tt }| j}x6t||k rNyvtj }tj| j| jgg g |\}}}| j|krjt j
| jd P |spP t j
| j|t| }|st d|j | W n t
k
r } z,|jtjkr|jtjkrt dj|W Y dd}~X nD tjk
r( } z$|d tjkrt dj|W Y dd}~X nX |dk r|tj | 8 }|dkrP qW 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.
i zgdevice reports readiness to read but returned no data (device disconnected or multiple access on port?)zread failed: {}Nr )r` r bytearray_timeoutlentimeselectr1 rn rF readr extendre rf EAGAINZEINTRr8 r~ bytes) r sizer timeoutZ
start_timeready_r9 r: r r r r s:
z Serial.readc C s t j| jd d S )N x)rF writero )r r r r cancel_read s zSerial.cancel_readc C s t j| jd d S )Nr )rF r rq )r r r r cancel_write s zSerial.cancel_writec C s | j s
tt|}t|}| j}|r8|dkr8|tj 7 }xb|dkrytj| j|}|dkrb|S |r|dkr|tj }|dk rt t
j
| j g| jgg |\}}} |rtj | j d P |st nN|dkst
t
j
| j g| jgg d\}}} |rtj | j d P |std||d }||8 }W q< tk
r> Y q< tk
r }
z>|
jtjkrltdj|
|r|tj dk rt W Y dd}
~
X qd}t| jd }nd}t| jd }y"t j
| j}|\}}}}} }
} W n4 t j k
r } zt j
dj| W Y dd} ~ X nX |dk s|dkrtdj||| t j< || t j< t j| jt j||||| |
| g dS )z,Set communication parameters on opened port.r Nr r z Could not configure port: {}r{ zInvalid vtime: {!r})superr rg r/ r1 rr r| r@ r r3 r} r~ r r r8 r7 r r r r )
r r^ r r r r r r r r r r rs ) __class__r r rg s(
"
z VTIMESerial._reconfigure_portr c C sP | j s
tt }x6t||k rFtj| j|t| }|s:P |j| qW 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.
) r` r r r rF r r1 r r )r r r r9 r r r r s zVTIMESerial.read)T)r )r r r r rg r
__classcell__r r )r r r s r ):rf r/ rF r r sysr3 r r Zserial.serialutilr r r r r objectr platformlowerr r. r2 r5 r4 r; rA r< r> r? r= r rE r rI rJ rK rL rM rN rO rQ rR rT rV rW r rX rY packr r r r[ r\ r r] r r r r r r st
P
J#