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
|
"""
cobbler daemon for logging remote syslog traffic during kickstart
Copyright 2007-2009, Red Hat, Inc
Michael DeHaan <mdehaan@redhat.com>
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 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 General Public License for more details.
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., 51 Franklin Street, Fifth Floor, Boston, MA
02110-1301 USA
"""
import sys
import socket
import time
import os
import SimpleXMLRPCServer
import glob
from utils import _
import xmlrpclib
import binascii
import utils
import api as cobbler_api
import yaml # Howell Clark version
import utils
import remote
def main():
core(logger=None)
def core(api):
bootapi = api
settings = bootapi.settings()
xmlrpc_port = settings.xmlrpc_port
regen_ss_file()
do_xmlrpc_tasks(bootapi, settings, xmlrpc_port)
def regen_ss_file():
# this is only used for Kerberos auth at the moment.
# it identifies XMLRPC requests from Apache that have already
# been cleared by Kerberos.
fd = open("/dev/urandom")
data = fd.read(512)
fd.close()
fd = open("/var/lib/cobbler/web.ss","w+")
fd.write(binascii.hexlify(data))
fd.close()
utils.os_system("chmod 700 /var/lib/cobbler/web.ss")
utils.os_system("chown apache /var/lib/cobbler/web.ss")
return 1
def do_xmlrpc_tasks(bootapi, settings, xmlrpc_port):
do_xmlrpc_rw(bootapi, settings, xmlrpc_port)
#def do_other_tasks(bootapi, settings, syslog_port, logger):
#
# # FUTURE: this should also start the Web UI, if the dependencies
# # are available.
#
# if os.path.exists("/usr/bin/avahi-publish-service"):
# pid2 = os.fork()
# if pid2 == 0:
# do_syslog(bootapi, settings, syslog_port, logger)
# else:
# do_avahi(bootapi, settings, logger)
# os.waitpid(pid2, 0)
# else:
# do_syslog(bootapi, settings, syslog_port, logger)
def log(logger,msg):
if logger is not None:
logger.info(msg)
else:
print >>sys.stderr, msg
#def do_avahi(bootapi, settings, logger):
# # publish via zeroconf. This command will not terminate
# log(logger, "publishing avahi service")
# cmd = [ "/usr/bin/avahi-publish-service",
# "cobblerd",
# "_http._tcp",
# "%s" % settings.xmlrpc_port ]
# proc = sub_process.Popen(cmd, shell=False, stderr=sub_process.PIPE, stdout=sub_process.PIPE, close_fds=True)
# proc.communicate()[0]
# log(logger, "avahi service terminated")
def do_xmlrpc_rw(bootapi,settings,port):
xinterface = remote.ProxiedXMLRPCInterface(bootapi,remote.CobblerXMLRPCInterface)
server = remote.CobblerXMLRPCServer(('127.0.0.1', port))
server.logRequests = 0 # don't print stuff
xinterface.logger.debug("XMLRPC running on %s" % port)
server.register_instance(xinterface)
while True:
try:
print "SERVING!"
server.serve_forever()
except IOError:
# interrupted? try to serve again
time.sleep(0.5)
if __name__ == "__main__":
#main()
#bootapi = cobbler_api.BootAPI()
#settings = bootapi.settings()
#syslog_port = settings.syslog_port
#xmlrpc_port = settings.xmlrpc_port
#xmlrpc_port2 = settings.xmlrpc_rw_port
#logger = bootapi.logger_remote
#do_xmlrpc_unix(bootapi, settings, logger)
regen_ss_file()
|
