Synnefo » snf-ganeti

# 02110-1301, USA.

# To set user mappings, use this command:

# To disable strict mode (enabled by default):

#   git config gnt-review.strict false

    "nodes": {

      "node1.example.com": {

        "total_disk": 858276,

        "tags": [],

        "free_memory": 3505,

        "free_disk": 856740,

      },

      "node2.example.com": {

        "total_disk": 858240,

        "tags": ["test"],

        "free_memory": 3505,

        "free_disk": 848320,

      },

      "node3.example.com.com": {

        "total_disk": 572184,

        "tags": [],

        "free_memory": 3505,

        "free_disk": 570648,

   but for Ganeti you need to have::

     127.0.0.1       localhost

   ``/etc/hostname`` which configures the hostname of the system

   should contain ``node1.example.com`` and not just ``node1`` (you

   need to run the command ``/etc/init.d/hostname.sh start`` after

  (xend-relocation-server yes)

  (xend-relocation-port 8002)

  (xend-relocation-address '')

The second line assumess that the hypervisor parameter

``migration_port`` is set 8002, otherwise modify it to match. The last

line assumes that all your nodes have secondary IPs in the

.. admonition:: Debian

  ``rw``).

``nics`` (list, required)

  List of NIC (network interface) definitions. Example: ``[{}, {},

``os`` (string)

  Instance operating system.

``force_variant`` (bool)

Our simulated, example cluster will have three machines, named

``node1``, ``node2``, ``node3``. Note that in real life machines will

usually FQDNs but here we use short names for brevity. We will use a

having the last octet the same as their index. The cluster name will be

``example-cluster``. All nodes have the same simulated hardware

configuration, two disks of 750GB, 32GB of memory and 4 CPUs.

Follow the :doc:`install` document and prepare the nodes. Then it's time

to initialise the cluster::

  node1#

The creation was fine. Let's check that one node we have is functioning

Since this proceeded correctly, let's add the other two nodes::

  -- WARNING --

  Performing this operation is going to replace the ssh daemon keypair

  on the target machine (node2) with the ones of the current one

  and grant full intra-cluster ssh root access to/from it

  RSA key fingerprint is 9f:…

  Are you sure you want to continue connecting (yes/no)? yes

  root@node2's password:

  Mon Oct 26 02:11:54 2009  - INFO: Node will be a master candidate

  -- WARNING --

  Performing this operation is going to replace the ssh daemon keypair

  on the target machine (node2) with the ones of the current one

  and grant full intra-cluster ssh root access to/from it

  RSA key fingerprint is 9f:…

  Are you sure you want to continue connecting (yes/no)? yes

  root@node2's password:

  node1# gnt-node info node3

  Node name: node3

    master candidate: True

    drained: False

    offline: False

reused. Re-adding it is simple::

  node1# gnt-node add --readd node3

  RSA key fingerprint is 9f:2e:5a:2e:e0:bd:00:09:e4:5c:32:f2:27:57:7a:f4.

  Are you sure you want to continue connecting (yes/no)? yes

  Mon Oct 26 05:27:39 2009  - INFO: Readding a node, the offline/drained flags were reset

      # Acquire all nodes and one instance

      self.needed_locks = {

        locking.LEVEL_NODE: locking.ALL_SET,

      }

      # Acquire just two nodes

      self.needed_locks = {

      }

      # Acquire no locks

      self.needed_locks = {} # No, you can't leave it to the default value None

        Example:

        <screen>

# gnt-node add node5.example.com

        </screen>

      </para>

    </refsect2>

    {

      "# Master node": null,

      "primary": "xen-test-0",

    },

    {

      "primary": "xen-test-1",

    }

  ],

	device			"/dev/drbd63";

	disk			"/dev/xenvg/test.data";

	meta-disk		"/dev/xenvg/test.meta" [ 0 ];

}

_remote_host {

}

	device			minor 0;

	disk			"/dev/xenvg/test.data";

	meta-disk		"/dev/xenvg/test.meta" [ 0 ];

}

_remote_host {

}

protocol C;

_this_host {

	device			"/dev/drbd59";

}

_remote_host {

}

  def testMasterIPUnreachable(self):

    # Network 192.0.2.0/24 is reserved for test/documentation as per

    bad_data =  ("master.example.com", "192.0.2.1")

    # we just test that whatever TcpPing returns, VerifyNode returns too

    netutils.TcpPing = lambda a, b, source=None: False

    self.failUnless(self._has_disk(result, "/dev/xenvg/test.data",

                                   "/dev/xenvg/test.meta"),

                    "Wrong local disk info")

                    "Wrong network info (8.0.x)")

  def testParser83(self):

    self.failUnless(self._has_disk(result, "/dev/xenvg/test.data",

                                   "/dev/xenvg/test.meta"),

                    "Wrong local disk info")

                    "Wrong network info (8.0.x)")

  def testParserNetIP4(self):

                     "meta_dev" not in result and

                     "meta_index" not in result),

                    "Should not find local disk info")

                    "Wrong network info (IPv4)")

  def testParserNetIP6(self):

  def testSetPeersFamily(self):

    self.client._SetPeersAddressFamily()

    self.assertEquals(self.client._family, self.family)

    self.client.UpdatePeerList(mixed_peers)

    self.assertRaises(errors.ConfdClientError,

                      self.client._SetPeersAddressFamily)

class TestIP4Client(unittest.TestCase, _BaseClientTest):

  """Client tests"""

            ]

  family = socket.AF_INET

  def setUp(self):

          else:

            self.assertFalse(magic_cmd)

          for port in [0, 1, 1234, 7856, 45452]:

            for cmd_prefix in [None, "PrefixCommandGoesHere|",

                               "dd if=/dev/hda bs=1048576 |"]:

    """check that I don't own an address"""

    # Network 192.0.2.0/24 is reserved for test/documentation as per

    # this fails, we should extend the test to multiple addresses

    DST_IP = "192.0.2.1"

    self.failIf(netutils.OwnIpAddress(DST_IP),

      # Two NICs

      [

        { "mode": constants.NIC_MODE_BRIDGED, "link": "n0", "bridge": "br1", },

      ],

  """Test case for the AddAuthorizedKey function"""

  KEY_A = 'ssh-dss AAAAB3NzaC1w5256closdj32mZaQU root@key-a'

           'ssh-dss AAAAB3NzaC1w520smc01ms0jfJs22 root@key-b')

  def setUp(self):

    self.assertFileContent(self.tmpname,

      "ssh-dss AAAAB3NzaC1w5256closdj32mZaQU root@key-a\n"

      " ssh-dss AAAAB3NzaC1w520smc01ms0jfJs22 root@key-b\n"

      "ssh-dss AAAAB3NzaC1kc3MAAACB root@test\n")

    self.assertFileContent(self.tmpname,

      "ssh-dss AAAAB3NzaC1w5256closdj32mZaQU root@key-a\n"

      " ssh-dss AAAAB3NzaC1w520smc01ms0jfJs22 root@key-b\n"

      "ssh-dss AAAAB3NzaC1w5256closdj32mZaQU root@test\n")

    self.assertFileContent(self.tmpname,

      "ssh-dss AAAAB3NzaC1w5256closdj32mZaQU root@key-a\n"

      " ssh-dss AAAAB3NzaC1w520smc01ms0jfJs22 root@key-b\n")

  def testRemovingExistingKeyWithSomeMoreSpaces(self):

        'ssh-dss  AAAAB3NzaC1w5256closdj32mZaQU   root@key-a')

    self.assertFileContent(self.tmpname,

      " ssh-dss AAAAB3NzaC1w520smc01ms0jfJs22 root@key-b\n")

  def testRemovingNonExistingKey(self):

    self.assertFileContent(self.tmpname,

      "ssh-dss AAAAB3NzaC1w5256closdj32mZaQU root@key-a\n"

      " ssh-dss AAAAB3NzaC1w520smc01ms0jfJs22 root@key-b\n")

    try:

      handle.write('# This is a test file for /etc/hosts\n')

      handle.write('127.0.0.1\tlocalhost\n')

    finally:

      handle.close()

  def testSettingNewIp(self):

    self.assertFileContent(self.tmpname,

      "# This is a test file for /etc/hosts\n"

      "127.0.0.1\tlocalhost\n"

    self.assertFileMode(self.tmpname, 0644)

  def testSettingExistingIp(self):

                     ['myhost'])

    self.assertFileContent(self.tmpname,

      "# This is a test file for /etc/hosts\n"

      "127.0.0.1\tlocalhost\n"

    self.assertFileMode(self.tmpname, 0644)

  def testSettingDuplicateName(self):

    self.assertFileContent(self.tmpname,

      "# This is a test file for /etc/hosts\n"

      "127.0.0.1\tlocalhost\n"

    self.assertFileMode(self.tmpname, 0644)

  def testRemovingExistingHost(self):

    self.assertFileContent(self.tmpname,

      "# This is a test file for /etc/hosts\n"

      "127.0.0.1\tlocalhost\n"

    self.assertFileMode(self.tmpname, 0644)

  def testRemovingSingleExistingHost(self):

    self.assertFileContent(self.tmpname,

      "# This is a test file for /etc/hosts\n"

    self.assertFileMode(self.tmpname, 0644)

  def testRemovingNonExistingHost(self):

    self.assertFileContent(self.tmpname,

      "# This is a test file for /etc/hosts\n"

      "127.0.0.1\tlocalhost\n"

    self.assertFileMode(self.tmpname, 0644)

  def testRemovingAlias(self):

    self.assertFileContent(self.tmpname,

      "# This is a test file for /etc/hosts\n"

      "127.0.0.1\tlocalhost\n"

    self.assertFileMode(self.tmpname, 0644)