SF.net SVN: fclient: [351] trunk/sandbox/fcp2/test_fcp/dummy_io.py
Status: Pre-Alpha
Brought to you by:
jurner
|
From: <jU...@us...> - 2008-03-09 12:56:26
|
Revision: 351
http://fclient.svn.sourceforge.net/fclient/?rev=351&view=rev
Author: jUrner
Date: 2008-03-09 05:56:27 -0700 (Sun, 09 Mar 2008)
Log Message:
-----------
fixes and beautification
Modified Paths:
--------------
trunk/sandbox/fcp2/test_fcp/dummy_io.py
Modified: trunk/sandbox/fcp2/test_fcp/dummy_io.py
===================================================================
--- trunk/sandbox/fcp2/test_fcp/dummy_io.py 2008-03-09 12:55:05 UTC (rev 350)
+++ trunk/sandbox/fcp2/test_fcp/dummy_io.py 2008-03-09 12:56:27 UTC (rev 351)
@@ -22,16 +22,18 @@
#********************************************************************
class DummyIO(iohandler.IOObjectBase):
- def __init__(self, ):
+ def __init__(self, **kwargs):
self.readBuffer = '' # buffer client reads from
self.writeBuffer = '' # buffer client writes to
self._isOpen = False
self._isBroken = False
- self._disallowConnect = False
+ self._allowConnect = True
self._reverseDirection = False
def connect(self, **kwargs):
+ if not self._allowConnect:
+ raise iohandler.IOConnectFailed('Refused')
self._isOpen = True
def read(self, n):
@@ -58,9 +60,7 @@
self.writeBuffer += bytes
def close(self):
- self._isBroken = False
- self._disallowConnect = False
- self._reverseDirection = False
+ self.reset()
if self.isOpen():
self._isOpen = False
self.readBuffer = ''
@@ -84,13 +84,12 @@
def setBroken(self, flag):
self._isBroken = flag
- def setDissallowConnect(self, flag):
- self.disallowConnect = flag
+ def setAllowConnect(self, flag):
+ self._allowConnect = flag
def setReverseDirection(self, flag):
self._reverseDirection = flag
-
def sendResponseMessage(self, name, data=None, **params):
buf = [name, ]
for name, value in params.items():
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|