]>
git.proxmox.com Git - pve-cluster.git/blob - data/PVE/Corosync.pm
8 use Net
::IP
qw(ip_is_ipv6);
12 my $basedir = "/etc/pve";
14 my $conf_array_sections = {
19 # a very simply parser ...
21 my ($filename, $raw) = @_;
25 my $digest = Digest
::SHA
::sha1_hex
(defined($raw) ?
$raw : '');
33 my @tokens = split(/\s/, $raw);
35 my $conf = { 'main' => {} };
38 my $section = $conf->{main
};
40 while (defined(my $token = shift @tokens)) {
41 my $nexttok = $tokens[0];
43 if ($nexttok && ($nexttok eq '{')) {
44 shift @tokens; # skip '{'
46 if ($conf_array_sections->{$token}) {
47 $section->{$token} = [] if !defined($section->{$token});
48 push @{$section->{$token}}, $new_section;
49 } elsif (!defined($section->{$token})) {
50 $section->{$token} = $new_section;
52 die "section '$token' already exists and not marked as array!\n";
54 push @$stack, $section;
55 $section = $new_section;
60 $section = pop @$stack;
61 die "parse error - uncexpected '}'\n" if !$section;
66 die "missing ':' after key '$key'\n" if ! ($key =~ s/:$//);
68 die "parse error - no value for '$key'\n" if !defined($nexttok);
69 my $value = shift @tokens;
71 $section->{$key} = $value;
74 # make working with the config way easier
75 my ($totem, $nodelist) = $conf->{main
}->@{"totem", "nodelist"};
76 $nodelist->{node
} = { map { $_->{name
} // $_->{ring0_addr
} => $_ } @{$nodelist->{node
}} };
77 $totem->{interface
} = { map { $_->{ringnumber
} => $_ } @{$totem->{interface
}} };
79 $conf->{digest
} = $digest;
86 my ($section, $prefix) = @_;
90 foreach my $k (sort keys %$section) {
91 my $v = $section->{$k};
92 if (ref($v) eq 'HASH') {
93 $raw .= $prefix . "$k {\n";
94 $raw .= &$dump_section($v, "$prefix ");
95 $raw .= $prefix . "}\n";
96 $raw .= "\n" if !$prefix; # add extra newline at 1st level only
97 } elsif (ref($v) eq 'ARRAY') {
98 foreach my $child (@$v) {
99 $raw .= $prefix . "$k {\n";
100 $raw .= &$dump_section($child, "$prefix ");
101 $raw .= $prefix . "}\n";
104 $raw .= $prefix . "$k: $v\n";
106 die "unexpected reference in config hash: $k => ". ref($v) ."\n";
114 my ($filename, $conf) = @_;
116 my $c = clone
($conf->{main
}) // die "no main section";
118 # retransform back for easier dumping
119 my $hash_to_array = sub {
121 return [ $hash->@{sort keys %$hash} ];
124 $c->{nodelist
}->{node
} = &$hash_to_array($c->{nodelist
}->{node
});
125 $c->{totem
}->{interface
} = &$hash_to_array($c->{totem
}->{interface
});
127 my $raw = &$dump_section($c, '');
132 # read only - use atomic_write_conf method to write
133 PVE
::Cluster
::cfs_register_file
('corosync.conf', \
&parse_conf
);
135 PVE
::Cluster
::cfs_register_file
('corosync.conf.new', \
&parse_conf
,
138 sub check_conf_exists
{
141 $silent = $silent // 0;
143 my $exists = -f
"$basedir/corosync.conf";
145 warn "Corosync config '$basedir/corosync.conf' does not exist - is this node part of a cluster?\n"
146 if !$silent && !$exists;
151 sub update_nodelist
{
152 my ($conf, $nodelist) = @_;
154 $conf->{main
}->{nodelist
}->{node
} = $nodelist;
156 atomic_write_conf
($conf);
161 return clone
($conf->{main
}->{nodelist
}->{node
});
166 return clone
($conf->{main
}->{totem
});
169 # caller must hold corosync.conf cfs lock if used in read-modify-write cycle
170 sub atomic_write_conf
{
171 my ($conf, $no_increase_version) = @_;
173 if (!$no_increase_version) {
174 die "invalid corosync config: unable to read config version\n"
175 if !defined($conf->{main
}->{totem
}->{config_version
});
176 $conf->{main
}->{totem
}->{config_version
}++;
179 PVE
::Cluster
::cfs_write_file
("corosync.conf.new", $conf);
181 rename("/etc/pve/corosync.conf.new", "/etc/pve/corosync.conf")
182 || die "activating corosync.conf.new failed - $!\n";
185 # for creating a new cluster with the current node
186 # params are those from the API/CLI cluster create call
188 my ($nodename, %param) = @_;
190 my $clustername = $param{clustername
};
191 my $nodeid = $param{nodeid
} || 1;
192 my $votes = $param{votes
} || 1;
194 my $local_ip_address = PVE
::Cluster
::remote_node_ip
($nodename);
195 my $ring0_addr = $param{ring0_addr
} // $local_ip_address;
196 my $bindnet0_addr = $param{bindnet0_addr
} // $ring0_addr;
198 my $use_ipv6 = ip_is_ipv6
($ring0_addr);
199 die "ring 0 addresses must be from same IP family!\n"
200 if $use_ipv6 != ip_is_ipv6
($bindnet0_addr);
204 version
=> 2, # protocol version
206 cluster_name
=> $clustername,
208 ip_version
=> $use_ipv6 ?
'ipv6' : 'ipv4',
211 bindnetaddr
=> $bindnet0_addr,
221 quorum_votes
=> $votes,
222 ring0_addr
=> $ring0_addr,
227 provider
=> 'corosync_votequorum',
235 die "Param bindnet1_addr set but ring1_addr not specified!\n"
236 if (defined($param{bindnet1_addr
}) && !defined($param{ring1_addr
}));
238 my $ring1_addr = $param{ring1_addr
};
239 my $bindnet1_addr = $param{bindnet1_addr
} // $param{ring1_addr
};
241 if ($bindnet1_addr) {
242 die "ring 1 addresses must be from same IP family as ring 0!\n"
243 if $use_ipv6 != ip_is_ipv6
($bindnet1_addr) ||
244 $use_ipv6 != ip_is_ipv6
($ring1_addr);
246 $conf->{totem
}->{interface
}->{1} = {
247 bindnetaddr
=> $bindnet1_addr,
250 $conf->{totem
}->{rrp_mode
} = 'passive';
251 $conf->{nodelist
}->{node
}->{$nodename}->{ring1_addr
} = $ring1_addr;
254 return { main
=> $conf };