New standard modules for the mac.

Mac/Unsupported/mactcp/MACTCPconst.py

+#
+# MACTCP - event codes for the mactcp module
+#
+
+# UDP asr event codes
+UDPDataArrival=1		# A datagram has arrived
+UDPICMPReceived=2		# An ICMP error was received
+
+# TCP asr event codes
+TCPClosing=1			# All incoming data has been received and read.
+TCPULPTimeout=2			# No response from remote process.
+TCPTerminate=3			# Connection terminated. Has a detail parameter.
+TCPDataArrival=4		# Data has arrived (and no Rcv call is outstanding)
+TCPUrgent=5				# Urgent data is outstanding
+TCPICMPReceived=6		# An ICMP error was received
+PassiveOpenDone=32766	# (python only) a PassiveOpen has completed.
+
+# TCP termination reasons
+TCPRemoteAbort=2
+TCPNetworkFailure=3
+TCPSecPrecMismatch=4
+TCPULPTimeoutTerminate=5
+TCPULPAbort=6
+TCPULPClose=7
+TCPServiceError=8
+
+# MacTCP/DNR errors
+ipBadLapErr = 			-23000			# bad network configuration 
+ipBadCnfgErr = 			-23001			# bad IP configuration error 
+ipNoCnfgErr = 			-23002			# missing IP or LAP configuration error 
+ipLoadErr = 			-23003			# error in MacTCP load 
+ipBadAddr = 			-23004			# error in getting address 
+connectionClosing = 	-23005			# connection is closing 
+invalidLength = 		-23006
+connectionExists = 		-23007			# request conflicts with existing connection 
+connectionDoesntExist =	-23008			# connection does not exist 
+insufficientResources =	-23009			# insufficient resources to perform request 
+invalidStreamPtr = 		-23010
+streamAlreadyOpen = 	-23011
+connectionTerminated = 	-23012
+invalidBufPtr = 		-23013
+invalidRDS = 			-23014
+invalidWDS = 			-23014
+openFailed = 			-23015
+commandTimeout = 		-23016
+duplicateSocket = 		-23017
+
+# Error codes from internal IP functions 
+ipDontFragErr = 		-23032			# Packet too large to send w/o fragmenting 
+ipDestDeadErr = 		-23033			# destination not responding
+icmpEchoTimeoutErr = 	-23035			# ICMP echo timed-out 
+ipNoFragMemErr = 		-23036			# no memory to send fragmented pkt 
+ipRouteErr = 			-23037			# can't route packet off-net 
+
+nameSyntaxErr =  		-23041		
+cacheFault = 			-23042
+noResultProc = 			-23043
+noNameServer = 			-23044
+authNameErr = 			-23045
+noAnsErr = 				-23046
+dnrErr = 				-23047
+outOfMemory = 			-23048

Mac/Unsupported/mactcp/MacTCPerrors.py

+ipBadLapErr = 			-23000			# bad network configuration 
+ipBadCnfgErr = 			-23001			# bad IP configuration error 
+ipNoCnfgErr = 			-23002			# missing IP or LAP configuration error 
+ipLoadErr = 			-23003			# error in MacTCP load 
+ipBadAddr = 			-23004			# error in getting address 
+connectionClosing = 	-23005			# connection is closing 
+invalidLength = 		-23006
+connectionExists = 		-23007			# request conflicts with existing connection 
+connectionDoesntExist =	-23008			# connection does not exist 
+insufficientResources =	-23009			# insufficient resources to perform request 
+invalidStreamPtr = 		-23010
+streamAlreadyOpen = 	-23011
+connectionTerminated = 	-23012
+invalidBufPtr = 		-23013
+invalidRDS = 			-23014
+invalidWDS = 			-23014
+openFailed = 			-23015
+commandTimeout = 		-23016
+duplicateSocket = 		-23017
+
+# Error codes from internal IP functions 
+ipDontFragErr = 		-23032			# Packet too large to send w/o fragmenting 
+ipDestDeadErr = 		-23033			# destination not responding
+icmpEchoTimeoutErr = 	-23035			# ICMP echo timed-out 
+ipNoFragMemErr = 		-23036			# no memory to send fragmented pkt 
+ipRouteErr = 			-23037			# can't route packet off-net 
+
+nameSyntaxErr =  		-23041		
+cacheFault = 			-23042
+noResultProc = 			-23043
+noNameServer = 			-23044
+authNameErr = 			-23045
+noAnsErr = 				-23046
+dnrErr = 				-23047
+outOfMemory = 			-23048

Mac/Unsupported/mactcp/socket.py

+#
+# socket.py for mac - Emulate socket module with mactcp and macdnr
+#
+# Jack Jansen, CWI, November 1994
+#
+import mactcp
+import MACTCP
+import macdnr
+import sys
+
+#
+# Constants
+#
+_myerror = 'socket_wrapper.error'
+error = (mactcp.error, macdnr.error, _myerror)
+
+SOCK_DGRAM=1
+SOCK_STREAM=2
+
+AF_INET=1
+
+#
+# Internal constants
+#
+_BUFSIZE=4096		# Size of tcp/udp input buffer
+_connectionClosing=-42 # XXXX
+
+_myaddress=None
+_myname=None
+_myaddrstr=None
+
+def _myipaddress():
+	global _myaddress
+	if _myaddress == None:
+		_myaddress = mactcp.IPAddr()
+	return _myaddress
+
+def _ipaddress(str):
+	if type(str) == type(1):
+		return str			# Already numeric
+	ptr = macdnr.StrToAddr(str)
+	ptr.wait()
+	return ptr.ip0
+	
+def gethostbyname(str):
+	id = _ipaddress(str)
+	return macdnr.AddrToStr(id)
+	
+def gethostname():
+	global _myname
+	if _myname == None:
+		id = _myipaddress()
+		ptr = macdnr.AddrToName(id)
+		ptr.wait()
+		_myname = ptr.cname
+	return _myname
+
+def _gethostaddress():
+	global _myaddrstr
+	if _myaddrstr == None:
+		id = _myipaddress()
+		_myaddrstr = macdnr.AddrToStr(id)
+	return _myaddrstr
+	
+def socket(family, type, *which):
+	if family <> AF_INET:
+		raise my_error, 'Protocol family not supported'
+	if type == SOCK_DGRAM:
+		return _udpsocket()
+	elif type == SOCK_STREAM:
+		return _tcpsocket()
+	raise my_error, 'Protocol type not supported'
+	
+def fromfd(*args):
+	raise my_error, 'Operation not supported on a mac'
+	
+class _socket:
+	def accept(self, *args):
+		raise my_error, 'Operation not supported on this socket'
+		
+	bind = accept
+	close = accept
+	connect = accept
+	fileno = accept
+	getpeername = accept
+	getsockname = accept
+	getsockopt = accept
+	listen = accept
+	recv = accept
+	recvfrom = accept
+	send = accept
+	sendto = accept
+	setblocking = accept
+	setsockopt = accept
+	shutdown = accept
+	 
+class _tcpsocket(_socket):
+	def __init__(self):
+		self.stream = mactcp.TCPCreate(_BUFSIZE)
+		##self.stream.asr = self.asr
+		self.databuf = ''
+		self.udatabuf = ''
+		self.port = 0
+		self.accepted = 0
+		self.listening = 0
+
+	def accept(self):
+		if not self.listening:
+			raise my_error, 'Not listening'
+		self.listening = 0
+		self.stream.wait()
+		self.accepted = 1
+		return self, self.getsockname()
+		
+	def bind(self, host, port):
+		self.port = port
+		
+	def close(self):
+		if self.accepted:
+			self.accepted = 0
+			return
+		self.stream.Abort()
+			
+	def connect(self, host, port):
+		self.stream.ActiveOpen(self.port, _ipaddress(host), port)
+		
+	def getsockname(self):
+		st = self.stream.Status()
+		host = macdnr.AddrToStr(st.localHost)
+		return host, st.localPort
+		
+	def getpeername(self):
+		st = self.stream.Status()
+		host = macdnr.AddrToStr(st.remoteHost)
+		return host, st.remotePort		
+		
+	def listen(self, backlog):
+		self.stream.PassiveOpen(self.port)
+		self.listening = 1
+		
+	def makefile(self, rw):
+		return _socketfile(self)
+		
+	def recv(self, bufsize, flags=0):
+		if flags:
+			raise my_error, 'recv flags not yet supported on mac'
+		if not self.databuf:
+			try:
+				self.databuf, urg, mark = self.stream.Rcv(0)
+				if not self.databuf:
+					print '** socket: no data!'
+				print '** recv: got ', len(self.databuf)
+			except mactcp.error, arg:
+				if arg[0] != MACTCP.connectionClosing:
+					raise mactcp.error, arg
+		rv = self.databuf[:bufsize]
+		self.databuf = self.databuf[bufsize:]
+		return rv
+		
+	def send(self, buf):
+		self.stream.Send(buf)
+		return len(buf)
+		
+	def shutdown(self, how):
+		if how == 0:
+			return
+		self.stream.Close()
+		
+	def bytes_readable(self):
+		st = self.stream.Status()
+		return st.amtUnreadData
+		
+	def bytes_writeable(self):
+		st = self.stream.Status()
+		return st.sendWindow - st.sendUnacked;
+		
+class _udpsocket(_socket):
+	def __init__(self):
+		pass
+		
+class _socketfile:
+	def __init__(self, sock):
+		self.sock = sock
+		self.buf = ''
+		
+	def read(self, *arg):
+		if arg:
+			length = arg
+		else:
+			length = 0x7fffffff
+		while len(self.buf) < length:
+			new = self.sock.recv(0x7fffffff)
+			if not new:
+				break
+			self.buf = self.buf + new
+		rv = self.buf[:length]
+		self.buf = self.buf[length:]
+		return rv
+		
+	def readline(self):
+		import string
+		while not '\n' in self.buf:
+			new = self.sock.recv(0x7fffffff)
+			if not new:
+				break
+			self.buf = self.buf + new
+		if not '\n' in self.buf:
+			rv = self.buf
+			self.buf = ''
+		else:
+			i = string.index(self.buf, '\n')
+			rv = self.buf[:i+1]
+			self.buf = self.buf[i+1:]
+		print '** Readline:',self, `rv`
+		return rv
+			
+	def write(self, buf):
+		self.sock.send(buf)
+		
+	def close(self):
+		self.sock.close()
+		del self.sock
+		
+def __test_tcp():
+	s = socket(AF_INET, SOCK_STREAM)
+	s.connect('poseidon.cwi.nl', 13)
+	rv = s.recv(1000)
+	print 'Time/date:', rv
+	rv = s.recv(1000)
+	if rv:
+		print 'Unexpected extra data:', rv
+	s.close()
+	
+def __test_udp():
+	s = socket(AF_INET, SOCK_DGRAM)
+	print 'Sending data... (hello world)'
+	s.sendto(('poseidon.cwi.nl', 7), 'hello world')
+	rv, host = s.recvfrom(1000)
+	print 'Got from ', host, ':', rv
+