U : iY¦{ã@sÂddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z m Z mZGdd„deƒZdZej ¡Zedd…dkrÐddlZdZdZd Zd Zd Zd Zd ZdZdZdZGdd„deƒZnÄedkrêGdd„deƒZnªedd…dkrddlZdZ Gdd„deƒZnzedd…dksbedd…dksbedd…dksbedd…dkr„Gdd „d eƒZ!Gd!d„deƒZnGd"d„deƒZe"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"ed/d0ƒZ*e"ed1d2ƒZ+e"ed3d4ƒZ,e"ed5e*ƒZ-e"ed6e+ƒZ.e/ed7ƒr8ej0Z0n e"ed8d9ƒZ0e"ed:d;ƒZ1e 2dƒZ6e"ed?d@ƒZ7GdAdB„dBe eƒZ8GdCdD„dDe8ƒZ9GdEdF„dFe8ƒZ:dS)GéN)Ú SerialBaseÚSerialExceptionÚto_bytesÚportNotOpenErrorÚwriteTimeoutErrorÚTimeoutc@s eZdZiZdd„Zdd„ZdS)ÚPlatformSpecificBasecCs tdƒ‚dS)Nz9non-standard baudrates are not supported on this platform©ÚNotImplementedError)ÚselfÚbaudrate©r ú4/usr/lib/python3/dist-packages/serial/serialposix.pyÚ_set_special_baudrate.sz*PlatformSpecificBase._set_special_baudratecCs tdƒ‚dS)Nz$RS485 not supported on this platformr )r Úrs485_settingsr r rÚ_set_rs485_mode1sz$PlatformSpecificBase._set_rs485_modeN©Ú__name__Ú __module__Ú __qualname__ÚBAUDRATE_CONSTANTSrrr r r rr+sréZlinuxi@l*TXi+T,@ii.Ti/Tééééc @s`eZdZddddddddd d d d d ddddddddddddddddddd œZd!d"„Zd#d$„Zd%S)&ÚPlatformSpecificrrrérréééé é é é é ééiiéiéiééé é é é é éé)ré2éKéné†é–éÈi,iXi°ii` iÀi€%iKi–iáiÂi„ié ¡éÊéé@Bé”é`ã逄é %&éÀÆ-iàg5i =c Cs¢t ddgd¡}zXt |jt|¡|dtjM<|dtO<||d<|d<t |jt|¡Wn2t k rœ}zt d  ||¡ƒ‚W5d}~XYnXdS)NÚiré@rr!r"z'Failed to set custom baud rate ({}): {}) ÚarrayÚfcntlÚioctlÚfdÚTCGETS2ÚtermiosZCBAUDÚBOTHERÚTCSETS2ÚIOErrorÚ ValueErrorÚformat)r r ÚbufÚer r rrtsú&PlatformSpecific._set_special_baudratec CsFt ddgd¡}züt |jt|¡|dtO<|dk rô|jrT|dtO<n|dtM<|jr~|dt O<n|dt M<|j r¨|dt O<n|dt M<|j dk rÖt |j dƒ|d<|jdk rüt |jdƒ|d<nd|d<t |jt|¡Wn2tk r@}ztd |¡ƒ‚W5d}~XYnXdS)NrBrr éèrrzFailed to set RS485 mode: {})rDrErFrGÚ TIOCGRS485ÚSER_RS485_ENABLEDZloopbackÚSER_RS485_RX_DURING_TXZrts_level_for_txÚSER_RS485_RTS_ON_SENDZrts_level_for_rxÚSER_RS485_RTS_AFTER_SENDZdelay_before_txÚintZdelay_before_rxÚ TIOCSRS485rLrMrN)r rrOrPr r rr„s,  z PlatformSpecific._set_rs485_modeNrr r r rrQsDá"rÚcygwinc @s(eZdZddddddddd d d d œ Zd S)rr(r)r*r+r,r-r.r/r0r1r2) iôièr9r:r;r<r=r>r?r@rAN)rrrrr r r rr£sõrÚdarwinlTc@s6eZdZe ¡d d¡Zeedƒdkr2dd„ZdS)rrÚ.rr cCs$t d|g¡}t |jt|d¡dS)NrBr)rDrErFrGÚ IOSSIOSPEED)r r rOr r rr»srQN) rrrÚosÚunameÚsplitZ osx_versionrXrr r r rr·srZbsdrZfreebsdZnetbsdZopenbsdc@seZdZdd„ZdS)ÚReturnBaudratecCs|S)Nr )r Úkeyr r rÚ __getitem__ÆszReturnBaudrate.__getitem__N)rrrrcr r r rraÅsrac@seZdZeƒZdS©rN)rrrrarr r r rrÉsc@s eZdZdSrd)rrrr r r rrÐsÚTIOCMGETiTÚTIOCMBISiTÚTIOCMBICiTÚTIOCMSETiTÚ TIOCM_DTRÚ TIOCM_RTSÚ TIOCM_CTSé Ú TIOCM_CARrCÚ TIOCM_RNGé€Ú TIOCM_DSRéÚTIOCM_CDÚTIOCM_RIÚTIOCINQZFIONREADiTÚTIOCOUTQiTÚIÚTIOCSBRKi'TÚTIOCCBRKi(Tc@sòeZdZdZdd„Zd7dd„Zdd„Zed d „ƒZd8d d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zd9dd„Zdd„Zdd „Zd!d"„Zed#d$„ƒZed%d&„ƒZed'd(„ƒZed)d*„ƒZed+d,„ƒZd-d.„Zd:d0d1„Zd;d2d3„Zd4d5„Zd6S)<ÚSerialz¢ Serial port class POSIX implementation. Serial port configuration is done with termios and fcntl. Runs on Linux and many other Un*x like systems. c Cs„|jdkrtdƒ‚|jr tdƒ‚d|_z"t |jtjtjBtj B¡|_Wn>t k r†}z d|_t|j d  |j|¡ƒ‚W5d}~XYnXz|j ddWn2zt |j¡Wn YnXd|_‚YnXd|_z |jsâ| ¡|jsð| ¡Wn<tk r.}z|j t jt jfkrn‚W5d}~XYnX| ¡t ¡\|_|_t ¡\|_|_t |jtjtj ¡t |jtjtj ¡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 {}: {}T)Ú force_update)Ú_portrÚis_openrGr^ÚopenZportstrÚO_RDWRÚO_NOCTTYÚ O_NONBLOCKÚOSErrorÚerrnorNÚ_reconfigure_portÚcloseZ_dsrdtrÚ_update_dtr_stateÚ_rtsctsÚ_update_rts_staterLZEINVALZENOTTYÚreset_input_bufferÚpipeÚpipe_abort_read_rÚpipe_abort_read_wÚpipe_abort_write_rÚpipe_abort_write_wrEÚF_SETFL)r ÚmsgrPr r rr}þsD "( 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 rz|j'|j%} } Wntt(k rŠttd ƒ} } zt |j%ƒ}Wn&t)k rjt)d   |j%¡ƒ‚YnX|dkr†t)d   |j%¡ƒ‚YnXYnX| tj*M} |j+dkr¶| tj,O} nX|j+dkrÎ| tj-O} n@|j+dkræ| tj.O} n(|j+dkrþ| tj/O} nt)d  |j+¡ƒ‚|j0t1j2kr*| tj3M} nD|j0t1j4krD| tj3O} n*|j0t1j5kr^| tj3O} nt)d  |j0¡ƒ‚|tj6tj7BM}|j8t1j9kr¦| tj:tj;Btkrú| t<M} | tj:tj;BO} nj|j8t1j?kr$t<r$| tj:t|dkrLt)d  |¡ƒ‚|| tjH<|dksj|dkrxt)d  |¡ƒ‚|| tjI<|s ||| | | | | g|krÀt J|jtjK||| | | | | g¡|dk rÔ| L|¡|jMdk rì| N|jM¡dS)ú,Set communication parameters on opened port.Nz+Can only operate on a valid file descriptorz&Could not exclusively lock port {}: {}rrr"úCould not configure port: {})ZECHOCTLZECHOKEÚIUCLCÚPARMRKzB{}ZB38400zInvalid baud rate: {!r}r rrrzInvalid char len: {!r}z$Invalid stop bit specification: {!r}zInvalid parity: {!r}ÚIXANYÚCRTSCTSÚ CNEW_RTSCTSéÿzInvalid vmin: {!r}úInvalid vtime: {!r})OrGrZ _exclusiverEZflockZLOCK_EXZLOCK_NBrLr‚rNr{ZLOCK_UNÚ_inter_byte_timeoutrXrIÚ tcgetattrÚerrorZCLOCALZCREADZICANONZECHOZECHOEZECHOKZECHONLZISIGZIEXTENÚhasattrÚgetattrZOPOSTZONLCRZOCRNLZINLCRZIGNCRZICRNLZIGNBRKr’r“Z _baudrateÚAttributeErrorrÚKeyErrorrMZCSIZEZ _bytesizeZCS8ZCS7ZCS6ZCS5Z _stopbitsÚserialZ STOPBITS_ONEZCSTOPBZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWOZINPCKZISTRIPZ_parityZ PARITY_NONEZPARENBZPARODDÚCMSPARZ PARITY_EVENZ PARITY_ODDZ PARITY_MARKZ PARITY_SPACEZ_xonxoffZIXONZIXOFFr”r†r•r–ÚVMINÚVTIMEÚ tcsetattrÚTCSANOWrZ _rs485_moder)r rzrZ custom_baudÚvminÚvtimeÚ orig_attrÚiflagÚoflagÚcflagÚlflagÚispeedÚospeedÚccÚflagr r rrƒ-sä  *   ÿÿþþ                           ý   zSerial._reconfigure_portcCst|jrp|jdk rjt |j¡d|_t |j¡t |j¡t |j¡t |j¡d\|_|_d\|_|_d|_dS)z Close portN)NNF)r|rGr^r„r‹rŠrrŒ©r r r rr„¿s        z Serial.closecCs t |jtt¡}t d|¡dS)z9Return the number of bytes currently in the input buffer.rvr)rErFrGrtÚTIOCM_zero_strÚstructÚunpack©r Úsr r rÚ in_waitingÏszSerial.in_waitingrc Cs\|js t‚tƒ}t|jƒ}t|ƒ|krTzzt |j|jggg|  ¡¡\}}}|j|krjt   |jd¡WqT|stWqTt   |j|t|ƒ¡}|s–t dƒ‚|  |¡Wn¢tk rð}z0|jtjtjtjtjtjfkràt d |¡ƒ‚W5d}~XYnVtjk rD}z4|dtjtjtjtjtjfkr4t d |¡ƒ‚W5d}~XYnX| ¡rqTqt|ƒ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. rRzgdevice reports readiness to read but returned no data (device disconnected or multiple access on port?)zread failed: {}Nr)r|rÚ bytearrayrÚ_timeoutÚlenÚselectrGrŠÚ time_leftr^ÚreadrÚextendrr‚ÚEAGAINÚEALREADYÚ EWOULDBLOCKÚ EINPROGRESSÚEINTRrNr›ÚexpiredÚbytes)r Úsizer¾ÚtimeoutÚreadyÚ_rOrPr r rr¾×s6 " ÿ" z Serial.readcCs|jrt |jd¡dS©Nóx)r|r^Úwriter‹r±r r rÚ cancel_readszSerial.cancel_readcCs|jrt |jd¡dSrË)r|r^rÍrr±r r rÚ cancel_write szSerial.cancel_writec Csê|js t‚t|ƒ}t|ƒ}}t|jƒ}|dkrÞzÚt |j|¡}|j rN|WS|j s¤|  ¡r`t ‚t   |jg|jgg| ¡¡\}}} |ršt |jd¡WqÞ|söt ‚nR| ¡dks´t‚t   |jg|jggd¡\}}} |rêt |jd¡WqÞ|sötdƒ‚||d…}||8}Wn¼tk r$‚Yn¦tk rt} z2| jtjtjtjtjtjfkrdtd | ¡ƒ‚W5d} ~ XYnVt jk rÈ} z4| dtjtjtjtjtjfkr¸td | ¡ƒ‚W5d} ~ XYnX|j s(|  ¡r(t ‚q(|t|ƒS)z2Output the given byte string over the serial port.rrRNrzwrite failed (select)zwrite failed: {})r|rrr»rZ_write_timeoutr^rÍrGZis_non_blockingZ is_infiniterÅrr¼rŒr½r¾ÚAssertionErrorrrr‚rÀrÁrÂrÃrÄrNr›) r ÚdataÚdZtx_lenZlengthrÈÚnÚabortrÉrÊrPr r rrÍsN   "   " 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|rrIZtcdrainrGr±r r rÚflushFsz Serial.flushcCs|js t‚t |jtj¡dS)z9Clear input buffer, discarding all that is in the buffer.N)r|rrIÚtcflushrGZTCIFLUSHr±r r rrˆOszSerial.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|rrIrÖrGZTCOFLUSHr±r r rÚreset_output_bufferUszSerial.reset_output_bufferçÐ?cCs$|js t‚t |jt|dƒ¡dS)za Send break condition. Timed, returns to idle state after given duration. rØN)r|rrIZ tcsendbreakrGrX)r Zdurationr r rÚ send_break^szSerial.send_breakcCs(|jrt |jt¡nt |jt¡dS)zS Set break: Controls TXD. When active, no transmitting is possible. N)Z _break_staterErFrGrwrxr±r r rÚ_update_break_stategszSerial._update_break_statecCs,|jrt |jtt¡nt |jtt¡dS)z)Set terminal status line: Request To SendN)Z _rts_staterErFrGrfÚ TIOCM_RTS_strrgr±r r rr‡pszSerial._update_rts_statecCs,|jrt |jtt¡nt |jtt¡dS)z-Set terminal status line: Data Terminal ReadyN)Z _dtr_staterErFrGrfÚ TIOCM_DTR_strrgr±r r rr…wszSerial._update_dtr_statecCs2|js t‚t |jtt¡}t d|¡dt @dkS)z(Read terminal status line: Clear To Sendrvr) r|rrErFrGrer²r³r´rkrµr r rÚcts~sz Serial.ctscCs2|js t‚t |jtt¡}t d|¡dt @dkS)z)Read terminal status line: Data Set Readyrvr) r|rrErFrGrer²r³r´rprµr r rÚdsr†sz Serial.dsrcCs2|js t‚t |jtt¡}t d|¡dt @dkS)z)Read terminal status line: Ring Indicatorrvr) r|rrErFrGrer²r³r´rsrµr r rÚriŽsz Serial.ricCs2|js t‚t |jtt¡}t d|¡dt @dkS)z)Read terminal status line: Carrier Detectrvr) r|rrErFrGrer²r³r´rrrµr r rÚcd–sz Serial.cdcCs t |jtt¡}t d|¡dS)z:Return the number of bytes currently in the output buffer.rvr)rErFrGrur²r³r´rµr r rÚ 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|rrGr±r r rÚfileno§sz Serial.filenoTcCs4|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|rrIÚtcflowrGZTCIONZTCIOFF©r Úenabler r rÚset_input_flow_control°s zSerial.set_input_flow_controlcCs4|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|rrIrãrGZTCOONZTCOOFFrär r rÚ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èr r rÚ nonblockingÊszSerial.nonblockingN)F)r)rØ)T)T)rrrÚ__doc__r}rƒr„Úpropertyr·r¾rÎrÏrÍrÕrˆr×rÙrÚr‡r…rÝrÞrßràrárârærçrër r r rry÷s@/   16         ryc@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). rcCsÞ|js t‚tƒ}t ¡}| |jtjtjBtj Btj B¡|dkrÖt |ƒ|krÖ| |j d¡D]&\}}|tjtj Btj B@r^t dƒ‚q^t |j|t |ƒ¡}| |¡|j dk rº|j dksÎ|jdk rB|jdkrB|sBqÖqBt|ƒS)r¸rrRzdevice reports error (poll)N)r|rr¹r¼ÚpollÚregisterrGZPOLLINZPOLLERRZPOLLHUPZPOLLNVALr»rºrr^r¾r¿r™rÆ)r rÇr¾rïrGZeventrOr r rr¾×s*"   ÿÿÿzPosixPollSerial.readN)r)rrrrìr¾r r r rrîÐsrîcs2eZdZdZd‡fdd„ Zd dd„ZeƒZ‡ZS) Ú VTIMESeriala 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. 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)rrNrr"r‘r—r˜)ÚsuperrñrƒrErGrŽr™rXrºrIršr›r rrNrMr£r¢r¤r¥) r rzr¦r§r¨r©rªr«r¬r­r®r¯r©Ú __class__r rrƒüs0   "  ýzVTIMESerial._reconfigure_portrcCsL|js t‚tƒ}t|ƒ|krDt |j|t|ƒ¡}|s8qD| |¡qt|ƒS)r¸) r|rr¹r»r^r¾rGr¿rÆ)r rÇr¾rOr r rr¾s  zVTIMESerial.read)T)r) rrrrìrƒr¾rírÎÚ __classcell__r r rórrñós rñ);r‚rEr^r¼r³ÚsysrIr Zserial.serialutilrrrrrrÚobjectrr¡ÚplatformÚlowerZplatrDrHrKrJrSrYrTrVrWrUrr]rarrerfrgrhrirjrkrmrnrprrrsrœrtruZpackr²rÛrÜrwrxryrîrñr r r rÚs†   P ÿþý                    \#