##// END OF EJS Templates
schain
RSS
controller from master
José Chávez -
r1055:54f61554a2b5
parent child
Show More
Side by Side Unified
Context file:
r1055:54f61554a2b5 Loading diff...:
Show file before | Show file after | Hide comments
This diff has been collapsed as it changes many lines, (978 lines changed) Show them Hide them
@@ -1,16 +1,12
1 1 '''
2 2 Created on September , 2012
3 @author:
3 @author:
4 4 '''
5
5
6 6 import sys
7 7 import ast
8 8 import datetime
9 9 import traceback
10 import math
11 import time
12 from multiprocessing import Process, Queue, cpu_count
13
14 10 import schainpy
15 11 import schainpy.admin
16 12
@@ -27,141 +23,96 def prettify(elem):
27 23 reparsed = minidom.parseString(rough_string)
28 24 return reparsed.toprettyxml(indent=" ")
29 25
30 def multiSchain(child, nProcess=cpu_count(), startDate=None, endDate=None, by_day=False):
31 skip = 0
32 cursor = 0
33 nFiles = None
34 processes = []
35 dt1 = datetime.datetime.strptime(startDate, '%Y/%m/%d')
36 dt2 = datetime.datetime.strptime(endDate, '%Y/%m/%d')
37 days = (dt2 - dt1).days
38
39 for day in range(days+1):
40 skip = 0
41 cursor = 0
42 q = Queue()
43 processes = []
44 dt = (dt1 + datetime.timedelta(day)).strftime('%Y/%m/%d')
45 firstProcess = Process(target=child, args=(cursor, skip, q, dt))
46 firstProcess.start()
47 if by_day:
48 continue
49 nFiles = q.get()
50 firstProcess.terminate()
51 skip = int(math.ceil(nFiles/nProcess))
52 while True:
53 processes.append(Process(target=child, args=(cursor, skip, q, dt)))
54 processes[cursor].start()
55 if nFiles < cursor*skip:
56 break
57 cursor += 1
58
59 def beforeExit(exctype, value, trace):
60 for process in processes:
61 process.terminate()
62 process.join()
63 print traceback.print_tb(trace)
64
65 sys.excepthook = beforeExit
66
67 for process in processes:
68 process.join()
69 process.terminate()
70 time.sleep(3)
71
72 26 class ParameterConf():
73
27
74 28 id = None
75 29 name = None
76 30 value = None
77 31 format = None
78
32
79 33 __formated_value = None
80
34
81 35 ELEMENTNAME = 'Parameter'
82
36
83 37 def __init__(self):
84
38
85 39 self.format = 'str'
86
40
87 41 def getElementName(self):
88
42
89 43 return self.ELEMENTNAME
90
44
91 45 def getValue(self):
92 46
93 47 value = self.value
94 48 format = self.format
95
49
96 50 if self.__formated_value != None:
97
51
98 52 return self.__formated_value
99
100 if format == 'obj':
101 return value
102
53
103 54 if format == 'str':
104 55 self.__formated_value = str(value)
105 56 return self.__formated_value
106
57
107 58 if value == '':
108 59 raise ValueError, "%s: This parameter value is empty" %self.name
109
60
110 61 if format == 'list':
111 62 strList = value.split(',')
112
63
113 64 self.__formated_value = strList
114
65
115 66 return self.__formated_value
116
67
117 68 if format == 'intlist':
118 69 """
119 70 Example:
120 71 value = (0,1,2)
121 72 """
122
73
123 74 new_value = ast.literal_eval(value)
124
75
125 76 if type(new_value) not in (tuple, list):
126 77 new_value = [int(new_value)]
127
78
128 79 self.__formated_value = new_value
129
80
130 81 return self.__formated_value
131
82
132 83 if format == 'floatlist':
133 84 """
134 85 Example:
135 86 value = (0.5, 1.4, 2.7)
136 87 """
137
88
138 89 new_value = ast.literal_eval(value)
139
90
140 91 if type(new_value) not in (tuple, list):
141 92 new_value = [float(new_value)]
142
93
143 94 self.__formated_value = new_value
144
95
145 96 return self.__formated_value
146
97
147 98 if format == 'date':
148 99 strList = value.split('/')
149 100 intList = [int(x) for x in strList]
150 101 date = datetime.date(intList[0], intList[1], intList[2])
151
102
152 103 self.__formated_value = date
153
104
154 105 return self.__formated_value
155
106
156 107 if format == 'time':
157 108 strList = value.split(':')
158 109 intList = [int(x) for x in strList]
159 110 time = datetime.time(intList[0], intList[1], intList[2])
160
111
161 112 self.__formated_value = time
162
113
163 114 return self.__formated_value
164
115
165 116 if format == 'pairslist':
166 117 """
167 118 Example:
@@ -169,483 +120,463 class ParameterConf():
169 120 """
170 121
171 122 new_value = ast.literal_eval(value)
172
123
173 124 if type(new_value) not in (tuple, list):
174 125 raise ValueError, "%s has to be a tuple or list of pairs" %value
175
126
176 127 if type(new_value[0]) not in (tuple, list):
177 128 if len(new_value) != 2:
178 129 raise ValueError, "%s has to be a tuple or list of pairs" %value
179 130 new_value = [new_value]
180
131
181 132 for thisPair in new_value:
182 133 if len(thisPair) != 2:
183 134 raise ValueError, "%s has to be a tuple or list of pairs" %value
184
135
185 136 self.__formated_value = new_value
186
137
187 138 return self.__formated_value
188
139
189 140 if format == 'multilist':
190 141 """
191 142 Example:
192 143 value = (0,1,2),(3,4,5)
193 144 """
194 145 multiList = ast.literal_eval(value)
195
146
196 147 if type(multiList[0]) == int:
197 148 multiList = ast.literal_eval("(" + value + ")")
198
149
199 150 self.__formated_value = multiList
200
151
201 152 return self.__formated_value
202
153
203 154 if format == 'bool':
204 155 value = int(value)
205
156
206 157 if format == 'int':
207 158 value = float(value)
208
159
209 160 format_func = eval(format)
210
161
211 162 self.__formated_value = format_func(value)
212
163
213 164 return self.__formated_value
214 165
215 166 def updateId(self, new_id):
216
167
217 168 self.id = str(new_id)
218
169
219 170 def setup(self, id, name, value, format='str'):
171
220 172 self.id = str(id)
221 173 self.name = name
222 if format == 'obj':
223 self.value = value
224 else:
225 self.value = str(value)
174 self.value = str(value)
226 175 self.format = str.lower(format)
227
176
228 177 self.getValue()
229
178
230 179 return 1
231
180
232 181 def update(self, name, value, format='str'):
233
182
234 183 self.name = name
235 184 self.value = str(value)
236 185 self.format = format
237
186
238 187 def makeXml(self, opElement):
239 if self.name not in ('queue',):
240 parmElement = SubElement(opElement, self.ELEMENTNAME)
241 parmElement.set('id', str(self.id))
242 parmElement.set('name', self.name)
243 parmElement.set('value', self.value)
244 parmElement.set('format', self.format)
245
188
189 parmElement = SubElement(opElement, self.ELEMENTNAME)
190 parmElement.set('id', str(self.id))
191 parmElement.set('name', self.name)
192 parmElement.set('value', self.value)
193 parmElement.set('format', self.format)
194
246 195 def readXml(self, parmElement):
247
196
248 197 self.id = parmElement.get('id')
249 198 self.name = parmElement.get('name')
250 199 self.value = parmElement.get('value')
251 200 self.format = str.lower(parmElement.get('format'))
252
201
253 202 #Compatible with old signal chain version
254 203 if self.format == 'int' and self.name == 'idfigure':
255 204 self.name = 'id'
256
205
257 206 def printattr(self):
258
207
259 208 print "Parameter[%s]: name = %s, value = %s, format = %s" %(self.id, self.name, self.value, self.format)
260 209
261 210 class OperationConf():
262
211
263 212 id = None
264 213 name = None
265 214 priority = None
266 215 type = None
267
216
268 217 parmConfObjList = []
269
218
270 219 ELEMENTNAME = 'Operation'
271
220
272 221 def __init__(self):
273
222
274 223 self.id = '0'
275 224 self.name = None
276 225 self.priority = None
277 226 self.type = 'self'
278
279
227
228
280 229 def __getNewId(self):
281
230
282 231 return int(self.id)*10 + len(self.parmConfObjList) + 1
283 232
284 233 def updateId(self, new_id):
285
234
286 235 self.id = str(new_id)
287
236
288 237 n = 1
289 238 for parmObj in self.parmConfObjList:
290
239
291 240 idParm = str(int(new_id)*10 + n)
292 241 parmObj.updateId(idParm)
293
242
294 243 n += 1
295
244
296 245 def getElementName(self):
297
246
298 247 return self.ELEMENTNAME
299
248
300 249 def getParameterObjList(self):
301
250
302 251 return self.parmConfObjList
303
252
304 253 def getParameterObj(self, parameterName):
305
254
306 255 for parmConfObj in self.parmConfObjList:
307
256
308 257 if parmConfObj.name != parameterName:
309 258 continue
310
259
311 260 return parmConfObj
312
261
313 262 return None
314 263
315 264 def getParameterObjfromValue(self, parameterValue):
316
265
317 266 for parmConfObj in self.parmConfObjList:
318
267
319 268 if parmConfObj.getValue() != parameterValue:
320 269 continue
321
270
322 271 return parmConfObj.getValue()
323
272
324 273 return None
325
274
326 275 def getParameterValue(self, parameterName):
327
276
328 277 parameterObj = self.getParameterObj(parameterName)
329 278
330 279 # if not parameterObj:
331 280 # return None
332 281
333 282 value = parameterObj.getValue()
334
283
335 284 return value
336
337
338 def getKwargs(self):
339
340 kwargs = {}
341
342 for parmConfObj in self.parmConfObjList:
343 if self.name == 'run' and parmConfObj.name == 'datatype':
344 continue
345
346 kwargs[parmConfObj.name] = parmConfObj.getValue()
347
348 return kwargs
349
285
350 286 def setup(self, id, name, priority, type):
351
287
352 288 self.id = str(id)
353 289 self.name = name
354 290 self.type = type
355 291 self.priority = priority
356
292
357 293 self.parmConfObjList = []
358
294
359 295 def removeParameters(self):
360
296
361 297 for obj in self.parmConfObjList:
362 298 del obj
363
299
364 300 self.parmConfObjList = []
365
301
366 302 def addParameter(self, name, value, format='str'):
367
303
368 304 id = self.__getNewId()
369
305
370 306 parmConfObj = ParameterConf()
371 307 if not parmConfObj.setup(id, name, value, format):
372 308 return None
373
309
374 310 self.parmConfObjList.append(parmConfObj)
375
311
376 312 return parmConfObj
377
313
378 314 def changeParameter(self, name, value, format='str'):
379
315
380 316 parmConfObj = self.getParameterObj(name)
381 317 parmConfObj.update(name, value, format)
382
318
383 319 return parmConfObj
384
320
385 321 def makeXml(self, procUnitElement):
386
322
387 323 opElement = SubElement(procUnitElement, self.ELEMENTNAME)
388 324 opElement.set('id', str(self.id))
389 325 opElement.set('name', self.name)
390 326 opElement.set('type', self.type)
391 327 opElement.set('priority', str(self.priority))
392
328
393 329 for parmConfObj in self.parmConfObjList:
394 330 parmConfObj.makeXml(opElement)
395
331
396 332 def readXml(self, opElement):
397
333
398 334 self.id = opElement.get('id')
399 335 self.name = opElement.get('name')
400 336 self.type = opElement.get('type')
401 337 self.priority = opElement.get('priority')
402
338
403 339 #Compatible with old signal chain version
404 340 #Use of 'run' method instead 'init'
405 341 if self.type == 'self' and self.name == 'init':
406 342 self.name = 'run'
407
343
408 344 self.parmConfObjList = []
409
345
410 346 parmElementList = opElement.iter(ParameterConf().getElementName())
411
347
412 348 for parmElement in parmElementList:
413 349 parmConfObj = ParameterConf()
414 350 parmConfObj.readXml(parmElement)
415
351
416 352 #Compatible with old signal chain version
417 353 #If an 'plot' OPERATION is found, changes name operation by the value of its type PARAMETER
418 354 if self.type != 'self' and self.name == 'Plot':
419 355 if parmConfObj.format == 'str' and parmConfObj.name == 'type':
420 356 self.name = parmConfObj.value
421 357 continue
422
358
423 359 self.parmConfObjList.append(parmConfObj)
424
360
425 361 def printattr(self):
426
362
427 363 print "%s[%s]: name = %s, type = %s, priority = %s" %(self.ELEMENTNAME,
428 364 self.id,
429 365 self.name,
430 366 self.type,
431 367 self.priority)
432
368
433 369 for parmConfObj in self.parmConfObjList:
434 370 parmConfObj.printattr()
435
371
436 372 def createObject(self, plotter_queue=None):
437
438
373
439 374 if self.type == 'self':
440 375 raise ValueError, "This operation type cannot be created"
441
376
442 377 if self.type == 'plotter':
443 378 #Plotter(plotter_name)
444 379 if not plotter_queue:
445 380 raise ValueError, "plotter_queue is not defined. Use:\nmyProject = Project()\nmyProject.setPlotterQueue(plotter_queue)"
446
381
447 382 opObj = Plotter(self.name, plotter_queue)
448
383
449 384 if self.type == 'external' or self.type == 'other':
450
451 385 className = eval(self.name)
452 kwargs = self.getKwargs()
453
454 opObj = className(**kwargs)
455
386 opObj = className()
387
456 388 return opObj
457
458
389
459 390 class ProcUnitConf():
460
391
461 392 id = None
462 393 name = None
463 394 datatype = None
464 395 inputId = None
465 396 parentId = None
466
397
467 398 opConfObjList = []
468
399
469 400 procUnitObj = None
470 401 opObjList = []
471
402
472 403 ELEMENTNAME = 'ProcUnit'
473
404
474 405 def __init__(self):
475
406
476 407 self.id = None
477 408 self.datatype = None
478 409 self.name = None
479 410 self.inputId = None
480
411
481 412 self.opConfObjList = []
482
413
483 414 self.procUnitObj = None
484 415 self.opObjDict = {}
485
416
486 417 def __getPriority(self):
487
418
488 419 return len(self.opConfObjList)+1
489
420
490 421 def __getNewId(self):
491
422
492 423 return int(self.id)*10 + len(self.opConfObjList) + 1
493
424
494 425 def getElementName(self):
495
426
496 427 return self.ELEMENTNAME
497
428
498 429 def getId(self):
499
430
500 431 return self.id
501 432
502 433 def updateId(self, new_id, parentId=parentId):
503
504
434
435
505 436 new_id = int(parentId)*10 + (int(self.id) % 10)
506 437 new_inputId = int(parentId)*10 + (int(self.inputId) % 10)
507
438
508 439 #If this proc unit has not inputs
509 440 if self.inputId == '0':
510 441 new_inputId = 0
511
442
512 443 n = 1
513 444 for opConfObj in self.opConfObjList:
514
445
515 446 idOp = str(int(new_id)*10 + n)
516 447 opConfObj.updateId(idOp)
517
448
518 449 n += 1
519
450
520 451 self.parentId = str(parentId)
521 452 self.id = str(new_id)
522 453 self.inputId = str(new_inputId)
523
524
454
455
525 456 def getInputId(self):
526
457
527 458 return self.inputId
528
459
529 460 def getOperationObjList(self):
530
461
531 462 return self.opConfObjList
532
463
533 464 def getOperationObj(self, name=None):
534
465
535 466 for opConfObj in self.opConfObjList:
536
467
537 468 if opConfObj.name != name:
538 469 continue
539
470
540 471 return opConfObj
541
472
542 473 return None
543
474
544 475 def getOpObjfromParamValue(self, value=None):
545
476
546 477 for opConfObj in self.opConfObjList:
547 478 if opConfObj.getParameterObjfromValue(parameterValue=value) != value:
548 479 continue
549 480 return opConfObj
550 481 return None
551
482
552 483 def getProcUnitObj(self):
553
484
554 485 return self.procUnitObj
555
486
556 487 def setup(self, id, name, datatype, inputId, parentId=None):
557
488
558 489 #Compatible with old signal chain version
559 490 if datatype==None and name==None:
560 491 raise ValueError, "datatype or name should be defined"
561
492
562 493 if name==None:
563 494 if 'Proc' in datatype:
564 495 name = datatype
565 496 else:
566 497 name = '%sProc' %(datatype)
567
498
568 499 if datatype==None:
569 500 datatype = name.replace('Proc','')
570
501
571 502 self.id = str(id)
572 503 self.name = name
573 504 self.datatype = datatype
574 505 self.inputId = inputId
575 506 self.parentId = parentId
576
507
577 508 self.opConfObjList = []
578
509
579 510 self.addOperation(name='run', optype='self')
580
511
581 512 def removeOperations(self):
582
513
583 514 for obj in self.opConfObjList:
584 515 del obj
585
516
586 517 self.opConfObjList = []
587 518 self.addOperation(name='run')
588
519
589 520 def addParameter(self, **kwargs):
590 521 '''
591 522 Add parameters to "run" operation
592 523 '''
593 524 opObj = self.opConfObjList[0]
594
525
595 526 opObj.addParameter(**kwargs)
596
527
597 528 return opObj
598
529
599 530 def addOperation(self, name, optype='self'):
600
531
601 532 id = self.__getNewId()
602 priority = self.__getPriority()
603
533 priority = self.__getPriority()
534
604 535 opConfObj = OperationConf()
605 536 opConfObj.setup(id, name=name, priority=priority, type=optype)
606
537
607 538 self.opConfObjList.append(opConfObj)
608
539
609 540 return opConfObj
610
541
611 542 def makeXml(self, projectElement):
612
543
613 544 procUnitElement = SubElement(projectElement, self.ELEMENTNAME)
614 545 procUnitElement.set('id', str(self.id))
615 546 procUnitElement.set('name', self.name)
616 547 procUnitElement.set('datatype', self.datatype)
617 548 procUnitElement.set('inputId', str(self.inputId))
618
549
619 550 for opConfObj in self.opConfObjList:
620 551 opConfObj.makeXml(procUnitElement)
621
552
622 553 def readXml(self, upElement):
623
554
624 555 self.id = upElement.get('id')
625 556 self.name = upElement.get('name')
626 557 self.datatype = upElement.get('datatype')
627 558 self.inputId = upElement.get('inputId')
628
559
629 560 if self.ELEMENTNAME == "ReadUnit":
630 561 self.datatype = self.datatype.replace("Reader", "")
631
562
632 563 if self.ELEMENTNAME == "ProcUnit":
633 564 self.datatype = self.datatype.replace("Proc", "")
634
565
635 566 if self.inputId == 'None':
636 567 self.inputId = '0'
637
568
638 569 self.opConfObjList = []
639
570
640 571 opElementList = upElement.iter(OperationConf().getElementName())
641
572
642 573 for opElement in opElementList:
643 574 opConfObj = OperationConf()
644 575 opConfObj.readXml(opElement)
645 576 self.opConfObjList.append(opConfObj)
646
577
647 578 def printattr(self):
648
579
649 580 print "%s[%s]: name = %s, datatype = %s, inputId = %s" %(self.ELEMENTNAME,
650 581 self.id,
651 582 self.name,
@@ -654,54 +585,41 class ProcUnitConf():
654 585
655 586 for opConfObj in self.opConfObjList:
656 587 opConfObj.printattr()
657
658
659 def getKwargs(self):
660
661 opObj = self.opConfObjList[0]
662 kwargs = opObj.getKwargs()
663
664 return kwargs
665
588
666 589 def createObjects(self, plotter_queue=None):
667
590
668 591 className = eval(self.name)
669 kwargs = self.getKwargs()
670 procUnitObj = className(**kwargs)
671
592 procUnitObj = className()
593
672 594 for opConfObj in self.opConfObjList:
673
674 if opConfObj.type=='self' and self.name=='run':
675 continue
676 elif opConfObj.type=='self':
677 procUnitObj.addOperationKwargs(opConfObj.id, **opConfObj.getKwargs())
595
596 if opConfObj.type == 'self':
678 597 continue
679
598
680 599 opObj = opConfObj.createObject(plotter_queue)
681
600
682 601 self.opObjDict[opConfObj.id] = opObj
683
684 602 procUnitObj.addOperation(opObj, opConfObj.id)
685
603
686 604 self.procUnitObj = procUnitObj
687
605
688 606 return procUnitObj
689
607
690 608 def run(self):
691
609
692 610 is_ok = False
693
611
694 612 for opConfObj in self.opConfObjList:
695
613
696 614 kwargs = {}
697 615 for parmConfObj in opConfObj.getParameterObjList():
698 616 if opConfObj.name == 'run' and parmConfObj.name == 'datatype':
699 617 continue
700
618
701 619 kwargs[parmConfObj.name] = parmConfObj.getValue()
702
620
703 621 #ini = time.time()
704
622
705 623 #print "\tRunning the '%s' operation with %s" %(opConfObj.name, opConfObj.id)
706 624 sts = self.procUnitObj.call(opType = opConfObj.type,
707 625 opName = opConfObj.name,
@@ -714,50 +632,49 class ProcUnitConf():
714 632 # print "%s::%s took %f seconds" %(self.name, opConfObj.name, total_time)
715 633
716 634 is_ok = is_ok or sts
717
635
718 636 return is_ok
719 637
720 638 def close(self):
721
639
722 640 for opConfObj in self.opConfObjList:
723 641 if opConfObj.type == 'self':
724 642 continue
725
643
726 644 opObj = self.procUnitObj.getOperationObj(opConfObj.id)
727 645 opObj.close()
728
646
729 647 self.procUnitObj.close()
730
648
731 649 return
732 650
733 651 class ReadUnitConf(ProcUnitConf):
734
652
735 653 path = None
736 654 startDate = None
737 655 endDate = None
738 656 startTime = None
739 657 endTime = None
740
658
741 659 ELEMENTNAME = 'ReadUnit'
742
660
743 661 def __init__(self):
744
662
745 663 self.id = None
746 664 self.datatype = None
747 665 self.name = None
748 666 self.inputId = None
749
667
750 668 self.parentId = None
751
669
752 670 self.opConfObjList = []
753 671 self.opObjList = []
754
672
755 673 def getElementName(self):
756
674
757 675 return self.ELEMENTNAME
758
759 def setup(self, id, name, datatype, path='', startDate="", endDate="", startTime="",
760 endTime="", parentId=None, queue=None, server=None, **kwargs):
676
677 def setup(self, id, name, datatype, path, startDate="", endDate="", startTime="", endTime="", parentId=None, **kwargs):
761 678
762 679 #Compatible with old signal chain version
763 680 if datatype==None and name==None:
@@ -768,40 +685,40 class ReadUnitConf(ProcUnitConf):
768 685 name = datatype
769 686 else:
770 687 name = '%sReader' %(datatype)
688
771 689 if datatype==None:
772 690 datatype = name.replace('Reader','')
773
691
774 692 self.id = id
775 693 self.name = name
776 694 self.datatype = datatype
777 if path != '':
778 self.path = os.path.abspath(path)
695
696 self.path = os.path.abspath(path)
779 697 self.startDate = startDate
780 698 self.endDate = endDate
781 699 self.startTime = startTime
782 700 self.endTime = endTime
783
701
784 702 self.inputId = '0'
785 703 self.parentId = parentId
786 self.queue = queue
787 self.server = server
704
788 705 self.addRunOperation(**kwargs)
789
706
790 707 def update(self, datatype, path, startDate, endDate, startTime, endTime, parentId=None, name=None, **kwargs):
791 708
792 709 #Compatible with old signal chain version
793 710 if datatype==None and name==None:
794 711 raise ValueError, "datatype or name should be defined"
795
712
796 713 if name==None:
797 714 if 'Reader' in datatype:
798 715 name = datatype
799 716 else:
800 717 name = '%sReader' %(datatype)
801
718
802 719 if datatype==None:
803 720 datatype = name.replace('Reader','')
804
721
805 722 self.datatype = datatype
806 723 self.name = name
807 724 self.path = path
@@ -809,54 +726,50 class ReadUnitConf(ProcUnitConf):
809 726 self.endDate = endDate
810 727 self.startTime = startTime
811 728 self.endTime = endTime
812
729
813 730 self.inputId = '0'
814 731 self.parentId = parentId
815
732
816 733 self.updateRunOperation(**kwargs)
817
734
818 735 def removeOperations(self):
819
736
820 737 for obj in self.opConfObjList:
821 738 del obj
822
739
823 740 self.opConfObjList = []
824
741
825 742 def addRunOperation(self, **kwargs):
826
743
827 744 opObj = self.addOperation(name = 'run', optype = 'self')
828
829 if self.server is None:
830 opObj.addParameter(name='datatype' , value=self.datatype, format='str')
831 opObj.addParameter(name='path' , value=self.path, format='str')
832 opObj.addParameter(name='startDate' , value=self.startDate, format='date')
833 opObj.addParameter(name='endDate' , value=self.endDate, format='date')
834 opObj.addParameter(name='startTime' , value=self.startTime, format='time')
835 opObj.addParameter(name='endTime' , value=self.endTime, format='time')
836 opObj.addParameter(name='queue' , value=self.queue, format='obj')
837 for key, value in kwargs.items():
838 opObj.addParameter(name=key, value=value, format=type(value).__name__)
839 else:
840 opObj.addParameter(name='server' , value=self.server, format='str')
841 745
842
746 opObj.addParameter(name='datatype' , value=self.datatype, format='str')
747 opObj.addParameter(name='path' , value=self.path, format='str')
748 opObj.addParameter(name='startDate' , value=self.startDate, format='date')
749 opObj.addParameter(name='endDate' , value=self.endDate, format='date')
750 opObj.addParameter(name='startTime' , value=self.startTime, format='time')
751 opObj.addParameter(name='endTime' , value=self.endTime, format='time')
752
753 for key, value in kwargs.items():
754 opObj.addParameter(name=key, value=value, format=type(value).__name__)
755
843 756 return opObj
844
757
845 758 def updateRunOperation(self, **kwargs):
846
759
847 760 opObj = self.getOperationObj(name = 'run')
848 761 opObj.removeParameters()
849
762
850 763 opObj.addParameter(name='datatype' , value=self.datatype, format='str')
851 764 opObj.addParameter(name='path' , value=self.path, format='str')
852 765 opObj.addParameter(name='startDate' , value=self.startDate, format='date')
853 766 opObj.addParameter(name='endDate' , value=self.endDate, format='date')
854 767 opObj.addParameter(name='startTime' , value=self.startTime, format='time')
855 768 opObj.addParameter(name='endTime' , value=self.endTime, format='time')
856
769
857 770 for key, value in kwargs.items():
858 771 opObj.addParameter(name=key, value=value, format=type(value).__name__)
859
772
860 773 return opObj
861 774
862 775 # def makeXml(self, projectElement):
@@ -871,314 +784,314 class ReadUnitConf(ProcUnitConf):
871 784 # opConfObj.makeXml(procUnitElement)
872 785
873 786 def readXml(self, upElement):
874
787
875 788 self.id = upElement.get('id')
876 789 self.name = upElement.get('name')
877 790 self.datatype = upElement.get('datatype')
878 791 self.inputId = upElement.get('inputId')
879
792
880 793 if self.ELEMENTNAME == "ReadUnit":
881 794 self.datatype = self.datatype.replace("Reader", "")
882
795
883 796 if self.inputId == 'None':
884 797 self.inputId = '0'
885
798
886 799 self.opConfObjList = []
887
800
888 801 opElementList = upElement.iter(OperationConf().getElementName())
889
802
890 803 for opElement in opElementList:
891 804 opConfObj = OperationConf()
892 805 opConfObj.readXml(opElement)
893 806 self.opConfObjList.append(opConfObj)
894
807
895 808 if opConfObj.name == 'run':
896 809 self.path = opConfObj.getParameterValue('path')
897 810 self.startDate = opConfObj.getParameterValue('startDate')
898 811 self.endDate = opConfObj.getParameterValue('endDate')
899 812 self.startTime = opConfObj.getParameterValue('startTime')
900 813 self.endTime = opConfObj.getParameterValue('endTime')
901
814
902 815 class Project():
903
816
904 817 id = None
905 818 name = None
906 819 description = None
907 820 filename = None
908
821
909 822 procUnitConfObjDict = None
910
823
911 824 ELEMENTNAME = 'Project'
912
825
913 826 plotterQueue = None
914
827
915 828 def __init__(self, plotter_queue=None):
916
829
917 830 self.id = None
918 831 self.name = None
919 832 self.description = None
920
833
921 834 self.plotterQueue = plotter_queue
922
835
923 836 self.procUnitConfObjDict = {}
924
837
925 838 def __getNewId(self):
926
839
927 840 idList = self.procUnitConfObjDict.keys()
928
841
929 842 id = int(self.id)*10
930
843
931 844 while True:
932 845 id += 1
933
846
934 847 if str(id) in idList:
935 848 continue
936
849
937 850 break
938
851
939 852 return str(id)
940
853
941 854 def getElementName(self):
942
855
943 856 return self.ELEMENTNAME
944 857
945 858 def getId(self):
946
859
947 860 return self.id
948
861
949 862 def updateId(self, new_id):
950
863
951 864 self.id = str(new_id)
952
865
953 866 keyList = self.procUnitConfObjDict.keys()
954 867 keyList.sort()
955
868
956 869 n = 1
957 870 newProcUnitConfObjDict = {}
958
871
959 872 for procKey in keyList:
960
873
961 874 procUnitConfObj = self.procUnitConfObjDict[procKey]
962 875 idProcUnit = str(int(self.id)*10 + n)
963 876 procUnitConfObj.updateId(idProcUnit, parentId = self.id)
964
877
965 878 newProcUnitConfObjDict[idProcUnit] = procUnitConfObj
966 879 n += 1
967
880
968 881 self.procUnitConfObjDict = newProcUnitConfObjDict
969
882
970 883 def setup(self, id, name, description):
971
884
972 885 self.id = str(id)
973 886 self.name = name
974 887 self.description = description
975 888
976 889 def update(self, name, description):
977
890
978 891 self.name = name
979 892 self.description = description
980
893
981 894 def addReadUnit(self, id=None, datatype=None, name=None, **kwargs):
982
895
983 896 if id is None:
984 897 idReadUnit = self.__getNewId()
985 898 else:
986 899 idReadUnit = str(id)
987
900
988 901 readUnitConfObj = ReadUnitConf()
989 902 readUnitConfObj.setup(idReadUnit, name, datatype, parentId=self.id, **kwargs)
990
903
991 904 self.procUnitConfObjDict[readUnitConfObj.getId()] = readUnitConfObj
992
905
993 906 return readUnitConfObj
994
907
995 908 def addProcUnit(self, inputId='0', datatype=None, name=None):
996
909
997 910 idProcUnit = self.__getNewId()
998
911
999 912 procUnitConfObj = ProcUnitConf()
1000 913 procUnitConfObj.setup(idProcUnit, name, datatype, inputId, parentId=self.id)
1001
914
1002 915 self.procUnitConfObjDict[procUnitConfObj.getId()] = procUnitConfObj
1003
916
1004 917 return procUnitConfObj
1005
918
1006 919 def removeProcUnit(self, id):
1007
920
1008 921 if id in self.procUnitConfObjDict.keys():
1009 922 self.procUnitConfObjDict.pop(id)
1010
923
1011 924 def getReadUnitId(self):
1012
925
1013 926 readUnitConfObj = self.getReadUnitObj()
1014
927
1015 928 return readUnitConfObj.id
1016
929
1017 930 def getReadUnitObj(self):
1018
931
1019 932 for obj in self.procUnitConfObjDict.values():
1020 933 if obj.getElementName() == "ReadUnit":
1021 934 return obj
1022
935
1023 936 return None
1024
937
1025 938 def getProcUnitObj(self, id=None, name=None):
1026
939
1027 940 if id != None:
1028 941 return self.procUnitConfObjDict[id]
1029
942
1030 943 if name != None:
1031 944 return self.getProcUnitObjByName(name)
1032
945
1033 946 return None
1034
947
1035 948 def getProcUnitObjByName(self, name):
1036
949
1037 950 for obj in self.procUnitConfObjDict.values():
1038 951 if obj.name == name:
1039 952 return obj
1040
953
1041 954 return None
1042
955
1043 956 def procUnitItems(self):
1044
957
1045 958 return self.procUnitConfObjDict.items()
1046
1047 def makeXml(self):
1048
959
960 def makeXml(self):
961
1049 962 projectElement = Element('Project')
1050 963 projectElement.set('id', str(self.id))
1051 964 projectElement.set('name', self.name)
1052 965 projectElement.set('description', self.description)
1053
966
1054 967 for procUnitConfObj in self.procUnitConfObjDict.values():
1055 968 procUnitConfObj.makeXml(projectElement)
1056
969
1057 970 self.projectElement = projectElement
1058
971
1059 972 def writeXml(self, filename=None):
1060
973
1061 974 if filename == None:
1062 975 if self.filename:
1063 976 filename = self.filename
1064 977 else:
1065 978 filename = "schain.xml"
1066
979
1067 980 if not filename:
1068 981 print "filename has not been defined. Use setFilename(filename) for do it."
1069 982 return 0
1070
983
1071 984 abs_file = os.path.abspath(filename)
1072
985
1073 986 if not os.access(os.path.dirname(abs_file), os.W_OK):
1074 987 print "No write permission on %s" %os.path.dirname(abs_file)
1075 988 return 0
1076
989
1077 990 if os.path.isfile(abs_file) and not(os.access(abs_file, os.W_OK)):
1078 991 print "File %s already exists and it could not be overwriten" %abs_file
1079 992 return 0
1080
993
1081 994 self.makeXml()
1082
995
1083 996 ElementTree(self.projectElement).write(abs_file, method='xml')
1084
997
1085 998 self.filename = abs_file
1086
999
1087 1000 return 1
1088 1001
1089 1002 def readXml(self, filename = None):
1090
1003
1091 1004 if not filename:
1092 1005 print "filename is not defined"
1093 1006 return 0
1094
1007
1095 1008 abs_file = os.path.abspath(filename)
1096
1009
1097 1010 if not os.path.isfile(abs_file):
1098 1011 print "%s file does not exist" %abs_file
1099 1012 return 0
1100
1013
1101 1014 self.projectElement = None
1102 1015 self.procUnitConfObjDict = {}
1103
1016
1104 1017 try:
1105 1018 self.projectElement = ElementTree().parse(abs_file)
1106 1019 except:
1107 1020 print "Error reading %s, verify file format" %filename
1108 1021 return 0
1109
1022
1110 1023 self.project = self.projectElement.tag
1111
1024
1112 1025 self.id = self.projectElement.get('id')
1113 1026 self.name = self.projectElement.get('name')
1114 1027 self.description = self.projectElement.get('description')
1115 1028
1116 1029 readUnitElementList = self.projectElement.iter(ReadUnitConf().getElementName())
1117
1030
1118 1031 for readUnitElement in readUnitElementList:
1119 1032 readUnitConfObj = ReadUnitConf()
1120 1033 readUnitConfObj.readXml(readUnitElement)
1121
1034
1122 1035 if readUnitConfObj.parentId == None:
1123 1036 readUnitConfObj.parentId = self.id
1124
1037
1125 1038 self.procUnitConfObjDict[readUnitConfObj.getId()] = readUnitConfObj
1126
1039
1127 1040 procUnitElementList = self.projectElement.iter(ProcUnitConf().getElementName())
1128
1041
1129 1042 for procUnitElement in procUnitElementList:
1130 1043 procUnitConfObj = ProcUnitConf()
1131 1044 procUnitConfObj.readXml(procUnitElement)
1132
1045
1133 1046 if procUnitConfObj.parentId == None:
1134 1047 procUnitConfObj.parentId = self.id
1135
1048
1136 1049 self.procUnitConfObjDict[procUnitConfObj.getId()] = procUnitConfObj
1137
1050
1138 1051 self.filename = abs_file
1139
1052
1140 1053 return 1
1141
1054
1142 1055 def printattr(self):
1143
1056
1144 1057 print "Project[%s]: name = %s, description = %s" %(self.id,
1145 self.name,
1146 self.description)
1147
1058 self.name,
1059 self.description)
1060
1148 1061 for procUnitConfObj in self.procUnitConfObjDict.values():
1149 1062 procUnitConfObj.printattr()
1150
1063
1151 1064 def createObjects(self):
1152
1065
1153 1066 for procUnitConfObj in self.procUnitConfObjDict.values():
1154 1067 procUnitConfObj.createObjects(self.plotterQueue)
1155
1068
1156 1069 def __connect(self, objIN, thisObj):
1157
1070
1158 1071 thisObj.setInput(objIN.getOutputObj())
1159
1072
1160 1073 def connectObjects(self):
1161
1074
1162 1075 for thisPUConfObj in self.procUnitConfObjDict.values():
1163
1076
1164 1077 inputId = thisPUConfObj.getInputId()
1165
1078
1166 1079 if int(inputId) == 0:
1167 1080 continue
1168
1081
1169 1082 #Get input object
1170 1083 puConfINObj = self.procUnitConfObjDict[inputId]
1171 1084 puObjIN = puConfINObj.getProcUnitObj()
1172
1085
1173 1086 #Get current object
1174 1087 thisPUObj = thisPUConfObj.getProcUnitObj()
1175
1088
1176 1089 self.__connect(puObjIN, thisPUObj)
1177
1090
1178 1091 def __handleError(self, procUnitConfObj, send_email=True):
1179
1092
1180 1093 import socket
1181
1094
1182 1095 err = traceback.format_exception(sys.exc_info()[0],
1183 1096 sys.exc_info()[1],
1184 1097 sys.exc_info()[2])
@@ -1187,20 +1100,20 class Project():
1187 1100 print "***** %s" %err[-1]
1188 1101
1189 1102 message = "".join(err)
1190
1103
1191 1104 sys.stderr.write(message)
1192
1105
1193 1106 if not send_email:
1194 1107 return
1195
1108
1196 1109 subject = "SChain v%s: Error running %s\n" %(schainpy.__version__, procUnitConfObj.name)
1197
1110
1198 1111 subtitle = "%s: %s\n" %(procUnitConfObj.getElementName() ,procUnitConfObj.name)
1199 1112 subtitle += "Hostname: %s\n" %socket.gethostbyname(socket.gethostname())
1200 1113 subtitle += "Working directory: %s\n" %os.path.abspath("./")
1201 1114 subtitle += "Configuration file: %s\n" %self.filename
1202 1115 subtitle += "Time: %s\n" %str(datetime.datetime.now())
1203
1116
1204 1117 readUnitConfObj = self.getReadUnitObj()
1205 1118 if readUnitConfObj:
1206 1119 subtitle += "\nInput parameters:\n"
@@ -1210,80 +1123,80 class Project():
1210 1123 subtitle += "[End date = %s]\n" %readUnitConfObj.endDate
1211 1124 subtitle += "[Start time = %s]\n" %readUnitConfObj.startTime
1212 1125 subtitle += "[End time = %s]\n" %readUnitConfObj.endTime
1213
1126
1214 1127 adminObj = schainpy.admin.SchainNotify()
1215 1128 adminObj.sendAlert(message=message,
1216 subject=subject,
1217 subtitle=subtitle,
1218 filename=self.filename)
1129 subject=subject,
1130 subtitle=subtitle,
1131 filename=self.filename)
1219 1132
1220 1133 def isPaused(self):
1221 1134 return 0
1222
1135
1223 1136 def isStopped(self):
1224 1137 return 0
1225
1138
1226 1139 def runController(self):
1227 1140 """
1228 1141 returns 0 when this process has been stopped, 1 otherwise
1229 1142 """
1230
1143
1231 1144 if self.isPaused():
1232 1145 print "Process suspended"
1233
1146
1234 1147 while True:
1235 1148 sleep(0.1)
1236
1149
1237 1150 if not self.isPaused():
1238 1151 break
1239
1152
1240 1153 if self.isStopped():
1241 1154 break
1242
1155
1243 1156 print "Process reinitialized"
1244
1157
1245 1158 if self.isStopped():
1246 1159 print "Process stopped"
1247 1160 return 0
1248
1161
1249 1162 return 1
1250 1163
1251 1164 def setFilename(self, filename):
1252
1165
1253 1166 self.filename = filename
1254
1167
1255 1168 def setPlotterQueue(self, plotter_queue):
1256
1169
1257 1170 raise NotImplementedError, "Use schainpy.controller_api.ControllerThread instead Project class"
1258 1171
1259 1172 def getPlotterQueue(self):
1260
1173
1261 1174 raise NotImplementedError, "Use schainpy.controller_api.ControllerThread instead Project class"
1262 1175
1263 1176 def useExternalPlotter(self):
1264
1177
1265 1178 raise NotImplementedError, "Use schainpy.controller_api.ControllerThread instead Project class"
1266
1179
1267 1180 def run(self):
1268
1181
1269 1182 print
1270 1183 print "*"*60
1271 1184 print " Starting SIGNAL CHAIN PROCESSING v%s " %schainpy.__version__
1272 1185 print "*"*60
1273 1186 print
1274
1187
1275 1188 keyList = self.procUnitConfObjDict.keys()
1276 1189 keyList.sort()
1277
1190
1278 1191 while(True):
1279
1192
1280 1193 is_ok = False
1281
1194
1282 1195 for procKey in keyList:
1283 1196 # print "Running the '%s' process with %s" %(procUnitConfObj.name, procUnitConfObj.id)
1284
1197
1285 1198 procUnitConfObj = self.procUnitConfObjDict[procKey]
1286
1199
1287 1200 try:
1288 1201 sts = procUnitConfObj.run()
1289 1202 is_ok = is_ok or sts
@@ -1300,7 +1213,7 class Project():
1300 1213 self.__handleError(procUnitConfObj)
1301 1214 is_ok = False
1302 1215 break
1303
1216
1304 1217 #If every process unit finished so end process
1305 1218 if not(is_ok):
1306 1219 # print "Every process unit have finished"
@@ -1308,17 +1221,74 class Project():
1308 1221
1309 1222 if not self.runController():
1310 1223 break
1311
1224
1312 1225 #Closing every process
1313 1226 for procKey in keyList:
1314 1227 procUnitConfObj = self.procUnitConfObjDict[procKey]
1315 1228 procUnitConfObj.close()
1316
1229
1317 1230 print "Process finished"
1318
1319 def start(self, filename=None):
1320
1321 self.writeXml(filename)
1231
1232 def start(self):
1233
1234 self.writeXml()
1235
1322 1236 self.createObjects()
1323 1237 self.connectObjects()
1324 1238 self.run()
1239
1240 if __name__ == '__main__':
1241
1242 desc = "Segundo Test"
1243 filename = "schain.xml"
1244
1245 controllerObj = Project()
1246
1247 controllerObj.setup(id = '191', name='test01', description=desc)
1248
1249 readUnitConfObj = controllerObj.addReadUnit(datatype='Voltage',
1250 path='data/rawdata/',
1251 startDate='2011/01/01',
1252 endDate='2012/12/31',
1253 startTime='00:00:00',
1254 endTime='23:59:59',
1255 online=1,
1256 walk=1)
1257
1258 procUnitConfObj0 = controllerObj.addProcUnit(datatype='Voltage', inputId=readUnitConfObj.getId())
1259
1260 opObj10 = procUnitConfObj0.addOperation(name='selectChannels')
1261 opObj10.addParameter(name='channelList', value='3,4,5', format='intlist')
1262
1263 opObj10 = procUnitConfObj0.addOperation(name='selectHeights')
1264 opObj10.addParameter(name='minHei', value='90', format='float')
1265 opObj10.addParameter(name='maxHei', value='180', format='float')
1266
1267 opObj12 = procUnitConfObj0.addOperation(name='CohInt', optype='external')
1268 opObj12.addParameter(name='n', value='10', format='int')
1269
1270 procUnitConfObj1 = controllerObj.addProcUnit(datatype='Spectra', inputId=procUnitConfObj0.getId())
1271 procUnitConfObj1.addParameter(name='nFFTPoints', value='32', format='int')
1272 # procUnitConfObj1.addParameter(name='pairList', value='(0,1),(0,2),(1,2)', format='')
1273
1274
1275 opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='external')
1276 opObj11.addParameter(name='idfigure', value='1', format='int')
1277 opObj11.addParameter(name='wintitle', value='SpectraPlot0', format='str')
1278 opObj11.addParameter(name='zmin', value='40', format='int')
1279 opObj11.addParameter(name='zmax', value='90', format='int')
1280 opObj11.addParameter(name='showprofile', value='1', format='int')
1281
1282 print "Escribiendo el archivo XML"
1283
1284 controllerObj.writeXml(filename)
1285
1286 print "Leyendo el archivo XML"
1287 controllerObj.readXml(filename)
1288 #controllerObj.printattr()
1289
1290 controllerObj.createObjects()
1291 controllerObj.connectObjects()
1292 controllerObj.run()
1293
1294 No newline at end of file
Show file before | Show file after | Hide comments
@@ -1,1 +1,1
1 <Project description="Claire" id="002" name="script02"><ReadUnit datatype="VoltageReader" id="21" inputId="0" name="VoltageReader"><Operation id="211" name="run" priority="1" type="self"><Parameter format="str" id="2111" name="datatype" value="VoltageReader" /><Parameter format="str" id="2112" name="path" value="/media/nanosat/0BDE10E00BDE10E0/CLAIRE" /><Parameter format="date" id="2113" name="startDate" value="2017/07/26" /><Parameter format="date" id="2114" name="endDate" value="2017/07/26" /><Parameter format="time" id="2115" name="startTime" value="15:00:00" /><Parameter format="time" id="2116" name="endTime" value="16:00:00" /><Parameter format="int" id="2118" name="delay" value="30" /><Parameter format="int" id="2119" name="walk" value="1" /><Parameter format="int" id="2120" name="online" value="0" /></Operation><Operation id="212" name="printNumberOfBlock" priority="2" type="self" /></ReadUnit><ProcUnit datatype="VoltageProc" id="22" inputId="21" name="VoltageProc"><Operation id="221" name="run" priority="1" type="self" /></ProcUnit><ProcUnit datatype="SpectraProc" id="23" inputId="22" name="SpectraProc"><Operation id="231" name="run" priority="1" type="self"><Parameter format="int" id="2311" name="nFFTPoints" value="128" /><Parameter format="int" id="2312" name="nProfiles" value="128" /><Parameter format="pairslist" id="2313" name="pairsList" value="(0,1),(0,2),(1,2)" /></Operation><Operation id="232" name="setRadarFrequency" priority="2" type="self"><Parameter format="float" id="2321" name="frequency" value="445000000.0" /></Operation><Operation id="233" name="IncohInt" priority="3" type="other"><Parameter format="float" id="2331" name="timeInterval" value="128" /></Operation><Operation id="234" name="removeDC" priority="4" type="self"><Parameter format="int" id="2341" name="mode" value="2" /></Operation><Operation id="235" name="SpectraPlot" priority="5" type="external"><Parameter format="int" id="2351" name="id" value="235" /><Parameter format="str" id="2352" name="wintitle" value="SpectraPlot" /><Parameter format="str" id="2353" name="xaxis" value="frequency" /><Parameter format="float" id="2354" name="zmin" value="15.0" /><Parameter format="float" id="2355" name="zmax" value="50.0" /><Parameter format="int" id="2356" name="exp_code" value="21" /><Parameter format="int" id="2357" name="ftp_wei" value="0" /><Parameter format="int" id="2358" name="plot_pos" value="0" /></Operation></ProcUnit></Project> No newline at end of file
1 <Project description="Claire" id="002" name="script02"><ReadUnit datatype="VoltageReader" id="21" inputId="0" name="VoltageReader"><Operation id="211" name="run" priority="1" type="self"><Parameter format="str" id="2111" name="datatype" value="VoltageReader" /><Parameter format="str" id="2112" name="path" value="/media/nanosat/0BDE10E00BDE10E0/CLAIRE" /><Parameter format="date" id="2113" name="startDate" value="2017/07/26" /><Parameter format="date" id="2114" name="endDate" value="2017/07/26" /><Parameter format="time" id="2115" name="startTime" value="15:00:00" /><Parameter format="time" id="2116" name="endTime" value="16:00:00" /><Parameter format="int" id="2117" name="delay" value="30" /><Parameter format="int" id="2118" name="walk" value="1" /><Parameter format="int" id="2119" name="online" value="0" /></Operation><Operation id="212" name="printNumberOfBlock" priority="2" type="self" /></ReadUnit><ProcUnit datatype="VoltageProc" id="22" inputId="21" name="VoltageProc"><Operation id="221" name="run" priority="1" type="self" /></ProcUnit><ProcUnit datatype="SpectraProc" id="23" inputId="22" name="SpectraProc"><Operation id="231" name="run" priority="1" type="self"><Parameter format="int" id="2311" name="nFFTPoints" value="128" /><Parameter format="int" id="2312" name="nProfiles" value="128" /><Parameter format="pairslist" id="2313" name="pairsList" value="(0,1),(0,2),(1,2)" /></Operation><Operation id="232" name="setRadarFrequency" priority="2" type="self"><Parameter format="float" id="2321" name="frequency" value="445000000.0" /></Operation><Operation id="233" name="IncohInt" priority="3" type="other"><Parameter format="float" id="2331" name="timeInterval" value="128" /></Operation><Operation id="234" name="removeDC" priority="4" type="self"><Parameter format="int" id="2341" name="mode" value="2" /></Operation><Operation id="235" name="SpectraPlot" priority="5" type="external"><Parameter format="int" id="2351" name="id" value="235" /><Parameter format="str" id="2352" name="wintitle" value="SpectraPlot" /><Parameter format="str" id="2353" name="xaxis" value="frequency" /><Parameter format="float" id="2354" name="zmin" value="15.0" /><Parameter format="float" id="2355" name="zmax" value="50.0" /><Parameter format="int" id="2356" name="exp_code" value="21" /><Parameter format="int" id="2357" name="ftp_wei" value="0" /><Parameter format="int" id="2358" name="plot_pos" value="0" /></Operation></ProcUnit></Project> No newline at end of file
General Comments 0
You need to be logged in to leave comments. Login now