schain Commit - r607:bc5d3588d2df · Jicamarca Repository

Bug fixed in Signal Chain GUI: Updating FTP configuration from old SendByFTP operation.

Miguel Valdez -

r607:bc5d3588d2df

parent child

Context file:

r607:bc5d3588d2df

Collapse all files

schainpy/controller.py +2 -2

             '''
             Created on September , 2012
             @author:
             '''
             from xml.etree.ElementTree import Element, SubElement
             from xml.etree import ElementTree as ET
             from xml.dom import minidom
             #import datetime
             from model import *
             try:
                 from gevent import sleep
             except:
                 from time import sleep
             import ast
             def prettify(elem):
                 """Return a pretty-printed XML string for the Element.
                 """
                 rough_string = ET.tostring(elem, 'utf-8')
                 reparsed = minidom.parseString(rough_string)
                 return reparsed.toprettyxml(indent="  ")
             class ParameterConf():
                 id = None
                 name = None
                 value = None
                 format = None
                 __formated_value = None
                 ELEMENTNAME = 'Parameter'
                 def __init__(self):
                     self.format = 'str'
                 def getElementName(self):
                     return self.ELEMENTNAME
                 def getValue(self):
                     value = self.value
                     format = self.format
                     if self.__formated_value != None:
                         return self.__formated_value
                     if format == 'str':
                         self.__formated_value = str(value)
                         return self.__formated_value
                     if value == '':
                         raise ValueError, "%s: This parameter value is empty" %self.name
                     if format == 'bool':
                         value = int(value)
                     if format == 'list':
                         strList = value.split(',')
                         self.__formated_value = strList
                         return self.__formated_value
                     if format == 'intlist':
                         """
                         Example:
                             value = (0,1,2)
                         """
                         value = value.replace('(', '')
                         value = value.replace(')', '')
                         value = value.replace('[', '')
                         value = value.replace(']', '')
                         strList = value.split(',')
                         intList = [int(x) for x in strList]
                         self.__formated_value = intList
                         return self.__formated_value
                     if format == 'floatlist':
                         """
                         Example:
                             value = (0.5, 1.4, 2.7)
                         """
                         value = value.replace('(', '')
                         value = value.replace(')', '')
                         value = value.replace('[', '')
                         value = value.replace(']', '')
                         strList = value.split(',')
                         floatList = [float(x) for x in strList]
                         self.__formated_value = floatList
                         return self.__formated_value
                     if format == 'date':
                         strList = value.split('/')
                         intList = [int(x) for x in strList]
                         date = datetime.date(intList[0], intList[1], intList[2])
                         self.__formated_value = date
                         return self.__formated_value
                     if format == 'time':
                         strList = value.split(':')
                         intList = [int(x) for x in strList]
                         time = datetime.time(intList[0], intList[1], intList[2])
                         self.__formated_value = time
                         return self.__formated_value
                     if format == 'pairslist':
                         """
                         Example:
                             value = (0,1),(1,2)
                         """
                         value = value.replace('(', '')
                         value = value.replace(')', '')
                         value = value.replace('[', '')
                         value = value.replace(']', '')
                         strList = value.split(',')
                         intList = [int(item) for item in strList]
                         pairList = []
                         for i in range(len(intList)/2):
                             pairList.append((intList[i*2], intList[i*2 + 1]))
                         self.__formated_value = pairList
                         return self.__formated_value
                     if format == 'multilist':
                         """
                         Example:
                             value = (0,1,2),(3,4,5)
                         """
                         multiList = ast.literal_eval(value)
                         if type(multiList[0]) == int:
                             multiList = ast.literal_eval("(" + value + ")")
                         self.__formated_value = multiList
                         return self.__formated_value
                     format_func = eval(format)
                     self.__formated_value = format_func(value)
                     return self.__formated_value
                 def updateId(self, new_id):
                     self.id = str(new_id)
                 def setup(self, id, name, value, format='str'):
                     self.id = str(id)
                     self.name = name
                     self.value = str(value)
                     self.format = str.lower(format)
                 def update(self, name, value, format='str'):
                     self.name = name
                     self.value = str(value)
                     self.format = format
                 def makeXml(self, opElement):
                     parmElement = SubElement(opElement, self.ELEMENTNAME)
                     parmElement.set('id', str(self.id))
                     parmElement.set('name', self.name)
                     parmElement.set('value', self.value)
                     parmElement.set('format', self.format)
                 def readXml(self, parmElement):
                     self.id = parmElement.get('id')
                     self.name = parmElement.get('name')
                     self.value = parmElement.get('value')
                     self.format = str.lower(parmElement.get('format'))
                     #Compatible with old signal chain version
                     if self.format == 'int' and self.name == 'idfigure':
                         self.name = 'id'
                 def printattr(self):
                     print "Parameter[%s]: name = %s, value = %s, format = %s" %(self.id, self.name, self.value, self.format)
             class OperationConf():
                 id = None
                 name = None
                 priority = None
                 type = None
                 parmConfObjList = []
                 ELEMENTNAME = 'Operation'
                 def __init__(self):
                     self.id = '0'
                     self.name = None
                     self.priority = None
                     self.type = 'self'
                 def __getNewId(self):
                     return int(self.id)*10 + len(self.parmConfObjList) + 1
                 def updateId(self, new_id):
                     self.id = str(new_id)
                     n = 1
                     for parmObj in self.parmConfObjList:
                         idParm = str(int(new_id)*10 + n)
                         parmObj.updateId(idParm)
                         n += 1
                 def getElementName(self):
                     return self.ELEMENTNAME
                 def getParameterObjList(self):
                     return self.parmConfObjList
                 def getParameterObj(self, parameterName):
                     for parmConfObj in self.parmConfObjList:
                         if parmConfObj.name != parameterName:
                             continue
                         return parmConfObj
                     return None
                 def getParameterObjfromValue(self, parameterValue):
                     for parmConfObj in self.parmConfObjList:
                         if parmConfObj.getValue() != parameterValue:
                             continue
                         return parmConfObj.getValue()
                     return None
                 def getParameterValue(self, parameterName):
                     parameterObj = self.getParameterObj(parameterName)
-                    if not parameterObj:
+            #         if not parameterObj:
-                        return None
+            #             return None
                     value = parameterObj.getValue()
                     return value
                 def setup(self, id, name, priority, type):
                     self.id = str(id)
                     self.name = name
                     self.type = type
                     self.priority = priority
                     self.parmConfObjList = []
                 def removeParameters(self):
                     for obj in self.parmConfObjList:
                         del obj
                     self.parmConfObjList = []
                 def addParameter(self, name, value, format='str'):
                     id = self.__getNewId()
                     parmConfObj = ParameterConf()
                     parmConfObj.setup(id, name, value, format)
                     self.parmConfObjList.append(parmConfObj)
                     return parmConfObj
                 def changeParameter(self, name, value, format='str'):
                     parmConfObj = self.getParameterObj(name)
                     parmConfObj.update(name, value, format)
                     return parmConfObj
                 def makeXml(self, upElement):
                     opElement = SubElement(upElement, self.ELEMENTNAME)
                     opElement.set('id', str(self.id))
                     opElement.set('name', self.name)
                     opElement.set('type', self.type)
                     opElement.set('priority', str(self.priority))
                     for parmConfObj in self.parmConfObjList:
                         parmConfObj.makeXml(opElement)
                 def readXml(self, opElement):
                     self.id = opElement.get('id')
                     self.name = opElement.get('name')
                     self.type = opElement.get('type')
                     self.priority = opElement.get('priority')
                     #Compatible with old signal chain version
                     #Use of 'run' method instead 'init'
                     if self.type == 'self' and self.name == 'init':
                         self.name = 'run'
                     self.parmConfObjList = []
                     parmElementList = opElement.getiterator(ParameterConf().getElementName())
                     for parmElement in parmElementList:
                         parmConfObj = ParameterConf()
                         parmConfObj.readXml(parmElement)
                         #Compatible with old signal chain version
                         #If an 'plot' OPERATION is found, changes name operation by the value of its type PARAMETER
                         if self.type != 'self' and self.name == 'Plot':
                             if parmConfObj.format == 'str' and parmConfObj.name == 'type':
                                 self.name = parmConfObj.value
                                 continue
                         self.parmConfObjList.append(parmConfObj)
                 def printattr(self):
                     print "%s[%s]: name = %s, type = %s, priority = %s" %(self.ELEMENTNAME,
                                                                           self.id,
                                                                           self.name,
                                                                           self.type,
                                                                           self.priority)
                     for parmConfObj in self.parmConfObjList:
                         parmConfObj.printattr()
                 def createObject(self):
                     if self.type == 'self':
                         raise ValueError, "This operation type cannot be created"
                     if self.type == 'external' or self.type == 'other':
                         className = eval(self.name)
                         opObj = className()
                     return opObj
             class ProcUnitConf():
                 id = None
                 name = None
                 datatype = None
                 inputId = None
                 parentId = None
                 opConfObjList = []
                 procUnitObj = None
                 opObjList = []
                 ELEMENTNAME = 'ProcUnit'
                 def __init__(self):
                     self.id = None
                     self.datatype = None
                     self.name = None
                     self.inputId = None
                     self.opConfObjList = []
                     self.procUnitObj = None
                     self.opObjDict = {}
                 def __getPriority(self):
                     return len(self.opConfObjList)+1
                 def __getNewId(self):
                     return int(self.id)*10 + len(self.opConfObjList) + 1
                 def getElementName(self):
                     return self.ELEMENTNAME
                 def getId(self):
                     return self.id
                 def updateId(self, new_id, parentId=parentId):
                     new_id = int(parentId)*10 + (int(self.id) % 10)
                     new_inputId = int(parentId)*10 + (int(self.inputId) % 10)
                     #If this proc unit has not inputs
                     if self.inputId == '0':
                         new_inputId = 0
                     n = 1
                     for opConfObj in self.opConfObjList:
                         idOp = str(int(new_id)*10 + n)
                         opConfObj.updateId(idOp)
                         n += 1
                     self.parentId = str(parentId)
                     self.id = str(new_id)
                     self.inputId = str(new_inputId)
                 def getInputId(self):
                     return self.inputId
                 def getOperationObjList(self):
                     return self.opConfObjList
                 def getOperationObj(self, name=None):
                     for opConfObj in self.opConfObjList:
                         if opConfObj.name != name:
                             continue
                         return opConfObj
                     return None
                 def getOpObjfromParamValue(self, value=None):
                     for opConfObj in self.opConfObjList:
                         if opConfObj.getParameterObjfromValue(parameterValue=value) != value:
                             continue
                         return opConfObj
                     return None
                 def getProcUnitObj(self):
                     return self.procUnitObj
                 def setup(self, id, name, datatype, inputId, parentId=None):
                     #Compatible with old signal chain version
                     if datatype==None and name==None:
                         raise ValueError, "datatype or name should be defined"
                     if name==None:
                         if 'Proc' in datatype:
                             name = datatype
                         else:
                             name = '%sProc' %(datatype)
                     if datatype==None:
                         datatype = name.replace('Proc','')
                     self.id = str(id)
                     self.name = name
                     self.datatype = datatype
                     self.inputId = inputId
                     self.parentId = parentId
                     self.opConfObjList = []
                     self.addOperation(name='run', optype='self')
                 def removeOperations(self):
                     for obj in self.opConfObjList:
                         del obj
                     self.opConfObjList = []
                     self.addOperation(name='run')
                 def addParameter(self, **kwargs):
                     '''
                     Add parameters to "run" operation
                     '''
                     opObj = self.opConfObjList[0]
                     opObj.addParameter(**kwargs)
                     return opObj
                 def addOperation(self, name, optype='self'):
                     id = self.__getNewId()
                     priority = self.__getPriority()
                     opConfObj = OperationConf()
                     opConfObj.setup(id, name=name, priority=priority, type=optype)
                     self.opConfObjList.append(opConfObj)
                     return opConfObj
                 def makeXml(self, procUnitElement):
                     upElement = SubElement(procUnitElement, self.ELEMENTNAME)
                     upElement.set('id', str(self.id))
                     upElement.set('name', self.name)
                     upElement.set('datatype', self.datatype)
                     upElement.set('inputId', str(self.inputId))
                     for opConfObj in self.opConfObjList:
                         opConfObj.makeXml(upElement)
                 def readXml(self, upElement):
                     self.id = upElement.get('id')
                     self.name = upElement.get('name')
                     self.datatype = upElement.get('datatype')
                     self.inputId = upElement.get('inputId')
                     if self.ELEMENTNAME == "ReadUnit":
                         self.datatype = self.datatype.replace("Reader", "")
                     if self.ELEMENTNAME == "ProcUnit":
                         self.datatype = self.datatype.replace("Proc", "")
                     if self.inputId == 'None':
                         self.inputId = '0'
                     self.opConfObjList = []
                     opElementList = upElement.getiterator(OperationConf().getElementName())
                     for opElement in opElementList:
                         opConfObj = OperationConf()
                         opConfObj.readXml(opElement)
                         self.opConfObjList.append(opConfObj)
                 def printattr(self):
                     print "%s[%s]: name = %s, datatype = %s, inputId = %s" %(self.ELEMENTNAME,
                                                                          self.id,
                                                                          self.name,
                                                                          self.datatype,
                                                                          self.inputId)
                     for opConfObj in self.opConfObjList:
                         opConfObj.printattr()
                 def createObjects(self):
                     className = eval(self.name)
                     procUnitObj = className()
                     for opConfObj in self.opConfObjList:
                         if opConfObj.type == 'self':
                             continue
                         opObj = opConfObj.createObject()
                         self.opObjDict[opConfObj.id] = opObj
                         procUnitObj.addOperation(opObj, opConfObj.id)
                     self.procUnitObj = procUnitObj
                     return procUnitObj
                 def run(self):
                     finalSts = False
                     for opConfObj in self.opConfObjList:
                         kwargs = {}
                         for parmConfObj in opConfObj.getParameterObjList():
                             if opConfObj.name == 'run' and parmConfObj.name == 'datatype':
                                 continue
                             kwargs[parmConfObj.name] = parmConfObj.getValue()
                         #print "\tRunning the '%s' operation with %s" %(opConfObj.name, opConfObj.id)
                         sts = self.procUnitObj.call(opType = opConfObj.type,
                                                     opName = opConfObj.name,
                                                     opId = opConfObj.id,
                                                      **kwargs)
                         finalSts = finalSts or sts
                     return finalSts
                 def close(self):
                     for opConfObj in self.opConfObjList:
                         if opConfObj.type == 'self':
                             continue
                         opObj = self.procUnitObj.getOperationObj(opConfObj.id)
                         opObj.close()
                     self.procUnitObj.close()
                     return
             class ReadUnitConf(ProcUnitConf):
                 path = None
                 startDate = None
                 endDate = None
                 startTime = None
                 endTime = None
                 ELEMENTNAME = 'ReadUnit'
                 def __init__(self):
                     self.id = None
                     self.datatype = None
                     self.name = None
                     self.inputId = None
                     self.parentId = None
                     self.opConfObjList = []
                     self.opObjList = []
                 def getElementName(self):
                     return self.ELEMENTNAME
                 def setup(self, id, name, datatype, path, startDate="", endDate="", startTime="", endTime="", parentId=None, **kwargs):
                     #Compatible with old signal chain version
                     if datatype==None and name==None:
                         raise ValueError, "datatype or name should be defined"
                     if name==None:
                         if 'Reader' in datatype:
                             name = datatype
                         else:
                             name = '%sReader' %(datatype)
                     if datatype==None:
                         datatype = name.replace('Reader','')
                     self.id = id
                     self.name = name
                     self.datatype = datatype
                     self.path = path
                     self.startDate = startDate
                     self.endDate = endDate
                     self.startTime = startTime
                     self.endTime = endTime
                     self.inputId = '0'
                     self.parentId = parentId
                     self.addRunOperation(**kwargs)
                 def update(self, datatype, path, startDate, endDate, startTime, endTime, parentId=None, name=None, **kwargs):
                     #Compatible with old signal chain version
                     if datatype==None and name==None:
                         raise ValueError, "datatype or name should be defined"
                     if name==None:
                         if 'Reader' in datatype:
                             name = datatype
                         else:
                             name = '%sReader' %(datatype)
                     if datatype==None:
                         datatype = name.replace('Reader','')
                     self.datatype = datatype
                     self.name = name
                     self.path = path
                     self.startDate = startDate
                     self.endDate = endDate
                     self.startTime = startTime
                     self.endTime = endTime
                     self.inputId = '0'
                     self.parentId = parentId
                     self.updateRunOperation(**kwargs)
                 def addRunOperation(self, **kwargs):
                     opObj = self.addOperation(name = 'run', optype = 'self')
                     opObj.addParameter(name='datatype' , value=self.datatype, format='str')
                     opObj.addParameter(name='path'     , value=self.path, format='str')
                     opObj.addParameter(name='startDate' , value=self.startDate, format='date')
                     opObj.addParameter(name='endDate'   , value=self.endDate, format='date')
                     opObj.addParameter(name='startTime' , value=self.startTime, format='time')
                     opObj.addParameter(name='endTime'   , value=self.endTime, format='time')
                     for key, value in kwargs.items():
                         opObj.addParameter(name=key, value=value, format=type(value).__name__)
                     return opObj
                 def updateRunOperation(self, **kwargs):
                     opObj = self.getOperationObj(name = 'run')
                     opObj.removeParameters()
                     opObj.addParameter(name='datatype' , value=self.datatype, format='str')
                     opObj.addParameter(name='path'     , value=self.path, format='str')
                     opObj.addParameter(name='startDate' , value=self.startDate, format='date')
                     opObj.addParameter(name='endDate'   , value=self.endDate, format='date')
                     opObj.addParameter(name='startTime' , value=self.startTime, format='time')
                     opObj.addParameter(name='endTime'   , value=self.endTime, format='time')
                     for key, value in kwargs.items():
                         opObj.addParameter(name=key, value=value, format=type(value).__name__)
                     return opObj
             class Project():
                 id = None
                 name = None
                 description = None
             #    readUnitConfObjList = None
                 procUnitConfObjDict = None
                 ELEMENTNAME = 'Project'
                 def __init__(self, control=None, dataq=None):
                     self.id = None
                     self.name = None
                     self.description = None
                     self.procUnitConfObjDict = {}
                     #global data_q
                     #data_q = dataq
                     if control==None:
                         control = {'stop':False,'pause':False}
                     self.control = control
                 def __getNewId(self):
                     id = int(self.id)*10 + len(self.procUnitConfObjDict) + 1
                     return str(id)
                 def getElementName(self):
                     return self.ELEMENTNAME
                 def getId(self):
                     return self.id
                 def updateId(self, new_id):
                     self.id = str(new_id)
                     keyList = self.procUnitConfObjDict.keys()
                     keyList.sort()
                     n = 1
                     newProcUnitConfObjDict = {}
                     for procKey in keyList:
                         procUnitConfObj = self.procUnitConfObjDict[procKey]
                         idProcUnit = str(int(self.id)*10 + n)
                         procUnitConfObj.updateId(idProcUnit, parentId = self.id)
                         newProcUnitConfObjDict[idProcUnit] = procUnitConfObj
                         n += 1
                     self.procUnitConfObjDict = newProcUnitConfObjDict
                 def setup(self, id, name, description):
                     self.id = str(id)
                     self.name = name
                     self.description = description
                 def update(self, name, description):
                     self.name = name
                     self.description = description
                 def addReadUnit(self, datatype=None, name=None, **kwargs):
                     idReadUnit = self.__getNewId()
                     readUnitConfObj = ReadUnitConf()
                     readUnitConfObj.setup(idReadUnit, name, datatype, parentId=self.id, **kwargs)
                     self.procUnitConfObjDict[readUnitConfObj.getId()] = readUnitConfObj
                     return readUnitConfObj
                 def addProcUnit(self, inputId='0', datatype=None, name=None):
                     idProcUnit = self.__getNewId()
                     procUnitConfObj = ProcUnitConf()
                     procUnitConfObj.setup(idProcUnit, name, datatype, inputId, parentId=self.id)
                     self.procUnitConfObjDict[procUnitConfObj.getId()] = procUnitConfObj
                     return procUnitConfObj
                 def removeProcUnit(self, id):
                     if id in self.procUnitConfObjDict.keys():
                         self.procUnitConfObjDict.pop(id)
                 def getReadUnitId(self):
                     readUnitConfObj = self.getReadUnitObj()
                     return readUnitConfObj.id
                 def getReadUnitObj(self):
                     for obj in self.procUnitConfObjDict.values():
                         if obj.getElementName() == "ReadUnit":
                             return obj
                     return None
                 def getProcUnitObj(self, id=None, name=None):
                     if id != None:
                         return self.procUnitConfObjDict[id]
                     if name != None:
                         return self.getProcUnitObjByName(name)
                     return None
                 def getProcUnitObjByName(self, name):
                     for obj in self.procUnitConfObjDict.values():
                         if obj.name == name:
                             return obj
                     return None
                 def procUnitItems(self):
                     return self.procUnitConfObjDict.items()
                 def makeXml(self):
                     projectElement = Element('Project')
                     projectElement.set('id', str(self.id))
                     projectElement.set('name', self.name)
                     projectElement.set('description', self.description)
             #        for readUnitConfObj in self.readUnitConfObjList:
             #            readUnitConfObj.makeXml(projectElement)
                     for procUnitConfObj in self.procUnitConfObjDict.values():
                         procUnitConfObj.makeXml(projectElement)
                     self.projectElement = projectElement
                 def writeXml(self, filename):
                     self.makeXml()
                     #print prettify(self.projectElement)
                     ElementTree(self.projectElement).write(filename, method='xml')
                 def readXml(self, filename):
                     #tree = ET.parse(filename)
                     self.projectElement = None
             #        self.readUnitConfObjList = []
                     self.procUnitConfObjDict = {}
                     self.projectElement = ElementTree().parse(filename)
                     self.project = self.projectElement.tag
                     self.id = self.projectElement.get('id')
                     self.name = self.projectElement.get('name')
                     self.description = self.projectElement.get('description')
                     readUnitElementList = self.projectElement.getiterator(ReadUnitConf().getElementName())
                     for readUnitElement in readUnitElementList:
                         readUnitConfObj = ReadUnitConf()
                         readUnitConfObj.readXml(readUnitElement)
                         if readUnitConfObj.parentId == None:
                             readUnitConfObj.parentId = self.id
                         self.procUnitConfObjDict[readUnitConfObj.getId()] = readUnitConfObj
                     procUnitElementList = self.projectElement.getiterator(ProcUnitConf().getElementName())
                     for procUnitElement in procUnitElementList:
                         procUnitConfObj = ProcUnitConf()
                         procUnitConfObj.readXml(procUnitElement)
                         if procUnitConfObj.parentId == None:
                             procUnitConfObj.parentId = self.id
                         self.procUnitConfObjDict[procUnitConfObj.getId()] = procUnitConfObj
                 def printattr(self):
                     print "Project[%s]: name = %s, description = %s" %(self.id,
                                                                           self.name,
                                                                           self.description)
             #        for readUnitConfObj in self.readUnitConfObjList:
             #            readUnitConfObj.printattr()
                     for procUnitConfObj in self.procUnitConfObjDict.values():
                         procUnitConfObj.printattr()
                 def createObjects(self):
             #        for readUnitConfObj in self.readUnitConfObjList:
             #            readUnitConfObj.createObjects()
                     for procUnitConfObj in self.procUnitConfObjDict.values():
                         procUnitConfObj.createObjects()
                 def __connect(self, objIN, thisObj):
                     thisObj.setInput(objIN.getOutputObj())
                 def connectObjects(self):
                     for thisPUConfObj in self.procUnitConfObjDict.values():
                         inputId = thisPUConfObj.getInputId()
                         if int(inputId) == 0:
                             continue
                         #Get input object
                         puConfINObj = self.procUnitConfObjDict[inputId]
                         puObjIN = puConfINObj.getProcUnitObj()
                         #Get current object
                         thisPUObj = thisPUConfObj.getProcUnitObj()
                         self.__connect(puObjIN, thisPUObj)
                 def run(self):
             #        for readUnitConfObj in self.readUnitConfObjList:
             #            readUnitConfObj.run()
                     print
                     print "*"*40
                     print "   Starting SIGNAL CHAIN PROCESSING  "
                     print "*"*40
                     print
                     keyList = self.procUnitConfObjDict.keys()
                     keyList.sort()
                     while(True):
                         finalSts = False
                         for procKey in keyList:
             #                 print "Running the '%s' process with %s" %(procUnitConfObj.name, procUnitConfObj.id)
                             procUnitConfObj = self.procUnitConfObjDict[procKey]
                             sts = procUnitConfObj.run()
                             finalSts = finalSts or sts
                         #If every process unit finished so end process
                         if not(finalSts):
                             print "Every process unit have finished"
                             break
                         if self.control['pause']:
                             print "Process suspended"
                             while True:
                                 sleep(0.1)
                                 if not self.control['pause']:
                                     break
                                 if self.control['stop']:
                                     break
                             print "Process reinitialized"
                         if self.control['stop']:
                             print "Process stopped"
                             break
                     #Closing every process
                     for procKey in keyList:
                         procUnitConfObj = self.procUnitConfObjDict[procKey]
                         procUnitConfObj.close()
                     print "Process finished"
                 def start(self, filename):
                     self.writeXml(filename)
                     self.readXml(filename)
                     self.createObjects()
                     self.connectObjects()
                     self.run()
             class ControllerThread(threading.Thread, Project):
                 def __init__(self, filename):
                     threading.Thread.__init__(self)
                     Project.__init__(self)
                     self.setDaemon(True)
                     self.filename = filename
                     self.control = {'stop':False, 'pause':False}
                 def stop(self):
                     self.control['stop'] = True
                 def pause(self):
                     self.control['pause'] = not(self.control['pause'])
                 def run(self):
                     self.control['stop'] = False
                     self.control['pause'] = False
                     self.readXml(self.filename)
                     self.createObjects()
                     self.connectObjects()
                     Project.run(self)
             if __name__ == '__main__':
                 desc = "Segundo Test"
                 filename = "schain.xml"
                 controllerObj = Project()
                 controllerObj.setup(id = '191', name='test01', description=desc)
                 readUnitConfObj = controllerObj.addReadUnit(datatype='Voltage',
                                                             path='data/rawdata/',
                                                             startDate='2011/01/01',
                                                             endDate='2012/12/31',
                                                             startTime='00:00:00',
                                                             endTime='23:59:59',
                                                             online=1,
                                                             walk=1)
             #    opObj00 = readUnitConfObj.addOperation(name='printInfo')
                 procUnitConfObj0 = controllerObj.addProcUnit(datatype='Voltage', inputId=readUnitConfObj.getId())
                 opObj10 = procUnitConfObj0.addOperation(name='selectChannels')
                 opObj10.addParameter(name='channelList', value='3,4,5', format='intlist')
                 opObj10 = procUnitConfObj0.addOperation(name='selectHeights')
                 opObj10.addParameter(name='minHei', value='90', format='float')
                 opObj10.addParameter(name='maxHei', value='180', format='float')
                 opObj12 = procUnitConfObj0.addOperation(name='CohInt', optype='external')
                 opObj12.addParameter(name='n', value='10', format='int')
                 procUnitConfObj1 = controllerObj.addProcUnit(datatype='Spectra', inputId=procUnitConfObj0.getId())
                 procUnitConfObj1.addParameter(name='nFFTPoints', value='32', format='int')
             #    procUnitConfObj1.addParameter(name='pairList', value='(0,1),(0,2),(1,2)', format='')
                 opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='external')
                 opObj11.addParameter(name='idfigure', value='1', format='int')
                 opObj11.addParameter(name='wintitle', value='SpectraPlot0', format='str')
                 opObj11.addParameter(name='zmin', value='40', format='int')
                 opObj11.addParameter(name='zmax', value='90', format='int')
                 opObj11.addParameter(name='showprofile', value='1', format='int')
             #    opObj11 = procUnitConfObj1.addOperation(name='CrossSpectraPlot', optype='external')
             #    opObj11.addParameter(name='idfigure', value='2', format='int')
             #    opObj11.addParameter(name='wintitle', value='CrossSpectraPlot', format='str')
             #    opObj11.addParameter(name='zmin', value='40', format='int')
             #    opObj11.addParameter(name='zmax', value='90', format='int')
             #    procUnitConfObj2 = controllerObj.addProcUnit(datatype='Voltage', inputId=procUnitConfObj0.getId())
             #
             #    opObj12 = procUnitConfObj2.addOperation(name='CohInt', optype='external')
             #    opObj12.addParameter(name='n', value='2', format='int')
             #    opObj12.addParameter(name='overlapping', value='1', format='int')
             #
             #    procUnitConfObj3 = controllerObj.addProcUnit(datatype='Spectra', inputId=procUnitConfObj2.getId())
             #    procUnitConfObj3.addParameter(name='nFFTPoints', value='32', format='int')
             #
             #    opObj11 = procUnitConfObj3.addOperation(name='SpectraPlot', optype='external')
             #    opObj11.addParameter(name='idfigure', value='2', format='int')
             #    opObj11.addParameter(name='wintitle', value='SpectraPlot1', format='str')
             #    opObj11.addParameter(name='zmin', value='40', format='int')
             #    opObj11.addParameter(name='zmax', value='90', format='int')
             #    opObj11.addParameter(name='showprofile', value='1', format='int')
             #    opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='external')
             #    opObj11.addParameter(name='idfigure', value='10', format='int')
             #    opObj11.addParameter(name='wintitle', value='RTI', format='str')
             ##    opObj11.addParameter(name='xmin', value='21', format='float')
             ##    opObj11.addParameter(name='xmax', value='22', format='float')
             #    opObj11.addParameter(name='zmin', value='40', format='int')
             #    opObj11.addParameter(name='zmax', value='90', format='int')
             #    opObj11.addParameter(name='showprofile', value='1', format='int')
             #    opObj11.addParameter(name='timerange', value=str(60), format='int')
             #    opObj10 = procUnitConfObj1.addOperation(name='selectChannels')
             #    opObj10.addParameter(name='channelList', value='0,2,4,6', format='intlist')
             #
             #    opObj12 = procUnitConfObj1.addOperation(name='IncohInt', optype='external')
             #    opObj12.addParameter(name='n', value='2', format='int')
             #
             #    opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='external')
             #    opObj11.addParameter(name='idfigure', value='2', format='int')
             #    opObj11.addParameter(name='wintitle', value='SpectraPlot10', format='str')
             #    opObj11.addParameter(name='zmin', value='70', format='int')
             #    opObj11.addParameter(name='zmax', value='90', format='int')
             #
             #    opObj10 = procUnitConfObj1.addOperation(name='selectChannels')
             #    opObj10.addParameter(name='channelList', value='2,6', format='intlist')
             #
             #    opObj12 = procUnitConfObj1.addOperation(name='IncohInt', optype='external')
             #    opObj12.addParameter(name='n', value='2', format='int')
             #
             #    opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='external')
             #    opObj11.addParameter(name='idfigure', value='3', format='int')
             #    opObj11.addParameter(name='wintitle', value='SpectraPlot10', format='str')
             #    opObj11.addParameter(name='zmin', value='70', format='int')
             #    opObj11.addParameter(name='zmax', value='90', format='int')
             #    opObj12 = procUnitConfObj1.addOperation(name='decoder')
             #    opObj12.addParameter(name='ncode', value='2', format='int')
             #    opObj12.addParameter(name='nbauds', value='8', format='int')
             #    opObj12.addParameter(name='code0', value='001110011', format='int')
             #    opObj12.addParameter(name='code1', value='001110011', format='int')
             #    procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=procUnitConfObj1.getId())
             #
             #    opObj21 = procUnitConfObj2.addOperation(name='IncohInt', optype='external')
             #    opObj21.addParameter(name='n', value='2', format='int')
             #
             #    opObj11 = procUnitConfObj2.addOperation(name='SpectraPlot', optype='external')
             #    opObj11.addParameter(name='idfigure', value='4', format='int')
             #    opObj11.addParameter(name='wintitle', value='SpectraPlot OBJ 2', format='str')
             #    opObj11.addParameter(name='zmin', value='70', format='int')
             #    opObj11.addParameter(name='zmax', value='90', format='int')
                 print "Escribiendo el archivo XML"
                 controllerObj.writeXml(filename)
                 print "Leyendo el archivo XML"
                 controllerObj.readXml(filename)
                 #controllerObj.printattr()
                 controllerObj.createObjects()
                 controllerObj.connectObjects()
                 controllerObj.run()
   No newline at end of file

schainpy/gui/viewcontroller/basicwindow.py +86 -242

             # -*- coding: utf-8 -*-
             """
             Module implementing MainWindow.
             #+++++++++++++GUI V1++++++++++++++#
             @author: AlexanderValdezPortocarrero ñ_ñ
             """
             import os, sys, time
             import datetime
             import numpy
             import Queue
             from collections import OrderedDict
             from os.path import  expanduser
             from time import sleep
             import ast
             from PyQt4.QtGui           import QMainWindow
             from PyQt4.QtCore          import pyqtSignature
             from PyQt4.QtCore          import pyqtSignal
             from PyQt4                 import QtCore
             from PyQt4                 import QtGui
             from schainpy.gui.viewer.ui_unitprocess import Ui_UnitProcess
             from schainpy.gui.viewer.ui_ftp      import Ui_Ftp
             from schainpy.gui.viewer.ui_mainwindow  import Ui_BasicWindow
             from schainpy.controller  import Project, ControllerThread
             from propertiesViewModel  import TreeModel, PropertyBuffer
             from parametersModel import ProjectParms
             from schainpy.gui.figures import tools
             FIGURES_PATH = tools.get_path()
             TEMPORAL_FILE = ".temp.xml"
             def isRadarFile(file):
                     try:
                         year = int(file[1:5])
                         doy = int(file[5:8])
                         set = int(file[8:11])
                     except:
                         return 0
                     return 1
             def isRadarPath(path):
                     try:
                         year = int(path[1:5])
                         doy = int(path[5:8])
                     except:
                         return 0
                     return 1
             class BasicWindow(QMainWindow, Ui_BasicWindow):
                 """
                 """
                 def __init__(self, parent=None):
                     """
                     """
                     QMainWindow.__init__(self, parent)
                     self.setupUi(self)
                     self.__puObjDict = {}
                     self.__itemTreeDict = {}
                     self.readUnitConfObjList = []
                     self.operObjList = []
                     self.projecObjView = None
                     self.idProject = 0
                     # self.idImag = 0
                     self.idImagscope = 0
                     self.idImagspectra = 0
                     self.idImagcross = 0
                     self.idImagrti = 0
                     self.idImagcoherence = 0
                     self.idImagpower = 0
                     self.idImagrtinoise = 0
                     self.idImagspectraHeis = 0
                     self.idImagrtiHeis = 0
                     self.dataPath = None
                     self.online = 0
                     self.walk = 0
                     self.create = False
                     self.selectedItemTree = None
                     self.controllerObj = None
             #         self.commCtrlPThread = None
             #         self.create_figure()
                     self.temporalFTP = ftpBuffer()
                     self.projectProperCaracteristica = []
                     self.projectProperPrincipal = []
                     self.projectProperDescripcion = []
                     self.volProperCaracteristica = []
                     self.volProperPrincipal = []
                     self.volProperDescripcion = []
                     self.specProperCaracteristica = []
                     self.specProperPrincipal = []
                     self.specProperDescripcion = []
                     self.specHeisProperCaracteristica = []
                     self.specHeisProperPrincipal = []
                     self.specHeisProperDescripcion = []
                     # self.pathWorkSpace = './'
                     self.__projectObjDict = {}
                     self.__operationObjDict = {}
                     self.__puLocalFolder2FTP = {}
                     self.__initialized = False
             #         self.create_comm()
                     self.create_updating_timer()
                     self.setParameter()
                 @pyqtSignature("")
                 def on_actionOpen_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.openProject()
                 @pyqtSignature("")
                 def on_actionCreate_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.setInputsProject_View()
                     self.create = True
                 @pyqtSignature("")
                 def on_actionSave_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.saveProject()
                 @pyqtSignature("")
                 def on_actionClose_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.close()
                 @pyqtSignature("")
                 def on_actionStart_triggered(self):
                     """
                     """
                     self.playProject()
                 @pyqtSignature("")
                 def on_actionPause_triggered(self):
                     """
                     """
                     self.pauseProject()
                 @pyqtSignature("")
                 def on_actionStop_triggered(self):
                     """
                     """
                     self.stopProject()
                 @pyqtSignature("")
                 def on_actionFTP_triggered(self):
                     """
                     """
                     self.configFTPWindowObj = Ftp(self)
                     if not self.temporalFTP.create:
                         self.temporalFTP.setwithoutconfiguration()
                     self.configFTPWindowObj.setParmsfromTemporal(self.temporalFTP.server,
                                                                  self.temporalFTP.remotefolder,
                                                                  self.temporalFTP.username,
                                                                  self.temporalFTP.password,
                                                                  self.temporalFTP.ftp_wei,
                                                                  self.temporalFTP.exp_code,
                                                                  self.temporalFTP.sub_exp_code,
                                                                  self.temporalFTP.plot_pos)
                     self.configFTPWindowObj.show()
                     self.configFTPWindowObj.closed.connect(self.createFTPConfig)
                 def createFTPConfig(self):
                     if not self.configFTPWindowObj.create:
                         self.console.clear()
                         self.console.append("There is no FTP configuration")
                         return
                     self.console.append("Push Ok in Spectra view to Add FTP Configuration")
                     server, remotefolder, username, password, ftp_wei, exp_code, sub_exp_code, plot_pos = self.configFTPWindowObj.getParmsFromFtpWindow()
                     self.temporalFTP.save(server=server,
                                           remotefolder=remotefolder,
                                           username=username,
                                           password=password,
                                           ftp_wei=ftp_wei,
                                           exp_code=exp_code,
                                           sub_exp_code=sub_exp_code,
                                           plot_pos=plot_pos)
                 @pyqtSignature("")
                 def on_actionOpenToolbar_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.openProject()
                 @pyqtSignature("")
                 def on_actionCreateToolbar_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.setInputsProject_View()
                     self.create = True
                 @pyqtSignature("")
                 def on_actionAddPU_triggered(self):
                     if len(self.__projectObjDict) == 0:
                         outputstr = "First Create a Project then add Processing Unit"
                         self.console.clear()
                         self.console.append(outputstr)
                         return 0
                     else:
                        self.addPUWindow()
                        self.console.clear()
                        self.console.append("Please, Choose the type of Processing Unit")
                        self.console.append("If your Datatype is rawdata, you will start with processing unit Type Voltage")
                        self.console.append("If your Datatype is pdata, you will choose between processing unit Type Spectra or Correlation")
                        self.console.append("If your Datatype is fits, you will start with processing unit Type SpectraHeis")
                 @pyqtSignature("")
                 def on_actionSaveToolbar_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.saveProject()
                 @pyqtSignature("")
                 def on_actionStarToolbar_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.playProject()
                 @pyqtSignature("")
                 def on_actionPauseToolbar_triggered(self):
                     self.pauseProject()
                 @pyqtSignature("")
                 def on_actionStopToolbar_triggered(self):
                     """
                     Slot documentation goes here.
                     """
                     self.stopProject()
                 @pyqtSignature("int")
                 def on_proComReadMode_activated(self, index):
                     """
                     SELECCION DEL MODO DE LECTURA ON=1, OFF=0
                     """
                     if index == 0:
                        self.online = 0
                        self.proDelay.setText("0")
                        self.proSet.setText("")
                        self.proSet.setEnabled(False)
                        self.proDelay.setEnabled(False)
                     elif index == 1:
                         self.online = 1
                         self.proSet.setText(" ")
                         self.proDelay.setText("5")
                         self.proSet.setEnabled(True)
                         self.proDelay.setEnabled(True)
                 @pyqtSignature("int")
                 def on_proComDataType_activated(self, index):
                     """
                     Voltage or Spectra
                     """
                     self.labelSet.show()
                     self.proSet.show()
                     self.labelIPPKm.hide()
                     self.proIPPKm.hide()
                     if index == 0:
                         extension = '.r'
                     elif index == 1:
                         extension = '.pdata'
                     elif index == 2:
                         extension = '.fits'
                     elif index == 3:
                         extension = '.hdf5'
                         self.labelSet.hide()
                         self.proSet.hide()
                         self.labelIPPKm.show()
                         self.proIPPKm.show()
                     self.proDataType.setText(extension)
                 @pyqtSignature("int")
                 def on_proComWalk_activated(self, index):
                     """
                     """
                     if index == 0:
                        self.walk = 0
                     elif index == 1:
                         self.walk = 1
                 @pyqtSignature("")
                 def on_proToolPath_clicked(self):
                     """
                     Choose your path
                     """
                     current_dpath = './'
                     if self.dataPath:
                         current_dpath = self.dataPath
                     datapath = str(QtGui.QFileDialog.getExistingDirectory(self, 'Open Directory', current_dpath, QtGui.QFileDialog.ShowDirsOnly))
                     #If it was canceled
                     if not datapath:
                         return
                     #If any change was done
                     if datapath == self.dataPath:
                         return
                     self.proDataPath.setText(datapath)
                     self.actionStart.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     self.proOk.setEnabled(False)
                     self.proComStartDate.clear()
                     self.proComEndDate.clear()
                     if not os.path.exists(datapath):
                         self.console.clear()
                         self.console.append("Write a correct a path")
                         return
                     self.dataPath = datapath
                     self.console.clear()
                     self.console.append("Select the read mode and press 'load button'")
                 @pyqtSignature("")
                 def on_proLoadButton_clicked(self):
                     self.console.clear()
                     parameter_list = self.checkInputsProject()
                     if not parameter_list[0]:
                         return
                     parms_ok, project_name, datatype, ext, data_path, read_mode, delay, walk, set = parameter_list
                     if read_mode == "Offline":
                         self.proComStartDate.clear()
                         self.proComEndDate.clear()
                         self.proComStartDate.setEnabled(True)
                         self.proComEndDate.setEnabled(True)
                         self.proStartTime.setEnabled(True)
                         self.proEndTime.setEnabled(True)
                         self.frame_2.setEnabled(True)
                     if read_mode == "Online":
                         self.proComStartDate.addItem("2000/01/30")
                         self.proComEndDate.addItem("2016/12/31")
                         self.proComStartDate.setEnabled(False)
                         self.proComEndDate.setEnabled(False)
                         self.proStartTime.setEnabled(False)
                         self.proEndTime.setEnabled(False)
                         self.frame_2.setEnabled(True)
                     self.loadDays(data_path, ext, walk)
                 @pyqtSignature("int")
                 def on_proComStartDate_activated(self, index):
                     """
                     SELECCION DEL RANGO DE FECHAS -START DATE
                     """
                     stopIndex = self.proComEndDate.count() - self.proComEndDate.currentIndex()
                     self.proComEndDate.clear()
                     for i in self.dateList[index:]:
                         self.proComEndDate.addItem(i)
                     self.proComEndDate.setCurrentIndex(self.proComEndDate.count() - stopIndex)
                 @pyqtSignature("int")
                 def on_proComEndDate_activated(self, index):
                     """
                     SELECCION DEL RANGO DE FECHAS-END DATE
                     """
                     startIndex = self.proComStartDate.currentIndex()
                     stopIndex = self.proComEndDate.count() - index
                     self.proComStartDate.clear()
                     for i in self.dateList[:len(self.dateList) - stopIndex + 1]:
                         self.proComStartDate.addItem(i)
                     self.proComStartDate.setCurrentIndex(startIndex)
                 @pyqtSignature("")
                 def on_proOk_clicked(self):
                     """
                     Añade al Obj XML de Projecto, name,datatype,date,time,readmode,wait,etc, crea el readUnitProcess del archivo xml.
                     Prepara la configuración del diágrama del Arbol del treeView numero 2
                     """
                     self.actionStart.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     if self.create:
                         projectId = self.__getNewProjectId()
                         if not projectId:
                             return 0
                         projectObjView = self.createProjectView(projectId)
                         if not projectObjView:
                             return 0
                         readUnitObj = self.createReadUnitView(projectObjView)
                         if not readUnitObj:
                             return 0
                     else:
                         projectObjView = self.updateProjectView()
                         if not projectObjView:
                             return 0
                         projectId = projectObjView.getId()
                         idReadUnit = projectObjView.getReadUnitId()
                         readUnitObj = self.updateReadUnitView(projectObjView, idReadUnit)
                         if not readUnitObj:
                             return 0
                         self.__itemTreeDict[projectId].setText(projectObjView.name)
                     # Project Properties
                     self.refreshProjectProperties(projectObjView)
                     # Disable tabProject after finish the creation
                     self.actionStart.setEnabled(True)
                     self.actionStarToolbar.setEnabled(True)
                     self.console.clear()
                     self.console.append("The project parameters were validated")
                     return 1
                 @pyqtSignature("")
                 def on_proClear_clicked(self):
                     self.console.clear()
                 @pyqtSignature("int")
                 def on_volOpCebChannels_stateChanged(self, p0):
                     """
                     Check Box habilita operaciones de Selecci�n de Canales
                     """
                     if  p0 == 2:
                         self.volOpComChannels.setEnabled(True)
                         self.volOpChannel.setEnabled(True)
                     if  p0 == 0:
                         self.volOpComChannels.setEnabled(False)
                         self.volOpChannel.setEnabled(False)
                         self.volOpChannel.clear()
                 @pyqtSignature("int")
                 def on_volOpCebHeights_stateChanged(self, p0):
                     """
                     Check Box habilita operaciones de Selecci�n de Alturas
                     """
                     if  p0 == 2:
                         self.volOpHeights.setEnabled(True)
                         self.volOpComHeights.setEnabled(True)
                     if  p0 == 0:
                         self.volOpHeights.setEnabled(False)
                         self.volOpHeights.clear()
                         self.volOpComHeights.setEnabled(False)
                 @pyqtSignature("int")
                 def on_volOpCebFilter_stateChanged(self, p0):
                      """
                      Name='Decoder', optype='other'
                      """
                      if  p0 == 2:
                         self.volOpFilter.setEnabled(True)
                      if  p0 == 0:
                         self.volOpFilter.setEnabled(False)
                         self.volOpFilter.clear()
                 @pyqtSignature("int")
                 def on_volOpCebProfile_stateChanged(self, p0):
                     """
                     Check Box habilita ingreso  del rango de Perfiles
                     """
                     if  p0 == 2:
                         self.volOpComProfile.setEnabled(True)
                         self.volOpProfile.setEnabled(True)
                     if  p0 == 0:
                         self.volOpComProfile.setEnabled(False)
                         self.volOpProfile.setEnabled(False)
                         self.volOpProfile.clear()
                 @pyqtSignature("int")
                 def on_volOpComProfile_activated(self, index):
                     """
                     Check Box habilita ingreso  del rango de Perfiles
                     """
                     #Profile List
                     if  index == 0:
                         self.volOpProfile.setToolTip('List of selected profiles. Example: 0, 1, 2, 3, 4, 5, 6, 7')
                     #Profile Range
                     if  index == 1:
                         self.volOpProfile.setToolTip('Minimum and maximum profile index. Example: 0, 7')
                     #Profile Range List
                     if index == 2:
                         self.volOpProfile.setToolTip('List of profile ranges. Example: (0, 7), (12, 19), (100, 200)')
                 @pyqtSignature("int")
                 def on_volOpCebDecodification_stateChanged(self, p0):
                     """
                     Check Box habilita
                     """
                     if  p0 == 2:
                         self.volOpComCode.setEnabled(True)
                         self.volOpComMode.setEnabled(True)
                     if  p0 == 0:
                         self.volOpComCode.setEnabled(False)
                         self.volOpComMode.setEnabled(False)
                 @pyqtSignature("int")
                 def on_volOpComCode_activated(self, index):
                     """
                     Check Box habilita ingreso
                     """
                     if  index == 13:
                         self.volOpCode.setEnabled(True)
                     else:
                         self.volOpCode.setEnabled(False)
                         if index == 0:
                             code = ''
                             self.volOpCode.setText(str(code))
                             return
                         if index == 1:
                             code = '(1,1,-1)'
                             nCode = '1'
                             nBaud = '3'
                         if index == 2:
                             code = '(1,1,-1,1)'
                             nCode = '1'
                             nBaud = '4'
                         if index == 3:
                             code = '(1,1,1,-1,1)'
                             nCode = '1'
                             nBaud = '5'
                         if index == 4:
                             code = '(1,1,1,-1,-1,1,-1)'
                             nCode = '1'
                             nBaud = '7'
                         if index == 5:
                             code = '(1,1,1,-1,-1,-1,1,-1,-1,1,-1)'
                             nCode = '1'
                             nBaud = '11'
                         if index == 6:
                             code = '(1,1,1,1,1,-1,-1,1,1,-1,1,-1,1)'
                             nCode = '1'
                             nBaud = '13'
                         if index == 7:
                             code = '(1,1,-1,-1,-1,1)'
                             nCode = '2'
                             nBaud = '3'
                         if index == 8:
                             code = '(1,1,-1,1,-1,-1,1,-1)'
                             nCode = '2'
                             nBaud = '4'
                         if index == 9:
                             code = '(1,1,1,-1,1,-1,-1,-1,1,-1)'
                             nCode = '2'
                             nBaud = '5'
                         if index == 10:
                             code = '(1,1,1,-1,-1,1,-1,-1,-1,-1,1,1,-1,1)'
                             nCode = '2'
                             nBaud = '7'
                         if index == 11:
                             code = '(1,1,1,-1,-1,-1,1,-1,-1,1,-1,-1 ,-1 ,-1 ,1 ,1,1,-1 ,1 ,1 ,-1 ,1)'
                             nCode = '2'
                             nBaud = '11'
                         if index == 12:
                             code = '(1,1,1,1,1,-1,-1,1,1,-1,1,-1,1,-1,-1,-1,-1,-1,1,1,-1,-1,1,-1,1,-1)'
                             nCode = '2'
                             nBaud = '13'
                         code = ast.literal_eval(code)
                         nCode = int(nCode)
                         nBaud = int(nBaud)
                         code = numpy.asarray(code).reshape((nCode, nBaud)).tolist()
                         self.volOpCode.setText(str(code))
                 @pyqtSignature("int")
                 def on_volOpCebFlip_stateChanged(self, p0):
                     """
                     Check Box habilita ingresode del numero de Integraciones a realizar
                     """
                     if  p0 == 2:
                         self.volOpFlip.setEnabled(True)
                     if  p0 == 0:
                         self.volOpFlip.setEnabled(False)
                         self.volOpFlip.clear()
                 @pyqtSignature("int")
                 def on_volOpCebCohInt_stateChanged(self, p0):
                     """
                     Check Box habilita ingresode del numero de Integraciones a realizar
                     """
                     if  p0 == 2:
                         self.volOpCohInt.setEnabled(True)
                     if  p0 == 0:
                         self.volOpCohInt.setEnabled(False)
                         self.volOpCohInt.clear()
                 @pyqtSignature("int")
                 def on_volOpCebRadarfrequency_stateChanged(self, p0):
                     """
                     Check Box habilita ingresode del numero de Integraciones a realizar
                     """
                     if  p0 == 2:
                         self.volOpRadarfrequency.setEnabled(True)
                     if  p0 == 0:
                         self.volOpRadarfrequency.clear()
                         self.volOpRadarfrequency.setEnabled(False)
                 @pyqtSignature("")
                 def on_volOutputToolPath_clicked(self):
                     dirOutPath = str(QtGui.QFileDialog.getExistingDirectory(self, 'Open Directory', './', QtGui.QFileDialog.ShowDirsOnly))
                     self.volOutputPath.setText(dirOutPath)
                 @pyqtSignature("")
                 def on_specOutputToolPath_clicked(self):
                     dirOutPath = str(QtGui.QFileDialog.getExistingDirectory(self, 'Open Directory', './', QtGui.QFileDialog.ShowDirsOnly))
                     self.specOutputPath.setText(dirOutPath)
                 @pyqtSignature("")
                 def on_specHeisOutputToolPath_clicked(self):
                     dirOutPath = str(QtGui.QFileDialog.getExistingDirectory(self, 'Open Directory', './', QtGui.QFileDialog.ShowDirsOnly))
                     self.specHeisOutputPath.setText(dirOutPath)
                 @pyqtSignature("")
                 def on_specHeisOutputMetadaToolPath_clicked(self):
                     filename = str(QtGui.QFileDialog.getOpenFileName(self, "Open text file", self.pathWorkSpace, self.tr("Text Files (*.xml)")))
                     self.specHeisOutputMetada.setText(filename)
                 @pyqtSignature("")
                 def on_volOpOk_clicked(self):
                     """
                     BUSCA EN LA LISTA DE OPERACIONES DEL TIPO VOLTAJE Y LES A�ADE EL PARAMETRO ADECUADO ESPERANDO LA ACEPTACION DEL USUARIO
                     PARA AGREGARLO AL ARCHIVO DE CONFIGURACION XML
                     """
                     checkPath = False
                     self.actionSaveToolbar.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     puObj = self.getSelectedItemObj()
                     puObj.removeOperations()
                     if self.volOpCebRadarfrequency.isChecked():
                         value = str(self.volOpRadarfrequency.text())
                         format = 'float'
                         name_operation = 'setRadarFrequency'
                         name_parameter = 'frequency'
                         if not value == "":
                             try:
                                 radarfreq = float(self.volOpRadarfrequency.text())*1e6
                             except:
                                 self.console.clear()
                                 self.console.append("Write the parameter Radar Frequency  type float")
                                 return 0
                             opObj = puObj.addOperation(name=name_operation)
                             opObj.addParameter(name=name_parameter, value=radarfreq, format=format)
                     if self.volOpCebChannels.isChecked():
                         value = str(self.volOpChannel.text())
                         if value == "":
                             print "Please fill channel list"
                             return 0
                         format = 'intlist'
                         if self.volOpComChannels.currentIndex() == 0:
                             name_operation = "selectChannels"
                             name_parameter = 'channelList'
                         else:
                             name_operation = "selectChannelsByIndex"
                             name_parameter = 'channelIndexList'
                         opObj = puObj.addOperation(name=name_operation)
                         opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.volOpCebHeights.isChecked():
                        value = str(self.volOpHeights.text())
                        if value == "":
                             print "Please fill height range"
                             return 0
                        valueList = value.split(',')
                        format = 'float'
                        if  self.volOpComHeights.currentIndex() == 0:
                            name_operation = 'selectHeights'
                            name_parameter1 = 'minHei'
                            name_parameter2 = 'maxHei'
                        else:
                            name_operation = 'selectHeightsByIndex'
                            name_parameter1 = 'minIndex'
                            name_parameter2 = 'maxIndex'
                        opObj = puObj.addOperation(name=name_operation)
                        opObj.addParameter(name=name_parameter1, value=valueList[0], format=format)
                        opObj.addParameter(name=name_parameter2, value=valueList[1], format=format)
                     if self.volOpCebFilter.isChecked():
                        value = str(self.volOpFilter.text())
                        if value == "":
                             print "Please fill filter value"
                             return 0
                        format = 'int'
                        name_operation = 'filterByHeights'
                        name_parameter = 'window'
                        opObj = puObj.addOperation(name=name_operation)
                        opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.volOpCebProfile.isChecked():
                         value = str(self.volOpProfile.text())
                         if value == "":
                             print "Please fill profile value"
                             return 0
                         format = 'intlist'
                         optype = 'other'
                         name_operation = 'ProfileSelector'
                         if self.volOpComProfile.currentIndex() == 0:
                             name_parameter = 'profileList'
                         if self.volOpComProfile.currentIndex() == 1:
                             name_parameter = 'profileRangeList'
                         if self.volOpComProfile.currentIndex() == 2:
                             name_parameter = 'rangeList'
                         opObj = puObj.addOperation(name='ProfileSelector', optype='other')
                         opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.volOpCebDecodification.isChecked():
                         if self.volOpComMode.currentIndex() == 0:
                             mode = '0'
                         if self.volOpComMode.currentIndex() == 1:
                             mode = '1'
                         if self.volOpComMode.currentIndex() == 2:
                             mode = '2'
                         if self.volOpComCode.currentIndex() == 0:
                             opObj = puObj.addOperation(name='Decoder', optype='other')
                             opObj.addParameter(name='mode', value=mode, format='int')
                         else:
                             #User defined
                             code = str(self.volOpCode.text())
                             try:
                                 code_tmp = ast.literal_eval(code)
                             except:
                                 code_tmp = []
                             if len(code_tmp) < 1:
                                 self.console.append("Please fill the code value")
                                 return 0
                             if len(code_tmp) == 1 or type(code_tmp[0]) != int:
                                 nBaud = len(code_tmp[0])
                                 nCode = len(code_tmp)
                             else:
                                 nBaud = len(code_tmp)
                                 nCode = 1
                             opObj = puObj.addOperation(name='Decoder', optype='other')
                             code = code.replace("(", "")
                             code = code.replace(")", "")
                             code = code.replace("[", "")
                             code = code.replace("]", "")
                             opObj.addParameter(name='code', value=code, format='intlist')
                             opObj.addParameter(name='nCode', value=nCode, format='int')
                             opObj.addParameter(name='nBaud', value=nBaud, format='int')
                             opObj.addParameter(name='mode', value=mode, format='int')
                     if self.volOpCebFlip.isChecked():
                         name_operation = 'deFlip'
                         optype = 'self'
                         value = str(self.volOpFlip.text())
                         name_parameter = 'channelList'
                         format = 'intlist'
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
                         if value:
                             opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.volOpCebCohInt.isChecked():
                         name_operation = 'CohInt'
                         optype = 'other'
                         value = str(self.volOpCohInt.text())
                         if value == "":
                             print "Please fill number of coherent integrations"
                             return 0
                         name_parameter = 'n'
                         format = 'float'
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
                         opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.volGraphCebshow.isChecked():
                         name_operation = 'Scope'
                         optype = 'other'
                         name_parameter = 'type'
                         value = 'Scope'
                         if self.idImagscope == 0:
                             self.idImagscope = 100
                         else:
                             self.idImagscope = self.idImagscope + 1
                         name_parameter1 = 'id'
                         value1 = int(self.idImagscope)
                         format1 = 'int'
                         format = 'str'
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
             #             opObj.addParameter(name=name_parameter, value=value, format=format)
                         opObj.addParameter(name=name_parameter1, value=opObj.id, format=format1)
                         channelList = str(self.volGraphChannelList.text()).replace(" ","")
                         xvalue = str(self.volGraphfreqrange.text()).replace(" ","")
                         yvalue = str(self.volGraphHeightrange.text()).replace(" ","")
                         if channelList:
                             opObj.addParameter(name='channelList', value=channelList, format='intlist')
                         if xvalue:
                             xvalueList = xvalue.split(',')
                             try:
                                value0 = float(xvalueList[0])
                                value1 = float(xvalueList[1])
                             except:
                                 return 0
                             opObj.addParameter(name='xmin', value=value0, format='float')
                             opObj.addParameter(name='xmax', value=value1, format='float')
                         if not yvalue == "":
                            yvalueList = yvalue.split(",")
                            try:
                                value0 = int(yvalueList[0])
                                value1 = int(yvalueList[1])
                            except:
                                 return 0
                            opObj.addParameter(name='ymin', value=value0, format='int')
                            opObj.addParameter(name='ymax', value=value1, format='int')
                         if self.volGraphCebSave.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value='1', format='int')
                             opObj.addParameter(name='figpath', value=self.volGraphPath.text(), format='str')
                             value = str(self.volGraphPrefix.text()).replace(" ","")
                             if value:
                                opObj.addParameter(name='figfile', value=value, format='str')
                     localfolder = None
                     if checkPath:
                         localfolder = str(self.volGraphPath.text())
                         if localfolder == '':
                             self.console.clear()
                             self.console.append("Graphic path should be defined")
                             return 0
                     # if something happend
                     parms_ok, output_path, blocksperfile, profilesperblock = self.checkInputsPUSave(datatype='Voltage')
                     if parms_ok:
                         name_operation = 'VoltageWriter'
                         optype = 'other'
                         name_parameter1 = 'path'
                         name_parameter2 = 'blocksPerFile'
                         name_parameter3 = 'profilesPerBlock'
                         value1 = output_path
                         value2 = blocksperfile
                         value3 = profilesperblock
                         format = "int"
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
                         opObj.addParameter(name=name_parameter1, value=value1)
                         opObj.addParameter(name=name_parameter2, value=value2, format=format)
                         opObj.addParameter(name=name_parameter3, value=value3, format=format)
                     self.console.clear()
                     try:
                         self.refreshPUProperties(puObj)
                     except:
                         self.console.append("Check input parameters")
                         return 0
                     self.console.append("If you want to save your project")
                     self.console.append("click on your project name in the Tree Project Explorer")
                     self.actionSaveToolbar.setEnabled(True)
                     self.actionStarToolbar.setEnabled(True)
                     return 1
                 """
                 Voltage Graph
                 """
                 @pyqtSignature("int")
                 def on_volGraphCebSave_stateChanged(self, p0):
                     """
                     Check Box habilita ingresode del numero de Integraciones a realizar
                     """
                     if  p0 == 2:
                         self.volGraphPath.setEnabled(True)
                         self.volGraphPrefix.setEnabled(True)
                         self.volGraphToolPath.setEnabled(True)
                     if  p0 == 0:
                         self.volGraphPath.setEnabled(False)
                         self.volGraphPrefix.setEnabled(False)
                         self.volGraphToolPath.setEnabled(False)
                 @pyqtSignature("")
                 def on_volGraphToolPath_clicked(self):
                     """
                     Donde se guardan los DATOS
                     """
                     self.dataPath = str(QtGui.QFileDialog.getExistingDirectory(self, 'Open Directory', './', QtGui.QFileDialog.ShowDirsOnly))
                     self.volGraphPath.setText(self.dataPath)
             #         if not os.path.exists(self.dataPath):
             #             self.volGraphOk.setEnabled(False)
             #             return
                 @pyqtSignature("int")
                 def on_volGraphCebshow_stateChanged(self, p0):
                     """
                     Check Box habilita ingresode del numero de Integraciones a realizar
                     """
                     if p0 == 0:
                        self.volGraphChannelList.setEnabled(False)
                        self.volGraphfreqrange.setEnabled(False)
                        self.volGraphHeightrange.setEnabled(False)
                     if p0 == 2:
                        self.volGraphChannelList.setEnabled(True)
                        self.volGraphfreqrange.setEnabled(True)
                        self.volGraphHeightrange.setEnabled(True)
                 """
                 Spectra operation
                 """
                 @pyqtSignature("int")
                 def on_specOpCebRadarfrequency_stateChanged(self, p0):
                     """
                     Check Box habilita ingresode del numero de Integraciones a realizar
                     """
                     if  p0 == 2:
                         self.specOpRadarfrequency.setEnabled(True)
                     if  p0 == 0:
                         self.specOpRadarfrequency.clear()
                         self.specOpRadarfrequency.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specOpCebCrossSpectra_stateChanged(self, p0):
                     """
                     Habilita la opcion de a�adir el par�metro CrossSpectra a la Unidad de Procesamiento .
                     """
                     if  p0 == 2:
                       #  self.specOpnFFTpoints.setEnabled(True)
                         self.specOppairsList.setEnabled(True)
                     if  p0 == 0:
                       #  self.specOpnFFTpoints.setEnabled(False)
                         self.specOppairsList.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specOpCebChannel_stateChanged(self, p0):
                     """
                     Habilita la opcion de a�adir el par�metro numero de Canales a la Unidad de Procesamiento .
                     """
                     if  p0 == 2:
                         self.specOpChannel.setEnabled(True)
                         self.specOpComChannel.setEnabled(True)
                     if  p0 == 0:
                         self.specOpChannel.setEnabled(False)
                         self.specOpComChannel.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specOpCebHeights_stateChanged(self, p0):
                     """
                     Habilita la opcion de a�adir el par�metro de alturas a la Unidad de Procesamiento .
                     """
                     if  p0 == 2:
                         self.specOpComHeights.setEnabled(True)
                         self.specOpHeights.setEnabled(True)
                     if  p0 == 0:
                         self.specOpComHeights.setEnabled(False)
                         self.specOpHeights.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specOpCebIncoherent_stateChanged(self, p0):
                     """
                     Habilita la opcion de a�adir el par�metro integraciones incoherentes a la Unidad de Procesamiento .
                     """
                     if  p0 == 2:
                         self.specOpIncoherent.setEnabled(True)
                     if  p0 == 0:
                         self.specOpIncoherent.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specOpCebRemoveDC_stateChanged(self, p0):
                     """
                     Habilita la opcion de a�adir el par�metro remover DC a la Unidad de Procesamiento .
                     """
                     if  p0 == 2:
                         self.specOpComRemoveDC.setEnabled(True)
                     if  p0 == 0:
                         self.specOpComRemoveDC.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specOpCebgetNoise_stateChanged(self, p0):
                     """
                     Habilita la opcion de a�adir la estimacion de ruido a la Unidad de Procesamiento .
                     """
                     if  p0 == 2:
                         self.specOpgetNoise.setEnabled(True)
                     if  p0 == 0:
                         self.specOpgetNoise.setEnabled(False)
                 @pyqtSignature("")
                 def on_specOpOk_clicked(self):
                     """
                     AÑADE OPERACION SPECTRA
                     """
                     addFTP = False
                     checkPath = False
                     self.actionSaveToolbar.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     projectObj = self.getSelectedProjectObj()
                     puObj = self.getSelectedItemObj()
                     puObj.removeOperations()
                     if self.specOpCebRadarfrequency.isChecked():
                         value = self.specOpRadarfrequency.text()
                         format = 'float'
                         name_operation = 'setRadarFrequency'
                         name_parameter = 'frequency'
                         if not value == "":
                             try:
                                 radarfreq = float(self.specOpRadarfrequency.text())*1e6
                             except:
                                 self.console.clear()
                                 self.console.append("Write the parameter Radar Frequency  type float")
                                 return 0
                             opObj = puObj.addOperation(name=name_operation)
                             opObj.addParameter(name=name_parameter, value=radarfreq, format=format)
                     inputId = puObj.getInputId()
                     inputPuObj = projectObj.getProcUnitObj(inputId)
                     if inputPuObj.datatype == 'Voltage' or inputPuObj.datatype == 'USRP':
                         try:
                             value = int(self.specOpnFFTpoints.text())
                             puObj.addParameter(name='nFFTPoints', value=value, format='int')
                         except:
                             self.console.clear()
                             self.console.append("Please write the number of FFT")
                             return 0
                         try:
                             value1 = int(self.specOpProfiles.text())
                             puObj.addParameter(name='nProfiles', value=value1, format='int')
                         except:
                             self.console.append("Please Write the number of Profiles")
                         try:
                             value2 = int(self.specOpippFactor.text())
                             puObj.addParameter(name='ippFactor' , value=value2 , format='int')
                         except:
                             self.console.append("Please Write the Number of IppFactor")
                     if self.specOpCebCrossSpectra.isChecked():
                         name_parameter = 'pairsList'
                         format = 'pairslist'
                         value2 = self.specOppairsList.text()
                         if value2 == "":
                             print "Please fill the pairs list field"
                             return 0
                         puObj.addParameter(name=name_parameter, value=value2, format=format)
                     if self.specOpCebHeights.isChecked():
                         value = str(self.specOpHeights.text())
                         if value == "":
                             print "Please fill height range"
                             return 0
                         valueList = value.split(',')
                         format = 'float'
                         value0 = valueList[0]
                         value1 = valueList[1]
                         if self.specOpComHeights.currentIndex() == 0:
                             name_operation = 'selectHeights'
                             name_parameter1 = 'minHei'
                             name_parameter2 = 'maxHei'
                         else:
                             name_operation = 'selectHeightsByIndex'
                             name_parameter1 = 'minIndex'
                             name_parameter2 = 'maxIndex'
                         opObj = puObj.addOperation(name=name_operation)
                         opObj.addParameter(name=name_parameter1, value=value0, format=format)
                         opObj.addParameter(name=name_parameter2, value=value1, format=format)
                     if self.specOpCebChannel.isChecked():
                         value = str(self.specOpChannel.text())
                         if value == "":
                             print "Please fill channel list"
                             return 0
                         format = 'intlist'
                         if self.specOpComChannel.currentIndex() == 0:
                             name_operation = "selectChannels"
                             name_parameter = 'channelList'
                         else:
                             name_operation = "selectChannelsByIndex"
                             name_parameter = 'channelIndexList'
                         opObj = puObj.addOperation(name=name_operation)
                         opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.specOpCebIncoherent.isChecked():
                         value = str(self.specOpIncoherent.text())
                         if value == "":
                             print "Please fill Incoherent integration value"
                             return 0
                         name_operation = 'IncohInt'
                         optype = 'other'
                         if self.specOpCobIncInt.currentIndex() == 0:
                             name_parameter = 'timeInterval'
                             format = 'float'
                         else:
                             name_parameter = 'n'
                             format = 'float'
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
                         opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.specOpCebRemoveDC.isChecked():
                         name_operation = 'removeDC'
                         name_parameter = 'mode'
                         format = 'int'
                         if self.specOpComRemoveDC.currentIndex() == 0:
                             value = 1
                         else:
                             value = 2
                         opObj = puObj.addOperation(name=name_operation)
                         opObj.addParameter(name=name_parameter, value=value, format=format)
                     if self.specOpCebRemoveInt.isChecked():
                         name_operation = 'removeInterference'
                         opObj = puObj.addOperation(name=name_operation)
                     if self.specOpCebgetNoise.isChecked():
                         value = self.specOpgetNoise.text()
                         valueList = value.split(',')
                         format = 'float'
                         name_operation = "getNoise"
                         opObj = puObj.addOperation(name=name_operation)
                         if not value == '':
                            valueList = value.split(',')
                            length = len(valueList)
                            if length == 1:
                                try:
                                    value1 = float(valueList[0])
                                except:
                                    self.console.clear()
                                    self.console.append("Please Write  correct parameter Get Noise")
                                    return 0
                                name1 = 'minHei'
                                opObj.addParameter(name=name1, value=value1, format=format)
                            elif length == 2:
                                try:
                                    value1 = float(valueList[0])
                                    value2 = float(valueList[1])
                                except:
                                    self.console.clear()
                                    self.console.append("Please Write  corrects parameter Get Noise")
                                    return 0
                                name1 = 'minHei'
                                name2 = 'maxHei'
                                opObj.addParameter(name=name1, value=value1, format=format)
                                opObj.addParameter(name=name2, value=value2, format=format)
                            elif length == 3:
                                try:
                                    value1 = float(valueList[0])
                                    value2 = float(valueList[1])
                                    value3 = float(valueList[2])
                                except:
                                    self.console.clear()
                                    self.console.append("Please Write  corrects parameter Get Noise")
                                    return 0
                                name1 = 'minHei'
                                name2 = 'maxHei'
                                name3 = 'minVel'
                                opObj.addParameter(name=name1, value=value1, format=format)
                                opObj.addParameter(name=name2, value=value2, format=format)
                                opObj.addParameter(name=name3, value=value3, format=format)
                            elif length == 4:
                                try:
                                    value1 = float(valueList[0])
                                    value2 = float(valueList[1])
                                    value3 = float(valueList[2])
                                    value4 = float(valueList[3])
                                except:
                                    self.console.clear()
                                    self.console.append("Please Write  corrects parameter Get Noise")
                                    return 0
                                name1 = 'minHei'
                                name2 = 'maxHei'
                                name3 = 'minVel'
                                name4 = 'maxVel'
                                opObj.addParameter(name=name1, value=value1, format=format)
                                opObj.addParameter(name=name2, value=value2, format=format)
                                opObj.addParameter(name=name3, value=value3, format=format)
                                opObj.addParameter(name=name4, value=value4, format=format)
                            elif length > 4:
                                self.console.clear()
                                self.console.append("Get Noise Operation only accepts  4 parameters")
                                return 0
                     channelList = str(self.specGgraphChannelList.text()).replace(" ","")
                     vel_range = str(self.specGgraphFreq.text()).replace(" ","")
                     hei_range = str(self.specGgraphHeight.text()).replace(" ","")
                     db_range = str(self.specGgraphDbsrange.text()).replace(" ","")
                     trange = str(self.specGgraphTminTmax.text()).replace(" ","")
                     magrange = str(self.specGgraphmagnitud.text()).replace(" ","")
                     phaserange = str(self.specGgraphPhase.text()).replace(" ","")
             #         timerange = str(self.specGgraphTimeRange.text()).replace(" ","")
                     figpath = str(self.specGraphPath.text())
                     figfile = str(self.specGraphPrefix.text()).replace(" ","")
                     try:
                         wrperiod = int(str(self.specGgraphftpratio.text()).replace(" ",""))
                     except:
                         wrperiod = None
                     #-----Spectra Plot-----
                     if self.specGraphCebSpectraplot.isChecked():
                         opObj = puObj.addOperation(name='SpectraPlot', optype='other')
                         opObj.addParameter(name='id', value=opObj.id, format='int')
                         if not channelList == '':
                            opObj.addParameter(name='channelList', value=channelList, format='intlist')
                         if not vel_range == '':
                            xvalueList = vel_range.split(',')
                            try:
                                value1 = float(xvalueList[0])
                                value2 = float(xvalueList[1])
                            except:
                                self.console.clear()
                                self.console.append("Invalid velocity/frequency range")
                                return 0
                            opObj.addParameter(name='xmin', value=value1, format='float')
                            opObj.addParameter(name='xmax', value=value2, format='float')
                         if not hei_range == '':
                           yvalueList = hei_range.split(",")
                           try:
                                value1 = float(yvalueList[0])
                                value2 = float(yvalueList[1])
                           except:
                               self.console.clear()
                               self.console.append("Invalid height range")
                               return 0
                           opObj.addParameter(name='ymin', value=value1, format='float')
                           opObj.addParameter(name='ymax', value=value2, format='float')
                         if not db_range == '':
                             zvalueList = db_range.split(",")
                             try:
                                value1 = float(zvalueList[0])
                                value2 = float(zvalueList[1])
                             except:
                                self.console.clear()
                                self.console.append("Invalid db range")
                                return 0
                             opObj.addParameter(name='zmin', value=value1, format='float')
                             opObj.addParameter(name='zmax', value=value2, format='float')
                         if self.specGraphSaveSpectra.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value=1 , format='bool')
                             opObj.addParameter(name='figpath', value=figpath, format='str')
                             if figfile:
                                 opObj.addParameter(name='figfile', value=figfile, format='str')
                             if wrperiod:
                                 opObj.addParameter(name='wr_period', value=wrperiod,format='int')
                         if self.specGraphftpSpectra.isChecked():
                            opObj.addParameter(name='ftp', value='1', format='int')
                            self.addFTPConf2Operation(puObj, opObj)
                            addFTP = True
                     if self.specGraphCebCrossSpectraplot.isChecked():
                         opObj = puObj.addOperation(name='CrossSpectraPlot', optype='other')
             #             opObj.addParameter(name='power_cmap', value='jet', format='str')
             #             opObj.addParameter(name='coherence_cmap', value='jet', format='str')
             #             opObj.addParameter(name='phase_cmap', value='RdBu_r', format='str')
                         opObj.addParameter(name='id', value=opObj.id, format='int')
                         if not vel_range == '':
                             xvalueList = vel_range.split(',')
                             try:
                                 value1 = float(xvalueList[0])
                                 value2 = float(xvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid velocity/frequency range")
                                 return 0
                             opObj.addParameter(name='xmin', value=value1, format='float')
                             opObj.addParameter(name='xmax', value=value2, format='float')
                         if not hei_range == '':
                             yvalueList = hei_range.split(",")
                             try:
                                  value1 = float(yvalueList[0])
                                  value2 = float(yvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid height range")
                                 return 0
                             opObj.addParameter(name='ymin', value=value1, format='float')
                             opObj.addParameter(name='ymax', value=value2, format='float')
                         if not db_range == '':
                             zvalueList = db_range.split(",")
                             try:
                                 value1 = float(zvalueList[0])
                                 value2 = float(zvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid db range")
                                 return 0
                             opObj.addParameter(name='zmin', value=value1, format='float')
                             opObj.addParameter(name='zmax', value=value2, format='float')
                         if not magrange == '':
                             zvalueList = magrange.split(",")
                             try:
                                 value1 = float(zvalueList[0])
                                 value2 = float(zvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid magnitude range")
                                 return 0
                             opObj.addParameter(name='coh_min', value=value1, format='float')
                             opObj.addParameter(name='coh_max', value=value2, format='float')
                         if not phaserange == '':
                             zvalueList = phaserange.split(",")
                             try:
                                 value1 = float(zvalueList[0])
                                 value2 = float(zvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid phase range")
                                 return 0
                             opObj.addParameter(name='phase_min', value=value1, format='float')
                             opObj.addParameter(name='phase_max', value=value2, format='float')
                         if self.specGraphSaveCross.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value='1', format='bool')
                             opObj.addParameter(name='figpath', value=figpath, format='str')
                             if figfile:
                                opObj.addParameter(name='figfile', value=figfile, format='str')
                             if wrperiod:
                                 opObj.addParameter(name='wr_period', value=wrperiod,format='int')
                         if self.specGraphftpCross.isChecked():
                            opObj.addParameter(name='ftp', value='1', format='int')
                            self.addFTPConf2Operation(puObj, opObj)
                            addFTP = True
                     if self.specGraphCebRTIplot.isChecked():
                         opObj = puObj.addOperation(name='RTIPlot', optype='other')
                         opObj.addParameter(name='id', value=opObj.id, format='int')
                         if not channelList == '':
                             opObj.addParameter(name='channelList', value=channelList, format='intlist')
                         if not trange == '':
                             xvalueList = trange.split(',')
                             try:
                                 value1 = float(xvalueList[0])
                                 value2 = float(xvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid time range")
                                 return 0
                             opObj.addParameter(name='xmin', value=value1, format='float')
                             opObj.addParameter(name='xmax', value=value2, format='float')
             #             if not timerange == '':
             #                 try:
             #                     timerange = float(timerange)
             #                 except:
             #                     self.console.clear()
             #                     self.console.append("Invalid time range")
             #                     return 0
             #
             #                 opObj.addParameter(name='timerange', value=timerange, format='float')
                         if not hei_range == '':
                             yvalueList = hei_range.split(",")
                             try:
                                 value1 = float(yvalueList[0])
                                 value2 = float(yvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid height range")
                                 return 0
                             opObj.addParameter(name='ymin', value=value1, format='float')
                             opObj.addParameter(name='ymax', value=value2, format='float')
                         if not db_range == '':
                             zvalueList = db_range.split(",")
                             try:
                                 value1 = float(zvalueList[0])
                                 value2 = float(zvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid db range")
                                 return 0
                             opObj.addParameter(name='zmin', value=value1, format='float')
                             opObj.addParameter(name='zmax', value=value2, format='float')
                         if self.specGraphSaveRTIplot.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value='1', format='bool')
                             opObj.addParameter(name='figpath', value=figpath, format='str')
                             if figfile:
                                opObj.addParameter(name='figfile', value=value, format='str')
                             if wrperiod:
                                 opObj.addParameter(name='wr_period', value=wrperiod,format='int')
                         if self.specGraphftpRTIplot.isChecked():
                            opObj.addParameter(name='ftp', value='1', format='int')
                            self.addFTPConf2Operation(puObj, opObj)
                            addFTP = True
                     if self.specGraphCebCoherencmap.isChecked():
                         opObj = puObj.addOperation(name='CoherenceMap', optype='other')
             #             opObj.addParameter(name=name_parameter, value=value, format=format)
                         # opObj.addParameter(name='coherence_cmap', value='jet', format='str')
                         # opObj.addParameter(name='phase_cmap', value='RdBu_r', format='str')
                         opObj.addParameter(name='id', value=opObj.id, format='int')
             #             if not timerange == '':
             #                 try:
             #                     timerange = int(timerange)
             #                 except:
             #                     self.console.clear()
             #                     self.console.append("Invalid time range")
             #                     return 0
             #
             #                 opObj.addParameter(name='timerange', value=timerange, format='int')
                         if not trange == '':
                             xvalueList = trange.split(',')
                             try:
                                 value1 = float(xvalueList[0])
                                 value2 = float(xvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid time range")
                                 return 0
                             opObj.addParameter(name='xmin', value=value1, format='float')
                             opObj.addParameter(name='xmax', value=value2, format='float')
                         if not hei_range == '':
                             yvalueList = hei_range.split(",")
                             try:
                                 value1 = float(yvalueList[0])
                                 value2 = float(yvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid height range")
                                 return 0
                             opObj.addParameter(name='ymin', value=value1, format='float')
                             opObj.addParameter(name='ymax', value=value2, format='float')
                         if not magrange == '':
                             zvalueList = magrange.split(",")
                             try:
                                 value1 = float(zvalueList[0])
                                 value2 = float(zvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid magnitude range")
                                 return 0
                             opObj.addParameter(name='zmin', value=value1, format='float')
                             opObj.addParameter(name='zmax', value=value2, format='float')
                         if not phaserange == '':
                             zvalueList = phaserange.split(",")
                             try:
                                 value1 = float(zvalueList[0])
                                 value2 = float(zvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid phase range")
                                 return 0
                             opObj.addParameter(name='phase_min', value=value1, format='float')
                             opObj.addParameter(name='phase_max', value=value2, format='float')
                         if self.specGraphSaveCoherencemap.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value='1', format='bool')
                             opObj.addParameter(name='figpath', value=figpath, format='str')
                             if figfile:
                                opObj.addParameter(name='figfile', value=value, format='str')
                             if wrperiod:
                                 opObj.addParameter(name='wr_period', value=wrperiod,format='int')
                         if self.specGraphftpCoherencemap.isChecked():
                            opObj.addParameter(name='ftp', value='1', format='int')
                            self.addFTPConf2Operation(puObj, opObj)
                            addFTP = True
                     if self.specGraphPowerprofile.isChecked():
                        opObj = puObj.addOperation(name='PowerProfilePlot', optype='other')
                        opObj.addParameter(name='id', value=opObj.id, format='int')
                        if not channelList == '':
                            opObj.addParameter(name='channelList', value=channelList, format='intlist')
                        if not db_range == '':
                            xvalueList = db_range.split(',')
                            try:
                                 value1 = float(xvalueList[0])
                                 value2 = float(xvalueList[1])
                            except:
                                 self.console.clear()
                                 self.console.append("Invalid db range")
                                 return 0
                            opObj.addParameter(name='xmin', value=value1, format='float')
                            opObj.addParameter(name='xmax', value=value2, format='float')
                        if not hei_range == '':
                             yvalueList = hei_range.split(",")
                             try:
                                  value1 = float(yvalueList[0])
                                  value2 = float(yvalueList[1])
                             except:
                                  self.console.clear()
                                  self.console.append("Invalid height range")
                                  return 0
                             opObj.addParameter(name='ymin', value=value1, format='float')
                             opObj.addParameter(name='ymax', value=value2, format='float')
                        if self.specGraphSavePowerprofile.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value='1', format='bool')
                             opObj.addParameter(name='figpath', value=figpath, format='str')
                             if figfile:
                                opObj.addParameter(name='figfile', value=value, format='str')
                             if wrperiod:
                                 opObj.addParameter(name='wr_period', value=wrperiod,format='int')
                        if self.specGraphftpPowerprofile.isChecked():
                           opObj.addParameter(name='ftp', value='1', format='int')
                           self.addFTPConf2Operation(puObj, opObj)
                           addFTP = True
                        # rti noise
                     if self.specGraphCebRTInoise.isChecked():
                         opObj = puObj.addOperation(name='Noise', optype='other')
                         opObj.addParameter(name='id', value=opObj.id, format='int')
                         if not channelList == '':
                             opObj.addParameter(name='channelList', value=channelList, format='intlist')
             #             if not timerange == '':
             #                 try:
             #                     timerange = float(timerange)
             #                 except:
             #                     self.console.clear()
             #                     self.console.append("Invalid time range")
             #                     return 0
             #
             #                 opObj.addParameter(name='timerange', value=timerange, format='float')
                         if not trange == '':
                             xvalueList = trange.split(',')
                             try:
                                 value1 = float(xvalueList[0])
                                 value2 = float(xvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid time range")
                                 return 0
                             opObj.addParameter(name='xmin', value=value1, format='float')
                             opObj.addParameter(name='xmax', value=value2, format='float')
                         if not db_range == '':
                             yvalueList = db_range.split(",")
                             try:
                                 value1 = float(yvalueList[0])
                                 value2 = float(yvalueList[1])
                             except:
                                 self.console.clear()
                                 self.console.append("Invalid db range")
                                 return 0
                             opObj.addParameter(name='ymin', value=value1, format='float')
                             opObj.addParameter(name='ymax', value=value2, format='float')
                         if self.specGraphSaveRTInoise.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value='1', format='bool')
                             opObj.addParameter(name='figpath', value=figpath, format='str')
                             if figfile:
                                opObj.addParameter(name='figfile', value=value, format='str')
                             if wrperiod:
                                 opObj.addParameter(name='wr_period', value=wrperiod,format='int')
                         # test_ftp
                         if self.specGraphftpRTInoise.isChecked():
                            opObj.addParameter(name='ftp', value='1', format='int')
                            self.addFTPConf2Operation(puObj, opObj)
                            addFTP = True
                     if checkPath:
                         if not figpath:
                             self.console.clear()
                             self.console.append("Graphic path should be defined")
                             return 0
                     if addFTP and not figpath:
                             self.console.clear()
                             self.console.append("You have to save the plots before sending them to FTP Server")
                             return 0
             #      if something happend
                     parms_ok, output_path, blocksperfile, profilesperblock = self.checkInputsPUSave(datatype='Spectra')
                     if parms_ok:
                         opObj = puObj.addOperation(name='SpectraWriter', optype='other')
                         opObj.addParameter(name='path', value=output_path)
                         opObj.addParameter(name='blocksPerFile', value=blocksperfile, format='int')
                         opObj.addParameter(name='profilesPerBlock', value=profilesperblock, format='int')
                     self.console.clear()
                     try:
                         self.refreshPUProperties(puObj)
                     except:
                         self.console.append("Check input parameters")
                         return 0
                     self.console.append("If you want to save your project")
                     self.console.append("click on your project name in the Tree Project Explorer")
                     self.actionSaveToolbar.setEnabled(True)
                     self.actionStarToolbar.setEnabled(True)
                     return 1
                 """
                 Spectra  Graph
                 """
                 @pyqtSignature("int")
                 def on_specGraphCebSpectraplot_stateChanged(self, p0):
                     self.__checkSpecGraphFilters()
                 @pyqtSignature("int")
                 def on_specGraphCebCrossSpectraplot_stateChanged(self, p0):
                     self.__checkSpecGraphFilters()
                 @pyqtSignature("int")
                 def on_specGraphCebRTIplot_stateChanged(self, p0):
                     self.__checkSpecGraphFilters()
                 @pyqtSignature("int")
                 def on_specGraphCebRTInoise_stateChanged(self, p0):
                     self.__checkSpecGraphFilters()
                 @pyqtSignature("int")
                 def on_specGraphCebCoherencmap_stateChanged(self, p0):
                     self.__checkSpecGraphFilters()
                 @pyqtSignature("int")
                 def on_specGraphPowerprofile_stateChanged(self, p0):
                     self.__checkSpecGraphFilters()
                 @pyqtSignature("int")
                 def on_specGraphPhase_stateChanged(self, p0):
                     self.__checkSpecGraphFilters()
                 @pyqtSignature("int")
                 def on_specGraphSaveSpectra_stateChanged(self, p0):
                     """
                     """
                     self.__checkSpecGraphSaving()
                 @pyqtSignature("int")
                 def on_specGraphSaveCross_stateChanged(self, p0):
                     self.__checkSpecGraphSaving()
                 @pyqtSignature("int")
                 def on_specGraphSaveRTIplot_stateChanged(self, p0):
                     self.__checkSpecGraphSaving()
                 @pyqtSignature("int")
                 def on_specGraphSaveRTInoise_stateChanged(self, p0):
                     self.__checkSpecGraphSaving()
                 @pyqtSignature("int")
                 def on_specGraphSaveCoherencemap_stateChanged(self, p0):
                     self.__checkSpecGraphSaving()
                 @pyqtSignature("int")
                 def on_specGraphSavePowerprofile_stateChanged(self, p0):
                     self.__checkSpecGraphSaving()
                 @pyqtSignature("int")
                 def on_specGraphftpSpectra_stateChanged(self, p0):
                     """
                     """
                     self.__checkSpecGraphFTP()
                 @pyqtSignature("int")
                 def on_specGraphftpCross_stateChanged(self, p0):
                     self.__checkSpecGraphFTP()
                 @pyqtSignature("int")
                 def on_specGraphftpRTIplot_stateChanged(self, p0):
                     self.__checkSpecGraphFTP()
                 @pyqtSignature("int")
                 def on_specGraphftpRTInoise_stateChanged(self, p0):
                     self.__checkSpecGraphFTP()
                 @pyqtSignature("int")
                 def on_specGraphftpCoherencemap_stateChanged(self, p0):
                     self.__checkSpecGraphFTP()
                 @pyqtSignature("int")
                 def on_specGraphftpPowerprofile_stateChanged(self, p0):
                     self.__checkSpecGraphFTP()
                 @pyqtSignature("")
                 def on_specGraphToolPath_clicked(self):
                     """
                     """
                     self.savePath = str(QtGui.QFileDialog.getExistingDirectory(self, 'Open Directory', './', QtGui.QFileDialog.ShowDirsOnly))
                     self.specGraphPath.setText(self.savePath)
                     if not os.path.exists(self.savePath):
                         self.console.clear()
                         self.console.append("Write a correct a path")
                         return
                 @pyqtSignature("")
                 def on_specGraphClear_clicked(self):
                     return
                 @pyqtSignature("")
                 def on_specHeisGraphToolPath_clicked(self):
                     """
                     """
                     self.savePath = str(QtGui.QFileDialog.getExistingDirectory(self, 'Open Directory', './', QtGui.QFileDialog.ShowDirsOnly))
                     self.specHeisGraphPath.setText(self.savePath)
                     if not os.path.exists(self.savePath):
                         self.console.clear()
                         self.console.append("Write a correct a path")
                         return
                 @pyqtSignature("int")
                 def on_specHeisOpCebIncoherent_stateChanged(self, p0):
                     """
                     Habilita la opcion de a�adir el par�metro integraciones incoherentes a la Unidad de Procesamiento .
                     """
                     if  p0 == 2:
                         self.specHeisOpIncoherent.setEnabled(True)
                         self.specHeisOpCobIncInt.setEnabled(True)
                     if  p0 == 0:
                         self.specHeisOpIncoherent.setEnabled(False)
                         self.specHeisOpCobIncInt.setEnabled(False)
                 @pyqtSignature("")
                 def on_specHeisOpOk_clicked(self):
                     """
                     AÑADE OPERACION SPECTRAHEIS
                     """
                     addFTP = False
                     checkPath = False
                     self.actionSaveToolbar.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     puObj = self.getSelectedItemObj()
                     puObj.removeOperations()
                     if self.specHeisOpCebIncoherent.isChecked():
                         value = self.specHeisOpIncoherent.text()
                         name_operation = 'IncohInt4SpectraHeis'
                         optype = 'other'
                         if self.specOpCobIncInt.currentIndex() == 0:
                             name_parameter = 'timeInterval'
                             format = 'float'
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
                         opObj.addParameter(name=name_parameter, value=value, format=format)
                     # ---- Spectra Plot-----
                     if self.specHeisGraphCebSpectraplot.isChecked():
                         name_operation = 'SpectraHeisScope'
                         optype = 'other'
                         name_parameter = 'type'
                         value = 'SpectraHeisScope'
                         format = 'str'
                         if self.idImagspectraHeis == 0:
                             self.idImagspectraHeis = 800
                         else:
                             self.idImagspectraHeis = self.idImagspectraHeis + 1
                         name_parameter1 = 'id'
                         value1 = int(self.idImagspectraHeis)
                         format1 = 'int'
                         format = 'str'
                         channelList = self.specHeisGgraphChannelList.text()
                         xvalue = self.specHeisGgraphXminXmax.text()
                         yvalue = self.specHeisGgraphYminYmax.text()
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
             #             opObj.addParameter(name=name_parameter, value=value, format=format)
                         opObj.addParameter(name=name_parameter1, value=value1, format=format1)
                         if not channelList == '':
                            name_parameter = 'channelList'
                            format = 'intlist'
                            opObj.addParameter(name=name_parameter, value=channelList, format=format)
                         if not xvalue == '':
                            xvalueList = xvalue.split(',')
                            try:
                                value1 = float(xvalueList[0])
                                value2 = float(xvalueList[1])
                            except:
                                    self.console.clear()
                                    self.console.append("Please Write  corrects parameter xmin-xmax")
                                    return 0
                            name1 = 'xmin'
                            name2 = 'xmax'
                            format = 'float'
                            opObj.addParameter(name=name1, value=value1, format=format)
                            opObj.addParameter(name=name2, value=value2, format=format)
                         #------specHeisGgraphYmin-Ymax---
                         if not yvalue == '':
                               yvalueList = yvalue.split(",")
                               try:
                                    value1 = float(yvalueList[0])
                                    value2 = float(yvalueList[1])
                               except:
                                   self.console.clear()
                                   self.console.append("Please Write  corrects parameter Ymix-Ymax")
                                   return 0
                               name1 = 'ymin'
                               name2 = 'ymax'
                               format = 'float'
                               opObj.addParameter(name=name1, value=value1, format=format)
                               opObj.addParameter(name=name2, value=value2, format=format)
                         if self.specHeisGraphSaveSpectra.isChecked():
                             checkPath = True
                             name_parameter1 = 'save'
                             name_parameter2 = 'figpath'
                             name_parameter3 = 'figfile'
                             value1 = '1'
                             value2 = self.specHeisGraphPath.text()
                             value3 = self.specHeisGraphPrefix.text()
                             format1 = 'bool'
                             format2 = 'str'
                             opObj.addParameter(name=name_parameter1, value=value1 , format=format1)
                             opObj.addParameter(name=name_parameter2, value=value2, format=format2)
                             if not value3 == "":
                                try:
                                    value3 = str(self.specHeisGraphPrefix.text())
                                except:
                                    self.console.clear()
                                    self.console.append("Please Write prefix")
                                    return 0
                                opObj.addParameter(name='figfile', value=self.specHeisGraphPrefix.text(), format='str')
                          #   opObj.addParameter(name=name_parameter3, value=value3, format=format2)
                          #   opObj.addParameter(name='wr_period', value='5',format='int')
                         if self.specHeisGraphftpSpectra.isChecked():
                            opObj.addParameter(name='ftp', value='1', format='int')
                            self.addFTPConf2Operation(puObj, opObj)
                            addFTP = True
                     if self.specHeisGraphCebRTIplot.isChecked():
                         name_operation = 'RTIfromSpectraHeis'
                         optype = 'other'
                         name_parameter = 'type'
                         value = 'RTIfromSpectraHeis'
                         format = 'str'
                         if self.idImagrtiHeis == 0:
                             self.idImagrtiHeis = 900
                         else:
                             self.idImagrtiHeis = self.idImagrtiHeis + 1
                         name_parameter1 = 'id'
                         value1 = int(self.idImagrtiHeis)
                         format1 = 'int'
                         format = 'str'
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
             #             opObj.addParameter(name=name_parameter, value=value, format=format)
                         opObj.addParameter(name=name_parameter1, value=value1, format=format1)
                         channelList = self.specHeisGgraphChannelList.text()
                         xvalue = self.specHeisGgraphTminTmax.text()
                         yvalue = self.specHeisGgraphYminYmax.text()
                         timerange = self.specHeisGgraphTimeRange.text()
                         if not channelList == '':
                             opObj.addParameter(name='channelList', value=channelList, format='intlist')
                         if not xvalue == '':
                             xvalueList = xvalue.split(',')
                             try:
                                 value = float(xvalueList[0])
                                 value = float(xvalueList[1])
                             except:
                                     return 0
                             format = 'float'
                             opObj.addParameter(name='xmin', value=xvalueList[0], format=format)
                             opObj.addParameter(name='xmax', value=xvalueList[1], format=format)
                         if not timerange == '':
                             format = 'int'
                             try:
                                 timerange = int(timerange)
                             except:
                                 return 0
                             opObj.addParameter(name='timerange', value=timerange, format=format)
                         if not yvalue == '':
                             yvalueList = yvalue.split(",")
                             try:
                                 value = float(yvalueList[0])
                                 value = float(yvalueList[1])
                             except:
                                     return 0
                             format = 'float'
                             opObj.addParameter(name='ymin', value=yvalueList[0], format=format)
                             opObj.addParameter(name='ymax', value=yvalueList[1], format=format)
                         if self.specHeisGraphSaveRTIplot.isChecked():
                             checkPath = True
                             opObj.addParameter(name='save', value='1', format='bool')
                             opObj.addParameter(name='figpath', value=self.specHeisGraphPath.text(), format='str')
                             value = self.specHeisGraphPrefix.text()
                             if not value == "":
                                try:
                                    value = str(self.specHeisGraphPrefix.text())
                                except:
                                     self.console.clear()
                                     self.console.append("Please Write prefix")
                                     return 0
                                opObj.addParameter(name='figfile', value=value, format='str')
                         # test_ftp
                         if self.specHeisGraphftpRTIplot.isChecked():
                            opObj.addParameter(name='ftp', value='1', format='int')
                            self.addFTPConf2Operation(puObj, opObj)
                            addFTP = True
                     localfolder = None
                     if checkPath:
                         localfolder = str(self.specGraphPath.text())
                         if localfolder == '':
                             self.console.clear()
                             self.console.append("Graphic path should be defined")
                             return 0
                     if addFTP and not localfolder:
                             self.console.clear()
                             self.console.append("You have to save the plots before sending them to FTP Server")
                             return 0
                     # if something happened
                     parms_ok, output_path, blocksperfile, metada = self.checkInputsPUSave(datatype='SpectraHeis')
                     if parms_ok:
                         name_operation = 'FitsWriter'
                         optype = 'other'
                         name_parameter1 = 'path'
                         name_parameter2 = 'dataBlocksPerFile'
                         name_parameter3 = 'metadatafile'
                         value1 = output_path
                         value2 = blocksperfile
                         value3 = metada
                         format2 = "int"
                         format3 = "str"
                         opObj = puObj.addOperation(name=name_operation, optype=optype)
                         opObj.addParameter(name=name_parameter1, value=value1)
                         opObj.addParameter(name=name_parameter2, value=value2, format=format2)
                         opObj.addParameter(name=name_parameter3, value=value3, format=format3)
                     self.console.clear()
                     try:
                         self.refreshPUProperties(puObj)
                     except:
                         self.console.append("Check input parameters")
                         return 0
                     self.console.append("Click on save icon ff you want to save your project")
                     self.actionSaveToolbar.setEnabled(True)
                     self.actionStarToolbar.setEnabled(True)
                     return 1
                 @pyqtSignature("int")
                 def on_specHeisGraphCebSpectraplot_stateChanged(self, p0):
                     if  p0 == 2:
                         self.specHeisGgraphChannelList.setEnabled(True)
                         self.specHeisGgraphXminXmax.setEnabled(True)
                         self.specHeisGgraphYminYmax.setEnabled(True)
                     if  p0 == 0:
                         self.specHeisGgraphXminXmax.setEnabled(False)
                         self.specHeisGgraphYminYmax.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specHeisGraphCebRTIplot_stateChanged(self, p0):
                     if  p0 == 2:
                         self.specHeisGgraphChannelList.setEnabled(True)
                         self.specHeisGgraphTminTmax.setEnabled(True)
                         self.specHeisGgraphYminYmax.setEnabled(True)
                         self.specHeisGgraphTimeRange.setEnabled(True)
                     if  p0 == 0:
                         self.specHeisGgraphTminTmax.setEnabled(False)
                         self.specHeisGgraphYminYmax.setEnabled(False)
                         self.specHeisGgraphTimeRange.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specHeisGraphSaveSpectra_stateChanged(self, p0):
                     """
                     """
                     if  p0 == 2:
                         self.specHeisGraphPath.setEnabled(True)
                         self.specHeisGraphPrefix.setEnabled(True)
                         self.specHeisGraphToolPath.setEnabled(True)
                     if  p0 == 0:
                         self.specHeisGraphPath.setEnabled(False)
                         self.specHeisGraphPrefix.setEnabled(False)
                         self.specHeisGraphToolPath.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specHeisGraphSaveRTIplot_stateChanged(self, p0):
                     if  p0 == 2:
                         self.specHeisGraphPath.setEnabled(True)
                         self.specHeisGraphPrefix.setEnabled(True)
                         self.specHeisGraphToolPath.setEnabled(True)
                 @pyqtSignature("int")
                 def on_specHeisGraphftpSpectra_stateChanged(self, p0):
                     """
                     """
                     if  p0 == 2:
                         self.specHeisGgraphftpratio.setEnabled(True)
                     if  p0 == 0:
                         self.specHeisGgraphftpratio.setEnabled(False)
                 @pyqtSignature("int")
                 def on_specHeisGraphftpRTIplot_stateChanged(self, p0):
                     if  p0 == 2:
                         self.specHeisGgraphftpratio.setEnabled(True)
                 @pyqtSignature("")
                 def on_specHeisGraphClear_clicked(self):
                     pass
                 def __checkSpecGraphSaving(self):
                     enable = False
                     if self.specGraphSaveSpectra.checkState():
                         enable = True
                     if self.specGraphSaveCross.checkState():
                         enable = True
                     if self.specGraphSaveRTIplot.checkState():
                         enable = True
                     if self.specGraphSaveCoherencemap.checkState():
                         enable = True
                     if self.specGraphSavePowerprofile.checkState():
                         enable = True
                     if self.specGraphSaveRTInoise.checkState():
                         enable = True
                     self.specGraphPath.setEnabled(enable)
                     self.specGraphPrefix.setEnabled(enable)
                     self.specGraphToolPath.setEnabled(enable)
                     self.specGgraphftpratio.setEnabled(enable)
                 def __checkSpecGraphFTP(self):
                     enable = False
                     if self.specGraphftpSpectra.checkState():
                         enable = True
                     if self.specGraphftpCross.checkState():
                         enable = True
                     if self.specGraphftpRTIplot.checkState():
                         enable = True
                     if self.specGraphftpCoherencemap.checkState():
                         enable = True
                     if self.specGraphftpPowerprofile.checkState():
                         enable = True
                     if self.specGraphftpRTInoise.checkState():
                         enable = True
             #         self.specGgraphftpratio.setEnabled(enable)
                 def __checkSpecGraphFilters(self):
                     freq = False
                     height = False
                     db = False
                     time = False
                     magnitud = False
                     phase = False
                     channelList = False
                     if self.specGraphCebSpectraplot.checkState():
                         freq = True
                         height = True
                         db = True
                         channelList = True
                     if self.specGraphCebCrossSpectraplot.checkState():
                         freq = True
                         height = True
                         db = True
                         magnitud = True
                         phase = True
                     if self.specGraphCebRTIplot.checkState():
                         height = True
                         db = True
                         time = True
                         channelList = True
                     if self.specGraphCebCoherencmap.checkState():
                         height = True
                         time = True
                         magnitud = True
                         phase = True
                     if self.specGraphPowerprofile.checkState():
                         height = True
                         db = True
                         channelList = True
                     if self.specGraphCebRTInoise.checkState():
                         db = True
                         time = True
                         channelList = True
                     self.specGgraphFreq.setEnabled(freq)
                     self.specGgraphHeight.setEnabled(height)
                     self.specGgraphDbsrange.setEnabled(db)
                     self.specGgraphTminTmax.setEnabled(time)
                     self.specGgraphmagnitud.setEnabled(magnitud)
                     self.specGgraphPhase.setEnabled(phase)
                     self.specGgraphChannelList.setEnabled(channelList)
                 def __getParmsFromProjectWindow(self):
                     """
                     Check Inputs Project:
                     - project_name
                     - datatype
                     - ext
                     - data_path
                     - readmode
                     - delay
                     - set
                     - walk
                     """
                     parms_ok = True
                     project_name = str(self.proName.text())
                     if project_name == '' or project_name == None:
                         outputstr = "Enter a project Name"
                         self.console.append(outputstr)
                         parms_ok = False
                         project_name = None
                     description = str(self.proDescription.toPlainText())
                     datatype = str(self.proComDataType.currentText())
                     ext = str(self.proDataType.text())
                     dpath = str(self.proDataPath.text())
                     if dpath == '':
                         outputstr = 'Datapath is empty'
                         self.console.append(outputstr)
                         parms_ok = False
                         dpath = None
                     if dpath != None:
                         if not os.path.isdir(dpath):
                             outputstr = 'Datapath (%s) does not exist' % dpath
                             self.console.append(outputstr)
                             parms_ok = False
                             dpath = None
                     online = int(self.proComReadMode.currentIndex())
                     delay = None
                     if online==1:
                         try:
                             delay = int(str(self.proDelay.text()))
                         except:
                             outputstr = 'Delay value (%s) must be a integer number' %str(self.proDelay.text())
                             self.console.append(outputstr)
                             parms_ok = False
                     set = None
                     value = str(self.proSet.text())
                     try:
                         set = int(value)
                     except:
                         pass
                     ippKm = None
                     value = str(self.proIPPKm.text())
                     try:
                         ippKm = float(value)
                     except:
                         if datatype=="USRP":
                             outputstr = 'IPP value (%s) must be a float number' % str(self.proIPPKm.text())
                             self.console.append(outputstr)
                             parms_ok = False
                     walk = int(self.proComWalk.currentIndex())
                     startDate = str(self.proComStartDate.currentText())
                     endDate = str(self.proComEndDate.currentText())
             #         startDateList = startDate.split("/")
             #         endDateList = endDate.split("/")
             #
             #         startDate = datetime.date(int(startDateList[0]), int(startDateList[1]), int(startDateList[2]))
             #         endDate = datetime.date(int(endDateList[0]), int(endDateList[1]), int(endDateList[2]))
                     startTime = self.proStartTime.time()
                     endTime = self.proEndTime.time()
                     startTime = str(startTime.toString("H:m:s"))
                     endTime = str(endTime.toString("H:m:s"))
                     projectParms = ProjectParms()
                     projectParms.name = project_name
                     projectParms.description = description
                     projectParms.datatype = datatype
                     projectParms.ext = ext
                     projectParms.dpath = dpath
                     projectParms.online = online
                     projectParms.startDate = startDate
                     projectParms.endDate = endDate
                     projectParms.startTime = startTime
                     projectParms.endTime = endTime
                     projectParms.delay=delay
                     projectParms.walk=walk
                     projectParms.set=set
                     projectParms.ippKm=ippKm
                     projectParms.parmsOk=parms_ok
                     return projectParms
                 def __getParmsFromProjectObj(self, projectObjView):
                     parms_ok = True
                     project_name, description = projectObjView.name, projectObjView.description
                     readUnitObj = projectObjView.getReadUnitObj()
                     datatype = readUnitObj.datatype
                     operationObj = readUnitObj.getOperationObj(name='run')
                     dpath = operationObj.getParameterValue(parameterName='path')
                     startDate = operationObj.getParameterValue(parameterName='startDate')
                     endDate = operationObj.getParameterValue(parameterName='endDate')
                     startDate = startDate.strftime("%Y/%m/%d")
                     endDate = endDate.strftime("%Y/%m/%d")
                     startTime = operationObj.getParameterValue(parameterName='startTime')
                     endTime = operationObj.getParameterValue(parameterName='endTime')
                     startTime = startTime.strftime("%H:%M:%S")
                     endTime = endTime.strftime("%H:%M:%S")
                     online = 0
                     try:
                         online = operationObj.getParameterValue(parameterName='online')
                     except:
                         pass
                     delay = ''
                     try:
                         delay = operationObj.getParameterValue(parameterName='delay')
                     except:
                         pass
                     walk = 0
                     try:
                         walk = operationObj.getParameterValue(parameterName='walk')
                     except:
                         pass
                     set = ''
                     try:
                         set = operationObj.getParameterValue(parameterName='set')
                     except:
                         pass
                     ippKm = ''
                     if datatype.lower() == 'usrp':
                         try:
                             ippKm = operationObj.getParameterValue(parameterName='ippKm')
                         except:
                             pass
                     projectParms = ProjectParms()
                     projectParms.name = project_name
                     projectParms.description = description
                     projectParms.datatype = datatype
                     projectParms.ext = None
                     projectParms.dpath = dpath
                     projectParms.online = online
                     projectParms.startDate = startDate
                     projectParms.endDate = endDate
                     projectParms.startTime = startTime
                     projectParms.endTime = endTime
                     projectParms.delay=delay
                     projectParms.walk=walk
                     projectParms.set=set
                     projectParms.ippKm=ippKm
                     projectParms.parmsOk=parms_ok
                     return projectParms
                 def refreshProjectWindow2(self, projectObjView):
                     projectParms = self.__getParmsFromProjectObj(projectObjView)
                     index = projectParms.getDatatypeIndex()
                     self.proName.setText(projectParms.name)
                     self.proDescription.clear()
                     self.proDescription.append(projectParms.description)
                     self.on_proComDataType_activated(index=index)
                     self.proDataPath.setText(projectParms.dpath)
                     self.proComDataType.setCurrentIndex(index)
                     self.proComReadMode.setCurrentIndex(projectParms.online)
                     self.proDelay.setText(str(projectParms.delay))
                     self.proSet.setText(str(projectParms.set))
                     self.proIPPKm.setText(str(projectParms.ippKm))
                     dateList = self.loadDays(data_path = projectParms.dpath,
                                              ext = projectParms.getExt(),
                                              walk = projectParms.walk,
                                              expLabel = projectParms.expLabel)
                     try:
                         startDateIndex = dateList.index(projectParms.startDate)
                     except:
                         startDateIndex = 0
                     try:
                         endDateIndex = dateList.index(projectParms.endDate)
                     except:
                         endDateIndex = int(self.proComEndDate.count()-1)
                     self.proComStartDate.setCurrentIndex(startDateIndex)
                     self.proComEndDate.setCurrentIndex(endDateIndex)
                     startlist = projectParms.startTime.split(":")
                     endlist = projectParms.endTime.split(":")
                     self.time.setHMS(int(startlist[0]), int(startlist[1]), int(startlist[2]))
                     self.proStartTime.setTime(self.time)
                     self.time.setHMS(int(endlist[0]), int(endlist[1]), int(endlist[2]))
                     self.proEndTime.setTime(self.time)
                 def __refreshVoltageWindow(self, puObj):
                     opObj = puObj.getOperationObj(name='setRadarFrequency')
                     if opObj == None:
                         self.volOpRadarfrequency.clear()
                         self.volOpCebRadarfrequency.setCheckState(0)
                     else:
                         value = opObj.getParameterValue(parameterName='frequency')
                         value = str(float(value)/1e6)
                         self.volOpRadarfrequency.setText(value)
                         self.volOpRadarfrequency.setEnabled(True)
                         self.volOpCebRadarfrequency.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name="selectChannels")
                     if opObj == None:
                         opObj = puObj.getOperationObj(name="selectChannelsByIndex")
                     if opObj == None:
                         self.volOpChannel.clear()
                         self.volOpCebChannels.setCheckState(0)
                     else:
                         channelEnabled = False
                         try:
                             value = opObj.getParameterValue(parameterName='channelList')
                             value = str(value)[1:-1]
                             channelEnabled = True
                             channelMode = 0
                         except:
                             pass
                         try:
                             value = opObj.getParameterValue(parameterName='channelIndexList')
                             value = str(value)[1:-1]
                             channelEnabled = True
                             channelMode = 1
                         except:
                             pass
                         if channelEnabled:
                             self.volOpChannel.setText(value)
                             self.volOpChannel.setEnabled(True)
                             self.volOpCebChannels.setCheckState(QtCore.Qt.Checked)
                             self.volOpComChannels.setCurrentIndex(channelMode)
                     opObj = puObj.getOperationObj(name="selectHeights")
                     if opObj == None:
                         self.volOpHeights.clear()
                         self.volOpCebHeights.setCheckState(0)
                     else:
                        value1 = int(opObj.getParameterValue(parameterName='minHei'))
                        value1 = str(value1)
                        value2 = int(opObj.getParameterValue(parameterName='maxHei'))
                        value2 = str(value2)
                        value = value1 + "," + value2
                        self.volOpHeights.setText(value)
                        self.volOpHeights.setEnabled(True)
                        self.volOpCebHeights.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name="filterByHeights")
                     if opObj == None:
                         self.volOpFilter.clear()
                         self.volOpCebFilter.setCheckState(0)
                     else:
                         value = opObj.getParameterValue(parameterName='window')
                         value = str(value)
                         self.volOpFilter.setText(value)
                         self.volOpFilter.setEnabled(True)
                         self.volOpCebFilter.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name="ProfileSelector")
                     if opObj == None:
                         self.volOpProfile.clear()
                         self.volOpCebProfile.setCheckState(0)
                     else:
                        for parmObj in opObj.getParameterObjList():
                             if parmObj.name == "profileList":
                                 value = parmObj.getValue()
                                 value = str(value)[1:-1]
                                 self.volOpProfile.setText(value)
                                 self.volOpProfile.setEnabled(True)
                                 self.volOpCebProfile.setCheckState(QtCore.Qt.Checked)
                                 self.volOpComProfile.setCurrentIndex(0)
                             if parmObj.name == "profileRangeList":
                                 value = parmObj.getValue()
                                 value = str(value)[1:-1]
                                 self.volOpProfile.setText(value)
                                 self.volOpProfile.setEnabled(True)
                                 self.volOpCebProfile.setCheckState(QtCore.Qt.Checked)
                                 self.volOpComProfile.setCurrentIndex(1)
                             if parmObj.name == "rangeList":
                                 value = parmObj.getValue()
                                 value = str(value)[1:-1]
                                 self.volOpProfile.setText(value)
                                 self.volOpProfile.setEnabled(True)
                                 self.volOpCebProfile.setCheckState(QtCore.Qt.Checked)
                                 self.volOpComProfile.setCurrentIndex(2)
                     opObj = puObj.getOperationObj(name="Decoder")
                     self.volOpCode.setText("")
                     if opObj == None:
                         self.volOpCebDecodification.setCheckState(0)
                     else:
                         self.volOpCebDecodification.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj('code')
                         if parmObj == None:
                             self.volOpComCode.setCurrentIndex(0)
                         else:
                             parmObj1 = opObj.getParameterObj('nCode')
                             parmObj2 = opObj.getParameterObj('nBaud')
                             if parmObj1 == None or parmObj2 == None:
                                 self.volOpComCode.setCurrentIndex(0)
                             else:
                                 code = ast.literal_eval(str(parmObj.getValue()))
                                 nCode = parmObj1.getValue()
                                 nBaud = parmObj2.getValue()
                                 code = numpy.asarray(code).reshape((nCode, nBaud)).tolist()
                                 #User defined by default
                                 self.volOpComCode.setCurrentIndex(13)
                                 self.volOpCode.setText(str(code))
                                 if nCode == 1:
                                     if nBaud == 3:
                                        self.volOpComCode.setCurrentIndex(1)
                                     if nBaud == 4:
                                         self.volOpComCode.setCurrentIndex(2)
                                     if nBaud == 5:
                                         self.volOpComCode.setCurrentIndex(3)
                                     if nBaud == 7:
                                         self.volOpComCode.setCurrentIndex(4)
                                     if nBaud == 11:
                                         self.volOpComCode.setCurrentIndex(5)
                                     if nBaud == 13:
                                         self.volOpComCode.setCurrentIndex(6)
                                 if nCode == 2:
                                     if nBaud == 3:
                                        self.volOpComCode.setCurrentIndex(7)
                                     if nBaud == 4:
                                         self.volOpComCode.setCurrentIndex(8)
                                     if nBaud == 5:
                                         self.volOpComCode.setCurrentIndex(9)
                                     if nBaud == 7:
                                         self.volOpComCode.setCurrentIndex(10)
                                     if nBaud == 11:
                                         self.volOpComCode.setCurrentIndex(11)
                                     if nBaud == 13:
                                         self.volOpComCode.setCurrentIndex(12)
                     opObj = puObj.getOperationObj(name="deFlip")
                     if opObj == None:
                         self.volOpFlip.clear()
                         self.volOpFlip.setEnabled(False)
                         self.volOpCebFlip.setCheckState(0)
                     else:
                         try:
                             value = opObj.getParameterValue(parameterName='channelList')
                             value = str(value)[1:-1]
                         except:
                             value = ""
                         self.volOpFlip.setText(value)
                         self.volOpFlip.setEnabled(True)
                         self.volOpCebFlip.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name="CohInt")
                     if opObj == None:
                         self.volOpCohInt.clear()
                         self.volOpCebCohInt.setCheckState(0)
                     else:
                         value = opObj.getParameterValue(parameterName='n')
                         self.volOpCohInt.setText(str(value))
                         self.volOpCohInt.setEnabled(True)
                         self.volOpCebCohInt.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name='Scope')
                     if opObj == None:
                         self.volGraphCebshow.setCheckState(0)
                     else:
                         self.volGraphCebshow.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='channelList')
                         if parmObj == None:
                             self.volGraphChannelList.clear()
                         else:
                             value = parmObj.getValue()
                             value = str(value)
                             self.volGraphChannelList.setText(value)
                             self.volOpProfile.setEnabled(True)
                         parmObj1 = opObj.getParameterObj(parameterName='xmin')
                         parmObj2 = opObj.getParameterObj(parameterName='xmax')
                         if parmObj1 == None or parmObj2 ==None:
                             self.volGraphfreqrange.clear()
                         else:
                             value1 = parmObj1.getValue()
                             value1 = str(value1)
                             value2 = parmObj2.getValue()
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.volGraphfreqrange.setText(value)
                         parmObj1 = opObj.getParameterObj(parameterName='ymin')
                         parmObj2 = opObj.getParameterObj(parameterName='ymax')
                         if parmObj1 == None or parmObj2 ==None:
                             self.volGraphHeightrange.clear()
                         else:
                             value1 = parmObj1.getValue()
                             value1 = str(value1)
                             value2 = parmObj2.getValue()
                             value2 = str(value2)
                             value = value1 + "," + value2
                             value2 = str(value2)
                             self.volGraphHeightrange.setText(value)
                         parmObj = opObj.getParameterObj(parameterName='save')
                         if parmObj == None:
                             self.volGraphCebSave.setCheckState(QtCore.Qt.Unchecked)
                         else:
                             value = parmObj.getValue()
                             if int(value):
                                 self.volGraphCebSave.setCheckState(QtCore.Qt.Checked)
                             else:
                                 self.volGraphCebSave.setCheckState(QtCore.Qt.Unchecked)
                         parmObj = opObj.getParameterObj(parameterName='figpath')
                         if parmObj == None:
                             self.volGraphPath.clear()
                         else:
                             value = parmObj.getValue()
                             path = str(value)
                             self.volGraphPath.setText(path)
                         parmObj = opObj.getParameterObj(parameterName='figfile')
                         if parmObj == None:
                             self.volGraphPrefix.clear()
                         else:
                             value = parmObj.getValue()
                             figfile = str(value)
                             self.volGraphPrefix.setText(figfile)
                     # outputVoltageWrite
                     opObj = puObj.getOperationObj(name='VoltageWriter')
                     if opObj == None:
                         self.volOutputPath.clear()
                         self.volOutputblocksperfile.clear()
                         self.volOutputprofilesperblock.clear()
                     else:
                         parmObj = opObj.getParameterObj(parameterName='path')
                         if parmObj == None:
                             self.volOutputPath.clear()
                         else:
                             value = parmObj.getValue()
                             path = str(value)
                             self.volOutputPath.setText(path)
                         parmObj = opObj.getParameterObj(parameterName='blocksPerFile')
                         if parmObj == None:
                            self.volOutputblocksperfile.clear()
                         else:
                             value = parmObj.getValue()
                             blocksperfile = str(value)
                             self.volOutputblocksperfile.setText(blocksperfile)
                         parmObj = opObj.getParameterObj(parameterName='profilesPerBlock')
                         if parmObj == None:
                             self.volOutputprofilesperblock.clear()
                         else:
                             value = parmObj.getValue()
                             profilesPerBlock = str(value)
                             self.volOutputprofilesperblock.setText(profilesPerBlock)
                     return
                 def __refreshSpectraWindow(self, puObj):
                     inputId = puObj.getInputId()
                     inputPUObj = self.__puObjDict[inputId]
                     if inputPUObj.datatype == 'Voltage':
                         self.specOpnFFTpoints.setEnabled(True)
                         self.specOpProfiles.setEnabled(True)
                         self.specOpippFactor.setEnabled(True)
                     else:
                         self.specOpnFFTpoints.setEnabled(False)
                         self.specOpProfiles.setEnabled(False)
                         self.specOpippFactor.setEnabled(False)
                     opObj = puObj.getOperationObj(name='setRadarFrequency')
                     if opObj == None:
                         self.specOpRadarfrequency.clear()
                         self.specOpCebRadarfrequency.setCheckState(0)
                     else:
                         value = opObj.getParameterValue(parameterName='frequency')
                         value = str(float(value)/1e6)
                         self.specOpRadarfrequency.setText(value)
                         self.specOpRadarfrequency.setEnabled(True)
                         self.specOpCebRadarfrequency.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name="run")
                     if opObj == None:
                         self.specOpnFFTpoints.clear()
                         self.specOpProfiles.clear()
                         self.specOpippFactor.clear()
                     else:
                         parmObj = opObj.getParameterObj(parameterName='nFFTPoints')
                         if parmObj == None:
                             self.specOpnFFTpoints.clear()
                         else:
                             self.specOpnFFTpoints.setEnabled(True)
                             value = opObj.getParameterValue(parameterName='nFFTPoints')
                             self.specOpnFFTpoints.setText(str(value))
                         parmObj = opObj.getParameterObj(parameterName='nProfiles')
                         if parmObj == None:
                             self.specOpProfiles.clear()
                         else:
                             self.specOpProfiles.setEnabled(True)
                             value = opObj.getParameterValue(parameterName='nProfiles')
                             self.specOpProfiles.setText(str(value))
                         parmObj = opObj.getParameterObj(parameterName='ippFactor')
                         if parmObj == None:
                             self.specOpippFactor.clear()
                         else:
                             self.specOpippFactor.setEnabled(True)
                             value = opObj.getParameterValue(parameterName='ippFactor')
                             self.specOpippFactor.setText(str(value))
                     opObj = puObj.getOperationObj(name="run")
                     if opObj == None:
                         self.specOppairsList.clear()
                         self.specOpCebCrossSpectra.setCheckState(0)
                     else:
                         parmObj = opObj.getParameterObj(parameterName='pairsList')
                         if parmObj == None:
                             self.specOppairsList.clear()
                             self.specOpCebCrossSpectra.setCheckState(0)
                         else:
                             value = opObj.getParameterValue(parameterName='pairsList')
                             value = str(value)[1:-1]
                             self.specOppairsList.setText(str(value))
                             self.specOppairsList.setEnabled(True)
                             self.specOpCebCrossSpectra.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name="selectChannels")
                     if opObj == None:
                         opObj = puObj.getOperationObj(name="selectChannelsByIndex")
                     if opObj == None:
                         self.specOpChannel.clear()
                         self.specOpCebChannel.setCheckState(0)
                     else:
                         channelEnabled = False
                         try:
                             value = opObj.getParameterValue(parameterName='channelList')
                             value = str(value)[1:-1]
                             channelEnabled = True
                             channelMode = 0
                         except:
                             pass
                         try:
                             value = opObj.getParameterValue(parameterName='channelIndexList')
                             value = str(value)[1:-1]
                             channelEnabled = True
                             channelMode = 1
                         except:
                             pass
                         if channelEnabled:
                             self.specOpChannel.setText(value)
                             self.specOpChannel.setEnabled(True)
                             self.specOpCebChannel.setCheckState(QtCore.Qt.Checked)
                             self.specOpComChannel.setCurrentIndex(channelMode)
                     opObj = puObj.getOperationObj(name="selectHeights")
                     if opObj == None:
                         self.specOpHeights.clear()
                         self.specOpCebHeights.setCheckState(0)
                     else:
                        value1 = int(opObj.getParameterValue(parameterName='minHei'))
                        value1 = str(value1)
                        value2 = int(opObj.getParameterValue(parameterName='maxHei'))
                        value2 = str(value2)
                        value = value1 + "," + value2
                        self.specOpHeights.setText(value)
                        self.specOpHeights.setEnabled(True)
                        self.specOpCebHeights.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name="IncohInt")
                     if opObj == None:
                         self.specOpIncoherent.clear()
                         self.specOpCebIncoherent.setCheckState(0)
                     else:
                         for parmObj in opObj.getParameterObjList():
                            if parmObj.name == 'timeInterval':
                                value = opObj.getParameterValue(parameterName='timeInterval')
                                value = float(value)
                                self.specOpIncoherent.setText(str(value))
                                self.specOpIncoherent.setEnabled(True)
                                self.specOpCebIncoherent.setCheckState(QtCore.Qt.Checked)
                                self.specOpCobIncInt.setCurrentIndex(0)
                            if parmObj.name == 'n':
                                value = opObj.getParameterValue(parameterName='n')
                                value = float(value)
                                self.specOpIncoherent.setText(str(value))
                                self.specOpIncoherent.setEnabled(True)
                                self.specOpCebIncoherent.setCheckState(QtCore.Qt.Checked)
                                self.specOpCobIncInt.setCurrentIndex(1)
                     opObj = puObj.getOperationObj(name="removeDC")
                     if opObj == None:
                         self.specOpCebRemoveDC.setCheckState(0)
                     else:
                         self.specOpCebRemoveDC.setCheckState(QtCore.Qt.Checked)
                         value = opObj.getParameterValue(parameterName='mode')
                         if value == 1:
                             self.specOpComRemoveDC.setCurrentIndex(0)
                         elif value == 2:
                             self.specOpComRemoveDC.setCurrentIndex(1)
                     opObj = puObj.getOperationObj(name="removeInterference")
                     if opObj == None:
                         self.specOpCebRemoveInt.setCheckState(0)
                     else:
                         self.specOpCebRemoveInt.setCheckState(QtCore.Qt.Checked)
                     opObj = puObj.getOperationObj(name='getNoise')
                     if opObj == None:
                         self.specOpCebgetNoise.setCheckState(0)
                         self.specOpgetNoise.clear()
                     else:
                         self.specOpCebgetNoise.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='minHei')
                         if parmObj == None:
                             self.specOpgetNoise.clear()
                             value1 = None
                         else:
                             value1 = opObj.getParameterValue(parameterName='minHei')
                             value1 = str(value1)
                             parmObj = opObj.getParameterObj(parameterName='maxHei')
                             if parmObj == None:
                                 value2 = None
                                 value = value1
                                 self.specOpgetNoise.setText(value)
                                 self.specOpgetNoise.setEnabled(True)
                             else:
                                 value2 = opObj.getParameterValue(parameterName='maxHei')
                                 value2 = str(value2)
                                 parmObj = opObj.getParameterObj(parameterName='minVel')
                                 if parmObj == None:
                                     value3 = None
                                     value = value1 + "," + value2
                                     self.specOpgetNoise.setText(value)
                                     self.specOpgetNoise.setEnabled(True)
                                 else:
                                     value3 = opObj.getParameterValue(parameterName='minVel')
                                     value3 = str(value3)
                                     parmObj = opObj.getParameterObj(parameterName='maxVel')
                                     if parmObj == None:
                                         value4 = None
                                         value = value1 + "," + value2 + "," + value3
                                         self.specOpgetNoise.setText(value)
                                         self.specOpgetNoise.setEnabled(True)
                                     else:
                                         value4 = opObj.getParameterValue(parameterName='maxVel')
                                         value4 = str(value4)
                                         value = value1 + "," + value2 + "," + value3 + ',' + value4
                                         self.specOpgetNoise.setText(value)
                                         self.specOpgetNoise.setEnabled(True)
                     self.specGraphPath.clear()
                     self.specGraphPrefix.clear()
                     self.specGgraphFreq.clear()
                     self.specGgraphHeight.clear()
                     self.specGgraphDbsrange.clear()
                     self.specGgraphmagnitud.clear()
                     self.specGgraphPhase.clear()
                     self.specGgraphChannelList.clear()
                     self.specGgraphTminTmax.clear()
                     self.specGgraphTimeRange.clear()
                     self.specGgraphftpratio.clear()
                     opObj = puObj.getOperationObj(name='SpectraPlot')
                     if opObj == None:
                         self.specGraphCebSpectraplot.setCheckState(0)
                         self.specGraphSaveSpectra.setCheckState(0)
                         self.specGraphftpSpectra.setCheckState(0)
                     else:
                         operationSpectraPlot = "Enable"
                         self.specGraphCebSpectraplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='channelList')
                         if parmObj == None:
                             self.specGgraphChannelList.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='channelList')
                             channelListSpectraPlot = str(value)[1:-1]
                             self.specGgraphChannelList.setText(channelListSpectraPlot)
                             self.specGgraphChannelList.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specGgraphFreq.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphFreq.setText(value)
                             self.specGgraphFreq.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specGgraphHeight.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphHeight.setText(value)
                             self.specGgraphHeight.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='zmin')
                         if parmObj == None:
                             self.specGgraphDbsrange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='zmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='zmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphDbsrange.setText(value)
                             self.specGgraphDbsrange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specGraphSaveSpectra.setCheckState(0)
                         else:
                             self.specGraphSaveSpectra.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specGraphftpSpectra.setCheckState(0)
                         else:
                             self.specGraphftpSpectra.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     opObj = puObj.getOperationObj(name='CrossSpectraPlot')
                     if opObj == None:
                         self.specGraphCebCrossSpectraplot.setCheckState(0)
                         self.specGraphSaveCross.setCheckState(0)
                         self.specGraphftpCross.setCheckState(0)
                     else:
                         operationCrossSpectraPlot = "Enable"
                         self.specGraphCebCrossSpectraplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specGgraphFreq.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphFreq.setText(value)
                             self.specGgraphFreq.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specGgraphHeight.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphHeight.setText(value)
                             self.specGgraphHeight.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='zmin')
                         if parmObj == None:
                             self.specGgraphDbsrange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='zmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='zmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphDbsrange.setText(value)
                             self.specGgraphDbsrange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='coh_min')
                         if parmObj == None:
                             self.specGgraphmagnitud.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='coh_min')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='coh_max')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphmagnitud.setText(value)
                             self.specGgraphmagnitud.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='phase_min')
                         if parmObj == None:
                             self.specGgraphPhase.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='phase_min')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='phase_max')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphPhase.setText(value)
                             self.specGgraphPhase.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specGraphSaveCross.setCheckState(0)
                         else:
                             self.specGraphSaveCross.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specGraphftpCross.setCheckState(0)
                         else:
                             self.specGraphftpCross.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     opObj = puObj.getOperationObj(name='RTIPlot')
                     if opObj == None:
                         self.specGraphCebRTIplot.setCheckState(0)
                         self.specGraphSaveRTIplot.setCheckState(0)
                         self.specGraphftpRTIplot.setCheckState(0)
                     else:
                         self.specGraphCebRTIplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='channelList')
                         if parmObj == None:
                             self.specGgraphChannelList.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='channelList')
                             channelListRTIPlot = str(value)[1:-1]
                             self.specGgraphChannelList.setText(channelListRTIPlot)
                             self.specGgraphChannelList.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specGgraphTminTmax.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphTminTmax.setText(value)
                             self.specGgraphTminTmax.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='timerange')
                         if parmObj == None:
                             self.specGgraphTimeRange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='timerange')
                             value1 = str(value1)
                             self.specGgraphTimeRange.setText(value1)
                             self.specGgraphTimeRange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specGgraphHeight.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphHeight.setText(value)
                             self.specGgraphHeight.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='zmin')
                         if parmObj == None:
                             self.specGgraphDbsrange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='zmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='zmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphDbsrange.setText(value)
                             self.specGgraphDbsrange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specGraphSaveRTIplot.setCheckState(0)
                         else:
                             self.specGraphSaveRTIplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specGraphftpRTIplot.setCheckState(0)
                         else:
                             self.specGraphftpRTIplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     opObj = puObj.getOperationObj(name='CoherenceMap')
                     if opObj == None:
                         self.specGraphCebCoherencmap.setCheckState(0)
                         self.specGraphSaveCoherencemap.setCheckState(0)
                         self.specGraphftpCoherencemap.setCheckState(0)
                     else:
                         operationCoherenceMap = "Enable"
                         self.specGraphCebCoherencmap.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specGgraphTminTmax.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphTminTmax.setText(value)
                             self.specGgraphTminTmax.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='timerange')
                         if parmObj == None:
                             self.specGgraphTimeRange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='timerange')
                             value1 = str(value1)
                             self.specGgraphTimeRange.setText(value1)
                             self.specGgraphTimeRange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specGgraphHeight.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphHeight.setText(value)
                             self.specGgraphHeight.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='zmin')
                         if parmObj == None:
                             self.specGgraphmagnitud.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='zmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='zmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphmagnitud.setText(value)
                             self.specGgraphmagnitud.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='coh_min')
                         if parmObj == None:
                             self.specGgraphmagnitud.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='coh_min')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='coh_max')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphmagnitud.setText(value)
                             self.specGgraphmagnitud.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='phase_min')
                         if parmObj == None:
                             self.specGgraphPhase.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='phase_min')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='phase_max')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphPhase.setText(value)
                             self.specGgraphPhase.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specGraphSaveCoherencemap.setCheckState(0)
                         else:
                             self.specGraphSaveCoherencemap.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specGraphftpCoherencemap.setCheckState(0)
                         else:
                             self.specGraphftpCoherencemap.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     opObj = puObj.getOperationObj(name='PowerProfilePlot')
                     if opObj == None:
                         self.specGraphPowerprofile.setCheckState(0)
                         self.specGraphSavePowerprofile.setCheckState(0)
                         self.specGraphftpPowerprofile.setCheckState(0)
                         operationPowerProfilePlot = "Disabled"
                         channelList = None
                         freq_vel = None
                         heightsrange = None
                     else:
                         operationPowerProfilePlot = "Enable"
                         self.specGraphPowerprofile.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specGgraphDbsrange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphDbsrange.setText(value)
                             self.specGgraphDbsrange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specGgraphHeight.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphHeight.setText(value)
                             self.specGgraphHeight.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specGraphSavePowerprofile.setCheckState(0)
                         else:
                             self.specGraphSavePowerprofile.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specGraphftpPowerprofile.setCheckState(0)
                         else:
                             self.specGraphftpPowerprofile.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     opObj = puObj.getOperationObj(name='Noise')
                     if opObj == None:
                         self.specGraphCebRTInoise.setCheckState(0)
                         self.specGraphSaveRTInoise.setCheckState(0)
                         self.specGraphftpRTInoise.setCheckState(0)
                     else:
                         self.specGraphCebRTInoise.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='channelList')
                         if parmObj == None:
                                self.specGgraphChannelList.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='channelList')
                             channelListRTINoise = str(value)[1:-1]
                             self.specGgraphChannelList.setText(channelListRTINoise)
                             self.specGgraphChannelList.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specGgraphTminTmax.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphTminTmax.setText(value)
                             self.specGgraphTminTmax.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='timerange')
                         if parmObj == None:
                             self.specGgraphTimeRange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='timerange')
                             value1 = str(value1)
                             self.specGgraphTimeRange.setText(value1)
                             self.specGgraphTimeRange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specGgraphDbsrange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specGgraphDbsrange.setText(value)
                             self.specGgraphDbsrange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specGraphSaveRTInoise.setCheckState(0)
                         else:
                             self.specGraphSaveRTInoise.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specGraphftpRTInoise.setCheckState(0)
                         else:
                             self.specGraphftpRTInoise.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     opObj = puObj.getOperationObj(name='SpectraWriter')
                     if opObj == None:
                         self.specOutputPath.clear()
                         self.specOutputblocksperfile.clear()
                         self.specOutputprofileperblock.clear()
                     else:
                         value = opObj.getParameterObj(parameterName='path')
                         if value == None:
                             self.specOutputPath.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='path')
                             path = str(value)
                             self.specOutputPath.setText(path)
                         value = opObj.getParameterObj(parameterName='blocksPerFile')
                         if value == None:
                            self.specOutputblocksperfile.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='blocksPerFile')
                             blocksperfile = str(value)
                             self.specOutputblocksperfile.setText(blocksperfile)
                         value = opObj.getParameterObj(parameterName='profilesPerBlock')
                         if value == None:
                             self.specOutputprofileperblock.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='profilesPerBlock')
                             profilesPerBlock = str(value)
                             self.specOutputprofileperblock.setText(profilesPerBlock)
                     return
                 def __refreshSpectraHeisWindow(self, puObj):
                     opObj = puObj.getOperationObj(name="IncohInt4SpectraHeis")
                     if opObj == None:
                         self.specHeisOpIncoherent.clear()
                         self.specHeisOpCebIncoherent.setCheckState(0)
                     else:
                         for parmObj in opObj.getParameterObjList():
                            if parmObj.name == 'timeInterval':
                                value = opObj.getParameterValue(parameterName='timeInterval')
                                value = float(value)
                                self.specHeisOpIncoherent.setText(str(value))
                                self.specHeisOpIncoherent.setEnabled(True)
                                self.specHeisOpCebIncoherent.setCheckState(QtCore.Qt.Checked)
                                self.specHeisOpCobIncInt.setCurrentIndex(0)
                     # SpectraHeis Graph
                     self.specHeisGgraphXminXmax.clear()
                     self.specHeisGgraphYminYmax.clear()
                     self.specHeisGgraphChannelList.clear()
                     self.specHeisGgraphTminTmax.clear()
                     self.specHeisGgraphTimeRange.clear()
                     self.specHeisGgraphftpratio.clear()
                     opObj = puObj.getOperationObj(name='SpectraHeisScope')
                     if opObj == None:
                         self.specHeisGraphCebSpectraplot.setCheckState(0)
                         self.specHeisGraphSaveSpectra.setCheckState(0)
                         self.specHeisGraphftpSpectra.setCheckState(0)
                     else:
                         operationSpectraHeisScope = "Enable"
                         self.specHeisGraphCebSpectraplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='channelList')
                         if parmObj == None:
                             self.specHeisGgraphChannelList.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='channelList')
                             channelListSpectraHeisScope = str(value)[1:-1]
                             self.specHeisGgraphChannelList.setText(channelListSpectraHeisScope)
                             self.specHeisGgraphChannelList.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specHeisGgraphXminXmax.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specHeisGgraphXminXmax.setText(value)
                             self.specHeisGgraphXminXmax.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specHeisGgraphYminYmax.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specHeisGgraphYminYmax.setText(value)
                             self.specHeisGgraphYminYmax.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specHeisGraphSaveSpectra.setCheckState(0)
                         else:
                             self.specHeisGraphSaveSpectra.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specHeisGraphftpSpectra.setCheckState(0)
                         else:
                             self.specHeisGraphftpSpectra.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specHeisGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specHeisGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     opObj = puObj.getOperationObj(name='RTIfromSpectraHeis')
                     if opObj == None:
                         self.specHeisGraphCebRTIplot.setCheckState(0)
                         self.specHeisGraphSaveRTIplot.setCheckState(0)
                         self.specHeisGraphftpRTIplot.setCheckState(0)
                     else:
                         self.specHeisGraphCebRTIplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName='channelList')
                         if parmObj == None:
                             self.specHeisGgraphChannelList.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='channelList')
                             channelListRTIPlot = str(value)[1:-1]
                             self.specGgraphChannelList.setText(channelListRTIPlot)
                             self.specGgraphChannelList.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='xmin')
                         if parmObj == None:
                             self.specHeisGgraphTminTmax.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='xmin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='xmax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specHeisGgraphTminTmax.setText(value)
                             self.specHeisGgraphTminTmax.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='timerange')
                         if parmObj == None:
                             self.specGgraphTimeRange.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='timerange')
                             value1 = str(value1)
                             self.specHeisGgraphTimeRange.setText(value1)
                             self.specHeisGgraphTimeRange.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName='ymin')
                         if parmObj == None:
                             self.specHeisGgraphYminYmax.clear()
                         else:
                             value1 = opObj.getParameterValue(parameterName='ymin')
                             value1 = str(value1)
                             value2 = opObj.getParameterValue(parameterName='ymax')
                             value2 = str(value2)
                             value = value1 + "," + value2
                             self.specHeisGgraphYminYmax.setText(value)
                             self.specHeisGgraphYminYmax.setEnabled(True)
                         parmObj = opObj.getParameterObj(parameterName="save")
                         if parmObj == None:
                             self.specHeisGraphSaveRTIplot.setCheckState(0)
                         else:
                             self.specHeisGraphSaveRTIplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="ftp")
                         if parmObj == None:
                             self.specHeisGraphftpRTIplot.setCheckState(0)
                         else:
                             self.specHeisGraphftpRTIplot.setCheckState(QtCore.Qt.Checked)
                         parmObj = opObj.getParameterObj(parameterName="figpath")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specHeisGraphPath.setText(value)
                         parmObj = opObj.getParameterObj(parameterName="wr_period")
                         if parmObj:
                             value = parmObj.getValue()
                             self.specHeisGgraphftpratio.setText(str(value))
-                        ########################################################
-                        parmObj = opObj.getParameterObj(parameterName="ftp_wei")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.ftp_wei = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.sub_exp_code = str(value)
-                        parmObj = opObj.getParameterObj(parameterName="plot_pos")
-                        if parmObj:
-                            value = parmObj.getValue()
-                            self.temporalFTP.plot_pos = str(value)
                     # outputSpectraHeisWrite
                     opObj = puObj.getOperationObj(name='FitsWriter')
                     if opObj == None:
                         self.specHeisOutputPath.clear()
                         self.specHeisOutputblocksperfile.clear()
                         self.specHeisOutputMetada.clear()
                     else:
                         value = opObj.getParameterObj(parameterName='path')
                         if value == None:
                             self.specHeisOutputPath.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='path')
                             path = str(value)
                             self.specHeisOutputPath.setText(path)
                         value = opObj.getParameterObj(parameterName='dataBlocksPerFile')
                         if value == None:
                            self.specHeisOutputblocksperfile.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='dataBlocksPerFile')
                             blocksperfile = str(value)
                             self.specHeisOutputblocksperfile.setText(blocksperfile)
                         value = opObj.getParameterObj(parameterName='metadatafile')
                         if value == None:
                             self.specHeisOutputMetada.clear()
                         else:
                             value = opObj.getParameterValue(parameterName='metadatafile')
                             metada = str(value)
                             self.specHeisOutputMetada.setText(metada)
                     return
                 def __refreshCorrelationWindow(self, puObj):
                     pass
                 def refreshPUWindow(self, puObj):
                     if puObj.datatype == 'Voltage':
                         self.__refreshVoltageWindow(puObj)
                     if puObj.datatype == 'Spectra':
                         self.__refreshSpectraWindow(puObj)
                     if puObj.datatype == 'SpectraHeis':
                         self.__refreshSpectraHeisWindow(puObj)
                 def refreshProjectProperties(self, projectObjView):
                     propertyBuffObj = PropertyBuffer()
                     name = projectObjView.name
                     propertyBuffObj.append("Properties", "Name", projectObjView.name),
                     propertyBuffObj.append("Properties", "Description", projectObjView.description)
                     propertyBuffObj.append("Properties", "Workspace", self.pathWorkSpace)
                     readUnitObj = projectObjView.getReadUnitObj()
                     runOperationObj = readUnitObj.getOperationObj(name='run')
                     for thisParmObj in runOperationObj.getParameterObjList():
                         propertyBuffObj.append("Reading parms", thisParmObj.name, str(thisParmObj.getValue()))
                     propertiesModel = propertyBuffObj.getPropertyModel()
                     self.treeProjectProperties.setModel(propertiesModel)
                     self.treeProjectProperties.expandAll()
                     self.treeProjectProperties.resizeColumnToContents(0)
                     self.treeProjectProperties.resizeColumnToContents(1)
                 def refreshPUProperties(self, puObjView):
                     ############ FTP CONFIG ################################
+                    #Deleting FTP Conf. This processing unit have not got any
+                    #FTP configuration by default
                     if puObjView.id in self.__puLocalFolder2FTP.keys():
                         self.__puLocalFolder2FTP.pop(puObjView.id)
                     ########################################################
                     propertyBuffObj = PropertyBuffer()
                     for thisOp in puObjView.getOperationObjList():
                         operationName = thisOp.name
                         if operationName == 'run':
                             operationName = 'Properties'
-                        if not thisOp.getParameterObjList():
+                        else:
-                            propertyBuffObj.append(operationName, '--', '--')
+                            if not thisOp.getParameterObjList():
-                            continue
+                                propertyBuffObj.append(operationName, '--', '--')
+                                continue
                         for thisParmObj in thisOp.getParameterObjList():
                             propertyBuffObj.append(operationName, thisParmObj.name, str(thisParmObj.getValue()))
                             ############ FTP CONFIG ################################
+                            if thisParmObj.name == "ftp_wei" and thisParmObj.getValue():
+                                value = thisParmObj.getValue()
+                                self.temporalFTP.ftp_wei = value
+                            if thisParmObj.name == "exp_code" and thisParmObj.getValue():
+                                value = thisParmObj.getValue()
+                                self.temporalFTP.exp_code = value
+                            if thisParmObj.name == "sub_exp_code" and thisParmObj.getValue():
+                                value = thisParmObj.getValue()
+                                self.temporalFTP.sub_exp_code = value
+                            if thisParmObj.name == "plot_pos" and thisParmObj.getValue():
+                                value = thisParmObj.getValue()
+                                self.temporalFTP.plot_pos = value
                             if thisParmObj.name == 'ftp' and thisParmObj.getValue():
-                                figpath = thisOp.getParameterValue('figpath')
+                                figpathObj = thisOp.getParameterObj('figpath')
-                                if not figpath:
+                                if figpathObj:
-                                    continue
+                                    self.__puLocalFolder2FTP[puObjView.id] = figpathObj.getValue()
-                                self.__puLocalFolder2FTP[puObjView.id] = figpath
                             ########################################################
                     propertiesModel = propertyBuffObj.getPropertyModel()
                     self.treeProjectProperties.setModel(propertiesModel)
                     self.treeProjectProperties.expandAll()
                     self.treeProjectProperties.resizeColumnToContents(0)
                     self.treeProjectProperties.resizeColumnToContents(1)
                 def refreshGraphicsId(self):
                     projectObj = self.getSelectedProjectObj()
                     for idPU, puObj in projectObj.procUnitConfObjDict.items():
                         for opObj in puObj.getOperationObjList():
                             if opObj.name not in ('Scope', 'SpectraPlot', 'CrossSpectraPlot', 'RTIPlot', 'CoherenceMap', 'PowerProfilePlot', 'Noise', 'SpectraHeisScope', 'RTIfromSpectraHeis'):
                                 continue
                             opObj.changeParameter(name='id', value=opObj.id, format='int')
                 def on_click(self, index):
                     self.selectedItemTree = self.projectExplorerModel.itemFromIndex(index)
                     projectObjView = self.getSelectedProjectObj()
                     if not projectObjView:
                         return
                     self.create = False
                     selectedObjView = self.getSelectedItemObj()
                     #A project has been selected
                     if projectObjView == selectedObjView:
                         self.refreshProjectWindow2(projectObjView)
                         self.refreshProjectProperties(projectObjView)
                         self.tabProject.setEnabled(True)
                         self.tabVoltage.setEnabled(False)
                         self.tabSpectra.setEnabled(False)
                         self.tabCorrelation.setEnabled(False)
                         self.tabSpectraHeis.setEnabled(False)
                         self.tabWidgetProject.setCurrentWidget(self.tabProject)
                         return
                     #A processing unit has been selected
                     voltEnable = False
                     specEnable = False
                     corrEnable = False
                     specHeisEnable = False
                     tabSelected = self.tabProject
                     puObj = selectedObjView
                     self.refreshPUWindow(puObj)
                     self.refreshPUProperties(puObj)
                     self.showtabPUCreated(puObj.datatype)
                 def on_right_click(self, pos):
                     self.menu = QtGui.QMenu()
                     quitAction0 = self.menu.addAction("Create a New Project")
                     quitAction1 = self.menu.addAction("Create a New Processing Unit")
                     quitAction2 = self.menu.addAction("Delete Item")
                     quitAction3 = self.menu.addAction("Quit")
                     if len(self.__itemTreeDict) == 0:
                         quitAction2.setEnabled(False)
                     else:
                         quitAction2.setEnabled(True)
                     action = self.menu.exec_(self.mapToGlobal(pos))
                     if action == quitAction0:
                        self. setInputsProject_View()
                        self.create = True
                     if action == quitAction1:
                         if len(self.__projectObjDict) == 0:
                             outputstr = "You need to create a Project before adding a Processing Unit"
                             self.console.clear()
                             self.console.append(outputstr)
                             return 0
                         else:
                            self.addPUWindow()
                            self.console.clear()
                            self.console.append("Please, Choose the type of Processing Unit")
             #                self.console.append("If your Datatype is rawdata, you will start with processing unit Type Voltage")
             #                self.console.append("If your Datatype is pdata, you will choose between processing unit Type Spectra or Correlation")
             #                self.console.append("If your Datatype is fits, you will start with processing unit Type SpectraHeis")
                     if action == quitAction2:
                         index = self.selectedItemTree
                         try:
                             index.parent()
                         except:
                             self.console.append('Please first select a Project or Processing Unit')
                             return 0
                         # print index.parent(),index
                         if index.parent() == None:
                            self.projectExplorerModel.removeRow(index.row())
                         else:
                             index.parent().removeRow(index.row())
                         self.removeItemTreeFromProject()
                         self.console.clear()
                         # for i in self.projectExplorerTree.selectionModel().selection().indexes():
                         #     print i.row()
                     if action == quitAction3:
                         self.close()
                         return 0
                 def create_updating_timer(self):
                     self.comm_data_timer = QtCore.QTimer(self)
                     self.comm_data_timer.timeout.connect(self.on_comm_updating_timer)
                     self.comm_data_timer.start(1000)
                 def createProjectView(self, id):
             #         project_name, description, datatype, data_path, starDate, endDate, startTime, endTime, online, delay, walk, set = self.getParmsFromProjectWindow()
                     id = str(id)
                     projectParms = self.__getParmsFromProjectWindow()
                     if not projectParms.isValid():
                         return None
                     projectObjView = Project()
                     projectObjView.setup(id=id, name=projectParms.name, description=projectParms.description)
                     self.__projectObjDict[id] = projectObjView
                     self.addProject2ProjectExplorer(id=id, name=projectObjView.name)
                     self.create = False
                     return projectObjView
                 def updateProjectView(self):
             #         project_name, description, datatype, data_path, starDate, endDate, startTime, endTime, online, delay, walk, set = self.getParmsFromProjectWindow()
                     projectParms = self.__getParmsFromProjectWindow()
                     if not projectParms.isValid():
                         return None
                     projectObjView = self.getSelectedProjectObj()
                     projectObjView.update(name=projectParms.name, description=projectParms.description)
                     return projectObjView
                 def createReadUnitView(self, projectObjView):
             #         project_name, description, datatype, data_path, startDate, endDate, startTime, endTime, online, delay, walk, set = self.getParmsFromProjectWindow()
                     projectParms = self.__getParmsFromProjectWindow()
                     if not projectParms.isValid():
                         return None
                     if projectParms.datatype in ("Voltage", "Spectra", "Fits"):
                         readUnitConfObj = projectObjView.addReadUnit(datatype=projectParms.datatype,
                                                                         path=projectParms.dpath,
                                                                         startDate=projectParms.startDate,
                                                                         endDate=projectParms.endDate,
                                                                         startTime=projectParms.startTime,
                                                                         endTime=projectParms.endTime,
                                                                         online=projectParms.online,
                                                                         walk=projectParms.walk
                                                                         )
                         if projectParms.set:
                             readUnitConfObj.addParameter(name="set", value=projectParms.set, format="int")
                         if projectParms.delay:
                             readUnitConfObj.addParameter(name="delay", value=projectParms.delay, format="int")
                     if projectParms.datatype == "USRP":
                         readUnitConfObj = projectObjView.addReadUnit(datatype=projectParms.datatype,
                                                                         path=projectParms.dpath,
                                                                         startDate=projectParms.startDate,
                                                                         endDate=projectParms.endDate,
                                                                         startTime=projectParms.startTime,
                                                                         endTime=projectParms.endTime,
                                                                         online=projectParms.online,
                                                                         ippKm=projectParms.ippKm
                                                                         )
                         if projectParms.delay:
                             readUnitConfObj.addParameter(name="delay", value=projectParms.delay, format="int")
                     return readUnitConfObj
                 def updateReadUnitView(self, projectObjView, idReadUnit):
             #         project_name, description, datatype, data_path, startDate, endDate, startTime, endTime, online, delay, walk , set = self.getParmsFromProjectWindow()
                     readUnitConfObj = projectObjView.getProcUnitObj(idReadUnit)
                     projectParms = self.__getParmsFromProjectWindow()
                     if not projectParms.isValid():
                         return None
                     if projectParms.datatype in ["Voltage", "Spectra", "Fits"]:
                         readUnitConfObj.update(datatype=projectParms.datatype,
                                                 path=projectParms.dpath,
                                                 startDate=projectParms.startDate,
                                                 endDate=projectParms.endDate,
                                                 startTime=projectParms.startTime,
                                                 endTime=projectParms.endTime,
                                                 online=projectParms.online,
                                                 walk=projectParms.walk
                                                 )
                         if projectParms.set:
                             readUnitConfObj.addParameter(name="set", value=projectParms.set, format="int")
                         if projectParms.delay:
                             readUnitConfObj.addParameter(name="delay", value=projectParms.delay, format="int")
                     if projectParms.datatype == "USRP":
                         readUnitConfObj.update(datatype=projectParms.datatype,
                                                 path=projectParms.dpath,
                                                 startDate=projectParms.startDate,
                                                 endDate=projectParms.endDate,
                                                 startTime=projectParms.startTime,
                                                 endTime=projectParms.endTime,
                                                 online=projectParms.online,
                                                 ippKm=projectParms.ippKm
                                                 )
                         if projectParms.delay:
                             readUnitConfObj.addParameter(name="delay", value=projectParms.delay, format="int")
                     return readUnitConfObj
                 def createProcUnitView(self, projectObjView, datatype, inputId):
                     procUnitConfObj = projectObjView.addProcUnit(datatype=datatype, inputId=inputId)
                     self.__puObjDict[procUnitConfObj.getId()] = procUnitConfObj
                     return procUnitConfObj
                 def updateProcUnitView(self, id):
                     procUnitConfObj = projectObjView.getProcUnitObj(id)
                     procUnitConfObj.removeOperations()
                     return procUnitConfObj
                 def addPUWindow(self):
                     self.configUPWindowObj = UnitProcessWindow(self)
                     fatherObj = self.getSelectedItemObj()
                     try:
                         fatherObj.getElementName()
                     except:
                         self.console.append("First left click on Project or Processing Unit")
                         return 0
                     if fatherObj.getElementName() == 'Project':
                         readUnitConfObj = fatherObj.getReadUnitObj()
                         self.configUPWindowObj.dataTypeProject = str(readUnitConfObj.datatype)
                     self.configUPWindowObj.getfromWindowList.append(fatherObj)
                     self.configUPWindowObj.loadTotalList()
                     self.configUPWindowObj.show()
                     self.configUPWindowObj.closed.connect(self.createPUWindow)
                 def createPUWindow(self):
                     if not self.configUPWindowObj.create:
                         return
                     fatherObj = self.configUPWindowObj.getFromWindow
                     datatype = self.configUPWindowObj.typeofUP
                     if fatherObj.getElementName() == 'Project':
                         inputId = fatherObj.getReadUnitId()
                         projectObjView = fatherObj
                     else:
                         inputId = fatherObj.getId()
                         projectObjView = self.getSelectedProjectObj()
                     puObj = self.createProcUnitView(projectObjView, datatype, inputId)
                     self.addPU2ProjectExplorer(puObj)
                     self.showtabPUCreated(datatype)
                     self.clearPUWindow(datatype)
                     self.showPUinitView()
                 def addFTPConf2Operation(self, puObj, opObj):
                     if not self.temporalFTP.create:
                         self.temporalFTP.setwithoutconfiguration()
             #         opObj.addParameter(name='server', value=self.temporalFTP.server, format='str')
             #         opObj.addParameter(name='remotefolder', value=self.temporalFTP.remotefolder, format='str')
             #         opObj.addParameter(name='username', value=self.temporalFTP.username, format='str')
             #         opObj.addParameter(name='password', value=self.temporalFTP.password, format='str')
                     if self.temporalFTP.ftp_wei:
                         opObj.addParameter(name='ftp_wei', value=int(self.temporalFTP.ftp_wei), format='int')
                     if self.temporalFTP.exp_code:
                         opObj.addParameter(name='exp_code', value=int(self.temporalFTP.exp_code), format='int')
                     if self.temporalFTP.sub_exp_code:
                         opObj.addParameter(name='sub_exp_code', value=int(self.temporalFTP.sub_exp_code), format='int')
                     if self.temporalFTP.plot_pos:
                         opObj.addParameter(name='plot_pos', value=int(self.temporalFTP.plot_pos), format='int')
                 def __checkFTPProcUnit(self, projectObj, localfolder):
                     puId = None
                     puObj = None
                     for thisPuId, thisPuObj in projectObj.procUnitItems():
                         if not thisPuObj.name == "SendToServer":
                             continue
                         opObj = thisPuObj.getOperationObj(name='run')
                         parmObj = opObj.getParameterObj('localfolder')
                         #localfolder parameter should always be set, if it is not set then ProcUnit should be removed
                         if not parmObj:
                             projectObj.removeProcUnit(thisPuId)
                             continue
                         thisLocalfolder = parmObj.getValue()
                         if localfolder != thisLocalfolder:
                             continue
                         puId = thisPuId
                         puObj = thisPuObj
                         break
                     return puObj
-                def __addFTPProcUnitFrom(self, operationObj):
+                def createFTPProcUnitView(self):
-                    if operationObj.name != "SendByFTP":
-                        return
-                    projectObj = self.getSelectedProjectObj()
-                    self.removeAllFTPProcUnitView(projectObj)
-                    procUnitConfObj = projectObj.addProcUnit(name="SendToServer")
-                    server = operationObj.getParameterValue("server")
-                    username = operationObj.getParameterValue("username")
-                    password = operationObj.getParameterValue("pasword")
-                    localfolder = operationObj.getParameterValue("localfolder")
-                    remotefolder = operationObj.getParameterValue("remotefolder")
-                    ext = operationObj.getParameterValue("ext")
-                    period = operationObj.getParameterValue("period")
-                    procUnitConfObj.addParameter(name='server', value=server, format='str')
-                    procUnitConfObj.addParameter(name='username', value=username, format='str')
-                    procUnitConfObj.addParameter(name='password', value=password, format='str')
-                    procUnitConfObj.addParameter(name='localfolder', value=localfolder, format='list')
-                    procUnitConfObj.addParameter(name='remotefolder', value=remotefolder, format='str')
-                    procUnitConfObj.addParameter(name='ext', value=ext, format='str')
-                    procUnitConfObj.addParameter(name='period', value=period, format='int')
-                    self.__puObjDict[procUnitConfObj.getId()] = procUnitConfObj
-                    return procUnitConfObj
-                def addFTPProcUnitView(self):
                     if not self.temporalFTP.create:
                         self.temporalFTP.setwithoutconfiguration()
                     projectObj = self.getSelectedProjectObj()
                     self.removeAllFTPProcUnitView(projectObj)
                     if not self.__puLocalFolder2FTP:
                         return
                     folderList = ""
                     for localfolder in self.__puLocalFolder2FTP.values():
                         folderList += str(localfolder) + ","
                     procUnitConfObj = projectObj.addProcUnit(name="SendToServer")
                     procUnitConfObj.addParameter(name='server', value=self.temporalFTP.server, format='str')
                     procUnitConfObj.addParameter(name='username', value=self.temporalFTP.username, format='str')
                     procUnitConfObj.addParameter(name='password', value=self.temporalFTP.password, format='str')
                     procUnitConfObj.addParameter(name='localfolder', value=folderList, format='list')
                     procUnitConfObj.addParameter(name='remotefolder', value=self.temporalFTP.remotefolder, format='str')
                     procUnitConfObj.addParameter(name='ext', value=self.temporalFTP.extension, format='str')
                     procUnitConfObj.addParameter(name='period', value=self.temporalFTP.period, format='int')
                     procUnitConfObj.addParameter(name='protocol', value=self.temporalFTP.protocol, format='str')
-                    procUnitConfObj.addParameter(name='ftp_wei', value=self.temporalFTP.ftp_wei, format='str')
+                    procUnitConfObj.addParameter(name='ftp_wei', value=self.temporalFTP.ftp_wei, format='int')
-                    procUnitConfObj.addParameter(name='exp_code', value=self.temporalFTP.exp_code, format='str')
+                    procUnitConfObj.addParameter(name='exp_code', value=self.temporalFTP.exp_code, format='int')
-                    procUnitConfObj.addParameter(name='sub_exp_code', value=self.temporalFTP.sub_exp_code, format='str')
+                    procUnitConfObj.addParameter(name='sub_exp_code', value=self.temporalFTP.sub_exp_code, format='int')
-                    procUnitConfObj.addParameter(name='plot_pos', value=self.temporalFTP.plot_pos, format='str')
+                    procUnitConfObj.addParameter(name='plot_pos', value=self.temporalFTP.plot_pos, format='int')
                     self.__puObjDict[procUnitConfObj.getId()] = procUnitConfObj
                 def removeAllFTPProcUnitView(self, projectObj):
                     for thisPuId, thisPuObj in projectObj.procUnitItems():
                         if not thisPuObj.name == "SendToServer":
                             continue
                         projectObj.removeProcUnit(thisPuId)
                         if thisPuId not in self.__puObjDict.keys():
                             continue
                         self.__puObjDict.pop(thisPuId)
                 def showPUinitView(self):
                     self.propertiesModel = TreeModel()
                     self.propertiesModel.initPUVoltageView()
                     self.treeProjectProperties.setModel(self.propertiesModel)
                     self.treeProjectProperties.expandAll()
                     self.treeProjectProperties.allColumnsShowFocus()
                     self.treeProjectProperties.resizeColumnToContents(1)
+                def saveFTPFromOpObj(self, operationObj):
+                    if operationObj.name != "SendByFTP":
+                        return
+                    server = operationObj.getParameterValue("server")
+                    username = operationObj.getParameterValue("username")
+                    password = operationObj.getParameterValue("password")
+                    localfolder = operationObj.getParameterValue("localfolder")
+                    remotefolder = operationObj.getParameterValue("remotefolder")
+                    ext = operationObj.getParameterValue("ext")
+                    period = operationObj.getParameterValue("period")
-                def saveFTPvalues(self, puObj):
+                    self.temporalFTP.save(server=server,
+                                          remotefolder=remotefolder,
+                                          username=username,
+                                          password=password,
+                                          localfolder=localfolder,
+                                          extension=ext)
+                    return
+                def saveFTPFromProcUnitObj(self, puObj):
                     opObj = puObj.getOperationObj(name="run")
                     parmObj = opObj.getParameterObj(parameterName="server")
                     if parmObj == None:
                         server = 'jro-app.igp.gob.pe'
                     else:
                         server = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="remotefolder")
                     if parmObj == None:
                         remotefolder = '/home/wmaster/graficos'
                     else:
                         remotefolder = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="username")
                     if parmObj == None:
                         username = 'wmaster'
                     else:
                         username = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="password")
                     if parmObj == None:
                         password = 'mst2010vhf'
                     else:
                         password = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="ftp_wei")
                     if parmObj == None:
-                        ftp_wei = '0'
+                        ftp_wei = 0
                     else:
                         ftp_wei = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="exp_code")
                     if parmObj == None:
-                        exp_code = '0'
+                        exp_code = 0
                     else:
                         exp_code = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="sub_exp_code")
                     if parmObj == None:
-                        sub_exp_code = '0'
+                        sub_exp_code = 0
                     else:
                         sub_exp_code = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="plot_pos")
                     if parmObj == None:
-                        plot_pos = '0'
+                        plot_pos = 0
                     else:
                         plot_pos = parmObj.getValue()
                     parmObj = opObj.getParameterObj(parameterName="localfolder")
                     if parmObj == None:
                         localfolder = None
                     else:
                         localfolder = parmObj.getValue()
-                    parmObj = opObj.getParameterObj(parameterName="extension")
+                    parmObj = opObj.getParameterObj(parameterName="ext")
                     if parmObj == None:
                         extension = '.png'
                     else:
                         extension = parmObj.getValue()
                     self.temporalFTP.save(server=server,
                                           remotefolder=remotefolder,
                                           username=username,
                                           password=password,
                                           ftp_wei=ftp_wei,
                                           exp_code=exp_code,
                                           sub_exp_code=sub_exp_code,
                                           plot_pos=plot_pos,
                                           localfolder=localfolder,
                                           extension=extension)
                 def addProject2ProjectExplorer(self, id, name):
                     itemTree = QtGui.QStandardItem(QtCore.QString(str(name)))
                     parentItem = self.projectExplorerModel.invisibleRootItem()
                     parentItem.appendRow(itemTree)
                     self.projectExplorerTree.setCurrentIndex(itemTree.index())
                     self.selectedItemTree = itemTree
                     self.__itemTreeDict[id] = itemTree
                 def addPU2ProjectExplorer(self, puObj):
                     id, name = puObj.id, puObj.datatype
                     itemTree = QtGui.QStandardItem(QtCore.QString(str(name)))
                     parentItem = self.selectedItemTree
                     parentItem.appendRow(itemTree)
                     self.projectExplorerTree.expandAll()
                     self.projectExplorerTree.setCurrentIndex(itemTree.index())
                     self.selectedItemTree = itemTree
                     self.__itemTreeDict[id] = itemTree
                 def addPU2PELoadXML(self, puObj):
                     id, name, inputId = puObj.id, puObj.datatype, puObj.inputId
                     itemTree = QtGui.QStandardItem(QtCore.QString(str(name)))
                     if self.__itemTreeDict.has_key(inputId):
                         parentItem = self.__itemTreeDict[inputId]
                     else:
                         #If parent is a Reader object
                         parentItem = self.__itemTreeDict[id[:-1]]
                     parentItem.appendRow(itemTree)
                     self.projectExplorerTree.expandAll()
                     parentItem = itemTree
                     self.projectExplorerTree.setCurrentIndex(parentItem.index())
                     self.__itemTreeDict[id] = itemTree
                     self.selectedItemTree = itemTree
                 def getSelectedProjectObj(self):
                     """
                     Return the current project object selected. If a processing unit is
                     actually selected this function returns associated project.
                     None if any project or processing unit is selected
                     """
                     for key in self.__itemTreeDict.keys():
                         if self.__itemTreeDict[key] != self.selectedItemTree:
                             continue
                         if self.__projectObjDict.has_key(key):
                             projectObj = self.__projectObjDict[key]
                             return projectObj
                         puObj = self.__puObjDict[key]
                         if puObj.parentId == None:
                             projectId = puObj.getId()[0]
                         else:
                             projectId = puObj.parentId
                         projectObj = self.__projectObjDict[projectId]
                         return projectObj
                     return None
                 def getSelectedItemObj(self):
                     """
                     Return the current project or processing unit object selected
                     None if any project or processing unit is selected
                     """
                     for key in self.__itemTreeDict.keys():
                         if self.__itemTreeDict[key] != self.selectedItemTree:
                             continue
                         if self.__projectObjDict.has_key(key) == True:
                             fatherObj = self.__projectObjDict[key]
                         else:
                             fatherObj = self.__puObjDict[key]
                         return fatherObj
                     return None
                 def _WarningWindow(self, text, information):
                     msgBox = QtGui.QMessageBox()
                     msgBox.setText(text)
                     msgBox.setInformativeText(information)
                     msgBox.setStandardButtons(QtGui.QMessageBox.Ok | QtGui.QMessageBox.Cancel)
                     msgBox.setDefaultButton(QtGui.QMessageBox.Ok)
                     ret = msgBox.exec_()
                     answer = False
                     if ret == QtGui.QMessageBox.Ok:
                         answer = True
                     return answer
                 def __getNewProjectId(self):
                     loadProject = False
                     for thisId in range(1,10):
                         newId = str(thisId)
                         if newId in self.__projectObjDict.keys():
                             continue
                         loadProject = True
                         projectId = newId
                         break
                     if not loadProject:
                         self.console.clear()
                         self.console.append("The maximum number of projects has been loaded, a new project can not be loaded")
                         return None
                     return projectId
                 def openProject(self):
                     self.actionStart.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     self.create = False
                     self.frame_2.setEnabled(True)
                     # print self.dir
                     filename = str(QtGui.QFileDialog.getOpenFileName(self, "Open text file", self.pathWorkSpace, self.tr("Text Files (*.xml)")))
                     projectObjLoad = Project()
                     try:
                         projectObjLoad.readXml(filename)
                     except:
                         self.console.clear()
                         self.console.append("The selected xml file could not be loaded ...")
                         return 0
                     self.refreshProjectWindow2(projectObjLoad)
                     self.refreshProjectProperties(projectObjLoad)
                     projectId = projectObjLoad.id
                     if projectId in self.__projectObjDict.keys():
             #             answer = self._WarningWindow("You already have a project loaded with the same Id",
             #                                             "Do you want to load the file anyway?")
             #             if not answer:
             #                 return
                         projectId = self.__getNewProjectId()
                         if not projectId:
                             return
                         projectObjLoad.updateId(projectId)
                     self.__projectObjDict[projectId] = projectObjLoad
                     self.addProject2ProjectExplorer(id=projectId, name=projectObjLoad.name)
                     self.tabWidgetProject.setEnabled(True)
                     self.tabWidgetProject.setCurrentWidget(self.tabProject)
                     # Disable tabProject after finish the creation
                     self.tabProject.setEnabled(True)
                     puObjorderList = OrderedDict(sorted(projectObjLoad.procUnitConfObjDict.items(), key=lambda x: x[0]))
                     for puId, puObj in puObjorderList.items():
                         self.__puObjDict[puId] = puObj
                         if puObj.name == "SendToServer":
-                            self.saveFTPvalues(puObj)
+                            self.saveFTPFromProcUnitObj(puObj)
+                        ############## COMPATIBLE WITH OLD VERSIONS ################
+                        operationObj = puObj.getOperationObj("SendByFTP")
+                        if operationObj:
+                            self.saveFTPFromOpObj(operationObj)
+                        ############################################################
                         if puObj.inputId == '0':
                             continue
                         self.addPU2PELoadXML(puObj)
                         self.refreshPUWindow(puObj)
                         self.refreshPUProperties(puObj)
                         self.showtabPUCreated(datatype=puObj.datatype)
-                        ############## COMPATIBLE FROM OLD VERSIONS ################
-                        operationObj = puObj.getOperationObj("SendByFTP")
-                        if operationObj:
-                            send2ServerObj = self.__addFTPProcUnitFrom(operationObj)
-                            self.saveFTPvalues(send2ServerObj)
-                        ############################################################
                     self.console.clear()
                     self.console.append("The selected xml file has been loaded successfully")
                     self.actionStart.setEnabled(True)
                     self.actionStarToolbar.setEnabled(True)
                 def on_comm_updating_timer(self):
                     # Verifica si algun proceso ha sido inicializado y sigue ejecutandose
                     if not self.__initialized:
                         return
                     if not self.controllerObj.isAlive():
                         self.stopProject()
                 def playProject(self, ext=".xml", save=1):
             #         self.console.clear()
                     projectObj = self.getSelectedProjectObj()
                     if not projectObj:
                         print "Please select a project before pressing PLAY button"
                         return
                     if save:
                         filename = self.saveProject()
                         if filename == None:
                             self.console.append("Process did not initialize.")
                             return
                     else:
                         filename = TEMPORAL_FILE
                         projectObj.writeXml( os.path.join(self.pathWorkSpace,filename) )
                     self.actionStart.setEnabled(False)
                     self.actionPause.setEnabled(True)
                     self.actionStop.setEnabled(True)
                     self.actionStarToolbar.setEnabled(False)
                     self.actionPauseToolbar.setEnabled(True)
                     self.actionStopToolbar.setEnabled(True)
                     self.console.append("Please Wait...")
                     self.controllerObj = ControllerThread(filename)
                     self.controllerObj.start()
                     sleep(0.5)
                     self.__initialized = True
                 def stopProject(self):
                     self.__initialized = False
             #         self.commCtrlPThread.cmd_q.put(ProcessCommand(ProcessCommand.STOP, True))
                     self.controllerObj.stop()
                     self.actionStart.setEnabled(True)
                     self.actionPause.setEnabled(False)
                     self.actionStop.setEnabled(False)
                     self.actionStarToolbar.setEnabled(True)
                     self.actionPauseToolbar.setEnabled(False)
                     self.actionStopToolbar.setEnabled(False)
                     self.restorePauseIcon()
                 def pauseProject(self):
             #         self.commCtrlPThread.cmd_q.put(ProcessCommand(ProcessCommand.PAUSE, data=True))
                     self.controllerObj.pause()
                     self.actionStart.setEnabled(False)
                     self.actionPause.setEnabled(True)
                     self.actionStop.setEnabled(True)
                     self.actionStarToolbar.setEnabled(False)
                     self.actionPauseToolbar.setEnabled(True)
                     self.actionStopToolbar.setEnabled(True)
                 def saveProject(self, filename=None):
                     self.actionStart.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     projectObj = self.getSelectedProjectObj()
                     self.refreshGraphicsId()
                     sts = True
                     selectedItemObj = self.getSelectedItemObj()
                     #A Processing Unit has been selected
                     if projectObj == selectedItemObj:
                         if not self.on_proOk_clicked():
                             return None
                     #A Processing Unit has been selected
                     if projectObj != selectedItemObj:
                         puObj = selectedItemObj
                         if puObj.name == 'VoltageProc':
                             sts = self.on_volOpOk_clicked()
                         if puObj.name == 'SpectraProc':
                             sts = self.on_specOpOk_clicked()
                         if puObj.name == 'SpectraHeisProc':
                             sts = self.on_specHeisOpOk_clicked()
                         if not sts:
                             return None
-                    self.addFTPProcUnitView()
+                    self.createFTPProcUnitView()
                     if not filename:
                         filename = os.path.join( str(self.pathWorkSpace), "%s%s" %(str(projectObj.name), '.xml') )
                     projectObj.writeXml(filename)
                     self.console.append("Now,  you can press Start button")
                     self.actionStart.setEnabled(True)
                     self.actionStarToolbar.setEnabled(True)
                     return filename
                 def removeItemTreeFromProject(self):
                     """
                     Metodo para eliminar el proyecto en el dictionario de proyectos y en el dictionario de vista de arbol
                     """
                     for key in self.__itemTreeDict.keys():
                         #Check again because an item can delete multiple items (childs)
                         if key not in self.__itemTreeDict.keys():
                             continue
                         if self.__itemTreeDict[key] != self.selectedItemTree:
                             continue
                         if self.__projectObjDict.has_key(key) == True:
                             del self.__projectObjDict[key]
                             del self.__itemTreeDict[key]
                         else:
                             puObj = self.__puObjDict[key]
                             idProjectParent = puObj.parentId
                             projectObj = self.__projectObjDict[idProjectParent]
                             del self.__puObjDict[key]
                             del self.__itemTreeDict[key]
                             del projectObj.procUnitConfObjDict[key]
                             for key in projectObj.procUnitConfObjDict.keys():
                                 if projectObj.procUnitConfObjDict[key].inputId != puObj.getId():
                                     continue
                                 del self.__puObjDict[projectObj.procUnitConfObjDict[key].getId()]
                                 del self.__itemTreeDict[projectObj.procUnitConfObjDict[key].getId()]
                                 del projectObj.procUnitConfObjDict[key]
                             # print projectObj.procUnitConfObjDict
                         # print self.__itemTreeDict,self.__projectObjDict,self.__puObjDict
                 def setInputsProject_View(self):
                     self.tabWidgetProject.setEnabled(True)
                     self.tabWidgetProject.setCurrentWidget(self.tabProject)
                     self.tabProject.setEnabled(True)
                     self.frame_2.setEnabled(False)
                     self.proName.clear()
                     self.proName.setFocus()
                     self.proName.setSelection(0, 0)
                     self.proName.setCursorPosition(0)
                     self.proDataType.setText('.r')
                     self.proDataPath.clear()
                     self.proComDataType.clear()
                     self.proComDataType.addItem("Voltage")
                     self.proComDataType.addItem("Spectra")
                     self.proComDataType.addItem("Fits")
                     self.proComDataType.addItem("USRP")
                     self.proComStartDate.clear()
                     self.proComEndDate.clear()
                     startTime = "00:00:00"
                     endTime = "23:59:59"
                     starlist = startTime.split(":")
                     endlist = endTime.split(":")
                     self.proDelay.setText("60")
                     self.proSet.setText("")
                     self.labelSet.show()
                     self.proSet.show()
                     self.labelIPPKm.hide()
                     self.proIPPKm.hide()
                     self.time.setHMS(int(starlist[0]), int(starlist[1]), int(starlist[2]))
                     self.proStartTime.setTime(self.time)
                     self.time.setHMS(int(endlist[0]), int(endlist[1]), int(endlist[2]))
                     self.proEndTime.setTime(self.time)
                     self.proDescription.clear()
                     self.proOk.setEnabled(False)
             #         self.console.append("Please, Write a name Project")
             #         self.console.append("Introduce Project Parameters")DC
             #         self.console.append("Select data type Voltage( .rawdata)  or Spectra(.pdata)")
                 def clearPUWindow(self, datatype):
                     projectObjView = self.getSelectedProjectObj()
                     if not projectObjView:
                         return
                     puObj = self.getSelectedItemObj()
                     inputId = puObj.getInputId()
                     inputPUObj = projectObjView.getProcUnitObj(inputId)
                     if datatype == 'Voltage':
                         self.volOpComChannels.setEnabled(False)
                         self.volOpComHeights.setEnabled(False)
                         self.volOpFilter.setEnabled(False)
                         self.volOpComProfile.setEnabled(False)
                         self.volOpComCode.setEnabled(False)
                         self.volOpCohInt.setEnabled(False)
                         self.volOpChannel.setEnabled(False)
                         self.volOpHeights.setEnabled(False)
                         self.volOpProfile.setEnabled(False)
                         self.volOpRadarfrequency.setEnabled(False)
                         self.volOpCebChannels.setCheckState(0)
                         self.volOpCebRadarfrequency.setCheckState(0)
                         self.volOpCebHeights.setCheckState(0)
                         self.volOpCebFilter.setCheckState(0)
                         self.volOpCebProfile.setCheckState(0)
                         self.volOpCebDecodification.setCheckState(0)
                         self.volOpCebCohInt.setCheckState(0)
                         self.volOpChannel.clear()
                         self.volOpHeights.clear()
                         self.volOpProfile.clear()
                         self.volOpFilter.clear()
                         self.volOpCohInt.clear()
                         self.volOpRadarfrequency.clear()
                     if datatype == 'Spectra':
                         if inputPUObj.datatype == 'Spectra':
                             self.specOpnFFTpoints.setEnabled(False)
                             self.specOpProfiles.setEnabled(False)
                             self.specOpippFactor.setEnabled(False)
                         else:
                             self.specOpnFFTpoints.setEnabled(True)
                             self.specOpProfiles.setEnabled(True)
                             self.specOpippFactor.setEnabled(True)
                         self.specOpCebCrossSpectra.setCheckState(0)
                         self.specOpCebChannel.setCheckState(0)
                         self.specOpCebHeights.setCheckState(0)
                         self.specOpCebIncoherent.setCheckState(0)
                         self.specOpCebRemoveDC.setCheckState(0)
                         self.specOpCebRemoveInt.setCheckState(0)
                         self.specOpCebgetNoise.setCheckState(0)
                         self.specOpCebRadarfrequency.setCheckState(0)
                         self.specOpRadarfrequency.setEnabled(False)
                         self.specOppairsList.setEnabled(False)
                         self.specOpChannel.setEnabled(False)
                         self.specOpHeights.setEnabled(False)
                         self.specOpIncoherent.setEnabled(False)
                         self.specOpgetNoise.setEnabled(False)
                         self.specOpRadarfrequency.clear()
                         self.specOpnFFTpoints.clear()
                         self.specOpProfiles.clear()
                         self.specOpippFactor.clear
                         self.specOppairsList.clear()
                         self.specOpChannel.clear()
                         self.specOpHeights.clear()
                         self.specOpIncoherent.clear()
                         self.specOpgetNoise.clear()
                         self.specGraphCebSpectraplot.setCheckState(0)
                         self.specGraphCebCrossSpectraplot.setCheckState(0)
                         self.specGraphCebRTIplot.setCheckState(0)
                         self.specGraphCebRTInoise.setCheckState(0)
                         self.specGraphCebCoherencmap.setCheckState(0)
                         self.specGraphPowerprofile.setCheckState(0)
                         self.specGraphSaveSpectra.setCheckState(0)
                         self.specGraphSaveCross.setCheckState(0)
                         self.specGraphSaveRTIplot.setCheckState(0)
                         self.specGraphSaveRTInoise.setCheckState(0)
                         self.specGraphSaveCoherencemap.setCheckState(0)
                         self.specGraphSavePowerprofile.setCheckState(0)
                         self.specGraphftpRTIplot.setCheckState(0)
                         self.specGraphftpRTInoise.setCheckState(0)
                         self.specGraphftpCoherencemap.setCheckState(0)
                         self.specGraphPath.clear()
                         self.specGraphPrefix.clear()
                         self.specGgraphftpratio.clear()
                         self.specGgraphChannelList.clear()
                         self.specGgraphFreq.clear()
                         self.specGgraphHeight.clear()
                         self.specGgraphDbsrange.clear()
                         self.specGgraphmagnitud.clear()
                         self.specGgraphTminTmax.clear()
                         self.specGgraphTimeRange.clear()
                     if datatype == 'SpectraHeis':
                         self.specHeisOpCebIncoherent.setCheckState(0)
                         self.specHeisOpIncoherent.setEnabled(False)
                         self.specHeisOpIncoherent.clear()
                         self.specHeisGraphCebSpectraplot.setCheckState(0)
                         self.specHeisGraphCebRTIplot.setCheckState(0)
                         self.specHeisGraphSaveSpectra.setCheckState(0)
                         self.specHeisGraphSaveRTIplot.setCheckState(0)
                         self.specHeisGraphftpSpectra.setCheckState(0)
                         self.specHeisGraphftpRTIplot.setCheckState(0)
                         self.specHeisGraphPath.clear()
                         self.specHeisGraphPrefix.clear()
                         self.specHeisGgraphChannelList.clear()
                         self.specHeisGgraphXminXmax.clear()
                         self.specHeisGgraphYminYmax.clear()
                         self.specHeisGgraphTminTmax.clear()
                         self.specHeisGgraphTimeRange.clear()
                         self.specHeisGgraphftpratio.clear()
                 def showtabPUCreated(self, datatype):
                     if datatype == "Voltage":
                         self.tabVoltage.setEnabled(True)
                         self.tabProject.setEnabled(False)
                         self.tabSpectra.setEnabled(False)
                         self.tabCorrelation.setEnabled(False)
                         self.tabSpectraHeis.setEnabled(False)
                         self.tabWidgetProject.setCurrentWidget(self.tabVoltage)
                     if datatype == "Spectra":
                         self.tabVoltage.setEnabled(False)
                         self.tabProject.setEnabled(False)
                         self.tabSpectra.setEnabled(True)
                         self.tabCorrelation.setEnabled(False)
                         self.tabSpectraHeis.setEnabled(False)
                         self.tabWidgetProject.setCurrentWidget(self.tabSpectra)
                     if datatype == "SpectraHeis":
                         self.tabVoltage.setEnabled(False)
                         self.tabProject.setEnabled(False)
                         self.tabSpectra.setEnabled(False)
                         self.tabCorrelation.setEnabled(False)
                         self.tabSpectraHeis.setEnabled(True)
                         self.tabWidgetProject.setCurrentWidget(self.tabSpectraHeis)
                 def checkInputsProject(self):
                     """
                     Check Inputs Project:
                     - project_name
                     - datatype
                     - ext
                     - data_path
                     - readmode
                     - delay
                     - set
                     - walk
                     """
                     parms_ok = True
                     project_name = str(self.proName.text())
                     if project_name == '' or project_name == None:
                         outputstr = "Enter the Project Name"
                         self.console.append(outputstr)
                         parms_ok = False
                         project_name = None
                     datatype = str(self.proComDataType.currentText())
                     if not(datatype in ['Voltage', 'Spectra', 'Fits', 'USRP']):
                         outputstr = 'datatype = %s, this must be either Voltage, Spectra, SpectraHeis or USRP' % datatype
                         self.console.append(outputstr)
                         parms_ok = False
                         datatype = None
                     ext = str(self.proDataType.text())
                     if not(ext in ['.r', '.pdata', '.fits', '.hdf5']):
                         outputstr = "extension files must be .r , .pdata, .fits or .hdf5"
                         self.console.append(outputstr)
                         parms_ok = False
                         ext = None
                     data_path = str(self.proDataPath.text())
                     if data_path == '':
                         outputstr = 'Datapath is empty'
                         self.console.append(outputstr)
                         parms_ok = False
                         data_path = None
                     if data_path != None:
                         if not os.path.isdir(data_path):
                             outputstr = 'Datapath:%s does not exists' % data_path
                             self.console.append(outputstr)
                             parms_ok = False
                             data_path = None
                     read_mode = str(self.proComReadMode.currentText())
                     if not(read_mode in ['Online', 'Offline']):
                         outputstr = 'Read Mode: %s, this must be either Online or Offline' % read_mode
                         self.console.append(outputstr)
                         parms_ok = False
                         read_mode = None
                     try:
                         delay = int(str(self.proDelay.text()))
                     except:
                         outputstr = 'Delay: %s, this must be a integer number' % str(self.proDelay.text())
                         self.console.append(outputstr)
             #             parms_ok = False
                         delay = None
                     try:
                         set = int(str(self.proSet.text()))
                     except:
                         # outputstr = 'Set: %s, this must be a integer number' % str(self.proName.text())
                         # self.console.append(outputstr)
                         # parms_ok = False
                         set = None
                     walk_str = str(self.proComWalk.currentText())
                     if walk_str == 'On Files':
                         walk = 0
                     elif walk_str == 'On Folder':
                         walk = 1
                     else:
                         outputstr = 'Walk: %s, this must be either On Files or On Folders' % walk_str
                         self.console.append(outputstr)
                         parms_ok = False
                         walk = None
                     return parms_ok, project_name, datatype, ext, data_path, read_mode, delay, walk, set
                 def checkInputsPUSave(self, datatype):
                     """
                     Check Inputs Spectra Save:
                     - path
                     - blocks Per File
                     - sufix
                     - dataformat
                     """
                     parms_ok = True
                     if datatype == "Voltage":
                         output_path = str(self.volOutputPath.text())
                         blocksperfile = str(self.volOutputblocksperfile.text())
                         profilesperblock = str(self.volOutputprofilesperblock.text())
                     if datatype == "Spectra":
                         output_path = str(self.specOutputPath.text())
                         blocksperfile = str(self.specOutputblocksperfile.text())
                         profilesperblock = str(self.specOutputprofileperblock.text())
                     if datatype == "SpectraHeis":
                         output_path = str(self.specHeisOutputPath.text())
                         blocksperfile = str(self.specHeisOutputblocksperfile.text())
                         metada = str(self.specHeisOutputMetada.text())
                     if output_path == '':
                         outputstr = 'Outputpath is empty'
                         self.console.append(outputstr)
                         parms_ok = False
                         data_path = None
                     if output_path != None:
                         if not os.path.exists(output_path):
                             outputstr = 'OutputPath:%s does not exists' % output_path
                             self.console.append(outputstr)
                             parms_ok = False
                             output_path = None
                     try:
                         profilesperblock = int(profilesperblock)
                     except:
                         if datatype == "Voltage":
                             outputstr = 'Profilesperblock: %s, this must be a integer number' % str(self.volOutputprofilesperblock.text())
                             self.console.append(outputstr)
                             parms_ok = False
                             profilesperblock = None
                         elif datatype == "Spectra":
                             outputstr = 'Profilesperblock: %s, this must be a integer number' % str(self.specOutputprofileperblock.text())
                             self.console.append(outputstr)
                             parms_ok = False
                             profilesperblock = None
                     try:
                         blocksperfile = int(blocksperfile)
                     except:
                         if datatype == "Voltage":
                             outputstr = 'Blocksperfile: %s, this must be a integer number' % str(self.volOutputblocksperfile.text())
                         elif datatype == "Spectra":
                             outputstr = 'Blocksperfile: %s, this must be a integer number' % str(self.specOutputblocksperfile.text())
                         elif datatype == "SpectraHeis":
                             outputstr = 'Blocksperfile: %s, this must be a integer number' % str(self.specHeisOutputblocksperfile.text())
                         self.console.append(outputstr)
                         parms_ok = False
                         blocksperfile = None
                     if datatype == "SpectraHeis":
                         if metada == '':
                             outputstr = 'Choose metada file'
                             self.console.append(outputstr)
                             parms_ok = False
                         if metada != None:
                            if not  os.path.isfile(metada):
                                 outputstr = 'Metadata:%s does not exists' % metada
                                 self.console.append(outputstr)
                                 parms_ok = False
                                 output_path = None
                     if datatype == "Voltage":
                         return parms_ok, output_path, blocksperfile, profilesperblock
                     if datatype == "Spectra":
                         return parms_ok, output_path, blocksperfile, profilesperblock
                     if datatype == "SpectraHeis":
                         return parms_ok, output_path, blocksperfile, metada
                 def findDatafiles(self, data_path, ext, walk, expLabel=''):
                     dateList = []
                     fileList = []
                     if ext == ".r":
                         from schainpy.model.io.jroIO_base import JRODataReader
                         readerObj = JRODataReader()
                         dateList = readerObj.findDatafiles(path=data_path,
                                                            expLabel=expLabel,
                                                            ext=ext,
                                                            walk=walk)
                     if ext == ".pdata":
                         from schainpy.model.io.jroIO_base import JRODataReader
                         readerObj = JRODataReader()
                         dateList = readerObj.findDatafiles(path=data_path,
                                                            expLabel=expLabel,
                                                            ext=ext,
                                                            walk=walk)
                     if ext == ".fits":
                         from schainpy.model.io.jroIO_base import JRODataReader
                         readerObj = JRODataReader()
                         dateList = readerObj.findDatafiles(path=data_path,
                                                            expLabel=expLabel,
                                                            ext=ext,
                                                            walk=walk)
                     if ext == ".hdf5":
                         from schainpy.model.io.jroIO_usrp import USRPReader
                         readerObj = USRPReader()
                         dateList = readerObj.findDatafiles(path=data_path)
                     return dateList
                 def loadDays(self, data_path, ext, walk, expLabel=''):
                     """
                     Method to loads day
                     """
                     self.proOk.setEnabled(False)
+                    self.proComStartDate.clear()
+                    self.proComEndDate.clear()
                     self.dateList = []
+                    if not os.path.isdir(data_path):
+                        return
                     dateList = self.findDatafiles(data_path, ext=ext, walk=walk, expLabel=expLabel)
                     if not dateList:
             #             self.console.clear()
                         outputstr = "The path: %s is empty with file extension *%s" % (data_path, ext)
                         self.console.append(outputstr)
                         return
-                    self.proComStartDate.clear()
-                    self.proComEndDate.clear()
                     dateStrList = []
                     for thisDate in dateList:
                         dateStr = thisDate.strftime("%Y/%m/%d")
                         self.proComStartDate.addItem(dateStr)
                         self.proComEndDate.addItem(dateStr)
                         dateStrList.append(dateStr)
                     self.proComStartDate.setCurrentIndex(0)
                     self.proComEndDate.setCurrentIndex(self.proComEndDate.count() - 1)
                     self.dateList = dateStrList
                     self.proOk.setEnabled(True)
                     return self.dateList
                 def setWorkSpaceGUI(self, pathWorkSpace=None):
                     if pathWorkSpace == None:
                         home = os.path.expanduser("~")
                         pathWorkSpace = os.path.join(home,'schain_workspace')
                     self.pathWorkSpace = pathWorkSpace
                 """
                 Comandos Usados en Console
                 """
                 def __del__(self):
                     sys.stdout = sys.__stdout__
                     sys.stderr = sys.__stderr__
                 def normalOutputWritten(self, text):
                     color_black = QtGui.QColor(0,0,0)
                     self.console.setTextColor(color_black)
                     self.console.append(text)
                 def errorOutputWritten(self, text):
                     color_red = QtGui.QColor(255,0,0)
                     color_black = QtGui.QColor(0,0,0)
                     self.console.setTextColor(color_red)
                     self.console.append(text)
                     self.console.setTextColor(color_black)
                 def setParameter(self):
                     self.setWindowTitle("ROJ-Signal Chain")
                     self.setWindowIcon(QtGui.QIcon( os.path.join(FIGURES_PATH,"adn.jpg") ))
                     self.tabWidgetProject.setEnabled(False)
                     self.tabVoltage.setEnabled(False)
                     self.tabSpectra.setEnabled(False)
                     self.tabCorrelation.setEnabled(False)
                     self.frame_2.setEnabled(False)
                     self.actionCreate.setShortcut('Ctrl+N')
                     self.actionOpen.setShortcut('Ctrl+O')
                     self.actionSave.setShortcut('Ctrl+S')
                     self.actionClose.setShortcut('Ctrl+X')
                     self.actionStart.setShortcut('Ctrl+1')
                     self.actionPause.setShortcut('Ctrl+2')
                     self.actionStop.setShortcut('Ctrl+3')
                     self.actionFTP.setShortcut('Ctrl+F')
                     self.actionStart.setEnabled(False)
                     self.actionPause.setEnabled(False)
                     self.actionStop.setEnabled(False)
                     self.actionStarToolbar.setEnabled(False)
                     self.actionPauseToolbar.setEnabled(False)
                     self.actionStopToolbar.setEnabled(False)
                     self.proName.clear()
                     self.proDataPath.setText('')
                     self.console.setReadOnly(True)
                     self.console.append("Welcome to Signal Chain\nOpen a project or Create a new one")
                     self.proStartTime.setDisplayFormat("hh:mm:ss")
                     self.proDataType.setEnabled(False)
                     self.time = QtCore.QTime()
                     self.hour = 0
                     self.min = 0
                     self.sec = 0
                     self.proEndTime.setDisplayFormat("hh:mm:ss")
                     startTime = "00:00:00"
                     endTime = "23:59:59"
                     starlist = startTime.split(":")
                     endlist = endTime.split(":")
                     self.time.setHMS(int(starlist[0]), int(starlist[1]), int(starlist[2]))
                     self.proStartTime.setTime(self.time)
                     self.time.setHMS(int(endlist[0]), int(endlist[1]), int(endlist[2]))
                     self.proEndTime.setTime(self.time)
                     self.proOk.setEnabled(False)
                     # set model Project Explorer
                     self.projectExplorerModel = QtGui.QStandardItemModel()
                     self.projectExplorerModel.setHorizontalHeaderLabels(("Project Explorer",))
                     layout = QtGui.QVBoxLayout()
                     layout.addWidget(self.projectExplorerTree)
                     self.projectExplorerTree.setModel(self.projectExplorerModel)
                     self.projectExplorerTree.setContextMenuPolicy(QtCore.Qt.CustomContextMenu)
                     self.projectExplorerTree.customContextMenuRequested.connect(self.on_right_click)
                     self.projectExplorerTree.clicked.connect(self.on_click)
                     self.projectExplorerTree.expandAll()
                     # set model Project Properties
                     self.propertiesModel = TreeModel()
                     self.propertiesModel.initProjectView()
                     self.treeProjectProperties.setModel(self.propertiesModel)
                     self.treeProjectProperties.expandAll()
                     self.treeProjectProperties.allColumnsShowFocus()
                     self.treeProjectProperties.resizeColumnToContents(1)
                     # set Project
                     self.proDelay.setEnabled(False)
                     self.proSet.setEnabled(False)
                     self.proDataType.setReadOnly(True)
                      # set Operation Voltage
                     self.volOpComChannels.setEnabled(False)
                     self.volOpComHeights.setEnabled(False)
                     self.volOpFilter.setEnabled(False)
                     self.volOpComProfile.setEnabled(False)
                     self.volOpComCode.setEnabled(False)
                     self.volOpFlip.setEnabled(False)
                     self.volOpCohInt.setEnabled(False)
                     self.volOpRadarfrequency.setEnabled(False)
                     self.volOpChannel.setEnabled(False)
                     self.volOpHeights.setEnabled(False)
                     self.volOpProfile.setEnabled(False)
                     self.volOpComMode.setEnabled(False)
                     self.volGraphPath.setEnabled(False)
                     self.volGraphPrefix.setEnabled(False)
                     self.volGraphToolPath.setEnabled(False)
                     # set Graph Voltage
                     self.volGraphChannelList.setEnabled(False)
                     self.volGraphfreqrange.setEnabled(False)
                     self.volGraphHeightrange.setEnabled(False)
                     # set Operation Spectra
                     self.specOpnFFTpoints.setEnabled(False)
                     self.specOpProfiles.setEnabled(False)
                     self.specOpippFactor.setEnabled(False)
                     self.specOppairsList.setEnabled(False)
                     self.specOpComChannel.setEnabled(False)
                     self.specOpComHeights.setEnabled(False)
                     self.specOpIncoherent.setEnabled(False)
                     self.specOpgetNoise.setEnabled(False)
                     self.specOpRadarfrequency.setEnabled(False)
                     self.specOpChannel.setEnabled(False)
                     self.specOpHeights.setEnabled(False)
                     # set Graph Spectra
                     self.specGgraphChannelList.setEnabled(False)
                     self.specGgraphFreq.setEnabled(False)
                     self.specGgraphHeight.setEnabled(False)
                     self.specGgraphDbsrange.setEnabled(False)
                     self.specGgraphmagnitud.setEnabled(False)
                     self.specGgraphTminTmax.setEnabled(False)
                     self.specGgraphTimeRange.setEnabled(False)
                     self.specGraphPath.setEnabled(False)
                     self.specGraphToolPath.setEnabled(False)
                     self.specGraphPrefix.setEnabled(False)
                     self.specGgraphftpratio.setEnabled(False)
                     # set Operation SpectraHeis
                     self.specHeisOpIncoherent.setEnabled(False)
                     self.specHeisOpCobIncInt.setEnabled(False)
                     # set Graph SpectraHeis
                     self.specHeisGgraphChannelList.setEnabled(False)
                     self.specHeisGgraphXminXmax.setEnabled(False)
                     self.specHeisGgraphYminYmax.setEnabled(False)
                     self.specHeisGgraphTminTmax.setEnabled(False)
                     self.specHeisGgraphTimeRange.setEnabled(False)
                     self.specHeisGgraphftpratio.setEnabled(False)
                     self.specHeisGraphPath.setEnabled(False)
                     self.specHeisGraphPrefix.setEnabled(False)
                     self.specHeisGraphToolPath.setEnabled(False)
                     # tool tip gui
                     QtGui.QToolTip.setFont(QtGui.QFont('SansSerif', 10))
                     self.projectExplorerTree.setToolTip('Right clik to add Project or Unit Process')
                     # tool tip gui project
                     self.proComWalk.setToolTip('<b>On Files</b>:<i>Search file in format .r or pdata</i> <b>On Folders</b>:<i>Search file in a directory DYYYYDOY</i>')
                     self.proComWalk.setCurrentIndex(0)
                     # tool tip gui volOp
                     self.volOpChannel.setToolTip('Example: 1,2,3,4,5')
                     self.volOpHeights.setToolTip('Example: 90,180')
                     self.volOpFilter.setToolTip('Example: 2')
                     self.volOpProfile.setToolTip('Example:0,127')
                     self.volOpCohInt.setToolTip('Example: 128')
                     self.volOpFlip.setToolTip('ChannelList where flip will be applied. Example: 0,2,3')
                     self.volOpOk.setToolTip('If you have finished, please Ok ')
                     # tool tip gui volGraph
                     self.volGraphfreqrange.setToolTip('Height range. Example: 50,100')
                     self.volGraphHeightrange.setToolTip('Amplitude. Example: 0,10000')
                     # tool tip gui specOp
                     self.specOpnFFTpoints.setToolTip('Example: 128')
                     self.specOpProfiles.setToolTip('Example: 128')
                     self.specOpippFactor.setToolTip('Example:1.0')
                     self.specOpIncoherent.setToolTip('Example: 10')
                     self.specOpgetNoise.setToolTip('Example:20,180,30,120 (minHei,maxHei,minVel,maxVel)')
                     self.specOpChannel.setToolTip('Example: 0,1,2,3')
                     self.specOpHeights.setToolTip('Example: 90,180')
                     self.specOppairsList.setToolTip('Example: (0,1),(2,3)')
                     # tool tip gui specGraph
                     self.specGgraphChannelList.setToolTip('Example: 0,3,4')
                     self.specGgraphFreq.setToolTip('Example: -20,20')
                     self.specGgraphHeight.setToolTip('Example: 100,400')
                     self.specGgraphDbsrange.setToolTip('Example: 30,170')
                     self.specGraphPrefix.setToolTip('Example: EXPERIMENT_NAME')
                     sys.stdout = ShowMeConsole(textWritten=self.normalOutputWritten)
                     sys.stderr = ShowMeConsole(textWritten=self.errorOutputWritten)
             class UnitProcessWindow(QMainWindow, Ui_UnitProcess):
                 """
                 Class documentation goes here.
                 """
                 closed = pyqtSignal()
                 create = False
                 def __init__(self, parent=None):
                     """
                     Constructor
                     """
                     QMainWindow.__init__(self, parent)
                     self.setupUi(self)
                     self.getFromWindow = None
                     self.getfromWindowList = []
                     self.dataTypeProject = None
                     self.listUP = None
                 @pyqtSignature("")
                 def on_unitPokbut_clicked(self):
                     """
                     Slot documentation goes here.
                     """
                     self.create = True
                     self.getFromWindow = self.getfromWindowList[int(self.comboInputBox.currentIndex())]
                     # self.nameofUP= str(self.nameUptxt.text())
                     self.typeofUP = str(self.comboTypeBox.currentText())
                     self.close()
                 @pyqtSignature("")
                 def on_unitPcancelbut_clicked(self):
                     """
                     Slot documentation goes here.
                     """
                     self.create = False
                     self.close()
                 def loadTotalList(self):
                     self.comboInputBox.clear()
                     for i in self.getfromWindowList:
                         name = i.getElementName()
                         if name == 'Project':
                             id = i.id
                             name = i.name
                             if self.dataTypeProject == 'Voltage':
                                 self.comboTypeBox.clear()
                                 self.comboTypeBox.addItem("Voltage")
                             if self.dataTypeProject == 'Spectra':
                                 self.comboTypeBox.clear()
                                 self.comboTypeBox.addItem("Spectra")
                                 self.comboTypeBox.addItem("Correlation")
                             if self.dataTypeProject == 'Fits':
                                 self.comboTypeBox.clear()
                                 self.comboTypeBox.addItem("SpectraHeis")
                         if name == 'ProcUnit':
                            id = int(i.id) - 1
                            name = i.datatype
                            if name == 'Voltage':
                               self.comboTypeBox.clear()
                               self.comboTypeBox.addItem("Spectra")
                               self.comboTypeBox.addItem("SpectraHeis")
                               self.comboTypeBox.addItem("Correlation")
                            if name == 'Spectra':
                               self.comboTypeBox.clear()
                               self.comboTypeBox.addItem("Spectra")
                               self.comboTypeBox.addItem("SpectraHeis")
                               self.comboTypeBox.addItem("Correlation")
                            if name == 'SpectraHeis':
                               self.comboTypeBox.clear()
                               self.comboTypeBox.addItem("SpectraHeis")
                         self.comboInputBox.addItem(str(name))
                        # self.comboInputBox.addItem(str(name)+str(id))
                 def closeEvent(self, event):
                     self.closed.emit()
                     event.accept()
             class Ftp(QMainWindow, Ui_Ftp):
                 """
                 Class documentation goes here.
                 """
                 create = False
                 closed = pyqtSignal()
                 server = None
                 remotefolder = None
                 username = None
                 password = None
                 ftp_wei = None
                 exp_code = None
                 sub_exp_code = None
                 plot_pos = None
                 def __init__(self, parent=None):
                     """
                     Constructor
                     """
                     QMainWindow.__init__(self, parent)
                     self.setupUi(self)
                     self.setParameter()
                 def setParameter(self):
                     self.setWindowTitle("ROJ-Signal Chain")
                     self.serverFTP.setToolTip('Example: jro-app.igp.gob.pe')
                     self.folderFTP.setToolTip('Example: /home/wmaster/graficos')
                     self.usernameFTP.setToolTip('Example: myusername')
                     self.passwordFTP.setToolTip('Example: mypass ')
                     self.weightFTP.setToolTip('Example: 0')
                     self.expcodeFTP.setToolTip('Example: 0')
                     self.subexpFTP.setToolTip('Example: 0')
                     self.plotposFTP.setToolTip('Example: 0')
                 def setParmsfromTemporal(self, server, remotefolder, username, password, ftp_wei, exp_code, sub_exp_code, plot_pos):
                     self.serverFTP.setText(str(server))
                     self.folderFTP.setText(str(remotefolder))
                     self.usernameFTP.setText(str(username))
                     self.passwordFTP.setText(str(password))
                     self.weightFTP.setText(str(ftp_wei))
                     self.expcodeFTP.setText(str(exp_code))
                     self.subexpFTP.setText(str(sub_exp_code))
                     self.plotposFTP.setText(str(plot_pos))
                 def getParmsFromFtpWindow(self):
                     """
                     Return Inputs Project:
                     - server
                     - remotefolder
                     - username
                     - password
                     - ftp_wei
                     - exp_code
                     - sub_exp_code
                     - plot_pos
                     """
                     name_server_ftp = str(self.serverFTP.text())
                     if not name_server_ftp:
                         self.console.clear()
                         self.console.append("Please Write  a FTP Server")
                         return 0
                     folder_server_ftp = str(self.folderFTP.text())
                     if not folder_server_ftp:
                         self.console.clear()
                         self.console.append("Please Write  a Folder")
                         return 0
                     username_ftp = str(self.usernameFTP.text())
                     if not username_ftp:
                         self.console.clear()
                         self.console.append("Please Write  a User Name")
                         return 0
                     password_ftp = str(self.passwordFTP.text())
                     if not password_ftp:
                         self.console.clear()
                         self.console.append("Please Write  a passwordFTP")
                         return 0
-                    ftp_wei = self.weightFTP.text()
+                    ftp_wei = str(self.weightFTP.text())
                     if not ftp_wei == "":
                         try:
                            ftp_wei = int(self.weightFTP.text())
                         except:
                             self.console.clear()
                             self.console.append("Please Write  a ftp_wei number")
                             return 0
-                    exp_code = self.expcodeFTP.text()
+                    exp_code = str(self.expcodeFTP.text())
                     if not exp_code == "":
                         try:
                            exp_code = int(self.expcodeFTP.text())
                         except:
                             self.console.clear()
                             self.console.append("Please Write  a  exp_code number")
                             return 0
-                    sub_exp_code = self.subexpFTP.text()
+                    sub_exp_code = str(self.subexpFTP.text())
                     if not sub_exp_code == "":
                         try:
                            sub_exp_code = int(self.subexpFTP.text())
                         except:
                             self.console.clear()
                             self.console.append("Please Write  a  sub_exp_code number")
                             return 0
-                    plot_pos = self.plotposFTP.text()
+                    plot_pos = str(self.plotposFTP.text())
                     if not plot_pos == "":
                         try:
                            plot_pos = int(self.plotposFTP.text())
                         except:
                             self.console.clear()
                             self.console.append("Please Write  a  plot_pos number")
                             return 0
                     return  name_server_ftp, folder_server_ftp, username_ftp, password_ftp, ftp_wei, exp_code, sub_exp_code, plot_pos
                 @pyqtSignature("")
                 def on_ftpOkButton_clicked(self):
                     server, remotefolder, username, password, ftp_wei, exp_code, sub_exp_code, plot_pos = self.getParmsFromFtpWindow()
                     self.create = True
                     self.close()
                 @pyqtSignature("")
                 def on_ftpCancelButton_clicked(self):
                     self.create = False
                     self.close()
                 def closeEvent(self, event):
                     self.closed.emit()
                     event.accept()
             class ftpBuffer():
                 server = None
                 remotefolder = None
                 username = None
                 password = None
                 ftp_wei = None
                 exp_code = None
                 sub_exp_code = None
                 plot_pos = None
                 create = False
                 withoutconfig = False
                 createforView = False
                 localfolder = None
                 extension = None
                 period = None
                 protocol = None
                 def __init__(self):
                     self.create = False
                     self.server = None
                     self.remotefolder = None
                     self.username = None
                     self.password = None
                     self.ftp_wei = None
                     self.exp_code = None
                     self.sub_exp_code = None
                     self.plot_pos = None
                     # self.create = False
                     self.localfolder = None
                     self.extension = None
                     self.period = None
                     self.protocol = None
                 def setwithoutconfiguration(self):
                     self.create = False
                     self.server = "jro-app.igp.gob.pe"
                     self.remotefolder = "/home/wmaster/graficos"
                     self.username = "wmaster"
                     self.password = "mst2010vhf"
                     self.withoutconfig = True
                     self.localfolder = './'
                     self.extension = '.png'
-                    self.period = '60'
+                    self.period = 60
                     self.protocol = 'ftp'
                     self.createforView = True
                     if not self.ftp_wei:
-                        self.ftp_wei = "0"
+                        self.ftp_wei = 0
                     if not self.exp_code:
-                        self.exp_code = "0"
+                        self.exp_code = 0
                     if not self.sub_exp_code:
-                        self.sub_exp_code = "0"
+                        self.sub_exp_code = 0
                     if not self.plot_pos:
-                        self.plot_pos = "0"
+                        self.plot_pos = 0
-                def save(self, server, remotefolder, username, password, ftp_wei, exp_code, sub_exp_code, plot_pos, localfolder='./', extension='.png', period='60', protocol='ftp'):
+                def save(self, server, remotefolder, username, password, ftp_wei=0, exp_code=0, sub_exp_code=0, plot_pos=0, localfolder='./', extension='.png', period=60, protocol='ftp'):
                     self.server = server
                     self.remotefolder = remotefolder
                     self.username = username
                     self.password = password
                     self.ftp_wei = ftp_wei
                     self.exp_code = exp_code
                     self.sub_exp_code = sub_exp_code
                     self.plot_pos = plot_pos
                     self.create = True
                     self.withoutconfig = False
                     self.createforView = True
                     self.localfolder = localfolder
                     self.extension = extension
                     self.period = period
                     self.protocol = protocol
                 def recover(self):
                     return self.server, self.remotefolder, self.username, self.password, self.ftp_wei, self.exp_code, self.sub_exp_code, self.plot_pos, self.extension, self.period, self.protocol
             class ShowMeConsole(QtCore.QObject):
                     textWritten = QtCore.pyqtSignal(str)
                     def write (self, text):
                         self.textWritten.emit(str(text))
             class PlotManager():
                 def __init__(self, queue):
                     self.queue = queue
                     self.objPlotDict = {}
                 def processIncoming(self):
                     while self.queue.qsize():
                         try:
                             dataFromQueue = self.queue.get(True)
                             if dataFromQueue == None:
                                 continue
                             dataPlot = dataFromQueue['data']
                             kwargs = dataFromQueue['kwargs']
                             id = kwargs['id']
                             if 'channelList' in kwargs.keys():
                                 channelList = kwargs['channelList']
                             else:
                                 channelList = None
                             plotname = kwargs.pop('type')
                             if not(id in self.objPlotDict.keys()):
                                 className = eval(plotname)
                                 self.objPlotDict[id] = className(id, channelList, dataPlot)
                                 self.objPlotDict[id].show()
                             self.objPlotDict[id].run(dataPlot , **kwargs)
                         except Queue.Empty:
                             pass

schainpy/model/io/jroIO_base.py +14 0

             '''
             Created on Jul 2, 2014
             @author: roj-idl71
             '''
             import os
             import sys
             import glob
             import time
             import numpy
             import fnmatch
             import time, datetime
             #import h5py
             import traceback
             try:
                 from gevent import sleep
             except:
                 from time import sleep
             from schainpy.model.data.jroheaderIO import PROCFLAG, BasicHeader, SystemHeader, RadarControllerHeader, ProcessingHeader
             LOCALTIME = True
             def isNumber(cad):
                 """
                 Chequea si el conjunto de caracteres que componen un string puede ser convertidos a un numero.
                 Excepciones:
                     Si un determinado string no puede ser convertido a numero
                 Input:
                     str, string al cual se le analiza para determinar si convertible a un numero o no
                 Return:
                     True    :    si el string es uno numerico
                     False   :    no es un string numerico
                 """
                 try:
                     float( cad )
                     return True
                 except:
                     return False
             def isThisFileinRange(filename, startUTSeconds, endUTSeconds):
                 """
                 Esta funcion determina si un archivo de datos se encuentra o no dentro del rango de fecha especificado.
                 Inputs:
                     filename            :    nombre completo del archivo de datos en formato Jicamarca (.r)
                     startUTSeconds      :    fecha inicial del rango seleccionado. La fecha esta dada en
                                              segundos contados desde 01/01/1970.
                     endUTSeconds        :    fecha final del rango seleccionado. La fecha esta dada en
                                              segundos contados desde 01/01/1970.
                 Return:
                     Boolean    :    Retorna True si el archivo de datos contiene datos en el rango de
                                     fecha especificado, de lo contrario retorna False.
                 Excepciones:
                     Si el archivo no existe o no puede ser abierto
                     Si la cabecera no puede ser leida.
                 """
                 basicHeaderObj = BasicHeader(LOCALTIME)
                 try:
                     fp = open(filename,'rb')
                 except IOError:
                     traceback.print_exc()
                     raise IOError, "The file %s can't be opened" %(filename)
                 sts = basicHeaderObj.read(fp)
                 fp.close()
                 if not(sts):
                     print "Skipping the file %s because it has not a valid header" %(filename)
                     return 0
                 if not ((startUTSeconds <= basicHeaderObj.utc) and (endUTSeconds > basicHeaderObj.utc)):
                     return 0
                 return 1
             def isFileinThisTime(filename, startTime, endTime):
                 """
                 Retorna 1 si el archivo de datos se encuentra dentro del rango de horas especificado.
                 Inputs:
                     filename            :    nombre completo del archivo de datos en formato Jicamarca (.r)
                     startTime          :    tiempo inicial del rango seleccionado en formato datetime.time
                     endTime            :    tiempo final del rango seleccionado en formato datetime.time
                 Return:
                     Boolean    :    Retorna True si el archivo de datos contiene datos en el rango de
                                     fecha especificado, de lo contrario retorna False.
                 Excepciones:
                     Si el archivo no existe o no puede ser abierto
                     Si la cabecera no puede ser leida.
                 """
                 try:
                     fp = open(filename,'rb')
                 except IOError:
                     traceback.print_exc()
                     raise IOError, "The file %s can't be opened" %(filename)
                 basicHeaderObj = BasicHeader(LOCALTIME)
                 sts = basicHeaderObj.read(fp)
                 fp.close()
                 thisDatetime = basicHeaderObj.datatime
                 thisTime = thisDatetime.time()
                 if not(sts):
                     print "Skipping the file %s because it has not a valid header" %(filename)
                     return None
                 if not ((startTime <= thisTime) and (endTime > thisTime)):
                     return None
                 return thisDatetime
             def getFileFromSet(path, ext, set):
                 validFilelist = []
                 fileList = os.listdir(path)
                 # 0 1234 567 89A BCDE
                 # H YYYY DDD SSS .ext
                 for thisFile in fileList:
                     try:
                         year = int(thisFile[1:5])
                         doy  = int(thisFile[5:8])
                     except:
                         continue
                     if (os.path.splitext(thisFile)[-1].lower() != ext.lower()):
                         continue
                     validFilelist.append(thisFile)
                 myfile = fnmatch.filter(validFilelist,'*%4.4d%3.3d%3.3d*'%(year,doy,set))
                 if len(myfile)!= 0:
                     return myfile[0]
                 else:
                     filename = '*%4.4d%3.3d%3.3d%s'%(year,doy,set,ext.lower())
                     print 'the filename %s does not exist'%filename
                     print '...going to the last file: '
                 if validFilelist:
                     validFilelist = sorted( validFilelist, key=str.lower )
                     return validFilelist[-1]
                 return None
             def getlastFileFromPath(path, ext):
                 """
                 Depura el fileList dejando solo los que cumplan el formato de "PYYYYDDDSSS.ext"
                 al final de la depuracion devuelve el ultimo file de la lista que quedo.
                 Input:
                     fileList    :    lista conteniendo todos los files (sin path) que componen una determinada carpeta
                     ext         :    extension de los files contenidos en una carpeta
                 Return:
                     El ultimo file de una determinada carpeta, no se considera el path.
                 """
                 validFilelist = []
                 fileList = os.listdir(path)
                 # 0 1234 567 89A BCDE
                 # H YYYY DDD SSS .ext
                 for thisFile in fileList:
                     year = thisFile[1:5]
                     if not isNumber(year):
                         continue
                     doy = thisFile[5:8]
                     if not isNumber(doy):
                         continue
                     year = int(year)
                     doy = int(doy)
                     if (os.path.splitext(thisFile)[-1].lower() != ext.lower()):
                         continue
                     validFilelist.append(thisFile)
                 if validFilelist:
                     validFilelist = sorted( validFilelist, key=str.lower )
                     return validFilelist[-1]
                 return None
             def checkForRealPath(path, foldercounter, year, doy, set, ext):
                 """
                 Por ser Linux Case Sensitive entonces checkForRealPath encuentra el nombre correcto de un path,
                 Prueba por varias combinaciones de nombres entre mayusculas y minusculas para determinar
                 el path exacto de un determinado file.
                 Example    :
                     nombre correcto del file es  .../.../D2009307/P2009307367.ext
                     Entonces la funcion prueba con las siguientes combinaciones
                         .../.../y2009307367.ext
                         .../.../Y2009307367.ext
                         .../.../x2009307/y2009307367.ext
                         .../.../x2009307/Y2009307367.ext
                         .../.../X2009307/y2009307367.ext
                         .../.../X2009307/Y2009307367.ext
                     siendo para este caso, la ultima combinacion de letras, identica al file buscado
                 Return:
                     Si encuentra la cobinacion adecuada devuelve el path completo y el nombre del file
                     caso contrario devuelve None como path y el la ultima combinacion de nombre en mayusculas
                     para el filename
                 """
                 fullfilename = None
                 find_flag = False
                 filename = None
                 prefixDirList = [None,'d','D']
                 if ext.lower() == ".r": #voltage
                     prefixFileList = ['d','D']
                 elif ext.lower() == ".pdata": #spectra
                     prefixFileList = ['p','P']
                 else:
                     return None, filename
                 #barrido por las combinaciones posibles
                 for prefixDir in prefixDirList:
                     thispath = path
                     if prefixDir != None:
                         #formo el nombre del directorio xYYYYDDD (x=d o x=D)
                         if foldercounter == 0:
                             thispath = os.path.join(path, "%s%04d%03d" % ( prefixDir, year, doy ))
                         else:
                             thispath = os.path.join(path, "%s%04d%03d_%02d" % ( prefixDir, year, doy , foldercounter))
                     for prefixFile in prefixFileList: #barrido por las dos combinaciones posibles de "D"
                         filename = "%s%04d%03d%03d%s" % ( prefixFile, year, doy, set, ext ) #formo el nombre del file xYYYYDDDSSS.ext
                         fullfilename = os.path.join( thispath, filename ) #formo el path completo
                         if os.path.exists( fullfilename ): #verifico que exista
                             find_flag = True
                             break
                     if find_flag:
                         break
                 if not(find_flag):
                     return None, filename
                 return fullfilename, filename
             def isRadarFolder(folder):
                 try:
                     year = int(folder[1:5])
                     doy = int(folder[5:8])
                 except:
                     return 0
                 return 1
             def isRadarFile(file):
                     try:
                         year = int(file[1:5])
                         doy = int(file[5:8])
                         set = int(file[8:11])
                     except:
                         return 0
                     return 1
             def getDateFromRadarFile(file):
                     try:
                         year = int(file[1:5])
                         doy = int(file[5:8])
                         set = int(file[8:11])
                     except:
                         return None
                     thisDate = datetime.date(year, 1, 1) + datetime.timedelta(doy-1)
                     return thisDate
             class JRODataIO:
                 c = 3E8
                 isConfig = False
                 basicHeaderObj = None
                 systemHeaderObj = None
                 radarControllerHeaderObj = None
                 processingHeaderObj = None
                 online = 0
                 dtype = None
                 pathList = []
                 filenameList = []
                 filename = None
                 ext = None
                 flagIsNewFile = 1
                 flagDiscontinuousBlock = 0
                 flagIsNewBlock = 0
                 fp = None
                 firstHeaderSize = 0
                 basicHeaderSize = 24
                 versionFile = 1103
                 fileSize = None
             #     ippSeconds = None
                 fileSizeByHeader = None
                 fileIndex = None
                 profileIndex = None
                 blockIndex = None
                 nTotalBlocks = None
                 maxTimeStep = 30
                 lastUTTime = None
                 datablock = None
                 dataOut = None
                 blocksize = None
                 getByBlock = False
                 def __init__(self):
                     raise ValueError, "Not implemented"
                 def run(self):
                     raise ValueError, "Not implemented"
             class JRODataReader(JRODataIO):
                 nReadBlocks = 0
                 delay  = 10   #number of seconds waiting a new file
                 nTries  = 3  #quantity tries
                 nFiles = 3   #number of files for searching
                 path = None
                 foldercounter = 0
                 flagNoMoreFiles = 0
                 datetimeList = []
                 __isFirstTimeOnline = 1
                 __printInfo = True
                 profileIndex = None
                 nTxs = 1
                 txIndex = None
                 def __init__(self):
                     """
                     """
             #         raise NotImplementedError, "This method has not been implemented"
                 def createObjByDefault(self):
                     """
                     """
                     raise NotImplementedError, "This method has not been implemented"
                 def getBlockDimension(self):
                     raise NotImplementedError, "No implemented"
                 def __searchFilesOffLine(self,
                                         path,
                                         startDate=None,
                                         endDate=None,
                                         startTime=datetime.time(0,0,0),
                                         endTime=datetime.time(23,59,59),
                                         set=None,
                                         expLabel='',
                                         ext='.r',
                                         walk=True):
                     self.filenameList = []
                     self.datetimeList = []
                     pathList = []
                     if not walk:
                         #pathList.append(path)
                         multi_path = path.split(',')
                         for single_path in multi_path:
+                            if not os.path.isdir(single_path):
+                                continue
                             pathList.append(single_path)
                     else:
                         #dirList = []
                         multi_path = path.split(',')
                         for single_path in multi_path:
+                            if not os.path.isdir(single_path):
+                                continue
                             dirList = []
                             for thisPath in os.listdir(single_path):
                                 if not os.path.isdir(os.path.join(single_path,thisPath)):
                                     continue
                                 if not isRadarFolder(thisPath):
                                     continue
                                 dirList.append(thisPath)
                             if not(dirList):
                                 return None, None
                             if startDate and endDate:
                                 thisDate = startDate
                                 while(thisDate <= endDate):
                                     year = thisDate.timetuple().tm_year
                                     doy = thisDate.timetuple().tm_yday
                                     matchlist = fnmatch.filter(dirList, '?' + '%4.4d%3.3d' % (year,doy) + '*')
                                     if len(matchlist) == 0:
                                         thisDate += datetime.timedelta(1)
                                         continue
                                     for match in matchlist:
                                         pathList.append(os.path.join(single_path,match,expLabel))
                                     thisDate += datetime.timedelta(1)
                             else:
                                 for thiDir in dirList:
                                     pathList.append(os.path.join(single_path,thiDir,expLabel))
                     if pathList == []:
                         print "Any folder was found for the date range: %s-%s" %(startDate, endDate)
                         return None, None
                     print "%d folder(s) was(were) found for the date range: %s - %s" %(len(pathList), startDate, endDate)
                     filenameList = []
                     datetimeList = []
                     pathDict = {}
                     filenameList_to_sort = []
                     for i in range(len(pathList)):
                         thisPath = pathList[i]
                         fileList = glob.glob1(thisPath, "*%s" %ext)
                         if len(fileList) < 1:
                             continue
                         fileList.sort()
                         pathDict.setdefault(fileList[0])
                         pathDict[fileList[0]] = i
                         filenameList_to_sort.append(fileList[0])
                     filenameList_to_sort.sort()
                     for file in filenameList_to_sort:
                         thisPath = pathList[pathDict[file]]
                         fileList = glob.glob1(thisPath, "*%s" %ext)
                         fileList.sort()
                         for file in fileList:
                             filename = os.path.join(thisPath,file)
                             thisDatetime = isFileinThisTime(filename, startTime, endTime)
                             if not(thisDatetime):
                                 continue
                             filenameList.append(filename)
                             datetimeList.append(thisDatetime)
                     if not(filenameList):
                         print "Any file was found for the time range %s - %s" %(startTime, endTime)
                         return None, None
                     print "%d file(s) was(were) found for the time range: %s - %s" %(len(filenameList), startTime, endTime)
                     print
                     for i in range(len(filenameList)):
                         print "%s -> [%s]" %(filenameList[i], datetimeList[i].ctime())
                     self.filenameList = filenameList
                     self.datetimeList = datetimeList
                     return pathList, filenameList
                 def __searchFilesOnLine(self, path, expLabel = "", ext = None, walk=True, set=None):
                     """
                     Busca el ultimo archivo de la ultima carpeta (determinada o no por startDateTime) y
                     devuelve el archivo encontrado ademas de otros datos.
                     Input:
                         path           :    carpeta donde estan contenidos los files que contiene data
                         expLabel        :     Nombre del subexperimento (subfolder)
                         ext              :    extension de los files
                         walk        :    Si es habilitado no realiza busquedas dentro de los ubdirectorios (doypath)
                     Return:
                         directory   :    eL directorio donde esta el file encontrado
                         filename    :    el ultimo file de una determinada carpeta
                         year        :    el anho
                         doy         :    el numero de dia del anho
                         set         :    el set del archivo
                     """
                     dirList = []
                     if not walk:
                         fullpath = path
                         foldercounter = 0
                     else:
                         #Filtra solo los directorios
                         for thisPath in os.listdir(path):
                             if not os.path.isdir(os.path.join(path,thisPath)):
                                 continue
                             if not isRadarFolder(thisPath):
                                 continue
                             dirList.append(thisPath)
                         if not(dirList):
                             return None, None, None, None, None, None
                         dirList = sorted( dirList, key=str.lower )
                         doypath = dirList[-1]
                         foldercounter = int(doypath.split('_')[1]) if len(doypath.split('_'))>1 else 0
                         fullpath = os.path.join(path, doypath, expLabel)
                     print "%s folder was found: " %(fullpath )
                     if set == None:
                         filename = getlastFileFromPath(fullpath, ext)
                     else:
                         filename = getFileFromSet(fullpath, ext, set)
                     if not(filename):
                         return None, None, None, None, None, None
                     print "%s file was found" %(filename)
                     if not(self.__verifyFile(os.path.join(fullpath, filename))):
                         return None, None, None, None, None, None
                     year = int( filename[1:5] )
                     doy  = int( filename[5:8] )
                     set  = int( filename[8:11] )
                     return fullpath, foldercounter, filename, year, doy, set
                 def __setNextFileOffline(self):
                     idFile = self.fileIndex
                     while (True):
                         idFile += 1
                         if not(idFile < len(self.filenameList)):
                             self.flagNoMoreFiles = 1
             #                 print "[Reading] No more Files"
                             return 0
                         filename = self.filenameList[idFile]
                         if not(self.__verifyFile(filename)):
                             continue
                         fileSize = os.path.getsize(filename)
                         fp = open(filename,'rb')
                         break
                     self.flagIsNewFile = 1
                     self.fileIndex = idFile
                     self.filename = filename
                     self.fileSize = fileSize
                     self.fp = fp
             #         print "[Reading] Setting the file: %s"%self.filename
                     return 1
                 def __setNextFileOnline(self):
                     """
                     Busca el siguiente file que tenga suficiente data para ser leida, dentro de un folder especifico, si
                     no encuentra un file valido espera un tiempo determinado y luego busca en los posibles n files
                     siguientes.
                     Affected:
                         self.flagIsNewFile
                         self.filename
                         self.fileSize
                         self.fp
                         self.set
                         self.flagNoMoreFiles
                     Return:
 : si luego de una busqueda del siguiente file valido este no pudo ser encontrado
 : si el file fue abierto con exito y esta listo a ser leido
                     Excepciones:
                         Si un determinado file no puede ser abierto
                     """
                     nFiles = 0
                     fileOk_flag = False
                     firstTime_flag = True
                     self.set += 1
                     if self.set > 999:
                         self.set = 0
                         self.foldercounter += 1
                     #busca el 1er file disponible
                     fullfilename, filename = checkForRealPath( self.path, self.foldercounter, self.year, self.doy, self.set, self.ext )
                     if fullfilename:
                         if self.__verifyFile(fullfilename, False):
                             fileOk_flag = True
                     #si no encuentra un file entonces espera y vuelve a buscar
                     if not(fileOk_flag):
                         for nFiles in range(self.nFiles+1): #busco en los siguientes self.nFiles+1 files posibles
                             if firstTime_flag: #si es la 1era vez entonces hace el for self.nTries veces
                                 tries = self.nTries
                             else:
                                 tries = 1 #si no es la 1era vez entonces solo lo hace una vez
                             for nTries in range( tries ):
                                 if firstTime_flag:
                                     print "\t[Reading] Waiting %0.2f sec for the file \"%s\" , try %03d ..." % ( self.delay, filename, nTries+1 )
                                     sleep( self.delay )
                                 else:
                                     print "\t[Reading] Searching the next \"%s%04d%03d%03d%s\" file ..." % (self.optchar, self.year, self.doy, self.set, self.ext)
                                 fullfilename, filename = checkForRealPath( self.path, self.foldercounter, self.year, self.doy, self.set, self.ext )
                                 if fullfilename:
                                     if self.__verifyFile(fullfilename):
                                         fileOk_flag = True
                                         break
                             if fileOk_flag:
                                 break
                             firstTime_flag = False
                             print "\t[Reading] Skipping the file \"%s\" due to this file doesn't exist" % filename
                             self.set += 1
                             if nFiles == (self.nFiles-1): #si no encuentro el file buscado cambio de carpeta y busco en la siguiente carpeta
                                 self.set = 0
                                 self.doy += 1
                                 self.foldercounter = 0
                     if fileOk_flag:
                         self.fileSize = os.path.getsize( fullfilename )
                         self.filename = fullfilename
                         self.flagIsNewFile = 1
                         if self.fp != None: self.fp.close()
                         self.fp = open(fullfilename, 'rb')
                         self.flagNoMoreFiles = 0
             #             print '[Reading] Setting the file: %s' % fullfilename
                     else:
                         self.fileSize = 0
                         self.filename = None
                         self.flagIsNewFile = 0
                         self.fp = None
                         self.flagNoMoreFiles = 1
             #             print '[Reading] No more files to read'
                     return fileOk_flag
                 def setNextFile(self):
                     if self.fp != None:
                         self.fp.close()
                     if self.online:
                         newFile = self.__setNextFileOnline()
                     else:
                         newFile = self.__setNextFileOffline()
                     if not(newFile):
                         print '[Reading] No more files to read'
                         return 0
                     print '[Reading] Setting the file: %s' % self.filename
                     self.__readFirstHeader()
                     self.nReadBlocks = 0
                     return 1
                 def __waitNewBlock(self):
                     """
                     Return 1 si se encontro un nuevo bloque de datos, 0 de otra forma.
                     Si el modo de lectura es OffLine siempre retorn 0
                     """
                     if not self.online:
                         return 0
                     if (self.nReadBlocks >= self.processingHeaderObj.dataBlocksPerFile):
                         return 0
                     currentPointer = self.fp.tell()
                     neededSize = self.processingHeaderObj.blockSize + self.basicHeaderSize
                     for nTries in range( self.nTries ):
                         self.fp.close()
                         self.fp = open( self.filename, 'rb' )
                         self.fp.seek( currentPointer )
                         self.fileSize = os.path.getsize( self.filename )
                         currentSize = self.fileSize - currentPointer
                         if ( currentSize >= neededSize ):
                             self.basicHeaderObj.read(self.fp)
                             return 1
                         if self.fileSize == self.fileSizeByHeader:
             #                self.flagEoF = True
                             return 0
                         print "[Reading] Waiting %0.2f seconds for the next block, try %03d ..." % (self.delay, nTries+1)
                         sleep( self.delay )
                     return 0
                 def waitDataBlock(self,pointer_location):
                     currentPointer = pointer_location
                     neededSize = self.processingHeaderObj.blockSize #+ self.basicHeaderSize
                     for nTries in range( self.nTries ):
                         self.fp.close()
                         self.fp = open( self.filename, 'rb' )
                         self.fp.seek( currentPointer )
                         self.fileSize = os.path.getsize( self.filename )
                         currentSize = self.fileSize - currentPointer
                         if ( currentSize >= neededSize ):
                             return 1
                         print "[Reading] Waiting %0.2f seconds for the next block, try %03d ..." % (self.delay, nTries+1)
                         sleep( self.delay )
                     return 0
                 def __jumpToLastBlock(self):
                     if not(self.__isFirstTimeOnline):
                         return
                     csize = self.fileSize - self.fp.tell()
                     blocksize = self.processingHeaderObj.blockSize
                     #salta el primer bloque de datos
                     if csize > self.processingHeaderObj.blockSize:
                         self.fp.seek(self.fp.tell() + blocksize)
                     else:
                         return
                     csize = self.fileSize - self.fp.tell()
                     neededsize = self.processingHeaderObj.blockSize + self.basicHeaderSize
                     while True:
                         if self.fp.tell()<self.fileSize:
                             self.fp.seek(self.fp.tell() + neededsize)
                         else:
                             self.fp.seek(self.fp.tell() - neededsize)
                             break
             #        csize = self.fileSize - self.fp.tell()
             #        neededsize = self.processingHeaderObj.blockSize + self.basicHeaderSize
             #        factor = int(csize/neededsize)
             #        if factor > 0:
             #            self.fp.seek(self.fp.tell() + factor*neededsize)
                     self.flagIsNewFile = 0
                     self.__isFirstTimeOnline = 0
                 def __setNewBlock(self):
                     if self.fp == None:
                         return 0
                     if self.online:
                         self.__jumpToLastBlock()
                     if self.flagIsNewFile:
                         return 1
                     self.lastUTTime = self.basicHeaderObj.utc
                     currentSize = self.fileSize - self.fp.tell()
                     neededSize = self.processingHeaderObj.blockSize + self.basicHeaderSize
                     if (currentSize >= neededSize):
                         self.basicHeaderObj.read(self.fp)
                         return 1
                     if self.__waitNewBlock():
                         return 1
                     if not(self.setNextFile()):
                         return 0
                     deltaTime = self.basicHeaderObj.utc - self.lastUTTime #
                     self.flagDiscontinuousBlock = 0
                     if deltaTime > self.maxTimeStep:
                         self.flagDiscontinuousBlock = 1
                     return 1
                 def readNextBlock(self):
                     if not(self.__setNewBlock()):
                         return 0
                     if not(self.readBlock()):
                         return 0
                     return 1
                 def __readFirstHeader(self):
                     self.basicHeaderObj.read(self.fp)
                     self.systemHeaderObj.read(self.fp)
                     self.radarControllerHeaderObj.read(self.fp)
                     self.processingHeaderObj.read(self.fp)
                     self.firstHeaderSize = self.basicHeaderObj.size
                     datatype = int(numpy.log2((self.processingHeaderObj.processFlags & PROCFLAG.DATATYPE_MASK))-numpy.log2(PROCFLAG.DATATYPE_CHAR))
                     if datatype == 0:
                         datatype_str = numpy.dtype([('real','<i1'),('imag','<i1')])
                     elif datatype == 1:
                         datatype_str = numpy.dtype([('real','<i2'),('imag','<i2')])
                     elif datatype == 2:
                         datatype_str = numpy.dtype([('real','<i4'),('imag','<i4')])
                     elif datatype == 3:
                         datatype_str = numpy.dtype([('real','<i8'),('imag','<i8')])
                     elif datatype == 4:
                         datatype_str = numpy.dtype([('real','<f4'),('imag','<f4')])
                     elif datatype == 5:
                         datatype_str = numpy.dtype([('real','<f8'),('imag','<f8')])
                     else:
                         raise ValueError, 'Data type was not defined'
                     self.dtype = datatype_str
                     #self.ippSeconds = 2 * 1000 * self.radarControllerHeaderObj.ipp / self.c
                     self.fileSizeByHeader = self.processingHeaderObj.dataBlocksPerFile * self.processingHeaderObj.blockSize + self.firstHeaderSize + self.basicHeaderSize*(self.processingHeaderObj.dataBlocksPerFile - 1)
             #        self.dataOut.channelList = numpy.arange(self.systemHeaderObj.numChannels)
             #        self.dataOut.channelIndexList = numpy.arange(self.systemHeaderObj.numChannels)
                     self.getBlockDimension()
                 def __verifyFile(self, filename, msgFlag=True):
                     msg = None
                     try:
                         fp = open(filename, 'rb')
                         currentPosition = fp.tell()
                     except IOError:
                         traceback.print_exc()
                         if msgFlag:
                             print "[Reading] The file %s can't be opened" % (filename)
                         return False
                     neededSize = self.processingHeaderObj.blockSize + self.firstHeaderSize
                     if neededSize == 0:
                         basicHeaderObj = BasicHeader(LOCALTIME)
                         systemHeaderObj = SystemHeader()
                         radarControllerHeaderObj = RadarControllerHeader()
                         processingHeaderObj = ProcessingHeader()
                         try:
                             if not( basicHeaderObj.read(fp) ): raise IOError
                             if not( systemHeaderObj.read(fp) ): raise IOError
                             if not( radarControllerHeaderObj.read(fp) ): raise IOError
                             if not( processingHeaderObj.read(fp) ): raise IOError
             #                 data_type = int(numpy.log2((processingHeaderObj.processFlags & PROCFLAG.DATATYPE_MASK))-numpy.log2(PROCFLAG.DATATYPE_CHAR))
                             neededSize = processingHeaderObj.blockSize + basicHeaderObj.size
                         except IOError:
                             traceback.print_exc()
                             if msgFlag:
                                 print "[Reading] The file %s is empty or it hasn't enough data" % filename
                             fp.close()
                             return False
                     else:
                         msg = "[Reading] Skipping the file %s due to it hasn't enough data" %filename
                     fp.close()
                     fileSize = os.path.getsize(filename)
                     currentSize = fileSize - currentPosition
                     if currentSize < neededSize:
                         if msgFlag and (msg != None):
                             print msg #print"\tSkipping the file %s due to it hasn't enough data" %filename
                         return False
                     return True
                 def findDatafiles(self, path, startDate=None, endDate=None, expLabel='', ext='.r', walk=True):
                     dateList = []
                     pathList = []
                     if not walk:
                         #pathList.append(path)
                         multi_path = path.split(',')
                         for single_path in multi_path:
+                            if not os.path.isdir(single_path):
+                                continue
                             ok = False
                             fileList = glob.glob1(single_path, "*"+ext)
                             for thisFile in fileList:
                                 if not os.path.isfile(os.path.join(single_path, thisFile)):
                                     continue
                                 if not isRadarFile(thisFile):
                                     continue
                                 ok = True
                                 thisDate = getDateFromRadarFile(thisFile)
                                 if thisDate not in dateList:
                                     dateList.append(thisDate)
                             if ok:
                                 pathList.append(single_path)
                         return dateList
                     multi_path = path.split(',')
                     for single_path in multi_path:
+                        if not os.path.isdir(single_path):
+                            continue
                         dirList = []
                         for thisPath in os.listdir(single_path):
                             if not os.path.isdir(os.path.join(single_path,thisPath)):
                                 continue
                             if not isRadarFolder(thisPath):
                                 continue
                             dirList.append(thisPath)
                         if not dirList:
                             return dateList
                         if startDate and endDate:
                             thisDate = startDate
                             while(thisDate <= endDate):
                                 year = thisDate.timetuple().tm_year
                                 doy = thisDate.timetuple().tm_yday
                                 matchlist = fnmatch.filter(dirList, '?' + '%4.4d%3.3d' % (year,doy) + '*')
                                 if len(matchlist) == 0:
                                     thisDate += datetime.timedelta(1)
                                     continue
                                 for match in matchlist:
                                     pathList.append(os.path.join(single_path,match,expLabel))
                                     dateList.append(thisDate)
                                 thisDate += datetime.timedelta(1)
                         else:
                             for thisDir in dirList:
                                 year = int(thisDir[1:5])
                                 doy = int(thisDir[5:8])
                                 thisDate = datetime.date(year,1,1) + datetime.timedelta(doy-1)
                                 pathList.append(os.path.join(single_path,thisDir,expLabel))
                                 dateList.append(thisDate)
                     return dateList
                 def setup(self,
                             path=None,
                             startDate=None,
                             endDate=None,
                             startTime=datetime.time(0,0,0),
                             endTime=datetime.time(23,59,59),
                             set=None,
                             expLabel = "",
                             ext = None,
                             online = False,
                             delay = 60,
                             walk = True,
                             getblock = False,
                             nTxs = 1):
                     if path == None:
                         raise ValueError, "[Reading] The path is not valid"
                     if ext == None:
                         ext = self.ext
                     if online:
                         print "[Reading] Searching files in online mode..."
                         for nTries in range( self.nTries ):
                             fullpath, foldercounter, file, year, doy, set = self.__searchFilesOnLine(path=path, expLabel=expLabel, ext=ext, walk=walk, set=set)
                             if fullpath:
                                 break
                             print '[Reading] Waiting %0.2f sec for an valid file in %s: try %02d ...' % (self.delay, path, nTries+1)
                             sleep( self.delay )
                         if not(fullpath):
                             print "[Reading] There 'isn't any valid file in %s" % path
                             return None
                         self.year = year
                         self.doy  = doy
                         self.set  = set - 1
                         self.path = path
                         self.foldercounter = foldercounter
                         last_set = None
                     else:
                         print "[Reading] Searching files in offline mode ..."
                         pathList, filenameList = self.__searchFilesOffLine(path, startDate=startDate, endDate=endDate,
                                                                            startTime=startTime, endTime=endTime,
                                                                            set=set, expLabel=expLabel, ext=ext,
                                                                            walk=walk)
                         if not(pathList):
                             print "[Reading] No *%s files into the folder %s \nfor the range: %s - %s"%(ext, path,
                                                                     datetime.datetime.combine(startDate,startTime).ctime(),
                                                                     datetime.datetime.combine(endDate,endTime).ctime())
                             sys.exit(-1)
                         self.fileIndex = -1
                         self.pathList = pathList
                         self.filenameList = filenameList
                         file_name = os.path.basename(filenameList[-1])
                         basename, ext = os.path.splitext(file_name)
                         last_set = int(basename[-3:])
                     self.online = online
                     self.delay = delay
                     ext = ext.lower()
                     self.ext = ext
                     self.getByBlock = getblock
                     self.nTxs = int(nTxs)
                     if not(self.setNextFile()):
                         if (startDate!=None) and (endDate!=None):
                             print "[Reading] No files in range: %s - %s" %(datetime.datetime.combine(startDate,startTime).ctime(), datetime.datetime.combine(endDate,endTime).ctime())
                         elif startDate != None:
                             print "[Reading] No files in range: %s" %(datetime.datetime.combine(startDate,startTime).ctime())
                         else:
                             print "[Reading] No files"
                         sys.exit(-1)
             #        self.updateDataHeader()
                     if last_set != None:
                         self.dataOut.last_block = last_set * self.processingHeaderObj.dataBlocksPerFile + self.basicHeaderObj.dataBlock
                     return
                 def getBasicHeader(self):
                     self.dataOut.utctime = self.basicHeaderObj.utc + self.basicHeaderObj.miliSecond/1000. + self.profileIndex * self.radarControllerHeaderObj.ippSeconds
                     self.dataOut.flagDiscontinuousBlock = self.flagDiscontinuousBlock
                     self.dataOut.timeZone = self.basicHeaderObj.timeZone
                     self.dataOut.dstFlag = self.basicHeaderObj.dstFlag
                     self.dataOut.errorCount = self.basicHeaderObj.errorCount
                     self.dataOut.useLocalTime = self.basicHeaderObj.useLocalTime
                     self.dataOut.ippSeconds = self.radarControllerHeaderObj.ippSeconds/self.nTxs
                     self.dataOut.nProfiles = self.processingHeaderObj.profilesPerBlock*self.nTxs
                 def getFirstHeader(self):
                     raise ValueError, "This method has not been implemented"
                 def getData(self):
                     raise ValueError, "This method has not been implemented"
                 def hasNotDataInBuffer(self):
                     raise ValueError, "This method has not been implemented"
                 def readBlock(self):
                     raise ValueError, "This method has not been implemented"
                 def isEndProcess(self):
                     return self.flagNoMoreFiles
                 def printReadBlocks(self):
                     print "[Reading] Number of read blocks per file %04d" %self.nReadBlocks
                 def printTotalBlocks(self):
                     print "[Reading] Number of read blocks %04d" %self.nTotalBlocks
                 def printNumberOfBlock(self):
                     if self.flagIsNewBlock:
                         print "[Reading] Block No. %04d, Total blocks %04d -> %s" %(self.basicHeaderObj.dataBlock, self.nTotalBlocks, self.dataOut.datatime.ctime())
                         self.dataOut.blocknow = self.basicHeaderObj.dataBlock
                 def printInfo(self):
                     if self.__printInfo == False:
                         return
                     self.basicHeaderObj.printInfo()
                     self.systemHeaderObj.printInfo()
                     self.radarControllerHeaderObj.printInfo()
                     self.processingHeaderObj.printInfo()
                     self.__printInfo = False
                 def run(self, **kwargs):
                     if not(self.isConfig):
             #            self.dataOut = dataOut
                         self.setup(**kwargs)
                         self.isConfig = True
                     self.getData()
             class JRODataWriter(JRODataIO):
                 """
                 Esta clase permite escribir datos a archivos procesados (.r o ,pdata). La escritura
                 de los datos siempre se realiza por bloques.
                 """
                 blockIndex = 0
                 path = None
                 setFile = None
                 profilesPerBlock = None
                 blocksPerFile = None
                 nWriteBlocks = 0
                 def __init__(self, dataOut=None):
                     raise ValueError, "Not implemented"
                 def hasAllDataInBuffer(self):
                     raise ValueError, "Not implemented"
                 def setBlockDimension(self):
                     raise ValueError, "Not implemented"
                 def writeBlock(self):
                     raise ValueError, "No implemented"
                 def putData(self):
                     raise ValueError, "No implemented"
                 def setBasicHeader(self):
                     self.basicHeaderObj.size = self.basicHeaderSize #bytes
                     self.basicHeaderObj.version = self.versionFile
                     self.basicHeaderObj.dataBlock = self.nTotalBlocks
                     utc = numpy.floor(self.dataOut.utctime)
                     milisecond  = (self.dataOut.utctime - utc)* 1000.0
                     self.basicHeaderObj.utc = utc
                     self.basicHeaderObj.miliSecond = milisecond
                     self.basicHeaderObj.timeZone = self.dataOut.timeZone
                     self.basicHeaderObj.dstFlag = self.dataOut.dstFlag
                     self.basicHeaderObj.errorCount = self.dataOut.errorCount
                 def setFirstHeader(self):
                     """
                     Obtiene una copia del First Header
                     Affected:
                         self.basicHeaderObj
                         self.systemHeaderObj
                         self.radarControllerHeaderObj
                         self.processingHeaderObj self.
                     Return:
                         None
                     """
                     raise ValueError, "No implemented"
                 def __writeFirstHeader(self):
                     """
                     Escribe el primer header del file es decir el Basic header y el Long header (SystemHeader, RadarControllerHeader, ProcessingHeader)
                     Affected:
                         __dataType
                     Return:
                         None
                     """
             #        CALCULAR PARAMETROS
                     sizeLongHeader = self.systemHeaderObj.size + self.radarControllerHeaderObj.size + self.processingHeaderObj.size
                     self.basicHeaderObj.size = self.basicHeaderSize + sizeLongHeader
                     self.basicHeaderObj.write(self.fp)
                     self.systemHeaderObj.write(self.fp)
                     self.radarControllerHeaderObj.write(self.fp)
                     self.processingHeaderObj.write(self.fp)
                     self.dtype = self.dataOut.dtype
                 def __setNewBlock(self):
                     """
                     Si es un nuevo file escribe el First Header caso contrario escribe solo el Basic Header
                     Return:
 :    si no pudo escribir nada
 :    Si escribio el Basic el First Header
                     """
                     if self.fp == None:
                         self.setNextFile()
                     if self.flagIsNewFile:
                         return 1
                     if self.blockIndex < self.processingHeaderObj.dataBlocksPerFile:
                         self.basicHeaderObj.write(self.fp)
                         return 1
                     if not( self.setNextFile() ):
                         return 0
                     return 1
                 def writeNextBlock(self):
                     """
                     Selecciona el bloque siguiente de datos y los escribe en un file
                     Return:
 :    Si no hizo pudo escribir el bloque de datos
 :    Si no pudo escribir el bloque de datos
                     """
                     if not( self.__setNewBlock() ):
                         return 0
                     self.writeBlock()
                     return 1
                 def setNextFile(self):
                     """
                     Determina el siguiente file que sera escrito
                     Affected:
                         self.filename
                         self.subfolder
                         self.fp
                         self.setFile
                         self.flagIsNewFile
                     Return:
 :    Si el archivo no puede ser escrito
 :    Si el archivo esta listo para ser escrito
                     """
                     ext = self.ext
                     path = self.path
                     if self.fp != None:
                         self.fp.close()
                     timeTuple = time.localtime( self.dataOut.utctime)
                     subfolder = 'd%4.4d%3.3d' % (timeTuple.tm_year,timeTuple.tm_yday)
                     fullpath = os.path.join( path, subfolder )
                     if not( os.path.exists(fullpath) ):
                         os.mkdir(fullpath)
                         self.setFile = -1 #inicializo mi contador de seteo
                     else:
                         filesList = os.listdir( fullpath )
                         if len( filesList ) > 0:
                             filesList = sorted( filesList, key=str.lower )
                             filen = filesList[-1]
                             # el filename debera tener el siguiente formato
                             # 0 1234 567 89A BCDE (hex)
                             # x YYYY DDD SSS .ext
                             if isNumber( filen[8:11] ):
                                 self.setFile = int( filen[8:11] ) #inicializo mi contador de seteo al seteo del ultimo file
                             else:
                                 self.setFile = -1
                         else:
                             self.setFile = -1 #inicializo mi contador de seteo
                     setFile = self.setFile
                     setFile += 1
                     filen = '%s%4.4d%3.3d%3.3d%s' % (self.optchar,
                                                     timeTuple.tm_year,
                                                     timeTuple.tm_yday,
                                                     setFile,
                                                     ext )
                     filename = os.path.join( path, subfolder, filen )
                     fp = open( filename,'wb' )
                     self.blockIndex = 0
                     #guardando atributos
                     self.filename = filename
                     self.subfolder = subfolder
                     self.fp = fp
                     self.setFile = setFile
                     self.flagIsNewFile = 1
                     self.setFirstHeader()
                     print '[Writing] file: %s'%self.filename
                     self.__writeFirstHeader()
                     return 1
                 def setup(self, dataOut, path, blocksPerFile, profilesPerBlock=64, set=0, ext=None):
                     """
                     Setea el tipo de formato en la cual sera guardada la data y escribe el First Header
                     Inputs:
                         path      :    el path destino en el cual se escribiran los files a crear
                         format    :    formato en el cual sera salvado un file
                         set       :    el setebo del file
                     Return:
 :    Si no realizo un buen seteo
 :    Si realizo un buen seteo
                     """
                     if ext == None:
                         ext = self.ext
                     ext = ext.lower()
                     self.ext = ext
                     self.path = path
                     self.setFile = set - 1
                     self.blocksPerFile = blocksPerFile
                     self.profilesPerBlock = profilesPerBlock
                     self.dataOut = dataOut
                     if not(self.setNextFile()):
                         print "[Writing] There isn't a next file"
                         return 0
                     self.setBlockDimension()
                     return 1
                 def run(self, dataOut, **kwargs):
                     if not(self.isConfig):
                         self.setup(dataOut, **kwargs)
                         self.isConfig = True
                     self.putData()

schainpy/model/io/jroIO_usrp.py +8 -1

             '''
             Created on Jul 3, 2014
             @author: roj-idl71
             '''
+            import os
             import datetime
             import numpy
             try:
                 from gevent import sleep
             except:
                 from time import sleep
             from schainpy.model.data.jroheaderIO import RadarControllerHeader, SystemHeader
             from schainpy.model.data.jrodata import Voltage
             from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation
             try:
                 import digital_rf_hdf5
             except:
                 print 'You should install "digital_rf_hdf5" module if you want to read USRP data'
             class USRPReader(ProcessingUnit):
                 '''
                 classdocs
                 '''
                 def __init__(self):
                     '''
                     Constructor
                     '''
                     ProcessingUnit.__init__(self)
                     self.dataOut = Voltage()
                     self.__printInfo = True
                     self.__flagDiscontinuousBlock = False
                     self.__bufferIndex = 9999999
                     self.__ippKm = None
                     self.__codeType = 0
                     self.__nCode = None
                     self.__nBaud = None
                     self.__code = None
                 def __getCurrentSecond(self):
                     return self.__thisUnixSample/self.__sample_rate
                 thisSecond = property(__getCurrentSecond, "I'm the 'thisSecond' property.")
                 def __setFileHeader(self):
                     '''
                     In this method will be initialized every parameter of dataOut object (header, no data)
                     '''
                     nProfiles = self.__sample_rate  #Number of profiles by second
                     self.dataOut.radarControllerHeaderObj = RadarControllerHeader(ippKm=self.__ippKm,
                                                                                   txA=0,
                                                                                   txB=0,
                                                                                   nWindows=1,
                                                                                   nHeights=self.__nSamples,
                                                                                   firstHeight=self.__firstHeigth,
                                                                                   deltaHeight=self.__deltaHeigth,
                                                                                   codeType=self.__codeType,
                                                                                   nCode=self.__nCode, nBaud=self.__nBaud,
                                                                                   code = self.__code)
                     self.dataOut.systemHeaderObj = SystemHeader(nSamples=self.__nSamples,
                                                                 nProfiles=nProfiles,
                                                                 nChannels=len(self.__channelList),
                                                                 adcResolution=14)
                     self.dataOut.type = "Voltage"
                     self.dataOut.data = None
                     self.dataOut.dtype = numpy.dtype([('real','<i8'),('imag','<i8')])
             #        self.dataOut.nChannels = 0
             #        self.dataOut.nHeights = 0
                     self.dataOut.nProfiles = nProfiles
                     self.dataOut.heightList = self.__firstHeigth + numpy.arange(self.__nSamples, dtype = numpy.float)*self.__deltaHeigth
                     self.dataOut.channelList = self.__channelList
                     self.dataOut.blocksize = self.dataOut.getNChannels() * self.dataOut.getNHeights()
             #        self.dataOut.channelIndexList = None
                     self.dataOut.flagNoData = True
                     #Set to TRUE if the data is discontinuous
                     self.dataOut.flagDiscontinuousBlock = False
                     self.dataOut.utctime = None
                     self.dataOut.timeZone = self.__timezone/60  #timezone like jroheader, difference in minutes between UTC and localtime
                     self.dataOut.dstFlag = 0
                     self.dataOut.errorCount = 0
                     self.dataOut.nCohInt = 1
                     self.dataOut.flagDecodeData = False #asumo que la data esta decodificada
                     self.dataOut.flagDeflipData = False #asumo que la data esta sin flip
                     self.dataOut.flagShiftFFT = False
                     self.dataOut.ippSeconds = 1.0*self.__nSamples/self.__sample_rate
                     #Time interval between profiles
                     #self.dataOut.timeInterval = self.dataOut.ippSeconds * self.dataOut.nCohInt
                     self.dataOut.frequency = self.__frequency
                     self.dataOut.realtime = self.__online
                 def findDatafiles(self, path, startDate=None, endDate=None):
+                    if not os.path.isdir(path):
+                        return []
                     try:
                         digitalReadObj = digital_rf_hdf5.read_hdf5(path, load_all_metadata=True)
                     except:
                         digitalReadObj = digital_rf_hdf5.read_hdf5(path)
                     channelNameList = digitalReadObj.get_channels()
                     if not channelNameList:
                         return []
                     metadata_dict = digitalReadObj.get_rf_file_metadata(channelNameList[0])
                     sample_rate = metadata_dict['sample_rate'][0]
                     this_metadata_file = digitalReadObj.get_metadata(channelNameList[0])
                     try:
                         timezone = this_metadata_file['timezone'].value
                     except:
                         timezone = 0
                     startUTCSecond, endUTCSecond = digitalReadObj.get_bounds(channelNameList[0])/sample_rate - timezone
                     startDatetime = datetime.datetime.utcfromtimestamp(startUTCSecond)
                     endDatatime = datetime.datetime.utcfromtimestamp(endUTCSecond)
                     if not startDate:
                         startDate = startDatetime.date()
                     if not endDate:
                         endDate = endDatatime.date()
                     dateList = []
                     thisDatetime = startDatetime
                     while(thisDatetime<=endDatatime):
                         thisDate = thisDatetime.date()
                         if thisDate < startDate:
                             continue
                         if thisDate > endDate:
                             break
                         dateList.append(thisDate)
                         thisDatetime += datetime.timedelta(1)
                     return dateList
                 def setup(self, path = None,
                                 startDate = None,
                                 endDate = None,
                                 startTime = datetime.time(0,0,0),
                                 endTime = datetime.time(23,59,59),
                                 channelList = None,
                                 nSamples = None,
                                 ippKm = 60,
                                 online = False,
                                 delay = 60,
                                 buffer_size = None,
                                 nbuffer = 1024,
                                 **kwargs):
                     '''
                     In this method we should set all initial parameters.
                     Inputs:
                         path
                         startDate
                         endDate
                         startTime
                         endTime
                         set
                         expLabel
                         ext
                         online
                         delay
                     '''
                     if not buffer_size:
                         buffer_size = nbuffer
+                    if not os.path.isdir(path):
+                        raise ValueError, "[Reading] This path %s does not exist" %path
                     try:
                         self.digitalReadObj = digital_rf_hdf5.read_hdf5(path, load_all_metadata=True)
                     except:
                         self.digitalReadObj = digital_rf_hdf5.read_hdf5(path)
                     channelNameList = self.digitalReadObj.get_channels()
                     if not channelNameList:
                         raise IOError, "[Reading] The path doesn,t have any files .. "
                     if not channelList:
                         channelList = range(len(channelNameList))
                     ##########  Reading metadata ######################
                     metadata_dict = self.digitalReadObj.get_rf_file_metadata(channelNameList[channelList[0]])
                     self.__sample_rate = metadata_dict['sample_rate'][0]
                     self.__samples_per_file = metadata_dict['samples_per_file'][0]
                     self.__deltaHeigth = 1e6*0.15/self.__sample_rate
                     this_metadata_file = self.digitalReadObj.get_metadata(channelNameList[channelList[0]])
                     self.__frequency = this_metadata_file['center_frequencies'].value
                     try:
                         self.__timezone = this_metadata_file['timezone'].value
                     except:
                         self.__timezone = 0
                     self.__firstHeigth = 0
                     try:
                         codeType = this_metadata_file['codeType'].value
                     except:
                         codeType = 0
                     nCode = 0
                     nBaud = 0
                     code = None
                     if codeType:
                         nCode = this_metadata_file['nCode'].value
                         nBaud = this_metadata_file['nBaud'].value
                         code = this_metadata_file['code'].value
                     if not ippKm:
                         try:
                             #seconds to km
                             ippKm = 1e6*0.15*this_metadata_file['ipp'].value
                         except:
                             ippKm = None
                     ####################################################
                     startUTCSecond = None
                     endUTCSecond = None
                     if startDate:
                         startDatetime = datetime.datetime.combine(startDate, startTime)
                         startUTCSecond = (startDatetime-datetime.datetime(1970,1,1)).total_seconds() + self.__timezone
                     if endDate:
                         endDatetime = datetime.datetime.combine(endDate, endTime)
                         endUTCSecond = (endDatetime-datetime.datetime(1970,1,1)).total_seconds() + self.__timezone
                     start_index, end_index = self.digitalReadObj.get_bounds(channelNameList[channelList[0]])
                     if not startUTCSecond:
                         startUTCSecond = start_index/self.__sample_rate
                     if start_index > startUTCSecond*self.__sample_rate:
                         startUTCSecond = start_index/self.__sample_rate
                     if not endUTCSecond:
                         endUTCSecond = end_index/self.__sample_rate
                     if end_index < endUTCSecond*self.__sample_rate:
                         endUTCSecond = end_index/self.__sample_rate
                     if not nSamples:
                         if not ippKm:
                             raise ValueError, "[Reading] nSamples or ippKm should be defined"
                         nSamples = ippKm / (1e6*0.15/self.__sample_rate)
                     channelBoundList = []
                     channelNameListFiltered = []
                     for thisIndexChannel in channelList:
                         thisChannelName =  channelNameList[thisIndexChannel]
                         start_index, end_index = self.digitalReadObj.get_bounds(thisChannelName)
                         channelBoundList.append((start_index, end_index))
                         channelNameListFiltered.append(thisChannelName)
                     self.profileIndex = 0
                     self.__delay = delay
                     self.__ippKm = ippKm
                     self.__codeType = codeType
                     self.__nCode = nCode
                     self.__nBaud = nBaud
                     self.__code = code
                     self.__datapath = path
                     self.__online = online
                     self.__channelList = channelList
                     self.__channelNameList = channelNameListFiltered
                     self.__channelBoundList = channelBoundList
                     self.__nSamples = nSamples
                     self.__samples_to_read = buffer_size*nSamples
                     self.__nChannels = len(self.__channelList)
                     self.__startUTCSecond = startUTCSecond
                     self.__endUTCSecond = endUTCSecond
                     self.__timeInterval = 1.0 * self.__samples_to_read/self.__sample_rate #Time interval
                     if online:
             #             self.__thisUnixSample = int(endUTCSecond*self.__sample_rate - 4*self.__samples_to_read)
                         startUTCSecond = numpy.floor(endUTCSecond)
                     self.__thisUnixSample = int(startUTCSecond*self.__sample_rate) - self.__samples_to_read
                     self.__data_buffer = numpy.zeros((self.__nChannels, self.__samples_to_read), dtype = numpy.complex)
                     self.__setFileHeader()
                     self.isConfig = True
                     print "[Reading] USRP Data was found from %s to %s " %(
                                                                   datetime.datetime.utcfromtimestamp(self.__startUTCSecond - self.__timezone),
                                                                   datetime.datetime.utcfromtimestamp(self.__endUTCSecond - self.__timezone)
                                                                   )
                     print "[Reading] Starting process from %s to %s" %(datetime.datetime.utcfromtimestamp(startUTCSecond - self.__timezone),
                                                                        datetime.datetime.utcfromtimestamp(endUTCSecond - self.__timezone)
                                                                        )
                 def __reload(self):
                     if not self.__online:
                         return
             #         print
             #         print "%s not in range [%s, %s]" %(
             #                                           datetime.datetime.utcfromtimestamp(self.thisSecond - self.__timezone),
             #                                           datetime.datetime.utcfromtimestamp(self.__startUTCSecond - self.__timezone),
             #                                           datetime.datetime.utcfromtimestamp(self.__endUTCSecond - self.__timezone)
             #                                           )
                     print "[Reading] reloading metadata ..."
                     try:
                         self.digitalReadObj.reload(complete_update=True)
                     except:
                         self.digitalReadObj.reload()
                     start_index, end_index = self.digitalReadObj.get_bounds(self.__channelNameList[self.__channelList[0]])
                     if start_index > self.__startUTCSecond*self.__sample_rate:
                         self.__startUTCSecond = 1.0*start_index/self.__sample_rate
                     if end_index > self.__endUTCSecond*self.__sample_rate:
                         self.__endUTCSecond = 1.0*end_index/self.__sample_rate
                         print
                         print "[Reading] New timerange found [%s, %s] " %(
                                                                   datetime.datetime.utcfromtimestamp(self.__startUTCSecond - self.__timezone),
                                                                   datetime.datetime.utcfromtimestamp(self.__endUTCSecond - self.__timezone)
                                                                   )
                         return True
                     return False
                 def __readNextBlock(self, seconds=30, volt_scale = 218776):
                     '''
                     '''
                     #Set the next data
                     self.__flagDiscontinuousBlock = False
                     self.__thisUnixSample += self.__samples_to_read
                     if self.__thisUnixSample + 2*self.__samples_to_read > self.__endUTCSecond*self.__sample_rate:
                         print "[Reading] There are no more data into selected timerange"
                         self.__reload()
                         if self.__thisUnixSample + 2*self.__samples_to_read > self.__endUTCSecond*self.__sample_rate:
                             self.__thisUnixSample -=  self.__samples_to_read
                             return False
                     indexChannel = 0
                     dataOk = False
                     for thisChannelName in self.__channelNameList:
                         try:
                             result = self.digitalReadObj.read_vector_c81d(self.__thisUnixSample,
                                                                           self.__samples_to_read,
                                                                           thisChannelName)
                         except IOError, e:
                             #read next profile
                             self.__flagDiscontinuousBlock = True
                             print e
                             break
                         if result.shape[0] != self.__samples_to_read:
                             self.__flagDiscontinuousBlock = True
                             print "[Reading] %s: Too few samples were found, just %d samples" %(datetime.datetime.utcfromtimestamp(self.thisSecond - self.__timezone),
                                                                                             result.shape[0])
                             break
                         self.__data_buffer[indexChannel,:] = result*volt_scale
                         indexChannel += 1
                         dataOk = True
                     self.__utctime = self.__thisUnixSample/self.__sample_rate
                     if not dataOk:
                         return False
                     print "[Reading] %s: %d samples <> %f sec" %(datetime.datetime.utcfromtimestamp(self.thisSecond - self.__timezone),
                                                                      self.__samples_to_read,
                                                                      self.__timeInterval)
                     self.__bufferIndex = 0
                     return True
                 def __isBufferEmpty(self):
                     if self.__bufferIndex <= self.__samples_to_read - self.__nSamples:
                         return False
                     return True
                 def getData(self, seconds=30, nTries=5):
                     '''
                     This method gets the data from files and put the data into the dataOut object
                     In addition, increase el the buffer counter in one.
                     Return:
                         data    :    retorna un perfil de voltages (alturas * canales) copiados desde el
                                      buffer. Si no hay mas archivos a leer retorna None.
                     Affected:
                         self.dataOut
                         self.profileIndex
                         self.flagDiscontinuousBlock
                         self.flagIsNewBlock
                     '''
                     err_counter = 0
                     self.dataOut.flagNoData = True
                     if self.__isBufferEmpty():
                         self.__flagDiscontinuousBlock = False
                         while True:
                             if self.__readNextBlock():
                                 break
                             if self.__thisUnixSample > self.__endUTCSecond*self.__sample_rate:
                                 return False
                             if self.__flagDiscontinuousBlock:
                                 print '[Reading] discontinuous block found ... continue with the next block'
                                 continue
                             if not self.__online:
                                 return False
                             err_counter += 1
                             if err_counter > nTries:
                                 return False
                             print '[Reading] waiting %d seconds to read a new block' %seconds
                             sleep(seconds)
                     self.dataOut.data = self.__data_buffer[:,self.__bufferIndex:self.__bufferIndex+self.__nSamples]
                     self.dataOut.utctime = (self.__thisUnixSample + self.__bufferIndex)/self.__sample_rate
                     self.dataOut.flagNoData = False
                     self.dataOut.flagDiscontinuousBlock = self.__flagDiscontinuousBlock
                     self.__bufferIndex += self.__nSamples
                     self.profileIndex += 1
                     return True
                 def printInfo(self):
                     '''
                     '''
                     if self.__printInfo == False:
                         return
             #         self.systemHeaderObj.printInfo()
             #         self.radarControllerHeaderObj.printInfo()
                     self.__printInfo = False
                 def printNumberOfBlock(self):
                     '''
                     '''
                     print self.profileIndex
                 def run(self, **kwargs):
                     '''
                     This method will be called many times so here you should put all your code
                     '''
                     if not self.isConfig:
                         self.setup(**kwargs)
                     self.getData(seconds=self.__delay)
                     return
             class USRPWriter(Operation):
                 '''
                 classdocs
                 '''
                 def __init__(self):
                     '''
                     Constructor
                     '''
                     self.dataOut = None
                 def setup(self, dataIn, path, blocksPerFile, set=0, ext=None):
                     '''
                     In this method we should set all initial parameters.
                     Input:
                         dataIn        :        Input data will also be outputa data
                     '''
                     self.dataOut = dataIn
                     self.isConfig = True
                     return
                 def run(self, dataIn, **kwargs):
                     '''
                     This method will be called many times so here you should put all your code
                     Inputs:
                         dataIn        :        object with the data
                     '''
                     if not self.isConfig:
                         self.setup(dataIn, **kwargs)
             if __name__ == '__main__':
                 readObj = USRPReader()
                 while True:
                     readObj.run(path='/Volumes/DATA/haystack/passive_radar/')
             #         readObj.printInfo()
                     readObj.printNumberOfBlock()
   No newline at end of file

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages