qVj&@sVddlZddlZddlZddlZyddlZWn!ek rcddljZYnXddlm Z m Z m Z m Z dej dejdejdejiZdZGdd d e Zed krRddlZed Zejjd eejjd ejdejejjdejdejdS)N) SerialBaseSerialExceptionportNotOpenErrorto_bytesdebuginfoZwarningerrorc@seZdZdZd:ZddZddZddZddZe ddZ dddZ d d!Z d"d#Z d$d%Zd&d'd(Zd)d*Zd+d,Zd-d.Ze d/d0Ze d1d2Ze d3d4Ze d5d6Zd7d8Zd9S);Serialz-Serial port implementation for plain sockets.2Kn,X` %KcCsd|_|jdkr$td|jr9tdy"tj|j|j|_WnGt k r}z'd|_td|j|fWYdd}~XnX|jj t |j d|_|j s|j|js|j|j|jdS)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.zCould not open port %s: %sT)loggerZ_portris_opensocketZcreate_connectionfrom_urlZportstr_socket ExceptionZ settimeout POLL_TIMEOUT_reconfigure_portZ_dsrdtr_update_dtr_stateZ_rtscts_update_rts_statereset_input_bufferreset_output_buffer)selfmsgr*C/usr/lib/python3/dist-packages/serial/urlhandler/protocol_socket.pyopen/s&    " ,       z Serial.opencCs8|jdkrtd|jr4|jjddS)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)r rrr)r(r*r*r+r#Ls  zSerial._reconfigure_portc Csd|jr`|jrJy$|jjtj|jjWnYnXd|_d|_tjddS)z Close portNFg333333?)rr ZshutdownrZ SHUT_RDWRclosetimeZsleep)r(r*r*r+r-Vs    z Serial.closecCsGtj|}|jdkr4td|jfyxtj|jdjD]r\}}|dkrtjtj d|_ |j j t |d|j j dqStd|fqSW|j|j}}d|kod knstd Wn5tk r<}ztd |WYd d }~XnX||fS) z(extract host and port from an URL stringrz}expected a string in the form "socket://:[?logging={debug|info|warning|error}]": not starting with socket:// (%r)TloggingzpySerial.socketrzenabled loggingzunknown option: %rizport not in range 0...65535z_expected a string in the form "socket://:[?logging={debug|info|warning|error}]": %sN)urlparseZurlsplitschemerZparse_qsZqueryitemsr/Z basicConfigZ getLoggerrZsetLevel LOGGER_LEVELSr ValueErrorZhostnameport)r(ZurlpartsZoptionvalueshostr5er*r*r+res"(  #zSerial.from_urlcCs@|jsttj|jgggd\}}}t|S)z9Return the number of bytes currently in the input buffer.r)rrselectr len)r(ZlrZlwZlxr*r*r+ in_waiting~s 'zSerial.in_waitingcCs |jstt}|jdk r=tj|j}nd}xt||kry7|jj|t|}|r|j|nPWnLt j k rYn8t j k r}zt d|WYdd}~XnX|dk rFtj|krFPqFWt |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. Nzconnection failed (%s))rr bytearrayZ_timeoutr.r;r Zrecvextendrtimeoutrrbytes)r(sizedatar@blockr9r*r*r+reads&  #z Serial.readcCsn|jsty|jjt|Wn8tjk rc}ztd|WYdd}~XnXt|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. zsocket connection failed: %sN) rrr Zsendallrrrrr;)r(rCr9r*r*r+writes #z Serial.writecCs,|jst|jr(|jjddS)z9Clear input buffer, discarding all that is in the buffer.zignored reset_input_bufferN)rrrr)r(r*r*r+r&s  zSerial.reset_input_buffercCs,|jst|jr(|jjddS)zs Clear output buffer, aborting the current output and discarding all that is in the buffer. zignored reset_output_bufferN)rrrr)r(r*r*r+r's  zSerial.reset_output_bufferg?cCs3|jst|jr/|jjd|fdS)za Send break condition. Timed, returns to idle state after given duration. zignored send_break(%r)N)rrrr)r(Zdurationr*r*r+ send_breaks  zSerial.send_breakcCs'|jr#|jjd|jfdS)zJSet break: Controls TXD. When active, to transmitting is possible.zignored _update_break_state(%r)N)rrZ _break_state)r(r*r*r+_update_break_states zSerial._update_break_statecCs'|jr#|jjd|jfdS)z)Set terminal status line: Request To Sendzignored _update_rts_state(%r)N)rrZ _rts_state)r(r*r*r+r%s zSerial._update_rts_statecCs'|jr#|jjd|jfdS)z-Set terminal status line: Data Terminal Readyzignored _update_dtr_state(%r)N)rrZ _dtr_state)r(r*r*r+r$s zSerial._update_dtr_statecCs,|jst|jr(|jjddS)z(Read terminal status line: Clear To Sendzreturning dummy for ctsT)rrrr)r(r*r*r+ctss   z Serial.ctscCs,|jst|jr(|jjddS)z)Read terminal status line: Data Set Readyzreturning dummy for dsrT)rrrr)r(r*r*r+dsrs   z Serial.dsrcCs,|jst|jr(|jjddS)z)Read terminal status line: Ring Indicatorzreturning dummy for riF)rrrr)r(r*r*r+ris   z Serial.ricCs,|jst|jr(|jjddS)z)Read terminal status line: Carrier Detectzreturning dummy for cd)T)rrrr)r(r*r*r+cds   z Serial.cdcCs |jjS)z@Get the file handle of the underlying socket for use with select)r fileno)r(r*r*r+rM sz Serial.filenoN)r r r rrrrrrrrrrrrrr)__name__ __module__ __qualname____doc__Z BAUDRATESr,r#r-rpropertyr<rErFr&r'rGrHr%r$rIrJrKrLrMr*r*r*r+r )s*     "          r __main__zsocket://localhost:7000z%s z write... shello z read: %s )r/r:rr.r0 ImportErrorZ urllib.parseparseZserial.serialutilrrrrDEBUGINFOZWARNINGZERRORr3r"r rNsyssstdoutrFflushrEr-r*r*r*r+s.     "