3
M]W ( @ sl d dl Z d dlZd dlZd dlZd dlZy d dlZW n ek
rR d dljZY nX y d dl Z W n ek
r| d dl
Z Y nX d dl Z d dl m
Z
mZmZmZmZ e je je je jdZdZdZdZdZdZd Z d
Z d Z d Z d
Z dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0d Z1d Z2d Z3d Z4d Z5d!Z6d"Z7d#Z8d$Z9d%Z:d&Z;d'Zd*Z?d+Z@d,ZAd-ZBd.ZCe,e8e-e9e.e:e/e;e0ee3e?e4e@e5eAe6eBe7eCi ZDdZEdZFdZGdZHdZIdZJd ZKd ZLd ZMd ZNd ZOd!ZPd"ZQd/ZRd0ZSd1ZTd2ZUd3ZVd4ZWd5ZXd6ZYd7ZZd8Z[d9Z\d:Z]d;Z^de jod;e jpd?iZqerd@dA eqjs D Zte jud=e jvd>e jwd s rK c c s | ]\}}||fV qd S )NrF )rG rH rI rF rF rJ rK s REQUESTEDACTIVEINACTIVEREALLY_INACTIVEc @ s* e Zd ZdZd 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)
connectionnameoptionsend_yessend_noack_yesack_nostateactiveactivation_callback)
selfrQ rR rS rT rU rV rW Z
initial_staterZ rF rF rJ __init__ s
zTelnetOption.__init__c C s dj | dS )zString for debug outputsz {o.name}:{o.active}({o.state}))o)format)r[ rF rF rJ __repr__ s zTelnetOption.__repr__c C s& || j kr| jtkr4t| _d| _| jdk r| j nt| jtkr@nh| jtkr|t| _| jj| j | j
d| _| jdk r| j n,| jt kr| jj| j | j
nt
dj| nx|| jkr"| jtkrt| _d| _nT| jtkrt| _| jj| j | j
d| _n*| jtkrn | jt krnt
dj| 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)rV rX rL rM rY rZ rN rQ telnet_send_optionrT rS rO rU
ValueErrorr^ rW )r[ commandrF rF rJ process_incoming s<
z TelnetOption.process_incoming)N)__name__
__module__ __qualname____doc__r\ r_ rc rF rF rF rJ rP s
rP 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 kr |}|| _ || _|| _d | _|| _t| _d S )N)rQ rR rS value
ack_optionrN rX )r[ rQ rR rS rj rF rF rJ r\ 6 s z TelnetSubnegotiation.__init__c C s dj | dS )zString for debug outputs.z{sn.name}:{sn.state})Zsn)r^ )r[ rF rF rJ r_ @ s z TelnetSubnegotiation.__repr__c C sD || _ t| _| jj| j| j | jjr@| jjjdj| 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)
ri rL rX rQ rfc2217_send_subnegotiationrS loggerr r^ rR )r[ ri rF rF rJ setD s
zTelnetSubnegotiation.setc C s$ | j tkrtdj| 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})rX rO ra r^ rR rM )r[ rF rF rJ is_readyP s
z TelnetSubnegotiation.is_readyrD c C sF t j | }x4t j |k r0t jd | j rP qW tdj| jdS )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.
g?z%timeout while waiting for option {!r}N)timesleeprn r r^ rR )r[ timeout timeout_timerF rF rJ wait[ s
zTelnetSubnegotiation.waitc C sN | j |dt| j kr t| _nt| _| jjrJ| jjjdj| 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} -> {})
ri lenrM rX rO rQ rl r r^ rR )r[ suboptionrF rF rJ check_answeri s
z!TelnetSubnegotiation.check_answer)N)rD ) rd re rf rg r\ r_ rm rn propertyrY rs rv rF rF rF rJ rh 0 s
rh c s e Zd ZdZdMZ fddZdd Zdd Zdd Zdd Z e
d d Z dNd d!Z d"d# Z
d$d% Zd&d' Zd(d) Zd*d+ Zd,d- Ze
d.d/ Ze
d0d1 Ze
d2d3 Ze
d4d5 Zd6d7 Zd8d9 Zd:d; Zdd? Zd@dA Z dOdCdDZ dEdF Z dGdH Z dIdJ Z dKdL Z! Z"S )PSerialz|j? qW t@j@ | j }xTt@j@ |k rt@jAd tBd d |D tBd d |D krPP qPW td!j|| j r| j jCd"j| j! | jD | jEs| jF | jGs| jH | jI | jJ W n | jK Y nX dS )#zx Open port with current settings. This may throw a SerialException
if the port cannot be opened.
NFrD z.Port must be configured before it can be used.zPort is already open.rE )rq rC zCould not open port {}: {}z we-BINARYz
we-RFC2217ECHOzwe-SGAzthey-SGAz they-BINARYz they-RFC2217baudratedatasizeparitystopsize)r r r r purgecontrol)r r r T)targetz&pySerial RFC 2217 reader thread for {}g?c s s | ] }|j V qd S )N)rY )rG r] rF rF rJ rK s z Serial.open..c s s | ]}|j tkV qd S )N)rX rN )rG r] rF rF rJ rK s z;Remote does not seem to support RFC2217 or BINARY mode {!r}zNegotiated options: {})Lrl r r r Z_portr is_opensocketZcreate_connectionfrom_urlZportstrr Z
setsockoptZ IPPROTO_TCPZ TCP_NODELAY Exceptionr^ Queuer threadingZLockr rP BINARYWILLWONTDODONTrN COM_PORT_OPTIONrL r SGAr rh 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 ZThread_telnet_read_loopr Z setDaemonZsetNamestartrX r` rT rS ro rp sumr _reconfigure_portZ_dsrdtr_update_dtr_state_rtscts_update_rts_statereset_input_bufferreset_output_bufferclose)r[ msgZmandadory_optionsrS rr rF rF rJ open s~
$
& z Serial.openc C s | j dkrtd| jdk r$tdd| j k o8dk n sNtdj| j| jd jt j
d | j | jd
jt j
d | j | jd jt j
d t | j
| jd
jt j
d t| j | jj }| jr| jjdj| tj | j }xFtj |k r&tjd tdd |D t|krP qW tdj|| jrP| jjdj| | jrj| jrjtdn2| jr~| jt n | jr| jt n
| jt dS )z,Set communication parameters on opened port.Nz Can only operate on open portsz(write_timeout is currently not supportedr rB r> zinvalid baudrate: {!r}r s !Ir s !Br r zNegotiating settings: {}g?c s s | ] }|j V qd S )N)rY )rG r] rF rF rJ rK s z+Serial._reconfigure_port..z7Remote does not accept parameter change (RFC2217): {!r}zNegotiated settings: {}z-xonxoff and rtscts together are not supportedl ) r r Z_write_timeoutNotImplementedErrorZ _baudratera r^ r rm structpackZ _bytesizeRFC2217_PARITY_MAPZ_parityRFC2217_STOPBIT_MAPZ _stopbitsvaluesrl r ro r rp r rt r r Z_xonxoffrfc2217_set_control SET_CONTROL_USE_HW_FLOW_CONTROL SET_CONTROL_USE_SW_FLOW_CONTROL SET_CONTROL_USE_NO_FLOW_CONTROL)r[ itemsrr rF rF rJ r s8
zSerial._reconfigure_portc C sb d| _ | jr6y | jjtj | jj W n Y nX | jrX| jjd d| _tj d d| _dS )z
Close portF Ng333333?)
r r Zshutdownr Z SHUT_RDWRr r joinro rp )r[ rF rF rJ r s
z Serial.closec C s. t j|}|jdkr$tdj|jyxt j|jdj D ]\}}|dkrtj tj
d| _ | j j t
|d | j jd q:|dkrd| _q:|d krd| _q:|d
krt|d | _q:td j|q:W d|j kod k n std
W n2 tk
r } ztdj|W Y dd}~X nX |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://:[?option[&option...]]": not starting with rfc2217:// ({!r})TloggingzpySerial.rfc2217r zenabled loggingZign_set_controlZ
poll_modemrq zunknown option: {!r}i zport not in range 0...65535zPexpected a string in the form "rfc2217://:[?option[&option...]]": {}N)urlparseZurlsplitschemer r^ Zparse_qsZqueryr r Z basicConfigZ getLoggerrl ZsetLevel
LOGGER_LEVELSr r r floatr ra ZportZhostname)r[ ZurlpartsrS r erF rF rJ r - s4
zSerial.from_urlc C s | j s
t| jj S )z9Return the number of bytes currently in the input buffer.)r r r qsize)r[ rF rF rJ
in_waitingR s zSerial.in_waitingrC c C sl | j s
tt }y| jt n
| jt dS )z[ Set break: Controls TXD. When active, to transmitting is
possible.
zset BREAK to {}rY inactiveN) r r rl r r^ Z _break_stater SET_CONTROL_BREAK_ONSET_CONTROL_BREAK_OFF)r[ rF rF rJ _update_break_state s zSerial._update_break_statec C sL | j s
t| jr,| jjdj| jr$dnd | jr>| jt n
| jt dS )z*Set terminal status line: Request To Send.z
set RTS to {}rY r N) r r rl r r^ Z
_rts_stater SET_CONTROL_RTS_ONSET_CONTROL_RTS_OFF)r[ rF rF rJ r s zSerial._update_rts_statec C sL | j s
t| jr,| jjdj| jr$dnd | jr>| jt n
| jt dS )z.Set terminal status line: Data Terminal Ready.z
set DTR to {}rY r N) r r rl r r^ Z
_dtr_stater SET_CONTROL_DTR_ONSET_CONTROL_DTR_OFF)r[ rF rF rJ r s zSerial._update_dtr_statec C s | j s
tt| j t@ S )z)Read terminal status line: Clear To Send.)r r boolget_modem_stateMODEMSTATE_MASK_CTS)r[ rF rF rJ cts s z
Serial.ctsc C s | j s
tt| j t@ S )z*Read terminal status line: Data Set Ready.)r r r r MODEMSTATE_MASK_DSR)r[ rF rF rJ dsr s z
Serial.dsrc C s | j s
tt| j t@ S )z*Read terminal status line: Ring Indicator.)r r r r MODEMSTATE_MASK_RI)r[ rF rF rJ ri s z Serial.ric C s | j s
tt| j t@ S )z*Read terminal status line: Carrier Detect.)r r r r MODEMSTATE_MASK_CD)r[ rF rF rJ cd s z Serial.cdc C s t }d}z|xt| jry| jjd}W nT tjk
r@ wY n> tjk
r| } z | jrj| jjdj | P W Y dd}~X nX |sP xt
|D ]}|t kr|t krt }n |dk r||7 }n | j
j| q|t krd|t kr |dk r|t 7 }n | j
jt t }nb|tkrt }t }nL|tkr8| jt| d}t }n*|ttttfkrT|}t}n| j| t }q|tkr| j|| t }qW qW W dd| _| jr| jjd X dS )zRead loop for the socket.Ni z!socket error in reader thread: {}zread thread terminated) M_NORMALr r Zrecvr rq r
rl r r^ r r
M_IAC_SEENr ZputSBr SE _telnet_process_subnegotiationr r r r r M_NEGOTIATE_telnet_process_command_telnet_negotiate_optionr )r[ moderu r r bytetelnet_commandrF rF rJ r sZ
zSerial._telnet_read_loopc C s | j r| j jdj| dS )z1Process commands other than DO, DONT, WILL, WONT.z ignoring Telnet command: {!r}N)rl r r^ )r[ rb rF rF rJ r s z Serial._telnet_process_commandc C st d}x&| j D ] }|j|kr |j| d}q W |sp|tks@|tkrp| j|tkrPtnt| | jrp| jj dj
| dS )z&Process incoming DO, DONT, WILL, WONT.FTz rejected Telnet option: {!r}N) r rS rc r r r` r r rl r r^ )r[ rb rS knownitemrF rF rJ r s
z Serial._telnet_negotiate_optionc C s\ |dd t kr>|dd tkr\t|dkr\t|dd | _| jrZ| jjdj| j n|dd tkrt|dkrt|dd | _ | jr| jjdj| j t
j
d | _ n|dd t krd| _
np|dd tkrd | _
nXxr| jj D ].}|j|dd kr|jt|dd
P qW | jrX| jjd j| n| jrX| jjd j| d
S )
z;Process subnegotiation, the data between IAC SB and IAC SE.r rC rB rD zNOTIFY_LINESTATE: {}zNOTIFY_MODEMSTATE: {}g333333?TFNz ignoring COM_PORT_OPTION: {!r}z ignoring subnegotiation: {!r})r SERVER_NOTIFY_LINESTATErt ordr rl r r^ SERVER_NOTIFY_MODEMSTATEr ro r FLOWCONTROL_SUSPENDr FLOWCONTROL_RESUMEr r rj rv r r )r[ ru r rF rF rJ r - s, z%Serial._telnet_process_subnegotiationc C s" | j | jj| W dQ R X dS )zGinternal socket write with no data escaping. used to send telnet stuff.N)r r r )r[ r rF rF rJ _internal_raw_writeM s zSerial._internal_raw_writec C s | j tt||g dS )zSend DO, DONT, WILL, WONT.N)r r r )r[ actionrS rF rF rJ r` R s zSerial.telnet_send_option c C s6 |j tt}| jtttt|gt| ttg dS )z%Subnegotiation of RFC2217 parameters.N) r r r r r r r listr )r[ rS ri rF rF rJ rk V s z"Serial.rfc2217_send_subnegotiationc C s$ | j d }|j| |j| j dS )z~ Send purge request to the remote.
(PURGE_RECEIVE_BUFFER / PURGE_TRANSMIT_BUFFER / PURGE_BOTH_BUFFERS)
r N)r rm rs r )r[ ri r rF rF rJ r [ s
zSerial.rfc2217_send_purgec C s6 | j d }|j| | jr&tjd n |j| j dS )z)transmit change of control line to remoter g?N)r rm r ro rp rs r )r[ ri r rF rF rJ r d s
zSerial.rfc2217_set_controlc C s dS )z` check if server is ready to receive data. block for some time when
not.
NrF )r[ rF rF rJ rfc2217_flow_server_readyp s z Serial.rfc2217_flow_server_readyc C s | j r|| jtj k r|| jr&| jjd | jt tj | j }x a,%
C
rx 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| _| jr| jjd x(| jD ] }|jtkr| j|j|j qW d S ) NF r r zwe-SGAzthey-SGAz we-BINARYz they-BINARYz
we-RFC2217z they-RFC2217z*requesting initial Telnet/RFC 2217 options) serialrQ rl _client_is_rfc2217r r ru r
modemstate_masklast_modemstate
linstate_maskrP r r r r r rL r rN r r
_client_okr r rX r` rT rS )r[ Z serial_portrQ rl rS rF rF rJ r\ s,
zPortManager.__init__c C s( d| _ | jr| jjd | 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 rl r check_modem_lines)r[ rF rF rJ r s zPortManager._client_okc C s | j jtt||g dS )zSend DO, DONT, WILL, WONT.N)rQ r r r )r[ r rS rF rF rJ r` s z PortManager.telnet_send_optionr c C s8 |j tt}| jjtttt|gt| tt g dS )z&Subnegotiation of RFC 2217 parameters.N)
r r r rQ r r r r r r )r[ rS ri rF rF rJ rk s z'PortManager.rfc2217_send_subnegotiationFc C s | j j o t| j j otB | j j o&tB | j j o4tB }|| j pBdA }|t@ rV|t
O }|t@ rf|t O }|t@ rv|t O }|t@ r|t
O }|| j ks|r| jr|| j@ s|r| jtt|| j@ g | jr| jjdj| |d@ | _ dS )z read control lines from serial port and compare the last value sent to remote.
send updates on changes.
r zNOTIFY_MODEMSTATE: {} N)r ZgetCTSr ZgetDSRr ZgetRIr ZgetCDr r MODEMSTATE_MASK_CTS_CHANGEMODEMSTATE_MASK_DSR_CHANGEMODEMSTATE_MASK_RI_CHANGEMODEMSTATE_MASK_CD_CHANGEr r rk r r rl r r^ )r[ r! Z
modemstateZdeltasrF rF rJ r" s& (z PortManager.check_modem_linesc c s2 x,t |D ] }|tkr$tV tV q
|V q
W dS )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 rF rF rJ escape
s
zPortManager.escapec c s xt |D ]}| jtkrN|tkr,t| _n | jdk rF| j|7 _n|V q | jtkr|tkr| jdk rz| j|7 _n|V t| _nl|tkrt | _t| _nT|tkr| j t
| j d| _t| _n.|t t t
tfkr|| _t| _n| j| t| _q | jtkr | j| j| t| _q W dS )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 ru r r r r r r r r r r
r r r )r[ r r rF rF rJ filter s8
zPortManager.filterc C s | j r| j jdj| dS )z1Process commands other than DO, DONT, WILL, WONT.z ignoring Telnet command: {!r}N)rl r r^ )r[ rb rF rF rJ r Y s z#PortManager._telnet_process_commandc C st d}x&| j D ] }|j|kr |j| d}q W |sp|tks@|tkrp| j|tkrPtnt| | jrp| jj dj
| dS )z&Process incoming DO, DONT, WILL, WONT.FTz rejected Telnet option: {!r}N) r rS rc r r r` r r rl r r^ )r[ rb rS r r rF rF rJ r _ s
z$PortManager._telnet_negotiate_optionc C s4 |dd t k r| jr*| jjdj| |dd tkr| jj}y*tjd|dd \}|dkrj|| j_W nB t k
r } z&| jr| jj
dj| || j_W Y dd}~X n(X | jr| jj d j|rd
nd | jj | j t
tjd| jj q0|dd tkr| jj}y,tjd |dd
\}|dkr6|| j_W nF t k
r~ } z(| jrf| jj
dj| || j_W Y dd}~X n,X | jr| jj dj|rd
nd | jj | j ttjd | jj q0|dd tkr| jj}y2tjd |dd
d }|dkrt| | j_W nF t k
rX } z(| jr@| jj
dj| || j_W Y dd}~X n,X | jr| jj dj|rvd
nd | jj | j ttjd t| jj q0|dd tkr| jj}y2tjd |dd
d }|dkrt| | j_W nF t k
r6 } z(| jr | jj
dj| || j_W Y dd}~X n,X | jrb| jj dj|rTd
nd | jj | j ttjd t| jj q0|dd t kr|dd
t kr| jj r| j t t n$| jj!r| j t t" n | j t t# q|dd
t#kr,d| j_ d| j_!| jr | jj d | j t t# q|dd
t krjd| j_ | jrZ| jj d | j t t q|dd
t"krd| j_!| jr| jj d | j t t" q|dd
t$kr| jr| jj%d q|dd
t&kr| jj'd | jr| jj d | j t t& q|dd
t(krV| jj'd | jrF| jj d | j t t( q|dd
t)kr| jr| jj%d q|dd
t*kr| jj+d | jr| jj d | j t t* n|dd
t,kr | jj+d | jr| jj d | j t t, n|dd
t-kr(| jr| jj%d n~|dd
t.krh| jj/d | jrZ| jj d | j t t. n>|dd
t0k r| jj/d | jr| jj d! | j t t0 q0|dd t1kr| j t2t3dg q0|dd t4kr| jr| jj d" | j5dd# q0|dd t6kr8| jr.| jj d$ d| _7 q0|dd t8krh| jr^| jj d% d| _7 q0|dd t9krt:|dd
| _;| j r| jj d&j| j; q0|dd tkr|dd
t?kr@| jj@ | jr2| jj d( | j tAt? n|dd
tBkr~| jjC | jrp| jj d) | j tAtB nn|dd
tDkr| jj@ | jjC | jr| jj d* | j tAtD n&| j r| jj
d+jtE|dd n&| j r0| jj
d,jtE|dd n| j r0| jj%d-j| dS ).z;Process subnegotiation, the data between IAC SB and IAC SE.r rC z received COM_PORT_OPTION: {!r}rB s !I zfailed to set baud rate: {}Nz{} baud rate: {}rm r s !BrD 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 state)r! 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 rl r r^ r r r r unpackra r
r rk r r r Zbytesizer r r RFC2217_REVERSE_PARITY_MAPr r r stopbitsRFC2217_REVERSE_STOPBIT_MAPr r r SET_CONTROL_REQ_FLOW_SETTINGZxonxoffr r Zrtsctsr r SET_CONTROL_REQ_BREAK_STATEr r ZsetBreakr SET_CONTROL_REQ_DTRr ZsetDTRr SET_CONTROL_REQ_RTSr ZsetRTSr NOTIFY_LINESTATEr
r r r" r r r SET_LINESTATE_MASKr r SET_MODEMSTATE_MASKr r r r r r r PURGE_BOTH_BUFFERSr )r[ ru Zbackupr r r r r- rF rF rJ r r sV
"
"
"
z*PortManager._telnet_process_subnegotiation)N)r )F)rd re rf rg r\ r r` rk r" r( r) r r r rF rF rF rJ r s
#
$;r __main__zrfc2217://localhost:7000i z{}
z write...
s hello
z read: {}
)r r r r ro r ImportErrorZ urllib.parseparser Zqueuer Zserial.serialutilr r r r r DEBUGINFOZWARNINGZERRORr r ZNOPZDMZBRKZIPZAOZAYTZECZELZGAr r r r r r r r r r r r r r r r r3 r r r r4 r5 r r r r r r r
r ZSERVER_FLOWCONTROL_SUSPENDZSERVER_FLOWCONTROL_RESUMEZSERVER_SET_LINESTATE_MASKZSERVER_SET_MODEMSTATE_MASKr ZRFC2217_ANSWER_MAPr/ r r r r0 r r r1 r r r2 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 r' r& r% r$ r r r6 Z PARITY_NONEZ
PARITY_ODDZ PARITY_EVENZ PARITY_MARKZ PARITY_SPACEr dictr r, Z STOPBITS_ONEZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWOr r. r r r rL rM rN rO objectrP rh rx r rd syssstdoutr r^ flushr r rF rF rF rJ = s.
FG ,