o ^g$@sFdZddlmZddlZddlZGdddeZGdddeZGdd d eZGd d d eZ Gd d d ej Z e dkrddl Z ddlZddlZdZGddde ZejedddZe eeZededWdn1suwYejedddZe eeZee\ZZedededSdS)z%Support threading with serial ports. )absolute_importNc@s(eZdZdZddZddZddZdS) Protocolzq Protocol as used by the ReaderThread. This base class provides empty implementations of all methods. cCdS)z$Called when reader thread is startedNself transportrr:/usr/lib/python3/dist-packages/serial/threaded/__init__.pyconnection_madezProtocol.connection_madecCr)z2Called with snippets received from the serial portNrrdatarrr data_receivedr zProtocol.data_receivedcCst|tr|dS)zg Called when the serial port is closed or the reader loop terminated otherwise. N) isinstance Exceptionrexcrrr connection_losts zProtocol.connection_lostN)__name__ __module__ __qualname____doc__r rrrrrr rs  rcsDeZdZdZdZddZddZfddZd d Zd d Z Z S) 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. cCst|_d|_dSN) bytearraybufferrrrrr __init__1s zPacketizer.__init__cC ||_dSzStore transportNrrrrr r 5 zPacketizer.connection_madecsd|_tt||dS)Forget transportN)rsuperrrr __class__rr r9szPacketizer.connection_lostcCsL|j||j|jvr$|j|jd\}|_|||j|jvs dSdS)z9Buffer received data, find TERMINATOR, call handle_packetN)rextend TERMINATORsplit handle_packet)rr packetrrr r>s   zPacketizer.data_receivedcCtdz1Process packets - to be overridden by subclassingz/please implement functionality in handle_packetNotImplementedErrorrr,rrr r+EzPacketizer.handle_packet) rrrrr)rr rrr+ __classcell__rrr%r r's rcsPeZdZdZdZdZddZddZfdd Zd d Z d d Z ddZ Z S) FramedPacketz Read binary packets. Packets are expected to have a start and stop marker. The class also keeps track of the transport. ()cCst|_d|_d|_dS)NF)rr, in_packetrrrrr rTs zFramedPacket.__init__cCrr r!rrrr r Yr"zFramedPacket.connection_madecs,d|_d|_|jdd=tt||dS)r#NF)rr7r,r$r4rrr%rr r]s zFramedPacket.connection_lostcCsrt|D]1}||jkrd|_q||jkr'd|_|t|j|jdd=q|jr1|j|q| |qdS)z4Find data enclosed in START/STOP, call handle_packetTFN) serialZ iterbytesSTARTr7STOPr+bytesr,r(handle_out_of_packet_data)rr Zbyterrr rds   zFramedPacket.data_receivedcCr-r.r/r1rrr r+rr2zFramedPacket.handle_packetcCr)z0Process data that is received outside of packetsNrr rrr r<vsz&FramedPacket.handle_out_of_packet_data) rrrrr9r:rr rrr+r<r3rrr%r r4Js r4c@s4eZdZdZdZdZdZddZddZd d Z d S) LineReaderzZ Read and write (Unicode) lines from/to serial port. The encoding is applied. s zutf-8replacecCs|||j|jdSr) handle_linedecodeENCODINGUNICODE_HANDLINGr1rrr r+szLineReader.handle_packetcCr-)z2Process one line - to be overridden by subclassingz-please implement functionality in handle_liner/)rlinerrr r?r2zLineReader.handle_linecCs"|j||j|j|jdS)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)rwriteencoderArBr))rtextrrr write_lines"zLineReader.write_lineN) rrrrr)rArBr+r?rGrrrr r={s r=csXeZdZdZfddZddZddZdd Zd d Zd d Z ddZ ddZ Z S) 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. csDtt|d|_||_||_d|_t|_ t |_ d|_ dS)z Initialize thread. Note that the serial_instance' timeout is set to one second! Other settings are not changed. TN) r$rHrZdaemonr8protocol_factoryalive threadingZLock_lockZEvent_connection_madeprotocol)rZserial_instancerIr%rr rs   zReaderThread.__init__cCs*d|_t|jdr|j|ddS)zStop the reader threadF cancel_readN)rJhasattrr8rOjoinrrrr stops  zReaderThread.stopc Cs:t|jds d|j_||_z|j|Wn!ty8}zd|_|j||j WYd}~dSd}~wwd}|j |jr|jj rz |j |jj pPd}Wntjyh}z|}WYd}~n+d}~ww|rz|j|Wnty}z|}WYd}~n d}~ww|jr|jj sGd|_|j|d|_dS)z Reader looprOr'FN)rQr8timeoutrIrNr rrJrrMsetZis_openreadZ in_waitingZSerialExceptionr)reerrorr rrr runsD         zReaderThread.runcCs6|j|j|WdS1swYdS)zThread safe writing (uses lock)N)rLr8rDr rrr rDs $zReaderThread.writecCs>|j||jWddS1swYdS)z8Close the serial port and exit reader thread (uses lock)N)rLrSr8closerrrr rZs "zReaderThread.closecCs0|jr|j|jstd||jfStd)zj Wait until connection is set up and return the transport and protocol instances. connection_lost already calledzalready stopped)rJrMwait RuntimeErrorrNrrrr connects   zReaderThread.connectcCs&||j|jstd|jS)zs Enter context handler. May raise RuntimeError in case the connection could not be created. r[)startrMr\rJr]rNrrrr __enter__s  zReaderThread.__enter__cCs |dS)zLeave context: close portN)rZ)rexc_typeZexc_valexc_tbrrr __exit__s zReaderThread.__exit__) rrrrrrSrYrDrZr^r`rcr3rrr%r rHs # rH__main__zloop://cs,eZdZfddZddZddZZS) PrintLinescs*tt||tjd|ddS)Nz port opened z hello world)r$rer sysstdoutrDrGrr%rr r s zPrintLines.connection_madecCstjd|dS)Nzline received: {!r} )rfrgrDformatr rrr r?szPrintLines.handle_linecCs|rt|tjddS)Nz port closed ) traceback print_excrfrgrDrrrr rs zPrintLines.connection_lost)rrrr r?rr3rrr%r res reir')ZbaudraterTZhellorP)rZ __future__rr8rKobjectrrr4r=ZThreadrHrrftimeriZPORTreZserial_for_urlZserrNrGsleeptr_r^rrZrrrr s8 #1q