o a_)@s.ddlmZddlZddlZddlZzddlZWney'ddlmZYnwzddl Z Wn ey;ddl Z Ynwddl m Z m Z mZmZmZmZejejejejdZGddde ZedkrddlZedZejd eejd ed eejd ed e dSdS))absolute_importN) SerialBaseSerialExceptionto_bytes iterbytesSerialTimeoutExceptionPortNotOpenError)debuginfoZwarningerrorcseZdZdZdZfddZddZfddZd d Zd d Z e d dZ d,ddZ ddZ ddZddZddZddZe ddZddZd d!Zd"d#Ze d$d%Ze d&d'Ze d(d)Ze d*d+ZZS)-SerialzSSerial port implementation that simulates a loop back connection in plain software.)2Kni,iXiii` ii%iKiiics2d|_d|_d|_d|_tt|j|i|dS)NiF) buffer_sizequeuelogger _cancel_writesuperr __init__)selfargskwargs __class__A/usr/lib/python3/dist-packages/serial/urlhandler/protocol_loop.pyr/s zSerial.__init__cCs~|jrtdd|_t|j|_|jdurtd||j| d|_|j s.| |j s5| ||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_openrrrQueuerZ_portfrom_urlZport_reconfigure_portZ_dsrdtr_update_dtr_stateZ_rtscts_update_rts_statereset_input_bufferreset_output_bufferrrrropen6s   z Serial.opencsD|jrd|_z|jdWn tjyYnwtt|dS)NF)r r put_nowaitZFullrr closer(rrrr+Qsz Serial.closecCsPt|jtjrd|jkrdksntd|j|jr&|jddSdS)zx Set communication parameters on opened port. For the loop:// protocol all settings are ignored! rlzinvalid baudrate: {!r}z_reconfigure_port()N) isinstance _baudratenumbersZIntegral ValueErrorformatrr r(rrrr#Zs &zSerial._reconfigure_portc Cst|}|jdkrtd|jz6t|jdD])\}}|dkr?t t d|_ |j t |d|j dqtd|Wd Sty[}ztd |d }~ww) 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})Tloggingz pySerial.looprzenabled loggingzunknown option: {!r}zPexpected a string in the form "loop://[?logging={debug|info|warning|error}]": {}N)urlparseZurlsplitZschemerr0Zparse_qsZqueryitemsr1Z basicConfigZ getLoggerrZsetLevel LOGGER_LEVELSr r/)rZurlpartsoptionvalueserrrr"es,   zSerial.from_urlcC4|jst|jr|jd|j|jS)z9Return the number of bytes currently in the input buffer.zin_waiting -> {:d}r rrr r0rqsizer(rrr in_waiting~  zSerial.in_waitingcCs|jst|jdur|jdkrt|j}nd}t}|dkrr|jrrz |jj|jd}WntjyB|jdkr@Yt |SYnw|durP||7}|d8}n t |S|rkt|krk|jrf|j d t |S|dkrr|js$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. Nrtimeoutr>z read timeout) r rZ_timeouttime bytearrayrgetEmptyrr bytes)rsizer@databrrrreads6    z Serial.readcCs|jddS)N)rr*r(rrr cancel_readszSerial.cancel_readcCs d|_dS)NT)rr(rrr cancel_writes zSerial.cancel_writecCsd|_|js tt|}dt||j}|jdurF||jkrF|j}|dkr=|js=tt |d|d8}|dkr=|jr*|jrBdSt dt |D] }|j j ||jdqJt|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 timeoutr?)rr rrlenr-Z_write_timeoutrAsleepminrrrZput)rrGZtime_used_to_sendZ time_leftZbyterrrwrites" z Serial.writecC`|jst|jr|jdz|jr"|j|jsWdSWdStjy/YdSw)z9Clear input buffer, discarding all that is in the buffer.zreset_input_buffer()Nr rrr rr;Z get_nowaitrDr(rrrr&s   zSerial.reset_input_buffercCrP)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zreset_output_buffer()NrQr(rrrr's   zSerial.reset_output_buffercCr9)z0Return how many bytes the in the outgoing bufferzout_waiting -> {:d}r:r(rrr out_waitingr=zSerial.out_waitingcC"|jr|jd|jdSdS)z[ Set break: Controls TXD. When active, to transmitting is possible. z_update_break_state({!r})N)rr r0Z _break_stater(rrr_update_break_stateszSerial._update_break_statecCrS)z)Set terminal status line: Request To Sendz'_update_rts_state({!r}) -> state of CTSN)rr r0 _rts_stater(rrrr%zSerial._update_rts_statecCrS)z-Set terminal status line: Data Terminal Readyz'_update_dtr_state({!r}) -> state of DSRNrr r0Z _dtr_stater(rrrr$rVzSerial._update_dtr_statecCs,|jst|jr|jd|j|jS)z(Read terminal status line: Clear To SendzCTS -> state of RTS ({!r}))r rrr r0rUr(rrrctss z Serial.ctscCs |jr |jd|j|jS)z)Read terminal status line: Data Set ReadyzDSR -> state of DTR ({!r})rWr(rrrdsr sz Serial.dsrcC"|jst|jr|jddS)z)Read terminal status line: Ring Indicatorzreturning dummy for RIFr rrr r(rrrri  z Serial.ricCrZ)z)Read terminal status line: Carrier Detectzreturning dummy for CDTr[r(rrrcdr]z Serial.cd)r>)__name__ __module__ __qualname____doc__Z BAUDRATESrr)r+r#r"propertyr<rIrJrKrOr&r'rRrTr%r$rXrYr\r^ __classcell__rrrrr )s:      !      r __main__zloop://z{} z write... zhello z read: {!r} )!Z __future__rr1r.rAr2 ImportErrorZ urllib.parseparserr!Zserial.serialutilrrrrrrDEBUGINFOZWARNINGZERRORr4r r_syssstdoutrOr0flushrIr+rrrrsB