3
MÊ]W@# ã @ s¨ d dl Z d dlZd dlZy d dlZW n ek
rB d dljZY nX dd„ Zdd„ ZG dd„ de ƒZ
G dd „ d e ƒZ G d
d „ d ej ƒZ e
d kr¤e dƒZd
e_eeƒ dS )é Nc c s´ d}xrt j| ƒD ]d}djt|ƒƒd| ko2dk n rB|jdƒndfV |d7 }|dkrbdV q|d krdV d}qW |dkr°x(|d k r¨|d7 }|dkr dV dV q‚W dV d S )z• yield tuples of hex and ASCII display in multiples of 16. Includes a
space after 8 bytes and (None, None) after 16 bytes and at the end.
r z{:02X} ó ó ÚasciiÚ.é é ú Ú é Nú )r r )NN)r r )r r )NN)ÚserialZ iterbytesÚformatÚordÚdecode)ÚdataÚnÚb© r ú"/usr/lib/python3.6/protocol_spy.pyÚsixteen" s 6
r c c s€ g }g }d}xnt | ƒD ]b\}}|dkrd|djdj|ƒdj|ƒgƒfV |dd…= |dd…= |d7 }q|j|ƒ |j|ƒ qW dS )z yield lines with hexdump of datar Nr r r
)r ÚjoinÚappend)r Úvaluesr ÚoffsetÚhÚar r r Úhexdump9 s
r c @ s0 e Zd ZdZdd„ Zdd„ Zdd„ Zdd „ Zd
S ) Ú FormatRawz&Forward only RX and TX data to output.c C s || _ || _d| _d| _d S )Nz[32mz[31m)ÚoutputÚcolorÚrx_colorÚtx_color)Úselfr r r r r Ú__init__L s zFormatRaw.__init__c C s. | j r| jj| jƒ | jj|ƒ | jjƒ dS )zshow received dataN)r r Úwriter Úflush)r" r r r r ÚrxR s z FormatRaw.rxc C s. | j r| jj| jƒ | jj|ƒ | jjƒ dS )zshow transmitted dataN)r r r$ r! r% )r" r r r r ÚtxY s z FormatRaw.txc C s dS )z(do not) show control callsNr )r" ÚnameÚvaluer r r Úcontrol` s zFormatRaw.controlN)Ú__name__Ú
__module__Ú __qualname__Ú__doc__r# r& r' r* r r r r r I s
r c @ s: e Zd ZdZdd„ Zddd„Zdd„ Zd d
„ Zd d „ Zd
S )Ú
FormatHexdumpax Create a hex dump of RX ad TX data, show when control lines are read or
written.
output example::
000000.000 Q-RX flushInput
000002.469 RTS inactive
000002.773 RTS active
000003.001 TX 48 45 4C 4C 4F HELLO
000003.102 RX 48 45 4C 4C 4F HELLO
c C s, t j ƒ | _|| _|| _d| _d| _d| _d S )Nz[32mz[31mz[37m)ÚtimeÚ
start_timer r r r! Ú
control_color)r" r r r r r r# t s
zFormatHexdump.__init__r c C s& | j jdj||||ƒƒ | j jƒ d S )Nz{:010.3f} {:4} {}{}
)r r$ r
r% )r" Z timestampZlabelr) Zvalue2r r r Ú
write_line| s zFormatHexdump.write_linec C sl | j r| jj| jƒ |rPxNt|ƒD ](\}}| jtjƒ | j ddj|ƒ|ƒ q"W n| jtjƒ | j ddƒ dS )z show received data as hex dumpZRXz{:04X} zN) r r r$ r r r3 r0 r1 r
)r" r r Úrowr r r r& € s &zFormatHexdump.rxc C sN | j r| jj| jƒ x4t|ƒD ](\}}| jtjƒ | j ddj|ƒ|ƒ q W dS )z!show transmitted data as hex dumpZTXz{:04X} N) r r r$ r! r r3 r0 r1 r
)r" r r r4 r r r r' Š s zFormatHexdump.txc C s0 | j r| jj| jƒ | jtjƒ | j ||ƒ dS )zshow control callsN)r r r$ r2 r3 r0 r1 )r" r( r) r r r r* ‘ s zFormatHexdump.controlN)r ) r+ r, r- r. r# r3 r& r' r* r r r r r/ e s
r/ c sT e Zd ZdZ‡ fdd„Zejjjdd„ ƒZdd„ Z ‡ fdd „Z
d,‡ fd d „ Z e ejd
ƒrd‡ fdd„Z
e ejdƒr|‡ fdd„Ze‡ fdd„ƒZ‡ fdd„Z‡ fdd„Z‡ fdd„Zd-‡ fd d „ Zejjjd d „ ƒZejjjd d!„ ƒZejjjd"d#„ ƒZejjj‡ fd$d%„ƒZejjj‡ fd&d'„ƒZejjj‡ fd(d)„ƒZejj j‡ fd*d+„ƒZ ‡ Z S ).ÚSerialzc Inherit the native Serial port implementation and wrap all the methods and
attributes.
c s" t t| ƒj||Ž d | _d| _d S )NF)Úsuperr5 r# Ú formatterÚshow_all)r" ÚargsÚkwargs)Ú __class__r r r# Ÿ s zSerial.__init__c C s" |d k r t jjj| | j|ƒƒ d S )N)r r5 ÚportÚ__set__Úfrom_url)r" r) r r r r< ¤ s z Serial.portc C sü t j|ƒ}|jdkr&tjdj|jƒƒ‚t}d}tj}yvxpt j |j
dƒj ƒ D ]Z\}}|dkrjt |d dƒ}qJ|dkrxd}qJ|d kr†t
}qJ|d
kr–d| _qJtd j|ƒƒ‚qJW W n2 tk
rÜ } ztjd j|ƒƒ‚W Y d
d
}~X nX |||ƒ| _dj|j|jgƒS )z(extract host and port from an URL stringZspyzmexpected a string in the form "spy://port[?option[=value][&option[=value]]]": not starting with spy:// ({!r})FTÚfiler Úwr ÚrawÚallzunknown option: {!r}zPexpected a string in the form "spy://port[?option[=value][&option[=value]]]": {}Nr )ÚurlparseZurlsplitÚschemer ZSerialExceptionr
r/ ÚsysÚstderrZparse_qsZqueryÚitemsÚopenr r8 Ú
ValueErrorr7 r ZnetlocÚpath) r" ZurlÚpartsr7 r r Zoptionr Úer r r r> © s2
zSerial.from_urlc s | j j|ƒ tt| ƒj|ƒS )N)r7 r' r6 r5 r$ )r" r' )r; r r r$ È s z Serial.writer c s* t t| ƒj|ƒ}|s| jr&| jj|ƒ |S )N)r6 r5 Úreadr8 r7 r& )r" Úsizer& )r; r r rM Ì s
z Serial.readÚ cancel_readc s | j jddƒ tt| ƒjƒ d S )NzQ-RXrO )r7 r* r6 r5 rO )r" )r; r r rO Ó s zSerial.cancel_readÚ cancel_writec s | j jddƒ tt| ƒjƒ d S )NzQ-TXrP )r7 r* r6 r5 rP )r" )r; r r rP Ø s zSerial.cancel_writec s* t t| ƒj}| jr&| jjddj|ƒƒ |S )NzQ-RXzin_waiting -> {})r6 r5 Ú
in_waitingr8 r7 r* r
)r" r )r; r r rQ Ü s zSerial.in_waitingc s | j jddƒ tt| ƒjƒ d S )NzQ-TXr% )r7 r* r6 r5 r% )r" )r; r r r% ã s z Serial.flushc s | j jddƒ tt| ƒjƒ d S )NzQ-RXÚreset_input_buffer)r7 r* r6 r5 rR )r" )r; r r rR ç s zSerial.reset_input_bufferc s | j jddƒ tt| ƒjƒ d S )NzQ-TXÚreset_output_buffer)r7 r* r6 r5 rS )r" )r; r r rS ë s zSerial.reset_output_bufferç Ð?c s( | j jddj|ƒƒ tt| ƒj|ƒ d S )NÚBRKzsend_break {}s)r7 r* r
r6 r5 Ú
send_break)r" Zduration)r; r r rV ï s zSerial.send_breakc C s* | j jd|rdndƒ tjjj| |ƒ d S )NrU ÚactiveÚinactive)r7 r* r r5 Úbreak_conditionr= )r" Úlevelr r r rY ó s zSerial.break_conditionc C s* | j jd|rdndƒ tjjj| |ƒ d S )NZRTSrW rX )r7 r* r r5 Úrtsr= )r" rZ r r r r[ ø s z
Serial.rtsc C s* | j jd|rdndƒ tjjj| |ƒ d S )NZDTRrW rX )r7 r* r r5 Údtrr= )r" rZ r r r r\ ý s z
Serial.dtrc s& t t| ƒj}| jjd|r dndƒ |S )NZCTSrW rX )r6 r5 Úctsr7 r* )r" rZ )r; r r r] s z
Serial.ctsc s& t t| ƒj}| jjd|r dndƒ |S )NZDSRrW rX )r6 r5 Údsrr7 r* )r" rZ )r; r r r^ s z
Serial.dsrc s& t t| ƒj}| jjd|r dndƒ |S )NZRIrW rX )r6 r5 Úrir7 r* )r" rZ )r; r r r_ s z Serial.ric s& t t| ƒj}| jjd|r dndƒ |S )NZCDrW rX )r6 r5 Úcdr7 r* )r" rZ )r; r r r` s z Serial.cd)r )rT ) r+ r, r- r. r# r r5 r< Úsetterr> r$ rM ÚhasattrrO rP ÚpropertyrQ r% rR rS rV rY r[ r\ r] Úgetterr^ r_ r` Ú
__classcell__r r )r; r r5 ˜ s, r5 Ú__main__zspy:///dev/ttyS0)rE r0 r rC Ú ImportErrorZ urllib.parseÚparser r Úobjectr r/ r5 r+ Zserr< Úprintr r r r Ú s 3