Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(668)

Unified Diff: tools/telemetry/third_party/pyserial/serial/urlhandler/protocol_socket.py

Issue 1647513002: Delete tools/telemetry. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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()

Powered by Google App Engine
This is Rietveld 408576698