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)debuginfowarningerrorcseZdZdZdZfddZddZfddZd 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_openrrrQueuer_portfrom_urlport_reconfigure_port_dsrdtr_update_dtr_state_rtscts_update_rts_statereset_input_bufferreset_output_bufferrrrr open6s   z Serial.opencsD|jrd|_z|jdWn tjyYnwtt|dS)NF)r!r put_nowaitFullrr closer-rrr r1Qsz 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 _baudratenumbersIntegral ValueErrorformatrr r-rrr r&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 stringloopznexpected 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)urlparseurlsplitschemerr7parse_qsqueryitemsr9 basicConfig getLoggerrsetLevel LOGGER_LEVELSr r6)rurlpartsoptionvalueserrr r$es,   zSerial.from_urlcC4|jst|jr|jd|j|jS)z9Return the number of bytes currently in the input buffer.zin_waiting -> {:d}r!rrr r7rqsizer-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. NrtimeoutrNz read timeout) r!r_timeouttime bytearrayrgetEmptyrr bytes)rsizerPdatabrrr reads6    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 timeoutrO)rr!rrlenr3_write_timeoutrRsleepminrrrput)rrXtime_used_to_send time_leftbyterrr writes" 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 rrK get_nowaitrUr-rrr r+s   zSerial.reset_input_buffercCrf)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zreset_output_buffer()Nrgr-rrr r,s   zSerial.reset_output_buffercCrI)z0Return how many bytes the in the outgoing bufferzout_waiting -> {:d}rJr-rrr out_waitingrMzSerial.out_waitingcC"|jr|jd|jdSdS)z[ Set break: Controls TXD. When active, to transmitting is possible. z_update_break_state({!r})N)rr r7 _break_stater-rrr _update_break_stateszSerial._update_break_statecCrj)z)Set terminal status line: Request To Sendz'_update_rts_state({!r}) -> state of CTSN)rr r7 _rts_stater-rrr r*zSerial._update_rts_statecCrj)z-Set terminal status line: Data Terminal Readyz'_update_dtr_state({!r}) -> state of DSRNrr r7 _dtr_stater-rrr r(rnzSerial._update_dtr_statecCs,|jst|jr|jd|j|jS)z(Read terminal status line: Clear To SendzCTS -> state of RTS ({!r}))r!rrr r7rmr-rrr ctss z Serial.ctscCs |jr |jd|j|jS)z)Read terminal status line: Data Set ReadyzDSR -> state of DTR ({!r})ror-rrr dsr sz Serial.dsrcC"|jst|jr|jddS)z)Read terminal status line: Ring Indicatorzreturning dummy for RIFr!rrr r-rrr ri  z Serial.ricCrs)z)Read terminal status line: Carrier Detectzreturning dummy for CDTrtr-rrr cdrvz Serial.cd)rN)__name__ __module__ __qualname____doc__ BAUDRATESrr.r1r&r$propertyrLrZr[r\rer+r,rirlr*r(rqrrrurw __classcell__rrrr r )s:      !      r __main__zloop://z{} z write... zhello z read: {!r} )! __future__rr9r4rRr: ImportError urllib.parseparserr"serial.serialutilrrrrrrDEBUGINFOWARNINGERRORrCr rxsyssstdoutrer7flushrZr1rrrr sB