U wWôW‡'ã@s$ddlZddlZddlZz ddlZWn ek rDddlmZYnXz ddlZWnek rnddlZYnXddl m Z m Z m Z m Z mZmZejejejejdœZGdd„de ƒZedkr ddlZedƒZej d e¡¡ej d ¡e d ¡e ¡ej d  e d ¡¡¡e ¡dS) éN)Ú SerialBaseÚSerialExceptionÚto_bytesÚ iterbytesÚwriteTimeoutErrorÚportNotOpenError)ÚdebugÚinfoZwarningÚerrorcsÎeZdZdZdZ‡fdd„Zdd„Z‡fdd„Zd d „Zd d „Z e d d„ƒZ d*dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zdd„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__©úA/usr/lib/python3/dist-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_urlZportÚ_reconfigure_portZ_dsrdtrÚ_update_dtr_stateZ_rtsctsÚ_update_rts_stateÚreset_input_bufferÚreset_output_buffer©rrrrÚopen4s  z Serial.opencsF|jr4d|_z|j d¡Wntjk r2YnXtt|ƒ ¡dS)NF)rrÚ put_nowaitZFullrr Úcloser'rrrr*Osz 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ÚnumbersZIntegralÚ ValueErrorÚformatrr r'rrrr"Xs&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 stringZloopznexpected 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)ÚurlparseZurlsplitZschemerr/Zparse_qsZqueryÚitemsr0Z basicConfigZ getLoggerrZsetLevelÚ LOGGER_LEVELSrr.)rZurlÚpartsZoptionÚvaluesÚerrrr!cs*  þÿ ÿÿzSerial.from_urlcCs2|js t‚|jr(|j d |j ¡¡¡|j ¡S)z9Return the number of bytes currently in the input buffer.zin_waiting -> {:d})rrrrr/rÚqsizer'rrrÚ in_waiting|s zSerial.in_waitingécCsÊ|js t‚|jdk r.|jdkr.t ¡|j}nd}tƒ}|dkrÂ|jrÂz|jj|jd}Wn$tjk r~|jdkrzYqÂYnX|dk rÂ||7}|d8}nqÂ|r8t ¡|kr8|jrÂ|j  d¡qÂq8t |ƒ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©Útimeoutr9z read timeout) rrZ_timeoutÚtimeÚ bytearrayrÚgetÚEmptyrr Úbytes)rÚsizer;Ú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 rz||jkrz|j}|dkrl|jslt t |dƒ¡|d8}qD|jrvdSt ‚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à?r:)rrrrÚlenr,Z_write_timeoutr<ÚsleepÚminrrrZput)rrBZtime_used_to_sendZ time_leftZbyterrrÚwrite®s   z Serial.writecCsR|js t‚|jr|j d¡z|j ¡r4|j ¡qWntjk rLYnXdS)z9Clear input buffer, discarding all that is in the buffer.zreset_input_buffer()N©rrrr rr7Z get_nowaitr?r'rrrr%És  zSerial.reset_input_buffercCsR|js t‚|jr|j d¡z|j ¡r4|j ¡qWntjk rLYnXdS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zreset_output_buffer()NrKr'rrrr&Õs  zSerial.reset_output_buffercCs|jr|j d |j¡¡dS)z[ Set break: Controls TXD. When active, to transmitting is possible. z_update_break_state({!r})N)rr r/Z _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 r/Ú _rts_stater'rrrr$ì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 r/Z _dtr_stater'rrrr#ñszSerial._update_dtr_statecCs*|js t‚|jr$|j d |j¡¡|jS)z(Read terminal status line: Clear To SendzCTS -> state of RTS ({!r}))rrrr r/rMr'rrrÚctsös z Serial.ctscCs |jr|j d |j¡¡|jS)z)Read terminal status line: Data Set ReadyzDSR -> state of DTR ({!r})rNr'rrrÚdsrÿsz Serial.dsrcCs |js t‚|jr|j d¡dS)z)Read terminal status line: Ring Indicatorzreturning dummy for RIF©rrrr r'rrrÚris  z Serial.ricCs |js t‚|jr|j d¡dS)z)Read terminal status line: Carrier Detectzreturning dummy for CDTrQr'rrrÚcds  z Serial.cd)r9)Ú__name__Ú __module__Ú __qualname__Ú__doc__Z BAUDRATESrr(r*r"r!Úpropertyr8rDrErFrJr%r&rLr$r#rOrPrRrSÚ __classcell__rrrrr 's4    !    r Ú__main__zloop://z{} z write... zhello z read: {!r} é)r0r-r<r1Ú ImportErrorZ urllib.parseÚparserr Zserial.serialutilrrrrrrÚDEBUGÚINFOZWARNINGZERRORr3r rTÚsysÚsÚstdoutrJr/ÚflushrDr*rrrrÚs6   üw