summaryrefslogtreecommitdiffstats
path: root/nixos/tests/moosefs.nix
blob: 9b4ccba08b8aafbed5968a6707c0919d0036b98a (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
{ pkgs, ... }:

let
  master =
    { pkgs, ... }:
    {
      # data base is stored in memory
      # server crashes with default memory size
      virtualisation.memorySize = 1024;

      services.moosefs.master = {
        enable = true;
        openFirewall = true;
        autoInit = true;
        exports = [
          "* / rw,alldirs,admin,maproot=0:0"
          "* . rw"
        ];
      };
    };

  chunkserver =
    { pkgs, ... }:
    {
      virtualisation.emptyDiskImages = [
        {
          size = 4096;
          driveConfig.deviceExtraOpts.serial = "data";
        }
      ];

      fileSystems = pkgs.lib.mkVMOverride {
        "/data" = {
          device = "/dev/disk/by-id/virtio-data";
          fsType = "ext4";
          autoFormat = true;
        };
      };

      services.moosefs = {
        masterHost = "master";
        chunkserver = {
          openFirewall = true;
          enable = true;
          hdds = [ "~/data" ];
        };
      };
    };

  metalogger =
    { pkgs, ... }:
    {
      services.moosefs = {
        masterHost = "master";
        metalogger.enable = true;
      };
    };

  client =
    { pkgs, ... }:
    {
      services.moosefs.client.enable = true;
    };

in
{
  name = "moosefs";

  nodes = {
    inherit master;
    inherit metalogger;
    chunkserver1 = chunkserver;
    chunkserver2 = chunkserver;
    client1 = client;
    client2 = client;
  };

  testScript = ''
    # prepare master server
    master.start()
    master.wait_for_unit("multi-user.target")
    master.wait_for_unit("mfs-master.service")

    metalogger.wait_for_unit("mfs-metalogger.service")

    for chunkserver in [chunkserver1, chunkserver2]:
        chunkserver.wait_for_unit("multi-user.target")
        chunkserver.succeed("chown moosefs:moosefs /data")
        chunkserver.succeed("systemctl restart mfs-chunkserver")
        chunkserver.wait_for_unit("mfs-chunkserver.service")

    for client in [client1, client2]:
        client.wait_for_unit("multi-user.target")
        client.succeed("mkdir /moosefs")
        client.succeed("mount -t moosefs master:/ /moosefs")

    client1.succeed("echo test > /moosefs/file")
    client2.succeed("grep test /moosefs/file")
  '';
}