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
|
"""
Builds out and synchronizes yum repo mirrors.
Initial support for rsync, perhaps reposync coming later.
Copyright 2006, Red Hat, Inc
Michael DeHaan <mdehaan@redhat.com>
This software may be freely redistributed under the terms of the GNU
general public license.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
"""
import os
import os.path
import shutil
import time
import yaml # Howell-Clark version
import sub_process
import sys
import utils
import cobbler_msg
import cexceptions
import traceback
import errno
class RepoSync:
"""
Handles conversion of internal state to the tftpboot tree layout
"""
def __init__(self,config):
"""
Constructor
"""
self.verbose = True
self.config = config
self.distros = config.distros()
self.profiles = config.profiles()
self.systems = config.systems()
self.settings = config.settings()
self.repos = config.repos()
def run(self,dryrun=False,verbose=True):
"""
Syncs the current repo configuration file with the filesystem.
"""
self.verbose = verbose
self.dryrun = dryrun
for repo in self.repos:
print "considering: %s" % repo
repo_path = os.path.join(repo.root, repo.name)
mirror = repo.mirror
if not os.path.isdir(repo_path):
try:
os.makedirs(repo_path)
except OSError, oe:
if not oe.errno == 17: # already exists, constant for this?
raise cexceptions.CobblerException("no_create", repo_path)
if mirror.startswith("rsync://") or mirror.startswith("ssh://"):
self.do_rsync_repo(repo)
else:
raise cexceptions.CobblerException("no_mirror")
return True
def do_rsync_repo(self,repo):
if not repo.keep_updated:
print "- %s is set to not be updated"
return True
print "imagine an rsync happened here, and that it was amazing..."
dest_path = os.path.join(self.settings.webdir, "repo_mirror", repo.name)
spacer = ""
if repo.mirror.find("ssh://") != -1:
spacer = "-e ssh"
cmd = "rsync -av %s --delete --delete-excluded --exclude-from=/etc/cobbler/rsync.exclude %s %s" % (spacer, repo.mirror, dest_path)
print "executing: %s" % cmd
rc = sub_process.call(cmd, shell=True)
arg = {}
print "- walking: %s" % dest_path
os.path.walk(dest_path, self.createrepo_walker, arg)
if repo.local_filename is not None and repo.local_filename != "":
# this is a rather primative configuration in terms of yum options, but allows
# for repos that were added with a value for --local-filename to provision a system
# using a kickstart that will write the yum config for that repo (named whatever
# was used for local_filename) in /etc/yum.repos.d ... see code in action_sync.py
# that relies on this and for more info about how this is added to %post kickstart
# templating.
config_file = open(os.path.join(dest_path,"config.repo"),"w+")
config_file.write("[%s]\n" % repo.local_filename)
config_file.write("baseurl=http://%s/cobbler/repo_mirror/%s\n" % (self.settings.server, repo.name))
config_file.write("enabled=1\n")
config_file.write("gpgcheck=0\n")
config_file.close()
def createrepo_walker(self, arg, dirname, fname):
target_dir = os.path.dirname(dirname).split("/")[-1]
print "- scanning: %s" % target_dir
if target_dir.lower() in [ "i386", "x86_64", "ia64" ]:
try:
cmd = "createrepo %s" % dirname
print cmd
sub_process.call(cmd, shell=True)
except:
print "- createrepo failed. Is it installed?"
fnames = [] # we're in the right place
|
