o Ȧ^_7@sddlmZddlZddlZddlZddlZddlZzddlZWney/ddl m ZYnwddl m Z m Z mZmZmZmZejejejejdZdZGddde ZedkrddlZed Zejd eejd ed eejd e de!dSdS))absolute_importN) SerialBaseSerialExceptionto_bytesPortNotOpenErrorSerialTimeoutExceptionTimeout)debuginfowarningerrorc@seZdZdZdZddZddZddZd d Ze d d Z d*ddZ ddZ ddZ ddZd+ddZddZddZddZe dd Ze d!d"Ze d#d$Ze d%d&Zd'd(Zd)S),Serialz-Serial port implementation for plain sockets.)2Kni,iXiii` ii%iKiiic Csd|_|jdur td|jrtdztj||jtd|_ Wnt y9}z d|_ td |j|d}~ww|j d| d|_|jsN||jsU|||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)logger_portris_opensocketcreate_connectionfrom_urlportstr POLL_TIMEOUT_socket Exceptionformat setblocking_reconfigure_port_dsrdtr_update_dtr_state_rtscts_update_rts_statereset_input_bufferreset_output_buffer)selfmsgr+C/usr/lib/python3/dist-packages/serial/urlhandler/protocol_socket.pyopen3s*   z Serial.opencCs,|jdur td|jr|jddSdS)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|jr&|jrz|jtj|jWnYd|_d|_tddSdS)z Close portNFg333333?)rrshutdownr SHUT_RDWRclosetimesleepr.r+r+r,r1[sz Serial.closec Cst|}|jdkrtd|jzHt|jdD])\}}|dkr?t t d|_ |j t |d|j dqtd|d|jkrTd ksYtd td Wntym}ztd |d }~ww|j|jfS) z(extract host and port from an URL stringrzexpected a string in the form "socket://:[?logging={debug|info|warning|error}]": not starting with socket:// ({!r})TloggingzpySerial.socketrzenabled loggingzunknown option: {!r}izport not in range 0...65535z_expected a string in the form "socket://:[?logging={debug|info|warning|error}]": {}N)urlparseurlsplitschemerr parse_qsqueryitemsr4 basicConfig getLoggerrsetLevel LOGGER_LEVELSr ValueErrorporthostname)r)urlpartsoptionvalueser+r+r,rjs6    zSerial.from_urlcCs.|jstt|jgggd\}}}t|S)z9Return the number of bytes currently in the input buffer.r)rrselectrlen)r)lrlwlxr+r+r, in_waitingszSerial.in_waitingc CsR|jstt}t|j}t||krz-t|jggg|\}}}|s+Wt|S|j |t|}|s;t d| |WnTt yi}z|j t jt jt jt jt jfvr_t d|WYd}~n1d}~wtjtjfy}z|dt jt jt jt jt jfvrt d|WYd}~nd}~ww|r t|St||kst|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 disconnectedread failed: {}Nr)rr bytearrayr_timeoutrHrGr time_leftrecvrextendOSErrorerrnoEAGAINEALREADY EWOULDBLOCK EINPROGRESSEINTRr r rexpiredbytes)r)sizereadrready_bufrFr+r+r,r^s<      z Serial.readc Cs|jstt|}t|}}t|j}|dkrzT|j|}|jr&|WS|j sG| r1t dt g|jgg| \}}}|sFt dn| dusOJt g|jggd\}}}|sbtd||d}||8}WnXtyuty} z| jtjtjtjtjtjfvrtd| WYd} ~ n.d} ~ wt jy} z| dtjtjtjtjtjfvrtd| WYd} ~ nd} ~ ww|js| rt d|dks|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: {})rrrrHr_write_timeoutrsendis_non_blocking is_infiniter[rrGrQrrTrUrVrWrXrYrZr r ) r)datadtx_lenlengthrnr`r_rFr+r+r,writesP          'z Serial.writec Cs|jstd}|rzt|jgggd\}}}z |r |jd}WnTtyI}z|jtjtjtj tj tj fvr?t d |WYd}~n1d}~wtjtjfyu}z|dtjtjtj tj tj fvrkt d |WYd}~nd}~ww|s dSdS)z9Clear input buffer, discarding all that is in the buffer.TrirNN)rrrGrrRrTrUrVrWrXrYrZrr r r)r)r_r`rFr+r+r,r's*     zSerial.reset_input_buffercCs&|jst|jr|jddSdS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zignored reset_output_bufferNrrrr r.r+r+r,r( s zSerial.reset_output_buffer?cCs,|jst|jr|jd|dSdS)za Send break condition. Timed, returns to idle state after given duration. zignored send_break({!r})N)rrrr r )r)durationr+r+r, send_breaks zSerial.send_breakcC"|jr|jd|jdSdS)zJSet break: Controls TXD. When active, to transmitting is possible.z!ignored _update_break_state({!r})N)rr r _break_stater.r+r+r,_update_break_stateszSerial._update_break_statecCrp)z)Set terminal status line: Request To Sendzignored _update_rts_state({!r})N)rr r _rts_stater.r+r+r,r&%zSerial._update_rts_statecCrp)z-Set terminal status line: Data Terminal Readyzignored _update_dtr_state({!r})N)rr r _dtr_stater.r+r+r,r$*rtzSerial._update_dtr_statecC"|jst|jr|jddS)z(Read terminal status line: Clear To Sendzreturning dummy for ctsTrlr.r+r+r,cts/  z Serial.ctscCrv)z)Read terminal status line: Data Set Readyzreturning dummy for dsrTrlr.r+r+r,dsr8rxz Serial.dsrcCrv)z)Read terminal status line: Ring Indicatorzreturning dummy for riFrlr.r+r+r,riArxz Serial.ricCrv)z)Read terminal status line: Carrier Detectzreturning dummy for cd)Trlr.r+r+r,cdJrxz Serial.cdcCs |jS)z@Get the file handle of the underlying socket for use with select)rfilenor.r+r+r,r|Vs z Serial.filenoN)rM)rm)__name__ __module__ __qualname____doc__ BAUDRATESr-r"r1rpropertyrLr^rkr'r(rorrr&r$rwryrzr{r|r+r+r+r,r-s4   )5       r__main__zsocket://localhost:7000z{} z write... shello z read: {} )" __future__rrUr4rGrr2r5 ImportError urllib.parseparseserial.serialutilrrrrrrDEBUGINFOWARNINGERRORr>rrr}syssstdoutrkr flushr^r1r+r+r+r,s>    2