root / prepareQMX / prepareQMX.py @ 13
Historique | Voir | Annoter | Télécharger (5,44 ko)
1 |
#!/usr/bin/env python
|
---|---|
2 |
|
3 |
# command line interface for setup of QMX calculations
|
4 |
#
|
5 |
# Torsten Kerber, ENS LYON: 2011, 07, 11
|
6 |
#
|
7 |
# This work is supported by Award No. UK-C0017, made by King Abdullah
|
8 |
# University of Science and Technology (KAUST)
|
9 |
|
10 |
#---------------------------------------------------------------------------------------------------
|
11 |
import os, sys |
12 |
from copy import deepcopy |
13 |
from optparse import OptionParser |
14 |
|
15 |
#---------------------------------------------------------------------------------------------------
|
16 |
from qmxEMBED import embedDefinitions |
17 |
from qmxJOB import jobDefinitions |
18 |
from qmxSTR import strDefinitions |
19 |
from qmxCALC import calcDefinitions, QmxCalcDefinition |
20 |
|
21 |
from qmxWRITE import writeData |
22 |
|
23 |
#---------------------------------------------------------------------------------------------------
|
24 |
#---------------------------------------------------------------------------------------------------
|
25 |
#---------------------------------------------------------------------------------------------------
|
26 |
def getline(section, subsection, lines): |
27 |
nline = -1
|
28 |
for iline in xrange(len(lines)): |
29 |
if lines[iline][0].strip() == subsection: |
30 |
if nline != -1: |
31 |
sys.stderr.write("section: <"+section+separator+subsection+"> has been definied more than once\n") |
32 |
sys.exit(1)
|
33 |
nline = iline |
34 |
if nline == -1: |
35 |
return None |
36 |
return lines[nline][1].strip() |
37 |
|
38 |
#---------------------------------------------------------------------------------------------------
|
39 |
def analyzeSection(definitions, section, lines): |
40 |
line = getline(section, "program", lines)
|
41 |
if line is None: |
42 |
print "section <" + section + "> does not contain program" |
43 |
sys.exit(1)
|
44 |
|
45 |
myDefinition = None
|
46 |
for definition in definitions: |
47 |
if definition.name == line:
|
48 |
myDefinition = deepcopy(definition) |
49 |
break
|
50 |
|
51 |
if myDefinition is None: |
52 |
print "the program <" + line + "> is not defined for the section <" + section + ">" |
53 |
sys.exit(1)
|
54 |
|
55 |
myDefinition.system = section |
56 |
|
57 |
subsections = [] |
58 |
for line in lines: |
59 |
subsections.append(line[0].strip().lower())
|
60 |
|
61 |
for subsection in subsections: |
62 |
line = getline(section, subsection, lines) |
63 |
if line is None: |
64 |
print "input error in <"+section+"."+subsection+">" |
65 |
sys.exit(1)
|
66 |
if subsection == "program": |
67 |
continue
|
68 |
if subsection == "options": |
69 |
subsection = 'class.options'
|
70 |
|
71 |
myDefinition.keywords[subsection] = line |
72 |
print subsection, myDefinition.keywords[subsection]
|
73 |
|
74 |
return myDefinition
|
75 |
|
76 |
#---------------------------------------------------------------------------------------------------
|
77 |
#--- setting default values ------------------------------------------------------------------------
|
78 |
#---------------------------------------------------------------------------------------------------
|
79 |
|
80 |
#define separators
|
81 |
separator=":"
|
82 |
subseparator="."
|
83 |
lineseparator="\n"
|
84 |
|
85 |
#--- parse arguments -------------------------------------------------------------------------------
|
86 |
#parse arguments (python 2.6)
|
87 |
parser = OptionParser() |
88 |
parser.add_option("-i", "--infile", dest="inputFile", help="specifies the input file", metavar="FILE", default="qmx.in") |
89 |
parser.add_option("-o", "--outfile", dest="outputFile", help="specifies the output file", metavar="FILE") |
90 |
parser.add_option("-f", action="store_true", dest="overwrite") |
91 |
(options, args) = parser.parse_args() |
92 |
|
93 |
#--- check wether output file exists ---------------------------------------------------------------
|
94 |
if options.outputFile is not None and os.path.exists(options.outputFile) and not options.overwrite: |
95 |
sys.stderr.write(lineseparator+"the output file <"+options.outputFile+"> already exists"+lineseparator) |
96 |
sys.exit(1)
|
97 |
|
98 |
#--- read intput file ------------------------------------------------------------------------------
|
99 |
file=open(options.inputFile, "r") |
100 |
lines = file.readlines()
|
101 |
file.close()
|
102 |
|
103 |
#--- remove comments -------------------------------------------------------------------------------
|
104 |
for iline in xrange(len(lines)): |
105 |
lines[iline] = lines[iline].split("#")[0] |
106 |
|
107 |
#--- collect data in class -------------------------------------------------------------------------
|
108 |
definitions=[] |
109 |
definitions.append(QmxCalcDefinition()) |
110 |
|
111 |
#--- analyze the input file ------------------------------------------------------------------------
|
112 |
for section in "high-level", "low-level", "cluster", "system", "job": |
113 |
#search lines for section
|
114 |
lines_section=[] |
115 |
for line in lines: |
116 |
line = line.split(separator) |
117 |
if line[0].find(section) >= 0: |
118 |
line[0] = line[0].replace(section+subseparator, "") |
119 |
lines_section.append(line) |
120 |
|
121 |
#calculators
|
122 |
if section == "high-level" or section == "low-level": |
123 |
definitions.append(analyzeSection(calcDefinitions, section, lines_section)) |
124 |
|
125 |
#structures (atoms)
|
126 |
if section == "cluster" or section == "system": |
127 |
definitions.append(analyzeSection(strDefinitions, section, lines_section)) |
128 |
|
129 |
#job
|
130 |
if section == "job": |
131 |
definitions.append(analyzeSection(jobDefinitions, section, lines_section)) |
132 |
|
133 |
#embed
|
134 |
if section == "embed": |
135 |
definitions.append(analyzeSection(embedDefinitions, section, lines_section)) |
136 |
|
137 |
output = None
|
138 |
if options.outputFile is None: |
139 |
output=sys.stdout |
140 |
else:
|
141 |
output=open(options.outputFile, "w") |
142 |
|
143 |
writeData(output, definitions) |
144 |
output.close() |
145 |
|