jqVu@s}ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z m Z mZGdddeZejjZedddkr*ddlZdZdZd Zd Zd Zd Zd ZdZdZGdddeZnedkrOGdddeZnedddkr~GdddeZnedddkpedddkrGdddeZnBedddkrddlZdZGdddeZnedddkr3Gd ddeZneddd!krbGd"ddeZnedd d#krGd$ddeZnteddd%krGd&ddeZnEeddd'krGd(ddeZnGd)ddeZe ed*d+Z!e ed,d-Z"e ed.d/Z#e ed0d1Z$e ed2d Z%e ed3dZ&e ed4d5Z'e ed6d7Z(e ed8d9Z)e ed:d;Z*e ed<e(Z+e ed=e)Z,e-ed>rej.Z.ne ed?d@Z.e edAdBZ/ej0dCdZ1ej0dCe&Z2ej0dCe%Z3e edDdEZ4e edFdGZ5dHZ6GdIdJdJe eZ7GdKdLdLe7Z8GdMdNdNe7Z9e:dOkrye7ddPdQdRej;dSej<dTej=dUddVddWdZ>dXe>_?dXe>_@e>jAe>jBe>jCdYejDjCdZe>jEdejDjCd[e>jF[>dS)\N) SerialBaseSerialExceptionto_bytesportNotOpenErrorwriteTimeoutErrorc@s:eZdZiZddZddZddZdS)PlatformSpecificBasecCs6tjjdtjtjtjftddS)Nadon't know how to number ttys on this system. ! Use an explicit path (eg /dev/ttyS1) or send this information to ! the author of this module: sys.platform = %r os.name = %r serialposix.py version = %s also add the device name of the serial port and where the counting starts for the first serial port. e.g. 'first serial port: /dev/ttyS0' and with a bit luck you can get this module running... z4no number-to-device mapping defined on this platform) sysstderrwriteplatformosnameserialVERSIONNotImplementedError)self port_numberr4/usr/lib/python3/dist-packages/serial/serialposix.pynumber_to_devices z%PlatformSpecificBase.number_to_devicecCstddS)Nz9non-standard baudrates are not supported on this platform)r)rbaudraterrr_set_special_baudrate0sz*PlatformSpecificBase._set_special_baudratecCstddS)Nz$RS485 not supported on this platform)r)rrs485_settingsrrr_set_rs485_mode3sz$PlatformSpecificBase._set_rs485_modeN)__name__ __module__ __qualname__BAUDRATE_CONSTANTSrrrrrrrrs   rlinuxl*TXi+T,@ii.Ti/Tc>@seZdZdddddddddd d d d d ddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=iZd>d?Zd@dAZdBdCZdDS)EPlatformSpecificr2r Kr!nr"ri,iXi i i` i i% iKiiiiiiiiii iiiiii@Biii i`i ii i%&i i-i ig5ii =icCs d|fS)Nz /dev/ttyS%dr)rrrrrrnsz!PlatformSpecific.number_to_devicecCstjddgd}ybtj|jt||dtjM<|dtO<||d<|dO}n|tj>M}|dks|dkrtd||| tj?<|dks|dkr#td||| tj@<|sW|||| | | | g|krtjA|jtjB|||| | | | g|dk r|jC||jDdk r|jE|jDdS)z,Set communication parameters on opened port.Nz+Can only operate on a valid file descriptorrr r0zCould not configure port: %sECHOCTLECHOKEIUCLCPARMRKzB%sZB38400zInvalid baud rate: %rr.r-r,rzInvalid char len: %rz"Invalid stop bit specification: %rrzInvalid parity: %rIXANYCRTSCTS CNEW_RTSCTSzInvalid vmin: %r zInvalid vtime: %r)ryrz)Fr;r_inter_byte_timeoutrHr= tcgetattrerrorZCLOCALZCREADZICANONZECHOZECHOEZECHOKZECHONLZISIGZIEXTENhasattrgetattrZOPOSTZONLCRZOCRNLZINLCRZIGNCRZICRNLZIGNBRKr{r|Z _baudrateAttributeErrorrKeyErrorrAZCSIZEZ _bytesizeZCS8ZCS7ZCS6ZCS5Z _stopbitsr STOPBITS_ONEZCSTOPBZSTOPBITS_ONE_POINT_FIVEZ STOPBITS_TWOZINPCKZISTRIPZ_parityZ PARITY_NONEZPARENBZPARODD PARITY_EVENZ PARITY_ODDZ PARITY_MARKplatCMSPARZ PARITY_SPACEZ_xonxoffZIXONZIXOFFr}rur~rVMINVTIME tcsetattrTCSANOWrZ _rs485_moder)rrjZ custom_baudvminvtime orig_attriflagoflagcflaglflagispeedospeedccrxZflagrrrrr<s  #5 #    ((      '  zSerial._reconfigure_portcCs>|jr:|jdk r1tj|jd|_d|_dS)z Close portNF)rkr;r rs)rrrrrss   z Serial.closecCs,tj|jtt}tjd|dS)z9Return the number of bytes currently in the input buffer.rfr)r9r:r;rdTIOCM_zero_strstructunpack)rsrrr in_waitingszSerial.in_waitingr c Cs|jstt}|j}xYt||kr|ytj}tj|jggg|\}}}|ssPtj |j|t|}|st d|j ||dk r|tj|8}|dkrPWq$t k r+}z*|j t jkrt d|fWYdd}~Xq$tjk rx}z+|dt jkrft d|fWYdd}~Xq$Xq$Wt|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. zgdevice reports readiness to read but returned no data (device disconnected or multiple access on port?)Nrzread failed: %s)rkr bytearray_timeoutlentimeselectr;r readrextendrprqEAGAINrbytes) rsizertimeoutZ start_timeready_rBrCrrrrs2    '    %*z Serial.readc Cs|jstt|}t|}|jdk r[|jdkr[tj|j}nd}x]|dkrytj|j|}|r|tj}|dkrt t j g|jgg|\}}}|st n9t j g|jggd\}}}|st d||d}||8}Wqdt k rQYqdt k r} zL| j t jkrt d| f|r|tjdkrt WYdd} ~ XqdXqdWt|S)z2Output the given byte string over the serial port.Nrzwrite failed (select)zwrite failed: %s)rkrrrZ_write_timeoutrr r r;rrrrprqr) rdatadZtx_lenrnZtimeleftrrvrrrr s<    ' '  z Serial.writecCs#|jsttj|jdS)zb Flush of file like objects. In this case, wait until all data is written. N)rkrr=Ztcdrainr;)rrrrflush)s z Serial.flushcCs)|jsttj|jtjdS)z9Clear input buffer, discarding all that is in the buffer.N)rkrr=tcflushr;ZTCIFLUSH)rrrrrw2s zSerial.reset_input_buffercCs)|jsttj|jtjdS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. N)rkrr=rr;ZTCOFLUSH)rrrrreset_output_buffer8s zSerial.reset_output_bufferg?cCs0|jsttj|jt|ddS)za Send break condition. Timed, returns to idle state after given duration. g?N)rkrr=Z tcsendbreakr;rH)rZdurationrrr send_breakAs zSerial.send_breakcCs6|jrtj|jtntj|jtdS)zS Set break: Controls TXD. When active, no transmitting is possible. N)Z _break_stater9r:r;rgrh)rrrr_update_break_stateJs zSerial._update_break_statecCs<|jr"tj|jttntj|jttdS)z)Set terminal status line: Request To SendN)Z _rts_stater9r:r;rV TIOCM_RTS_strrW)rrrrrvSs zSerial._update_rts_statecCs<|jr"tj|jttntj|jttdS)z-Set terminal status line: Data Terminal ReadyN)Z _dtr_stater9r:r;rV TIOCM_DTR_strrW)rrrrrtZs zSerial._update_dtr_statecCsE|jsttj|jtt}tjd|dt @dkS)z(Read terminal status line: Clear To Sendrfr) rkrr9r:r;rUrrrr[)rrrrrctsas z Serial.ctscCsE|jsttj|jtt}tjd|dt @dkS)z)Read terminal status line: Data Set Readyrfr) rkrr9r:r;rUrrrr`)rrrrrdsris z Serial.dsrcCsE|jsttj|jtt}tjd|dt @dkS)z)Read terminal status line: Ring Indicatorrfr) rkrr9r:r;rUrrrrc)rrrrrriqs z Serial.ricCsE|jsttj|jtt}tjd|dt @dkS)z)Read terminal status line: Carrier Detectrfr) rkrr9r:r;rUrrrrb)rrrrrcdys z Serial.cdcCs,tj|jtt}tjd|dS)z:Return the number of bytes currently in the output buffer.rfr)r9r:r;rerrr)rrrrr out_waitingszSerial.out_waitingcCs/|jsttj|jtjtjdS)zinternal - not portable!N)rkrr9r;F_SETFLr ro)rrrr nonblockings zSerial.nonblockingcCs|jst|jS)z For easier use of the serial port instance with select. WARNING: this function is not portable to different platforms! )rkrr;)rrrrfilenos z Serial.filenoTcCsH|jst|r.tj|jtjntj|jtjdS)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)rkrr=tcflowr;ZTCIONZTCIOFF)renablerrrset_input_flow_controls  zSerial.set_input_flow_controlcCsH|jst|r.tj|jtjntj|jtjdS)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)rkrr=rr;ZTCOONZTCOOFF)rrrrrset_output_flow_controls  zSerial.set_output_flow_controlN)rrr__doc__rlrrrspropertyrrr rrwrrrrvrtrrrrrrrrrrrrrris.  $ . '        ric@s%eZdZdZdddZdS)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 cCsB|jdkrtt}tj}|j|jtjtjBtjBtj B|dkr8xt ||kr7xK|j|j dD]3\}}|tjtjBtj B@rt dqWt j|j|t |}|j||j dk r|j dks,|jdk rd|jdkrd| rdPqdWt|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. Nrizdevice reports error (poll))r;rrrpollregisterZPOLLINZPOLLERRZPOLLHUPZPOLLNVALrrrr rrrr)rrrrr;ZeventrBrrrrs   + # %zPosixPollSerial.readN)rrrrrrrrrrs rcs:eZdZdZdfddZdddZS) 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 sStt|jtj|jtjd|jdk rWd}t|jd}nd}t|jd}y1t j |j}|\}}}}} } } Wn;t j k r} zt j d| WYdd} ~ XnX|dks|dkrtd||| t j<|| t jrDrIZSER_RS485_ENABLEDrFrGrEr$rMrrUrVrWrXrYrZr[r]r^r`rbrcrrdreZpackrrrrgrhrrirrrZ EIGHTBITSrrrZrtsZdtrrwrr stdoutrZ inWaitingrrrrs         ( P ,    #6