+ ^g$Rt^RIHt^RIt^RIt!RR]4t!RR]4t!RR]4t!R R ]4t !R R ]P4t ] R 8Xd^RI t ^RIt^RItRt!RR] 4t]P$!]R^R7t] !]]4;_uu_4t]P+R4]P,!^4RRR4]P$!]R^R7t] !]]4t]P14]P34wtt]P+R4]P,!^4]P74R#R# +'giL;i)z%Support threading with serial ports. )absolute_importNc6a]tRt^toRtRtRtRtRtVt R#)ProtocolzeProtocol as used by the ReaderThread. This base class provides empty implementations of all methods. c R#)z$Called when reader thread is startedNself transports&&:/usr/lib/python3/dist-packages/serial/threaded/__init__.pyconnection_madeProtocol.connection_madec R#)z2Called with snippets received from the serial portNrrdatas&&r data_receivedProtocol.data_receivedr rc 6\V\4'dVhR#)zOCalled when the serial port is closed or the reader loop terminated otherwise. N) isinstance Exceptionrexcs&&r connection_lostProtocol.connection_losts c9 % %I &rrN) __name__ __module__ __qualname____firstlineno____doc__r rr__static_attributes____classdictcell__ __classdict__s@r rrs 3ArrcRaa]tRt^'toRtRtRtRtV3RltRt Rt Rt Vt V;t #) Packetizerz Read binary packets from serial port. Packets are expected to be terminated with a TERMINATOR byte (null byte by default). The class also keeps track of the transport. c2\4VnRVnR#N) bytearraybufferr rs&r __init__Packetizer.__init__1sk rc WnR#zStore transportNr rs&&r r Packetizer.connection_made5"rc <<RVn\\V`V4R#)Forget transportN)r superr%rrr __class__s&&r rPacketizer.connection_lost9s j$/4rc VPPV4VPVP9dAVPPVP^4wq nVP V4K[R#)z9Buffer received data, find TERMINATOR, call handle_packetN)r*extend TERMINATORsplit handle_packet)rrpackets&& r rPacketizer.data_received>sV 4 oo,"&++"3"3DOOQ"G FK   v &-rc \R4hz1Process packets - to be overridden by subclassingz/please implement functionality in handle_packetNotImplementedErrorrr>s&&r r=Packetizer.handle_packetE!"STTr)r*r )rrrrrr;r,r rrr=r r! __classcell__r7r#s@@r r%r%'s1J#5 'UUrr%c\aa]tRt^JtoRtRtRtRtRtV3Rlt Rt Rt R t R t VtV;t#) FramedPacketzz Read binary packets. Packets are expected to have a start and stop marker. The class also keeps track of the transport. ()c@\4VnRVnRVnR#)FN)r)r> in_packetr r+s&r r,FramedPacket.__init__Tsk rc WnR#r/r0rs&&r r FramedPacket.connection_madeYr2rc d<RVnRVnVPR\\V`V4R#)r4NFNNN)r rNr>r5rJrr6s&&r rFramedPacket.connection_lost]s+ KKN lD1#6rc \P!V4FpW P8Xd RVnKW P8Xd;RVnVP \ VP44VPRKfVP'dVPPV4KVPV4K R#)z4Find data enclosed in START/STOP, call handle_packetTFrSN) serial iterbytesSTARTrNSTOPr=bytesr>r:handle_out_of_packet_data)rrbytes&& r rFramedPacket.data_receivedds$$T*Dzz!!%"!&""5#56KKN ""4(..t4+rc \R4hrArBrDs&&r r=FramedPacket.handle_packetrrFrc R#)z0Process data that is received outside of packetsNrrs&&r r[&FramedPacket.handle_out_of_packet_datavs r)rNr>r )rrrrrrXrYr,r rrr=r[r r!rGrHs@@r rJrJJs: E D #7 5U  rrJcBa]tRt^{toRtRtRtRtRtRt Rt Rt Vt R #) LineReaderzN Read and write (Unicode) lines from/to serial port. The encoding is applied. s zutf-8replacecpVPVPVPVP44R#r() handle_linedecodeENCODINGUNICODE_HANDLINGrDs&&r r=LineReader.handle_packets% t}}d6K6KLMrc \R4h)z2Process one line - to be overridden by subclassingz-please implement functionality in handle_linerB)rlines&&r rfLineReader.handle_lines!"QRRrc VPPVPVPVP4VP ,4R#)z Write text to the transport. ``text`` is a Unicode string and the encoding is applied before sending ans also the newline is append. N)r writeencoderhrir;)rtexts&&r write_lineLineReader.write_lines7 T[[8M8MNQUQ`Q``arrN) rrrrrr;rhrir=rfrrr r!r"s@r rcrc{s4 JH NSbbrrcc`aa]tRt^toRtV3RltRtRtRtRt Rt Rt R t R t VtV;t#) ReaderThreada Implement a serial port read loop and dispatch to a Protocol instance (like the asyncio.Protocol) but do it with threads. Calls to close() will close the serial port but it is also possible to just stop() this thread and continue the serial port instance otherwise. c <\\V` 4RVnWnW nRVn\P!4Vn \P!4Vn RVn R#)zqInitialize thread. Note that the serial_instance' timeout is set to one second! Other settings are not changed. TN) r5rur,daemonrVprotocol_factoryalive threadingLock_lockEvent_connection_madeprotocol)rserial_instancerxr7s&&&r r,ReaderThread.__init__sO lD*, % 0 ^^% ) 1 rc RVn\VPR4'dVPP4VP ^4R#)zStop the reader threadF cancel_readN)ryhasattrrVrjoinr+s&r stopReaderThread.stops5 4;; . . KK # # % ! rc \VPR4'g^VPnVP4VnVPP V4RpTPP4TP'dTPP'dcTPPTPP;'g^4pT'dTPPT4KKRTnTPPT4RTnR# \ dHpRTnTPPT4TPP4Rp?R#Rp?ii;i \ dpTpRp?KRp?ii;i \PdpTpRp?KRp?ii;i)z Reader looprFN)rrVtimeoutrxrr rryrr~setis_openread in_waitingrSerialException)reerrorrs& r runReaderThread.runs_t{{M22"#DKK --/   MM ) )$ /  !!#jjjT[[000 {{'' (>(>(C(C!D 33D9  %%e, 5 DJ MM ) )! ,  ! ! % % '   *% !))   sND6*1F&F&,F 6 F  ""$zzz?@ @}}rc &VP4R#)zLeave context: close portN)r)rexc_typeexc_valexc_tbs&&&&r __exit__ReaderThread.__exit__s  r)r~r|ryrwrrxrV)rrrrrr,rrrorrrrr r!rGrHs@@r rurus8 !F+   2 rru__main__zloop://c>aa]tRtRtoV3RltRtRtRtVtV;t #) PrintLinesic<\\V` V4\PP R4VP R4R#)z port opened z hello worldN)r5rr sysstdoutrorr)rr r7s&&r r PrintLines.connection_mades0 *d 3I > JJ  _ - OOM *rcb\PPRPV44R#)zline received: {!r} N)rrroformatrs&&r rfPrintLines.handle_lines JJ  4;;DA BrcV'd\P!V4\PP R4R#)z port closed N) traceback print_excrrrors&&r rPrintLines.connection_losts%##C( JJ  _ -rr) rrrrr rfrr r!rGrHs@@r rrs +  C . .rri)baudraterhello)r __future__rrVrzobjectrr%rJrcThreadrurrtimerPORTrserial_for_urlserrrrsleeptrrr rrrr rs5' v* U UF. 8. bbb4l9##lb z D .Z .   vq AC c: & &(G$ 1  '   vq ACS*%AGGI))+Ix  JJqMGGIG0 ' &s $D<< E