import socket
import os
import sys
import subprocess
import signal
import re
try:
import xml.etree.cElementTree as ET
except ImportError:
import xml.etree.ElementTree as ET
#Exit Code
EXIT_SUCCESS = 0
EXIT_FAILURE = -1
EXIT_STATUS_IDEL = 1
EXIT_STATUS_RUNNING = 2
class gds_entry:
port = -1
name = None
log_file = None
data_dir = None
err_dir = None
data_seg = None
err_seg = None
ctl_file = None
recursive = False
daemon = False
host = None
ip = None
parallel = -1
help = False
def is_valid(self):
if self.help == True:
return True
if self.port < 1024 or self.port > 65535:
return False
if self.data_dir == None:
return False
if self.name == None:
return False
if re.search('^\w+([-+.]\w+)*$', self.name) == None:
return False
return True
def to_str(self):
str = ('name:{0}'.format(self.name))
if self.ip != None:
str += (' ip:{0}'.format(self.ip))
str += (' port:{0:d}'.format(self.port))
str += (' data_dir:{0}'.format(self.dta_dir))
if self.err_dir != None:
str += (' err_dir:{0}'.format(self.drr_dir))
if self.data_seg != None:
str += (' data_seg:{0}'.format(self.data_seg))
if self.err_seg != None:
str += (' err_seg:{0}'.format(self.err_seg))
if self.log_file != None:
str += (' log_file:{0}'.format(self.log_file))
if self.host != None:
str += (' host:{0}'.format(self.host))
if self.recursive == True:
str += ' recursive:{true}'
else:
str += ' recursive:{false}'
if self.daemon == True:
str += ' daemon:{true}'
else:
str += ' daemon:{false}'
if self.enablessl == True:
str += ' enablessl:{true}'
else:
str += ' enablessl:{false}'
if self.parallel != None:
str += (' parallel:{0}'.format(self.parallel))
if self.help == True:
str += ' help:{true}'
else:
str += ' help:{false}'
return str
def usage():
print "gds_ctl.py [start|stop|status]"
#Read the GDS configration
def read_conf(filename):
try:
tree = ET.ElementTree(file=filename)
root = tree.getroot()
gds_array = []
gds_dict = {}
except:
print 'Invalid gds configuration file \"' + filename + '\"'
sys.exit(EXIT_FAILURE)
for cell in root:
entry = gds_entry()
entry.port = int(cell.get('port', '-1'))
entry.data_dir = cell.get('data_dir', None)
entry.err_dir = cell.get('err_dir', None)
entry.data_seg = cell.get('data_seg', None)
entry.err_seg = cell.get('err_seg', None)
entry.recursive = (cell.get('recursive', 'False').lower() == 'true')
entry.daemon = (cell.get('daemon', 'False').lower() == 'true')
entry.help = (cell.get('help', 'False').lower() == 'true')
#make the data_dir as a ABS path
if entry.data_dir != None:
entry.data_dir = entry.data_dir.strip()
if os.path.isabs(entry.data_dir) == False:
entry.data_dir = sys.path[0] + '/' +entry.data_dir
#make the err_dir as a ABS path
if entry.err_dir != None:
entry.err_dir = entry.err_dir.strip()
if os.path.isabs(entry.err_dir) == False:
entry.err_dir = sys.path[0] + '/' +entry.err_dir
entry.name = cell.get('name', None)
entry.ctl_file = '.gds.' + entry.name
entry.log_file = cell.get('log_file', None)
entry.host = cell.get('host', None)
entry.ip = cell.get('ip', None)
entry.parallel = cell.get('parallel', None)
if entry.is_valid() != True:
print 'Invalid item in configuration file \"' + filename + '\"'
sys.exit(EXIT_FAILURE);
gds_array.append(entry)
if gds_dict.has_key(entry.name):
print ('Conflict GDS name \"{0}\"'.format(entry.name))
sys.exit(EXIT_FAILURE)
gds_dict[entry.name] = entry
gds_dict.clear()
return gds_array
#Start GDS
def gds_start(entries):
for cell in entries:
if cell.help == True:
cmd = g_bin_path + '/gds -h'
if subprocess.call(cmd, shell = True) !=0:
return EXIT_FAILURE
else:
return EXIT_SUCCESS
if __is_GDS_exist__(cell):
print (('GDS {0} already exists.').format(cell.name))
return EXIT_FAILURE
#Create the data directory if dosen't exist,
if os.path.exists(cell.data_dir) == False:
os.makedirs(cell.data_dir)
#Create the error log directory if dosen't exist,
if os.path.exists(cell.err_dir) == False:
os.makedirs(cell.err_dir)
if os.path.exists(cell.ctl_file):
subprocess.call(('rm {0}'.format(cell.ctl_file)), shell = True)
cmd = g_bin_path + ('/gds -d {0} -s {1} -D'.format(cell.data_dir, cell.ctl_file))
if cell.ip != None:
cmd += (' -p {0}:{1:d}'.format(cell.ip, cell.port))
else:
cmd += (' -p {0:d}'.format(cell.port))
if cell.log_file != None:
cmd += (' -l {0}'.format(cell.log_file))
if cell.recursive == True:
cmd += ' -r'
if cell.daemon == True:
cmd += ' -D'
if cell.host != None:
cmd += (' -H {0}'.format(cell.host))
if cell.parallel != -1:
cmd += (' -t {0}'.format(cell.parallel))
if cell.err_dir != None:
cmd += (' -e {0}'.format(cell.err_dir))
if cell.data_seg != None:
cmd += (' -S {0}'.format(cell.data_seg))
if cell.err_seg != None:
cmd += (' -E {0}'.format(cell.err_seg))
if subprocess.call(cmd, shell = True) != 0:
print ('Start GDS {0:20s}[ERROR]'.format(cell.name))
return EXIT_FAILURE
print ('Start GDS {0:30s}[OK]'.format(cell.name))
return EXIT_SUCCESS
#Stop the GDS
def gds_stop_entries(entries):
gds_proc = []
out,err = subprocess.Popen(['ps', 'ax'], stdout = subprocess.PIPE).communicate()
for line in out.splitlines():
if 'gds' in line:
gds_proc.append(line)
for cell in entries:
for proc in gds_proc:
if cell.ctl_file in proc.split(' '):
pid = int(proc.split(None, 1)[0])
os.kill(pid, signal.SIGRTMIN)
if (os.path.exists(cell.ctl_file)):
os.system(('rm {0}'.format(cell.ctl_file)))
if __is_GDS_exist__(cell) == False:
print ('Stop GDS {0:32s}[OK]'.format(cell.name))
else:
print ('Stop GDS {0:32s}[ERROR]'.format(cell.name))
return EXIT_SUCCESS
def gds_stop_all():
out,err = subprocess.Popen(['ps', 'ax'], stdout = subprocess.PIPE).communicate()
for line in out.splitlines():
if 'gds' in line and '-p' in line and '-d' in line:
tokens = line.split(' ')
i = 0
for token in tokens:
if token == '-p':
break
i = i + 1
single = tokens[i+1]
pid = int(line.split(None, 1)[0])
os.kill(pid, signal.SIGRTMIN)
if __is_GDS_exist__(pid) == False:
print ('Stop GDS {0:32s}[OK]'.format(single))
else:
print ('Stop GDS {0:32s}[ERROR]'.format(single))
return EXIT_SUCCESS
def gds_stop_single(single):
out,err = subprocess.Popen(['ps', 'ax'], stdout = subprocess.PIPE).communicate()
for line in out.splitlines():
if 'gds' in line and '-p' in line and '-d' in line:
tokens = line.split(' ')
i = 0
dws_client_8.0.x_suse_x64.zip （186个子文件） 
libsasl2.so.3.0.0 137KB libkrb5support_gauss.so.0 58KB libcom_err_gauss.so.3.0 14KB libcrypto.so.1.1 10.55MB libssl.so.1.1 2.5MB libpgport_tool.so.1 968KB libcmclient.so.1 309KB libk5crypto_gauss.so.3.1 206KB libcmpq.so.1 200KB libkrb5support_gauss.so.0.1 58KB libcmcommon.so.2 358KB libgssapi_krb5_gauss.so.2 316KB libgssapi_krb5_gauss.so.2.2 316KB libgssrpc_gauss.so.4.2 131KB libkrb5_gauss.so.3.3 914KB libkrb5_gauss.so.3 914KB libk5crypto_gauss.so.3 206KB libsasl2.so.3 137KB libcom_err_gauss.so.3 14KB libconfig.so.4 188KB libgssrpc_gauss.so.4 131KB libpq.so.5 409KB libpq.so.5.5 409KB libpq.a 1.23MB gds.conf 316B gds 4.88MB Makefile.global 53KB gs_dump 588KB gs_dumpall 282KB gs_restore 323KB gsql 1.88MB install-sh 14KB
pljava.jar 290KB pgxs.mk 8KB nls-global.mk 6KB pg_recvlogical 80KB Makefile.port 487B gds_ctl.py 11KB gds.conf.sample 980B setup.sh 3KB tpcds100x.sh 2KB gsql_env.sh 1KB Makefile.shlib 15KB libcrypto.so 3.3MB utf8_and_gb18030.so 999KB libpgport_tool.so 968KB libkrb5_gauss.so 914KB libssl.so 711KB dict_snowball.so 466KB libpq.so 409KB utf8_and_gbk.so 383KB libcmcommon.so 358KB utf8_and_euc_tw.so 331KB libgssapi_krb5_gauss.so 316KB libpljava.so 312KB libcmclient.so 309KB utf8_and_uhc.so 278KB utf8_and_johab.so 275KB utf8_and_big5.so 223KB utf8_and_euc_jp.so 215KB libk5crypto_gauss.so 206KB libcmpq.so 200KB libconfig.so 188KB utf8_and_euc2004.so 188KB utf8_and_sjis2004.so 187KB libsasl2.so 137KB utf8_and_euc_kr.so 137KB libgssrpc_gauss.so 131KB utf8_and_sjis.so 127KB utf8_and_euc_cn.so 125KB libkrb5support_gauss.so 58KB utf8_and_iso8859.so 39KB utf8_and_win.so 34KB cyrillic_and_mic.so 24KB euc_tw_and_big5.so 18KB euc_jp_and_sjis.so 17KB utf8_and_cyrillic.so 17KB libcom_err_gauss.so 14KB latin2_and_win1250.so 13KB latin_and_mic.so 13KB utf8_and_iso8859_1.so 13KB euc2004_sjis2004.so 13KB euc_kr_and_mic.so 12KB euc_cn_and_mic.so 12KB utf8_and_ascii.so 8KB ascii_and_mic.so 8KB tpcds_load_data_from_obs.sql 75KB Q66.sql 7KB Q14.sql 7KB Q08.sql 6KB Q88.sql 5KB Q04.sql 4KB Q05.sql 4KB Q23.sql 4KB Q49.sql 4KB Q64.sql 3KB Q75.sql 3KB Q77.sql 3KB Q80.sql 3KB Q11.sql 3KB共 186 条
- 1
- 2
资源评论
