diff --git a/manifests/site.pp b/manifests/site.pp index 69a12e3fc5..8c3332758c 100644 --- a/manifests/site.pp +++ b/manifests/site.pp @@ -1307,6 +1307,21 @@ node 'kdc02.openstack.org' { } } +# Node-OS: trusty +node afsdb01.openstack.org/ { + $group = "afsdb" + + class { 'openstack_project::server': + iptables_public_udp_ports => [7000,7002,7003,7004,7005,7006,7007], + sysadmins => hiera('sysadmins', []), + afs => true, + manage_exim => true, + } + + include openstack_project::afsdb + include openstack_project::afsrelease +} + # Node-OS: trusty node /^afsdb.*\.openstack\.org$/ { $group = "afsdb" diff --git a/modules/openstack_project/files/openafs/release-volumes.py b/modules/openstack_project/files/openafs/release-volumes.py new file mode 100644 index 0000000000..605b6202d5 --- /dev/null +++ b/modules/openstack_project/files/openafs/release-volumes.py @@ -0,0 +1,78 @@ +# Copyright 2016 Red Hat, Inc. +# +# Licensed under the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. You may obtain +# a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT +# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the +# License for the specific language governing permissions and limitations +# under the License. + +from datetime import datetime +import re +import subprocess +import logging + +VOLUMES = ['docs', + 'docs.dev', + ] + +log = logging.getLogger("release") + +UPDATE_RE = re.compile("^\s+Last Update (.*)$") + + +def get_last_update(volume): + ret = [] + out = subprocess.check_output(['vos', 'examine', volume, '-localauth']) + state = 0 + for line in out.split('\n'): + if state == 0 and line.startswith(volume): + state = 1 + site = None + elif state == 1: + site = line.strip() + state = 0 + m = UPDATE_RE.match(line) + if m: + ret.append(dict(site=site, + volume=volume, + updated=datetime.strptime(m.group(1), + '%a %b %d %H:%M:%S %Y'))) + + return ret + + +def release(volume): + log.info("Releasing %s" % volume) + subprocess.check_output(['vos', 'release', volume, '-localauth']) + + +def check_release(volume): + log.info("Checking %s" % volume) + rw = get_last_update(volume)[0] + log.debug(" %s %s %s" % (rw['site'], rw['updated'], rw['volume'])) + ros = get_last_update(volume + '.readonly') + update = False + for ro in ros: + log.debug(" %s %s %s" % (ro['site'], ro['updated'], ro['volume'])) + if ro['updated'] < rw['updated']: + update = True + if update: + release(volume) + + +def main(): + logging.basicConfig(level=logging.DEBUG, + format='%(asctime)s %(name)s ' + '%(levelname)-8s %(message)s') + for volume in VOLUMES: + check_release(volume) + + +if __name__ == '__main__': + main() diff --git a/modules/openstack_project/manifests/afsrelease.pp b/modules/openstack_project/manifests/afsrelease.pp new file mode 100644 index 0000000000..39a403c482 --- /dev/null +++ b/modules/openstack_project/manifests/afsrelease.pp @@ -0,0 +1,44 @@ +# Release afs volumes +class openstack_project::afsrelease ( +) { + include logrotate + + file { '/usr/local/bin/release-volumes': + ensure => present, + owner => 'root', + group => 'root', + mode => '0755', + source => 'puppet:///modules/openstack_project/openafs/release-volumes.py', + } + + file { '/var/log/release': + ensure => directory, + owner => 'root', + group => 'root', + mode => '0755', + } + + cron { 'release': + user => 'root', + minute => '*/5', + command => '/usr/local/bin/release-volumes >>/var/log/release/release.log 2>&1', + environment => 'PATH=/usr/local/bin:/usr/bin:/bin:/usr/sbin:/sbin', + require => [ + File['/usr/local/bin/release-volumes'], + ] + } + + logrotate::file { 'release': + ensure => present, + log => '/var/log/release/release.log', + options => ['compress', + 'copytruncate', + 'delaycompress', + 'missingok', + 'rotate 7', + 'daily', + 'notifempty', + ], + require => Cron['release'], + } +}