­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ 3 M]W@# @sddlZddlZddlZy ddlZWnek rBddljZYnXddZddZGddde Z Gdd d e Z Gd d d ej Z e d kre dZd e_eedS)Nccsd}xrtj|D]d}djt|d|ko2dknrB|jdndfV|d7}|dkrbdVq|d krdVd}qW|dkrx(|d kr|d7}|dkrdVdVqWdVd 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. rz{:02X}  ascii. N )rr )NN)rr )r r)NN)serialZ iterbytesformatorddecode)datanbr"/usr/lib/python3.6/protocol_spy.pysixteen"s 6  rccsg}g}d}xnt|D]b\}}|dkrd|djdj|dj|gfV|dd=|dd=|d7}q|j||j|qWdS)z yield lines with hexdump of datarNrr r )rjoinappend)rvaluesroffsetharrrhexdump9s     rc@s0eZdZdZddZddZddZdd Zd S) FormatRawz&Forward only RX and TX data to output.cCs||_||_d|_d|_dS)Nzz)outputcolorrx_colortx_color)selfrrrrr__init__LszFormatRaw.__init__cCs.|jr|jj|j|jj||jjdS)zshow received dataN)rrwriter flush)r"rrrrrxRs z FormatRaw.rxcCs.|jr|jj|j|jj||jjdS)zshow transmitted dataN)rrr$r!r%)r"rrrrtxYs z FormatRaw.txcCsdS)z(do not) show control callsNr)r"namevaluerrrcontrol`szFormatRaw.controlN)__name__ __module__ __qualname____doc__r#r&r'r*rrrrrIs rc@s:eZdZdZddZdddZddZd 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 cCs,tj|_||_||_d|_d|_d|_dS)Nzzz)time start_timerrr r! control_color)r"rrrrrr#ts  zFormatHexdump.__init__r cCs&|jjdj|||||jjdS)Nz{:010.3f} {:4} {}{} )rr$r r%)r"Z timestampZlabelr)Zvalue2rrr write_line|szFormatHexdump.write_linecCsl|jr|jj|j|rPxNt|D](\}}|jtj|jddj||q"Wn|jtj|jdddS)zshow received data as hex dumpZRXz{:04X} zN) rrr$r rr3r0r1r )r"rrrowrrrr&s &zFormatHexdump.rxcCsN|jr|jj|jx4t|D](\}}|jtj|jddj||qWdS)z!show transmitted data as hex dumpZTXz{:04X} N) rrr$r!rr3r0r1r )r"rrr4rrrr'szFormatHexdump.txcCs0|jr|jj|j|jtj|j||dS)zshow control callsN)rrr$r2r3r0r1)r"r(r)rrrr*szFormatHexdump.controlN)r ) r+r,r-r.r#r3r&r'r*rrrrr/es    r/csTeZdZdZfddZejjjddZddZ fdd Z d,fd d Z e ejd rdfddZ e ejdr|fddZefddZfddZfddZfddZd-fdd ZejjjddZejjjd d!Zejjjd"d#Zejjjfd$d%Zejjjfd&d'Zejjjfd(d)Zejjjfd*d+ZZS).Serialzc Inherit the native Serial port implementation and wrap all the methods and attributes. cs"tt|j||d|_d|_dS)NF)superr5r# formattershow_all)r"argskwargs) __class__rrr#szSerial.__init__cCs"|dk rtjjj||j|dS)N)r r5port__set__from_url)r"r)rrrr<sz Serial.portc Cstj|}|jdkr&tjdj|jt}d}tj}yvxptj |j dj D]Z\}}|dkrjt |dd}qJ|dkrxd}qJ|d krt }qJ|d krd|_qJtd j|qJWWn2tk r}ztjd j|WYd d }~XnX||||_dj|j|jgS)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})FTfilerwrrawallzunknown option: {!r}zPexpected a string in the form "spy://port[?option[=value][&option[=value]]]": {}Nr )urlparseZurlsplitschemer ZSerialExceptionr r/sysstderrZparse_qsZqueryitemsopenrr8 ValueErrorr7rZnetlocpath) r"Zurlpartsr7rrZoptionrerrrr>s2    zSerial.from_urlcs|jj|tt|j|S)N)r7r'r6r5r$)r"r')r;rrr$s z Serial.writercs*tt|j|}|s|jr&|jj||S)N)r6r5readr8r7r&)r"sizer&)r;rrrMs  z Serial.read cancel_readcs |jjddtt|jdS)NzQ-RXrO)r7r*r6r5rO)r")r;rrrOszSerial.cancel_read cancel_writecs |jjddtt|jdS)NzQ-TXrP)r7r*r6r5rP)r")r;rrrPszSerial.cancel_writecs*tt|j}|jr&|jjddj||S)NzQ-RXzin_waiting -> {})r6r5 in_waitingr8r7r*r )r"r)r;rrrQs zSerial.in_waitingcs |jjddtt|jdS)NzQ-TXr%)r7r*r6r5r%)r")r;rrr%sz Serial.flushcs |jjddtt|jdS)NzQ-RXreset_input_buffer)r7r*r6r5rR)r")r;rrrRszSerial.reset_input_buffercs |jjddtt|jdS)NzQ-TXreset_output_buffer)r7r*r6r5rS)r")r;rrrSszSerial.reset_output_buffer?cs(|jjddj|tt|j|dS)NBRKzsend_break {}s)r7r*r r6r5 send_break)r"Zduration)r;rrrVszSerial.send_breakcCs*|jjd|rdndtjjj||dS)NrUactiveinactive)r7r*r r5break_conditionr=)r"levelrrrrYszSerial.break_conditioncCs*|jjd|rdndtjjj||dS)NZRTSrWrX)r7r*r r5rtsr=)r"rZrrrr[sz Serial.rtscCs*|jjd|rdndtjjj||dS)NZDTRrWrX)r7r*r r5dtrr=)r"rZrrrr\sz Serial.dtrcs&tt|j}|jjd|rdnd|S)NZCTSrWrX)r6r5ctsr7r*)r"rZ)r;rrr]s z Serial.ctscs&tt|j}|jjd|rdnd|S)NZDSRrWrX)r6r5dsrr7r*)r"rZ)r;rrr^s z Serial.dsrcs&tt|j}|jjd|rdnd|S)NZRIrWrX)r6r5rir7r*)r"rZ)r;rrr_s z Serial.rics&tt|j}|jjd|rdnd|S)NZCDrWrX)r6r5cdr7r*)r"rZ)r;rrr`s z Serial.cd)r)rT)r+r,r-r.r#r r5r<setterr>r$rMhasattrrOrPpropertyrQr%rRrSrVrYr[r\r]getterr^r_r` __classcell__rr)r;rr5s,         r5__main__zspy:///dev/ttyS0)rEr0r rC ImportErrorZ urllib.parseparserrobjectrr/r5r+Zserr<printrrrrs  3