netcache_client.py 文件源码

def read_header(conn):
    cnt = 0
    buf = []
    while cnt < HEADER_SIZE:
        data = conn.recv(HEADER_SIZE - cnt)
        if not data:
            #import traceback
            #traceback.print_stack()
            raise ValueError('connection ended when reading a header %r' % buf)
        buf.append(data)
        cnt += len(data)
    if sys.hexversion > 0x3000000:
        ret = ''.encode('iso8859-1').join(buf)
        ret = ret.decode('iso8859-1')
    else:
        ret = ''.join(buf)
    return ret