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
|
#!/usr/bin/env python
# $Id: $
from syslog import syslog, LOG_INFO
from time import time
from elementtree.ElementTree import Element, tostring
from Bcfg2.Core import Core
from Bcfg2.Metadata import Metadata
from sss.restriction import DataSet, Data
from sss.server import Server
class MetadataStore(object):
def __init__(self):
self.classes = {}
self.images = {'debian-3.1':['topaz']}
self.tags = {'laptop':['topaz']}
self.bundles = {'global':['ssh'], 'tags':{'laptop':[]}, 'hosts':{}}
def GetMetadata(self, client):
tags = [k for (k,v) in self.tags.iteritems() if client in v]
bundles = self.bundles['global'] + self.bundles['hosts'].get(client,[])
bundles += reduce(lambda x,y:x+y, map(lambda b:self.bundles.get(b,[]), tags))
return Metadata(False, self.images[client], bundles, tags, client)
class BcfgServer(Server):
__implementation__ = 'Bcfg2'
__component__ = 'bcfg2'
__dispatch__ = {'get-config':'BuildConfig', 'get-probes':'GetProbes', 'probe-data':'CommitProbeData'}
__statefields__ = ['metadata']
__validate__ = 0
def __setup__(self):
self.metadata = MetadataStore()
self.core=Core('/home/desai/data/b2',['bundler'],['sshbase','fstab','myri','cfg','pkgmgr','servicemgr'])
self.__progress__()
def __progress__(self):
while self.core.fam.fm.pending():
self.core.fam.HandleEvent()
return 1
def BuildConfig(self, xml, (peer,port)):
t = time()
# get metadata for host
config = Element("Configuration", version='2.0')
m = Metadata(False, 'chiba-rh73', [], ['ssh'], [], 'topaz')
structures = self.core.GetStructures(m)
for s in structures:
self.core.BindStructure(s, m)
config.append(s)
#for x in s.getchildren():
# print x.attrib['name'], '\000' in tostring(x)
syslog(LOG_INFO, "Generated config for %s in %s seconds"%(peer, time()-t))
return config
def GetProbes(self, xml, (peer,port)):
return Element("probes")
def CommitProbeData(self, xml, (peer,port)):
return Element("success")
if __name__ == '__main__':
server = BcfgServer()
for i in range(10):
server.__progress__()
|
