o l@xd7@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)loggerZ_portris_opensocketcreate_connectionfrom_urlZportstr POLL_TIMEOUT_socket Exceptionformat setblocking_reconfigure_portZ_dsrdtr_update_dtr_stateZ_rtscts_update_rts_statereset_input_bufferreset_output_buffer)selfmsgr'ID:\rfid_django\env\Lib\site-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(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)urlparseurlsplitschemerrparse_qsqueryitemsr0 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%lrZlwlxr'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_timeoutrDrCr time_leftrecvrextendOSErrorerrnoEAGAINEALREADY EWOULDBLOCK EINPROGRESSEINTRrr rexpiredbytes)r%sizereadrready_bufrBr'r'r(rYs<      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: {})rrrrDrZ_write_timeoutrsendZis_non_blocking is_infiniterVrrCrLrrOrPrQrRrSrTrUrr ) r%datadZtx_lenlengthrnr[rZrBr'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.TrirIN)rrrCrrMrOrPrQrRrSrTrUrrr r)r%rZr[rBr'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 rZ _break_stater*r'r'r(_update_break_stateszSerial._update_break_statecCrh)z)Set terminal status line: Request To Sendzignored _update_rts_state({!r})N)rr rZ _rts_stater*r'r'r(r"%zSerial._update_rts_statecCrh)z-Set terminal status line: Data Terminal Readyzignored _update_dtr_state({!r})N)rr rZ _dtr_stater*r'r'r(r!*rjzSerial._update_dtr_statecC"|jst|jr|jddS)z(Read terminal status line: Clear To Sendzreturning dummy for ctsTrdr*r'r'r(cts/  z Serial.ctscCrk)z)Read terminal status line: Data Set Readyzreturning dummy for dsrTrdr*r'r'r(dsr8rmz Serial.dsrcCrk)z)Read terminal status line: Ring Indicatorzreturning dummy for riFrdr*r'r'r(riArmz Serial.ricCrk)z)Read terminal status line: Carrier Detectzreturning dummy for cd)Trdr*r'r'r(cdJrmz Serial.cdcCs |jS)z@Get the file handle of the underlying socket for use with select)rfilenor*r'r'r(rqVs z Serial.filenoN)rH)re)__name__ __module__ __qualname____doc__Z BAUDRATESr)r r-rpropertyrGrYrcr#r$rgrir"r!rlrnrorprqr'r'r'r(r-s4   )5       r__main__zsocket://localhost:7000z{} z write... shello z read: {} )" __future__rrPr0rCrr.r1 ImportError urllib.parseparseZserial.serialutilrrrrrrDEBUGINFOWARNINGERRORr:rrrrsyssstdoutrcrflushrYr-r'r'r'r(s>    2