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
|
#!/usr/bin/python
import libvirt,time
from socket import *
from ssl import *
def print_vm_status(vmname):
# connect to ovirt
domains = { }
conn = libvirt.open('qemu:///system')
#active domains
active_ids = conn.listDomainsID()
for id in active_ids:
dom = conn.lookupByID(id)
id_str = str(id)
name = dom.name()
domains[name] = dom
# inactive domains
for name in conn.listDefinedDomains():
dom = conn.lookupByName(name)
domains[name] = dom
if vmname in domains:
if domains[vmname].isActive():
return "on"
else:
return "off"
else:
return "NaN"
def set_vm_status(vmname,vmstatus):
# check if VM is already in desired status, just return result if yes
if print_vm_status(vmname).lower() == vmstatus.lower():
return vmstatus
else:
#do actual fencing here
if print_vm_status(vmname) in ('on','off'):
conn = libvirt.open('qemu:///system')
dom = conn.lookupByName(vmname)
if vmstatus == "off":
dom.destroy()
return "off"
if vmstatus == "on":
dom.create()
return "on"
else:
#return error if VM not present
return "NaN"
def logprint(msg):
logfile = open('/var/log/fake_ilo.log','a')
logline = time.strftime("[%Y-%m-%d %H:%M:%S] - ") + msg + "\n"
logfile.write(logline)
logfile.close()
#create socket
server_socket=socket(AF_INET, SOCK_STREAM)
username = ''
#Bind to an unused port on the local machine
server_socket.bind(('',1234))
#listen for connection
server_socket.listen (1)
tls_server = wrap_socket(server_socket, ssl_version=PROTOCOL_SSLv23, cert_reqs=CERT_NONE, server_side=True, keyfile='/etc/fake_ilo/server.key', certfile='/etc/fake_ilo/server.crt')
logprint('server started')
while True:
#accept connection
connection, client_address= tls_server.accept()
#server is not finished
finnished =False
emptyresponse=0
#while not finished
while not finnished:
#send and receive data from the client socket
data_in=connection.recv(1024)
message=data_in.decode()
if message=='quit':
finnished= True
else:
#login = VM name
if message.find('USER_LOGIN') > 1:
username=message.split()[3].replace('"', '')
if message.find('xml') > 1:
response='<RIBCL VERSION="2.0"></RIBCL>'
data_out=response.encode()
connection.send(data_out)
# return firmware version
if message.find('GET_FW_VERSION') > 1:
response='<GET_FW_VERSION\r\n FIRMWARE_VERSION="1.91"\r\n MANAGEMENT_PROCESSOR="2.22"\r\n />'
data_out=response.encode()
connection.send(data_out)
# get power status
if message.find('GET_HOST_POWER_STATUS') > 1:
response='HOST_POWER="' + print_vm_status(username) + '"'
logprint('received status request for '+username+' from '+client_address[0]+':'+str(client_address[1])+' - responding with: ' + print_vm_status(username))
data_out=response.encode()
connection.send(data_out)
# set power status
if message.find('SET_HOST_POWER') > 1:
power=message.split()[6].replace('"', '')
response='HOST_POWER="' + set_vm_status(username,power) + '"'
logprint('received fencing command for '+username+' from '+client_address[0]+':'+str(client_address[1])+' - requested status: '+power+ ', status after fencing is: ' + print_vm_status(username))
data_out=response.encode()
connection.send(data_out)
# filter out the rest
else:
if len(message) > 0:
do_nothing = 0
else:
emptyresponse+=1
if emptyresponse > 30:
finnished=True
#close the connection
connection.shutdown(SHUT_RDWR)
connection.close()
#close the server socket
server_socket.shutdown(SHUT_RDWR)
server_socket.close()
|
