qV %@s]ddlZddlZddlZyddlZWn!ek rWddljZYnXyddlZWnek rddlZYnXddl Tdej dej dej dej iZGdddeZed krYddlZed Zejjd eejjd ejd ejejjdejdejdS)N)*debuginfoZwarningerrorcseZdZdZd6ZfddZddZfddZddZddZ e ddZ dd d!Z d"d#Z d$d%Zd&d'Zd(d)Zd*d+Zd,d-Ze d.d/Ze d0d1Ze d2d3Ze d4d5ZS)7SerialzSSerial port implementation that simulates a loop back connection in plain software.2Kn,X` %Kcs8tt|j||d|_d|_d|_dS)Ni)superr__init__ buffer_sizequeuelogger)selfargskwargs) __class__A/usr/lib/python3/dist-packages/serial/urlhandler/protocol_loop.pyr-s  zSerial.__init__cCs|jrtdd|_tj|j|_|jdkrNtd|j|j|j d|_|j s|j |j s|j |j|jdS)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_openSerialExceptionrrQueuerZ_portfrom_urlZport_reconfigure_portZ_dsrdtr_update_dtr_stateZ_rtscts_update_rts_statereset_input_bufferreset_output_buffer)rr!r!r"open3s           z Serial.openc sU|jr>d|_y|jjdWntjk r=YnXtt|jdS)NF)r#rZ put_nowaitZFullrrclose)r)r r!r"r-Ns  z Serial.closecCsft|jtj s6d|jko0dkn rItd|j|jrb|jjddS)zx Set communication parameters on opened port. For the loop:// protocol all settings are ignored! r zinvalid baudrate: %rz_reconfigure_port()Nl) isinstance _baudratenumbersZIntegral ValueErrorrr)rr!r!r"r'Ws6 zSerial._reconfigure_portcCstj|}|jdkr4td|jfyxtj|jdjD]r\}}|dkrtjtj d|_ |j j t |d|j j dqStd|fqSWWn5tk r}ztd |WYd d }~XnXd S) z(extract host and port from an URL stringZloopzlexpected a string in the form "loop://[?logging={debug|info|warning|error}]": not starting with loop:// (%r)Tloggingz pySerial.looprzenabled loggingzunknown option: %rzPexpected a string in the form "loop://[?logging={debug|info|warning|error}]": %sN)urlparseZurlsplitschemer$Zparse_qsZqueryitemsr4Z basicConfigZ getLoggerrZsetLevel LOGGER_LEVELSrr3)rZurlpartsZoptionvalueser!r!r"r&bs(  zSerial.from_urlcCsE|jst|jr8|jjd|jjf|jjS)z9Return the number of bytes currently in the input buffer.zin_waiting -> %d)r#portNotOpenErrorrrrqsize)rr!r!r" in_waitingvs    zSerial.in_waitingc Cs|jst|jdk rC|jdkrCtj|j}nd}t}x|dkr|jry|jjd|j}Wn%tjk r|jdkrPYn%X|dk r||7}|d8}nP|rUtj|krU|jr|jj dPqUWt |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#r<Z_timeouttime bytearrayrgetEmptyrrbytes)rsizer@databr!r!r"reads*      z Serial.readcCs|jstt|}dt||j}|jdk rf||jkrftj|jtx-t |D]}|j j |d|jqsWt|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. g$@Nr@) r#r<to_byteslenr1Z_write_timeoutrAZsleepZwriteTimeoutErrorZ iterbytesrZput)rrGZtime_used_to_sendZbyter!r!r"writes  z Serial.writec Csk|jst|jr(|jjdy'x |jjrM|jjq.WWntjk rfYnXdS)z9Clear input buffer, discarding all that is in the buffer.zreset_input_buffer()N)r#r<rrrr= get_nowaitrD)rr!r!r"r*s  zSerial.reset_input_bufferc Csk|jst|jr(|jjdy'x |jjrM|jjq.WWntjk rfYnXdS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zreset_output_buffer()N)r#r<rrrr=rMrD)rr!r!r"r+s  zSerial.reset_output_buffercCs'|jr#|jjd|jfdS)z[ Set break: Controls TXD. When active, to transmitting is possible. z_update_break_state(%r)N)rrZ _break_state)rr!r!r"_update_break_states zSerial._update_break_statecCs'|jr#|jjd|jfdS)z)Set terminal status line: Request To Sendz%_update_rts_state(%r) -> state of CTSN)rr _rts_state)rr!r!r"r)s zSerial._update_rts_statecCs'|jr#|jjd|jfdS)z-Set terminal status line: Data Terminal Readyz%_update_dtr_state(%r) -> state of DSRN)rr _dtr_state)rr!r!r"r(s zSerial._update_dtr_statecCs9|jst|jr2|jjd|jf|jS)z(Read terminal status line: Clear To SendzCTS -> state of RTS (%r))r#r<rrrO)rr!r!r"ctss   z Serial.ctscCs*|jr#|jjd|jf|jS)z)Read terminal status line: Data Set ReadyzDSR -> state of DTR (%r))rrrP)rr!r!r"dsrs z Serial.dsrcCs,|jst|jr(|jjddS)z)Read terminal status line: Ring Indicatorzreturning dummy for RIF)r#r<rr)rr!r!r"ris   z Serial.ricCs,|jst|jr(|jjddS)z)Read terminal status line: Carrier Detectzreturning dummy for CDT)r#r<rr)rr!r!r"cds   z Serial.cd)rrr r r r r rrrrrrrrrr)__name__ __module__ __qualname____doc__Z BAUDRATESrr,r-r'r&propertyr>rIrLr*r+rNr)r(rQrRrSrTr!r!)r r"r's(    !       r__main__zloop://z%s z write... zhello z read: %s )r4r2rAr5 ImportErrorZ urllib.parseparserr%Zserial.serialutilDEBUGINFOZWARNINGZERRORr8Z SerialBaserrUsyssstdoutrLflushrIr-r!r!r!r"s2