U =Y27ã@sddlZddlZddlZddlZddlZz ddlZWn ek rTddlmZYnXddl m Z m Z m Z m Z mZmZejejejejdœZdZGdd„de ƒZedkr ddlZedƒZej d  e¡¡ej d ¡e d ¡e ¡ej d  e d¡¡¡e ¡dS) éN)Ú SerialBaseÚSerialExceptionÚto_bytesÚportNotOpenErrorÚwriteTimeoutErrorÚTimeout)ÚdebugÚinfoZwarningÚerroréc@s¼eZdZdZdZdd„Zdd„Zdd„Zd d „Ze d d „ƒZ d*dd„Z dd„Z dd„Z dd„Zd+dd„Zdd„Zdd„Zdd„Ze dd „ƒZe d!d"„ƒZe d#d$„ƒZe d%d&„ƒZd'd(„Zd)S),ÚSerialz-Serial port implementation for plain sockets.)é2éKéné†é–éÈi,iXi°ii` iÀi€%iKi–iáiÂc CsÈd|_|jdkrtdƒ‚|jr&tdƒ‚ztj| |j¡td|_ Wn:t k r|}zd|_ td  |j|¡ƒ‚W5d}~XYnX|j   d¡|  ¡d|_|js¦| ¡|js´| ¡| ¡| ¡dS)zx Open port with current settings. This may throw a SerialException if the port cannot be opened. Nz.Port must be configured before it can be used.zPort is already open.)ÚtimeoutzCould not open port {}: {}FT)ÚloggerZ_portrÚis_openÚsocketZcreate_connectionÚfrom_urlZportstrÚ POLL_TIMEOUTÚ_socketÚ ExceptionÚformatZ setblockingÚ_reconfigure_portZ_dsrdtrÚ_update_dtr_stateZ_rtsctsÚ_update_rts_stateÚreset_input_bufferÚreset_output_buffer)ÚselfÚmsg©r#úC/usr/lib/python3/dist-packages/serial/urlhandler/protocol_socket.pyÚopen1s& $ z Serial.opencCs(|jdkrtdƒ‚|jr$|j d¡dS)zz Set communication parameters on opened port. For the socket:// protocol all settings are ignored! NzCan only operate on open portsz!ignored port configuration change)rrrr ©r!r#r#r$rOs zSerial._reconfigure_portcCsP|jrL|jr:[?logging={debug|info|warning|error}]": not starting with socket:// ({!r})TÚloggingzpySerial.socketrzenabled loggingzunknown option: {!r}izport not in range 0...65535z_expected a string in the form "socket://:[?logging={debug|info|warning|error}]": {}N)ÚurlparseZurlsplitZschemerrZparse_qsZqueryÚitemsr*Z basicConfigZ getLoggerrZsetLevelÚ LOGGER_LEVELSrÚ ValueErrorZportZhostname)r!ZurlÚpartsZoptionÚvaluesÚer#r#r$rhs0  þÿ  ÿÿzSerial.from_urlcCs,|js t‚t |jgggd¡\}}}t|ƒS)z9Return the number of bytes currently in the input buffer.r)rrÚselectrÚlen)r!ZlrZlwZlxr#r#r$Ú in_waiting…szSerial.in_waitingéc Cs>|js t‚tƒ}t|jƒ}t|ƒ|kr6zVt |jggg| ¡¡\}}}|sRWq6|j  |t|ƒ¡}|srt dƒ‚|  |¡Wn¨t k rÌ}z0|j t jt jt jt jt jfkr¼t d |¡ƒ‚W5d}~XYn\tjtjfk r&}z4|dt jt jt jt jt jfkrt d |¡ƒ‚W5d}~XYnX| ¡rq6qt|ƒ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. zsocket disconnectedúread failed: {}Nr)rrÚ bytearrayrZ_timeoutr3r2rÚ time_leftÚrecvrÚextendÚOSErrorÚerrnoÚEAGAINÚEALREADYÚ EWOULDBLOCKÚ EINPROGRESSÚEINTRrr rÚexpiredÚbytes)r!ÚsizeÚreadrÚreadyÚ_Zbufr1r#r#r$rE’s, " z Serial.readc Cs®|js t‚t|ƒ}t|ƒ}}t|jƒ}|dkr¢z |j |¡}|jrL|WS|j s†|  ¡r^t ‚t   g|jgg|  ¡¡\}}}|s¼t ‚n6|  ¡dks–t‚t   g|jggd¡\}}}|s¼tdƒ‚||d…}||8}Wnºtk rè‚Yn¦tk r8} z2| jtjtjtjtjtjfkr(td | ¡ƒ‚W5d} ~ XYnVt jk rŒ} z4| dtjtjtjtjtjfkr|td | ¡ƒ‚W5d} ~ XYnX|js(|  ¡r(t ‚q(|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. rNzwrite failed (select)zwrite failed: {})rrrr3rZ_write_timeoutrÚsendZis_non_blockingZ is_infiniterBrr2r8ÚAssertionErrorrr;r<r=r>r?r@rArr ) r!ÚdataÚdZtx_lenZlengthrÚnrGrFr1r#r#r$Úwrite»sB       " z Serial.writec Csè|js t‚d}|rät |jgggd¡\}}}z|j d¡Wqtk rŠ}z0|jtjtjtj tj tj fkrzt d  |¡ƒ‚W5d}~XYqtjtjfk rà}z2|dtjtjtj tj tj fkrÐt d  |¡ƒ‚W5d}~XYqXqdS)z9Clear input buffer, discarding all that is in the buffer.Trir6N)rrr2rr9r;r<r=r>r?r@rArrr r)r!rFrGr1r#r#r$rðs zSerial.reset_input_buffercCs |js t‚|jr|j d¡dS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zignored reset_output_bufferN©rrrr r&r#r#r$r szSerial.reset_output_bufferçÐ?cCs&|js t‚|jr"|j d |¡¡dS)za Send break condition. Timed, returns to idle state after given duration. zignored send_break({!r})N)rrrr r)r!Zdurationr#r#r$Ú send_breakszSerial.send_breakcCs|jr|j d |j¡¡dS)zJSet break: Controls TXD. When active, to transmitting is possible.z!ignored _update_break_state({!r})N)rr rZ _break_stater&r#r#r$Ú_update_break_stateszSerial._update_break_statecCs|jr|j d |j¡¡dS)z)Set terminal status line: Request To Sendzignored _update_rts_state({!r})N)rr rZ _rts_stater&r#r#r$r"szSerial._update_rts_statecCs|jr|j d |j¡¡dS)z-Set terminal status line: Data Terminal Readyzignored _update_dtr_state({!r})N)rr rZ _dtr_stater&r#r#r$r'szSerial._update_dtr_statecCs |js t‚|jr|j d¡dS)z(Read terminal status line: Clear To Sendzreturning dummy for ctsTrNr&r#r#r$Úcts,s  z Serial.ctscCs |js t‚|jr|j d¡dS)z)Read terminal status line: Data Set Readyzreturning dummy for dsrTrNr&r#r#r$Údsr5s  z Serial.dsrcCs |js t‚|jr|j d¡dS)z)Read terminal status line: Ring Indicatorzreturning dummy for riFrNr&r#r#r$Úri>s  z Serial.ricCs |js t‚|jr|j d¡dS)z)Read terminal status line: Carrier Detectzreturning dummy for cd)TrNr&r#r#r$ÚcdGs  z Serial.cdcCs |j ¡S)z@Get the file handle of the underlying socket for use with select)rÚfilenor&r#r#r$rVSsz Serial.filenoN)r5)rO)Ú__name__Ú __module__Ú __qualname__Ú__doc__Z BAUDRATESr%rr'rÚpropertyr4rErMrr rPrQrrrRrSrTrUrVr#r#r#r$r +s2  )5     r Ú__main__zsocket://localhost:7000z{} z write... shello z read: {} ) r<r*r2rr(r+Ú ImportErrorZ urllib.parseÚparseZserial.serialutilrrrrrrÚDEBUGÚINFOZWARNINGZERRORr-rr rWÚsysÚsÚstdoutrMrÚflushrEr'r#r#r#r$Ús6  ü1