⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.24
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.9
/
site-packages
/
serial
/
__pycache__
/
View File Name :
rfc2217.cpython-39.pyc
a U Y^è ã @ sn d dl Z d dlZd dlZd dlZd dlZz d dlZW n eyR d dlmZ Y n0 z d dl Z W n eyz d dl Z Y n0 d dl Z d dl m Z mZmZmZmZmZ e je je je jdœZdZdZdZdZdZ d Z d Z d Z d Z d Z!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1d Z2d Z3d Z4d Z5d Z6d!Z7d"Z8d#Z9d$Z:d%Z;d&Z<d'Z=d(Z>d)Z?d*Z@d+ZAd,ZBd-ZCd.ZDe-e9e.e:e/e;e0e<e1e=e2e>e3e?e4e@e5eAe6eBe7eCe8eDi ZEdZFdZGdZHdZIdZJdZKd ZLd ZMd ZNd ZOd ZPd!ZQd"ZRd/ZSd0ZTd1ZUd2ZVd3ZWd4ZXd5ZYd6ZZd7Z[d8Z\d9Z]d:Z^d;Z_d<Z`d=Zad6Zbd7Zcd8Zdd9Zed:Zfd;Zgd<Zhd=ZidZjdZkdZle jmd=e jnd<e jod>e jpd;e jqd?iZresd@dA„ er t¡ D ƒƒZue jvd=e jwd>e jxd<iZyesdBdA„ ey t¡ D ƒƒZzd Z{d=Z|d<Z}dCZ~dDZdEZ€dFZG dGdH„ dHe‚ƒZƒG dIdJ„ dJe‚ƒZ„G dKdL„ dLe ƒZ…G dMdN„ dNe‚ƒZ†e‡dOkrjd dlˆZˆe…dPdQƒZ‰eˆjŠ ‹dR Œe‰¡¡ eˆjŠ ‹dS¡ e‰ ‹dT¡ e‰ ¡ eˆjŠ ‹dU Œe‰ Žd?¡¡¡ e‰ ¡ dS )Vé N)Ú SerialBaseÚSerialExceptionÚto_bytesÚ iterbytesÚportNotOpenErrorÚTimeout)ÚdebugÚinfoÚwarningÚerroró ðó ñó òó óó ôó õó öó ÷ó øó ùó úó ûó üó ýó þó ÿs ÿÿó ó ó ó ,ó ó ó ó ó ó ó ó ó ó ó eó fó gó hó ió jó kó ló mó nó oó pó ó ó ó ó ó ó é€ é@ é é é é é é é é c c s | ]\}}||fV qd S ©N© ©Ú.0ÚkÚvrH rH ú2/usr/lib/python3.9/site-packages/serial/rfc2217.pyÚ <genexpr>Ö ó rN c c s | ]\}}||fV qd S rG rH rI rH rH rM rN Ý rO Ú REQUESTEDÚACTIVEÚINACTIVEÚREALLY_INACTIVEc @ s* e Zd ZdZd dd„Zdd„ Zdd„ ZdS ) Ú TelnetOptionz@Manage a single telnet option, keeps track of DO/DONT WILL/WONT.Nc C s@ || _ || _|| _|| _|| _|| _|| _|| _d| _| | _ dS )a; Initialize option. :param connection: connection used to transmit answers :param name: a readable name for debug outputs :param send_yes: what to send when option is to be enabled. :param send_no: what to send when option is to be disabled. :param ack_yes: what to expect when remote agrees on option. :param ack_no: what to expect when remote disagrees on option. :param initial_state: options initialized with REQUESTED are tried to be enabled on startup. use INACTIVE for all others. FN) Ú connectionÚnameÚoptionÚsend_yesÚsend_noÚack_yesÚack_noÚstateÚactiveÚactivation_callback) ÚselfrU rV rW rX rY rZ r[ Z initial_stater^ rH rH rM Ú__init__î s zTelnetOption.__init__c C s dj | dS )zString for debug outputsz {o.name}:{o.active}({o.state}))Úo©Úformat©r_ rH rH rM Ú__repr__ s zTelnetOption.__repr__c C s& || j krª| jtu r4t| _d| _| jdur¨| ¡ nt| jtu r@nh| jtu r|t| _| j | j | j ¡ d| _| jdur¨| ¡ n,| jt u rš| j | j | j ¡ nt d | ¡ƒ‚nx|| jkr"| jtu rÎt| _d| _nT| jtu røt| _| j | j | j ¡ d| _n*| jtu rn | jt u rnt d | ¡ƒ‚dS )zo A DO/DONT/WILL/WONT was received for this option, update state and answer when needed. TNz option in illegal state {!r}F)rZ r\ rP rQ r] r^ rR rU Útelnet_send_optionrX rW rS rY Ú ValueErrorrc r[ ©r_ ÚcommandrH rH rM Úprocess_incoming s< z TelnetOption.process_incoming)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__r` re rj rH rH rH rM rT ë s ÿ rT c @ sL e Zd ZdZddd„Zdd„ Zdd„ Zd d „ ZeeƒZ dd d „Z dd„ Z dS )ÚTelnetSubnegotiationz” A object to handle subnegotiation of options. In this case actually sub-sub options for RFC 2217. It is used to track com port options. Nc C s4 |d u r |}|| _ || _|| _d | _|| _t| _d S rG )rU rV rW ÚvalueÚ ack_optionrR r\ )r_ rU rV rW rq rH rH rM r` 7 s z TelnetSubnegotiation.__init__c C s dj | dS )zString for debug outputs.z{sn.name}:{sn.state})Zsnrb rd rH rH rM re A s z TelnetSubnegotiation.__repr__c C sD || _ t| _| j | j| j ¡ | jjr@| jj d | j | j ¡¡ dS )zÁ Request a change of the value. a request is sent to the server. if the client needs to know if the change is performed he has to check the state of this object. zSB Requesting {} -> {!r}N) rp rP r\ rU Úrfc2217_send_subnegotiationrW Úloggerr rc rV )r_ rp rH rH rM ÚsetE s zTelnetSubnegotiation.setc C s$ | j tkrtd | j¡ƒ‚| j tkS )z{ Check if answer from server has been received. when server rejects the change, raise a ValueError. z%remote rejected value for option {!r})r\ rS rg rc rV rQ rd rH rH rM Úis_readyQ s z TelnetSubnegotiation.is_readyrE c C s: t |ƒ}| ¡ s&t d¡ | ¡ rq6qtd | j¡ƒ‚dS )z¿ Wait until the subnegotiation has been acknowledged or timeout. It can also throw a value error when the answer from the server does not match the value sent. çš™™™™™©?z%timeout while waiting for option {!r}N)r ÚexpiredÚtimeÚsleepru r rc rV )r_ ÚtimeoutZ timeout_timerrH rH rM Úwait\ s zTelnetSubnegotiation.waitc C sN | j |dt| j ƒ… kr t| _nt| _| jjrJ| jj d | j || j¡¡ dS )zŸ Check an incoming subnegotiation block. The parameter already has cut off the header like sub option number and com port option value. NzSB Answer {} -> {!r} -> {}) rp ÚlenrQ r\ rS rU rs r rc rV )r_ Ú suboptionrH rH rM Ú check_answerj s z!TelnetSubnegotiation.check_answer)N)rE ) rk rl rm rn r` re rt ru Úpropertyr] r{ r~ rH rH rH rM ro 1 s ro c s e Zd ZdZdZ‡ fdd„Zdd„ Zdd„ Zd d „ Zd d „ Z e d d„ ƒZ d=dd„Z dd„ Z dd„ Zdd„ Zdd„ Zdd„ Zd d „ Ze d d „ ƒZe d d!„ ƒZe d"d#„ ƒZe d$d%„ ƒZd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Zd.d/„ Zd0d1„ Z d>d3d4„Z d5d6„ Z d7d8„ Z d9d:„ Z d;d<„ Z!‡ Z"S )?ÚSerialz<Serial port implementation for RFC 2217 remote serial ports.)é2 éK én é† é– éÈ i, iX i° i i` iÀ i€% i K i – i á é  c sx d | _ d | _d| _d | _tdƒ| _d| _d | _d | _d| _ d| _ d| _ d | _ d | _ d | _d | _tt| ƒj|i |¤Ž d S )Nr éÿÿÿÿFrE )Ú_threadÚ_socketÚ _linestateÚ _modemstater Ú_modemstate_timeoutÚ_remote_suspend_flowÚ _write_lockrs Ú_ignore_set_control_answerÚ_poll_modem_stateÚ_network_timeoutÚ_telnet_optionsÚ_rfc2217_port_settingsÚ_rfc2217_optionsÚ _read_bufferÚsuperr€ r` )r_ ÚargsÚkwargs©Ú __class__rH rM r` ~ s zSerial.__init__c C s d| _ d| _d| _d| _| jdu r*tdƒ‚| jr8tdƒ‚z0tj| | j ¡dd| _ | j tj tjd¡ W n< ty¤ } z$d| _ td | j |¡ƒ‚W Y d}~n d}~0 0 t ¡ | _t ¡ | _t| d tttttt ƒt| d t ttttt ƒg}t| d t ttttt ƒt| d t ttttt ƒt| dt ttttt ƒt| dtttttt ƒt| dt ttttt ƒg| | _!t"| dt#t$ƒt"| dt%t&ƒt"| dt't(ƒt"| dt)t*ƒdœ| _+t"| dt,t-ƒt"| dt.t/ƒdœ| _0| j0 1| j+¡ d| _2d| _3t4dƒ| _5d| _6d| _tj7| j8d | _9| j9 :d¡ | j9 ;d | j¡¡ | j9 <¡ zÜ| j!D ]"}|j=t u r | >|j?|j@¡ q t4| jƒ}| A¡ sŽtB Cd ¡ tDd d „ |D ƒƒtDd!d „ |D ƒƒkrLqœqLtd" |¡ƒ‚| j r¸| j Ed# | j!¡¡ | F¡ | jGsÐ| H¡ | jIsà| J¡ | K¡ | L¡ W n | M¡ ‚ Y n0 dS )$zx Open port with current settings. This may throw a SerialException if the port cannot be opened. NFrE z.Port must be configured before it can be used.zPort is already open.rF )rz rD zCould not open port {}: {}ú we-BINARYú we-RFC2217ÚECHOúwe-SGAúthey-SGAú they-BINARYú they-RFC2217ÚbaudrateÚdatasizeÚparityÚstopsize)r£ r¤ r¥ r¦ ÚpurgeÚcontrol)r§ r¨ r rˆ T)Útargetz&pySerial RFC 2217 reader thread for {}rv c s s | ] }|j V qd S rG ©r] ©rJ ra rH rH rM rN Ü rO z Serial.open.<locals>.<genexpr>c s s | ]}|j tkV qd S rG )r\ rR r« rH rH rM rN Ü rO z;Remote does not seem to support RFC2217 or BINARY mode {!r}zNegotiated options: {})Nrs r r‘ r’ Z_portr Úis_openÚsocketZcreate_connectionÚfrom_urlZportstrrŠ Z setsockoptZ IPPROTO_TCPZ TCP_NODELAYÚ Exceptionrc ÚQueuer– Ú threadingÚLockr rT ÚBINARYÚWILLÚWONTÚDOÚDONTrR ÚCOM_PORT_OPTIONrP rž ÚSGAr“ ro Ú SET_BAUDRATEÚSERVER_SET_BAUDRATEÚ SET_DATASIZEÚSERVER_SET_DATASIZEÚ SET_PARITYÚSERVER_SET_PARITYÚ SET_STOPSIZEÚSERVER_SET_STOPSIZEr” Ú PURGE_DATAÚSERVER_PURGE_DATAÚ SET_CONTROLÚSERVER_SET_CONTROLr• Úupdater‹ rŒ r r rŽ ÚThreadÚ_telnet_read_loopr‰ Ú setDaemonÚsetNameÚstartr\ rf rX rW rw rx ry Úsumr Ú_reconfigure_portZ_dsrdtrÚ_update_dtr_stateÚ_rtsctsÚ_update_rts_stateÚreset_input_bufferÚreset_output_bufferÚclose)r_ ÚmsgZmandadory_optionsrW rz rH rH rM Úopen sŠ ( þûú ü þ &ÿ z Serial.openc C s” | j du rtdƒ‚| jdur$tdƒ‚d| j k r:dk sLn td | j¡ƒ‚| jd t d| j¡¡ | jd t d | j ¡¡ | jd t d t | j ¡¡ | jd t d t| j ¡¡ | j ¡ }| jrÞ| j d |¡¡ t| jƒ}| ¡ s t d¡ tdd„ |D ƒƒt|ƒkrèq*qètd |¡ƒ‚| jrD| j d |¡¡ | jr^| j r^tdƒ‚n2| jrr| t ¡ n | j r†| t ¡ n | t ¡ dS )z,Set communication parameters on opened port.Nz Can only operate on open portsz(write_timeout is currently not supportedr l zinvalid baudrate: {!r}r£ ó !Ir¤ ó !Br¥ r¦ zNegotiating settings: {}rv c s s | ] }|j V qd S rG rª r« rH rH rM rN rO z+Serial._reconfigure_port.<locals>.<genexpr>z7Remote does not accept parameter change (RFC2217): {!r}zNegotiated settings: {}z-xonxoff and rtscts together are not supported)!rŠ r Z_write_timeoutÚNotImplementedErrorZ _baudraterg rc r” rt ÚstructÚpackZ _bytesizeÚRFC2217_PARITY_MAPZ_parityÚRFC2217_STOPBIT_MAPZ _stopbitsÚvaluesrs r r r’ rw rx ry rÌ r| r rÏ Z_xonxoffÚrfc2217_set_controlÚ SET_CONTROL_USE_HW_FLOW_CONTROLÚ SET_CONTROL_USE_SW_FLOW_CONTROLÚ SET_CONTROL_USE_NO_FLOW_CONTROL)r_ Úitemsrz rH rH rM rÍ ñ s8 zSerial._reconfigure_portc C sb d| _ | jr6z | j tj¡ | j ¡ W n Y n0 | jrX| j d¡ d| _t d¡ d| _dS )z Close portFé Nç333333Ó?) r¬ rŠ Zshutdownr Z SHUT_RDWRrÓ r‰ Újoinrx ry rd rH rH rM rÓ s z Serial.closec C s* t |¡}|jdkr$td |j¡ƒ‚zÄt |jd¡ ¡ D ]Œ\}}|dkr~t ¡ t d¡| _ | j t |d ¡ | j d¡ q8|dkrŽd| _q8|d kržd| _q8|d kr¶t|d ƒ| _q8td |¡ƒ‚q8d|j krÜd k sæn td ƒ‚W n4 ty } ztd |¡ƒ‚W Y d}~n d}~0 0 |j|jfS )zu extract host and port from an URL string, other settings are extracted an stored in instance Zrfc2217zqexpected a string in the form "rfc2217://<host>:<port>[?option[&option...]]": not starting with rfc2217:// ({!r})TÚloggingzpySerial.rfc2217r zenabled loggingZign_set_controlZ poll_modemrz zunknown option: {!r}i zport not in range 0...65535zPexpected a string in the form "rfc2217://<host>:<port>[?option[&option...]]": {}N)ÚurlparseÚurlsplitÚschemer rc Úparse_qsÚqueryrâ ræ Z basicConfigZ getLoggerrs ZsetLevelÚ LOGGER_LEVELSr r r‘ Úfloatr’ rg ÚportÚhostname)r_ ÚurlÚpartsrW rÝ ÚerH rH rM r® . s< þÿ ÿÿzSerial.from_urlc C s | j s t‚| j ¡ S )z9Return the number of bytes currently in the input buffer.)r¬ r r– Úqsizerd rH rH rM Ú in_waitingS s zSerial.in_waitingrD c C s| | j s t‚tƒ }zNt| jƒ}t|ƒ|k r\| jdu r:tdƒ‚|| j d| ¡ ¡7 }| ¡ r q\q W n t j yr Y n0 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. Nz&connection failed (reader thread died)T)r¬ r Ú bytearrayr Ú_timeoutr| r‰ r r– ÚgetZ time_leftrw r° ZEmptyÚbytes)r_ ÚsizeÚdatarz rH rH rM ÚreadZ s z Serial.readc C sŠ | j s t‚| jb z | j t|ƒ tt¡¡ W n4 t j yb } zt d |¡ƒ‚W Y d}~n d}~0 0 W d ƒ n1 sx0 Y 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$connection failed (socket error): {}N)r¬ r r rŠ Úsendallr ÚreplaceÚIACÚ IAC_DOUBLEDr r r rc r| )r_ rú rò rH rH rM Úwriteo s Bz Serial.writec C s0 | j s t‚| t¡ | j ¡ r,| j d¡ qdS )z9Clear input buffer, discarding all that is in the buffer.FN)r¬ r Úrfc2217_send_purgeÚPURGE_RECEIVE_BUFFERr– ró r÷ rd rH rH rM rÑ s zSerial.reset_input_bufferc C s | j s t‚| t¡ dS )zs Clear output buffer, aborting the current output and discarding all that is in the buffer. N)r¬ r r ÚPURGE_TRANSMIT_BUFFERrd rH rH rM rÒ ˆ s zSerial.reset_output_bufferc C sL | j s t‚| jr,| j d | jr$dnd¡¡ | jr>| t¡ n | t¡ dS )z[ Set break: Controls TXD. When active, to transmitting is possible. zset BREAK to {}r] ÚinactiveN) r¬ r rs r rc Z _break_staterÞ ÚSET_CONTROL_BREAK_ONÚSET_CONTROL_BREAK_OFFrd rH rH rM Ú_update_break_state‘ s zSerial._update_break_statec C sL | j s t‚| jr,| j d | jr$dnd¡¡ | jr>| t¡ n | t¡ dS )z*Set terminal status line: Request To Send.z set RTS to {}r] r N) r¬ r rs r rc Z _rts_staterÞ ÚSET_CONTROL_RTS_ONÚSET_CONTROL_RTS_OFFrd rH rH rM rÐ Ÿ s zSerial._update_rts_statec C sL | j s t‚| jr,| j d | jr$dnd¡¡ | jr>| t¡ n | t¡ dS )z.Set terminal status line: Data Terminal Ready.z set DTR to {}r] r N) r¬ r rs r rc Z _dtr_staterÞ ÚSET_CONTROL_DTR_ONÚSET_CONTROL_DTR_OFFrd rH rH rM rÎ ª s zSerial._update_dtr_statec C s | j s t‚t| ¡ t@ ƒS )z)Read terminal status line: Clear To Send.)r¬ r ÚboolÚget_modem_stateÚMODEMSTATE_MASK_CTSrd rH rH rM Úctsµ s z Serial.ctsc C s | j s t‚t| ¡ t@ ƒS )z*Read terminal status line: Data Set Ready.)r¬ r r r ÚMODEMSTATE_MASK_DSRrd rH rH rM Údsr¼ s z Serial.dsrc C s | j s t‚t| ¡ t@ ƒS )z*Read terminal status line: Ring Indicator.)r¬ r r r ÚMODEMSTATE_MASK_RIrd rH rH rM Úrià s z Serial.ric C s | j s t‚t| ¡ t@ ƒS )z*Read terminal status line: Carrier Detect.)r¬ r r r ÚMODEMSTATE_MASK_CDrd rH rH rM ÚcdÊ s z Serial.cdc C sÈ t }d}zœ| jrŠz| j d¡}W nb tjy< Y q Y nL tjy† } z2| jrd| j d |¡¡ W Y d}~qŠW Y d}~n d}~0 0 |sqŠt |ƒD ]î}|t krÒ|t kr²t }n |durÄ||7 }n | j |¡ q˜|t krn|t kr |durø|t 7 }n | j t ¡ t }nb|tkr tƒ }t }nL|tkrB| t|ƒ¡ d}t }n*|ttttfv r^|}t}n| |¡ t }q˜|tkr˜| ||¡ t }q˜q W d| _| jrÄ| j d¡ n d| _| jrÂ| j d¡ 0 dS )zRead loop for the socket.Ni z!socket error in reader thread: {}zread thread terminated) ÚM_NORMALr¬ rŠ Zrecvr rz r rs r rc r rþ Ú M_IAC_SEENr– ZputÚSBrõ ÚSEÚ _telnet_process_subnegotiationrø r¶ r· r´ rµ Ú M_NEGOTIATEÚ_telnet_process_commandÚ_telnet_negotiate_optionr‰ )r_ Úmoder} rú rò ÚbyteÚtelnet_commandrH rH rM rÈ Ö s` $ þzSerial._telnet_read_loopc C s | j r| j d |¡¡ dS ©z1Process commands other than DO, DONT, WILL, WONT.z ignoring Telnet command: {!r}N©rs r rc rh rH rH rM r s z Serial._telnet_process_commandc C sp d}| j D ] }|j|kr | |¡ d}q |sl|tks<|tkrl| |tkrLtnt|¡ | jrl| j d |¡¡ dS ©z&Process incoming DO, DONT, WILL, WONT.FTz rejected Telnet option: {!r}N© r“ rW rj r´ r¶ rf r· rµ rs r rc ©r_ ri rW ZknownÚitemrH rH rM r s z Serial._telnet_negotiate_optionc C sZ |dd… t kr<|dd… tkr\t|ƒdkr\t|dd… ƒ| _| jrZ| j d | j¡¡ nÞ|dd… tkr²t|ƒdkr²t|dd… ƒ| _ | jr¤| j d | j ¡¡ | j d¡ nˆ|dd… t krÊd| _ np|dd… tkrâd | _ nX| j ¡ D ]2}|j|dd… krì| t|dd … ƒ¡ qVqì| jrV| j d |¡¡ n| jrV| j d |¡¡ d S ) ú;Process subnegotiation, the data between IAC SB and IAC SE.r rD rC rE zNOTIFY_LINESTATE: {}úNOTIFY_MODEMSTATE: {}rä TFNz ignoring COM_PORT_OPTION: {!r}z ignoring subnegotiation: {!r})r¸ ÚSERVER_NOTIFY_LINESTATEr| Úordr‹ rs r rc ÚSERVER_NOTIFY_MODEMSTATErŒ r ZrestartÚFLOWCONTROL_SUSPENDrŽ ÚFLOWCONTROL_RESUMEr• rÝ rq r~ rø r )r_ r} r& rH rH rM r 2 s, z%Serial._telnet_process_subnegotiationc C s6 | j | j |¡ W d ƒ n1 s(0 Y dS )zGinternal socket write with no data escaping. used to send telnet stuff.N)r rŠ rü )r_ rú rH rH rM Ú_internal_raw_writeR s zSerial._internal_raw_writec C s | t| | ¡ dS ©zSend DO, DONT, WILL, WONT.N)r. rþ ©r_ ÚactionrW rH rH rM rf W s zSerial.telnet_send_optionrO c C s2 | tt¡}| tt t | | t t ¡ dS )z%Subnegotiation of RFC2217 parameters.N)rý rþ rÿ r. r r¸ r ©r_ rW rp rH rH rM rr [ s z"Serial.rfc2217_send_subnegotiationc C s$ | j d }| |¡ | | j¡ dS )z~ Send purge request to the remote. (PURGE_RECEIVE_BUFFER / PURGE_TRANSMIT_BUFFER / PURGE_BOTH_BUFFERS) r§ N)r• rt r{ r’ ©r_ rp r& rH rH rM r ` s zSerial.rfc2217_send_purgec C s6 | j d }| |¡ | jr&t d¡ n | | j¡ dS )z)transmit change of control line to remoter¨ gš™™™™™¹?N)r• rt r rx ry r{ r’ r3 rH rH rM rÞ i s zSerial.rfc2217_set_controlc C s dS )z` check if server is ready to receive data. block for some time when not. NrH rd rH rH rM Úrfc2217_flow_server_readyu s z Serial.rfc2217_flow_server_readyc C s– | j rh| j ¡ rh| jr"| j d¡ | t¡ t| jƒ}| ¡ sVt d¡ | j ¡ s6qhq6| jrh| j d¡ | j durŠ| jr„| j d¡ | j S t dƒ‚dS )zÿ get last modem state (cached value. If value is "old", request a new one. This cache helps that we don't issue to many requests when e.g. all status lines, one after the other is queried by the user (CTS, DSR etc.) zpolling modem staterv zpoll for modem state failedNzusing cached modem statez!remote sends no NOTIFY_MODEMSTATE)r‘ r rw rs r rr ÚNOTIFY_MODEMSTATEr r’ rx ry r rŒ r )r_ rz rH rH rM r } s zSerial.get_modem_state)rD )rO )#rk rl rm rn Z BAUDRATESr` rÕ rÍ rÓ r® r rô rû r rÑ rÒ r rÐ rÎ r r r r rÈ r r r r. rf rr r rÞ r4 r Ú __classcell__rH rH rš rM r€ x sF a,% C r€ c @ sf e Zd ZdZddd„Zdd„ Zdd„ Zdd d „Zdd d„Zdd„ Z dd„ Z dd„ Z dd„ Z dd„ Z dS ) Ú PortManagerzê This class manages the state of Telnet and RFC 2217. It needs a serial instance and a connection to work with. Connection is expected to implement a (thread safe) write function, that writes the string to the network. Nc C s || _ || _|| _d| _t| _d | _d | _d| _d | _ d| _ t | dt t ttttƒt | dtt ttttƒt | dtttt ttƒt | dtt ttttƒt | dtttt ttƒt | d tt tttt| jƒ t | d tttt tt| jƒ g| _| jrè| j d ¡ | jD ] }|jtu rî| |j|j ¡ qîd S ) NFéÿ r rž rŸ r rœ r¡ r r¢ z*requesting initial Telnet/RFC 2217 options) ÚserialrU rs Ú_client_is_rfc2217r r r} r Úmodemstate_maskÚlast_modemstateÚ linstate_maskrT rž r´ rµ r¶ r· rP r¹ rR r³ r¸ Ú _client_okr“ r r\ rf rX rW )r_ Z serial_portrU rs rW rH rH rM r` « s. ù zPortManager.__init__c C s( d| _ | jr| j d¡ | jdd dS )a callback of telnet option. It gets called when option is activated. This one here is used to detect when the client agrees on RFC 2217. A flag is set so that other functions like check_modem_lines know if the client is OK. Tzclient accepts RFC 2217©Úforce_notificationN)r: rs r Úcheck_modem_linesrd rH rH rM r> Î s zPortManager._client_okc C s | j t| | ¡ dS r/ )rU r rþ r0 rH rH rM rf â s z PortManager.telnet_send_optionrO c C s4 | tt¡}| j tt t | | t t ¡ dS )z&Subnegotiation of RFC 2217 parameters.N)rý rþ rÿ rU r r r¸ r r2 rH rH rM rr æ s z'PortManager.rfc2217_send_subnegotiationFc C sÞ | j jo t| j jotB | j jo tB | j jo,tB }|| j p:dA }|t@ rN|t O }|t@ r^|t O }|t@ rn|t O }|t@ r~|t O }|| j ksŒ|rÚ| jrœ|| j@ s |rÐ| tt|| j@ gƒ¡ | jrÐ| j d |¡¡ |d@ | _ dS )z€ read control lines from serial port and compare the last value sent to remote. send updates on changes. r r( éð N)r9 r r r r r r r r r< ÚMODEMSTATE_MASK_CTS_CHANGEÚMODEMSTATE_MASK_DSR_CHANGEÚMODEMSTATE_MASK_RI_CHANGEÚMODEMSTATE_MASK_CD_CHANGEr: r; rr r+ r rs r rc )r_ r@ Z modemstateZdeltasrH rH rM rA î s4 ÿ þ ýÿþz PortManager.check_modem_linesc c s. t |ƒD ] }|tkr"tV tV q|V qdS )zû This generator function is for the user. All outgoing data has to be properly escaped, so that no IAC character in the data stream messes up the Telnet state machine in the server. socket.sendall(escape(data)) N)r rþ ©r_ rú r rH rH rM Úescape s zPortManager.escapec c s t |ƒD ]}| jtkrJ|tkr(t| _n | jdurB| j|7 _n|V q| jtkrò|tkr„| jdurv| j|7 _n|V t| _nl|tkrœtƒ | _t| _nT|tkrÂ| t | jƒ¡ d| _t| _n.|t t t tfv rà|| _t| _n| |¡ t| _q| jtkr| | j|¡ t| _qdS )aò Handle a bunch of incoming bytes. This is a generator. It will yield all characters not of interest for Telnet/RFC 2217. The idea is that the reader thread pushes data from the socket through this filter: for byte in filter(socket.recv(1024)): # do things like CR/LF conversion/whatever # and write data to the serial port serial.write(byte) (socket error handling code left as exercise for the reader) N)r r r rþ r r} r rõ r r rø r¶ r· r´ rµ r r r r rG rH rH rM Úfilter# s8 zPortManager.filterc C s | j r| j d |¡¡ dS r! r" rh rH rH rM r ^ s z#PortManager._telnet_process_commandc C sp d}| j D ] }|j|kr | |¡ d}q |sl|tks<|tkrl| |tkrLtnt|¡ | jrl| j d |¡¡ dS r# r$ r% rH rH rM r d s z$PortManager._telnet_negotiate_optionc C s$ |dd… t k r| jr*| j d |¡¡ |dd… tkrô| jj}z*t d|dd… ¡\}|dkrj|| j_W nD t y° } z,| jr”| j d |¡¡ || j_W Y d}~n0d}~0 0 | jrØ| j d |rÊd nd | jj¡¡ | t t d| jj¡¡ q |dd… tkrÊ| jj}z,t d |dd … ¡\}|dkr8|| j_W nH t y‚ } z.| jrf| j d |¡¡ || j_W Y d}~n4d}~0 0 | jr®| j d |r d nd | jj¡¡ | tt d | jj¡¡ q |dd… tkrª| jj}z2t d |dd … ¡d }|dkrt| | j_W nH t y^ } z.| jrB| j d |¡¡ || j_W Y d}~n4d}~0 0 | jrŠ| j d |r|d nd | jj¡¡ | tt d t| jj ¡¡ q |dd… tkrŠ| jj}z2t d |dd … ¡d }|dkrôt| | j_W nH t y> } z.| jr"| j d |¡¡ || j_W Y d}~n4d}~0 0 | jrj| j d |r\d nd | jj¡¡ | tt d t| jj ¡¡ q |dd… t krš|dd … t krî| jj rÆ| t t ¡ n$| jj!rÞ| t t"¡ n | t t#¡ q|dd … t#kr4d| j_ d| j_!| jr$| j d¡ | t t#¡ q|dd … t krrd| j_ | jrb| j d¡ | t t ¡ q|dd … t"kr°d| j_!| jr | j d¡ | t t"¡ q|dd … t$krÚ| jr–| j %d¡ q|dd … t&krd| j_'| jr| j d¡ | t t&¡ q|dd … t(krVd| j_'| jrF| j d¡ | t t(¡ q|dd … t)kr€| jr–| j %d ¡ q|dd … t*kr¼d| j_+| jr®| j d ¡ | t t*¡ nÚ|dd … t,krød| j_+| jrê| j d ¡ | t t,¡ nž|dd … t-kr | jr–| j %d ¡ nv|dd … t.kr\d| j_/| jrN| j d ¡ | t t.¡ n:|dd … t0k rd| j_/| jrŠ| j d!¡ | t t0¡ q |dd… t1krÂ| t2t3dgƒ¡ q |dd… t4krø| jrè| j d"¡ | j5dd# q |dd… t6kr(| jr | j d$¡ d| _7 q |dd… t8krX| jrN| j d%¡ d| _7 q |dd… t9krœt:|dd … ƒ| _;| j r| j d& | j;¡¡ q |dd… t<kràt:|dd … ƒ| _=| j r| j d' | j=¡¡ q |dd… t>krÞ|dd … t?kr0| j @¡ | jr"| j d(¡ | tAt?¡ n¬|dd … tBkrn| j C¡ | jr`| j d)¡ | tAtB¡ nn|dd … tDkr¶| j @¡ | j C¡ | jr¨| j d*¡ | tAtD¡ n&| j r| j d+ tE|dd… ƒ¡¡ n&| j r | j d, tE|dd… ƒ¡¡ n| j r | j %d- |¡¡ dS ).r' r rD z received COM_PORT_OPTION: {!r}rC rÖ é zfailed to set baud rate: {}Nz{} baud rate: {}rt r÷ r× rE zfailed to set data size: {}z{} data size: {}zfailed to set parity: {}z {} parity: {}zfailed to set stop bits: {}z{} stop bits: {}Fz changed flow control to NoneTz changed flow control to XON/XOFFz changed flow control to RTS/CTSz'requested break state - not implementedzchanged BREAK to activezchanged BREAK to inactivez%requested DTR state - not implementedzchanged DTR to activezchanged DTR to inactivez%requested RTS state - not implementedzchanged RTS to activezchanged RTS to inactivezrequest for modem stater? ZsuspendZresumezline state mask: 0x{:02x}zmodem state mask: 0x{:02x}zpurge inz purge outz purge bothzundefined PURGE_DATA: {!r}z undefined COM_PORT_OPTION: {!r}z unknown subnegotiation: {!r})Fr¸ rs r rc rº r9 r£ rÙ Úunpackrg r r rr r» rÚ r¼ Zbytesizer½ r¾ r¥ ÚRFC2217_REVERSE_PARITY_MAPr¿ rÛ rÀ ÚstopbitsÚRFC2217_REVERSE_STOPBIT_MAPrÁ rÜ rÄ Ú SET_CONTROL_REQ_FLOW_SETTINGZxonxoffrÅ rà Zrtsctsrß rá ÚSET_CONTROL_REQ_BREAK_STATEr r Zbreak_conditionr ÚSET_CONTROL_REQ_DTRr Zdtrr ÚSET_CONTROL_REQ_RTSr Zrtsr ÚNOTIFY_LINESTATEr) r r5 rA r, rŽ r- ÚSET_LINESTATE_MASKr* r= ÚSET_MODEMSTATE_MASKr; r r rÑ rà r rÒ ÚPURGE_BOTH_BUFFERSÚlist)r_ r} Zbackupr£ rò r¤ r¥ rM rH rH rM r w s\ " "þ "þ þ z*PortManager._telnet_process_subnegotiation)N)rO )F)rk rl rm rn r` r> rf rr rA rH rI r r r rH rH rH rM r7 ¤ s # $;r7 Ú__main__zrfc2217://localhost:7000r‡ z{} z write... s hello z read: {} )ræ r rÙ r± rx rç Ú ImportErrorÚ urllib.parseÚparser° Zqueuer9 Zserial.serialutilr r r r r r ÚDEBUGÚINFOZWARNINGZERRORrì r ZNOPZDMZBRKZIPZAOZAYTZECZELZGAr r´ rµ r¶ r· rþ rÿ r³ rž r¹ r¸ rº r¼ r¾ rÀ rÄ rS r5 r, r- rT rU r r» r½ r¿ rÁ rÅ r) r+ ZSERVER_FLOWCONTROL_SUSPENDZSERVER_FLOWCONTROL_RESUMEZSERVER_SET_LINESTATE_MASKZSERVER_SET_MODEMSTATE_MASKrà ZRFC2217_ANSWER_MAPrO rá rà rß rP r r rQ r r rR r r Z SET_CONTROL_REQ_FLOW_SETTING_INZ"SET_CONTROL_USE_NO_FLOW_CONTROL_INZ!SET_CONTROL_USE_SW_FLOW_CONTOL_INZ!SET_CONTROL_USE_HW_FLOW_CONTOL_INZ SET_CONTROL_USE_DCD_FLOW_CONTROLZ SET_CONTROL_USE_DTR_FLOW_CONTROLZ SET_CONTROL_USE_DSR_FLOW_CONTROLZLINESTATE_MASK_TIMEOUTZ LINESTATE_MASK_SHIFTREG_EMPTYZ LINESTATE_MASK_TRANSREG_EMPTYZLINESTATE_MASK_BREAK_DETECTZ LINESTATE_MASK_FRAMING_ERRORZLINESTATE_MASK_PARTIY_ERRORZ LINESTATE_MASK_OVERRUN_ERRORZLINESTATE_MASK_DATA_READYr r r r rF rE rD rC r r rV Z PARITY_NONEZ PARITY_ODDZ PARITY_EVENZ PARITY_MARKZ PARITY_SPACErÛ Údictrâ rL Z STOPBITS_ONEZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWOrÜ rN r r r rP rQ rR rS ÚobjectrT ro r€ r7 rk ÚsysÚsÚstdoutr rc Úflushrû rÓ rH rH rH rM Ú<module>= s6 ü ôûýFG 0