| Index: tools/telemetry/third_party/pyserial/serial/urlhandler/protocol_socket.py
|
| diff --git a/tools/telemetry/third_party/pyserial/serial/urlhandler/protocol_socket.py b/tools/telemetry/third_party/pyserial/serial/urlhandler/protocol_socket.py
|
| deleted file mode 100644
|
| index c90a8e4aa5260cad4c8c2cb5a15b4f4eaf8b5e55..0000000000000000000000000000000000000000
|
| --- a/tools/telemetry/third_party/pyserial/serial/urlhandler/protocol_socket.py
|
| +++ /dev/null
|
| @@ -1,274 +0,0 @@
|
| -#! python
|
| -#
|
| -# Python Serial Port Extension for Win32, Linux, BSD, Jython
|
| -# see __init__.py
|
| -#
|
| -# This module implements a simple socket based client.
|
| -# It does not support changing any port parameters and will silently ignore any
|
| -# requests to do so.
|
| -#
|
| -# The purpose of this module is that applications using pySerial can connect to
|
| -# TCP/IP to serial port converters that do not support RFC 2217.
|
| -#
|
| -# (C) 2001-2011 Chris Liechti <cliechti@gmx.net>
|
| -# this is distributed under a free software license, see license.txt
|
| -#
|
| -# URL format: socket://<host>:<port>[/option[/option...]]
|
| -# options:
|
| -# - "debug" print diagnostic messages
|
| -
|
| -from serial.serialutil import *
|
| -import time
|
| -import socket
|
| -import logging
|
| -
|
| -# map log level names to constants. used in fromURL()
|
| -LOGGER_LEVELS = {
|
| - 'debug': logging.DEBUG,
|
| - 'info': logging.INFO,
|
| - 'warning': logging.WARNING,
|
| - 'error': logging.ERROR,
|
| - }
|
| -
|
| -POLL_TIMEOUT = 2
|
| -
|
| -class SocketSerial(SerialBase):
|
| - """Serial port implementation for plain sockets."""
|
| -
|
| - BAUDRATES = (50, 75, 110, 134, 150, 200, 300, 600, 1200, 1800, 2400, 4800,
|
| - 9600, 19200, 38400, 57600, 115200)
|
| -
|
| - def open(self):
|
| - """Open port with current settings. This may throw a SerialException
|
| - if the port cannot be opened."""
|
| - self.logger = None
|
| - if self._port is None:
|
| - raise SerialException("Port must be configured before it can be used.")
|
| - if self._isOpen:
|
| - raise SerialException("Port is already open.")
|
| - try:
|
| - # XXX in future replace with create_connection (py >=2.6)
|
| - self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
| - self._socket.connect(self.fromURL(self.portstr))
|
| - except Exception, msg:
|
| - self._socket = None
|
| - raise SerialException("Could not open port %s: %s" % (self.portstr, msg))
|
| -
|
| - self._socket.settimeout(POLL_TIMEOUT) # used for write timeout support :/
|
| -
|
| - # not that there anything to configure...
|
| - self._reconfigurePort()
|
| - # all things set up get, now a clean start
|
| - self._isOpen = True
|
| - if not self._rtscts:
|
| - self.setRTS(True)
|
| - self.setDTR(True)
|
| - self.flushInput()
|
| - self.flushOutput()
|
| -
|
| - def _reconfigurePort(self):
|
| - """Set communication parameters on opened port. for the socket://
|
| - protocol all settings are ignored!"""
|
| - if self._socket is None:
|
| - raise SerialException("Can only operate on open ports")
|
| - if self.logger:
|
| - self.logger.info('ignored port configuration change')
|
| -
|
| - def close(self):
|
| - """Close port"""
|
| - if self._isOpen:
|
| - if self._socket:
|
| - try:
|
| - self._socket.shutdown(socket.SHUT_RDWR)
|
| - self._socket.close()
|
| - except:
|
| - # ignore errors.
|
| - pass
|
| - self._socket = None
|
| - self._isOpen = False
|
| - # in case of quick reconnects, give the server some time
|
| - time.sleep(0.3)
|
| -
|
| - def makeDeviceName(self, port):
|
| - raise SerialException("there is no sensible way to turn numbers into URLs")
|
| -
|
| - def fromURL(self, url):
|
| - """extract host and port from an URL string"""
|
| - if url.lower().startswith("socket://"): url = url[9:]
|
| - try:
|
| - # is there a "path" (our options)?
|
| - if '/' in url:
|
| - # cut away options
|
| - url, options = url.split('/', 1)
|
| - # process options now, directly altering self
|
| - for option in options.split('/'):
|
| - if '=' in option:
|
| - option, value = option.split('=', 1)
|
| - else:
|
| - value = None
|
| - if option == 'logging':
|
| - logging.basicConfig() # XXX is that good to call it here?
|
| - self.logger = logging.getLogger('pySerial.socket')
|
| - self.logger.setLevel(LOGGER_LEVELS[value])
|
| - self.logger.debug('enabled logging')
|
| - else:
|
| - raise ValueError('unknown option: %r' % (option,))
|
| - # get host and port
|
| - host, port = url.split(':', 1) # may raise ValueError because of unpacking
|
| - port = int(port) # and this if it's not a number
|
| - if not 0 <= port < 65536: raise ValueError("port not in range 0...65535")
|
| - except ValueError, e:
|
| - raise SerialException('expected a string in the form "[rfc2217://]<host>:<port>[/option[/option...]]": %s' % e)
|
| - return (host, port)
|
| -
|
| - # - - - - - - - - - - - - - - - - - - - - - - - -
|
| -
|
| - def inWaiting(self):
|
| - """Return the number of characters currently in the input buffer."""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - # set this one to debug as the function could be called often...
|
| - self.logger.debug('WARNING: inWaiting returns dummy value')
|
| - return 0 # hmmm, see comment in read()
|
| -
|
| - def read(self, size=1):
|
| - """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."""
|
| - if not self._isOpen: raise portNotOpenError
|
| - data = bytearray()
|
| - if self._timeout is not None:
|
| - timeout = time.time() + self._timeout
|
| - else:
|
| - timeout = None
|
| - while len(data) < size and (timeout is None or time.time() < timeout):
|
| - try:
|
| - # an implementation with internal buffer would be better
|
| - # performing...
|
| - t = time.time()
|
| - block = self._socket.recv(size - len(data))
|
| - duration = time.time() - t
|
| - if block:
|
| - data.extend(block)
|
| - else:
|
| - # no data -> EOF (connection probably closed)
|
| - break
|
| - except socket.timeout:
|
| - # just need to get out of recv from time to time to check if
|
| - # still alive
|
| - continue
|
| - except socket.error, e:
|
| - # connection fails -> terminate loop
|
| - raise SerialException('connection failed (%s)' % e)
|
| - return bytes(data)
|
| -
|
| - def write(self, data):
|
| - """Output the given string over the serial port. Can block if the
|
| - connection is blocked. May raise SerialException if the connection is
|
| - closed."""
|
| - if not self._isOpen: raise portNotOpenError
|
| - try:
|
| - self._socket.sendall(to_bytes(data))
|
| - except socket.error, e:
|
| - # XXX what exception if socket connection fails
|
| - raise SerialException("socket connection failed: %s" % e)
|
| - return len(data)
|
| -
|
| - def flushInput(self):
|
| - """Clear input buffer, discarding all that is in the buffer."""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('ignored flushInput')
|
| -
|
| - def flushOutput(self):
|
| - """Clear output buffer, aborting the current output and
|
| - discarding all that is in the buffer."""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('ignored flushOutput')
|
| -
|
| - def sendBreak(self, duration=0.25):
|
| - """Send break condition. Timed, returns to idle state after given
|
| - duration."""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('ignored sendBreak(%r)' % (duration,))
|
| -
|
| - def setBreak(self, level=True):
|
| - """Set break: Controls TXD. When active, to transmitting is
|
| - possible."""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('ignored setBreak(%r)' % (level,))
|
| -
|
| - def setRTS(self, level=True):
|
| - """Set terminal status line: Request To Send"""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('ignored setRTS(%r)' % (level,))
|
| -
|
| - def setDTR(self, level=True):
|
| - """Set terminal status line: Data Terminal Ready"""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('ignored setDTR(%r)' % (level,))
|
| -
|
| - def getCTS(self):
|
| - """Read terminal status line: Clear To Send"""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('returning dummy for getCTS()')
|
| - return True
|
| -
|
| - def getDSR(self):
|
| - """Read terminal status line: Data Set Ready"""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('returning dummy for getDSR()')
|
| - return True
|
| -
|
| - def getRI(self):
|
| - """Read terminal status line: Ring Indicator"""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('returning dummy for getRI()')
|
| - return False
|
| -
|
| - def getCD(self):
|
| - """Read terminal status line: Carrier Detect"""
|
| - if not self._isOpen: raise portNotOpenError
|
| - if self.logger:
|
| - self.logger.info('returning dummy for getCD()')
|
| - return True
|
| -
|
| - # - - - platform specific - - -
|
| - # None so far
|
| -
|
| -
|
| -# assemble Serial class with the platform specific implementation and the base
|
| -# for file-like behavior. for Python 2.6 and newer, that provide the new I/O
|
| -# library, derive from io.RawIOBase
|
| -try:
|
| - import io
|
| -except ImportError:
|
| - # classic version with our own file-like emulation
|
| - class Serial(SocketSerial, FileLike):
|
| - pass
|
| -else:
|
| - # io library present
|
| - class Serial(SocketSerial, io.RawIOBase):
|
| - pass
|
| -
|
| -
|
| -# simple client test
|
| -if __name__ == '__main__':
|
| - import sys
|
| - s = Serial('socket://localhost:7000')
|
| - sys.stdout.write('%s\n' % s)
|
| -
|
| - sys.stdout.write("write...\n")
|
| - s.write("hello\n")
|
| - s.flush()
|
| - sys.stdout.write("read: %s\n" % s.read(5))
|
| -
|
| - s.close()
|
|
|