SF.net SVN: fclient: [318] trunk/sandbox/fcp2/test_fcp/dummy_socket.py

[<ju...@us...>]

Revision: 318
          http://fclient.svn.sourceforge.net/fclient/?rev=318&view=rev
Author:   jurner
Date:     2008-03-06 04:05:53 -0800 (Thu, 06 Mar 2008)

Log Message:
-----------
removed dummy socket. Use io now

Modified Paths:
--------------
    trunk/sandbox/fcp2/test_fcp/dummy_socket.py

Modified: trunk/sandbox/fcp2/test_fcp/dummy_socket.py
===================================================================
--- trunk/sandbox/fcp2/test_fcp/dummy_socket.py	2008-03-06 12:05:35 UTC (rev 317)
+++ trunk/sandbox/fcp2/test_fcp/dummy_socket.py	2008-03-06 12:05:53 UTC (rev 318)
@@ -1,8 +1,5 @@
 """Dummy socket object for testing"""
 
-import socket
-
-
 import os, sys
 
 #--> rel import hack
@@ -91,7 +88,6 @@
 		self.disallowConnect = flag
 
 	def setReverseDirection(self, flag):
-		""""""
 		self._reverseDirection = flag
 		
 	
@@ -109,94 +105,4 @@
 			assert params['DataLength'] == len(data)
 			self.readBuffer += data
 		
-			
 		
-
-
-
-#********************************************************************
-#
-#********************************************************************
-class DummySocket(object):
-	"""Dummy socket for testing"""
-	 
-	def __init__(self, family=socket.AF_INET, type=socket.SOCK_STREAM):
-		
-		self.closed = False
-		self.error = False
-		self.timeout = 0
-		self.bytesReceiver = None
-		
-		self.bytes = ''
-		self.responseBytes = ''
-					
-	def setBytes(self, bytes):
-		self.bytes = bytes
-	
-	def setResponse(self, bytes):
-		self.responseBytes += bytes
-		
-	def sendResponseMessage(self, name, data=None, **params):
-		buf = [name, ]
-		for name, value in params.items():
-			buf.append('%s=%s' % (name, value) )
-		if data is None:
-			buf.append('EndMessage\n')
-		else:
-			buf.append('Data\n')
-		self.responseBytes += '\n'.join(buf)
-		if data:
-			assert 'DataLength' in params
-			assert params['DataLength'] == len(data)
-			self.responseBytes += data
-	
-		
-	def setBytesReceiver(self, cb):
-		self.bytesReceiver = cb
-	
-	def setClosed(self, flag):
-		self.closed = flag
-		
-	def setError(self, flag):
-		self.error = flag
-	
-	def __call__(self, family=socket.AF_INET, type=socket.SOCK_STREAM):
-		self.bytes = ''
-		self.closed = False
-		self.error = False		
-		return self
-	
-	
-	def connect(self, (host, port)):
-		if self.error:
-			raise socket.error(0, 'I am dead')
-		
-	def close(self):
-		self.closed = True
-		self.bytes = ''
-		
-	def recv(self, n):
-		if self.closed:
-			return ''
-		elif self.error:
-			raise socket.error(0, 'I am dead!')
-		self.responseBytes, bytes = self.responseBytes[n:], self.responseBytes[:n]
-		if bytes:
-			return bytes
-		raise socket.timeout(0)
-		
-	def sendall(self, bytes):
-		if self.closed:
-			raise socket.error(0, 'I am dead!')
-		self.bytes += bytes
-		if self.bytesReceiver is not None:
-			self.bytesReceiver(bytes)
-			
-	
-	def settimeout(self, n):
-		self.timeout = n
-		
-
-
-
-


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.