SF.net SVN: fclient: [351] trunk/sandbox/fcp2/test_fcp/dummy_io.py

[<jU...@us...>]

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.