blob: 0d89fb0c0b3bab48b65c12555a4634a1314adce2 (
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
{ pkgs, lib, ... }:
let
master =
{ pkgs, ... }:
{
# data base is stored in memory
# server may crash with default memory size
virtualisation.memorySize = 1024;
services.saunafs.master = {
enable = true;
openFirewall = true;
exports = [
"* / rw,alldirs,maproot=0:0"
];
};
};
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.saunafs = {
masterHost = "master";
chunkserver = {
openFirewall = true;
enable = true;
hdds = [ "/data" ];
# The test image is too small and gets set to "full"
settings.HDD_LEAVE_SPACE_DEFAULT = "100M";
};
};
};
metalogger =
{ pkgs, ... }:
{
services.saunafs = {
masterHost = "master";
metalogger.enable = true;
};
};
client =
{ pkgs, lib, ... }:
{
services.saunafs.client.enable = true;
# systemd.tmpfiles.rules = [ "d /sfs 755 root root -" ];
systemd.network.enable = true;
# Use networkd to have properly functioning
# network-online.target
networking = {
useDHCP = false;
useNetworkd = true;
};
systemd.mounts = [
{
requires = [ "network-online.target" ];
after = [ "network-online.target" ];
wantedBy = [ "remote-fs.target" ];
type = "saunafs";
what = "master:/";
where = "/sfs";
}
];
};
in
{
name = "saunafs";
meta.maintainers = [ lib.maintainers.markuskowa ];
nodes = {
inherit master metalogger;
chunkserver1 = chunkserver;
chunkserver2 = chunkserver;
client1 = client;
client2 = client;
};
testScript = ''
# prepare master server
master.start()
master.wait_for_unit("multi-user.target")
master.succeed("sfsmaster-init")
master.succeed("systemctl restart sfs-master")
master.wait_for_unit("sfs-master.service")
metalogger.wait_for_unit("sfs-metalogger.service")
# Setup chunkservers
for chunkserver in [chunkserver1, chunkserver2]:
chunkserver.wait_for_unit("multi-user.target")
chunkserver.succeed("chown saunafs:saunafs /data")
chunkserver.succeed("systemctl restart sfs-chunkserver")
chunkserver.wait_for_unit("sfs-chunkserver.service")
for client in [client1, client2]:
client.wait_for_unit("multi-user.target")
client1.succeed("echo test > /sfs/file")
client2.succeed("grep test /sfs/file")
'';
}
|
