def _load_from_socket(port, auth_secret):
    '\n    Load data from a given socket, this is a blocking method thus only return when the socket\n    connection has been closed.\n    '
    (sockfile, sock) = local_connect_and_auth(port, auth_secret)
    sock.settimeout(None)
    write_int(BARRIER_FUNCTION, sockfile)
    sockfile.flush()
    res = UTF8Deserializer().loads(sockfile)
    sockfile.close()
    sock.close()
    return res
Load data from a given socket, this is a blocking method thus only return when the socket
connection has been closed.
def _load_from_socket(port, auth_secret):
    '\n    Load data from a given socket, this is a blocking method thus only return when the socket\n    connection has been closed.\n    '
    (sockfile, sock) = local_connect_and_auth(port, auth_secret)
    sock.settimeout(None)
    write_int(BARRIER_FUNCTION, sockfile)
    sockfile.flush()
    res = UTF8Deserializer().loads(sockfile)
    sockfile.close()
    sock.close()
    return res