Qn: Socket performance under Windows

[Colin Brown]

Python2.3.2: Running the following receiver and sender code in separate
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])

----------------------------------------------------------------------