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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
# Simple? gluster module by James
# Copyright (C) 2010-2013+ James Shubin
# Written by James Shubin <james@shubin.ca>
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
# TODO: instead of peering manually this way (which makes the most sense, but
# might be unsupported by gluster) we could peer using the cli, and ensure that
# only the host holding the vip is allowed to execute cluster peer operations.
define gluster::host(
$uuid = '' # if empty, puppet will attempt to use the gluster fact
) {
include gluster::vardir
#$vardir = $::gluster::vardir::module_vardir # with trailing slash
$vardir = regsubst($::gluster::vardir::module_vardir, '\/$', '')
Gluster::Host[$name] -> Service['glusterd'] # glusterd requires host
# if we're on itself
if ( "${fqdn}" == "${name}" ) {
# don't purge the uuid file generated within
file { "${vardir}/uuid/":
ensure => directory, # make sure this is a directory
recurse => false, # don't recurse into directory
purge => false, # don't purge unmanaged files
force => false, # don't purge subdirs and links
require => File["${vardir}/"],
}
$valid_uuid = "${uuid}" ? {
# fact from the data generated in: ${vardir}/uuid/uuid
'' => "${::gluster_uuid}",
default => "${uuid}",
}
if "${valid_uuid}" == '' {
fail('No valid UUID exists yet!')
} else {
# set a unique uuid per host
file { '/var/lib/glusterd/glusterd.info':
content => template('gluster/glusterd.info.erb'),
owner => root,
group => root,
mode => 600, # u=rw,go=r
seltype => 'glusterd_var_lib_t',
seluser => 'unconfined_u',
ensure => present,
notify => Service['glusterd'],
require => File['/var/lib/glusterd/'],
}
# NOTE: $name here should probably be the fqdn...
@@file { "${vardir}/uuid/uuid_${name}":
content => "${valid_uuid}\n",
tag => 'gluster_uuid',
owner => root,
group => root,
mode => 600,
ensure => present,
}
}
File <<| tag == 'gluster_uuid' |>> { # collect to make facts
}
} else {
$valid_uuid = "${uuid}" ? {
# fact from the data generated in: ${vardir}/uuid/uuid
'' => getvar("gluster_uuid_${name}"), # fact !
default => "${uuid}",
}
if "${valid_uuid}" == '' {
notice('No valid UUID exists yet.') # different msg
} else {
# set uuid=
exec { "/bin/echo 'uuid=${valid_uuid}' >> '/var/lib/glusterd/peers/${valid_uuid}'":
logoutput => on_failure,
unless => "/bin/grep -qF 'uuid=' '/var/lib/glusterd/peers/${valid_uuid}'",
notify => File['/var/lib/glusterd/peers/'], # propagate the notify up
before => File["/var/lib/glusterd/peers/${valid_uuid}"],
alias => "gluster-host-uuid-${name}",
# FIXME: doing this causes a dependency cycle! adding
# the Package[] require doesn't. It would be most
# correct to require the peers/ folder, but since it's
# not working, requiring the Package[] will still give
# us the same result. (Package creates peers/ folder).
# NOTE: it's possible the cycle is a bug in puppet or a
# bug in the dependencies somewhere else in this module.
#require => File['/var/lib/glusterd/peers/'],
require => Package['glusterfs-server'],
}
# set state=
exec { "/bin/echo 'state=3' >> '/var/lib/glusterd/peers/${valid_uuid}'":
logoutput => on_failure,
unless => "/bin/grep -qF 'state=' '/var/lib/glusterd/peers/${valid_uuid}'",
notify => File['/var/lib/glusterd/peers/'], # propagate the notify up
before => File["/var/lib/glusterd/peers/${valid_uuid}"],
require => Exec["gluster-host-uuid-${name}"],
alias => "gluster-host-state-${name}",
}
# set hostname1=...
exec { "/bin/echo 'hostname1=${name}' >> '/var/lib/glusterd/peers/${valid_uuid}'":
logoutput => on_failure,
unless => "/bin/grep -qF 'hostname1=' '/var/lib/glusterd/peers/${valid_uuid}'",
notify => File['/var/lib/glusterd/peers/'], # propagate the notify up
before => File["/var/lib/glusterd/peers/${valid_uuid}"],
require => Exec["gluster-host-state-${name}"],
}
# tag the file so it doesn't get removed by purge
file { "/var/lib/glusterd/peers/${valid_uuid}":
ensure => present,
owner => root,
group => root,
# NOTE: this mode was found by inspecting the process
mode => 600, # u=rw,go=r
seltype => 'glusterd_var_lib_t',
seluser => 'unconfined_u',
notify => File['/var/lib/glusterd/peers/'], # propagate the notify up
}
}
}
}
# vim: ts=8
|
