| Index: third_party/twisted_8_1/twisted/internet/_javaserialport.py
|
| diff --git a/third_party/twisted_8_1/twisted/internet/_javaserialport.py b/third_party/twisted_8_1/twisted/internet/_javaserialport.py
|
| deleted file mode 100644
|
| index ee8469508d4372cd3464a1d82a69d7fc111229e7..0000000000000000000000000000000000000000
|
| --- a/third_party/twisted_8_1/twisted/internet/_javaserialport.py
|
| +++ /dev/null
|
| @@ -1,78 +0,0 @@
|
| -# 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
|
|
|