| Server IP : 138.197.176.125 / Your IP : 216.73.217.54 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/serial/urlhandler/__pycache__/ |
Upload File : |
U
=Y27 � @ s d dl Z d dlZd dlZd dlZd dlZz d dlZW n ek
rT d dlmZ Y nX d dl m
Z
m Z m Z m
Z
mZmZ ejejejejd�ZdZG dd� de
�Zedk�r
d dlZed�Zej�d � e�� ej�d
� e�d � e� � ej�d � e� d��� e� � dS )
� N)�
SerialBase�SerialException�to_bytes�portNotOpenError�writeTimeoutError�Timeout)�debug�infoZwarning�error� c @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Ze d d � �Z
d*dd�Z dd� Z dd� Z
dd� Zd+dd�Zdd� Zdd � Zd d � Ze d d � �Ze d!d"� �Ze d#d$� �Ze d%d&� �Zd'd(� Zd)S ),�Serialz-Serial port implementation for plain sockets.)�2 �K �n � � �� i, iX i� i i` i� i�% i K i � i � i � c
C s� d| _ | jdkrtd��| jr&td��z tj| �| j�td�| _ W n: t
k
r| } z d| _ td� | j|���W 5 d}~X Y nX | j � d� | �
� d| _| js�| �� | js�| �� | �� | �� 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.)�timeoutzCould not open port {}: {}FT)�loggerZ_portr �is_open�socketZcreate_connection�from_urlZportstr� POLL_TIMEOUT�_socket� Exception�formatZ setblocking�_reconfigure_portZ_dsrdtr�_update_dtr_stateZ_rtscts�_update_rts_state�reset_input_buffer�reset_output_buffer)�self�msg� r# �C/usr/lib/python3/dist-packages/serial/urlhandler/protocol_socket.py�open1 s&
$ z Serial.openc C s( | j dkrtd��| jr$| j�d� dS )zz Set communication parameters on opened port. For the socket://
protocol all settings are ignored!
Nz Can only operate on open portsz!ignored port configuration change)r r r r �r! r# r# r$ r O s
zSerial._reconfigure_portc C sP | j rL| jr<z | j�tj� | j�� W n Y nX d| _d| _ t�d� dS )z
Close portNFg333333�?)r r Zshutdownr Z SHUT_RDWR�close�time�sleepr& r# r# r$ r' Y s z Serial.closec
C s� t �|�}|jdkr$td�|j���z�t �|jd��� D ]T\}}|dkr~t� � t�
d�| _ | j � t
|d � | j �d� q8td�|���q8d|j kr�d k s�n td
��W n0 tk
r� } ztd �|���W 5 d }~X Y nX |j|jfS )
z(extract host and port from an URL stringr zexpected a string in the form "socket://<host>:<port>[?logging={debug|info|warning|error}]": not starting with socket:// ({!r})T�loggingzpySerial.socketr zenabled loggingzunknown option: {!r}i zport not in range 0...65535z_expected a string in the form "socket://<host>:<port>[?logging={debug|info|warning|error}]": {}N)�urlparseZurlsplitZschemer r Zparse_qsZquery�itemsr* Z basicConfigZ getLoggerr ZsetLevel�
LOGGER_LEVELSr �
ValueErrorZportZhostname)r! Zurl�partsZoption�values�er# r# r$ r h s0
�� ��zSerial.from_urlc C s, | j s
t�t�| jgg g d�\}}}t|�S )z9Return the number of bytes currently in the input buffer.r )r r �selectr �len)r! ZlrZlwZlxr# r# r$ �
in_waiting� s zSerial.in_waiting� c
C s> | j s
t�t� }t| j�}t|�|k �r6zVt�| jgg g |�� �\}}}|sRW �q6| j� |t|� �}|srt
d��|� |� W n� t k
r� } z0|j
t
jt
jt
jt
jt
jfkr�t
d�|���W 5 d}~X Y n\ tjtjfk
�r& } z4|d t
jt
jt
jt
jt
jfk�rt
d�|���W 5 d}~X Y nX |�� r�q6qt|�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.
zsocket disconnected�read failed: {}Nr )r r � bytearrayr Z_timeoutr3 r2 r � time_left�recvr �extend�OSError�errno�EAGAIN�EALREADY� EWOULDBLOCK� EINPROGRESS�EINTRr r
r �expired�bytes)r! �size�readr �ready�_Zbufr1 r# r# r$ rE � s,
" z Serial.readc
C s� | j s
t�t|�}t|� }}t| j�}|dk�r�z�| j�|�}|jrL|W S |j s�|�
� r^t �t � g | jgg |�
� �\}}}|s�t �n6|�
� dks�t�t � g | jgg d�\}}}|s�td��||d� }||8 }W n� tk
r� � Y n� tk
�r8 } z2| jtjtjtjtjtjfk�r(td�| ���W 5 d} ~ X Y nV t jk
�r� } z4| d tjtjtjtjtjfk�r|td�| ���W 5 d} ~ X Y nX |js(|�
� r(t �q(|t|� S )z� Output the given byte string over the serial port. Can block if the
connection is blocked. May raise SerialException if the connection is
closed.
r Nzwrite failed (select)zwrite failed: {})r r r r3 r Z_write_timeoutr �sendZis_non_blockingZ is_infiniterB r r2 r8 �AssertionErrorr r; r< r= r> r? r@ rA r r
)
r! �data�dZtx_lenZlengthr �nrG rF r1 r# r# r$ �write� sB
" z Serial.writec
C s� | j s
t�d}|r�t�| jgg g d�\}}}z| j�d� W q tk
r� } z0|jtjtjtj tj
tj fkrzt d�
|���W 5 d}~X Y q tjtjfk
r� } z2|d tjtjtj tj
tj fkr�t d�
|���W 5 d}~X Y qX qdS )z9Clear input buffer, discarding all that is in the buffer.Tr i r6 N)r r r2 r r9 r; r< r= r> r? r@ rA r r r
r )r! rF rG r1 r# r# r$ r � s zSerial.reset_input_bufferc C s | j s
t�| jr | j�d� dS )zs Clear output buffer, aborting the current output and
discarding all that is in the buffer.
zignored reset_output_bufferN�r r r r r& r# r# r$ r s zSerial.reset_output_buffer� �?c C s& | j s
t�| jr"| j�d�|�� dS )za Send break condition. Timed, returns to idle state after given
duration.
zignored send_break({!r})N)r r r r r )r! Zdurationr# r# r$ �
send_break s zSerial.send_breakc C s | j r| j �d�| j�� dS )zJSet break: Controls TXD. When active, to transmitting is
possible.z!ignored _update_break_state({!r})N)r r r Z _break_stater& r# r# r$ �_update_break_state s zSerial._update_break_statec C s | j r| j �d�| j�� dS )z)Set terminal status line: Request To Sendz ignored _update_rts_state({!r})N)r r r Z
_rts_stater& r# r# r$ r " s zSerial._update_rts_statec C s | j r| j �d�| j�� dS )z-Set terminal status line: Data Terminal Readyz ignored _update_dtr_state({!r})N)r r r Z
_dtr_stater& r# r# r$ r ' s zSerial._update_dtr_statec C s | j s
t�| jr | j�d� dS )z(Read terminal status line: Clear To Sendzreturning dummy for ctsTrN r& r# r# r$ �cts, s
z
Serial.ctsc C s | j s
t�| jr | j�d� dS )z)Read terminal status line: Data Set Readyzreturning dummy for dsrTrN r& r# r# r$ �dsr5 s
z
Serial.dsrc C s | j s
t�| jr | j�d� dS )z)Read terminal status line: Ring Indicatorzreturning dummy for riFrN r& r# r# r$ �ri> s
z Serial.ric C s | j s
t�| jr | j�d� dS )z)Read terminal status line: Carrier Detectzreturning dummy for cd)TrN r& r# r# r$ �cdG s
z Serial.cdc C s
| j �� S )z@Get the file handle of the underlying socket for use with select)r �filenor& r# r# r$ rV S s z
Serial.filenoN)r5 )rO )�__name__�
__module__� __qualname__�__doc__Z BAUDRATESr% r r' r �propertyr4 rE rM r r rP rQ r r rR rS rT rU rV r# r# r# r$ r + s2
)5
r �__main__zsocket://localhost:7000z{}
z write...
s hello
z read: {}
) r< r* r2 r r( r+ � ImportErrorZ urllib.parse�parseZserial.serialutilr r r r r r �DEBUG�INFOZWARNINGZERRORr- r r rW �sys�s�stdoutrM r �flushrE r' r# r# r# r$ �<module> s6 � 1