Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/serial/urlhandler/__pycache__/protocol_socket.cpython-39.pyc
Ðазад
a ]�h�7 � @ s d dl mZ d dlZd dlZd dlZd dlZd dlZz d dlZW n ey^ d dl m Z Y n0 d dl m Z m Z mZmZmZmZ ejejejejd�ZdZG dd� de �Zedk�rd dlZed �Zej � d � e�� ej � d � e� d � e� � ej � d � e� d��� e�!� 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 rtd��| jr&td��z tj| �| j�td�| _ W n< t y~ } z$d| _ td� | j|���W Y d}~n d}~0 0 | 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�socket�create_connection�from_urlZportstr� POLL_TIMEOUT�_socket� Exception�format� setblocking�_reconfigure_portZ_dsrdtr�_update_dtr_stateZ_rtscts�_update_rts_state�reset_input_buffer�reset_output_buffer)�self�msg� r' ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/serial/urlhandler/protocol_socket.py�open3 s& ( z Serial.openc C s( | j du rtd��| 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 Q s zSerial._reconfigure_portc C sP | j rL| jr<z | j�tj� | j�� W n Y n0 d| _d| _ t�d� dS )z Close portNFg333333�?)r r �shutdownr � SHUT_RDWR�close�time�sleepr* r' r' r( r- [ 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 n2 ty� } ztd �|���W Y d }~n d }~0 0 |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�itemsr0 � basicConfig� getLoggerr �setLevel� LOGGER_LEVELSr � ValueError�port�hostname)r% �url�parts�option�values�er' r' r( r j 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% �lrZlw�lxr' r' r( � in_waiting� s zSerial.in_waiting� c C sD | j s t� �t� }t| j�}t|�|k �r<zVt�| jgg g |�� �\}}}|sTW �q<| j� |t|� �}|stt d��|� |� W n� t y� } z8|j t jt jt jt jt jfvr�t d�|���W Y d}~nfd}~0 tjtjf�y, } z<|d t jt jt jt jt jfv�rt d�|���W Y d}~n d}~0 0 |�� r �q<q 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 disconnected�read failed: {}Nr )r r � bytearrayr �_timeoutrD rC r � time_left�recvr �extend�OSError�errno�EAGAIN�EALREADY� EWOULDBLOCK� EINPROGRESS�EINTRr r r �expired�bytes)r% �size�readr �ready�_�bufrB r' r' r( rY � s, ""$z Serial.readc C s� | j s t� �t|�}t|� }}t| j�}|dk�r�z�| j�|�}|jrN|W S |j s�|� � rdt d��t � g | jgg |� � �\}}}|s�t d��n6|� � du s�J �t � g | jgg d�\}}}|s�td��||d� }||8 }W n� ty� � Y n� t�yB } z:| jtjtjtjtjtjfv�r.td�| ���W Y d} ~ n`d} ~ 0 t j�y� } z<| d tjtjtjtjtjfv�r�td�| ���W Y d} ~ n d} ~ 0 0 |js*|� � r*t d��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 z Write timeoutNzwrite failed (select)zwrite failed: {})r r r rD r Z_write_timeoutr �sendZis_non_blocking� is_infiniterV r rC rL r rO rP rQ rR rS rT rU r r ) r% �data�dZtx_len�lengthr �nr[ rZ rB r' r' r( �write� sB ""$ z Serial.writec C s� | j s t� �d}|r�t�| jgg g d�\}}}z|r@| j�d�}W q ty� } z8|jtjtjtj tj tj fvr~t d� |���W Y d}~qd}~0 tjtjfy� } z:|d tjtjtj tj tj fvr�t d� |���W Y d}~qd}~0 0 qdS )z9Clear input buffer, discarding all that is in the buffer.Tr i rI N)r r rC r rM rO rP rQ rR rS rT rU r r r r )r% rZ r[ rB 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% �durationr' 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 ctsTrd 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 dsrTrd r* r' r' r( �dsr8 s z Serial.dsrc C s" | j s t� �| jr | j�d� dS )z)Read terminal status line: Ring Indicatorzreturning dummy for riFrd r* r' r' r( �riA s z Serial.ric C s" | j s t� �| jr | j�d� dS )z)Read terminal status line: Carrier Detectzreturning dummy for cd)Trd r* r' r' r( �cdJ 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( rm V s z Serial.filenoN)rH )re )�__name__� __module__� __qualname__�__doc__Z BAUDRATESr) r r- r �propertyrG rY rc r# r$ rg rh r" r! ri rj rk rl rm r' r' r' r( r - s2 )5 r �__main__zsocket://localhost:7000z{} z write... s hello z read: {} )"� __future__r rP r0 rC r r. r1 � ImportError� urllib.parse�parseZserial.serialutilr r r r r r �DEBUG�INFO�WARNING�ERRORr: r r rn �sys�s�stdoutrc r �flushrY r- r' r' r' r( �<module> s8 � 2
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка