⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.30
Server IP:
45.79.8.107
Server:
Linux localhost 5.15.0-140-generic #150-Ubuntu SMP Sat Apr 12 06:00:09 UTC 2025 x86_64
Server Software:
nginx/1.18.0
PHP Version:
8.1.2-1ubuntu2.21
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
serial
/
__pycache__
/
View File Name :
rfc2217.cpython-310.pyc
o «¦^_4é ć @ s~ d dl mZ d dlZd dlZd dlZd dlZd dlZzd dlZW n ey/ d dl m Z Y nw zd dl Z W n eyC d dl Z Y nw d dl Z d dlmZmZmZmZmZmZ ejejejejdZdZdZdZ dZ d Z d Z d Z d Z!d Z"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2d Z3d Z4d Z5d Z6d Z7d!Z8d"Z9d#Z:d$Z;d%Z<d&Z=d'Z>d(Z?d)Z@d*ZAd+ZBd,ZCd-ZDd.ZEd/ZFe/e;e0e<e1e=e2e>e3e?e4e@e5eAe6eBe7eCe8eDe9eEe:eFi ZGdZHdZIdZJdZKdZLd ZMd ZNd ZOd ZPd ZQd!ZRd"ZSd#ZTd0ZUd1ZVd2ZWd3ZXd4ZYd5ZZd6Z[d7Z\d8Z]d9Z^d:Z_d;Z`d<Zad=Zbd>Zcd7Zdd8Zed9Zfd:Zgd;Zhd<Zid=Zjd>ZkdZldZmdZne jod>e jpd=e jqd?e jrd<e jsd@iZteudAdB et v” D Zwe jxd>e jyd?e jzd=iZ{eudCdB e{ v” D Z|d Z}d>Z~d=ZdDZdEZdFZdGZG dHdI dIeZ G dJdK dKeZG dLdM dMeZG dNdO dOeZedPkr½d dlZedQdRZej dS e”” ej dT” e dU” e ” ej dV e d@””” e ” dS dS )Wé )Śabsolute_importN)Ś 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 ó | ] \}}||fV qd S ©N© ©Ś.0ŚkŚvrJ rJ ś0/usr/lib/python3/dist-packages/serial/rfc2217.pyŚ <genexpr>Ų ó rP c c rH rI rJ rK rJ rJ rO rP ß rQ Ś REQUESTEDŚACTIVEŚINACTIVEŚREALLY_INACTIVEc @ s, e Zd ZdZ d ddZdd 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) ŚselfrW rX rY rZ r[ r\ r] Z initial_stater` rJ rJ rO Ś__init__š s zTelnetOption.__init__c C ó dj | dS )zString for debug outputsz {o.name}:{o.active}({o.state}))Śo©Śformat©ra rJ rJ rO Ś__repr__ ó zTelnetOption.__repr__c C s6 || j kr\| jtu r t| _d| _| jdur| ” dS dS | jtu r$dS | jtu rEt| _| j | j | j ” d| _| jdurC| ” dS dS | jt u rU| j | j | j ” dS t d | ”|| jkr| jtu rnt| _d| _dS | jtu rt| _| j | j | j ” d| _dS | jtu rdS | jt u rdS t 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)r\ r^ rR rS r_ r` rT rW Śtelnet_send_optionrZ rY rU r[ Ś ValueErrorrf r] ©ra ŚcommandrJ rJ rO Śprocess_incoming sB ’ ’ óz TelnetOption.process_incomingrI )Ś__name__Ś __module__Ś __qualname__Ś__doc__rb rh rn rJ rJ rJ rO rV ķ s ’ rV c @ sL e Zd ZdZdddZdd Zdd Zd d ZeeZ 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 rI )rW rX rY ŚvalueŚ ack_optionrT r^ )ra rW rX rY ru rJ rJ rO rb 9 s z TelnetSubnegotiation.__init__c C rc )zString for debug outputs.z{sn.name}:{sn.state})Zsnre rg rJ rJ rO rh C ri z TelnetSubnegotiation.__repr__c C sH || _ t| _| j | j| j ” | jjr"| jj d | j | j ”” dS 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) rt rR r^ rW Śrfc2217_send_subnegotiationrY Śloggerr rf rX )ra rt rJ rJ rO ŚsetG s ’zTelnetSubnegotiation.setc C s$ | j tkr td | 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^ rU rk rf rX rS rg rJ rJ rO Śis_readyS s z TelnetSubnegotiation.is_readyrF c C s> t |}| ” st d” | ” rdS | ” rtd | j”)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Śsleepry r rf rX )ra ŚtimeoutZ timeout_timerrJ rJ rO Śwait^ s żzTelnetSubnegotiation.waitc C sR | j |dt| j krt| _nt| _| jjr'| jj d | j || j”” dS 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} -> {}) rt ŚlenrS r^ rU rW rw r rf rX )ra Ś suboptionrJ rJ rO Ś check_answerl s ’z!TelnetSubnegotiation.check_answerrI )rF ) ro rp rq rr rb rh rx ry Śpropertyr_ r r rJ rJ rJ rO rs 3 s rs c s e Zd ZdZdZ fddZdd Zdd Zd d Zd d Z e d d Z d=ddZ 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>d3d4Z 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 é’’’’FrF )Ś_threadŚ_socketŚ _linestateŚ _modemstater Ś_modemstate_timeoutŚ_remote_suspend_flowŚ _write_lockrw Ś_ignore_set_control_answerŚ_poll_modem_stateŚ_network_timeoutŚ_telnet_optionsŚ_rfc2217_port_settingsŚ_rfc2217_optionsŚ _read_bufferŚsuperr rb )ra ŚargsŚkwargs©Ś __class__rJ rO rb s zSerial.__init__c C sž d| _ d| _d| _d| _| jdu rtd| jr tdztj| | j ”dd| _ | j tj tjd” W n tyL } z d| _ td | j |”d}~ww 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 <” zq| j!D ]}|j=t u r| >|j?|j@” q t4| j}| A” sCtB Cd ” tDd d |D tDd!d |D kr>n | A” r%td" |”| j rX| j Ed# | j!”” | F” | jGsd| H” | jIsl| J” | K” | L” W dS | M” )$zx Open port with current settings. This may throw a SerialException if the port cannot be opened. NFrF z.Port must be configured before it can be used.zPort is already open.rG )r~ rE 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 {}rz c s ó | ]}|j V qd S rI ©r_ ©rL rd rJ rJ rO rP Ž ó z Serial.open.<locals>.<genexpr>c s s | ]}|j tkV qd S rI )r^ rT r° rJ rJ rO rP Ž s z;Remote does not seem to support RFC2217 or BINARY mode {!r}zNegotiated options: {})Nrw r r r Z_portr Śis_openŚsocketZcreate_connectionŚfrom_urlZportstrr Z setsockoptZ IPPROTO_TCPZ TCP_NODELAYŚ Exceptionrf ŚQueuer Ś threadingZLockr rV ŚBINARYŚWILLŚWONTŚDOŚDONTrT ŚCOM_PORT_OPTIONrR r¢ ŚSGAr rs Ś 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 ZThreadŚ_telnet_read_loopr Z setDaemonZsetNameŚstartr^ rj rZ rY r{ r| r} Śsumr Ś_reconfigure_portZ_dsrdtrŚ_update_dtr_stateŚ_rtsctsŚ_update_rts_stateŚreset_input_bufferŚreset_output_bufferŚclose)ra ŚmsgZmandadory_optionsrY r~ rJ rJ rO Śopen s ž žūś ü ž & ż’z Serial.openc C s | j du r td| jdurtdd| j k r dk s&n td | j”| jd t d| j”” | jd t d | j ”” | jd t d t | j ”” | jd t d t| j ”” | j ” }| jro| j d |”” t| j}| ” st d” tdd |D t|krn | ” rxtd |”| jr¢| j d |”” | jr¬| j r¬td| jr¶| t ” dS | j rĄ| t ” dS | 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: {}rz c s r® rI rÆ r° rJ rJ rO rP r± 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 _baudraterk rf r rx ŚstructŚpackZ _bytesizeŚRFC2217_PARITY_MAPZ_parityŚRFC2217_STOPBIT_MAPZ _stopbitsŚvaluesrw r r r r{ r| r} 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)ra Śitemsr~ rJ rJ rO rĻ ó s: ż zSerial._reconfigure_portc C s^ d| _ | jrz| j tj” | j ” W n Y | jr*| j d” d| _t d” d| _dS )z Close portFé Nē333333Ó?) r² r Zshutdownr³ Z SHUT_RDWRrÕ r Śjoinr| r} rg rJ rJ rO rÕ s z Serial.closec C s t |”}|jdkrtd |j”zdt |jd” ” D ]E\}}|dkr?t ” t d”| _ | j t |d ” | j d” q |dkrGd| _q |d krOd| _q |d kr[t|d | _q td |”d|j krpd k sutd td W n ty } ztd |”d}~ww |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_modemr~ zunknown option: {!r}i zport not in range 0...65535zPexpected a string in the form "rfc2217://<host>:<port>[?option[&option...]]": {}N)ŚurlparseZurlsplitZschemer rf Zparse_qsZqueryrä rč Z basicConfigZ getLoggerrw ZsetLevelŚ LOGGER_LEVELSr r r Śfloatr rk ZportZhostname)ra ZurlŚpartsrY rß ŚerJ rJ rO r“ 0 sB ż ’’ž’ zSerial.from_urlc C s | j st | j ” S )z9Return the number of bytes currently in the input buffer.)r² r r Śqsizerg rJ rJ rO Ś in_waitingU s zSerial.in_waitingrE c C sĄ | j st t }zIt| j}t||k rI| jdu s | j ” s#td| j d| ” ”}|du r5t |W S ||7 }| ” r>nt||k sW t |S W t |S W t |S tjy_ Y t |S w )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 Z_timeoutr r Zis_aliver r ŚgetZ time_leftŚbytesr{ r¶ ZEmpty)ra ŚsizeŚdatar~ ŚbufrJ rJ rO Śread\ s0 ų õ żžžz Serial.readc C s | j st | j. z| j t| tt”” W n t j y, } zt d |”d}~ww W d t |S 1 s:w 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 rf r )ra rō rķ rJ rJ rO Śwritet s ’’ žūz Serial.writec C s> | j st | t” | j ” r | j d” | j ” sdS dS )z9Clear input buffer, discarding all that is in the buffer.FN)r² r Śrfc2217_send_purgeŚPURGE_RECEIVE_BUFFERr rī rń rg rJ rJ rO rÓ s ’zSerial.reset_input_bufferc C s | j st | t” dS )zs Clear output buffer, aborting the current output and discarding all that is in the buffer. N)r² r rü ŚPURGE_TRANSMIT_BUFFERrg rJ rJ rO rŌ s zSerial.reset_output_bufferc C óP | j st | jr| j d | jrdnd”” | jr!| t” dS | t” dS )z[ Set break: Controls TXD. When active, to transmitting is possible. zset BREAK to {}r_ ŚinactiveN) r² r rw r rf Z _break_staterą ŚSET_CONTROL_BREAK_ONŚSET_CONTROL_BREAK_OFFrg rJ rJ rO Ś_update_break_state s zSerial._update_break_statec C r’ )z*Set terminal status line: Request To Send.z set RTS to {}r_ r N) r² r rw r rf Z _rts_staterą ŚSET_CONTROL_RTS_ONŚSET_CONTROL_RTS_OFFrg rJ rJ rO rŅ £ ó zSerial._update_rts_statec C r’ )z.Set terminal status line: Data Terminal Ready.z set DTR to {}r_ r N) r² r rw r rf Z _dtr_staterą ŚSET_CONTROL_DTR_ONŚSET_CONTROL_DTR_OFFrg rJ rJ rO rŠ ® r zSerial._update_dtr_statec C ó | j st t| ” t@ S )z)Read terminal status line: Clear To Send.)r² r ŚboolŚget_modem_stateŚMODEMSTATE_MASK_CTSrg rJ rJ rO Ścts¹ ó z Serial.ctsc C r )z*Read terminal status line: Data Set Ready.)r² r r r ŚMODEMSTATE_MASK_DSRrg rJ rJ rO ŚdsrĄ r z Serial.dsrc C r )z*Read terminal status line: Ring Indicator.)r² r r r ŚMODEMSTATE_MASK_RIrg rJ rJ rO ŚriĒ r z Serial.ric C r )z*Read terminal status line: Carrier Detect.)r² r r r ŚMODEMSTATE_MASK_CDrg rJ rJ rO ŚcdĪ r z Serial.cdc C s¶ t }d}zĖ| jrĀz| j d”}W n. tjy Y q tjy> } z| jr.| j d |”” | j d” W Y d}~nd}~ww |sH| j d” nzt |D ]r}|t kri|t krYt}qL|durb||7 }qL| j |” qL|tkr²|t kr|durz|t 7 }n| j t ” t }qL|tkrt }t }qL|tkr| t|” d}t }qL|ttttfv rŖ|}t}qL| |” t }qL|tkr¾| ||” t }qL| jsW | jrĪ| j d” dS dS | jrŚ| j d” w w )zRead loop for the socket.Ni z!socket error in reader thread: {}zread thread terminated)ŚM_NORMALr² r Zrecvr³ r~ r rw r rf r Zputr rł Ś M_IAC_SEENŚSBrš ŚSEŚ _telnet_process_subnegotiationrņ r» r¼ r¹ rŗ Ś M_NEGOTIATEŚ_telnet_process_commandŚ_telnet_negotiate_option)ra Śmoder rō rķ ŚbyteŚtelnet_commandrJ rJ rO rĢ Ś sl ū Č: ’’zSerial._telnet_read_loopc C ó | j r| j d |”” dS dS ©z1Process commands other than DO, DONT, WILL, WONT.z ignoring Telnet command: {!r}N©rw r rf rl rJ rJ rO r ó ’z Serial._telnet_process_commandc C ó| d}| j D ]}|j|kr| |” d}q|s8|tks |tkr:| |tkr&tnt|” | jr<| j d |”” dS dS dS dS ©z&Process incoming DO, DONT, WILL, WONT.FTz rejected Telnet option: {!r}N© r rY rn r¹ r» rj r¼ rŗ rw r rf ©ra rm rY ZknownŚitemrJ rJ rO r $ ó śz Serial._telnet_negotiate_optionc C sj |dd t kr„|dd tkr0t|dkr0t|dd | _| jr.| j d | j”” d S d S |dd tkr\t|dkr\t|dd | _ | jrT| j d | j ”” | j d” d S |dd t krid| _ d S |dd tkrvd | _ d S | j ” D ]}|j|dd kr| t|dd ” d S q{| jr£| j d |”” d S d S | jr³| j d |”” d S d S ) ś;Process subnegotiation, the data between IAC SB and IAC SE.r rE rD rF zNOTIFY_LINESTATE: {}śNOTIFY_MODEMSTATE: {}rę TFNz ignoring COM_PORT_OPTION: {!r}z ignoring subnegotiation: {!r})r½ ŚSERVER_NOTIFY_LINESTATEr Śordr rw r rf ŚSERVER_NOTIFY_MODEMSTATEr r ZrestartŚFLOWCONTROL_SUSPENDr ŚFLOWCONTROL_RESUMEr rß ru r rņ r )ra r r( rJ rJ rO r 7 s4 ’ ż’’z%Serial._telnet_process_subnegotiationc C s8 | j | j |” W d dS 1 sw Y dS )zGinternal socket write with no data escaping. used to send telnet stuff.N)r r r÷ )ra rō rJ rJ rO Ś_internal_raw_writeW s "’zSerial._internal_raw_writec C s | t| | ” dS ©zSend DO, DONT, WILL, WONT.N)r1 rł ©ra ŚactionrY rJ rJ rO rj \ s zSerial.telnet_send_optionó c C s2 | tt”}| tt t | | t t ” dS )z%Subnegotiation of RFC2217 parameters.N)rų rł rś r1 r r½ r ©ra rY rt rJ rJ rO rv ` 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 rx r r ©ra rt r( rJ rJ rO rü e s zSerial.rfc2217_send_purgec C s8 | j d }| |” | jrt d” dS | | j” dS )z)transmit change of control line to remoter¬ g¹?N)r rx r r| r} r r r7 rJ rJ rO rą n s zSerial.rfc2217_set_controlc C s dS )z` check if server is ready to receive data. block for some time when not. NrJ rg rJ rJ rO Śrfc2217_flow_server_readyz s z Serial.rfc2217_flow_server_readyc C s | j r7| j ” r7| jr| j d” | t” t| j}| ” s.t d” | j ” s*n | ” r | jr7| j d” | j durH| jrE| j d” | j S t d)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 staterz zpoll for modem state failedNzusing cached modem statez!remote sends no NOTIFY_MODEMSTATE)r r r{ rw r rv ŚNOTIFY_MODEMSTATEr r r| r} r r r )ra r~ rJ rJ rO r s" ū zSerial.get_modem_state)rE ©r5 )#ro rp rq rr Z BAUDRATESrb r× rĻ rÕ r“ r rļ rö rū rÓ rŌ r rŅ rŠ r r r r rĢ r r r r1 rj rv rü rą r8 r Ś __classcell__rJ rJ r rO r z sH a,% D r c @ sf e Zd ZdZdddZdd Zdd Zdd d Zdd dZdd 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 ttttt | dtt ttttt | dtttt ttt | dtt ttttt | dtttt ttt | d tt tttt| j t | d tttt tt| j g| _| jrt| j d ” | jD ]}|jtu r| |j|j ” qwd S ) NFé’ r r¢ r£ r¤ r r„ r” r¦ z*requesting initial Telnet/RFC 2217 options) ŚserialrW rw Ś_client_is_rfc2217r r r r Śmodemstate_maskŚlast_modemstateŚ linstate_maskrV r¢ r¹ rŗ r» r¼ rR r¾ rT rø r½ Ś _client_okr r r^ rj rZ rY )ra Z serial_portrW rw rY rJ rJ rO rb ° s2 ł ž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? rw r Ścheck_modem_linesrg rJ rJ rO rC Ó s zPortManager._client_okc C s | j t| | ” dS r2 )rW rū rł r3 rJ rJ rO rj ē s z PortManager.telnet_send_optionr5 c C s4 | tt”}| j tt t | | t t ” dS )z&Subnegotiation of RFC 2217 parameters.N)rų rł rś rW rū r r½ r r6 rJ rJ rO rv ė s (z'PortManager.rfc2217_send_subnegotiationFc C sā | j jot| j jo tB | j jotB | j jotB }|| j p dA }|t@ r'|t O }|t@ r/|t O }|t@ r7|t O }|t@ r?|t O }|| j ksF|ro| jrN|| j@ sP|rh| tt|| j@ g” | jrh| j d |”” |d@ | _ dS dS )z read control lines from serial port and compare the last value sent to remote. send updates on changes. r r+ éš N)r> r r r r r r r r rA ŚMODEMSTATE_MASK_CTS_CHANGEŚMODEMSTATE_MASK_DSR_CHANGEŚMODEMSTATE_MASK_RI_CHANGEŚMODEMSTATE_MASK_CD_CHANGEr? r@ rv r. r rw r rf )ra rE Z modemstateZdeltasrJ rJ rO rF ó s6 ’ ž ż’žöz PortManager.check_modem_linesc c s0 t |D ]}|tkrtV 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ł ©ra rō r rJ rJ rO Śescape s ūzPortManager.escapec c s t |D ]}| jtkr%|tkrt| _q| jdur!| j|7 _q|V q| jtkry|tkrB| jdur;| j|7 _n|V t| _q|tkrNt | _t| _q|tkra| t | j” d| _t| _q|t t t tfv rp|| _t| _q| |” 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 rL rJ rJ rO Śfilter( s> ŲzPortManager.filterc C r r! r" rl rJ rJ rO r c r# z#PortManager._telnet_process_commandc C r$ r% r& r' rJ rJ rO r i r) z$PortManager._telnet_negotiate_optionc C sF |dd t kr| jr| j d |”” |dd tkrz| jj}zt d|dd ”\}|dkr5|| j_W n" t yX } z| jrJ| j d |”” || j_W Y d}~nd}~ww | jrl| j d |red nd | jj”” | t t d| jj”” dS |dd tkrß| jj}zt d |dd ”\}|dkr|| j_W n" t y½ } z| jrÆ| j d |”” || j_W Y d}~nd}~ww | jrŃ| j d |rŹd nd | jj”” | tt d | jj”” dS |dd tkrO| jj}zt d |dd ”d }|dkrt| | j_W n$ t y) } z| jr| j d |”” || j_W Y d}~nd}~ww | jr?| j d |r8d nd | jj”” | tt d t| jj ”” dS |dd tkræ| jj}zt d |dd ”d }|dkrtt| | j_W n$ t y } z| jr| j d |”” || j_W Y d}~nd}~ww | jrÆ| j d |rØd nd | jj”” | tt d t| jj ”” dS |dd t krO|dd t kró| jj rŽ| t t ” dS | jj!rė| t t"” dS | t t#” dS |dd t#krd| j_ d| j_!| jr| j d” | t t#” dS |dd t kr5d| j_ | jr-| j d” | t t ” dS |dd t"krTd| j_!| jrL| j d” | t t"” dS |dd t$kri| jrg| j %d” dS |dd t&krd| j_'| jr| j d” | t t&” dS |dd t(kr§d| j_'| jr| j d” | t t(” dS |dd t)kr¼| jrŗ| j %d ” dS |dd t*krŪd| j_+| jrÓ| j d ” | t t*” dS |dd t,krśd| j_+| jrņ| j d ” | t t,” dS |dd t-kr| jr | j %d ” dS |dd t.kr.d| j_/| jr&| j d ” | t t.” dS |dd t0krMd| j_/| jrE| j d!” | t t0” dS dS |dd t1krc| t2t3dg” dS |dd t4kr~| jrv| j d"” | j5dd# dS |dd t6kr| jr| j d$” d| _7dS |dd t8kr®| jr©| j d%” d| _7dS |dd t9krŅt:|dd | _;| jrŠ| j d& | j;”” dS dS |dd t<kröt:|dd | _=| jrō| j d' | j=”” dS dS |dd t>kr{|dd t?kr | j @” | jr| j d(” | tAt?” dS |dd tBkr?| j C” | jr7| j d)” | tAtB” dS |dd tDkrd| j @” | j C” | jr\| j d*” | tAtD” dS | jry| j d+ tE|dd ”” dS dS | jr| j d, tE|dd ”” dS dS | jr”| j %d- |”” dS dS ).r* r rE z received COM_PORT_OPTION: {!r}rD rŲ é zfailed to set baud rate: {}Nz{} baud rate: {}rx rń rŁ rF 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 staterD 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½ rw r rf ræ r> r§ rŪ Śunpackrk r r rv 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 r9 rF r/ r r0 ŚSET_LINESTATE_MASKr- rB ŚSET_MODEMSTATE_MASKr@ rĒ rż rÓ rČ rž rŌ ŚPURGE_BOTH_BUFFERSŚlist)ra r Zbackupr§ rķ rØ r© rR rJ rJ rO r | s ż ż ż"ž ż"ž ü ž ’’ "’"’’z*PortManager._telnet_process_subnegotiationrI r: )F)ro rp rq rr rb rC rj rv rF rM rN r r r rJ rJ rJ rO r< © s # $; r< Ś__main__zrfc2217://localhost:7000r z{} z write... s hello z read: {} )Z __future__r rč r³ rŪ r· r| ré Ś ImportErrorZ urllib.parseŚparser¶ Śqueuer> 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É rX r9 r/ r0 rY rZ rĒ rĄ rĀ rÄ rĘ rŹ r, r. ZSERVER_FLOWCONTROL_SUSPENDZSERVER_FLOWCONTROL_RESUMEZSERVER_SET_LINESTATE_MASKZSERVER_SET_MODEMSTATE_MASKrČ ZRFC2217_ANSWER_MAPrT rć rā rį rU r r rV r r rW 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 rK rJ rI rH rż rž r[ Z PARITY_NONEZ PARITY_ODDZ PARITY_EVENZ PARITY_MARKZ PARITY_SPACErŻ Śdicträ rQ Z STOPBITS_ONEZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWOrŽ rS r r r rR rS rT rU ŚobjectrV rs r r< ro ŚsysŚsŚstdoutrū rf Śflushrö rÕ rJ rJ rJ rO Ś<module> s@ < ’ ’ ü ōūżFG 3 ÷