mirror of
https://github.com/xcat2/xcat-core.git
synced 2025-10-31 11:22:27 +00:00
125 lines
3.5 KiB
Python
125 lines
3.5 KiB
Python
#!/usr/bin/env python
|
|
###############################################################################
|
|
# IBM(c) 2018 EPL license http://www.eclipse.org/legal/epl-v10.html
|
|
###############################################################################
|
|
# -*- coding: utf-8 -*-
|
|
#
|
|
import struct
|
|
import sys
|
|
import inspect
|
|
import re, os
|
|
import logging
|
|
from logging.handlers import SysLogHandler
|
|
|
|
XCAT_LOG_FMT = logging.Formatter("%(asctime)s %(levelname)s " +
|
|
"%(name)s %(process)d " +
|
|
"(%(filename)s:%(lineno)d) "+
|
|
"%(message)s")
|
|
XCAT_LOG_FMT.datefmt = '%Y-%m-%d %H:%M:%S'
|
|
|
|
def getxCATLog(name=None):
|
|
xl = logging.getLogger(name)
|
|
xl.fmt = XCAT_LOG_FMT
|
|
return xl
|
|
|
|
def enableSyslog(name='xcat'):
|
|
try:
|
|
h = SysLogHandler(address='/dev/log', facility=SysLogHandler.LOG_LOCAL4)
|
|
except:
|
|
# this will connect localhost:514
|
|
h = SysLogHandler(facility=SysLogHandler.LOG_LOCAL4)
|
|
h.setFormatter(logging.Formatter('%s: ' % name + '%(levelname)s %(message)s'))
|
|
logging.getLogger('xcatagent').addHandler(h)
|
|
|
|
def int2bytes(num):
|
|
return struct.pack('i', num)
|
|
|
|
|
|
def bytes2int(buf):
|
|
return struct.unpack('i', buf)[0]
|
|
|
|
|
|
def get_classes(module_name):
|
|
ret = []
|
|
for name, obj in inspect.getmembers(sys.modules[module_name]):
|
|
if inspect.isclass(obj):
|
|
ret.append(obj)
|
|
|
|
return ret
|
|
|
|
|
|
def class_func(module_name, class_name):
|
|
func = getattr(sys.modules[module_name], class_name)
|
|
return func
|
|
|
|
|
|
def recv_all(sock, size):
|
|
recv_size = 4096
|
|
buf_size = 0
|
|
buf_parts = []
|
|
while buf_size < size:
|
|
tmp_size = recv_size
|
|
left_size = size - buf_size
|
|
if left_size < recv_size:
|
|
tmp_size = left_size
|
|
buf_part = sock.recv(tmp_size)
|
|
buf_parts.append(buf_part)
|
|
buf_size += len(buf_part)
|
|
buf = ''.join(buf_parts)
|
|
return buf
|
|
|
|
|
|
def update2Ddict(updata_dict, key_a, key_b, value):
|
|
if key_a in updata_dict:
|
|
updata_dict[key_a].update({key_b: value})
|
|
else:
|
|
updata_dict.update({key_a: {key_b: value}})
|
|
|
|
def emb_numbers(string):
|
|
re_digits = re.compile(r'(\d+)')
|
|
pieces = re_digits.split(string)
|
|
pieces[1::2] = map(int,pieces[1::2])
|
|
return pieces
|
|
|
|
def sort_string_with_numbers(origin_list):
|
|
new_list = [(emb_numbers(string),string) for string in origin_list]
|
|
new_list.sort()
|
|
return [string for __,string in new_list]
|
|
|
|
def mask_str2int(mask):
|
|
count_bit = lambda bin_str: len([i for i in bin_str if i=='1'])
|
|
mask_splited = mask.split('.')
|
|
mask_count = [count_bit(bin(int(i))) for i in mask_splited]
|
|
return sum(mask_count)
|
|
|
|
def mask_int2str(mask_int):
|
|
mask_num = (0x1 << 32) - (0x1 << (32 - mask_int))
|
|
return "%s.%s.%s.%s" % (str((mask_num >> 24) & 0xff), str((mask_num >>16)&0xff), str((mask_num >> 8) & 0xff), str(mask_num & 0xff))
|
|
|
|
def get_full_path(cwd, directory):
|
|
if not os.path.isabs(directory):
|
|
directory = os.path.join(cwd, directory)
|
|
return directory
|
|
|
|
class Messager(object):
|
|
def __init__(self, name=None):
|
|
self.logger = logging.getLogger(name or 'xcatagent')
|
|
|
|
def info(self, msg):
|
|
self.logger.info(msg)
|
|
|
|
def warn(self, msg):
|
|
self.logger.warn(msg)
|
|
|
|
def error(self, msg, node=''):
|
|
if node:
|
|
self.logger.error('%s: Error: %s' % (node, msg))
|
|
else:
|
|
self.logger.error('Error: %s' % msg)
|
|
|
|
def syslog(self, msg):
|
|
pass
|
|
|
|
def update_node_attributes(self, attribute, node, data):
|
|
pass
|