U ÏÐ~d7‰ã@sÎddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z m Z mZmZmZGdd„deƒZdZej ¡Zedd…dkrÜddlZdZd Zd Zd Zd Zd ZdZdZdZdZ Gdd„deƒZ!nÄedkröGdd„deƒZ!nªedd…dkr&ddlZdZ"Gdd„deƒZ!nzedd…dksnedd…dksnedd…dksnedd…dkrGd d!„d!eƒZ#Gd"d„deƒZ!nGd#d„deƒZ!e$ed$d%ƒZ%e$ed&d'ƒZ&e$ed(d)ƒZ'e$ed*d+ƒZ(e$ed,dƒZ)e$ed-dƒZ*e$ed.d/ƒZ+e$ed0d1ƒZ,e$ed2d3ƒZ-e$ed4d5ƒZ.e$ed6e,ƒZ/e$ed7e-ƒZ0e1ed8ƒrDej2Z2n e$ed9d:ƒZ2e$ed;d<ƒZ3e 4d=d¡Z5e 4d=e*¡Z6e 4d=e)¡Z7e$ed>d?ƒZ8e$ed@dAƒZ9GdBdC„dCe e!ƒZ:GdDdE„dEe:ƒZ;GdFdG„dGe:ƒZt k r†}z d|_t|j d  |j|¡ƒ‚W5d}~XYnXd\|_ |_d\|_|_zº|jddz |js¾| ¡|jsÌ| ¡Wn8tk r}z|j t jt jfkrö‚W5d}~XYnX| ¡t ¡\|_ |_t ¡\|_|_t |j tjtj ¡t |jtjtj ¡Wn¾tk rzt |j¡Wntk r’YnXd|_|jdk r¸t |j¡d|_|j dk rÖt |j ¡d|_ |jdk rôt |j¡d|_|jdk rt |j¡d|_‚YnXd|_dS)zo 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.zcould not open port {}: {}©NNT)Ú force_update) Ú_portrÚis_openrroÚopenZportstrÚO_RDWRÚO_NOCTTYÚ O_NONBLOCKÚOSErrorÚerrnorUÚpipe_abort_read_rÚpipe_abort_read_wÚpipe_abort_write_rÚpipe_abort_write_wÚ_reconfigure_portZ_dsrdtrÚ_update_dtr_stateÚ_rtsctsÚ_update_rts_staterSÚEINVALZENOTTYÚ_reset_input_bufferÚpiperÚF_SETFLÚ BaseExceptionÚcloseÚ Exception)r ÚmsgrWrrrrŒ7s^ "(            z Serial.openFcCs|jdkrtdƒ‚|jdk rˆ|jrxzt |jtjtjB¡Wqˆtk rt}zt|jd  |j |¡ƒ‚W5d}~XYqˆXnt |jtj ¡d}d}}|j dk r°d}t |j dƒ}z"t |j¡}|\}}} } } } } Wn4tjk r}ztd  |¡ƒ‚W5d}~XYnX| tjtjBO} | tjtjBtjBtjBtjBtjBtjBM} dD]"}tt|ƒrL| tt|ƒM} qL|tjtjBtjBM}|tjtj Btj!Btj"BM}ttd ƒr¾|tj#M}ttd ƒrÖ|tj$M}zttd   |j%¡ƒ} } WnÄt&k r´z|j'|j%} } Wn˜t(k r®z t)} } Wn$t*k rXttd ƒ} } YnXzt |j%ƒ}Wn&t+k rŽt+d   |j%¡ƒ‚YnX|dkrªt+d   |j%¡ƒ‚YnXYnX| tj,M} |j-dkrÚ| tj.O} nX|j-dkrò| tj/O} n@|j-dkr | tj0O} n(|j-dkr"| tj1O} nt+d  |j-¡ƒ‚|j2t3j4krN| tj5M} nD|j2t3j6krh| tj5O} n*|j2t3j7kr‚| tj5O} nt+d  |j2¡ƒ‚|tj8tj9BM}|j:t3j;krÊ| tjBM} n¾|j:t3j?krô| tj=t>BM} | tjM} | tjrH| tjBtj=BO} n@|j:t3jBkrxt>rx| tjBO} | tj=M} nt+d  |j:¡ƒ‚ttdƒrÈ|jCr®|tjDtjEBO}n|tjDtjEBtjFBM}n,|jCrâ|tjDtjEBO}n|tjDtjEBM}ttdƒr"|jGr| tjHO} n | tjHM} n,ttdƒrN|jGrB| tjIO} n | tjIM} |dksb|dkrpt+d  |¡ƒ‚|| tjJ<|dksŽ|dkrœt+d  |¡ƒ‚|| tjK<|sÄ||| | | | | g|krät L|jtjM||| | | | | g¡|dk rø| N|¡|jOdk r| P|jO¡dS)ú,Set communication parameters on opened port.Nz+Can only operate on a valid file descriptorz&Could not exclusively lock port {}: {}rr#r-úCould not configure port: {})ÚECHOCTLÚECHOKEÚIUCLCÚPARMRKzB{}ÚB38400zInvalid baud rate: {!r}r+r*r)r!zInvalid char len: {!r}z$Invalid stop bit specification: {!r}zInvalid parity: {!r}ÚIXANYÚCRTSCTSÚ CNEW_RTSCTSéÿzInvalid vmin: {!r}úInvalid vtime: {!r})QrrZ _exclusiverZflockZLOCK_EXZLOCK_NBrSr‘rUrŠZLOCK_UNÚ_inter_byte_timeoutrdrPÚ tcgetattrÚerrorÚCLOCALÚCREADÚICANONÚECHOÚECHOEÚECHOKÚECHONLÚISIGÚIEXTENÚhasattrÚgetattrÚOPOSTÚONLCRÚOCRNLÚINLCRÚIGNCRÚICRNLÚIGNBRKr¦r§Z _baudrateÚAttributeErrorr ÚKeyErrorr[Ú NameErrorrTÚCSIZEZ _bytesizeÚCS8ÚCS7ÚCS6ÚCS5Z _stopbitsÚserialZ STOPBITS_ONEÚCSTOPBZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWOÚINPCKÚISTRIPZ_parityZ PARITY_NONEÚPARENBÚPARODDÚCMSPARZ PARITY_EVENZ PARITY_ODDZ PARITY_MARKZ PARITY_SPACEZ_xonxoffÚIXONÚIXOFFr©r˜rªr«ÚVMINÚVTIMEÚ tcsetattrÚTCSANOWrZ _rs485_moder)r r‰r¡Z custom_baudÚvminÚvtimeÚ orig_attrÚiflagÚoflagÚcflagÚlflagÚispeedÚospeedÚccÚflagrrrr–xsê  *   ÿÿþþ                            ý   zSerial._reconfigure_portcCst|jrp|jdk rjt |j¡d|_t |j¡t |j¡t |j¡t |j¡d\|_|_d\|_|_d|_dS)z Close portNrˆF)r‹rrorŸr“r’r•r”rrrrrŸs        z Serial.closecCs t |jtt¡}t d|¡dS)z9Return the number of bytes currently in the input buffer.r†r)rrrrƒÚTIOCM_zero_strÚstructÚunpack©r ÚsrrrÚ in_waiting!szSerial.in_waitingr#c Cs`|js tƒ‚tƒ}t|jƒ}t|ƒ|krXzdt |j|jggg|  ¡¡\}}}|j|krlt   |jd¡WqX|svWqXt   |j|t|ƒ¡}Wn¢t k rÜ}z0|j t jt jt jt jt jfkrÌtd |¡ƒ‚W5d}~XYnntjk r0}z4|dt jt jt jt jt jfkr td |¡ƒ‚W5d}~XYnX|s@tdƒ‚| |¡| ¡rqXqt|ƒS)úÑ 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. r^zread failed: {}Nrzgdevice reports readiness to read but returned no data (device disconnected or multiple access on port?))r‹rÚ bytearrayrÚ_timeoutÚlenÚselectrr’Ú time_leftroÚreadrr‘ÚEAGAINÚEALREADYÚ EWOULDBLOCKÚ EINPROGRESSÚEINTRrrUr°ÚextendÚexpiredÚbytes)r ÚsizerïÚtimeoutÚreadyÚ_rVrWrrrrï)s6 " " ÿ z Serial.readcCs|jrt |jd¡dS©Nóx)r‹roÚwriter“rrrrÚ cancel_read\szSerial.cancel_readcCs|jrt |jd¡dSrü)r‹rorþr•rrrrÚ cancel_write`szSerial.cancel_writec Csú|js tƒ‚t|ƒ}t|ƒ}}t|jƒ}|dkrîzät |j|¡}|j rP|WS|j s®|  ¡rft dƒ‚t   |jg|jgg| ¡¡\}}} |r t |jd¡Wqî|s¬t dƒ‚nT| ¡dks¾t‚t   |jg|jggd¡\}}} |rôt |jd¡Wqî|stdƒ‚||d…}||8}Wn¼tk r0‚Yn¦tk r€} z2| jtjtjtjtjtjfkrptd | ¡ƒ‚W5d} ~ XYnVt jk rÔ} z4| dtjtjtjtjtjfkrÄtd | ¡ƒ‚W5d} ~ XYnX|j s*|  ¡r*t dƒ‚q*|t|ƒS)z2Output the given byte string over the serial port.rz Write timeoutr^Nr#zwrite failed (select)zwrite failed: {})r‹rrrìrZ_write_timeoutrorþrZis_non_blockingÚ is_infiniterörrír”rîrïÚAssertionErrorrrr‘rðrñròrórôrUr°) r ÚdataÚdZtx_lenÚlengthrùÚnÚabortrúrûrWrrrrþdsN   "    "  z Serial.writecCs|js tƒ‚t |j¡dS)zb Flush of file like objects. In this case, wait until all data is written. N)r‹rrPÚtcdrainrrrrrÚflushšsz Serial.flushcCst |jtj¡dS©z9Clear input buffer, discarding all that is in the buffer.N)rPÚtcflushrÚTCIFLUSHrrrrr›£szSerial._reset_input_buffercCs|js tƒ‚| ¡dSr )r‹rr›rrrrÚreset_input_buffer§szSerial.reset_input_buffercCs |js tƒ‚t |jtj¡dS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. N)r‹rrPr rÚTCOFLUSHrrrrÚreset_output_buffer­szSerial.reset_output_bufferçÐ?cCs&|js tƒ‚t |jt|dƒ¡dS)za Send break condition. Timed, returns to idle state after given duration. rN)r‹rrPÚ tcsendbreakrrd)r ÚdurationrrrÚ send_break¶szSerial.send_breakcCs,|jrt |jtt¡nt |jtt¡dS)z)Set terminal status line: Request To SendN)Z _rts_staterrrrvÚ TIOCM_RTS_strrwrrrrr™¿szSerial._update_rts_statecCs,|jrt |jtt¡nt |jtt¡dS)z-Set terminal status line: Data Terminal ReadyN)Z _dtr_staterrrrvÚ TIOCM_DTR_strrwrrrrr—ÆszSerial._update_dtr_statecCs4|js tƒ‚t |jtt¡}t d|¡dt @dkS)z(Read terminal status line: Clear To Sendr†r) r‹rrrrrurãrärår{rærrrÚctsÍsz Serial.ctscCs4|js tƒ‚t |jtt¡}t d|¡dt @dkS)z)Read terminal status line: Data Set Readyr†r) r‹rrrrrurãrärårrærrrÚdsrÕsz Serial.dsrcCs4|js tƒ‚t |jtt¡}t d|¡dt @dkS)z)Read terminal status line: Ring Indicatorr†r) r‹rrrrrurãrärår‚rærrrÚriÝsz Serial.ricCs4|js tƒ‚t |jtt¡}t d|¡dt @dkS)z)Read terminal status line: Carrier Detectr†r) r‹rrrrrurãrärårrærrrÚcdåsz Serial.cdcCs t |jtt¡}t d|¡dS)z:Return the number of bytes currently in the output buffer.r†r)rrrr…rãrärårærrrÚ out_waitingïszSerial.out_waitingcCs|js tƒ‚|jS)z For easier use of the serial port instance with select. WARNING: this function is not portable to different platforms! )r‹rrrrrrÚfilenoösz Serial.filenoTcCs6|js tƒ‚|r"t |jtj¡nt |jtj¡dS)zÝ Manually control flow - when software flow control is enabled. This will send XON (true) or XOFF (false) to the other device. WARNING: this function is not portable to different platforms! N)r‹rrPÚtcflowrÚTCIONÚTCIOFF©r ÚenablerrrÚset_input_flow_controlÿs zSerial.set_input_flow_controlcCs6|js tƒ‚|r"t |jtj¡nt |jtj¡dS)z» Manually control flow of outgoing data - when hardware or software flow control is enabled. WARNING: this function is not portable to different platforms! N)r‹rrPrrÚTCOONÚTCOOFFrrrrÚset_output_flow_control s zSerial.set_output_flow_controlcCsddl}| dt¡dS)zDEPRECATED - has no userNz0nonblocking() has no effect, already nonblocking)ÚwarningsÚwarnÚDeprecationWarning)r r%rrrÚ nonblockingszSerial.nonblockingN)F)r#)r)T)T)rrrÚ__doc__rŒr–rŸÚpropertyrèrïrÿrrþr r›r rrr™r—rrrrrrr!r$r(rrrrr‡0s@A   36        r‡c@seZdZdZddd„ZdS)ÚPosixPollSerialzÕ Poll based read implementation. Not all systems support poll properly. However this one has better handling of errors, such as a device disconnecting while it's in use (e.g. USB-serial unplugged). r#cCs>|js tƒ‚tƒ}t|jƒ}t ¡}| |jtj tj Btj Btj B¡| |j tj tj Btj Btj B¡|dkr6t|ƒ|kr6| |jrŽdn | ¡d¡D]4\}}||j kr²qÒ|tj tj Btj B@rœtdƒ‚qœ||j krît |j d¡q6t |j|t|ƒ¡}| |¡| ¡s6|jdk rr|jdkrr|srq6qrt|ƒS)rérNr^zdevice reports error (poll))r‹rrêrrëríÚpollÚregisterrÚPOLLINÚPOLLERRÚPOLLHUPÚPOLLNVALr’rìrrîrrorïrõrör®r÷)r rørïrùr,rÚeventrVrrrrï&s8 "" $     ÿÿÿzPosixPollSerial.readN)r#)rrrr)rïrrrrr+sr+cs2eZdZdZd‡fdd„ Zd dd„ZeƒZ‡ZS) Ú VTIMESerialab Implement timeout using vtime of tty device instead of using select. This means that no inter character timeout can be specified and that the error handling is degraded. Overall timeout is disabled when inter-character timeout is used. Note that this implementation does NOT support cancel_read(), it will just ignore that. Tc stt|ƒ ¡t |jtjd¡|jdk r>d}t|jdƒ}n&|jdkrRd}d}nd}t|jdƒ}z"t   |j¡}|\}}}}} } } Wn4t j k rº} zt   d | ¡¡‚W5d} ~ XYnX|dksÌ|dkrÚtd |¡ƒ‚|| t j<|| t j<t  |jt j||||| | | g¡dS)r¢rNr#r-r£r¬r­)Úsuperr3r–rrrr®rdrërPr¯r°rËrrUrTrÕrÔrÖr×) r r‰rØrÙrÚrÛrÜrÝrÞrßràrár¡©Ú __class__rrr–Us0   "  ýzVTIMESerial._reconfigure_portr#cCsN|js tƒ‚tƒ}t|ƒ|krFt |j|t|ƒ¡}|s:qF| |¡qt|ƒS)ré) r‹rrêrìrorïrrõr÷)r rørïrVrrrrïss  zVTIMESerial.read)T)r#) rrrr)r–rïr*rÿÚ __classcell__rrr5rr3Is  r3)=Ú __future__rr‘rroríräÚsysrPrËZserial.serialutilrrrrrrÚobjectr rÑÚplatformÚlowerÚplatrOrYr\r[r_rer`rbrcrar'rkrrr»rurvrwrxryrzr{r|r}rrr‚rºrƒr…Úpackrãrrrrr‡r+r3rrrrÚsˆ   bÿþý                    r*