U ÏÐ~d)ã@s0ddlmZddlZddlZddlZz ddlZWn ek rPddlmZYnXz ddl Z Wnek rzddl Z YnXddl m Z m Z mZmZmZmZejejejejdœZGdd„de ƒZedkr,ddlZedƒZej d  e¡¡ej d ¡e d ¡e ¡ej d  e d ¡¡¡e  ¡dS)é)Úabsolute_importN)Ú SerialBaseÚSerialExceptionÚto_bytesÚ iterbytesÚSerialTimeoutExceptionÚPortNotOpenError)ÚdebugÚinfoÚwarningÚerrorcsÚeZdZdZdZ‡fdd„Zdd„Z‡fdd„Zd d „Zd d „Z e d d„ƒZ d,dd„Z dd„Z dd„Zdd„Zdd„Zdd„Ze dd„ƒZdd„Zd d!„Zd"d#„Ze d$d%„ƒZe d&d'„ƒZe d(d)„ƒZe d*d+„ƒZ‡ZS)-ÚSerialzSSerial port implementation that simulates a loop back connection in plain software.)é2éKéné†é–éÈi,iXi°ii` iÀi€%iKi–iáiÂcs.d|_d|_d|_d|_tt|ƒj||ŽdS)NiF)Ú buffer_sizeÚqueueÚloggerÚ _cancel_writeÚsuperr Ú__init__)ÚselfÚargsÚkwargs©Ú __class__©ú\/var/www/html/myproject/myenv/lib/python3.8/site-packages/serial/urlhandler/protocol_loop.pyr/s zSerial.__init__cCs~|jrtdƒ‚d|_t |j¡|_|jdkr4tdƒ‚| |j¡|  ¡d|_|j s\|  ¡|j sj|  ¡| ¡| ¡dS)zx Open port with current settings. This may throw a SerialException if the port cannot be opened. zPort is already open.Nz.Port must be configured before it can be used.T)Úis_openrrrÚQueuerZ_portÚfrom_urlÚportÚ_reconfigure_portZ_dsrdtrÚ_update_dtr_stateZ_rtsctsÚ_update_rts_stateÚreset_input_bufferÚreset_output_buffer©rrrr Úopen6s  z Serial.opencsF|jr4d|_z|j d¡Wntjk r2YnXtt|ƒ ¡dS)NF)r!rÚ put_nowaitÚFullrr Úcloser*rrr r.Qsz Serial.closecCsLt|jtjƒr&d|jkr$dks6ntd |j¡ƒ‚|jrH|j d¡dS)zx Set communication parameters on opened port. For the loop:// protocol all settings are ignored! rlzinvalid baudrate: {!r}z_reconfigure_port()N)Ú isinstanceÚ _baudrateÚnumbersÚIntegralÚ ValueErrorÚformatrr r*rrr r%Zs&zSerial._reconfigure_portc CsÆt |¡}|jdkr$td |j¡ƒ‚zlt |jd¡ ¡D]T\}}|dkr~t  ¡t  d¡|_ |j   t |d¡|j  d¡q8td |¡ƒ‚q8Wn0tk rÀ}ztd  |¡ƒ‚W5d }~XYnXd S) z(extract host and port from an URL stringÚloopznexpected a string in the form "loop://[?logging={debug|info|warning|error}]": not starting with loop:// ({!r})TÚloggingz pySerial.looprzenabled loggingzunknown option: {!r}zPexpected a string in the form "loop://[?logging={debug|info|warning|error}]": {}N)ÚurlparseÚurlsplitÚschemerr4Úparse_qsÚqueryÚitemsr6Ú basicConfigÚ getLoggerrÚsetLevelÚ LOGGER_LEVELSr r3)rÚurlÚpartsÚoptionÚvaluesÚerrr r#es*  þÿ ÿÿzSerial.from_urlcCs4|js tƒ‚|jr*|j d |j ¡¡¡|j ¡S)z9Return the number of bytes currently in the input buffer.zin_waiting -> {:d}©r!rrr r4rÚqsizer*rrr Ú in_waiting~s zSerial.in_waitingécCsÌ|js tƒ‚|jdk r0|jdkr0t ¡|j}nd}tƒ}|dkrÄ|jrÄz|jj|jd}Wn$tjk r€|jdkr|YqÄYnX|dk rÄ||7}|d8}nqÄ|r:t ¡|kr:|jrÄ|j  d¡qÄq:t |ƒS)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. Nr©ÚtimeoutrIz read timeout) r!rÚ_timeoutÚtimeÚ bytearrayrÚgetÚEmptyrr Úbytes)rÚsizerKÚdataÚbrrr Úread‰s*    z Serial.readcCs|j d¡dS)N)rr,r*rrr Ú cancel_readªszSerial.cancel_readcCs d|_dS)NT)rr*rrr Ú cancel_write­szSerial.cancel_writecCs¨d|_|jstƒ‚t|ƒ}dt|ƒ|j}|jdk r€||jkr€|j}|dkrn|jsnt t |dƒ¡|d8}qF|jrxdSt dƒ‚t |ƒD]}|j j ||jdqˆ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. Fg$@Nrgà?z Write timeoutrJ)rr!rrÚlenr0Z_write_timeoutrMÚsleepÚminrrrÚput)rrSZtime_used_to_sendZ time_leftÚbyterrr Úwrite°s   z Serial.writecCsT|js tƒ‚|jr|j d¡z|j ¡r6|j ¡q Wntjk rNYnXdS)z9Clear input buffer, discarding all that is in the buffer.zreset_input_buffer()N©r!rrr rrGÚ get_nowaitrPr*rrr r(Ës  zSerial.reset_input_buffercCsT|js tƒ‚|jr|j d¡z|j ¡r6|j ¡q Wntjk rNYnXdS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zreset_output_buffer()Nr^r*rrr r)×s  zSerial.reset_output_buffercCs4|js tƒ‚|jr*|j d |j ¡¡¡|j ¡S)z0Return how many bytes the in the outgoing bufferzout_waiting -> {:d}rFr*rrr Ú out_waitingæs zSerial.out_waitingcCs|jr|j d |j¡¡dS)z[ Set break: Controls TXD. When active, to transmitting is possible. z_update_break_state({!r})N)rr r4Z _break_stater*rrr Ú_update_break_stateñszSerial._update_break_statecCs|jr|j d |j¡¡dS)z)Set terminal status line: Request To Sendz'_update_rts_state({!r}) -> state of CTSN)rr r4Ú _rts_stater*rrr r'ùszSerial._update_rts_statecCs|jr|j d |j¡¡dS)z-Set terminal status line: Data Terminal Readyz'_update_dtr_state({!r}) -> state of DSRN©rr r4Z _dtr_stater*rrr r&þszSerial._update_dtr_statecCs,|js tƒ‚|jr&|j d |j¡¡|jS)z(Read terminal status line: Clear To SendzCTS -> state of RTS ({!r}))r!rrr r4rbr*rrr Úctss z Serial.ctscCs |jr|j d |j¡¡|jS)z)Read terminal status line: Data Set ReadyzDSR -> state of DTR ({!r})rcr*rrr Údsr sz Serial.dsrcCs"|js tƒ‚|jr|j d¡dS)z)Read terminal status line: Ring Indicatorzreturning dummy for RIF©r!rrr r*rrr Úris  z Serial.ricCs"|js tƒ‚|jr|j d¡dS)z)Read terminal status line: Carrier Detectzreturning dummy for CDTrfr*rrr Úcds  z Serial.cd)rI)Ú__name__Ú __module__Ú __qualname__Ú__doc__Z BAUDRATESrr+r.r%r#ÚpropertyrHrUrVrWr]r(r)r`rar'r&rdrergrhÚ __classcell__rrrr r )s8    !     r Ú__main__zloop://z{} z write... zhello z read: {!r} é)!Ú __future__rr6r1rMr7Ú ImportErrorÚ urllib.parseÚparserr"Zserial.serialutilrrrrrrÚDEBUGÚINFOÚWARNINGÚERRORr@r riÚsysÚsÚstdoutr]r4ÚflushrUr.rrrr Ús:    ü