File: //lib/python3/dist-packages/serial/urlhandler/__pycache__/protocol_socket.cpython-310.pyc
o
Ȧ^_�7 � @ s d dl mZ d dlZd dlZd dlZd dlZd dlZzd dlZW n ey/ d dl m
Z Y nw d dl m Z m
Z
mZmZmZmZ ejejejejd�ZdZG dd� de �Zedkr�d dlZed �Zej � d
� e�� ej � d � e� d � e� � ej � d
� e� d��� e�!� dS dS )� )�absolute_importN)�
SerialBase�SerialException�to_bytes�PortNotOpenError�SerialTimeoutException�Timeout)�debug�info�warning�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| _ | jdu r td��| jrtd��ztj| �| j�td�| _ W n t
y9 } z d| _ td� | j|���d}~ww | j � d� | �
� d| _| jsN| �� | jsU| �� | �� | �� 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)�logger�_portr �is_open�socket�create_connection�from_url�portstr� POLL_TIMEOUT�_socket� Exception�format� setblocking�_reconfigure_port�_dsrdtr�_update_dtr_state�_rtscts�_update_rts_state�reset_input_buffer�reset_output_buffer)�self�msg� r+ �C/usr/lib/python3/dist-packages/serial/urlhandler/protocol_socket.py�open3 s*
�� z Serial.openc C s, | j du r td��| jr| j�d� dS 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" Q s
�zSerial._reconfigure_portc C sP | j r&| jr z| j�tj� | j�� W n Y d| _d| _ t�d� dS dS )z
Close portNFg333333�?)r r �shutdownr � SHUT_RDWR�close�time�sleepr. r+ r+ r, r1 [ s �z Serial.closec
C s� t �|�}|jdkrtd�|j���zHt �|jd��� D ])\}}|dkr?t� � t�
d�| _ | j � t
|d � | j �d� q td�|���d|j krTd k sYtd
�� td
��W n tym } ztd �|���d }~ww |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)�urlparse�urlsplit�schemer r �parse_qs�query�itemsr4 � basicConfig� getLoggerr �setLevel�
LOGGER_LEVELSr �
ValueError�port�hostname)r) �url�parts�option�values�er+ r+ r, r j s6
� ����� zSerial.from_urlc C s. | j st� �t�| jgg g d�\}}}t|�S )z9Return the number of bytes currently in the input buffer.r )r r �selectr �len)r) �lr�lw�lxr+ r+ r, �
in_waiting� s zSerial.in_waiting� c
C sR | j st� �t� }t| j�}t|�|k r�z-t�| jgg g |�� �\}}}|s+W t|�S | j� |t|� �}|s;t
d��|� |� W nT t yi } z |j
t
jt
jt
jt
jt
jfvr_t
d�|���W Y d}~n1d}~w tjtjfy� } z |d t
jt
jt
jt
jt
jfvr�t
d�|���W Y d}~nd}~ww |�� r� t|�S t|�|k st|�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 �_timeoutrH rG r � time_left�recvr �extend�OSError�errno�EAGAIN�EALREADY� EWOULDBLOCK� EINPROGRESS�EINTRr r r �expired�bytes)r) �size�readr �ready�_�bufrF r+ r+ r, r^ � s<
� �� ��� � z Serial.readc
C s� | j st� �t|�}t|� }}t| j�}|dkr�zT| j�|�}|jr&|W S |j sG|�
� r1t d��t � g | jgg |�
� �\}}}|sFt d��n|�
� du sOJ �t � g | jgg d�\}}}|sbtd��||d� }||8 }W nX tyu � ty� } z | jtjtjtjtjtjfvr�td�| ���W Y d} ~ n.d} ~ w t jy� } z | d tjtjtjtjtjfvr�td�| ���W Y d} ~ nd} ~ ww |js�|�
� r�t d��|dks|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 z
Write timeoutNzwrite failed (select)zwrite failed: {})r r r rH r �_write_timeoutr �send�is_non_blocking� is_infiniter[ r rG rQ r rT rU rV rW rX rY rZ r r )
r) �data�d�tx_len�lengthr �nr` r_ rF r+ r+ r, �write� sP
� �� ���� 'z Serial.writec
C s� | j st� �d}|rzt�| jgg g d�\}}}z
|r | j�d�}W nT tyI } z |jtjtjtj tj
tj fvr?t d�
|���W Y d}~n1d}~w tjtjfyu } z |d tjtjtj tj
tj fvrkt d�
|���W Y d}~nd}~ww |s
dS dS )z9Clear input buffer, discarding all that is in the buffer.Tr i rN N)r r rG r rR rT rU rV rW rX rY rZ r r r r )r) r_ r` rF r+ r+ r, r' � s* � �� ��� �zSerial.reset_input_bufferc C s& | j st� �| jr| j�d� dS 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 st� �| jr| j�d�|�� dS dS )za Send break condition. Timed, returns to idle state after given
duration.
zignored send_break({!r})N)r r r r
r )r) �durationr+ r+ r, �
send_break s
�zSerial.send_breakc C �" | j r| j �d�| j�� dS dS )zJSet break: Controls TXD. When active, to transmitting is
possible.z!ignored _update_break_state({!r})N)r r
r � _break_stater. r+ r+ r, �_update_break_state s �zSerial._update_break_statec C rp )z)Set terminal status line: Request To Sendz ignored _update_rts_state({!r})N)r r
r �
_rts_stater. r+ r+ r, r& % � �zSerial._update_rts_statec C rp )z-Set terminal status line: Data Terminal Readyz ignored _update_dtr_state({!r})N)r r
r �
_dtr_stater. r+ r+ r, r$ * rt zSerial._update_dtr_statec C �" | j st� �| jr| j�d� dS )z(Read terminal status line: Clear To Sendzreturning dummy for ctsTrl r. r+ r+ r, �cts/ �
z
Serial.ctsc C rv )z)Read terminal status line: Data Set Readyzreturning dummy for dsrTrl r. r+ r+ r, �dsr8 rx z
Serial.dsrc C rv )z)Read terminal status line: Ring Indicatorzreturning dummy for riFrl r. r+ r+ r, �riA rx z Serial.ric C rv )z)Read terminal status line: Carrier Detectzreturning dummy for cd)Trl r. r+ r+ r, �cdJ rx 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, r| V s
z
Serial.filenoN)rM )rm )�__name__�
__module__� __qualname__�__doc__� BAUDRATESr- r" r1 r �propertyrL r^ rk r' r( ro rr r& r$ rw ry rz r{ r| r+ r+ r+ r, r - s4
)5
r �__main__zsocket://localhost:7000z{}
z write...
s hello
z read: {}
)"�
__future__r rU r4 rG r r2 r5 � ImportError� urllib.parse�parse�serial.serialutilr r r r r r �DEBUG�INFO�WARNING�ERRORr> r r r} �sys�s�stdoutrk r �flushr^ r1 r+ r+ r+ r, �<module> s> � � 2
�