*qVG@sddlZddlZddlmZddlZddlmZmZmZmZm Z GdddeZ e dkr ddl Z e dZ e jjde e Z e jjde de _d e _e jde _e je jjde dS) N)win32) SerialBaseSerialExceptionto_bytesportNotOpenErrorwriteTimeoutErrorcsZeZdZdZdCZfddZddZddZddZddZ e ddZ dd d!Z d"d#Z d$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Ze d2d3Ze d4d5Ze d6d7Ze d8d9Zd:d;d<d=Zd>d?d@Ze dAdBZS)DSerialz5Serial port implementation for Win32 based on ctypes.2Kn,X` %KcsEtt|jd|_d|_d|_tj|||dS)N)superr__init__ _port_handle_overlapped_read_overlapped_write)selfargskwargs) __class__4/usr/lib/python3/dist-packages/serial/serialwin32.pyrs    zSerial.__init__cCs|jdkrtd|jr0td|j}y?|jjdrwt|dddkrwd|}Wntk rYnXtj |tj tj Bddtj tj tjBd|_|jtjkrd|_td |jtjfytj|_tjdd dd|j_tj|_tjdddd|j_tj|jd d tj|_tj|jtj|j|jtj|jtj tj!Btj"Btj#BWn-y|j$WnYnXd|_Yn Xd |_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.ZCOMz\\.\rzcould not open port %r: %riT)%Z_portris_opennameupper startswithint ValueErrorrZ CreateFileZ GENERIC_READZ GENERIC_WRITEZ OPEN_EXISTINGFILE_ATTRIBUTE_NORMALZFILE_FLAG_OVERLAPPEDrZINVALID_HANDLE_VALUEZportstrctypesWinErrorZ OVERLAPPEDrZ CreateEventhEventr SetupComm COMMTIMEOUTS _orgTimeoutsZGetCommTimeoutsbyref_reconfigure_port PurgeComm PURGE_TXCLEAR PURGE_TXABORT PURGE_RXCLEAR PURGE_RXABORT_close)rportr#r#r$open!sR    1      # z Serial.opencCsD|jstdtj}|jdkr3n=|jdkrQtj|_ntt|jdd|_ |jdkr|j dk rtt|j dd|_|j dkrn=|j dkrtj|_ ntt|j dd|_ tj |jtj|tj|jtjtj}tj|jtj||j|_|jtjkrd|_nm|jtjkrd|_nO|jtjkrd|_n1|jtjkrd |_ntd |j|jtjkrtj |_!d|_"n|jtj#krAtj$|_!d|_"n|jtj%krktj&|_!d|_"ng|jtj'krtj(|_!d|_"n=|jtj)krtj*|_!d|_"ntd |j|j+tj,krtj-|_.nU|j+tj/krtj0|_.n4|j+tj1kr5tj2|_.ntd |j+d|_3|j4dkr|j5rxtj6|_7n|j8rtj9ntj:|_7|j5|_;n|j4j<std |j4j<f|j4j=rtd|j4j=f|j4j>dk rtd|j4j>f|j4j?dk rEtd|j4j?f|j4j@rjtd|j4j@ftjA|_7d|_;|jBrtjC|_Dn|jErtjFntjG|_D|jB|_H|jI|_J|jI|_Kd|_Ld|_Md|_NtjO|_PtjQ|_RtjS|jtj|s@tdtjTdS)z,Set communication parameters on opened port.z'Can only operate on a valid port handleNrir'r&z#Unsupported number of data bits: %rzUnsupported parity mode: %rz#Unsupported number of stop bits: %rz8Unsupported value for RS485Settings.rts_level_for_tx: %rz8Unsupported value for RS485Settings.rts_level_for_rx: %rz7Unsupported value for RS485Settings.delay_before_tx: %rz7Unsupported value for RS485Settings.delay_before_rx: %rz0Unsupported value for RS485Settings.loopback: %rzACannot configure port, something went wrong. Original message: %r)Urrrr3Z_timeoutZMAXDWORDZReadIntervalTimeoutmaxr,ZReadTotalTimeoutConstantZ_inter_byte_timeout_write_timeoutZWriteTotalTimeoutConstantSetCommTimeoutsr/r5Z SetCommMaskZEV_ERRZDCBZ GetCommStateZ _baudrateZBaudRateZ _bytesizeserialZFIVEBITSZByteSizeZSIXBITSZ SEVENBITSZ EIGHTBITSr-Z_parityZ PARITY_NONEZNOPARITYZParityZfParityZ PARITY_EVENZ EVENPARITYZ PARITY_ODDZ ODDPARITYZ PARITY_MARKZ MARKPARITYZ PARITY_SPACEZ SPACEPARITYZ _stopbitsZ STOPBITS_ONEZ ONESTOPBITZStopBitsZSTOPBITS_ONE_POINT_FIVEZ ONE5STOPBITSZ STOPBITS_TWOZ TWOSTOPBITSZfBinaryZ _rs485_modeZ_rtsctsZRTS_CONTROL_HANDSHAKEZ fRtsControl _rts_stateZRTS_CONTROL_ENABLEZRTS_CONTROL_DISABLEZ fOutxCtsFlowZrts_level_for_txZrts_level_for_rxZdelay_before_txZdelay_before_rxZloopbackZRTS_CONTROL_TOGGLEZ_dsrdtrZDTR_CONTROL_HANDSHAKEZ fDtrControl _dtr_stateZDTR_CONTROL_ENABLEZDTR_CONTROL_DISABLEZ fOutxDsrFlowZ_xonxoffZfOutXZfInXZfNullZ fErrorCharZ fAbortOnErrorZXONZXonCharZXOFFZXoffCharZ SetCommStater0)rZtimeoutsZcomDCBr#r#r$r6bs                                   zSerial._reconfigure_portcCs|jrtj|j|jtj|j|jdk rZtj|jjd|_|jdk rtj|jjd|_d|_dS)zinternal close port helperN)rrrDr4Z CloseHandlerr1r)rr#r#r$r<s   z Serial._closecCs |jr|jd|_dS)z Close portFN)r(r<)rr#r#r$closes  z Serial.closecCsUtj}tj}tj|jtj|tj|sNtd|jS)z9Return the number of bytes currently in the input buffer.zcall to ClearCommError failed) rDWORDCOMSTATClearCommErrorrr/r5rcbInQue)rflagscomstatr#r#r$ in_waitings   * zSerial.in_waitingr'c Csh|jst|dkrUtj|jjtj}tj}tj|jt j |t j |s|t d|j dkrt |j|}|dkryt j|}tj}tj|j||t j |t j |j}| r2tjtjtjfkr2t dt jtj|jt j |jt j |d|jd|j}qRt}q^t j|}tj}tj|j||t j |t j |j}| rtjtjtjfkrt dt jtj|jt j |jt j |d|jd|j}n t}t|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.rzcall to ClearCommError failedzReadFile failed (%r)TN)rrrZ ResetEventrr1rIrJrKr/r5rZtimeoutminrLZcreate_string_bufferZReadFile GetLastErrorZ ERROR_SUCCESSERROR_IO_PENDINGr0GetOverlappedResultrawvaluebytes) rsizerMrNnZbufrcZread_okreadr#r#r$rZs8    *   3%.  3%. z Serial.readcCs|jstt|}|rtj}tj|j|t|tj||j }| rtj tj krt dtj |jdkrtj|j|j tj|d}|jt|krt|jSdSdS)z2Output the given byte string over the serial port.zWriteFile failed (%r)rTN)rrrrrIZ WriteFilelenr/r5rrQrRrr0rCrSrUr)rdatarXerrr#r#r$write&s   0'z Serial.writecCs!x|jrtjdqWdS)zb Flush of file like objects. In this case, wait until all data is written. g?N) out_waitingtimeZsleep)rr#r#r$flush>s z Serial.flushcCs0|jsttj|jtjtjBdS)z9Clear input buffer, discarding all that is in the buffer.N)rrrr7r:r;)rr#r#r$reset_input_bufferIs zSerial.reset_input_buffercCs0|jsttj|jtjtjBdS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. N)rrrr7r8r9)rr#r#r$reset_output_bufferOs zSerial.reset_output_buffercCs?|jst|jr+tj|jntj|jdS)zBSet break: Controls TXD. When active, to transmitting is possible.N)rrZ _break_staterZ SetCommBreakZClearCommBreak)rr#r#r$_update_break_stateXs   zSerial._update_break_statecCs<|jr"tj|jtjntj|jtjdS)z)Set terminal status line: Request To SendN)rFrEscapeCommFunctionrZSETRTSZCLRRTS)rr#r#r$_update_rts_stateas zSerial._update_rts_statecCs<|jr"tj|jtjntj|jtjdS)z-Set terminal status line: Data Terminal ReadyN)rGrrerZSETDTRZCLRDTR)rr#r#r$_update_dtr_statehs zSerial._update_dtr_statecCs>|jsttj}tj|jtj||jS)N)rrrrIZGetCommModemStatusr/r5rU)rstatr#r#r$_GetCommModemStatusos   zSerial._GetCommModemStatuscCstj|j@dkS)z(Read terminal status line: Clear To Sendr)rZ MS_CTS_ONri)rr#r#r$ctsvsz Serial.ctscCstj|j@dkS)z)Read terminal status line: Data Set Readyr)rZ MS_DSR_ONri)rr#r#r$dsr{sz Serial.dsrcCstj|j@dkS)z)Read terminal status line: Ring Indicatorr)rZ MS_RING_ONri)rr#r#r$risz Serial.ricCstj|j@dkS)z)Read terminal status line: Carrier Detectr)rZ MS_RLSD_ONri)rr#r#r$cdsz Serial.cdiNcCs,|dkr|}tj|j||dS)z Recommend a buffer size to the driver (device driver can ignore this value). Must be called before the port is opended. N)rr2r)rZrx_sizeZtx_sizer#r#r$set_buffer_sizes zSerial.set_buffer_sizeTcCsH|jst|r.tj|jtjntj|jtjdS)a* Manually control flow - when software flow control is enabled. This will do the same as if XON (true) or XOFF (false) are received from the other device and control the transmission accordingly. WARNING: this function is not portable to different platforms! N)rrrreZSETXONZSETXOFF)renabler#r#r$set_output_flow_controls  zSerial.set_output_flow_controlcCsUtj}tj}tj|jtj|tj|sNtd|jS)z0Return how many bytes the in the outgoing bufferzcall to ClearCommError failed) rrIrJrKrr/r5rZcbOutQue)rrMrNr#r#r$r_s   * zSerial.out_waiting)r r r r r rrrrrrrrrrrr)__name__ __module__ __qualname____doc__Z BAUDRATESrr>r6r<rHpropertyrOrZr^rarbrcrdrfrgrirjrkrlrmrnrpr_r#r#)r"r$rs2  A    %      r__main__z%s iKrA)r/r`rErZserial.serialutilrrrrrrrqsyssstdoutr^ZbaudrateZdatabitsrHr=r>r#r#r#r$ s$   (