| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
o
�b2 � @ sl d Z ddlZddlZddlmZ ddlmZmZ ddlmZ ddl m
Z
ddl m Z G dd � d e e
j
�ZdS )
zB
Serial port support for Windows.
Requires PySerial and pywin32.
� N)� PARITY_NONE)� EIGHTBITS� STOPBITS_ONE)�to_bytes)�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�stopbits�timeout�xonxoff�rtsctsr r �serialReadEvent�serialWriteEvent)�_serialFactory�_serial�
flushInput� flushOutput�reactor�protocol�outQueue�closed�closedNotifies�writeInProgress� win32file�
OVERLAPPED�_overlappedRead�
win32event� CreateEvent�hEvent�_overlappedWrite�addEvent�makeConnection�_finishPortSetup)
�selfr �deviceNameOrPortNumberr 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& L s �zSerialPort._finishPortSetupc C s t �| jj�S )N)r �ClearCommErrorr r. )r' r) r) r* r, Y s zSerialPort._clearCommErrorc C s� t �| jj| jd�}t| jd |� �}| �� \}}|jrLt �
| jj � t � | jjt �
|j�| j�\}}t �| jj| jd�}| j�|t|d |� � � n| j�|� t �
| jj � t � | jjt �
d�| j�\}| _d S )Nr r )r �GetOverlappedResultr r. r r r0 r, �cbInQuer �
ResetEventr" r- r/ r � dataReceived)r' �n�firstr1 r2 r3 �bufr) r) r* r \ s. �
� � �zSerialPort.serialReadEventc C s< |r | j r
| j�|� d S d| _ t�| jj|| j� d S d S )Nr )r r �appendr � WriteFiler r. r# )r' �datar) r) r* �write| s ��zSerialPort.writec C sD z| j �d�}W n
ty d| _Y d S w t�| jj|| j� d S )Nr ) r �pop�
IndexErrorr r r= r r. r# )r' � dataToWriter) r) r* r � 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 � removeEventr r" r# r �FileDescriptor�connectionLostr �closer )r' �reasonr) r) r* rE � s
zSerialPort.connectionLostN)�__name__�
__module__� __qualname__�__doc__� connectedr r r r+ r& r, r r? r rE r) r) r) r* r s
�+
r )rK r r �serialr r r �serial.serialutilr �twisted.internetr �twisted.internet.serialportr rD r r) r) r) r* �<module> s