"Krister Liljedahl" <bl******@hotmail.com> wrote in message
news:a9**************************@posting.google.c om...
Hi,
.... Does anyone else experience problem with large numbers (>63) of
sockets under Windows?
Yes, see details of previous post of mine below.
================================================== ====
windows under Win2K does not work properly (missed & very delayed
transmissions). Under Redhat Linux 9 (where I will be using it) it works
fine (with up to 250 sending threads; I hit the thread limit at 255!)
Any idea why do I not get any errors reported under Windows?
Colin Brown
PyNZ
--[Sender.py]--------------------------------------------------------
# Send 50 'simultaneous' tcp transmissions to receiver
import os,socket,sys,time,thread,traceback
def error():
tb =
traceback.format_exception(sys.exc_info()[0],sys.exc_info()[1],sys.exc_info(
)[2])
return tb[len(tb)-1].replace('\n','')
class client:
def __init__(self,nodeport):
self.nodeport = nodeport
self.cli = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.cli.settimeout(60.0)
def connect(self):
self.cli.connect((self.nodeport))
def write(self,data):
self.cli.sendall(data)
def close(self):
self.cli.close()
def send(v,data):
cli = client(('localhost',20031))
for cnt in range(5):
try:
cli.connect()
break
except:
if cnt == 4:
print v,'Connect failure: ',error()
else:
time.sleep(0.3)
try:
cli.write(data)
except:
print v,'Send failure: ',error()
cli.close()
print v
def action(data,number):
for ii in range(1,1+number):
thread.start_new_thread(send,(str(ii),data))
if __name__ == '__main__':
action(''.join(['00001000',chr(32)*1000]),50)
time.sleep(75.0)
--[Receiver.py]------------------------------------------------------
import select,socket,thread, time
COUNTER = 0
TIME0 = 0.0
class rx:
def __init__(self,LocPort=20031,NumConn=100):
self.svr = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.svr.bind (('', LocPort))
self.svr.listen(NumConn)
def nextConnAddr(self):
if select.select([self.svr], [], [], None)[0]:
return self.svr.accept()
else:
raise 'SocketReceiver.rx.nextConnAddr','connection lost'
def rxThread(self,recvr):
thread.start_new_thread(newSession,(recvr,))
def close(self):
self.svr.close()
def newSession(conn):
sess = session(conn)
sess.run()
class session:
def __init__(self,conn,timeout=180.0):
self.conn = conn
self.conn.settimeout(timeout)
def recvblock(self,length):
block = []
size = length
while size > 0:
chunk = self.conn.recv(size)
if chunk:
block.append(chunk)
size = size - len(chunk)
else:
raise 'Session.recvblock','connection lost'
return ''.join(block)
def getsize(self):
length = self.recvblock(8)
return int(length)
def getdata(self,size):
return self.recvblock(size)
def run(self):
global COUNTER, TIME0
data = self.getdata(self.getsize())
if len(data) != 1000:
print 'Transmission error'
else:
COUNTER = COUNTER + 1
if TIME0 == 0.0:
TIME0 = time.time()
print '%i%s%0.3f' % (COUNTER,'\t',time.time()-TIME0)
rcvr = rx()
while 1:
rcvr.rxThread(rcvr.nextConnAddr()[0])
----------------------------------------------------------------------
