o Ȧ^_7@sddlmZddlZddlZddlZddlZddlZzddlZWney/ddl m ZYnwddl m Z m Z mZmZmZmZejejejejdZdZGddde ZedkrddlZed Zejd eejd ed eejd e de!dSdS))absolute_importN) SerialBaseSerialExceptionto_bytesPortNotOpenErrorSerialTimeoutExceptionTimeout)debuginfoZwarningerrorc@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)loggerZ_portris_opensocketZcreate_connectionfrom_urlZportstr POLL_TIMEOUT_socket ExceptionformatZ setblocking_reconfigure_portZ_dsrdtr_update_dtr_stateZ_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%rQs zSerial._reconfigure_portcCsP|jr&|jrz|jtj|jWnYd|_d|_tddSdS)z Close portNFg333333?)rrZshutdownrZ SHUT_RDWRclosetimesleepr'r$r$r%r([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)urlparseZurlsplitZschemerrZparse_qsZqueryitemsr+Z basicConfigZ getLoggerrZsetLevel LOGGER_LEVELSr ValueErrorZportZhostname)r"Zurlpartsoptionvalueser$r$r%rjs6    zSerial.from_urlcCs.|jstt|jgggd\}}}t|S)z9Return the number of bytes currently in the input buffer.r)rrselectrlen)r"ZlrZlwZlxr$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 bytearrayrZ_timeoutr5r4r time_leftrecvrextendOSErrorerrnoEAGAINEALREADY EWOULDBLOCK EINPROGRESSEINTRrr rexpiredbytes)r"sizereadrready_bufr3r$r$r%rGs<      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: {})rrrr5rZ_write_timeoutrsendZis_non_blockingZ is_infiniterDrr4r:rr=r>r?r@rArBrCrr ) r"datadZtx_lenlengthrnrIrHr3r$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.Trir8N)rrr4rr;r=r>r?r@rArBrCrrr r)r"rHrIr3r$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"Zdurationr$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 rZ _break_stater'r$r$r%_update_break_stateszSerial._update_break_statecCrT)z)Set terminal status line: Request To Sendzignored _update_rts_state({!r})N)rr rZ _rts_stater'r$r$r%r%zSerial._update_rts_statecCrT)z-Set terminal status line: Data Terminal Readyzignored _update_dtr_state({!r})N)rr rZ _dtr_stater'r$r$r%r*rVzSerial._update_dtr_statecC"|jst|jr|jddS)z(Read terminal status line: Clear To Sendzreturning dummy for ctsTrQr'r$r$r%cts/  z Serial.ctscCrW)z)Read terminal status line: Data Set Readyzreturning dummy for dsrTrQr'r$r$r%dsr8rYz Serial.dsrcCrW)z)Read terminal status line: Ring Indicatorzreturning dummy for riFrQr'r$r$r%riArYz Serial.ricCrW)z)Read terminal status line: Carrier Detectzreturning dummy for cd)TrQr'r$r$r%cdJrYz 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)r7)rR)__name__ __module__ __qualname____doc__Z BAUDRATESr&rr(rpropertyr6rGrPr r!rSrUrrrXrZr[r\r]r$r$r$r%r -s4   )5       r __main__zsocket://localhost:7000z{} z write... shello z read: {} )"Z __future__rr>r+r4rr)r, ImportErrorZ urllib.parseparseZserial.serialutilrrrrrrDEBUGINFOZWARNINGZERRORr.rr r^syssstdoutrPrflushrGr(r$r$r$r%s>    2