/usr/lib/python3/dist-packages/serial/__pycache__
Edit: /usr/lib/python3/dist-packages/serial/__pycache__/rfc2217.cpython-310.pyc (32296B)
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*ZAd+ZBd,ZCd-ZDd.ZEd/ZFe/e;e0ee3e?e4e@e5eAe6eBe7eCe8eDe9eEe:eFi ZGdZHdZIdZJdZKdZLd ZMd ZNd ZOd ZPd ZQd!ZRd"ZSd#ZTd0ZUd1ZVd2ZWd3ZXd4ZYd5ZZd6Z[d7Z\d8Z]d9Z^d:Z_d;Z`dZcd7Zdd8Zed9Zfd:Zgd;ZhdZkdZldZmdZne
jod>e
jpd=e
jqd?e
jrde
jyd?e
jzd=iZ{eudCdB e{v D Z|d Z}d>Z~d=ZdDZdEZdFZdGZG dHdI dIeZG dJdK dKeZG dLdM dMeZG dNdO dOeZedPkrd dlZedQdRZejdSe ejdT edU e ejdVed@ e dS dS )W )absolute_importN)
SerialBaseSerialExceptionto_bytes iterbytesPortNotOpenErrorTimeout)debuginfowarningerror s ,
e f g h i j k l m n o p
@ c c | ] \}}||fV qd S N .0kvrJ rJ 0/usr/lib/python3/dist-packages/serial/rfc2217.py rP c c rH rI rJ rK rJ rJ rO rP rQ REQUESTEDACTIVEINACTIVEREALLY_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)
connectionnameoptionsend_yessend_noack_yesack_nostateactiveactivation_callback)
selfrW rX rY rZ r[ r\ r]
initial_stater` rJ rJ rO __init__ s
zTelnetOption.__init__c C dj | dS )zString for debug outputsz {o.name}:{o.active}({o.state}))oformatra 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[
ValueErrorrg r] ra commandrJ rJ rO process_incoming sB
z TelnetOption.process_incomingrI )__name__
__module__ __qualname____doc__rc ri ro 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 rv rJ rJ rO rc 9 s
z TelnetSubnegotiation.__init__c C rd )zString for debug outputs.z{sn.name}:{sn.state})snrf rh rJ rJ rO ri C rj z TelnetSubnegotiation.__repr__c C sH || _ t| _| j| j| j | jjr"| jjd| 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)
ru rR r^ rW rfc2217_send_subnegotiationrY loggerr rg rX )ra ru 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 rl rg rX rS rh rJ rJ rO is_readyS s
z TelnetSubnegotiation.is_readyrF c C s> t |}| std | 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 expiredtimesleepr{ r rg rX )ra timeout
timeout_timerrJ rJ rO wait^ s
zTelnetSubnegotiation.waitc C sR | j |dt| j krt| _nt| _| jjr'| jjd| 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} -> {})
ru lenrS r^ rU rW ry r rg rX )ra suboptionrJ rJ rO check_answerl s z!TelnetSubnegotiation.check_answerrI )rF ) rp rq rr rs rc ri rz r{ propertyr_ r r rJ rJ rJ rO rt 3 s
rt 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|j?|j@ q t4| j}|A sCtBCd 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-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 s | ]}|j V qd S rI r_ rL re rJ rJ rO rP z Serial.open..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: {})Nry r r r _portr is_opensocketcreate_connectionfrom_urlportstrr
setsockopt IPPROTO_TCP TCP_NODELAY Exceptionrg Queuer threadingLockr rV BINARYWILLWONTDODONTrT COM_PORT_OPTIONrR r SGAr rt 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 setDaemonsetNamestartr^ rk rZ rY r} r~ r sumr
_reconfigure_port_dsrdtr_update_dtr_state_rtscts_update_rts_statereset_input_bufferreset_output_bufferclose)ra msgmandadory_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| jd
| t| j}| std tdd |D t|krn | rxtd|| jr| jd| | jr| j rtd| 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: {}r| c s r rI r r rJ rJ rO rP r z+Serial._reconfigure_port..z7Remote does not accept parameter change (RFC2217): {!r}zNegotiated settings: {}z-xonxoff and rtscts together are not supported)!r r _write_timeoutNotImplementedError _baudraterl rg r rz structpack _bytesizeRFC2217_PARITY_MAP_parityRFC2217_STOPBIT_MAP _stopbitsvaluesry 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)ra itemsr rJ rJ rO r s:
zSerial._reconfigure_portc C s^ d| _ | jrz| jtj | j W n Y | jr*| jd d| _t d d| _dS )z
Close portF N333333?)
r r shutdownr SHUT_RDWRr r joinr~ r rh rJ rJ rO r s
z Serial.closec
C s t |}|jdkrtd|jzdt |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
rfc2217zqexpected a string in the form "rfc2217://:[?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://:[?option[&option...]]": {}N)urlparseurlsplitschemer rg parse_qsqueryr r basicConfig getLoggerry setLevel
LOGGER_LEVELSr r r floatr rl porthostname)ra urlpartsrY 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 qsizerh 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 _timeoutr r is_aliver r get time_leftbytesr} r Empty)ra sizedatar bufrJ rJ rO read\ s0
z Serial.readc C s | j st | j. z| jt|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 replaceIAC IAC_DOUBLEDr r r rg r )ra r r rJ rJ rO writet s
z Serial.writec C s> | j st | t | j r | jd | j sdS dS )z9Clear input buffer, discarding all that is in the buffer.FN)r r rfc2217_send_purgePURGE_RECEIVE_BUFFERr r r rh 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_BUFFERrh rJ rJ rO r s zSerial.reset_output_bufferc C P | j st | jr| jd| jrdnd | jr!| t dS | t dS )z[ Set break: Controls TXD. When active, to transmitting is
possible.
zset BREAK to {}r_ inactiveN) r r ry r
rg _break_stater SET_CONTROL_BREAK_ONSET_CONTROL_BREAK_OFFrh 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 ry r
rg
_rts_stater SET_CONTROL_RTS_ONSET_CONTROL_RTS_OFFrh 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 ry r
rg
_dtr_stater SET_CONTROL_DTR_ONSET_CONTROL_DTR_OFFrh rJ rJ rO r r0 zSerial._update_dtr_statec C | j st t| t@ S )z)Read terminal status line: Clear To Send.)r r boolget_modem_stateMODEMSTATE_MASK_CTSrh rJ rJ rO cts z
Serial.ctsc C r4 )z*Read terminal status line: Data Set Ready.)r r r5 r6 MODEMSTATE_MASK_DSRrh rJ rJ rO dsr r9 z
Serial.dsrc C r4 )z*Read terminal status line: Ring Indicator.)r r r5 r6 MODEMSTATE_MASK_RIrh rJ rJ rO ri r9 z Serial.ric C r4 )z*Read terminal status line: Carrier Detect.)r r r5 r6 MODEMSTATE_MASK_CDrh rJ rJ rO cd r9 z Serial.cdc
C s t }d}z| jrz| jd}W n. tjy Y q tjy> } z| jr.| jd | | 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| jd dS dS | jr| jd w w )zRead loop for the socket.Ni z!socket error in reader thread: {}zread thread terminated)M_NORMALr r recvr r r ry r rg r putr r!
M_IAC_SEENSBr SE _telnet_process_subnegotiationr r r r r M_NEGOTIATE_telnet_process_command_telnet_negotiate_option)ra moder r r bytetelnet_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}Nry r rg rm rJ rJ rO rH 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 ro r r rk r r ry r rg ra rn rY knownitemrJ rJ rO rI $
z Serial._telnet_negotiate_optionc C sj |dd t kr|dd tkr0t|dkr0t|dd | _| jr.| jd| j d
S d
S |dd tkr\t|dkr\t|dd | _ | jrT| jd| 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| jd | d
S d
S | jr| jd | 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 ry r
rg SERVER_NOTIFY_MODEMSTATEr r restartFLOWCONTROL_SUSPENDr FLOWCONTROL_RESUMEr r rv r r r )ra r rV rJ rJ rO rF 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)r` r! ra actionrY rJ rJ rO rk \ s zSerial.telnet_send_option c C s2 | tt}| tt t | | t t dS )z%Subnegotiation of RFC2217 parameters.N)r r! r" r` rD r rE ra rY ru rJ rJ rO rx ` 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 rz r r ra ru rV rJ rJ rO r$ e s
zSerial.rfc2217_send_purgec C s8 | j d }|| | jrtd dS || j dS )z)transmit change of control line to remoter g?N)r rz r r~ r r r rf 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 rh rJ rJ rO rfc2217_flow_server_readyz s z Serial.rfc2217_flow_server_readyc C s | j r7| j r7| jr| jd | t t| j}| s.t
d | j s*n
| r | jr7| j d | j durH| jrE| jd | 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 failedNzusing cached modem statez!remote sends no NOTIFY_MODEMSTATE)r r r} ry r rx NOTIFY_MODEMSTATEr r r~ r r r r )ra r rJ rJ rO r6 s"
zSerial.get_modem_state)rE rd )#rp rq rr rs BAUDRATESrc r r r r r r r r# r r r, r r r8 r; r= r? r rH rI rF r` rk rx r$ r rg r6
__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| jd | jD ]}|jtu r| |j|j qwd S ) NF r r r r r r r r z*requesting initial Telnet/RFC 2217 options) serialrW ry _client_is_rfc2217r@ rJ r rL modemstate_masklast_modemstate
linstate_maskrV r r r r r rR r rT r r
_client_okr r r^ rk rZ rY )ra serial_portrW ry rY rJ rJ rO rc s2
zPortManager.__init__c C s( d| _ | jr | jd | 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 2217force_notificationN)ro ry r
check_modem_linesrh rJ rJ rO rs s zPortManager._client_okc C s | j t| | dS ra )rW r# r! rb rJ rJ rO rk s z PortManager.telnet_send_optionrd c C s4 | tt}| jtt t | | t t dS )z&Subnegotiation of RFC 2217 parameters.N)r r! r" rW r# rD r rE re rJ rJ rO rx 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| jd| |d@ | _ dS dS )z read control lines from serial port and compare the last value sent to remote.
send updates on changes.
r rY N)rn r8 r7 r; r: r= r< r? r> rq MODEMSTATE_MASK_CTS_CHANGEMODEMSTATE_MASK_DSR_CHANGEMODEMSTATE_MASK_RI_CHANGEMODEMSTATE_MASK_CD_CHANGEro rp rx r\ r ry r
rg )ra rv
modemstatedeltasrJ rJ rO rw 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 rK 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 rJ r@ r! rC r rD r rE rF r r r r r rL rG rH rI r rJ rJ rO filter( s>
zPortManager.filterc C rM rN rO rm rJ rJ rO rH c rP z#PortManager._telnet_process_commandc C rQ rR rS rT rJ rJ rO rI i rW z$PortManager._telnet_negotiate_optionc
C sF |dd t kr| jr| jd| |dd tkrz| jj}ztd|dd \}|dkr5|| j_W n" t yX } z| jrJ| j
d| || j_W Y d}~nd}~ww | jrl| j d |red
nd | jj | t
td| jj dS |dd tkr| jj}ztd |dd
\}|dkr|| j_W n" t y } z| jr| j
d| || j_W Y d}~nd}~ww | jr| j d|rd
nd | jj | ttd | jj dS |dd tkrO| jj}ztd |dd
d }|dkrt| | j_W n$ t y) } z| jr| j
d| || j_W Y d}~nd}~ww | jr?| j d|r8d
nd | jj | ttd t| jj dS |dd tkr| jj}ztd |dd
d }|dkrtt| | j_W n$ t y } z| jr| j
d| || j_W Y d}~nd}~ww | jr| j d|rd
nd | jj | ttd 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(krd| j_'| jr| j d | t t( dS |dd
t)kr| jr| j%d dS |dd
t*krd| j_+| jr| j d | t t* dS |dd
t,krd| 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 t9krt:|dd
| _;| jr| j d&| j; dS dS |dd tkr{|dd
t?kr | j@ | jr| j d( | tAt? dS |dd
tBkr?| jC | jr7| j d) | tAtB dS |dd
tDkrd| j@ | jC | jr\| j d* | tAtD dS | jry| j
d+tE|dd dS dS | jr| j
d,tE|dd dS dS | jr| j%d-| dS dS ).rX r rE z received COM_PORT_OPTION: {!r}rD r zfailed to set baud rate: {}Nz{} baud rate: {}rz 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 stateru 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 ry r rg r rn r r unpackrl r r
rx 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 r* break_conditionr+ SET_CONTROL_REQ_DTRr2 dtrr3 SET_CONTROL_REQ_RTSr. rtsr/ NOTIFY_LINESTATErZ r rh rw r^ r r_ SET_LINESTATE_MASKr[ rr SET_MODEMSTATE_MASKrp r r% r r r& r PURGE_BOTH_BUFFERSlist)ra r backupr r r r r rJ rJ rO rF | s
"
"
""z*PortManager._telnet_process_subnegotiationrI ri )F)rp rq rr rs rc rs rk rx rw r r rH rI rF rJ rJ rJ rO rl s
#
$; rl __main__zrfc2217://localhost:7000r z{}
z write...
s hello
z read: {}
)
__future__r r r r r r~ r ImportError urllib.parseparser queuern serial.serialutilr r r r r r DEBUGINFOWARNINGERRORr rE NOPDMBRKIPAOAYTECELGArD r r r r r! r" r r r r r r r r r r rh r^ r_ r r r r r r r r rZ r\ SERVER_FLOWCONTROL_SUSPENDSERVER_FLOWCONTROL_RESUMESERVER_SET_LINESTATE_MASKSERVER_SET_MODEMSTATE_MASKr RFC2217_ANSWER_MAPr r r r r r* r+ r r2 r3 r r. r/ 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> r< r: r7 r| r{ rz ry r% r& r PARITY_NONE
PARITY_ODD PARITY_EVEN PARITY_MARK PARITY_SPACEr dictr r STOPBITS_ONESTOPBITS_ONE_POINT_FIVE STOPBITS_TWOr r r@ rC rG rR rS rT rU objectrV rt r rl rp syssstdoutr# rg flushr r rJ rJ rJ rO s@ <
FG 3