mirror of
https://github.com/apache/cloudstack.git
synced 2025-10-26 08:42:29 +01:00
91 lines
2.4 KiB
Python
Executable File
91 lines
2.4 KiB
Python
Executable File
#!/usr/bin/python
|
|
#
|
|
# A plugin for executing script needed by vmops cloud
|
|
|
|
import os, sys, time
|
|
import XenAPIPlugin
|
|
sys.path.append("/opt/xensource/sm/")
|
|
import util
|
|
import socket
|
|
|
|
def echo(fn):
|
|
def wrapped(*v, **k):
|
|
name = fn.__name__
|
|
util.SMlog("#### VMOPS enter %s ####" % name )
|
|
res = fn(*v, **k)
|
|
util.SMlog("#### VMOPS exit %s ####" % name )
|
|
return res
|
|
return wrapped
|
|
|
|
@echo
|
|
def copy_vhd_to_secondarystorage(session, args):
|
|
mountpoint = args['mountpoint']
|
|
vdiuuid = args['vdiuuid']
|
|
sruuid = args['sruuid']
|
|
try:
|
|
cmd = ["bash", "/opt/xensource/bin/copy_vhd_to_secondarystorage.sh", mountpoint, vdiuuid, sruuid]
|
|
txt = util.pread2(cmd)
|
|
except:
|
|
txt = '10#failed'
|
|
return txt
|
|
|
|
@echo
|
|
def copy_vhd_from_secondarystorage(session, args):
|
|
mountpoint = args['mountpoint']
|
|
sruuid = args['sruuid']
|
|
try:
|
|
cmd = ["bash", "/opt/xensource/bin/copy_vhd_from_secondarystorage.sh", mountpoint, sruuid]
|
|
txt = util.pread2(cmd)
|
|
except:
|
|
txt = '10#failed'
|
|
return txt
|
|
|
|
@echo
|
|
def setup_heartbeat_sr(session, args):
|
|
host = args['host']
|
|
sr = args['sr']
|
|
try:
|
|
cmd = ["bash", "/opt/xensource/bin/setup_heartbeat_sr.sh", host, sr]
|
|
txt = util.pread2(cmd)
|
|
except:
|
|
txt = ''
|
|
return txt
|
|
|
|
@echo
|
|
def setup_heartbeat_file(session, args):
|
|
host = args['host']
|
|
sr = args['sr']
|
|
try:
|
|
cmd = ["bash", "/opt/xensource/bin/setup_heartbeat_file.sh", host, sr]
|
|
txt = util.pread2(cmd)
|
|
except:
|
|
txt = ''
|
|
return txt
|
|
|
|
@echo
|
|
def check_heartbeat(session, args):
|
|
host = args['host']
|
|
interval = args['interval']
|
|
try:
|
|
cmd = ["bash", "/opt/xensource/bin/check_heartbeat.sh", host, interval]
|
|
txt = util.pread2(cmd)
|
|
except:
|
|
txt=''
|
|
return txt
|
|
|
|
|
|
@echo
|
|
def heartbeat(session, args):
|
|
host = args['host']
|
|
interval = args['interval']
|
|
try:
|
|
cmd = ["/bin/bash", "/opt/xensource/bin/launch_hb.sh", host, interval]
|
|
txt = util.pread2(cmd)
|
|
except:
|
|
txt='fail'
|
|
return txt
|
|
|
|
if __name__ == "__main__":
|
|
XenAPIPlugin.dispatch({"copy_vhd_to_secondarystorage":copy_vhd_to_secondarystorage, "copy_vhd_from_secondarystorage":copy_vhd_from_secondarystorage, "setup_heartbeat_sr":setup_heartbeat_sr, "setup_heartbeat_file":setup_heartbeat_file, "check_heartbeat":check_heartbeat, "heartbeat": heartbeat})
|
|
|