Remove third_party/twisted_8_1

third_party/twisted_8_1/twisted/internet/_javaserialport.py

-# Copyright (c) 2001-2004 Twisted Matrix Laboratories.
-# See LICENSE for details.
-
-
-"""
-Serial Port Protocol
-"""
-
-# system imports
-import os
-
-# dependent on pyserial ( http://pyserial.sf.net/ )
-# only tested w/ 1.18 (5 Dec 2002)
-import serial
-from serial import PARITY_NONE, PARITY_EVEN, PARITY_ODD
-from serial import STOPBITS_ONE, STOPBITS_TWO
-from serial import FIVEBITS, SIXBITS, SEVENBITS, EIGHTBITS
-from serialport import BaseSerialPort
-
-# twisted imports
-from twisted.internet import abstract, javareactor, main
-from twisted.python import log
-
-class SerialPort(BaseSerialPort, javareactor.JConnection):
-    """A select()able serial device, acting as a transport."""
-    connected = 1
-
-    def __init__(self, protocol, deviceNameOrPortNumber, reactor, 
-        baudrate = 9600, bytesize = EIGHTBITS, parity = PARITY_NONE,
-        stopbits = STOPBITS_ONE, timeout = 3, xonxoff = 0, rtscts = 0):
-        # do NOT use timeout = 0 !!
-        self._serial = serial.Serial(deviceNameOrPortNumber, baudrate = baudrate, bytesize = bytesize, parity = parity, stopbits = stopbits, timeout = timeout, xonxoff = xonxoff, rtscts = rtscts)
-        javareactor.JConnection.__init__(self, self._serial.sPort, protocol, None)
-        self.flushInput()
-        self.flushOutput()
-        
-        self.reactor = reactor
-        self.protocol = protocol
-        self.protocol.makeConnection(self)
-        wb = javareactor.WriteBlocker(self, reactor.q)
-        wb.start()
-        self.writeBlocker = wb
-        javareactor.ReadBlocker(self, reactor.q).start()
-          
-    def writeSomeData(self, data):
-        try:
-          self._serial.write(data)
-          return len(data)
-        # should have something better here
-        except Exception, e:
-          return main.CONNECTION_LOST
-
-    def doRead(self):
-        readBytes = ''
-        try:
-          readBytes = self._serial.read(min(8192, self.inWaiting()))
-        except Exception, e:
-          return main.CONNECTION_LOST
-        if not readBytes:
-          return main.CONNECTION_LOST
-        self.protocol.dataReceived(readBytes)
-        
-    def connectionLost(self, reason):
-        self._serial.close()
-        self.protocol.connectionLost(reason)
-        abstract.FileDescriptor.connectionLost(self, reason)
-
-    def getHost(self):
-        raise NotImplementedError
-
-    def getPeer(self):
-        raise NotImplementedError
-
-    def getTcpNoDelay(self):
-        raise NotImplementedError
-
-    def setTcpNoDelay(self, enabled):
-        raise NotImplementedError