endpoint_proxy.py 文件源码

def forward( source, dest, address, server ):
    buff = bytearray( 4096 )
    mv_buffer = memoryview( buff )
    try:
        while True:
            nReceived = source.recv_into( buff )
            if 0 == nReceived:
                break
            dest.sendall( mv_buffer[ : nReceived ] )
    except:
        pass
    finally:
        print( "Closed from %s" % str( address ) )
        try:
            source.close()
        except:
            pass
        try:
            dest.close()
        except:
            pass
        server = None