| Server IP : 192.158.238.246 / Your IP : 3.15.22.62 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /usr/lib/python3.6/site-packages/serial/urlhandler/__pycache__/ |
Upload File : |
3
M�]W�+ �
@ s d dl Z d dlZd dlZd dlZd dlZy d dlZW n ek
rR d dljZY nX d dl m
Z
m Z m Z m
Z
ejejejejd�ZdZG dd� de
�Zedkr�d dlZed�Zejjd je�� ejjd
� ejd � ej� ejjd jej d��� ej � dS )
� N)�
SerialBase�SerialException�portNotOpenError�to_bytes)�debug�infoZwarning�error� c @ s� e Zd ZdZd:Zdd� Zdd� Zdd� Zdd� Ze dd � �Z
d;d d �Z d d!� Z d"d#� Z
d$d%� Zd<d'd(�Zd)d*� Zd+d,� Zd-d.� Ze d/d0� �Ze d1d2� �Ze d3d4� �Ze d5d6� �Zd7d8� Zd9S )=�Serialz-Serial port implementation for plain sockets.�2 �K �n � � �� �, �X � � �` � �% � K � � � � � � c C s� d| _ | jdkrtd��| jr&td��y tj| j| j�td�| _ W n: t
k
r| } z d| _ tdj | j|���W Y dd}~X nX | j � d| _| j
s�| j� | js�| j� | j� | j� 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 {}: {}T)�loggerZ_portr �is_open�socketZcreate_connection�from_urlZportstr� POLL_TIMEOUT�_socket� Exception�format�_reconfigure_portZ_dsrdtr�_update_dtr_stateZ_rtscts�_update_rts_state�reset_input_buffer�reset_output_buffer)�self�msg� r, �%/usr/lib/python3.6/protocol_socket.py�open0 s$
$z Serial.openc C s( | j dkrtd��| jr$| jjd� 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% L s
zSerial._reconfigure_portc C sP | j rL| jr<y | jjtj� | jj� W n Y nX d| _d| _ tjd� dS )z
Close portNFg333333�?)r r" Zshutdownr Z SHUT_RDWR�close�timeZsleep)r* r, r, r- r/ V s z Serial.closec C s� t j|�}|jdkr$tdj|j���y�xjt j|jd�j� D ]T\}}|dkr�tj � tj
d�| _ | j j t
|d � | j jd� q:tdj|���q:W d|j ko�d k n s�td
��W n0 tk
r� } ztd j|���W Y d d }~X 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)�urlparseZurlsplit�schemer r$ Zparse_qsZquery�itemsr1 Z basicConfigZ getLoggerr ZsetLevel�
LOGGER_LEVELSr �
ValueErrorZportZhostname)r* Zurl�partsZoption�values�er, r, r- r e s(
zSerial.from_urlc C s, | j s
t�tj| 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 st | j s
t�t� }| j}�xRt|�|k �rjyxtj� }tj| jgg g |�\}}}|sRP | jj|t|� �}|srt d��|j
|� |dk r�|tj� | 8 }|dkr�P W q t j k
r� Y q t j
k
r� } zt dj|���W Y dd}~X q tk
�r$ } z"|jtjk�rt dj|���W Y dd}~X q tj
k
�rf } z$|d tjk�rVt dj|���W Y dd}~X qX 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.
zsocket disconnectedNr zconnection failed ({})zread failed: {})r r � bytearrayZ_timeoutr; r0 r: r" Zrecvr �extendr r r r$ �OSError�errnoZEAGAIN�bytes) r* �size�readr Z
start_timeZready�_Zbufr9 r, r, r- rD � s:
$z Serial.readc C sZ | j s
t�y| jjt|�� W n2 tjk
rP } ztdj|���W Y dd}~X nX 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.
z socket connection failed: {}N)
r r r" Zsendallr r r r r$ r; )r* �datar9 r, r, r- �write� s z Serial.writec C s | j s
t�| jr | jjd� dS )z9Clear input buffer, discarding all that is in the buffer.zignored reset_input_bufferN)r r r r )r* r, r, r- r( � s zSerial.reset_input_bufferc C s | j s
t�| jr | jjd� 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"| jjdj|�� 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 jdj| j�� dS )zJSet break: Controls TXD. When active, to transmitting is
possible.z!ignored _update_break_state({!r})N)r r r$ Z _break_state)r* r, r, r- �_update_break_state� s zSerial._update_break_statec C s | j r| j jdj| j�� dS )z)Set terminal status line: Request To Sendz ignored _update_rts_state({!r})N)r r r$ Z
_rts_state)r* r, r, r- r' � s zSerial._update_rts_statec C s | j r| j jdj| j�� dS )z-Set terminal status line: Data Terminal Readyz ignored _update_dtr_state({!r})N)r r r$ Z
_dtr_state)r* r, r, r- r& � s zSerial._update_dtr_statec C s | j s
t�| jr | jjd� dS )z(Read terminal status line: Clear To Sendzreturning dummy for ctsT)r r r r )r* r, r, r- �cts� s
z
Serial.ctsc C s | j s
t�| jr | jjd� dS )z)Read terminal status line: Data Set Readyzreturning dummy for dsrT)r r r r )r* r, r, r- �dsr s
z
Serial.dsrc C s | j s
t�| jr | jjd� dS )z)Read terminal status line: Ring Indicatorzreturning dummy for riF)r r r r )r* r, r, r- �ri s
z Serial.ric C s | j s
t�| jr | jjd� dS )z)Read terminal status line: Carrier Detectzreturning dummy for cd)T)r r r r )r* r, r, r- �cd s
z Serial.cdc C s
| j j� S )z@Get the file handle of the underlying socket for use with select)r" �fileno)r* r, r, r- rO ! s z
Serial.filenoN)r r r
r r r r r r r r r r r r r r )r= )rH )�__name__�
__module__� __qualname__�__doc__Z BAUDRATESr. r% r/ r �propertyr< rD rG r( r) rI rJ r' r& rK rL rM rN rO r, r, r, r- r
* s*
1
r
�__main__zsocket://localhost:7000z{}
z write...
s hello
z read: {}
) rA r1 r: r r0 r2 � ImportErrorZ urllib.parse�parseZserial.serialutilr r r r �DEBUG�INFOZWARNINGZERRORr5 r! r
rP �sys�s�stdoutrG r$ �flushrD r/ r, r, r, r- �<module> s4