Synnefo » snf-ganeti

    # Clean queue directory on added node

    result = rpc.RpcRunner.call_jobqueue_purge(node_name)

    if msg:

      logging.warning("Cannot cleanup queue directory on node %s: %s",

                      node_name, msg)

      result = rpc.RpcRunner.call_jobqueue_update([node_name],

                                                  [node.primary_ip],

                                                  file_name, content)

      if msg:

        logging.error("Failed to upload file %s to node %s: %s",

                      file_name, node_name, msg)

    success = []

    for node in nodes:

      if msg:

        failed.append(node)

        logging.error("RPC call %s failed on node %s: %s",