0x1949 Team - FAZEMRX - MANAGER
Edit File: 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 �