|
Server : Apache System : Linux server.mata-lashes.com 3.10.0-1160.90.1.el7.x86_64 #1 SMP Thu May 4 15:21:22 UTC 2023 x86_64 User : matalashes ( 1004) PHP Version : 8.1.29 Disable Function : NONE Directory : /usr/local/lib/python3.6/site-packages/serial/__pycache__/ |
Upload File : |
3
F�Kd7� � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
m Z m Z m
Z
mZmZmZ G dd� de�Zd Zejj� Zedd� dkr�d dlZdZd Zd
Zd Zd Zd
Z dZ dZ dZ dZ G dd� de�Z!n�edkr�G dd� de�Z!n�edd� dk�r&d dlZdZ"G dd� de�Z!nzedd� dk�snedd � d k�snedd� d k�snedd � d k�r�G d d!� d!e�Z#G d"d� de�Z!nG d#d� de�Z!e$ed$d%�Z%e$ed&d'�Z&e$ed(d)�Z'e$ed*d+�Z(e$ed,d�Z)e$ed-d�Z*e$ed.d/�Z+e$ed0d1�Z,e$ed2d3�Z-e$ed4d5�Z.e$ed6e,�Z/e$ed7e-�Z0e1ed8��rDej2Z2n e$ed9d:�Z2e$ed;d<�Z3ej4d=d �Z5ej4d=e*�Z6ej4d=e)�Z7e$ed>d?�Z8e$ed@dA�Z9G dBdC� dCe e!�Z:G dDdE� dEe:�Z;G dFdG� dGe:�Z<dS )H� )�absolute_importN)�
SerialBase�SerialException�to_bytes�PortNotOpenError�SerialTimeoutException�Timeoutc @ s0 e Zd Zi Zdd� Zdd� Zdd� Zdd� Zd S )
�PlatformSpecificBasec C s t d��d S )Nz9non-standard baudrates are not supported on this platform)�NotImplementedError)�self�baudrate� r
�6/tmp/pip-build-8nxjc3nm/pyserial/serial/serialposix.py�_set_special_baudrate0 s z*PlatformSpecificBase._set_special_baudratec C s t d��d S )Nz$RS485 not supported on this platform)r
)r �rs485_settingsr
r
r �_set_rs485_mode3 s z$PlatformSpecificBase._set_rs485_modec C s t d��d S )Nz*Low latency not supported on this platform)r
)r �low_latency_settingsr
r
r �set_low_latency_mode6 s z)PlatformSpecificBase.set_low_latency_modec C s( | j rtj| jt� ntj| jt� dS )zS Set break: Controls TXD. When active, no transmitting is possible.
N)� _break_state�fcntl�ioctl�fd�TIOCSBRK�TIOCCBRK)r r
r
r �_update_break_state9 s z(PlatformSpecificBase._update_break_stateN)�__name__�
__module__� __qualname__�BAUDRATE_CONSTANTSr r r r r
r
r
r r - s
r � �linuxi @l *TX i+T,@i i.T i/T � � � � c @ sh e Zd Zddddddddd d
d d d
ddddddddddddddd d d d d � Zd!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��- i�g5 i = c C s� t j ddgd �}yNtj| jtj|� |r<|d dO < n|d dM < tj| jtj|� W n2 tk
r� } ztdj ||���W Y d d }~X nX d S )N�ir � r# i z1Failed to update ASYNC_LOW_LATENCY flag to {}: {}i���)
�arrayr r r �termios� TIOCGSERIAL� TIOCSSERIAL�IOError�
ValueError�format)r r �buf�er
r
r r � s z%PlatformSpecific.set_low_latency_modec 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 )Nr7 r �@ r" r* r+ z'Failed to set custom baud rate ({}): {}) r9 r r r �TCGETS2r: �CBAUD�BOTHER�TCSETS2r= r> r? )r r r@ rA r
r
r r � s z&PlatformSpecific._set_special_baudratec C sF t j ddgd �}y�tj| 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 r�t
|j d �|d< |jd k r�t
|jd �|d< nd|d< tj| jt|� W n2 tk
�r@ } ztdj|���W Y d d }~X nX d S )Nr7 r r) i� r! r" z Failed to set RS485 mode: {})r9 r r r �
TIOCGRS485�SER_RS485_ENABLEDZloopback�SER_RS485_RX_DURING_TXZrts_level_for_tx�SER_RS485_RTS_ON_SENDZrts_level_for_rx�SER_RS485_RTS_AFTER_SENDZdelay_before_tx�intZdelay_before_rx�
TIOCSRS485r= r> r? )r r r@ rA r
r
r r � s,
z PlatformSpecific._set_rs485_modeN)r r r r r r r r
r
r
r r% _ sD 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 @ sF e Zd Zej� d jd�ZdZdZe ed �dkr:dd� Z
d d
� Z d S ) r% r" �.i{t izt r r) c C s$ t j d|g�}tj| jt|d� d S )Nr7 r! )r9 r r r � IOSSIOSPEED)r r r@ r
r
r r � s z&PlatformSpecific._set_special_baudratec C s, | j rtj| jtj� ntj| jtj� dS )z[ Set break: Controls TXD. When active, no transmitting is possible.
N)r r r r r% r r )r r
r
r r � s z$PlatformSpecific._update_break_stateN) r r r �os�uname�splitZ osx_versionr r rL r r r
r
r
r r% � s r& Zbsdr( ZfreebsdZnetbsdZopenbsdc @ s e Zd Zdd� ZdS )�ReturnBaudratec C s |S )Nr
)r �keyr
r
r � __getitem__� s zReturnBaudrate.__getitem__N)r r r rW r
r
r
r rU � s rU c @ s" e Zd Ze� ZdZdZdd� ZdS )r% i{t izt c C s, | j rtj| jtj� ntj| jtj� dS )z[ Set break: Controls TXD. When active, no transmitting is possible.
N)r r r r r% r r )r r
r
r r � s z$PlatformSpecific._update_break_stateN)r r r rU r r r 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_CTSr8 � TIOCM_CARrB � TIOCM_RNG� � TIOCM_DSR� �TIOCM_CD�TIOCM_RI�TIOCINQ�FIONREADiT �TIOCOUTQiT �Ir i'T r i(T c @ s� e Zd ZdZdd� Zd7dd�Zdd� Zed d
� �Zd8d d
�Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd9d d �Zd d � Zd!d"� Zed#d$� �Zed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Zd-d.� Zd:d0d1�Zd;d2d3�Zd4d5� 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 td��d| _y"tj| jtjtjB tj B �| _W n> t
k
r� } z"d| _t|j dj | j |���W Y dd}~X nX d\| _
| _d\| _| _y�| jdd� y | js�| j� | js�| j� W n: tk
�r } z |j t jt jfk� r�� W Y dd}~X nX | j� tj� \| _
| _tj� \| _| _tj| j
tj tj � tj| jtj tj � W n� t k
�r ytj | j� W n t k
�r� Y nX d| _| jdk �r�tj | j� d| _| j
dk �r�tj | j
� d| _
| jdk �r�tj | j� d| _| jdk �rtj | j� d| _� Y nX d| _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)NN)NN) �_portr �is_openr rR �openZportstr�O_RDWR�O_NOCTTY�
O_NONBLOCK�OSError�errnor? �pipe_abort_read_r�pipe_abort_read_w�pipe_abort_write_r�pipe_abort_write_w�_reconfigure_portZ_dsrdtr�_update_dtr_state�_rtscts�_update_rts_stater= �EINVALZENOTTY�_reset_input_buffer�piper �F_SETFL�
BaseException�close� Exception)r �msgrA r
r
r rn 7 s^
"( z Serial.openFc B C s | j dkrtd��| jdk r�| jrxytj| j tjtjB � W q� tk
rt } z t|jdj | j
|���W Y dd}~X q�X ntj| j tj � d}d }}| j dk r�d}t
| j d �}y"tj| j �}|\}}} }
} } }
W n4 tjk
�r } ztdj |���W Y dd}~X nX | tjtjB O } |
tjtjB tjB tjB tjB tjB tjB M }
x*d D ]"}tt|��rN|
tt|� M }
�qNW |tj tj B tj B M }|tj tj B tj!B tj"B M }ttd
��r�|tj# M }ttd ��r�|tj$ M }yttd j | j%�� } } W n� t&k
�r� y| j'| j% } } W n� t(k
�r� y t) } } W n$ t*k
�r\ ttd
� } } Y nX yt
| j%�}W n& t+k
�r� t+dj | j%���Y n X |dk �r�t+dj | j%���Y nX Y nX | tj, M } | j-dk�r�| tj.O } nX| j-dk�r�| tj/O } n@| j-dk�r| tj0O } n(| j-dk�r&| tj1O } nt+dj | j-���| j2t3j4k�rR| tj5 M } nD| j2t3j6k�rl| tj5O } n*| j2t3j7k�r�| tj5O } nt+dj | j2���|tj8tj9B M }| j:t3j;k�r�| tj<tj=B t>B M } n�| j:t3j?k�r�| tj=t>B M } | tj<O } n�| j:t3j@k�r"| t> M } | tj<tj=B O } nj| j:t3jAk�rLt>�rL| tj<t>B tj=B O } n@| j:t3jBk�r|t>�r|| tj<t>B O } | tj= M } nt+dj | j:���ttd��r�| jC�r�|tjDtjEB O }n|tjDtjEB tjFB M }n,| jC�r�|tjDtjEB O }n|tjDtjEB M }ttd��r&| jG�r| tjHO } n | tjH M } n,ttd��rR| jG�rF| tjIO } n | tjI M } |dk �sf|dk�rtt+dj |���||
tjJ< |dk �s�|dk�r�t+dj |���||
tjK< |�s�||| |
| | |
g|k�r�tjL| j tjM||| |
| | |
g� |dk �r�| jN|� | jOdk �r| jP| jO� dS ) z,Set communication parameters on opened port.Nz+Can only operate on a valid file descriptorz&Could not exclusively lock port {}: {}r r! r+ z Could not configure port: {}�ECHOCTL�ECHOKE�IUCLC�PARMRKzB{}�B38400zInvalid baud rate: {!r}r) r( r' r zInvalid char len: {!r}z$Invalid stop bit specification: {!r}zInvalid parity: {!r}�IXANY�CRTSCTS� CNEW_RTSCTS� zInvalid vmin: {!r}zInvalid vtime: {!r})r� r� )Qr r Z
_exclusiver �flock�LOCK_EX�LOCK_NBr= rs r? rl �LOCK_UN�_inter_byte_timeoutrL r: � tcgetattr�error�CLOCAL�CREAD�ICANON�ECHO�ECHOE�ECHOK�ECHONL�ISIG�IEXTEN�hasattr�getattr�OPOST�ONLCR�OCRNL�INLCR�IGNCR�ICRNL�IGNBRKr� r� Z _baudrate�AttributeErrorr �KeyErrorrE � NameErrorr> �CSIZEZ _bytesize�CS8�CS7�CS6�CS5Z _stopbits�serialZ STOPBITS_ONE�CSTOPBZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWO�INPCK�ISTRIPZ_parityZ PARITY_NONE�PARENB�PARODD�CMSPARZ PARITY_EVENZ
PARITY_ODDZ PARITY_MARKZ PARITY_SPACEZ_xonxoff�IXON�IXOFFr� rz r� r� �VMIN�VTIME� tcsetattr�TCSANOWr Z _rs485_moder )r rk r� Z custom_baud�vmin�vtime� orig_attr�iflag�oflag�cflag�lflag�ispeed�ospeed�cc�flagr
r
r rx x 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)rm r rR r� ru rt rw rv )r r
r
r r� s
z Serial.closec C s t j| jtt�}tjd|�d S )z9Return the number of bytes currently in the input buffer.ri r )r r r rf �TIOCM_zero_str�struct�unpack)r �sr
r
r �
in_waiting! s zSerial.in_waitingr! c C s\ | j s t� �t� }t| j�}�x4t|�|k �rRy\tj| j| jgg g |j � �\}}}| j|krlt
j | jd� P |srP t
j | j|t|� �}W n� t k
r� } z2|j
t
jt
jt
jt
jt
jfkr�tdj|���W Y dd}~X nn tjk
�r, } z6|d t
jt
jt
jt
jt
jfk�r tdj|���W Y dd}~X nX |�s<td��|j|� |j� r 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.
i� zread failed: {}Nr zgdevice reports readiness to read but returned no data (device disconnected or multiple access on port?))rm r � bytearrayr �_timeout�len�selectr rt � time_leftrR �readrr rs �EAGAIN�EALREADY� EWOULDBLOCK� EINPROGRESS�EINTRr r? r� �extend�expired�bytes)r �sizer� �timeout�ready�_r@ rA r
r
r r� ) s4
"
"
z Serial.readc C s | j rtj| jd� d S )N� x)rm rR �writeru )r r
r
r � cancel_read\ s zSerial.cancel_readc C s | j rtj| jd� d S )Nr� )rm rR r� rw )r r
r
r � cancel_write` s zSerial.cancel_writec C s� | j s t� �t|�}t|� }}t| j�}�x�|dk�r�y�tj| j|�}|j rR|S |j
s�|j � rht d��t
j
| jg| jgg |j� �\}}} |r�tj| jd� P |s�t d��nP|j� dks�t�t
j
| jg| jgg d�\}}} |r�tj| jd� P |� s�td��||d� }||8 }W n� tk
�r* � Y n� tk
�rz }
z4|
jtjtjtjtjtjfk�rjtdj|
���W Y dd}
~
X nV t
jk
�r� }
z6|
d tjtjtjtjtjfk�r�tdj|
���W Y dd}
~
X nX |j r.|j � r.t d��q.W |t|� S )z2Output the given byte string over the serial port.r z
Write timeouti� Nr! zwrite failed (select)zwrite failed: {}) rm r r r� r Z_write_timeoutrR r� r Zis_non_blocking� is_infiniter� r r� rv r� r� �AssertionErrorr rr rs r� r� r� r� r� r? r� ) r �data�dZtx_len�lengthr� �n�abortr� r� rA r
r
r r� d sN
"
" z Serial.writec C s | j s t� �tj| j� dS )zb Flush of file like objects. In this case, wait until all data
is written.
N)rm r r: �tcdrainr )r r
r
r �flush� s z Serial.flushc C s t j| jt j� dS )z9Clear input buffer, discarding all that is in the buffer.N)r: �tcflushr �TCIFLUSH)r r
r
r r} � s zSerial._reset_input_bufferc C s | j s t� �| j� dS )z9Clear input buffer, discarding all that is in the buffer.N)rm r r} )r r
r
r �reset_input_buffer� s zSerial.reset_input_bufferc C s | j s t� �tj| jtj� dS )zs Clear output buffer, aborting the current output and discarding all
that is in the buffer.
N)rm r r: r� r �TCOFLUSH)r r
r
r �reset_output_buffer� s zSerial.reset_output_buffer� �?c C s& | j s t� �tj| jt|d �� dS )za Send break condition. Timed, returns to idle state after given
duration.
g �?N)rm r r: � tcsendbreakr rL )r �durationr
r
r �
send_break� s zSerial.send_breakc C s, | j rtj| jtt� ntj| jtt� dS )z)Set terminal status line: Request To SendN)Z
_rts_stater r r rY �
TIOCM_RTS_strrZ )r r
r
r r{ � s zSerial._update_rts_statec C s, | j rtj| jtt� ntj| jtt� dS )z-Set terminal status line: Data Terminal ReadyN)Z
_dtr_stater r r rY �
TIOCM_DTR_strrZ )r r
r
r ry � s zSerial._update_dtr_statec C s4 | j s t� �tj| jtt�}tjd|�d t @ dkS )z(Read terminal status line: Clear To Sendri r )
rm r r r r rX r� r� r� r^ )r r� r
r
r �cts� s z
Serial.ctsc C s4 | j s t� �tj| jtt�}tjd|�d t @ dkS )z)Read terminal status line: Data Set Readyri r )
rm r r r r rX r� r� r� rb )r r� r
r
r �dsr� s z
Serial.dsrc C s4 | j s t� �tj| jtt�}tjd|�d t @ dkS )z)Read terminal status line: Ring Indicatorri r )
rm r r r r rX r� r� r� re )r r� r
r
r �ri� s z Serial.ric C s4 | j s t� �tj| jtt�}tjd|�d t @ dkS )z)Read terminal status line: Carrier Detectri r )
rm r r r r rX r� r� r� rd )r r� r
r
r �cd� s z Serial.cdc C s t j| jtt�}tjd|�d S )z:Return the number of bytes currently in the output buffer.ri r )r r r rh r� r� r� )r r� r
r
r � out_waiting� s zSerial.out_waitingc C s | j s t� �| jS )z� For easier use of the serial port instance with select.
WARNING: this function is not portable to different platforms!
)rm r r )r r
r
r �fileno� s z
Serial.filenoTc C s6 | j s t� �|r"tj| jtj� ntj| jtj� dS )z� Manually control flow - when software flow control is enabled.
This will send XON (true) or XOFF (false) to the other device.
WARNING: this function is not portable to different platforms!
N)rm r r: �tcflowr �TCION�TCIOFF)r �enabler
r
r �set_input_flow_control� s
z Serial.set_input_flow_controlc C s6 | j s t� �|r"tj| jtj� ntj| jtj� dS )z� Manually control flow of outgoing data - when hardware or software flow
control is enabled.
WARNING: this function is not portable to different platforms!
N)rm r r: r� r �TCOON�TCOOFF)r r� r
r
r �set_output_flow_control s
z Serial.set_output_flow_controlc C s ddl }|jdt� dS )zDEPRECATED - has no user Nz0nonblocking() has no effect, already nonblocking)�warnings�warn�DeprecationWarning)r r r
r
r � nonblocking s zSerial.nonblockingN)F)r! )r� )T)T) r r r �__doc__rn rx r� �propertyr� r� r� r� r� r� r} r� r� r� r{ ry r� r� r� r� r� r� r� r r r
r
r
r rj 0 s4 A
36
rj c @ s e Zd ZdZddd�ZdS )�PosixPollSerialz� Poll based read implementation. Not all systems support poll properly.
However this one has better handling of errors, such as a device
disconnecting while it's in use (e.g. USB-serial unplugged).
r! c C sB | j s t� �t� }t| j�}tj� }|j| jtj tj
B tj B tj B � |j| j
tj tj
B tj B tj B � |dk�r:x�t|�|k �r8xR|j|jr�dn
|j� d �D ]2\}}|| j
kr�P |tj
tj B tj B @ r�td��q�W || j
kr�tj| j
d� P tj| j|t|� �}|j|� |j� �s4| jdk rt| jdkrt| rtP qtW 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 Ni� zdevice reports error (poll))rm r r� r r� r� �poll�registerr �POLLIN�POLLERR�POLLHUP�POLLNVALrt r� r� r� r rR r� r� r� r� r� )r r� r� r� r
r �eventr@ r
r
r r� & s.
""
&
zPosixPollSerial.readN)r! )r r r r r� r
r
r
r r s r c s2 e Zd ZdZd� fdd� Zd dd�Ze� Z� ZS )
� VTIMESerialab Implement timeout using vtime of tty device instead of using select.
This means that no inter character timeout can be specified and that
the error handling is degraded.
Overall timeout is disabled when inter-character timeout is used.
Note that this implementation does NOT support cancel_read(), it will
just ignore that.
Tc
s t t| �j� tj| jtjd� | jdk r>d}t| jd �}n&| jdkrRd}d}nd}t| jd �}y"t j
| j�}|\}}}}} }
} W n4 t j k
r� } zt j
dj| ���W Y dd} ~ X nX |dk s�|dkr�tdj|���|| 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 rx r r r r� rL r� r: r� r� r� r r? r> r� r� r� r� )
r rk r� r� r� r� r� r� r� r� r� r� r� )� __class__r
r rx U s.
"
z VTIMESerial._reconfigure_portr! c C sR | j s t� �t� }x6t|�|k rHtj| 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.
) rm r r� r� rR r� r r� r� )r r� r� r@ r
r
r r� s s zVTIMESerial.read)T)r! ) r r r r rx r� r r� �
__classcell__r
r
)r r r I s
r )=�
__future__r rs r rR r� r� �sysr: r� Zserial.serialutilr r r r r r �objectr r� �platform�lower�platr9 rC rF rE rG rM rH rJ rK rI r% rQ rU r� rX rY rZ r[ r\ r] r^ r_ r` rb rd re r� rf rh �packr� r� r� r r rj r r r
r
r
r �<module> s�
b r*