|
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�Kd<O � @ s` d dl mZ d dlZd dlZd dlmZ d dlZd dlmZmZm Z m
Z
m Z G dd� de�Z dS )� )�absolute_importN)�win32)�
SerialBase�SerialException�to_bytes�PortNotOpenError�SerialTimeoutExceptionc s e Zd ZdZdKZ� fdd�Zdd� Zdd� Zdd� Zdd � Z e
d d � �Z dLd d!�Z d"d#� Z
d$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Ze
d2d3� �Ze
d4d5� �Ze
d6d7� �Ze
d8d9� �ZdMd<d=�ZdNd?d@�Ze
dAdB� �ZdCdD� Z dEdF� Z dGdH� Z e j j!dIdJ� �Z � Z"S )O�Serialz5Serial port implementation for Win32 based on ctypes.�2 �K �n � � �� �, �X � � �` � �% � K � � � � � � c s( d | _ d | _d | _tt| �j||� d S )N)� _port_handle�_overlapped_read�_overlapped_write�superr �__init__)�self�args�kwargs)� __class__� �6/tmp/pip-build-8nxjc3nm/pyserial/serial/serialwin32.pyr s zSerial.__init__c C s� | j dkrtd��| jr td��| j}y.|j� jd�rRt|dd� �dkrRd| }W n tk
rh Y nX tj |tj
tj B ddtj tj
tjB d�| _| jtjkr�d| _td j| jtj� ���y�tj� | _tjdd
dd�| j_tj� | _tjdddd�| j_tj| jd d � tj� | _ tj | jtj | j �� | j � tj | jtj!tj"B tj#B tj$B � W n. y | j%� W n Y nX d| _� Y nX d | _dS )
zx 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.ZCOM� � z\\.\r z could not open port {!r}: {!r}� i T)&Z_portr �is_open�name�upper�
startswith�int�
ValueErrorr Z
CreateFileZ GENERIC_READZ
GENERIC_WRITEZ
OPEN_EXISTING�FILE_ATTRIBUTE_NORMALZFILE_FLAG_OVERLAPPEDr ZINVALID_HANDLE_VALUE�formatZportstr�ctypes�WinErrorZ
OVERLAPPEDr Z CreateEvent�hEventr � SetupComm� COMMTIMEOUTS� _orgTimeoutsZGetCommTimeouts�byref�_reconfigure_port� PurgeComm�
PURGE_TXCLEAR�
PURGE_TXABORT�
PURGE_RXCLEAR�
PURGE_RXABORT�_close)r �portr$ r$ r% �open# sR
"
z Serial.openc C s� | j std��tj� }| jdkr"n*| jdkr6tj|_ntt| jd �d�|_ | jdkrv| j
dk rvtt| j
d �d�|_| j dkr�n*| j dkr�tj|_ ntt| j d �d�|_ tj
| j tj|�� tj| j tj� tj� }tj| j tj|�� | j|_| jtjk�r
d|_nR| jtjk�r d|_n<| jtjk�r6d|_n&| jtj k�rLd |_nt d
j | j���| j tj k�rztj!|_"d|_#n�| j tj$k�r�tj%|_"d|_#nj| j tj&k�r�tj'|_"d|_#nL| j tj(k�r�tj)|_"d|_#n.| j tj*k�r�tj+|_"d|_#nt d j | j ���| j,tj-k�rtj.|_/n@| j,tj0k�r2tj1|_/n(| j,tj2k�rJtj3|_/nt d j | j,���d|_4| j5dk�r�| j6�r~tj7|_8n| j9�r�tj:ntj;|_8| j6|_<n�| j5j=�s�t d
j | j5j=���| j5j>�r�t dj | j5j>���| j5j?dk �r�t dj | j5j?���| j5j@dk �rt dj | j5j@���| j5jA�r2t dj | j5jA���tjB|_8d|_<| jC�rRtjD|_En| jF�r`tjGntjH|_E| jC|_I| jJ|_K| jJ|_Ld|_Md|_Nd|_OtjP|_QtjR|_StjT| j tj|���s�tdj tjU� ���dS )z,Set communication parameters on opened port.z'Can only operate on a valid port handleNr i� r( � � � r' z%Unsupported number of data bits: {!r}z Unsupported parity mode: {!r}z%Unsupported number of stop bits: {!r}zQUnsupported value for RS485Settings.rts_level_for_tx: {!r} (only True is allowed)zRUnsupported value for RS485Settings.rts_level_for_rx: {!r} (only False is allowed)zPUnsupported value for RS485Settings.delay_before_tx: {!r} (only None is allowed)zPUnsupported value for RS485Settings.delay_before_rx: {!r} (only None is allowed)zJUnsupported value for RS485Settings.loopback: {!r} (only False is allowed)zCCannot configure port, something went wrong. Original message: {!r})Vr r r r5 �_timeoutZMAXDWORDZReadIntervalTimeout�maxr- ZReadTotalTimeoutConstantZ_inter_byte_timeout�_write_timeoutZWriteTotalTimeoutConstant�SetCommTimeoutsr1 r7 Z SetCommMaskZEV_ERRZDCBZ GetCommStateZ _baudrateZBaudRateZ _bytesize�serialZFIVEBITSZByteSizeZSIXBITSZ SEVENBITSZ EIGHTBITSr. r0 Z_parityZ PARITY_NONEZNOPARITYZParityZfParityZ PARITY_EVENZ
EVENPARITYZ
PARITY_ODDZ ODDPARITYZ PARITY_MARKZ
MARKPARITYZ PARITY_SPACEZ SPACEPARITYZ _stopbitsZ STOPBITS_ONEZ
ONESTOPBITZStopBitsZSTOPBITS_ONE_POINT_FIVEZ ONE5STOPBITSZ STOPBITS_TWOZ TWOSTOPBITSZfBinaryZ _rs485_modeZ_rtsctsZRTS_CONTROL_HANDSHAKEZ fRtsControl�
_rts_stateZRTS_CONTROL_ENABLEZRTS_CONTROL_DISABLEZ fOutxCtsFlowZrts_level_for_txZrts_level_for_rxZdelay_before_txZdelay_before_rxZloopbackZRTS_CONTROL_TOGGLEZ_dsrdtrZDTR_CONTROL_HANDSHAKEZ fDtrControl�
_dtr_stateZDTR_CONTROL_ENABLEZDTR_CONTROL_DISABLEZ fOutxDsrFlowZ_xonxoffZfOutXZfInXZfNullZ
fErrorCharZ
fAbortOnErrorZXONZXonCharZXOFFZXoffCharZ SetCommStater2 )r ZtimeoutsZcomDCBr$ r$ r% r8 d s�
zSerial._reconfigure_portc C s| | j dk rxtj| j | j� | jdk r@| j� tj| jj� d| _| jdk rf| j � tj| jj� d| _tj| j � d| _ dS )zinternal close port helperN)
r r rG r6 r � cancel_readZ CloseHandler3 r � cancel_write)r r$ r$ r% r> � s
z
Serial._closec C s | j r| j� d| _ dS )z
Close portFN)r) r> )r r$ r$ r% �close� s z Serial.closec C sD t j� }t j� }t j| jtj|�tj|��s>tdjtj � ���|j
S )z9Return the number of bytes currently in the input buffer.z ClearCommError failed ({!r})) r �DWORD�COMSTAT�ClearCommErrorr r1 r7 r r0 r2 �cbInQue)r �flags�comstatr$ r$ r% �
in_waiting� s
zSerial.in_waitingr( c
C sV | j s t� �|dk�rHtj| jj� tj� }tj� }tj| j t
j |�t
j |��sbt dj
t
j� ���| jdkrxt|j|�n|}|dk�r@t
j|�}tj� }tj| j ||t
j |�t
j | j��}| r�tj� tjtjfkr�t dj
t
j� ���tj| j t
j | j�t
j |�d�}|�s.tj� tjk�r.t dj
t
j� ���|jd|j� } nt� } nt� } 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 z ClearCommError failed ({!r})zReadFile failed ({!r})Tz!GetOverlappedResult failed ({!r})N) r) r r Z
ResetEventr r3 rN rO rP r r1 r7 r r0 r2 �timeout�minrQ �create_string_bufferZReadFile� GetLastError�
ERROR_SUCCESS�ERROR_IO_PENDING�GetOverlappedResult�ERROR_OPERATION_ABORTED�raw�value�bytes)
r �sizerR rS �n�buf�rc�read_okZ result_ok�readr$ r$ r% re s@
z Serial.readc C s" | j s t� �t|�}|�rtj� }tj| j|t|�tj |�| j
�}| j dkr�| rxtj � tj
tjfkrxtdjtj� ���tj| j| j
tj |�d� tj � tjkr�|jS |jt|�kr�td��|jS |r�tj
ntj � }|tjtjtjfkr�dS |tj
tjfk�rt|�S tdjtj� ���ndS dS )z2Output the given byte string over the serial port.r zWriteFile failed ({!r})Tz
Write timeoutN)r) r r r rN Z WriteFiler �lenr1 r7 r rF rX rY rZ r r0 r2 r[ r\ r^ r ZERROR_INVALID_USER_BUFFERZERROR_NOT_ENOUGH_MEMORY)r �datara �success� errorcoder$ r$ r% �write/ s.
z Serial.writec C s x| j rtjd� qW dS )zb Flush of file like objects. In this case, wait until all data
is written.
g�������?N)� out_waiting�time�sleep)r r$ r$ r% �flushT s z Serial.flushc C s& | j s t� �tj| jtjtjB � dS )z9Clear input buffer, discarding all that is in the buffer.N)r) r r r9 r r< r= )r r$ r$ r% �reset_input_buffer_ s zSerial.reset_input_bufferc C s& | j s t� �tj| jtjtjB � dS )zs Clear output buffer, aborting the current output and discarding all
that is in the buffer.
N)r) r r r9 r r: r; )r r$ r$ r% �reset_output_buffere s zSerial.reset_output_bufferc C s0 | j s t� �| jr tj| j� n tj| j� dS )zBSet break: Controls TXD. When active, to transmitting is possible.N)r) r Z _break_stater Z SetCommBreakr ZClearCommBreak)r r$ r$ r% �_update_break_staten s
zSerial._update_break_statec C s, | j rtj| jtj� ntj| jtj� dS )z)Set terminal status line: Request To SendN)rI r �EscapeCommFunctionr ZSETRTSZCLRRTS)r r$ r$ r% �_update_rts_statew s zSerial._update_rts_statec C s, | j rtj| jtj� ntj| jtj� dS )z-Set terminal status line: Data Terminal ReadyN)rJ r rr r ZSETDTRZCLRDTR)r r$ r$ r% �_update_dtr_state~ s zSerial._update_dtr_statec C s. | j s t� �tj� }tj| jtj|�� |jS )N) r) r r rN ZGetCommModemStatusr r1 r7 r^ )r �statr$ r$ r% �_GetCommModemStatus� s
zSerial._GetCommModemStatusc C s t j| j� @ dkS )z(Read terminal status line: Clear To Sendr )r Z MS_CTS_ONrv )r r$ r$ r% �cts� s z
Serial.ctsc C s t j| j� @ dkS )z)Read terminal status line: Data Set Readyr )r Z MS_DSR_ONrv )r r$ r$ r% �dsr� s z
Serial.dsrc C s t j| j� @ dkS )z)Read terminal status line: Ring Indicatorr )r Z
MS_RING_ONrv )r r$ r$ r% �ri� s z Serial.ric C s t j| j� @ dkS )z)Read terminal status line: Carrier Detectr )r Z
MS_RLSD_ONrv )r r$ r$ r% �cd� s z Serial.cd� Nc C s |dkr |}t j| j||� dS )z� Recommend a buffer size to the driver (device driver can ignore this
value). Must be called after the port is opened.
N)r r4 r )r Zrx_sizeZtx_sizer$ r$ r% �set_buffer_size� s zSerial.set_buffer_sizeTc C s6 | j s t� �|r"tj| jtj� ntj| jtj� dS )a* Manually control flow - when software flow control is enabled.
This will do the same as if XON (true) or XOFF (false) are received
from the other device and control the transmission accordingly.
WARNING: this function is not portable to different platforms!
N)r) r r rr r ZSETXONZSETXOFF)r �enabler$ r$ r% �set_output_flow_control� s
z Serial.set_output_flow_controlc C sD t j� }t j� }t j| jtj|�tj|��s>tdjtj � ���|j
S )z0Return how many bytes the in the outgoing bufferz ClearCommError failed ({!r})) r rN rO rP r r1 r7 r r0 r2 ZcbOutQue)r rR rS r$ r$ r% rk � s
zSerial.out_waitingc C sR t j� }t j| jtj|�tj|�d�}| rNt j� t jt jfkrNt j | j|� dS )zACancel a blocking read operation, may be called from other threadFN)
r rN r[ r r1 r7 rX rZ ZERROR_IO_INCOMPLETEZ
CancelIoEx)r Z
overlappedrc �errr$ r$ r% �_cancel_overlapped_io� s z Serial._cancel_overlapped_ioc C s | j | j� dS )zACancel a blocking read operation, may be called from other threadN)r� r )r r$ r$ r% rK � s zSerial.cancel_readc C s | j | j� dS )zBCancel a blocking write operation, may be called from other threadN)r� r )r r$ r$ r% rL � s zSerial.cancel_writec C s2 |dk r | r t dj|���ntjjj| |� dS )z$Change the exclusive access setting.Nz.win32 only supports exclusive access (not: {}))r. r0 rH r � exclusive�__set__)r r� r$ r$ r% r� � s zSerial.exclusive)r
r r r
r r r r r r r r r r r r r )r( )r{ N)T)#�__name__�
__module__� __qualname__�__doc__Z BAUDRATESr r@ r8 r> rM �propertyrT re rj rn ro rp rq rs rt rv rw rx ry rz r| r~ rk r� rK rL r r� �setter�
__classcell__r$ r$ )r# r% r s< A
)%
r )
�
__future__r r1 rl rH r Zserial.serialutilr r r r r r r$ r$ r$ r% �<module> s