from emailTxt import mailtxt
from nodeconfig import network_config_to_str
import traceback
-import monitorconfig
+import config
import signal
class Sopen(subprocess.Popen):
args['port'] = self.port
args['user'] = 'root'
args['hostname'] = self.node
- args['monitordir'] = monitorconfig.MONITOR_SCRIPT_ROOT
+ args['monitordir'] = config.MONITOR_SCRIPT_ROOT
ssh_port = 22
if self.nosetup:
import inspect
import shutil
import config
-import config as monitorconfig
DEBUG= 0
-PICKLE_PATH=monitorconfig.MONITOR_DATA_ROOT
+PICKLE_PATH=config.MONITOR_DATA_ROOT
def dbLoad(name, type=None):
api = plc.getAuthAPI()
import sys
import os
-import monitorconfig
+import config
def getconf(hostname, force=False, media=None):
n = api.GetNodes(hostname)
args = {}
if not media:
- args['url_list'] = " http://%s/bootcds/%s-partition.usb\n" % (monitorconfig.MONITOR_HOSTNAME, hostname)
- args['url_list'] += " http://%s/bootcds/%s.iso" % (monitorconfig.MONITOR_HOSTNAME, hostname)
+ args['url_list'] = " http://%s/bootcds/%s-partition.usb\n" % (config.MONITOR_HOSTNAME, hostname)
+ args['url_list'] += " http://%s/bootcds/%s.iso" % (config.MONITOR_HOSTNAME, hostname)
else:
if media == "usb":
- args['url_list'] = " http://%s/bootcds/%s-partition.usb\n" % (monitorconfig.MONITOR_HOSTNAME, hostname)
+ args['url_list'] = " http://%s/bootcds/%s-partition.usb\n" % (config.MONITOR_HOSTNAME, hostname)
elif media == "iso":
- args['url_list'] = " http://%s/bootcds/%s.iso" % (monitorconfig.MONITOR_HOSTNAME, hostname)
+ args['url_list'] = " http://%s/bootcds/%s.iso" % (config.MONITOR_HOSTNAME, hostname)
else:
- args['url_list'] = " http://%s/bootcds/%s-partition.usb\n" % (monitorconfig.MONITOR_HOSTNAME, hostname)
- args['url_list'] += " http://%s/bootcds/%s.iso" % (monitorconfig.MONITOR_HOSTNAME, hostname)
+ args['url_list'] = " http://%s/bootcds/%s-partition.usb\n" % (config.MONITOR_HOSTNAME, hostname)
+ args['url_list'] += " http://%s/bootcds/%s.iso" % (config.MONITOR_HOSTNAME, hostname)
return args
import time
import xml, xmlrpclib
try:
- import monitorconfig
- auth = {'Username' : monitorconfig.API_AUTH_USER,
+ import config
+ auth = {'Username' : config.API_AUTH_USER,
'AuthMethod' : "password",
- 'AuthString' : monitorconfig.API_AUTH_PASSWORD}
+ 'AuthString' : config.API_AUTH_PASSWORD}
except:
import traceback
print traceback.print_exc()
import logging
import os
import time
-import monitorconfig
logger = logging.getLogger("monitor")
def _setupRTenvironment():
- os.environ['PATH'] = os.environ['PATH'] + ":" + monitorconfig.RT_WEB_TOOLS_PATH
- os.environ['RTSERVER'] = monitorconfig.RT_WEB_SERVER
- os.environ['RTUSER'] = monitorconfig.RT_WEB_USER
- os.environ['RTPASSWD'] = monitorconfig.RT_WEB_PASSWORD
- os.environ['RTDEBUG'] = monitorconfig.RT_WEB_DEBUG
+ os.environ['PATH'] = os.environ['PATH'] + ":" + config.RT_WEB_TOOLS_PATH
+ os.environ['RTSERVER'] = config.RT_WEB_SERVER
+ os.environ['RTUSER'] = config.RT_WEB_USER
+ os.environ['RTPASSWD'] = config.RT_WEB_PASSWORD
+ os.environ['RTDEBUG'] = config.RT_WEB_DEBUG
return
def setTicketStatus(ticket_id, status):
fbnode['kernel'] = fbnode['kernel'].split()[2]
fbnode['boot_state'] = fbnode['plcnode']['boot_state']
- if len(fbnode['nodegroups']) > 0:
- fbnode['category'] = fbnode['nodegroups'][0]
+ try:
+ if len(fbnode['nodegroups']) > 0:
+ fbnode['category'] = fbnode['nodegroups'][0]
+ except:
+ #print "ERROR!!!!!!!!!!!!!!!!!!!!!"
+ pass
print "%(hostname)-45s | %(checked)11.11s | %(boot_state)5.5s| %(state)8.8s | %(ssh)5.5s | %(pcu)6.6s | %(bootcd)6.6s | %(category)8.8s | %(kernel)s" % fbnode
else:
# 'vivek@cs.princeton.edu',
]
-import monitorconfig
-api = plc.PLC(monitorconfig.API_AUTH, monitorconfig.API_SERVER)
-api06 = plc.PLC(monitorconfig.API_AUTH06, monitorconfig.API_SERVER06)
+import config
+api = plc.PLC(config.API_AUTH, config.API_SERVER)
+api06 = plc.PLC(config.API_AUTH06, config.API_SERVER06)
# add planetlab-15.cs.princeton.edu, and use the key on the CD.
import re
import database
from threading import *
-import monitorconfig
+import config
# TODO: merge the RT mailer from mailer.py into this file.
# return -1
try:
- rt_db = MySQLdb.connect(host=monitorconfig.RT_DB_HOST,
- user=monitorconfig.RT_DB_USER,
- passwd=monitorconfig.RT_DB_PASSWORD,
- db=monitorconfig.RT_DB_NAME)
+ rt_db = MySQLdb.connect(host=config.RT_DB_HOST,
+ user=config.RT_DB_USER,
+ passwd=config.RT_DB_PASSWORD,
+ db=config.RT_DB_NAME)
except Exception, err:
print "Failed to connect to RT database: %s" %err
return -1
import shutil
import config
-import monitorconfig
+import config
DEBUG= 0
-PICKLE_PATH=monitorconfig.MONITOR_DATA_ROOT
+PICKLE_PATH=config.MONITOR_DATA_ROOT
class ExceptionTimeout(Exception): pass