⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
serial
/
__pycache__
/
View File Name :
rfc2217.cpython-312.pyc
=}`e d dl mZ d dlZd dlZd dlZd dlZd dlZ d dlZ d dl Z d dl Z d dlmZmZmZmZmZmZ ej* ej, ej. ej0 dZdZdZdZ 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 j d>e j d=e j d?e j d<e j d@iZt eudA etj D Zwe j d>e j d?e j d=iZ{ eudB e{j D Z|d Z}d>Z~d=ZdCZdDZdEZdFZ G dG dHe Z G dI dJe Z G dK dLe Z G dM dNe ZedOk( rd dlZ edPdQ Zej j dRj e ej j dS ej dT ej ej j dUj ej! d@ ej# yy# e$ r d dl m Z Y w xY w# e$ r d dl Z Y w xY w)V )absolute_importN) SerialBaseSerialExceptionto_bytes iterbytesPortNotOpenErrorTimeout)debuginfowarningerror s , e f g h i j k l m n o p @ c # * K | ] \ }}||f y wN .0kvs 0/usr/lib/python3/dist-packages/serial/rfc2217.py <genexpr>rQ s !P5OTQ1a&5O c # * K | ] \ }}||f y wrJ rK rL s rP rQ rQ s "R6QdaAq66QrR REQUESTEDACTIVEINACTIVEREALLY_INACTIVEc & e Zd ZdZ ddZd Zd Zy) TelnetOptionz@Manage a single telnet option, keeps track of DO/DONT WILL/WONT.Nc || _ || _ || _ || _ || _ || _ || _ || _ d| _ | | _ y)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) connectionnameoptionsend_yessend_noack_yesack_nostateactiveactivation_callback) selfr[ r\ r] r^ r_ r` ra initial_staterd s rP __init__zTelnetOption.__init__ sK % " #6 c & dj | S )zString for debug outputsz {o.name}:{o.active}({o.state}))oformatre s rP __repr__zTelnetOption.__repr__ s /666>>rh c || j k( r$| j t u r/t | _ d| _ | j | j y| j t u ry| j t u r_t | _ | j j | j | j d| _ | j n| j y| j t u r1| j j | j | j yt dj | yy|| j k( r| j t u rt | _ d| _ y| j t u rCt | _ | j j | j | j d| _ y| j t u ry| j t u ryt dj | y)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` rb rT rU rc rd rV r[ telnet_send_optionr^ r] rW r_ ValueErrorrl ra re commands rP process_incomingz TelnetOption.process_incoming s dll "zzY& # " ++7,,.v%x' # 224==$++N " ++7,,..224<<M !?!F!Ft!LMM 8 8 #zzY& % # v% % 224<<M # x'. !?!F!Ft!LMM $rh rJ )__name__ __module__ __qualname____doc__rg rn rt rK rh rP rY rY s J =A70?$Nrh rY c H e Zd ZdZd dZd Zd Zd Z ee Z d dZ d Z y) 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 h ||}|| _ || _ || _ d | _ || _ t | _ y rJ )r[ r\ r] value ack_optionrV rb )re r[ r\ r] r} s rP rg z TelnetSubnegotiation.__init__9 s7 J$ $ rh c & dj | S )zString for debug outputs.z{sn.name}:{sn.state})snrk rm s rP rn z TelnetSubnegotiation.__repr__C s %,,,55rh c H || _ t | _ | j j | j | j | j j rJ| j j j dj | j | j yy)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) r| rT rb r[ rfc2217_send_subnegotiationr] loggerr rl r\ )re r| s rP setzTelnetSubnegotiation.setG sq 33DKKL ?? ! ! OO " " ( ()C)J)J499VZV`V`)a b "rh c | j t k( r$t dj | j | j t k( S )z{ Check if answer from server has been received. when server rejects the change, raise a ValueError. z%remote rejected value for option {!r})rb rW rq rl r\ rU rm s rP is_readyz TelnetSubnegotiation.is_readyS s: :: ( D K KDII VW WzzV##rh c t | }|j s7t j d | j ry|j s7t dj | 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 expiredtimesleepr r rl r\ )re timeout timeout_timers rP waitzTelnetSubnegotiation.wait^ s` ( '') JJt }} '') ""I"P"PQUQZQZ"[\ \rh c > | j |dt | j k( r t | _ n t | _ | j j rK| j j j dj | j || j yy)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} -> {}) r| lenrU rb rW r[ r r rl r\ )re suboptions rP check_answerz!TelnetSubnegotiation.check_answerl sv ::#3C O4 4 DJ )DJ ?? ! ! OO " " ( ()E)L)LTYYXacgcmcm)n o "rh rJ )rG ) ru rv rw rx rg rn r r propertyrc r r rK rh rP rz rz 3 s4 6 c$ h F ] prh rz c 2 e Zd ZdZdZ fdZd Zd Zd Zd Z e d Z d!d Z d Z d Zd Zd Zd Zd Ze d Ze d Ze d Ze d Ze d Zej0 d Zd Zd Zd Zd Z d Z d Z d"d Z d Z d Z!d Z"d Z# xZ$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 d | _ d | _ d| _ d | _ t d | _ d| _ d | _ d | _ d| _ d| _ d| _ d | _ d | _ d | _ d | _ t! t" | J |i | y )Nr FrG )_thread_socket _linestate _modemstater _modemstate_timeout_remote_suspend_flow _write_lockr _ignore_set_control_answer_poll_modem_state_network_timeout_telnet_options_rfc2217_port_settings_rfc2217_options _read_buffersuperr rg )re argskwargs __class__s rP rg zSerial.__init__ s #*2; $)! */'!& ! # &*# $ fd$d5f5rh c d| _ d| _ d| _ d| _ | j t d | j r t d t j | j | j d | _ | j j t j t j d t# j" | _ t' j( | _ t- | d t. t0 t2 t4 t6 t8 t- | d t: t0 t2 t4 t6 t< g}t- | d t> t4 t6 t0 t2 t< t- | d t@ t0 t2 t4 t6 t< t- | dt@ t4 t6 t0 t2 t< t- | dt. t4 t6 t0 t2 t8 t- | dt: t4 t6 t0 t2 t< g|z | _! tE | dtF tH tE | dtJ tL tE | dtN tP tE | dtR tT d| _+ tE | dtX tZ tE | dt\ t^ d| _0 | j` jc | jV d| _2 d| _3 ti d | _5 d| _6 d| _ t' jn | jp | _9 | jr ju d | jr jw d j! | j | jr jy | jB D ]; }|jz t< u s| j} |j~ |j = ti | j }|j sLt j d t d |D t d |D k( rn+|j sLt d!j! | | j r4| j j d"j! | jB | j | j s| j | j s| j | j | j y# t $ r1}d| _ t d j! | j | d}~ww xY w# | j xY w)#zx Open port with current settings. This may throw a SerialException if the port cannot be opened. NFrG z.Port must be configured before it can be used.zPort is already open.rH )r rF zCould not open port {}: {} we-BINARY we-RFC2217ECHOwe-SGAthey-SGA they-BINARY they-RFC2217baudratedatasizeparitystopsize)r r r r purgecontrol)r r r r T)targetz&pySerial RFC 2217 reader thread for {}r c 3 4 K | ] }|j y wrJ rc rM rj s rP rQ z Serial.open.<locals>.<genexpr> s ;):Aqxx): c 3 B K | ] }|j t k7 y wrJ )rb rV r s rP rQ z Serial.open.<locals>.<genexpr> s Br`q[\177hCV`qs z;Remote does not seem to support RFC2217 or BINARY mode {!r}zNegotiated options: {})Nr r r r _portr is_opensocketcreate_connectionfrom_urlportstrr setsockopt IPPROTO_TCP TCP_NODELAY Exceptionrl Queuer threadingLockr rY BINARYWILLWONTDODONTrV COM_PORT_OPTIONrT r SGAr rz SET_BAUDRATESERVER_SET_BAUDRATE SET_DATASIZESERVER_SET_DATASIZE SET_PARITYSERVER_SET_PARITY SET_STOPSIZESERVER_SET_STOPSIZEr PURGE_DATASERVER_PURGE_DATA SET_CONTROLSERVER_SET_CONTROLr updater r r r r Thread_telnet_read_loopr setDaemonsetNamestartrb rp r^ r] r r r sumr _reconfigure_port_dsrdtr_update_dtr_state_rtscts_update_rts_statereset_input_bufferreset_output_bufferclose)re msgmandadory_optionsr] r s rP openz Serial.open s */'!& ! :: !"RS S <<!"9: : Z!33DMM$,,4OYZ[DL LL # #F$6$68J8JA N "KKM %>>+ {FD$D( S |_dD"dT] ^ vtRtT9 M xdD"dI N z3D$i P }fb$dH U ~D$PTV_ ` -T:|M`a,T:|M`a,T8zM^_,T:|M`a ' # -T7zM^_,T9{M_`! $$T%@%@A #*2; $)! ''t/E/EF t$ E L LTZZ XY ..<<9,++FOOV]]K / d 3 34G oo' 4 ;):;;sBr`qBr?rr oo' &QXXYjkm m{{ !9!@!@AUAU!VW " " $<<&&(<<&&( # # % $ $ &Y Z DL!">"E"EdllTW"XY Y ZZ JJL s3 A.T !U 'BU CU T= ,T88T= Uc | j t d | j t d d| j cxk rdk s&n t dj | j | j d j t j d| j | j d j t j d | j | j d j t j d t | j | j d j t j d t | j | j j! }| j" r*| j" j% d j | t' | j( }|j+ sEt- j. d t1 d |D t3 | k( rn+|j+ sEt dj | | j" r*| j" j5 dj | | j6 r| j8 r t d | j6 r| j; t< y| j8 r| j; t> y| j; t@ y)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: {}r c 3 4 K | ] }|j y wrJ r r s rP rQ z+Serial._reconfigure_port.<locals>.<genexpr> s +U188Ur z7Remote does not accept parameter change (RFC2217): {!r}zNegotiated settings: {}z-xonxoff and rtscts together are not supported)!r r _write_timeoutNotImplementedError _baudraterq rl r r structpack _bytesizeRFC2217_PARITY_MAP_parityRFC2217_STOPBIT_MAP _stopbitsvaluesr r r r r r r r r r r _xonxoffrfc2217_set_control SET_CONTROL_USE_HW_FLOW_CONTROL SET_CONTROL_USE_SW_FLOW_CONTROL SET_CONTROL_USE_NO_FLOW_CONTROL)re itemsr s rP r zSerial._reconfigure_port s, << !"BC C *%&PQ Q 4>>+G+ 5 < <T^^ LM M ##J/33FKKt~~4VW ##J/33FKKt~~4VW ##H-11&++eEWX\XdXdEe2fg ##J/33FKKGZ[_[i[iGj4kl ++224 ;; KK 8 ? ? F G$//0//# JJt +U++s5z9 //# ""["b"bch"ij j ;; KK 6 = =e D E <<DMM LM M \\ $ $%D E ]] $ $%D E $ $%D Erh c T d| _ | j rD | j j t j | j j | j r7| j j d d| _ t j d d| _ y# Y OxY w)z Close portF N333333?) r r shutdownr SHUT_RDWRr r joinr r rm s rP r z Serial.close s{ << %%f&6&67 ""$ << LL a DL JJsO s AB# #B'c ` t j | }|j dk7 r$t dj |j t j |j d j D ] \ }}|dk( rot j t j d | _ | j j t |d | j j d z|dk( rd| _ |d k( rd| _ |d k( rt# |d | _ t' d j | d|j( cxk rd k st' d t' d |j* |j( fS # t& $ r }t dj | d}~ww xY w)zu extract host and port from an URL string, other settings are extracted an stored in instance rfc2217zqexpected a string in the form "rfc2217://<host>:<port>[?option[&option...]]": not starting with rfc2217:// ({!r})TloggingzpySerial.rfc2217r zenabled loggingign_set_control poll_modemr zunknown option: {!r}i zport not in range 0...65535zPexpected a string in the form "rfc2217://<host>:<port>[?option[&option...]]": {}N)urlparseurlsplitschemer rl parse_qsqueryr r basicConfig getLoggerr setLevel LOGGER_LEVELSr r r floatr rq porthostname)re urlpartsr] r es rP r zSerial.from_url0 s !!#& <<9 $!66<fU\\6JL L P"*"3"3EKK"F"L"L"NY&'')")"3"34F"GDKKK(( vay)ABKK%%&78 006:D3|+-1D*y(,1&),<D)$%;%B%B6%JKK #O *U* !>?? + !>?? + ++ P!EEKVAYP P Ps D"F F-F((F-c b | j s t | j j S )z9Return the number of bytes currently in the input buffer.)r r r qsizerm s rP in_waitingzSerial.in_waitingU s) ||"$ $ &&((rh c | j s t t } t | j }t | |k r| j | j j s t d | j j d|j }| t | S ||z }|j rnt | |k rt | S # t j $ r Y t | S w xY 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. z&connection failed (reader thread died)T)r r bytearrayr _timeoutr r is_aliver r get time_leftbytesr r Empty)re sizedatar bufs rP readz Serial.read\ s ||"$ ${ dmm,Gd)d"<<'t||/D/D/F)*RSS''++D'2C2C2EF; ;& ??$ d)d" T{ {{ T{ s B C -$C C=<C=c | j s t | j 5 | j j t | j t t ddd t | S # t j $ r }t dj | d}~ww xY w# 1 sw Y t | S xY w)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 replaceIAC IAC_DOUBLEDr r r rl r )re r1 r$ s rP writez Serial.writet s ||"$ $ X $$Xd^%;%;C%MN 4y << X%&L&S&STU&VWW X 4ys( B*<A55B'B""B''B**B=c | j s t | j t | j j r7| j j d | j j r6yy)z9Clear input buffer, discarding all that is in the buffer.FN)r r rfc2217_send_purgePURGE_RECEIVE_BUFFERr r& r, rm s rP r zSerial.reset_input_buffer s[ ||"$ $ 45 %%' ! !% ( %%'rh c Z | j s t | j t y)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. N)r r r; PURGE_TRANSMIT_BUFFERrm s rP r zSerial.reset_output_buffer s# ||"$ $ 56rh c & | j s t | j r8| j j dj | j rdnd | j r| j t y| j t y)z[ Set break: Controls TXD. When active, to transmitting is possible. zset BREAK to {}rc inactiveN) r r r r rl _break_stater SET_CONTROL_BREAK_ONSET_CONTROL_BREAK_OFFrm s rP _update_break_statezSerial._update_break_state sk ||"$ $ ;; KK . 5 5$BSBShYc d e $ $%9 : $ $%: ;rh c & | j s t | j r8| j j dj | j rdnd | j r| j t y| j t y)z*Set terminal status line: Request To Send.z set RTS to {}rc r@ N) r r r r rl _rts_stater SET_CONTROL_RTS_ONSET_CONTROL_RTS_OFFrm s rP r zSerial._update_rts_state d ||"$ $ ;; KK _ 3 3HU_ ` a ?? $ $%7 8 $ $%8 9rh c & | j s t | j r8| j j dj | j rdnd | j r| j t y| j t y)z.Set terminal status line: Data Terminal Ready.z set DTR to {}rc r@ N) r r r r rl _dtr_stater SET_CONTROL_DTR_ONSET_CONTROL_DTR_OFFrm s rP r zSerial._update_dtr_state rI rh c n | j s t t | j t z S )z)Read terminal status line: Clear To Send.)r r boolget_modem_stateMODEMSTATE_MASK_CTSrm s rP ctsz Serial.cts . ||"$ $D((*-@@AArh c n | j s t t | j t z S )z*Read terminal status line: Data Set Ready.)r r rO rP MODEMSTATE_MASK_DSRrm s rP dsrz Serial.dsr rS rh c n | j s t t | j t z S )z*Read terminal status line: Ring Indicator.)r r rO rP MODEMSTATE_MASK_RIrm s rP riz Serial.ri . ||"$ $D((*-??@@rh c n | j s t t | j t z S )z*Read terminal status line: Carrier Detect.)r r rO rP MODEMSTATE_MASK_CDrm s rP cdz Serial.cd rZ rh c | j S )z Get the current timeout setting.)r* rm s rP r zSerial.timeout s }} rh c |% |dz |dk rt dj | || _ y# t $ r t dj | w xY w)zChange timeout setting.NrF zNot a valid timeout: {!r}r ) TypeErrorrq rl r* re r s rP r zSerial.timeout sh N! { !<!C!CG!LMM N !<!C!CG!LMM Ns 0 $Ac t }d} | j r | j j d }|s | j j d nDt | D ]' }|t k( r4|t k( rt } |||z }%| j j | A|t k( r|t k( r2| |t z }n | j j t t }|t k( rt! }t }|t" k( r#| j% t' | d}t }|t( t* t, t. fv r |}t0 }| j3 | t }|t0 k( s| j5 | t }* | j r| j r | j j d yy# t j $ r Y t j $ r[}| j r*| j j dj | | j j d Y d}~d}~ww xY w# | j r | j j d w w xY w)zRead loop for the socket.Ni z!socket error in reader thread: {}zread thread terminated)M_NORMALr r recvr r r r r rl r putr r7 M_IAC_SEENSBr) SE _telnet_process_subnegotiationr. r r r r M_NEGOTIATE_telnet_process_command_telnet_negotiate_option)re moder r1 r$ bytetelnet_commands rP r zSerial._telnet_read_loop s < <,, <<,,T2D %%))$/ %dODx' 3;#-D ) 4 )T 1 $ 1 1 5 5d ; + 3; ) 4 )S 0 $ 1 1 5 5c :#+D !RZ(1 I#+D !RZ ? ?i@P Q(,I#+D !b$d%; ;-1N#.D ! 8 8 >#+D , 55ndK 'Q ,! ,,t {{ !!":; o ~~ || {{ ))*M*T*TUV*WX%%))$/ f {{ !!":; sG I F? D8I -'I ?II I'AH=8I =II *I/c r | j r+| j j dj | yyz1Process commands other than DO, DONT, WILL, WONT.z ignoring Telnet command: {!r}Nr r rl rr s rP rk z Serial._telnet_process_command/ . ;; KK ? F Fw O P rh c T d}| j D ]% }|j |k( s|j | d}' |sp|t k( s |t k( r]| j |t k( rt nt | | j r+| j j dj | yyyyz&Process incoming DO, DONT, WILL, WONT.FTz rejected Telnet option: {!r}N r r] rt r r rp r r r r rl re rs r] knownitems rP rl z Serial._telnet_negotiate_option5 ((D {{f$%%g. ) $'R-''D dVT;;KK''(F(M(Mf(UV #0 rh c |dd t k( r|dd t k( rct | dk\ rUt |dd | _ | j rn| j j dj | j y |dd t k( r}t | dk\ rot |dd | _ | j r4| j j dj | j | j j d y |dd t k( rd| _ y |dd t k( rd | _ y | j j! D ]3 }|j" |dd k( s|j% t' |dd y | j r+| j j) d j | y y y | j r+| j j) d j | y y ) ;Process subnegotiation, the data between IAC SB and IAC SE.r rF rE rG zNOTIFY_LINESTATE: {}NOTIFY_MODEMSTATE: {}r TFNz ignoring COM_PORT_OPTION: {!r}z ignoring subnegotiation: {!r})r SERVER_NOTIFY_LINESTATEr ordr r r rl SERVER_NOTIFY_MODEMSTATEr r restartFLOWCONTROL_SUSPENDr FLOWCONTROL_RESUMEr r r} r r. r )re r ry s rP ri z%Serial._telnet_process_subnegotiationH s Qq>_ ,1~!88S^q=P"%i!n"5;;KK$$%;%B%B4??%ST1Q #;;IRS@S#&y1~#6 ;;KK$$%<%C%CDDTDT%UV((0051Q #66,0)1Q #55,1) 1 1 8 8 :D)Aa.8 ))% !" *>? ; {{ ++,L,S,ST],^_ #' , {{ ##$C$J$J9$UV rh c | | j 5 | j j | ddd y# 1 sw Y yxY w)zGinternal socket write with no data escaping. used to send telnet stuff.N)r r r5 )re r1 s rP _internal_raw_writezSerial._internal_raw_writeh s) LL & s 2;c : | j t |z |z yzSend DO, DONT, WILL, WONT.N)r r7 re actionr] s rP rp zSerial.telnet_send_optionm s v !67rh c |j t t }| j t t z t z |z |z t z t z y)z%Subnegotiation of RFC2217 parameters.N)r6 r7 r8 r rg r rh re r] r| s rP r z"Serial.rfc2217_send_subnegotiationq s> c;/ rO!;f!Du!Ls!RUW!WXrh c z | j d }|j | |j | j y)z~ Send purge request to the remote. (PURGE_RECEIVE_BUFFER / PURGE_TRANSMIT_BUFFER / PURGE_BOTH_BUFFERS) r N)r r r r re r| ry s rP r; zSerial.rfc2217_send_purgev s1 $$W- $''(rh c | j d }|j | | j rt j d y|j | j y)z)transmit change of control line to remoter g?N)r r r r r r r r s rP r zSerial.rfc2217_set_control sE $$Y/ * * JJsO IId++ ,rh c y)z` check if server is ready to receive data. block for some time when not. NrK rm s rP rfc2217_flow_server_readyz Serial.rfc2217_flow_server_ready s rh c t | j r| j j r| j r| j j d | j t t | j }|j sAt j d | j j sn8|j sA| j r| j j d | j 3| j r| j 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 stater zpoll for modem state failedzusing cached modem statez!remote sends no NOTIFY_MODEMSTATE)r r r r r r NOTIFY_MODEMSTATEr r r r r r r ra s rP rP zSerial.get_modem_state s ! !d&>&>&F&F&H{{ !!"78 , ,-> ? d 3 34G oo' 4 //779 oo' ;;KK''(EF '{{ !!"<=## # ""EF Frh )rF rh )%ru rv rw rx BAUDRATESrg r r r r r r' r3 r9 r r rD r r rR rV rY r] r setterr rk rl ri r rp r r; r r rP __classcell__)r s @rP r r z s% F4I6$_B*FX "!,J ) ) 0 )7 < : : B B B B A A A A ^^ @<HQ W& W@' 8Y ) - !Grh r c R e Zd ZdZd dZd Zd ZddZddZd Z d Z d Z d Z d Z y) 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 || _ || _ || _ d| _ t | _ d | _ d | _ d| _ d | _ d| _ t | dt t t t t t" t | dt$ t t t t t" t | dt$ t t t t t& t | dt( t t t t t& t | dt( t t t t t" t | d t* t t t t t" | j, t | d t* t t t t t& | j, g| _ | j r| j j1 d | j. D ]; }|j2 t" u s| j5 |j6 |j8 = y ) NF r r r r r r r r z*requesting initial Telnet/RFC 2217 options) serialr[ r _client_is_rfc2217rc rm r ro modemstate_masklast_modemstate linstate_maskrY r r r r r rT r rV r r _client_okr r rb rp r^ r] )re serial_portr[ r r] s rP rg zPortManager.__init__ s\ ! $ "' " # # vtT4T9 M xdD"dI N z3D$h O {FD$D( S }fb$dI V |_dD"dT]_c_n_n o ~D$PTV^`d`o`o p ;; KK J K**F||y('' G +rh c d| _ | j r| j j d | j d y)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 2217force_notificationN)r r r check_modem_linesrm s rP r zPortManager._client_ok s9 #' ;; KK 6 7 $ 7rh c N | j j t |z |z yr )r[ r9 r7 r s rP rp z PortManager.telnet_send_option s cFlV 34rh c |j t t }| j j t t z t z |z |z t z t z y)z&Subnegotiation of RFC 2217 parameters.N)r6 r7 r8 r[ r9 rg r rh r s rP r z'PortManager.rfc2217_send_subnegotiation sB c;/ cBh 86 AE IC ORT TUrh c | j j xr t | j j xr t z | j j xr t z | j j xr t z }|| j xs dz }|t z r |t z }|t z r |t z }|t z r |t z }|t z r |t z }|| j k7 s|r| j r|| j z s|rc| j! t" t% || j z g | j& r*| j& j) dj+ | |dz | _ yy)z read control lines from serial port and compare the last value sent to remote. send updates on changes. r r} N)r rR rQ rV rU rY rX r] r\ r MODEMSTATE_MASK_CTS_CHANGEMODEMSTATE_MASK_DSR_CHANGEMODEMSTATE_MASK_RI_CHANGEMODEMSTATE_MASK_CD_CHANGEr r r r r r r rl )re r modemstatedeltass rP r z PortManager.check_modem_lines sU [[__ 4!4 [[__ 4!4 6 [[^^ 2 2 4 [[^^ 2 2 4 t 3 3 8q9 ' ' 4 4J ' ' 4 4J & & 3 3J & & 3 3J -- -1C''Z$:N:N-NTf00, j4+?+? ? @AC ;;KK$$%<%C%CJ%OP $.#4D 2Drh c # h K t | D ] }|t k( rt t | " yw)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 r7 re r1 rn s rP escapezPortManager.escape( s, dODs{ $s 02c # @ K t | D ] }| j t k( r<|t k( r t | _ ,| j | xj |z c_ N| S| j t k( r|t k( r2| j | xj |z c_ n| t | _ |t k( rt | _ t | _ |t k( r8| j t | j d| _ t | _ |t t t t fv r|| _ t | _ 2| j# | t | _ P| j t k( se| j% | j | t | _ yw)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 rm rc r7 rf r rg r) rh ri r. r r r r ro rj rk rl r s rP filterzPortManager.filter9 s, dODyyH$3; *DI ~~1 $. " j(3; ~~1 $. " (DIRZ%.[DN (DIRZ77dnn8MN%)DN (DIb$d 33*.D' +DI 006 (DIk)--d.A.A4H $ Q $s E/F 3+F c r | j r+| j j dj | yyrq rr rr s rP rk z#PortManager._telnet_process_commandt rs rh c T d}| j D ]% }|j |k( s|j | d}' |sp|t k( s |t k( r]| j |t k( rt nt | | j r+| j j dj | yyyyru rv rw s rP rl z$PortManager._telnet_negotiate_optionz rz rh c |dd t k( r| j r*| j j dj | |dd t k( r| j j } t j d|dd \ }|dk7 r|| j _ | j rD| j j dj |rdnd | j j | j t t j d| j j y |dd t k( r| j j } t j d |dd \ }|dk7 r|| j _ | j rD| j j dj |rdnd | j j | j t" t j d | j j y |dd t$ k( r| j j& } t j d |dd d }|dk7 rt( | | j _ | j rD| j j dj |rdnd | j j& | j t* t j d t, | j j& y |dd t. k( r| j j0 } t j d |dd d }|dk7 rt2 | | j _ | j rD| j j dj |rdnd | j j0 | j t4 t j d t6 | j j0 y |dd t8 k( r|dd t: k( r}| j j< r| j t> t@ y | j jB r| j t> tD y | j t> tF y |dd tF k( rdd| j _ d| j _! | j r| j j d | j t> tF y |dd t@ k( rSd| j _ | j r| j j d | j t> t@ y |dd tD k( rSd| j _! | j r| j j d | j t> tD y |dd tH k( r(| j r| j jK d y |dd tL k( rSd| j _' | j r| j j d | j t> tL y |dd tP k( rSd| j _' | j r| j j d | j t> tP y |dd tR k( r(| j r| j jK d y |dd tT k( rSd| j _+ | j r| j j d | j t> tT y |dd tX k( rSd| j _+ | j r| j j d | j t> tX y |dd tZ k( r(| j r| j jK d y |dd t\ k( rSd| j _/ | j r| j j d | j t> t\ y |dd t` k( rd| j _/ | j r| j j d! | j t> t` y |dd tb k( r!| j td tg dg y |dd th k( r:| j r| j j d" | jk d# y |dd tl k( r/| j r| j j d$ d| _7 y |dd tp k( r/| j r| j j d% d| _7 y |dd tr k( rUtu |dd | _; | j r~| j j d&j | jv y |dd tx k( rUtu |dd | _= | j r | j j d'j | jz y |dd t| k( r|dd t~ k( r\| j j | j r| j j d( | j t t~ y |dd t k( r\| j j | j r| j j d) | j t t y |dd t k( rv| j j | j j | j r| j j d* | j t t y | j r{| j j d+j t |dd y | j r7| j j d,j t |dd y y y y y y | j r+| j jK d-j | y y # t $ rR}| j r*| j j d j | || j _ Y d }~ d }~ww xY w# t $ rR}| j r*| j j dj | || j _ Y d }~ ?d }~ww xY w# t $ rR}| j r*| j j dj | || j _ Y d }~ d }~ww xY w# t $ rR}| j r*| j j dj | || j _ Y d }~ d }~ww xY w).r| r rF z received COM_PORT_OPTION: {!r}rE r z{} baud rate: {}r r, zfailed to set baud rate: {}Nr rG z{} data size: {}zfailed to set data size: {}z {} parity: {}zfailed to set parity: {}z{} stop bits: {}zfailed to set 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 suspendresumezline 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 r r rl r r r r unpackr rq r r r r r bytesizer r r RFC2217_REVERSE_PARITY_MAPr r r stopbitsRFC2217_REVERSE_STOPBIT_MAPr r r SET_CONTROL_REQ_FLOW_SETTINGxonxoffr r rtsctsr r SET_CONTROL_REQ_BREAK_STATEr rB break_conditionrC SET_CONTROL_REQ_DTRrL dtrrM SET_CONTROL_REQ_RTSrG rtsrH NOTIFY_LINESTATEr~ r r r r r r SET_LINESTATE_MASKr r SET_MODEMSTATE_MASKr r r< r r r> r PURGE_BOTH_BUFFERSlist)re r backupr r$ r r r s rP ri z*PortManager._telnet_process_subnegotiation s Qq>_ ,{{ !!"B"I"I)"TU1~ - -- x"(--y1~"FKX 1}/7 , {{ (();)B)BH5Z_aealalauau)vw001DfkkRWY]YdYdYmYmFno1Q </ -- x"(--y1~"FKX 1}/7 , {{ (();)B)BH5Z_aealalauau)vw001DfkkRWY]YdYdYmYmFno1Q :- ++ q #]]5)Aa. A! DF {-G-O * {{ (( )?)?UZ\`\g\g\n\n)op00%KK'9$++:L:L'MNP 1Q </ -- x %}}UIaN CA FH 1}/J8/T , {{ (();)B)BH5Z_aealalauau)vw00'KK':4;;;O;O'PQS 1Q ;. Qq>%AA{{** 889KMlm ++ 889KMlm 889KMlm q^'FF*/DKK').DKK&{{ (()GH445GIhi q^'FF*.DKK'{{ (()KL445GIhi q^'FF)-DKK&{{ (()JK445GIhi q^'BB{{ ++,UV q^';;26DKK/{{ (()BC445GI]^ q^'<<27DKK/{{ (()DE445GI^_ q^'::{{ ++,ST q^'99&*DKKO{{ (()@A445GI[\ q^'::&+DKKO{{ (()BC445GI\] q^'::{{ ++,ST q^'99&*DKKO{{ (()@A445GI[\ q^'::&+DKKO{{ (()BC445GI\] 1Q #3300+ aSM# 1Q #44;;KK$$%>?&&$&?1Q #66;;KK$$Y/,0)1Q #55;;KK$$X.,1)1Q #55%(1Q %8";;KK$$%@%G%GHZHZ%[\1Q #66'*9Qq>':$;;KK$$%A%H%HI]I]%^_1Q :- Qq>%99KK224{{ ((4445FH\] q^'<<KK335{{ ((5445FH]^ q^'99KK224KK335{{ (( 6445FHZ[{{ ))*F*M*MdS\]^]_S`Na*bc;;KK%%&G&N&NtT]^_^`TaOb&cd #) A ;| {{ ##$B$I$I)$TU e " 2{{ ))*G*N*Nq*QR+1DKK((2 " 2{{ ))*G*N*Nq*QR+1DKK((2 " 0{{ ))*D*K*KA*NO)/DKK&&0 " 2{{ ))*G*N*Nq*QR+1DKK((2sd '1q 1r4 -9t 9u0 r1 Ar,,r14 t=At t u-Au((u-0 w 9Aww rJ r )F)ru rv rw rx rg r rp r r r r rk rl ri rK rh rP r r sB HF8(5V 5H "7%vQ W&~Vrh r __main__zrfc2217://localhost:7000r z{} z write... s hello z read: {} ) __future__r r r r r r r ImportError urllib.parseparser queuer serial.serialutilr r r r r r DEBUGINFOWARNINGERRORr rh NOPDMBRKIPAOAYTECELGArg r r r r r7 r8 r r r r r r r r r r r r r r r r r r r r r r~ r SERVER_FLOWCONTROL_SUSPENDSERVER_FLOWCONTROL_RESUMESERVER_SET_LINESTATE_MASKSERVER_SET_MODEMSTATE_MASKr RFC2217_ANSWER_MAPr r r r r rB rC r rL rM r rG rH SET_CONTROL_REQ_FLOW_SETTING_IN"SET_CONTROL_USE_NO_FLOW_CONTROL_IN!SET_CONTROL_USE_SW_FLOW_CONTOL_IN!SET_CONTROL_USE_HW_FLOW_CONTOL_IN SET_CONTROL_USE_DCD_FLOW_CONTROL SET_CONTROL_USE_DTR_FLOW_CONTROL SET_CONTROL_USE_DSR_FLOW_CONTROLLINESTATE_MASK_TIMEOUT LINESTATE_MASK_SHIFTREG_EMPTY LINESTATE_MASK_TRANSREG_EMPTYLINESTATE_MASK_BREAK_DETECT LINESTATE_MASK_FRAMING_ERRORLINESTATE_MASK_PARTIY_ERROR LINESTATE_MASK_OVERRUN_ERRORLINESTATE_MASK_DATA_READYr\ rX rU rQ r r r r r< r> r PARITY_NONE PARITY_ODD PARITY_EVEN PARITY_MARK PARITY_SPACEr dictr r STOPBITS_ONESTOPBITS_ONE_POINT_FIVE STOPBITS_TWOr r rc rf rj rT rU rV rW objectrY rz r r ru syssstdoutr9 rl flushr3 r rK rh rP <module>r sb z ' $ ) ) ]] LL ]] ! " $ # # $ %%!%#-/3113! ' ") ") ") % ") %, "$+ !$+ !#* #* #* " " q "!P5G5M5M5O!P P ""A #"R6I6O6O6Q"R R #CN6 CNLDp6 DpNzGZ zG@QV& QVj z)62AJJV]]1%&JJ\"GGJGGIJJ\((34GGI S( $##$ s" K K# K K # K0/K0