3
M]W+
@ s d dl Z d dlZd dlZd dlZd dlZy d dlZW n ek
rR d dljZY nX d dl m
Z
m Z m Z m
Z
ejejejejdZdZG dd de
Zedkrd dlZedZejjd je ejjd
ejd ej ejjd jej d ej dS )
N)
SerialBaseSerialExceptionportNotOpenErrorto_bytes)debuginfoZwarningerror c @ s e Zd ZdZd:Zdd Zdd Zdd Zdd Ze dd Z
d;d d Z d d! Z d"d# Z
d$d% Zd:[?logging={debug|info|warning|error}]": not starting with socket:// ({!r})TloggingzpySerial.socketr zenabled loggingzunknown option: {!r}i zport not in range 0...65535z_expected a string in the form "socket://:[?logging={debug|info|warning|error}]": {}N)urlparseZurlsplitschemer r$ Zparse_qsZqueryitemsr1 Z basicConfigZ getLoggerr ZsetLevel
LOGGER_LEVELSr
ValueErrorZportZhostname)r* ZurlpartsZoptionvalueser, r, r- r e s(
zSerial.from_urlc C s, | j s
ttj| jgg g d\}}}t|S )z9Return the number of bytes currently in the input buffer.r )r r selectr" len)r* ZlrZlwZlxr, r, r-
in_waiting s zSerial.in_waiting c C st | j s
tt }| j}xRt||k rjyxtj }tj| jgg g |\}}}|sRP | jj|t| }|srt d|j
| |dk r|tj | 8 }|dkrP W q t j k
r Y q t j
k
r } zt dj|W Y dd}~X q tk
r$ } z"|jtjkrt dj|W Y dd}~X q tj
k
rf } z$|d tjkrVt dj|W Y dd}~X qX qW 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.
zsocket disconnectedNr zconnection failed ({})zread failed: {})r r bytearrayZ_timeoutr; r0 r: r" Zrecvr extendr r r r$ OSErrorerrnoZEAGAINbytes) r* sizereadr Z
start_timeZready_Zbufr9 r, r, r- rD s:
$z Serial.readc C sZ | j s
ty| jjt| W n2 tjk
rP } ztdj|W Y dd}~X nX t |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.
z socket connection failed: {}N)
r r r" Zsendallr r r r r$ r; )r* datar9 r, r, r- write s z Serial.writec C s | j s
t| jr | jjd dS )z9Clear input buffer, discarding all that is in the buffer.zignored reset_input_bufferN)r r r r )r* r, r, r- r( s zSerial.reset_input_bufferc C s | j s
t| jr | jjd dS )zs Clear output buffer, aborting the current output and
discarding all that is in the buffer.
zignored reset_output_bufferN)r r r r )r* r, r, r- r) s zSerial.reset_output_buffer ?c C s& | j s
t| jr"| jjdj| dS )za Send break condition. Timed, returns to idle state after given
duration.
zignored send_break({!r})N)r r r r r$ )r* Zdurationr, r, r-
send_break s zSerial.send_breakc C s | j r| j jdj| j dS )zJSet break: Controls TXD. When active, to transmitting is
possible.z!ignored _update_break_state({!r})N)r r r$ Z _break_state)r* r, r, r- _update_break_state s zSerial._update_break_statec C s | j r| j jdj| j dS )z)Set terminal status line: Request To Sendz ignored _update_rts_state({!r})N)r r r$ Z
_rts_state)r* r, r, r- r' s zSerial._update_rts_statec C s | j r| j jdj| j dS )z-Set terminal status line: Data Terminal Readyz ignored _update_dtr_state({!r})N)r r r$ Z
_dtr_state)r* r, r, r- r& s zSerial._update_dtr_statec C s | j s
t| jr | jjd dS )z(Read terminal status line: Clear To Sendzreturning dummy for ctsT)r r r r )r* r, r, r- cts s
z
Serial.ctsc C s | j s
t| jr | jjd dS )z)Read terminal status line: Data Set Readyzreturning dummy for dsrT)r r r r )r* r, r, r- dsr s
z
Serial.dsrc C s | j s
t| jr | jjd dS )z)Read terminal status line: Ring Indicatorzreturning dummy for riF)r r r r )r* r, r, r- ri s
z Serial.ric C s | j s
t| jr | jjd dS )z)Read terminal status line: Carrier Detectzreturning dummy for cd)T)r r r r )r* r, r, r- cd s
z Serial.cdc C s
| j j S )z@Get the file handle of the underlying socket for use with select)r" fileno)r* r, r, r- rO ! s z
Serial.filenoN)r r r
r r r r r r r r r r r r r r )r= )rH )__name__
__module__ __qualname____doc__Z BAUDRATESr. r% r/ r propertyr< rD rG r( r) rI rJ r' r& rK rL rM rN rO r, r, r, r- r
* s*
1
r
__main__zsocket://localhost:7000z{}
z write...
s hello
z read: {}
) rA r1 r: r r0 r2 ImportErrorZ urllib.parseparseZserial.serialutilr r r r DEBUGINFOZWARNINGZERRORr5 r! r
rP syssstdoutrG r$ flushrD r/ r, r, r, r- s4