U ÏÐ~dÛ7ã@sddlmZddlZddlZddlZddlZddlZz ddlZWn ek r`ddl m ZYnXddl m Z m Z mZmZmZmZejejejejdœZdZGdd„de ƒZedkrddlZed ƒZej d  e¡¡ej d ¡e d ¡e ¡ej d  e  d¡¡¡e !¡dS)é)Úabsolute_importN)Ú SerialBaseÚSerialExceptionÚto_bytesÚPortNotOpenErrorÚSerialTimeoutExceptionÚTimeout)ÚdebugÚinfoÚwarningÚ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ÚsocketÚcreate_connectionÚfrom_urlZportstrÚ POLL_TIMEOUTÚ_socketÚ ExceptionÚformatÚ setblockingÚ_reconfigure_portZ_dsrdtrÚ_update_dtr_stateZ_rtsctsÚ_update_rts_stateÚreset_input_bufferÚreset_output_buffer)ÚselfÚmsg©r'ú^/var/www/html/myproject/myenv/lib/python3.8/site-packages/serial/urlhandler/protocol_socket.pyÚopen3s& $ 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(r Qs 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)ÚurlparseÚurlsplitÚschemerrÚparse_qsÚqueryÚitemsr0Ú basicConfigÚ getLoggerrÚsetLevelÚ LOGGER_LEVELSr Ú ValueErrorÚportÚhostname)r%ÚurlÚpartsÚoptionÚvaluesÚer'r'r(rjs0  þÿ  ÿÿzSerial.from_urlcCs.|js tƒ‚t |jgggd¡\}}}t|ƒS)z9Return the number of bytes currently in the input buffer.r)rrÚselectrÚlen)r%ÚlrZlwÚlxr'r'r(Ú in_waiting‡szSerial.in_waitingéc Cs@|js tƒ‚tƒ}t|jƒ}t|ƒ|kr8zVt |jggg| ¡¡\}}}|sTWq8|j  |t|ƒ¡}|stt 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| ¡rq8qt|ƒ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Ú bytearrayrÚ_timeoutrDrCrÚ time_leftÚrecvrÚextendÚOSErrorÚerrnoÚEAGAINÚEALREADYÚ EWOULDBLOCKÚ EINPROGRESSÚEINTRrr rÚexpiredÚbytes)r%ÚsizeÚreadrÚreadyÚ_ÚbufrBr'r'r(rY”s, " z Serial.readc Cs¼|js tƒ‚t|ƒ}t|ƒ}}t|jƒ}|dkr°z¨|j |¡}|jrN|WS|j s|  ¡rdt dƒ‚t   g|jgg|  ¡¡\}}}|sÆt dƒ‚n6|  ¡dks t‚t   g|jggd¡\}}}|sÆtdƒ‚||d…}||8}Wnºtk rò‚Yn¦tk rB} z2| jtjtjtjtjtjfkr2td | ¡ƒ‚W5d} ~ XYnVt jk r–} z4| dtjtjtjtjtjfkr†td | ¡ƒ‚W5d} ~ XYnX|js*|  ¡r*t dƒ‚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. rz Write timeoutNzwrite failed (select)zwrite failed: {})rrrrDrZ_write_timeoutrÚsendZis_non_blockingÚ is_infiniterVrrCrLÚAssertionErrorrrOrPrQrRrSrTrUrr ) r%ÚdataÚdZtx_lenÚlengthrÚnr[rZrBr'r'r(Úwrite½sB        "  z Serial.writec Csî|js tƒ‚d}|rêt |jgggd¡\}}}z|r@|j d¡}Wqtk r}z0|jtjtjtj tj tj fkr€t d  |¡ƒ‚W5d}~XYqtjtjfk ræ}z2|dtjtjtj tj tj fkrÖt d  |¡ƒ‚W5d}~XYqXqdS)z9Clear input buffer, discarding all that is in the buffer.TrirIN)rrrCrrMrOrPrQrRrSrTrUrrr r)r%rZr[rBr'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%Údurationr'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 ctsTrer*r'r'r(Úcts/s  z Serial.ctscCs"|js tƒ‚|jr|j d¡dS)z)Read terminal status line: Data Set Readyzreturning dummy for dsrTrer*r'r'r(Údsr8s  z Serial.dsrcCs"|js tƒ‚|jr|j d¡dS)z)Read terminal status line: Ring Indicatorzreturning dummy for riFrer*r'r'r(ÚriAs  z Serial.ricCs"|js tƒ‚|jr|j d¡dS)z)Read terminal status line: Carrier Detectzreturning dummy for cd)Trer*r'r'r(ÚcdJs  z Serial.cdcCs |j ¡S)z@Get the file handle of the underlying socket for use with select)rÚfilenor*r'r'r(rnVsz Serial.filenoN)rH)rf)Ú__name__Ú __module__Ú __qualname__Ú__doc__Z BAUDRATESr)r r-rÚpropertyrGrYrdr#r$rhrir"r!rjrkrlrmrnr'r'r'r(r-s2  )5     rÚ__main__zsocket://localhost:7000z{} z write... shello z read: {} )"Ú __future__rrPr0rCrr.r1Ú ImportErrorÚ urllib.parseÚparseZserial.serialutilrrrrrrÚDEBUGÚINFOÚWARNINGÚERRORr:rrroÚsysÚsÚstdoutrdrÚflushrYr-r'r'r'r(Ús8   ü2