| Server IP : 138.197.176.125 / Your IP : 216.73.217.55 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
U
W[� � @ s� d Z ddlmZmZ ddlmZ ddlmZ ddlmZ ddlm Z ddl
Z
ddl Z ddl m
Z
dd lmZ G d
d � d ee
j�ZdS ) zB
Serial port support for Windows.
Requires PySerial and pywin32.
� )�division�absolute_import)� PARITY_NONE)� STOPBITS_ONE)� EIGHTBITS)�to_bytesN)�abstract)�BaseSerialPortc @ sZ e Zd ZdZdZdeeeddfdd�Zdd� Z d d
� Z
d d � Z d
d� Z dd� Z
dd� ZdS )�
SerialPortz@A serial device, acting as a transport, that uses a win32 event.� i�% r c
C s� | j |||||d || d�| _| �� | �� || _|| _g | _d| _d| _d| _ || _t
� � | _ t
�d ddd �| j _t
� � | _t
�d ddd �| j_| j�| j j| d� | j�| jj| d� | j�| � | �� d S )N)�baudrate�bytesize�parity�stopbitsZtimeout�xonxoff�rtsctsr r �serialReadEvent�serialWriteEvent)Z_serialFactory�_serialZ
flushInputZ flushOutput�reactor�protocol�outQueue�closedZclosedNotifies�writeInProgress� win32fileZ
OVERLAPPED�_overlappedRead�
win32eventZ CreateEvent�hEvent�_overlappedWriteZaddEventZmakeConnection�_finishPortSetup)
�selfr ZdeviceNameOrPortNumberr r r
r r r r � r! �C/usr/lib/python3/dist-packages/twisted/internet/_win32serialport.py�__init__! s6 �
zSerialPort.__init__c C s0 | � � \}}t�| jjt�d�| j�\}| _dS )zn
Finish setting up the serial port.
This is a separate method to facilitate testing.
r N)�_clearCommErrorr �ReadFiler � _port_handle�AllocateReadBufferr �read_buf)r �flags�comstat�rcr! r! r" r > s
�zSerialPort._finishPortSetupc C s t �| jj�S )N)r ZClearCommErrorr r& )r r! r! r" r$ J s zSerialPort._clearCommErrorc C s� t �| jj| jd�}t| jd |� �}| �� \}}|jr�t �
| jj � t � | jjt �
|j�| j�\}}t �| jj| jd�}| j�|t|d |� � � n | j�|� t �
| jj � t � | jjt �
d�| j�\}| _d S )Nr r )r ZGetOverlappedResultr r& r r r( r$ ZcbInQuer Z
ResetEventr r% r' r Z dataReceived)r �n�firstr) r* r+ Zbufr! r! r" r N s"
�
�zSerialPort.serialReadEventc C s6 |r2| j r| j�|� nd| _ t�| jj|| j� d S )Nr )r r �appendr � WriteFiler r& r )r �datar! r! r" �writeg s
zSerialPort.writec C sF z| j �d�}W n tk
r, d| _Y d S X t�| jj|| j� d S )Nr ) r �pop�
IndexErrorr r r/ r r& r )r Z dataToWriter! r! r" r p s zSerialPort.serialWriteEventc C sH | j �| jj� | j �| jj� tj�| |� | j� � | j
�|� dS )z�
Called when the serial port disconnects.
Will call C{connectionLost} on the protocol that is handling the
serial data.
N) r Z removeEventr r r r �FileDescriptor�connectionLostr �closer )r �reasonr! r! r" r5 z s
zSerialPort.connectionLostN)�__name__�
__module__� __qualname__�__doc__Z connectedr r r r# r r$ r r1 r r5 r! r! r! r" r
s �
r
)r; Z
__future__r r �serialr r r Zserial.serialutilr r r Ztwisted.internetr Ztwisted.internet.serialportr r4 r
r! r! r! r" �<module> s