beremiz

refactoring

2012-05-09, Edouard Tisserant
31dade089db5
Parents e0630d262ac3
Children ae63ccc29444
refactoring
17 files changed, 2133 insertions(+), 2122 deletions(-)
  • +5 -4
    Beremiz.py
  • +0 -2066
    ConfigTree.py
  • +632 -0
    ConfigTreeNode.py
  • +16 -13
    LPCBeremiz.py
  • +1359 -0
    ProjectController.py
  • +1 -1
    c_ext/c_ext.py
  • +1 -1
    canfestival/canfestival.py
  • +1 -1
    py_ext/modules/svgui/svgui.py
  • +1 -1
    py_ext/modules/wxglade_hmi/wxglade_hmi.py
  • +1 -1
    py_ext/py_ext.py
  • +3 -3
    targets/LPC/__init__.py
  • +3 -3
    targets/Xenomai/__init__.py
  • +19 -19
    targets/toolchain_gcc.py
  • +9 -9
    targets/toolchain_makefile.py
  • +51 -0
    util/MiniTextControler.py
  • +2 -0
    util/__init__.py
  • +29 -0
    util/misc.py
    • --- a/Beremiz.py Tue May 08 22:27:49 2012 +0200
    +++ b/Beremiz.py Wed May 09 00:00:50 2012 +0200
    @@ -147,7 +147,8 @@
    import cPickle
    from util.BrowseValuesLibraryDialog import BrowseValuesLibraryDialog
    import types, time, re, platform, time, traceback, commands
    -from ConfigTree import ConfigTreeRoot, MiniTextControler, MATIEC_ERROR_MODEL
    +from ProjectController import ProjectController, MATIEC_ERROR_MODEL
    +from util import MiniTextControler
    from ProcessLogger import ProcessLogger
    from docutils import *
    @@ -556,7 +557,7 @@
    projectOpen = None
    if projectOpen is not None and os.path.isdir(projectOpen):
    - self.CTR = ConfigTreeRoot(self, self.Log)
    + self.CTR = ProjectController(self, self.Log)
    self.Controler = self.CTR
    result = self.CTR.LoadProject(projectOpen, buildpath)
    if not result:
    @@ -1677,7 +1678,7 @@
    self.Config.Write("lastopenedfolder", os.path.dirname(projectpath))
    self.Config.Flush()
    self.ResetView()
    - ctr = ConfigTreeRoot(self, self.Log)
    + ctr = ProjectController(self, self.Log)
    result = ctr.NewProject(projectpath)
    if not result:
    self.CTR = ctr
    @@ -1713,7 +1714,7 @@
    self.Config.Write("lastopenedfolder", os.path.dirname(projectpath))
    self.Config.Flush()
    self.ResetView()
    - self.CTR = ConfigTreeRoot(self, self.Log)
    + self.CTR = ProjectController(self, self.Log)
    self.Controler = self.CTR
    result = self.CTR.LoadProject(projectpath)
    if not result:
    --- a/ConfigTree.py Tue May 08 22:27:49 2012 +0200
    +++ /dev/null Thu Jan 01 00:00:00 1970 +0000
    @@ -1,2066 +0,0 @@
    -"""
    -Base definitions for beremiz confnodes
    -"""
    -
    -import os,sys,traceback
    -import time
    -import features
    -import types
    -import shutil
    -from xml.dom import minidom
    -import wx
    -
    -#Quick hack to be able to find Beremiz IEC tools. Should be config params.
    -base_folder = os.path.split(sys.path[0])[0]
    -
    -from xmlclass import GenerateClassesFromXSDstring
    -from ProcessLogger import ProcessLogger
    -
    -from PLCControler import PLCControler, LOCATION_CONFNODE, LOCATION_MODULE, LOCATION_GROUP, LOCATION_VAR_INPUT, LOCATION_VAR_OUTPUT, LOCATION_VAR_MEMORY
    -
    -_BaseParamsClass = GenerateClassesFromXSDstring("""<?xml version="1.0" encoding="ISO-8859-1" ?>
    - <xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema">
    - <xsd:element name="BaseParams">
    - <xsd:complexType>
    - <xsd:attribute name="Name" type="xsd:string" use="optional" default="__unnamed__"/>
    - <xsd:attribute name="IEC_Channel" type="xsd:integer" use="required"/>
    - <xsd:attribute name="Enabled" type="xsd:boolean" use="optional" default="true"/>
    - </xsd:complexType>
    - </xsd:element>
    - </xsd:schema>""")["BaseParams"]
    -
    -NameTypeSeparator = '@'
    -
    -class MiniTextControler:
    -
    - def __init__(self, filepath):
    - self.FilePath = filepath
    -
    - def CTNFullName(self):
    - return ""
    -
    - def SetEditedElementText(self, tagname, text):
    - file = open(self.FilePath, "w")
    - file.write(text)
    - file.close()
    -
    - def GetEditedElementText(self, tagname, debug = False):
    - if os.path.isfile(self.FilePath):
    - file = open(self.FilePath, "r")
    - text = file.read()
    - file.close()
    - return text
    - return ""
    -
    - def GetEditedElementInterfaceVars(self, tagname, debug = False):
    - return []
    -
    - def GetEditedElementType(self, tagname, debug = False):
    - return "program"
    -
    - def GetBlockTypes(self, tagname = "", debug = False):
    - return []
    -
    - def GetDataTypes(self, tagname = "", basetypes = True, only_locatables = False, debug = False):
    - return []
    -
    - def GetEnumeratedDataValues(self, debug = False):
    - return []
    -
    - def StartBuffering(self):
    - pass
    -
    - def EndBuffering(self):
    - pass
    -
    - def BufferProject(self):
    - pass
    -
    -# helper func to get path to images
    -def opjimg(imgname):
    - return os.path.join(base_folder, "beremiz", "images",imgname)
    -
    -# helper func to check path write permission
    -def CheckPathPerm(path):
    - if path is None or not os.path.isdir(path):
    - return False
    - for root, dirs, files in os.walk(path):
    - for name in files:
    - if os.access(root, os.W_OK) is not True or os.access(os.path.join(root, name), os.W_OK) is not True:
    - return False
    - return True
    -
    -class ConfigTreeNode:
    - """
    - This class is the one that define confnodes.
    - """
    -
    - XSD = None
    - CTNChildrenTypes = []
    - CTNMaxCount = None
    - ConfNodeMethods = []
    - LibraryControler = None
    - EditorType = None
    -
    - def _AddParamsMembers(self):
    - self.CTNParams = None
    - if self.XSD:
    - self.Classes = GenerateClassesFromXSDstring(self.XSD)
    - Classes = [(name, XSDclass) for name, XSDclass in self.Classes.items() if XSDclass.IsBaseClass]
    - if len(Classes) == 1:
    - name, XSDclass = Classes[0]
    - obj = XSDclass()
    - self.CTNParams = (name, obj)
    - setattr(self, name, obj)
    -
    - def __init__(self):
    - # Create BaseParam
    - self.BaseParams = _BaseParamsClass()
    - self.MandatoryParams = ("BaseParams", self.BaseParams)
    - self._AddParamsMembers()
    - self.Children = {}
    - self._View = None
    - # copy ConfNodeMethods so that it can be later customized
    - self.ConfNodeMethods = [dic.copy() for dic in self.ConfNodeMethods]
    - self.LoadSTLibrary()
    -
    - def ConfNodeBaseXmlFilePath(self, CTNName=None):
    - return os.path.join(self.CTNPath(CTNName), "baseconfnode.xml")
    -
    - def ConfNodeXmlFilePath(self, CTNName=None):
    - return os.path.join(self.CTNPath(CTNName), "confnode.xml")
    -
    - def ConfNodeLibraryFilePath(self):
    - return os.path.join(self.ConfNodePath(), "pous.xml")
    -
    - def ConfNodePath(self):
    - return os.path.join(self.CTNParent.ConfNodePath(), self.CTNType)
    -
    - def CTNPath(self,CTNName=None):
    - if not CTNName:
    - CTNName = self.CTNName()
    - return os.path.join(self.CTNParent.CTNPath(),
    - CTNName + NameTypeSeparator + self.CTNType)
    -
    - def CTNName(self):
    - return self.BaseParams.getName()
    -
    - def CTNEnabled(self):
    - return self.BaseParams.getEnabled()
    -
    - def CTNFullName(self):
    - parent = self.CTNParent.CTNFullName()
    - if parent != "":
    - return parent + "." + self.CTNName()
    - return self.BaseParams.getName()
    -
    - def GetIconPath(self, name):
    - return opjimg(name)
    -
    - def CTNTestModified(self):
    - return self.ChangesToSave
    -
    - def ProjectTestModified(self):
    - """
    - recursively check modified status
    - """
    - if self.CTNTestModified():
    - return True
    -
    - for CTNChild in self.IterChildren():
    - if CTNChild.ProjectTestModified():
    - return True
    -
    - return False
    -
    - def RemoteExec(self, script, **kwargs):
    - return self.CTNParent.RemoteExec(script, **kwargs)
    -
    - def OnCTNSave(self):
    - #Default, do nothing and return success
    - return True
    -
    - def GetParamsAttributes(self, path = None):
    - if path:
    - parts = path.split(".", 1)
    - if self.MandatoryParams and parts[0] == self.MandatoryParams[0]:
    - return self.MandatoryParams[1].getElementInfos(parts[0], parts[1])
    - elif self.CTNParams and parts[0] == self.CTNParams[0]:
    - return self.CTNParams[1].getElementInfos(parts[0], parts[1])
    - else:
    - params = []
    - if wx.VERSION < (2, 8, 0) and self.MandatoryParams:
    - params.append(self.MandatoryParams[1].getElementInfos(self.MandatoryParams[0]))
    - if self.CTNParams:
    - params.append(self.CTNParams[1].getElementInfos(self.CTNParams[0]))
    - return params
    -
    - def SetParamsAttribute(self, path, value):
    - self.ChangesToSave = True
    - # Filter IEC_Channel and Name, that have specific behavior
    - if path == "BaseParams.IEC_Channel":
    - old_leading = ".".join(map(str, self.GetCurrentLocation()))
    - new_value = self.FindNewIEC_Channel(value)
    - new_leading = ".".join(map(str, self.CTNParent.GetCurrentLocation() + (new_value,)))
    - self.GetCTRoot().UpdateProjectVariableLocation(old_leading, new_leading)
    - return new_value, True
    - elif path == "BaseParams.Name":
    - res = self.FindNewName(value)
    - self.CTNRequestSave()
    - return res, True
    -
    - parts = path.split(".", 1)
    - if self.MandatoryParams and parts[0] == self.MandatoryParams[0]:
    - self.MandatoryParams[1].setElementValue(parts[1], value)
    - elif self.CTNParams and parts[0] == self.CTNParams[0]:
    - self.CTNParams[1].setElementValue(parts[1], value)
    - return value, False
    -
    - def CTNMakeDir(self):
    - os.mkdir(self.CTNPath())
    -
    - def CTNRequestSave(self):
    - if self.GetCTRoot().CheckProjectPathPerm(False):
    - # If confnode do not have corresponding directory
    - ctnpath = self.CTNPath()
    - if not os.path.isdir(ctnpath):
    - # Create it
    - os.mkdir(ctnpath)
    -
    - # generate XML for base XML parameters controller of the confnode
    - if self.MandatoryParams:
    - BaseXMLFile = open(self.ConfNodeBaseXmlFilePath(),'w')
    - BaseXMLFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n")
    - BaseXMLFile.write(self.MandatoryParams[1].generateXMLText(self.MandatoryParams[0], 0).encode("utf-8"))
    - BaseXMLFile.close()
    -
    - # generate XML for XML parameters controller of the confnode
    - if self.CTNParams:
    - XMLFile = open(self.ConfNodeXmlFilePath(),'w')
    - XMLFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n")
    - XMLFile.write(self.CTNParams[1].generateXMLText(self.CTNParams[0], 0).encode("utf-8"))
    - XMLFile.close()
    -
    - # Call the confnode specific OnCTNSave method
    - result = self.OnCTNSave()
    - if not result:
    - return _("Error while saving \"%s\"\n")%self.CTNPath()
    -
    - # mark confnode as saved
    - self.ChangesToSave = False
    - # go through all children and do the same
    - for CTNChild in self.IterChildren():
    - result = CTNChild.CTNRequestSave()
    - if result:
    - return result
    - return None
    -
    - def CTNImport(self, src_CTNPath):
    - shutil.copytree(src_CTNPath, self.CTNPath)
    - return True
    -
    - def CTNGenerate_C(self, buildpath, locations):
    - """
    - Generate C code
    - @param locations: List of complete variables locations \
    - [{"IEC_TYPE" : the IEC type (i.e. "INT", "STRING", ...)
    - "NAME" : name of the variable (generally "__IW0_1_2" style)
    - "DIR" : direction "Q","I" or "M"
    - "SIZE" : size "X", "B", "W", "D", "L"
    - "LOC" : tuple of interger for IEC location (0,1,2,...)
    - }, ...]
    - @return: [(C_file_name, CFLAGS),...] , LDFLAGS_TO_APPEND
    - """
    - self.GetCTRoot().logger.write_warning(".".join(map(lambda x:str(x), self.GetCurrentLocation())) + " -> Nothing to do\n")
    - return [],"",False
    -
    - def _Generate_C(self, buildpath, locations):
    - # Generate confnodes [(Cfiles, CFLAGS)], LDFLAGS, DoCalls, extra_files
    - # extra_files = [(fname,fobject), ...]
    - gen_result = self.CTNGenerate_C(buildpath, locations)
    - CTNCFilesAndCFLAGS, CTNLDFLAGS, DoCalls = gen_result[:3]
    - extra_files = gen_result[3:]
    - # if some files have been generated put them in the list with their location
    - if CTNCFilesAndCFLAGS:
    - LocationCFilesAndCFLAGS = [(self.GetCurrentLocation(), CTNCFilesAndCFLAGS, DoCalls)]
    - else:
    - LocationCFilesAndCFLAGS = []
    -
    - # confnode asks for some LDFLAGS
    - if CTNLDFLAGS:
    - # LDFLAGS can be either string
    - if type(CTNLDFLAGS)==type(str()):
    - LDFLAGS=[CTNLDFLAGS]
    - #or list of strings
    - elif type(CTNLDFLAGS)==type(list()):
    - LDFLAGS=CTNLDFLAGS[:]
    - else:
    - LDFLAGS=[]
    -
    - # recurse through all children, and stack their results
    - for CTNChild in self.IECSortedChildren():
    - new_location = CTNChild.GetCurrentLocation()
    - # How deep are we in the tree ?
    - depth=len(new_location)
    - _LocationCFilesAndCFLAGS, _LDFLAGS, _extra_files = \
    - CTNChild._Generate_C(
    - #keep the same path
    - buildpath,
    - # filter locations that start with current IEC location
    - [loc for loc in locations if loc["LOC"][0:depth] == new_location ])
    - # stack the result
    - LocationCFilesAndCFLAGS += _LocationCFilesAndCFLAGS
    - LDFLAGS += _LDFLAGS
    - extra_files += _extra_files
    -
    - return LocationCFilesAndCFLAGS, LDFLAGS, extra_files
    -
    - def ConfNodeTypesFactory(self):
    - if self.LibraryControler is not None:
    - return [{"name" : self.CTNType, "types": self.LibraryControler.Project}]
    - return []
    -
    - def ParentsTypesFactory(self):
    - return self.CTNParent.ParentsTypesFactory() + self.ConfNodeTypesFactory()
    -
    - def ConfNodesTypesFactory(self):
    - list = self.ConfNodeTypesFactory()
    - for CTNChild in self.IterChildren():
    - list += CTNChild.ConfNodesTypesFactory()
    - return list
    -
    - def STLibraryFactory(self):
    - if self.LibraryControler is not None:
    - program, errors, warnings = self.LibraryControler.GenerateProgram()
    - return program + "\n"
    - return ""
    -
    - def ConfNodesSTLibraryFactory(self):
    - program = self.STLibraryFactory()
    - for CTNChild in self.IECSortedChildren():
    - program += CTNChild.ConfNodesSTLibraryFactory()
    - return program
    -
    - def IterChildren(self):
    - for CTNType, Children in self.Children.items():
    - for CTNInstance in Children:
    - yield CTNInstance
    -
    - def IECSortedChildren(self):
    - # reorder children by IEC_channels
    - ordered = [(chld.BaseParams.getIEC_Channel(),chld) for chld in self.IterChildren()]
    - if ordered:
    - ordered.sort()
    - return zip(*ordered)[1]
    - else:
    - return []
    -
    - def _GetChildBySomething(self, something, toks):
    - for CTNInstance in self.IterChildren():
    - # if match component of the name
    - if getattr(CTNInstance.BaseParams, something) == toks[0]:
    - # if Name have other components
    - if len(toks) >= 2:
    - # Recurse in order to find the latest object
    - return CTNInstance._GetChildBySomething( something, toks[1:])
    - # No sub name -> found
    - return CTNInstance
    - # Not found
    - return None
    -
    - def GetChildByName(self, Name):
    - if Name:
    - toks = Name.split('.')
    - return self._GetChildBySomething("Name", toks)
    - else:
    - return self
    -
    - def GetChildByIECLocation(self, Location):
    - if Location:
    - return self._GetChildBySomething("IEC_Channel", Location)
    - else:
    - return self
    -
    - def GetCurrentLocation(self):
    - """
    - @return: Tupple containing confnode IEC location of current confnode : %I0.0.4.5 => (0,0,4,5)
    - """
    - return self.CTNParent.GetCurrentLocation() + (self.BaseParams.getIEC_Channel(),)
    -
    - def GetCurrentName(self):
    - """
    - @return: String "ParentParentName.ParentName.Name"
    - """
    - return self.CTNParent._GetCurrentName() + self.BaseParams.getName()
    -
    - def _GetCurrentName(self):
    - """
    - @return: String "ParentParentName.ParentName.Name."
    - """
    - return self.CTNParent._GetCurrentName() + self.BaseParams.getName() + "."
    -
    - def GetCTRoot(self):
    - return self.CTNParent.GetCTRoot()
    -
    - def GetFullIEC_Channel(self):
    - return ".".join([str(i) for i in self.GetCurrentLocation()]) + ".x"
    -
    - def GetLocations(self):
    - location = self.GetCurrentLocation()
    - return [loc for loc in self.CTNParent.GetLocations() if loc["LOC"][0:len(location)] == location]
    -
    - def GetVariableLocationTree(self):
    - '''
    - This function is meant to be overridden by confnodes.
    -
    - It should returns an list of dictionaries
    -
    - - IEC_type is an IEC type like BOOL/BYTE/SINT/...
    - - location is a string of this variable's location, like "%IX0.0.0"
    - '''
    - children = []
    - for child in self.IECSortedChildren():
    - children.append(child.GetVariableLocationTree())
    - return {"name": self.BaseParams.getName(),
    - "type": LOCATION_CONFNODE,
    - "location": self.GetFullIEC_Channel(),
    - "children": children}
    -
    - def FindNewName(self, DesiredName):
    - """
    - Changes Name to DesiredName if available, Name-N if not.
    - @param DesiredName: The desired Name (string)
    - """
    - # Get Current Name
    - CurrentName = self.BaseParams.getName()
    - # Do nothing if no change
    - #if CurrentName == DesiredName: return CurrentName
    - # Build a list of used Name out of parent's Children
    - AllNames=[]
    - for CTNInstance in self.CTNParent.IterChildren():
    - if CTNInstance != self:
    - AllNames.append(CTNInstance.BaseParams.getName())
    -
    - # Find a free name, eventually appending digit
    - res = DesiredName
    - suffix = 1
    - while res in AllNames:
    - res = "%s-%d"%(DesiredName, suffix)
    - suffix += 1
    -
    - # Get old path
    - oldname = self.CTNPath()
    - # Check previous confnode existance
    - dontexist = self.BaseParams.getName() == "__unnamed__"
    - # Set the new name
    - self.BaseParams.setName(res)
    - # Rename confnode dir if exist
    - if not dontexist:
    - shutil.move(oldname, self.CTNPath())
    - # warn user he has two left hands
    - if DesiredName != res:
    - self.GetCTRoot().logger.write_warning(_("A child names \"%s\" already exist -> \"%s\"\n")%(DesiredName,res))
    - return res
    -
    - def GetAllChannels(self):
    - AllChannels=[]
    - for CTNInstance in self.CTNParent.IterChildren():
    - if CTNInstance != self:
    - AllChannels.append(CTNInstance.BaseParams.getIEC_Channel())
    - AllChannels.sort()
    - return AllChannels
    -
    - def FindNewIEC_Channel(self, DesiredChannel):
    - """
    - Changes IEC Channel number to DesiredChannel if available, nearest available if not.
    - @param DesiredChannel: The desired IEC channel (int)
    - """
    - # Get Current IEC channel
    - CurrentChannel = self.BaseParams.getIEC_Channel()
    - # Do nothing if no change
    - #if CurrentChannel == DesiredChannel: return CurrentChannel
    - # Build a list of used Channels out of parent's Children
    - AllChannels = self.GetAllChannels()
    -
    - # Now, try to guess the nearest available channel
    - res = DesiredChannel
    - while res in AllChannels: # While channel not free
    - if res < CurrentChannel: # Want to go down ?
    - res -= 1 # Test for n-1
    - if res < 0 :
    - self.GetCTRoot().logger.write_warning(_("Cannot find lower free IEC channel than %d\n")%CurrentChannel)
    - return CurrentChannel # Can't go bellow 0, do nothing
    - else : # Want to go up ?
    - res += 1 # Test for n-1
    - # Finally set IEC Channel
    - self.BaseParams.setIEC_Channel(res)
    - return res
    -
    - def _OpenView(self, name=None):
    - if self.EditorType is not None and self._View is None:
    - app_frame = self.GetCTRoot().AppFrame
    -
    - self._View = self.EditorType(app_frame.TabsOpened, self, app_frame)
    -
    - app_frame.EditProjectElement(self._View, self.CTNName())
    -
    - return self._View
    - return None
    -
    - def OnCloseEditor(self, view):
    - if self._View == view:
    - self._View = None
    -
    - def OnCTNClose(self):
    - if self._View is not None:
    - app_frame = self.GetCTRoot().AppFrame
    - if app_frame is not None:
    - app_frame.DeletePage(self._View)
    - return True
    -
    - def _doRemoveChild(self, CTNInstance):
    - # Remove all children of child
    - for SubCTNInstance in CTNInstance.IterChildren():
    - CTNInstance._doRemoveChild(SubCTNInstance)
    - # Call the OnCloseMethod
    - CTNInstance.OnCTNClose()
    - # Delete confnode dir
    - shutil.rmtree(CTNInstance.CTNPath())
    - # Remove child of Children
    - self.Children[CTNInstance.CTNType].remove(CTNInstance)
    - # Forget it... (View have to refresh)
    -
    - def CTNRemove(self):
    - # Fetch the confnode
    - #CTNInstance = self.GetChildByName(CTNName)
    - # Ask to his parent to remove it
    - self.CTNParent._doRemoveChild(self)
    -
    - def CTNAddChild(self, CTNName, CTNType, IEC_Channel=0):
    - """
    - Create the confnodes that may be added as child to this node self
    - @param CTNType: string desining the confnode class name (get name from CTNChildrenTypes)
    - @param CTNName: string for the name of the confnode instance
    - """
    - # reorganize self.CTNChildrenTypes tuples from (name, CTNClass, Help)
    - # to ( name, (CTNClass, Help)), an make a dict
    - transpose = zip(*self.CTNChildrenTypes)
    - CTNChildrenTypes = dict(zip(transpose[0],zip(transpose[1],transpose[2])))
    - # Check that adding this confnode is allowed
    - try:
    - CTNClass, CTNHelp = CTNChildrenTypes[CTNType]
    - except KeyError:
    - raise Exception, _("Cannot create child %s of type %s ")%(CTNName, CTNType)
    -
    - # if CTNClass is a class factory, call it. (prevent unneeded imports)
    - if type(CTNClass) == types.FunctionType:
    - CTNClass = CTNClass()
    -
    - # Eventualy Initialize child instance list for this class of confnode
    - ChildrenWithSameClass = self.Children.setdefault(CTNType, list())
    - # Check count
    - if getattr(CTNClass, "CTNMaxCount", None) and len(ChildrenWithSameClass) >= CTNClass.CTNMaxCount:
    - raise Exception, _("Max count (%d) reached for this confnode of type %s ")%(CTNClass.CTNMaxCount, CTNType)
    -
    - # create the final class, derived of provided confnode and template
    - class FinalCTNClass(CTNClass, ConfigTreeNode):
    - """
    - ConfNode class is derivated into FinalCTNClass before being instanciated
    - This way __init__ is overloaded to ensure ConfigTreeNode.__init__ is called
    - before CTNClass.__init__, and to do the file related stuff.
    - """
    - def __init__(_self):
    - # self is the parent
    - _self.CTNParent = self
    - # Keep track of the confnode type name
    - _self.CTNType = CTNType
    - # remind the help string, for more fancy display
    - _self.CTNHelp = CTNHelp
    - # Call the base confnode template init - change XSD into class members
    - ConfigTreeNode.__init__(_self)
    - # check name is unique
    - NewCTNName = _self.FindNewName(CTNName)
    - # If dir have already be made, and file exist
    - if os.path.isdir(_self.CTNPath(NewCTNName)): #and os.path.isfile(_self.ConfNodeXmlFilePath(CTNName)):
    - #Load the confnode.xml file into parameters members
    - _self.LoadXMLParams(NewCTNName)
    - # Basic check. Better to fail immediately.
    - if (_self.BaseParams.getName() != NewCTNName):
    - raise Exception, _("Project tree layout do not match confnode.xml %s!=%s ")%(NewCTNName, _self.BaseParams.getName())
    -
    - # Now, self.CTNPath() should be OK
    -
    - # Check that IEC_Channel is not already in use.
    - _self.FindNewIEC_Channel(_self.BaseParams.getIEC_Channel())
    - # Call the confnode real __init__
    - if getattr(CTNClass, "__init__", None):
    - CTNClass.__init__(_self)
    - #Load and init all the children
    - _self.LoadChildren()
    - #just loaded, nothing to saved
    - _self.ChangesToSave = False
    - else:
    - # If confnode do not have corresponding file/dirs - they will be created on Save
    - _self.CTNMakeDir()
    - # Find an IEC number
    - _self.FindNewIEC_Channel(IEC_Channel)
    - # Call the confnode real __init__
    - if getattr(CTNClass, "__init__", None):
    - CTNClass.__init__(_self)
    - _self.CTNRequestSave()
    - #just created, must be saved
    - _self.ChangesToSave = True
    -
    - def _getBuildPath(_self):
    - return self._getBuildPath()
    -
    - # Create the object out of the resulting class
    - newConfNodeOpj = FinalCTNClass()
    - # Store it in CTNgedChils
    - ChildrenWithSameClass.append(newConfNodeOpj)
    -
    - return newConfNodeOpj
    -
    - def ClearChildren(self):
    - for child in self.IterChildren():
    - child.ClearChildren()
    - self.Children = {}
    -
    - def LoadSTLibrary(self):
    - # Get library blocks if plcopen library exist
    - library_path = self.ConfNodeLibraryFilePath()
    - if os.path.isfile(library_path):
    - self.LibraryControler = PLCControler()
    - self.LibraryControler.OpenXMLFile(library_path)
    - self.LibraryControler.ClearConfNodeTypes()
    - self.LibraryControler.AddConfNodeTypesList(self.ParentsTypesFactory())
    -
    - def LoadXMLParams(self, CTNName = None):
    - methode_name = os.path.join(self.CTNPath(CTNName), "methods.py")
    - if os.path.isfile(methode_name):
    - execfile(methode_name)
    -
    - # Get the base xml tree
    - if self.MandatoryParams:
    - try:
    - basexmlfile = open(self.ConfNodeBaseXmlFilePath(CTNName), 'r')
    - basetree = minidom.parse(basexmlfile)
    - self.MandatoryParams[1].loadXMLTree(basetree.childNodes[0])
    - basexmlfile.close()
    - except Exception, exc:
    - self.GetCTRoot().logger.write_error(_("Couldn't load confnode base parameters %s :\n %s") % (CTNName, str(exc)))
    - self.GetCTRoot().logger.write_error(traceback.format_exc())
    -
    - # Get the xml tree
    - if self.CTNParams:
    - try:
    - xmlfile = open(self.ConfNodeXmlFilePath(CTNName), 'r')
    - tree = minidom.parse(xmlfile)
    - self.CTNParams[1].loadXMLTree(tree.childNodes[0])
    - xmlfile.close()
    - except Exception, exc:
    - self.GetCTRoot().logger.write_error(_("Couldn't load confnode parameters %s :\n %s") % (CTNName, str(exc)))
    - self.GetCTRoot().logger.write_error(traceback.format_exc())
    -
    - def LoadChildren(self):
    - # Iterate over all CTNName@CTNType in confnode directory, and try to open them
    - for CTNDir in os.listdir(self.CTNPath()):
    - if os.path.isdir(os.path.join(self.CTNPath(), CTNDir)) and \
    - CTNDir.count(NameTypeSeparator) == 1:
    - pname, ptype = CTNDir.split(NameTypeSeparator)
    - try:
    - self.CTNAddChild(pname, ptype)
    - except Exception, exc:
    - self.GetCTRoot().logger.write_error(_("Could not add child \"%s\", type %s :\n%s\n")%(pname, ptype, str(exc)))
    - self.GetCTRoot().logger.write_error(traceback.format_exc())
    -
    - def EnableMethod(self, method, value):
    - for d in self.ConfNodeMethods:
    - if d["method"]==method:
    - d["enabled"]=value
    - return True
    - return False
    -
    - def ShowMethod(self, method, value):
    - for d in self.ConfNodeMethods:
    - if d["method"]==method:
    - d["shown"]=value
    - return True
    - return False
    -
    - def CallMethod(self, method):
    - for d in self.ConfNodeMethods:
    - if d["method"]==method and d.get("enabled", True) and d.get("shown", True):
    - getattr(self, method)()
    -
    -
    -####################################################################################
    -####################################################################################
    -####################################################################################
    -################################### ROOT ######################################
    -####################################################################################
    -####################################################################################
    -####################################################################################
    -
    -if wx.Platform == '__WXMSW__':
    - exe_ext=".exe"
    -else:
    - exe_ext=""
    -
    -# import for project creation timestamping
    -from threading import Timer, Lock, Thread, Semaphore
    -from time import localtime
    -from datetime import datetime
    -# import necessary stuff from PLCOpenEditor
    -from PLCOpenEditor import PLCOpenEditor, ProjectDialog
    -from TextViewer import TextViewer
    -from plcopen.structures import IEC_KEYWORDS, TypeHierarchy_list
    -
    -
    -import re, tempfile
    -import targets
    -from targets.typemapping import DebugTypesSize
    -
    -import connectors
    -from discovery import DiscoveryDialog
    -from weakref import WeakKeyDictionary
    -
    -MATIEC_ERROR_MODEL = re.compile(".*\.st:(\d+)-(\d+)\.\.(\d+)-(\d+): error : (.*)$")
    -
    -DEBUG_RETRIES_WARN = 3
    -DEBUG_RETRIES_REREGISTER = 4
    -
    -def CTNClassFactory(classpath):
    - if type(classpath)==str:
    - def fac():
    - mod=__import__(classpath.rsplit('.',1)[0])
    - return reduce(getattr, classpath.split('.')[1:], mod)
    - return fac
    - else:
    - return lambda:classpath
    -
    -class ConfigTreeRoot(ConfigTreeNode, PLCControler):
    - """
    - This class define Root object of the confnode tree.
    - It is responsible of :
    - - Managing project directory
    - - Building project
    - - Handling PLCOpenEditor controler and view
    - - Loading user confnodes and instanciante them as children
    - - ...
    -
    - """
    -
    - # For root object, available Children Types are modules of the confnode packages.
    - CTNChildrenTypes = [(n, CTNClassFactory(c), d) for n,d,h,c in features.catalog]
    -
    - XSD = """<?xml version="1.0" encoding="ISO-8859-1" ?>
    - <xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema">
    - <xsd:element name="BeremizRoot">
    - <xsd:complexType>
    - <xsd:sequence>
    - <xsd:element name="TargetType">
    - <xsd:complexType>
    - <xsd:choice minOccurs="0">
    - """+targets.targetchoices+"""
    - </xsd:choice>
    - </xsd:complexType>
    - </xsd:element>
    - </xsd:sequence>
    - <xsd:attribute name="URI_location" type="xsd:string" use="optional" default=""/>
    - <xsd:attribute name="Enable_ConfNodes" type="xsd:boolean" use="optional" default="true"/>
    - </xsd:complexType>
    - </xsd:element>
    - </xsd:schema>
    - """
    -
    - def __init__(self, frame, logger):
    - PLCControler.__init__(self)
    -
    - self.MandatoryParams = None
    - self.SetAppFrame(frame, logger)
    - self._builder = None
    - self._connector = None
    -
    - self.iec2c_path = os.path.join(base_folder, "matiec", "iec2c"+exe_ext)
    - self.ieclib_path = os.path.join(base_folder, "matiec", "lib")
    -
    - # Setup debug information
    - self.IECdebug_datas = {}
    - self.IECdebug_lock = Lock()
    -
    - self.DebugTimer=None
    - self.ResetIECProgramsAndVariables()
    -
    - #This method are not called here... but in NewProject and OpenProject
    - #self._AddParamsMembers()
    - #self.Children = {}
    -
    - # In both new or load scenario, no need to save
    - self.ChangesToSave = False
    - # root have no parent
    - self.CTNParent = None
    - # Keep track of the confnode type name
    - self.CTNType = "Beremiz"
    - self.Children = {}
    - # After __init__ root confnode is not valid
    - self.ProjectPath = None
    - self._setBuildPath(None)
    - self.DebugThread = None
    - self.debug_break = False
    - self.previous_plcstate = None
    - # copy ConfNodeMethods so that it can be later customized
    - self.ConfNodeMethods = [dic.copy() for dic in self.ConfNodeMethods]
    - self.LoadSTLibrary()
    -
    - def __del__(self):
    - if self.DebugTimer:
    - self.DebugTimer.cancel()
    - self.KillDebugThread()
    -
    - def SetAppFrame(self, frame, logger):
    - self.AppFrame = frame
    - self.logger = logger
    - self.StatusTimer = None
    -
    - if frame is not None:
    - # Timer to pull PLC status
    - ID_STATUSTIMER = wx.NewId()
    - self.StatusTimer = wx.Timer(self.AppFrame, ID_STATUSTIMER)
    - self.AppFrame.Bind(wx.EVT_TIMER, self.PullPLCStatusProc, self.StatusTimer)
    -
    - self.RefreshConfNodesBlockLists()
    -
    - def ResetAppFrame(self, logger):
    - if self.AppFrame is not None:
    - self.AppFrame.Unbind(wx.EVT_TIMER, self.StatusTimer)
    - self.StatusTimer = None
    - self.AppFrame = None
    -
    - self.logger = logger
    -
    - def ConfNodeLibraryFilePath(self):
    - return os.path.join(os.path.split(__file__)[0], "pous.xml")
    -
    - def CTNTestModified(self):
    - return self.ChangesToSave or not self.ProjectIsSaved()
    -
    - def CTNFullName(self):
    - return ""
    -
    - def GetCTRoot(self):
    - return self
    -
    - def GetIECLibPath(self):
    - return self.ieclib_path
    -
    - def GetIEC2cPath(self):
    - return self.iec2c_path
    -
    - def GetCurrentLocation(self):
    - return ()
    -
    - def GetCurrentName(self):
    - return ""
    -
    - def _GetCurrentName(self):
    - return ""
    -
    - def GetProjectPath(self):
    - return self.ProjectPath
    -
    - def GetProjectName(self):
    - return os.path.split(self.ProjectPath)[1]
    -
    - def GetDefaultTargetName(self):
    - if wx.Platform == '__WXMSW__':
    - return "Win32"
    - else:
    - return "Linux"
    -
    - def GetTarget(self):
    - target = self.BeremizRoot.getTargetType()
    - if target.getcontent() is None:
    - target = self.Classes["BeremizRoot_TargetType"]()
    - target_name = self.GetDefaultTargetName()
    - target.setcontent({"name": target_name, "value": self.Classes["TargetType_%s"%target_name]()})
    - return target
    -
    - def GetParamsAttributes(self, path = None):
    - params = ConfigTreeNode.GetParamsAttributes(self, path)
    - if params[0]["name"] == "BeremizRoot":
    - for child in params[0]["children"]:
    - if child["name"] == "TargetType" and child["value"] == '':
    - child.update(self.GetTarget().getElementInfos("TargetType"))
    - return params
    -
    - def SetParamsAttribute(self, path, value):
    - if path.startswith("BeremizRoot.TargetType.") and self.BeremizRoot.getTargetType().getcontent() is None:
    - self.BeremizRoot.setTargetType(self.GetTarget())
    - return ConfigTreeNode.SetParamsAttribute(self, path, value)
    -
    - # helper func to check project path write permission
    - def CheckProjectPathPerm(self, dosave=True):
    - if CheckPathPerm(self.ProjectPath):
    - return True
    - dialog = wx.MessageDialog(self.AppFrame,
    - _('You must have permission to work on the project\nWork on a project copy ?'),
    - _('Error'),
    - wx.YES_NO | wx.NO_DEFAULT | wx.ICON_QUESTION)
    - answer = dialog.ShowModal()
    - dialog.Destroy()
    - if answer == wx.ID_YES:
    - if self.SaveProjectAs():
    - self.AppFrame.RefreshAll()
    - self.AppFrame.RefreshTitle()
    - self.AppFrame.RefreshFileMenu()
    - return True
    - return False
    -
    - def NewProject(self, ProjectPath, BuildPath=None):
    - """
    - Create a new project in an empty folder
    - @param ProjectPath: path of the folder where project have to be created
    - @param PLCParams: properties of the PLCOpen program created
    - """
    - # Verify that chosen folder is empty
    - if not os.path.isdir(ProjectPath) or len(os.listdir(ProjectPath)) > 0:
    - return _("Chosen folder isn't empty. You can't use it for a new project!")
    -
    - dialog = ProjectDialog(self.AppFrame)
    - if dialog.ShowModal() == wx.ID_OK:
    - values = dialog.GetValues()
    - values["creationDateTime"] = datetime(*localtime()[:6])
    - dialog.Destroy()
    - else:
    - dialog.Destroy()
    - return _("Project not created")
    -
    - # Create PLCOpen program
    - self.CreateNewProject(values)
    - # Change XSD into class members
    - self._AddParamsMembers()
    - self.Children = {}
    - # Keep track of the root confnode (i.e. project path)
    - self.ProjectPath = ProjectPath
    - self._setBuildPath(BuildPath)
    - # get confnodes bloclist (is that usefull at project creation?)
    - self.RefreshConfNodesBlockLists()
    - # this will create files base XML files
    - self.SaveProject()
    - return None
    -
    - def LoadProject(self, ProjectPath, BuildPath=None):
    - """
    - Load a project contained in a folder
    - @param ProjectPath: path of the project folder
    - """
    - if os.path.basename(ProjectPath) == "":
    - ProjectPath = os.path.dirname(ProjectPath)
    - # Verify that project contains a PLCOpen program
    - plc_file = os.path.join(ProjectPath, "plc.xml")
    - if not os.path.isfile(plc_file):
    - return _("Chosen folder doesn't contain a program. It's not a valid project!")
    - # Load PLCOpen file
    - result = self.OpenXMLFile(plc_file)
    - if result:
    - return result
    - # Change XSD into class members
    - self._AddParamsMembers()
    - self.Children = {}
    - # Keep track of the root confnode (i.e. project path)
    - self.ProjectPath = ProjectPath
    - self._setBuildPath(BuildPath)
    - # If dir have already be made, and file exist
    - if os.path.isdir(self.CTNPath()) and os.path.isfile(self.ConfNodeXmlFilePath()):
    - #Load the confnode.xml file into parameters members
    - result = self.LoadXMLParams()
    - if result:
    - return result
    - #Load and init all the children
    - self.LoadChildren()
    - self.RefreshConfNodesBlockLists()
    -
    - if os.path.exists(self._getBuildPath()):
    - self.EnableMethod("_Clean", True)
    -
    - if os.path.isfile(self._getIECrawcodepath()):
    - self.ShowMethod("_showIECcode", True)
    -
    - return None
    -
    - def CloseProject(self):
    - self.ClearChildren()
    - self.ResetAppFrame(None)
    -
    - def SaveProject(self):
    - if self.CheckProjectPathPerm(False):
    - self.SaveXMLFile(os.path.join(self.ProjectPath, 'plc.xml'))
    - result = self.CTNRequestSave()
    - if result:
    - self.logger.write_error(result)
    -
    - def SaveProjectAs(self, dosave=True):
    - # Ask user to choose a path with write permissions
    - if wx.Platform == '__WXMSW__':
    - path = os.getenv("USERPROFILE")
    - else:
    - path = os.getenv("HOME")
    - dirdialog = wx.DirDialog(self.AppFrame , _("Choose a directory to save project"), path, wx.DD_NEW_DIR_BUTTON)
    - answer = dirdialog.ShowModal()
    - dirdialog.Destroy()
    - if answer == wx.ID_OK:
    - newprojectpath = dirdialog.GetPath()
    - if os.path.isdir(newprojectpath):
    - self.ProjectPath = newprojectpath
    - if dosave:
    - self.SaveProject()
    - self._setBuildPath(self.BuildPath)
    - return True
    - return False
    -
    - # Update PLCOpenEditor ConfNode Block types from loaded confnodes
    - def RefreshConfNodesBlockLists(self):
    - if getattr(self, "Children", None) is not None:
    - self.ClearConfNodeTypes()
    - self.AddConfNodeTypesList(self.ConfNodesTypesFactory())
    - if self.AppFrame is not None:
    - self.AppFrame.RefreshLibraryPanel()
    - self.AppFrame.RefreshEditor()
    -
    - # Update a PLCOpenEditor Pou variable location
    - def UpdateProjectVariableLocation(self, old_leading, new_leading):
    - self.Project.updateElementAddress(old_leading, new_leading)
    - self.BufferProject()
    - if self.AppFrame is not None:
    - self.AppFrame.RefreshTitle()
    - self.AppFrame.RefreshInstancesTree()
    - self.AppFrame.RefreshFileMenu()
    - self.AppFrame.RefreshEditMenu()
    - self.AppFrame.RefreshEditor()
    -
    - def GetVariableLocationTree(self):
    - '''
    - This function is meant to be overridden by confnodes.
    -
    - It should returns an list of dictionaries
    -
    - - IEC_type is an IEC type like BOOL/BYTE/SINT/...
    - - location is a string of this variable's location, like "%IX0.0.0"
    - '''
    - children = []
    - for child in self.IECSortedChildren():
    - children.append(child.GetVariableLocationTree())
    - return children
    -
    - def ConfNodePath(self):
    - return os.path.split(__file__)[0]
    -
    - def CTNPath(self, CTNName=None):
    - return self.ProjectPath
    -
    - def ConfNodeXmlFilePath(self, CTNName=None):
    - return os.path.join(self.CTNPath(CTNName), "beremiz.xml")
    -
    - def ParentsTypesFactory(self):
    - return self.ConfNodeTypesFactory()
    -
    - def _setBuildPath(self, buildpath):
    - if CheckPathPerm(buildpath):
    - self.BuildPath = buildpath
    - else:
    - self.BuildPath = None
    - self.BuildPath = buildpath
    - self.DefaultBuildPath = None
    - if self._builder is not None:
    - self._builder.SetBuildPath(self._getBuildPath())
    -
    - def _getBuildPath(self):
    - # BuildPath is defined by user
    - if self.BuildPath is not None:
    - return self.BuildPath
    - # BuildPath isn't defined by user but already created by default
    - if self.DefaultBuildPath is not None:
    - return self.DefaultBuildPath
    - # Create a build path in project folder if user has permissions
    - if CheckPathPerm(self.ProjectPath):
    - self.DefaultBuildPath = os.path.join(self.ProjectPath, "build")
    - # Create a build path in temp folder
    - else:
    - self.DefaultBuildPath = os.path.join(tempfile.mkdtemp(), os.path.basename(self.ProjectPath), "build")
    -
    - if not os.path.exists(self.DefaultBuildPath):
    - os.makedirs(self.DefaultBuildPath)
    - return self.DefaultBuildPath
    -
    - def _getExtraFilesPath(self):
    - return os.path.join(self._getBuildPath(), "extra_files")
    -
    - def _getIECcodepath(self):
    - # define name for IEC code file
    - return os.path.join(self._getBuildPath(), "plc.st")
    -
    - def _getIECgeneratedcodepath(self):
    - # define name for IEC generated code file
    - return os.path.join(self._getBuildPath(), "generated_plc.st")
    -
    - def _getIECrawcodepath(self):
    - # define name for IEC raw code file
    - return os.path.join(self.CTNPath(), "raw_plc.st")
    -
    - def GetLocations(self):
    - locations = []
    - filepath = os.path.join(self._getBuildPath(),"LOCATED_VARIABLES.h")
    - if os.path.isfile(filepath):
    - # IEC2C compiler generate a list of located variables : LOCATED_VARIABLES.h
    - location_file = open(os.path.join(self._getBuildPath(),"LOCATED_VARIABLES.h"))
    - # each line of LOCATED_VARIABLES.h declares a located variable
    - lines = [line.strip() for line in location_file.readlines()]
    - # This regular expression parses the lines genereated by IEC2C
    - LOCATED_MODEL = re.compile("__LOCATED_VAR\((?P<IEC_TYPE>[A-Z]*),(?P<NAME>[_A-Za-z0-9]*),(?P<DIR>[QMI])(?:,(?P<SIZE>[XBWDL]))?,(?P<LOC>[,0-9]*)\)")
    - for line in lines:
    - # If line match RE,
    - result = LOCATED_MODEL.match(line)
    - if result:
    - # Get the resulting dict
    - resdict = result.groupdict()
    - # rewrite string for variadic location as a tuple of integers
    - resdict['LOC'] = tuple(map(int,resdict['LOC'].split(',')))
    - # set located size to 'X' if not given
    - if not resdict['SIZE']:
    - resdict['SIZE'] = 'X'
    - # finally store into located variable list
    - locations.append(resdict)
    - return locations
    -
    - def _Generate_SoftPLC(self):
    - """
    - Generate SoftPLC ST/IL/SFC code out of PLCOpenEditor controller, and compile it with IEC2C
    - @param buildpath: path where files should be created
    - """
    -
    - # Update PLCOpenEditor ConfNode Block types before generate ST code
    - self.RefreshConfNodesBlockLists()
    -
    - self.logger.write(_("Generating SoftPLC IEC-61131 ST/IL/SFC code...\n"))
    - buildpath = self._getBuildPath()
    - # ask PLCOpenEditor controller to write ST/IL/SFC code file
    - program, errors, warnings = self.GenerateProgram(self._getIECgeneratedcodepath())
    - if len(warnings) > 0:
    - self.logger.write_warning(_("Warnings in ST/IL/SFC code generator :\n"))
    - for warning in warnings:
    - self.logger.write_warning("%s\n"%warning)
    - if len(errors) > 0:
    - # Failed !
    - self.logger.write_error(_("Error in ST/IL/SFC code generator :\n%s\n")%errors[0])
    - return False
    - plc_file = open(self._getIECcodepath(), "w")
    - # Add ST Library from confnodes
    - plc_file.write(self.ConfNodesSTLibraryFactory())
    - if os.path.isfile(self._getIECrawcodepath()):
    - plc_file.write(open(self._getIECrawcodepath(), "r").read())
    - plc_file.write("\n")
    - plc_file.close()
    - plc_file = open(self._getIECcodepath(), "r")
    - self.ProgramOffset = 0
    - for line in plc_file.xreadlines():
    - self.ProgramOffset += 1
    - plc_file.close()
    - plc_file = open(self._getIECcodepath(), "a")
    - plc_file.write(open(self._getIECgeneratedcodepath(), "r").read())
    - plc_file.close()
    -
    - self.logger.write(_("Compiling IEC Program into C code...\n"))
    -
    - # Now compile IEC code into many C files
    - # files are listed to stdout, and errors to stderr.
    - status, result, err_result = ProcessLogger(
    - self.logger,
    - "\"%s\" -f -I \"%s\" -T \"%s\" \"%s\""%(
    - self.iec2c_path,
    - self.ieclib_path,
    - buildpath,
    - self._getIECcodepath()),
    - no_stdout=True, no_stderr=True).spin()
    - if status:
    - # Failed !
    -
    - # parse iec2c's error message. if it contains a line number,
    - # then print those lines from the generated IEC file.
    - for err_line in err_result.split('\n'):
    - self.logger.write_warning(err_line + "\n")
    -
    - m_result = MATIEC_ERROR_MODEL.match(err_line)
    - if m_result is not None:
    - first_line, first_column, last_line, last_column, error = m_result.groups()
    - first_line, last_line = int(first_line), int(last_line)
    -
    - last_section = None
    - f = open(self._getIECcodepath())
    -
    - for i, line in enumerate(f.readlines()):
    - i = i + 1
    - if line[0] not in '\t \r\n':
    - last_section = line
    -
    - if first_line <= i <= last_line:
    - if last_section is not None:
    - self.logger.write_warning("In section: " + last_section)
    - last_section = None # only write section once
    - self.logger.write_warning("%04d: %s" % (i, line))
    -
    - f.close()
    -
    - self.logger.write_error(_("Error : IEC to C compiler returned %d\n")%status)
    - return False
    -
    - # Now extract C files of stdout
    - C_files = [ fname for fname in result.splitlines() if fname[-2:]==".c" or fname[-2:]==".C" ]
    - # remove those that are not to be compiled because included by others
    - C_files.remove("POUS.c")
    - if not C_files:
    - self.logger.write_error(_("Error : At least one configuration and one resource must be declared in PLC !\n"))
    - return False
    - # transform those base names to full names with path
    - C_files = map(lambda filename:os.path.join(buildpath, filename), C_files)
    - self.logger.write(_("Extracting Located Variables...\n"))
    - # Keep track of generated located variables for later use by self._Generate_C
    - self.PLCGeneratedLocatedVars = self.GetLocations()
    - # Keep track of generated C files for later use by self.CTNGenerate_C
    - self.PLCGeneratedCFiles = C_files
    - # compute CFLAGS for plc
    - self.plcCFLAGS = "\"-I"+self.ieclib_path+"\""
    - return True
    -
    - def GetBuilder(self):
    - """
    - Return a Builder (compile C code into machine code)
    - """
    - # Get target, module and class name
    - targetname = self.GetTarget().getcontent()["name"]
    - modulename = "targets." + targetname
    - classname = targetname + "_target"
    -
    - # Get module reference
    - try :
    - targetmodule = getattr(__import__(modulename), targetname)
    -
    - except Exception, msg:
    - self.logger.write_error(_("Can't find module for target %s!\n")%targetname)
    - self.logger.write_error(str(msg))
    - return None
    -
    - # Get target class
    - targetclass = getattr(targetmodule, classname)
    -
    - # if target already
    - if self._builder is None or not isinstance(self._builder,targetclass):
    - # Get classname instance
    - self._builder = targetclass(self)
    - return self._builder
    -
    - def ResetBuildMD5(self):
    - builder=self.GetBuilder()
    - if builder is not None:
    - builder.ResetBinaryCodeMD5()
    - self.EnableMethod("_Transfer", False)
    -
    - def GetLastBuildMD5(self):
    - builder=self.GetBuilder()
    - if builder is not None:
    - return builder.GetBinaryCodeMD5()
    - else:
    - return None
    -
    - #######################################################################
    - #
    - # C CODE GENERATION METHODS
    - #
    - #######################################################################
    -
    - def CTNGenerate_C(self, buildpath, locations):
    - """
    - Return C code generated by iec2c compiler
    - when _generate_softPLC have been called
    - @param locations: ignored
    - @return: [(C_file_name, CFLAGS),...] , LDFLAGS_TO_APPEND
    - """
    -
    - return ([(C_file_name, self.plcCFLAGS)
    - for C_file_name in self.PLCGeneratedCFiles ],
    - "", # no ldflags
    - False) # do not expose retreive/publish calls
    -
    - def ResetIECProgramsAndVariables(self):
    - """
    - Reset variable and program list that are parsed from
    - CSV file generated by IEC2C compiler.
    - """
    - self._ProgramList = None
    - self._VariablesList = None
    - self._IECPathToIdx = {}
    - self._Ticktime = 0
    - self.TracedIECPath = []
    -
    - def GetIECProgramsAndVariables(self):
    - """
    - Parse CSV-like file VARIABLES.csv resulting from IEC2C compiler.
    - Each section is marked with a line staring with '//'
    - list of all variables used in various POUs
    - """
    - if self._ProgramList is None or self._VariablesList is None:
    - try:
    - csvfile = os.path.join(self._getBuildPath(),"VARIABLES.csv")
    - # describes CSV columns
    - ProgramsListAttributeName = ["num", "C_path", "type"]
    - VariablesListAttributeName = ["num", "vartype", "IEC_path", "C_path", "type"]
    - self._ProgramList = []
    - self._VariablesList = []
    - self._IECPathToIdx = {}
    -
    - # Separate sections
    - ListGroup = []
    - for line in open(csvfile,'r').xreadlines():
    - strippedline = line.strip()
    - if strippedline.startswith("//"):
    - # Start new section
    - ListGroup.append([])
    - elif len(strippedline) > 0 and len(ListGroup) > 0:
    - # append to this section
    - ListGroup[-1].append(strippedline)
    -
    - # first section contains programs
    - for line in ListGroup[0]:
    - # Split and Maps each field to dictionnary entries
    - attrs = dict(zip(ProgramsListAttributeName,line.strip().split(';')))
    - # Truncate "C_path" to remove conf an ressources names
    - attrs["C_path"] = '__'.join(attrs["C_path"].split(".",2)[1:])
    - # Push this dictionnary into result.
    - self._ProgramList.append(attrs)
    -
    - # second section contains all variables
    - for line in ListGroup[1]:
    - # Split and Maps each field to dictionnary entries
    - attrs = dict(zip(VariablesListAttributeName,line.strip().split(';')))
    - # Truncate "C_path" to remove conf an ressources names
    - parts = attrs["C_path"].split(".",2)
    - if len(parts) > 2:
    - attrs["C_path"] = '__'.join(parts[1:])
    - else:
    - attrs["C_path"] = '__'.join(parts)
    - # Push this dictionnary into result.
    - self._VariablesList.append(attrs)
    - # Fill in IEC<->C translation dicts
    - IEC_path=attrs["IEC_path"]
    - Idx=int(attrs["num"])
    - self._IECPathToIdx[IEC_path]=(Idx, attrs["type"])
    -
    - # third section contains ticktime
    - if len(ListGroup) > 2:
    - self._Ticktime = int(ListGroup[2][0])
    -
    - except Exception,e:
    - self.logger.write_error(_("Cannot open/parse VARIABLES.csv!\n"))
    - self.logger.write_error(traceback.format_exc())
    - self.ResetIECProgramsAndVariables()
    - return False
    -
    - return True
    -
    - def Generate_plc_debugger(self):
    - """
    - Generate trace/debug code out of PLC variable list
    - """
    - self.GetIECProgramsAndVariables()
    -
    - # prepare debug code
    - debug_code = targets.code("plc_debug") % {
    - "buffer_size": reduce(lambda x, y: x + y, [DebugTypesSize.get(v["type"], 0) for v in self._VariablesList], 0),
    - "programs_declarations":
    - "\n".join(["extern %(type)s %(C_path)s;"%p for p in self._ProgramList]),
    - "extern_variables_declarations":"\n".join([
    - {"EXT":"extern __IEC_%(type)s_p %(C_path)s;",
    - "IN":"extern __IEC_%(type)s_p %(C_path)s;",
    - "MEM":"extern __IEC_%(type)s_p %(C_path)s;",
    - "OUT":"extern __IEC_%(type)s_p %(C_path)s;",
    - "VAR":"extern __IEC_%(type)s_t %(C_path)s;"}[v["vartype"]]%v
    - for v in self._VariablesList if v["vartype"] != "FB" and v["C_path"].find('.')<0]),
    - "for_each_variable_do_code":"\n".join([
    - {"EXT":" (*fp)((void*)&%(C_path)s,%(type)s_P_ENUM);\n",
    - "IN":" (*fp)((void*)&%(C_path)s,%(type)s_P_ENUM);\n",
    - "MEM":" (*fp)((void*)&%(C_path)s,%(type)s_O_ENUM);\n",
    - "OUT":" (*fp)((void*)&%(C_path)s,%(type)s_O_ENUM);\n",
    - "VAR":" (*fp)((void*)&%(C_path)s,%(type)s_ENUM);\n"}[v["vartype"]]%v
    - for v in self._VariablesList if v["vartype"] != "FB" and v["type"] in DebugTypesSize ]),
    - "find_variable_case_code":"\n".join([
    - " case %(num)s:\n"%v+
    - " *varp = (void*)&%(C_path)s;\n"%v+
    - {"EXT":" return %(type)s_P_ENUM;\n",
    - "IN":" return %(type)s_P_ENUM;\n",
    - "MEM":" return %(type)s_O_ENUM;\n",
    - "OUT":" return %(type)s_O_ENUM;\n",
    - "VAR":" return %(type)s_ENUM;\n"}[v["vartype"]]%v
    - for v in self._VariablesList if v["vartype"] != "FB" and v["type"] in DebugTypesSize ])}
    -
    - return debug_code
    -
    - def Generate_plc_common_main(self):
    - """
    - Use confnodes layout given in LocationCFilesAndCFLAGS to
    - generate glue code that dispatch calls to all confnodes
    - """
    - # filter location that are related to code that will be called
    - # in retreive, publish, init, cleanup
    - locstrs = map(lambda x:"_".join(map(str,x)),
    - [loc for loc,Cfiles,DoCalls in self.LocationCFilesAndCFLAGS if loc and DoCalls])
    -
    - # Generate main, based on template
    - if self.BeremizRoot.getEnable_ConfNodes():
    - plc_main_code = targets.code("plc_common_main") % {
    - "calls_prototypes":"\n".join([(
    - "int __init_%(s)s(int argc,char **argv);\n"+
    - "void __cleanup_%(s)s(void);\n"+
    - "void __retrieve_%(s)s(void);\n"+
    - "void __publish_%(s)s(void);")%{'s':locstr} for locstr in locstrs]),
    - "retrieve_calls":"\n ".join([
    - "__retrieve_%s();"%locstrs[i-1] for i in xrange(len(locstrs), 0, -1)]),
    - "publish_calls":"\n ".join([ #Call publish in reverse order
    - "__publish_%s();"%locstr for locstr in locstrs]),
    - "init_calls":"\n ".join([
    - "init_level=%d; "%(i+1)+
    - "if((res = __init_%s(argc,argv))){"%locstr +
    - #"printf(\"%s\"); "%locstr + #for debug
    - "return res;}" for i,locstr in enumerate(locstrs)]),
    - "cleanup_calls":"\n ".join([
    - "if(init_level >= %d) "%i+
    - "__cleanup_%s();"%locstrs[i-1] for i in xrange(len(locstrs), 0, -1)])
    - }
    - else:
    - plc_main_code = targets.code("plc_common_main") % {
    - "calls_prototypes":"\n",
    - "retrieve_calls":"\n",
    - "publish_calls":"\n",
    - "init_calls":"\n",
    - "cleanup_calls":"\n"
    - }
    - plc_main_code += targets.targetcode(self.GetTarget().getcontent()["name"])
    - return plc_main_code
    -
    -
    - def _Build(self):
    - """
    - Method called by user to (re)build SoftPLC and confnode tree
    - """
    - if self.AppFrame is not None:
    - self.AppFrame.ClearErrors()
    -
    - buildpath = self._getBuildPath()
    -
    - # Eventually create build dir
    - if not os.path.exists(buildpath):
    - os.mkdir(buildpath)
    - # There is something to clean
    - self.EnableMethod("_Clean", True)
    -
    - self.logger.flush()
    - self.logger.write(_("Start build in %s\n") % buildpath)
    -
    - # Generate SoftPLC IEC code
    - IECGenRes = self._Generate_SoftPLC()
    - self.ShowMethod("_showIECcode", True)
    -
    - # If IEC code gen fail, bail out.
    - if not IECGenRes:
    - self.logger.write_error(_("IEC-61131-3 code generation failed !\n"))
    - self.ResetBuildMD5()
    - return False
    -
    - # Reset variable and program list that are parsed from
    - # CSV file generated by IEC2C compiler.
    - self.ResetIECProgramsAndVariables()
    -
    - # Generate C code and compilation params from confnode hierarchy
    - try:
    - self.LocationCFilesAndCFLAGS, self.LDFLAGS, ExtraFiles = self._Generate_C(
    - buildpath,
    - self.PLCGeneratedLocatedVars)
    - except Exception, exc:
    - self.logger.write_error(_("Runtime extensions C code generation failed !\n"))
    - self.logger.write_error(traceback.format_exc())
    - self.ResetBuildMD5()
    - return False
    -
    - # Get temporary directory path
    - extrafilespath = self._getExtraFilesPath()
    - # Remove old directory
    - if os.path.exists(extrafilespath):
    - shutil.rmtree(extrafilespath)
    - # Recreate directory
    - os.mkdir(extrafilespath)
    - # Then write the files
    - for fname,fobject in ExtraFiles:
    - fpath = os.path.join(extrafilespath,fname)
    - open(fpath, "wb").write(fobject.read())
    - # Now we can forget ExtraFiles (will close files object)
    - del ExtraFiles
    -
    - # Template based part of C code generation
    - # files are stacked at the beginning, as files of confnode tree root
    - for generator, filename, name in [
    - # debugger code
    - (self.Generate_plc_debugger, "plc_debugger.c", "Debugger"),
    - # init/cleanup/retrieve/publish, run and align code
    - (self.Generate_plc_common_main,"plc_common_main.c","Common runtime")]:
    - try:
    - # Do generate
    - code = generator()
    - if code is None:
    - raise
    - code_path = os.path.join(buildpath,filename)
    - open(code_path, "w").write(code)
    - # Insert this file as first file to be compiled at root confnode
    - self.LocationCFilesAndCFLAGS[0][1].insert(0,(code_path, self.plcCFLAGS))
    - except Exception, exc:
    - self.logger.write_error(name+_(" generation failed !\n"))
    - self.logger.write_error(traceback.format_exc())
    - self.ResetBuildMD5()
    - return False
    -
    - self.logger.write(_("C code generated successfully.\n"))
    -
    - # Get current or fresh builder
    - builder = self.GetBuilder()
    - if builder is None:
    - self.logger.write_error(_("Fatal : cannot get builder.\n"))
    - self.ResetBuildMD5()
    - return False
    -
    - # Build
    - try:
    - if not builder.build() :
    - self.logger.write_error(_("C Build failed.\n"))
    - return False
    - except Exception, exc:
    - self.logger.write_error(_("C Build crashed !\n"))
    - self.logger.write_error(traceback.format_exc())
    - self.ResetBuildMD5()
    - return False
    -
    - self.logger.write(_("Successfully built.\n"))
    - # Update GUI status about need for transfer
    - self.CompareLocalAndRemotePLC()
    - return True
    -
    - def ShowError(self, logger, from_location, to_location):
    - chunk_infos = self.GetChunkInfos(from_location, to_location)
    - for infos, (start_row, start_col) in chunk_infos:
    - start = (from_location[0] - start_row, from_location[1] - start_col)
    - end = (to_location[0] - start_row, to_location[1] - start_col)
    - #print from_location, to_location, start_row, start_col, start, end
    - if self.AppFrame is not None:
    - self.AppFrame.ShowError(infos, start, end)
    -
    - def _showIECcode(self):
    - self._OpenView("IEC code")
    -
    - def _editIECrawcode(self):
    - self._OpenView("IEC raw code")
    -
    - def _OpenView(self, name=None):
    - if name == "IEC code":
    - plc_file = self._getIECcodepath()
    -
    - IEC_code_viewer = TextViewer(self.AppFrame.TabsOpened, "", None, None, instancepath=name)
    - #IEC_code_viewer.Enable(False)
    - IEC_code_viewer.SetTextSyntax("ALL")
    - IEC_code_viewer.SetKeywords(IEC_KEYWORDS)
    - try:
    - text = file(plc_file).read()
    - except:
    - text = '(* No IEC code have been generated at that time ! *)'
    - IEC_code_viewer.SetText(text = text)
    - IEC_code_viewer.SetIcon(self.AppFrame.GenerateBitmap("ST"))
    -
    - self.AppFrame.EditProjectElement(IEC_code_viewer, name)
    -
    - return IEC_code_viewer
    -
    - elif name == "IEC raw code":
    - controler = MiniTextControler(self._getIECrawcodepath())
    - IEC_raw_code_viewer = TextViewer(self.AppFrame.TabsOpened, "", None, controler, instancepath=name)
    - #IEC_raw_code_viewer.Enable(False)
    - IEC_raw_code_viewer.SetTextSyntax("ALL")
    - IEC_raw_code_viewer.SetKeywords(IEC_KEYWORDS)
    - IEC_raw_code_viewer.RefreshView()
    - IEC_raw_code_viewer.SetIcon(self.AppFrame.GenerateBitmap("ST"))
    -
    - self.AppFrame.EditProjectElement(IEC_raw_code_viewer, name)
    -
    - return IEC_raw_code_viewer
    -
    - return None
    -
    - def _Clean(self):
    - if os.path.isdir(os.path.join(self._getBuildPath())):
    - self.logger.write(_("Cleaning the build directory\n"))
    - shutil.rmtree(os.path.join(self._getBuildPath()))
    - else:
    - self.logger.write_error(_("Build directory already clean\n"))
    - self.ShowMethod("_showIECcode", False)
    - self.EnableMethod("_Clean", False)
    - # kill the builder
    - self._builder = None
    - self.CompareLocalAndRemotePLC()
    -
    - ############# Real PLC object access #############
    - def UpdateMethodsFromPLCStatus(self):
    - # Get PLC state : Running or Stopped
    - # TODO : use explicit status instead of boolean
    - status = None
    - if self._connector is not None:
    - status = self._connector.GetPLCstatus()
    - if status is None:
    - self._connector = None
    - status = "Disconnected"
    - if(self.previous_plcstate != status):
    - for args in {
    - "Started" : [("_Run", False),
    - ("_Stop", True)],
    - "Stopped" : [("_Run", True),
    - ("_Stop", False)],
    - "Empty" : [("_Run", False),
    - ("_Stop", False)],
    - "Broken" : [],
    - "Disconnected" :[("_Run", False),
    - ("_Stop", False),
    - ("_Transfer", False),
    - ("_Connect", True),
    - ("_Disconnect", False)],
    - }.get(status,[]):
    - self.ShowMethod(*args)
    - self.previous_plcstate = status
    - return True
    - return False
    -
    - def PullPLCStatusProc(self, event):
    - if self._connector is None:
    - self.StatusTimer.Stop()
    - if self.UpdateMethodsFromPLCStatus():
    -
    - status = _(self.previous_plcstate)
    - {"Broken": self.logger.write_error,
    - None: lambda x: None}.get(
    - self.previous_plcstate, self.logger.write)(_("PLC is %s\n")%status)
    - self.AppFrame.RefreshAll()
    -
    - def RegisterDebugVarToConnector(self):
    - self.DebugTimer=None
    - Idxs = []
    - self.TracedIECPath = []
    - if self._connector is not None:
    - self.IECdebug_lock.acquire()
    - IECPathsToPop = []
    - for IECPath,data_tuple in self.IECdebug_datas.iteritems():
    - WeakCallableDict, data_log, status, fvalue = data_tuple
    - if len(WeakCallableDict) == 0:
    - # Callable Dict is empty.
    - # This variable is not needed anymore!
    - #print "Unused : " + IECPath
    - IECPathsToPop.append(IECPath)
    - elif IECPath != "__tick__":
    - # Convert
    - Idx, IEC_Type = self._IECPathToIdx.get(IECPath,(None,None))
    - if Idx is not None:
    - if IEC_Type in DebugTypesSize:
    - Idxs.append((Idx, IEC_Type, fvalue, IECPath))
    - else:
    - self.logger.write_warning(_("Debug : Unsuppoted type to debug %s\n")%IEC_Type)
    - else:
    - self.logger.write_warning(_("Debug : Unknown variable %s\n")%IECPath)
    - for IECPathToPop in IECPathsToPop:
    - self.IECdebug_datas.pop(IECPathToPop)
    -
    - if Idxs:
    - Idxs.sort()
    - self.TracedIECPath = zip(*Idxs)[3]
    - self._connector.SetTraceVariablesList(zip(*zip(*Idxs)[0:3]))
    - else:
    - self.TracedIECPath = []
    - self._connector.SetTraceVariablesList([])
    - self.IECdebug_lock.release()
    -
    - #for IEC_path, IECdebug_data in self.IECdebug_datas.iteritems():
    - # print IEC_path, IECdebug_data[0].keys()
    -
    - def ReArmDebugRegisterTimer(self):
    - if self.DebugTimer is not None:
    - self.DebugTimer.cancel()
    -
    - # Timer to prevent rapid-fire when registering many variables
    - # use wx.CallAfter use keep using same thread. TODO : use wx.Timer instead
    - self.DebugTimer=Timer(0.5,wx.CallAfter,args = [self.RegisterDebugVarToConnector])
    - # Rearm anti-rapid-fire timer
    - self.DebugTimer.start()
    -
    - def GetDebugIECVariableType(self, IECPath):
    - Idx, IEC_Type = self._IECPathToIdx.get(IECPath,(None,None))
    - return IEC_Type
    -
    - def SubscribeDebugIECVariable(self, IECPath, callableobj, *args, **kwargs):
    - """
    - Dispatching use a dictionnary linking IEC variable paths
    - to a WeakKeyDictionary linking
    - weakly referenced callables to optionnal args
    - """
    - if IECPath != "__tick__" and not self._IECPathToIdx.has_key(IECPath):
    - return None
    -
    - self.IECdebug_lock.acquire()
    - # If no entry exist, create a new one with a fresh WeakKeyDictionary
    - IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    - if IECdebug_data is None:
    - IECdebug_data = [
    - WeakKeyDictionary(), # Callables
    - [], # Data storage [(tick, data),...]
    - "Registered", # Variable status
    - None] # Forced value
    - self.IECdebug_datas[IECPath] = IECdebug_data
    -
    - IECdebug_data[0][callableobj]=(args, kwargs)
    -
    - self.IECdebug_lock.release()
    -
    - self.ReArmDebugRegisterTimer()
    -
    - return IECdebug_data[1]
    -
    - def UnsubscribeDebugIECVariable(self, IECPath, callableobj):
    - #print "Unsubscribe", IECPath, callableobj
    - self.IECdebug_lock.acquire()
    - IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    - if IECdebug_data is not None:
    - IECdebug_data[0].pop(callableobj,None)
    - self.IECdebug_lock.release()
    -
    - self.ReArmDebugRegisterTimer()
    -
    - def UnsubscribeAllDebugIECVariable(self):
    - self.IECdebug_lock.acquire()
    - IECdebug_data = {}
    - self.IECdebug_lock.release()
    -
    - self.ReArmDebugRegisterTimer()
    -
    - def ForceDebugIECVariable(self, IECPath, fvalue):
    - if not self.IECdebug_datas.has_key(IECPath):
    - return
    -
    - self.IECdebug_lock.acquire()
    -
    - # If no entry exist, create a new one with a fresh WeakKeyDictionary
    - IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    - IECdebug_data[2] = "Forced"
    - IECdebug_data[3] = fvalue
    -
    - self.IECdebug_lock.release()
    -
    - self.ReArmDebugRegisterTimer()
    -
    - def ReleaseDebugIECVariable(self, IECPath):
    - if not self.IECdebug_datas.has_key(IECPath):
    - return
    -
    - self.IECdebug_lock.acquire()
    -
    - # If no entry exist, create a new one with a fresh WeakKeyDictionary
    - IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    - IECdebug_data[2] = "Registered"
    - IECdebug_data[3] = None
    -
    - self.IECdebug_lock.release()
    -
    - self.ReArmDebugRegisterTimer()
    -
    - def CallWeakcallables(self, IECPath, function_name, *cargs):
    - data_tuple = self.IECdebug_datas.get(IECPath, None)
    - if data_tuple is not None:
    - WeakCallableDict, data_log, status, fvalue = data_tuple
    - #data_log.append((debug_tick, value))
    - for weakcallable,(args,kwargs) in WeakCallableDict.iteritems():
    - #print weakcallable, value, args, kwargs
    - function = getattr(weakcallable, function_name, None)
    - if function is not None:
    - if status == "Forced" and cargs[1] == fvalue:
    - function(*(cargs + (True,) + args), **kwargs)
    - else:
    - function(*(cargs + args), **kwargs)
    - # This will block thread if more than one call is waiting
    -
    - def GetTicktime(self):
    - return self._Ticktime
    -
    - def RemoteExec(self, script, **kwargs):
    - if self._connector is None:
    - return -1, "No runtime connected!"
    - return self._connector.RemoteExec(script, **kwargs)
    -
    - def DebugThreadProc(self):
    - """
    - This thread waid PLC debug data, and dispatch them to subscribers
    - """
    - self.debug_break = False
    - debug_getvar_retry = 0
    - while (not self.debug_break) and (self._connector is not None):
    - Trace = self._connector.GetTraceVariables()
    - if(Trace):
    - plc_status, debug_tick, debug_vars = Trace
    - else:
    - plc_status = None
    - debug_getvar_retry += 1
    - #print debug_tick, debug_vars
    - if plc_status == "Started":
    - self.IECdebug_lock.acquire()
    - if len(debug_vars) == len(self.TracedIECPath):
    - if debug_getvar_retry > DEBUG_RETRIES_WARN:
    - self.logger.write(_("... debugger recovered\n"))
    - debug_getvar_retry = 0
    - for IECPath,value in zip(self.TracedIECPath, debug_vars):
    - if value is not None:
    - self.CallWeakcallables(IECPath, "NewValue", debug_tick, value)
    - self.CallWeakcallables("__tick__", "NewDataAvailable")
    - self.IECdebug_lock.release()
    - if debug_getvar_retry == DEBUG_RETRIES_WARN:
    - self.logger.write(_("Waiting debugger to recover...\n"))
    - if debug_getvar_retry == DEBUG_RETRIES_REREGISTER:
    - # re-register debug registry to PLC
    - wx.CallAfter(self.RegisterDebugVarToConnector)
    - if debug_getvar_retry != 0:
    - # Be patient, tollerate PLC to come up before debugging
    - time.sleep(0.1)
    - else:
    - self.debug_break = True
    - self.logger.write(_("Debugger disabled\n"))
    - self.DebugThread = None
    -
    - def KillDebugThread(self):
    - tmp_debugthread = self.DebugThread
    - self.debug_break = True
    - if tmp_debugthread is not None:
    - self.logger.writeyield(_("Stopping debugger...\n"))
    - tmp_debugthread.join(timeout=5)
    - if tmp_debugthread.isAlive() and self.logger:
    - self.logger.write_warning(_("Couldn't stop debugger.\n"))
    - else:
    - self.logger.write(_("Debugger stopped.\n"))
    - self.DebugThread = None
    -
    - def _connect_debug(self):
    - if self.AppFrame:
    - self.AppFrame.ResetGraphicViewers()
    - self.RegisterDebugVarToConnector()
    - if self.DebugThread is None:
    - self.DebugThread = Thread(target=self.DebugThreadProc)
    - self.DebugThread.start()
    -
    - def _Run(self):
    - """
    - Start PLC
    - """
    - if self.GetIECProgramsAndVariables():
    - self._connector.StartPLC()
    - self.logger.write(_("Starting PLC\n"))
    - self._connect_debug()
    - else:
    - self.logger.write_error(_("Couldn't start PLC !\n"))
    - wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    -
    - def _Stop(self):
    - """
    - Stop PLC
    - """
    - if self._connector is not None and not self._connector.StopPLC():
    - self.logger.write_error(_("Couldn't stop PLC !\n"))
    -
    - # debugthread should die on his own
    - #self.KillDebugThread()
    -
    - wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    -
    - def _Connect(self):
    - # don't accept re-connetion is already connected
    - if self._connector is not None:
    - self.logger.write_error(_("Already connected. Please disconnect\n"))
    - return
    -
    - # Get connector uri
    - uri = self.\
    - BeremizRoot.\
    - getURI_location().\
    - strip()
    -
    - # if uri is empty launch discovery dialog
    - if uri == "":
    - # Launch Service Discovery dialog
    - dialog = DiscoveryDialog(self.AppFrame)
    - answer = dialog.ShowModal()
    - uri = dialog.GetURI()
    - dialog.Destroy()
    -
    - # Nothing choosed or cancel button
    - if uri is None or answer == wx.ID_CANCEL:
    - self.logger.write_error(_("Connection canceled!\n"))
    - return
    - else:
    - self.\
    - BeremizRoot.\
    - setURI_location(uri)
    -
    - # Get connector from uri
    - try:
    - self._connector = connectors.ConnectorFactory(uri, self)
    - except Exception, msg:
    - self.logger.write_error(_("Exception while connecting %s!\n")%uri)
    - self.logger.write_error(traceback.format_exc())
    -
    - # Did connection success ?
    - if self._connector is None:
    - # Oups.
    - self.logger.write_error(_("Connection failed to %s!\n")%uri)
    - else:
    - self.ShowMethod("_Connect", False)
    - self.ShowMethod("_Disconnect", True)
    - self.ShowMethod("_Transfer", True)
    -
    - self.CompareLocalAndRemotePLC()
    -
    - # Init with actual PLC status and print it
    - self.UpdateMethodsFromPLCStatus()
    - if self.previous_plcstate is not None:
    - status = _(self.previous_plcstate)
    - else:
    - status = ""
    - self.logger.write(_("PLC is %s\n")%status)
    -
    - # Start the status Timer
    - self.StatusTimer.Start(milliseconds=500, oneShot=False)
    -
    - if self.previous_plcstate=="Started":
    - if self.DebugAvailable() and self.GetIECProgramsAndVariables():
    - self.logger.write(_("Debug connect matching running PLC\n"))
    - self._connect_debug()
    - else:
    - self.logger.write_warning(_("Debug do not match PLC - stop/transfert/start to re-enable\n"))
    -
    - def CompareLocalAndRemotePLC(self):
    - if self._connector is None:
    - return
    - # We are now connected. Update button status
    - MD5 = self.GetLastBuildMD5()
    - # Check remote target PLC correspondance to that md5
    - if MD5 is not None:
    - if not self._connector.MatchMD5(MD5):
    -# self.logger.write_warning(
    -# _("Latest build does not match with target, please transfer.\n"))
    - self.EnableMethod("_Transfer", True)
    - else:
    -# self.logger.write(
    -# _("Latest build matches target, no transfer needed.\n"))
    - self.EnableMethod("_Transfer", True)
    - # warns controller that program match
    - self.ProgramTransferred()
    - #self.EnableMethod("_Transfer", False)
    - else:
    -# self.logger.write_warning(
    -# _("Cannot compare latest build to target. Please build.\n"))
    - self.EnableMethod("_Transfer", False)
    -
    -
    - def _Disconnect(self):
    - self._connector = None
    - self.StatusTimer.Stop()
    - wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    -
    - def _Transfer(self):
    - # Get the last build PLC's
    - MD5 = self.GetLastBuildMD5()
    -
    - # Check if md5 file is empty : ask user to build PLC
    - if MD5 is None :
    - self.logger.write_error(_("Failed : Must build before transfer.\n"))
    - return False
    -
    - # Compare PLC project with PLC on target
    - if self._connector.MatchMD5(MD5):
    - self.logger.write(
    - _("Latest build already matches current target. Transfering anyway...\n"))
    -
    - # Get temprary directory path
    - extrafilespath = self._getExtraFilesPath()
    - extrafiles = [(name, open(os.path.join(extrafilespath, name),
    - 'rb').read()) \
    - for name in os.listdir(extrafilespath) \
    - if not name=="CVS"]
    -
    - # Send PLC on target
    - builder = self.GetBuilder()
    - if builder is not None:
    - data = builder.GetBinaryCode()
    - if data is not None :
    - if self._connector.NewPLC(MD5, data, extrafiles) and self.GetIECProgramsAndVariables():
    - self.UnsubscribeAllDebugIECVariable()
    - self.ProgramTransferred()
    - if self.AppFrame is not None:
    - self.AppFrame.RefreshInstancesTree()
    - self.AppFrame.CloseObsoleteDebugTabs()
    - self.logger.write(_("Transfer completed successfully.\n"))
    - else:
    - self.logger.write_error(_("Transfer failed\n"))
    - else:
    - self.logger.write_error(_("No PLC to transfer (did build succeed ?)\n"))
    -
    - wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    -
    - ConfNodeMethods = [
    - {"bitmap" : opjimg("Build"),
    - "name" : _("Build"),
    - "tooltip" : _("Build project into build folder"),
    - "method" : "_Build"},
    - {"bitmap" : opjimg("Clean"),
    - "name" : _("Clean"),
    - "enabled" : False,
    - "tooltip" : _("Clean project build folder"),
    - "method" : "_Clean"},
    - {"bitmap" : opjimg("Run"),
    - "name" : _("Run"),
    - "shown" : False,
    - "tooltip" : _("Start PLC"),
    - "method" : "_Run"},
    - {"bitmap" : opjimg("Stop"),
    - "name" : _("Stop"),
    - "shown" : False,
    - "tooltip" : _("Stop Running PLC"),
    - "method" : "_Stop"},
    - {"bitmap" : opjimg("Connect"),
    - "name" : _("Connect"),
    - "tooltip" : _("Connect to the target PLC"),
    - "method" : "_Connect"},
    - {"bitmap" : opjimg("Transfer"),
    - "name" : _("Transfer"),
    - "shown" : False,
    - "tooltip" : _("Transfer PLC"),
    - "method" : "_Transfer"},
    - {"bitmap" : opjimg("Disconnect"),
    - "name" : _("Disconnect"),
    - "shown" : False,
    - "tooltip" : _("Disconnect from PLC"),
    - "method" : "_Disconnect"},
    - {"bitmap" : opjimg("ShowIECcode"),
    - "name" : _("Show code"),
    - "shown" : False,
    - "tooltip" : _("Show IEC code generated by PLCGenerator"),
    - "method" : "_showIECcode"},
    - {"bitmap" : opjimg("editIECrawcode"),
    - "name" : _("Raw IEC code"),
    - "tooltip" : _("Edit raw IEC code added to code generated by PLCGenerator"),
    - "method" : "_editIECrawcode"},
    - ]
    --- /dev/null Thu Jan 01 00:00:00 1970 +0000
    +++ b/ConfigTreeNode.py Wed May 09 00:00:50 2012 +0200
    @@ -0,0 +1,632 @@
    +"""
    +Config Tree Node base class.
    +
    +- A Beremiz project is organized in a tree each node derivate from ConfigTreeNode
    +- Project tree organization match filesystem organization of project directory.
    +- Each node of the tree have its own xml configuration, whose grammar is defined for each node type, as XSD
    +- ... TODO : document
    +"""
    +
    +import os,traceback,types
    +import shutil
    +from xml.dom import minidom
    +
    +from xmlclass import GenerateClassesFromXSDstring
    +from util import opjimg, GetClassImporter
    +
    +from PLCControler import PLCControler, LOCATION_CONFNODE
    +
    +_BaseParamsClass = GenerateClassesFromXSDstring("""<?xml version="1.0" encoding="ISO-8859-1" ?>
    + <xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema">
    + <xsd:element name="BaseParams">
    + <xsd:complexType>
    + <xsd:attribute name="Name" type="xsd:string" use="optional" default="__unnamed__"/>
    + <xsd:attribute name="IEC_Channel" type="xsd:integer" use="required"/>
    + <xsd:attribute name="Enabled" type="xsd:boolean" use="optional" default="true"/>
    + </xsd:complexType>
    + </xsd:element>
    + </xsd:schema>""")["BaseParams"]
    +
    +NameTypeSeparator = '@'
    +
    +class ConfigTreeNode:
    + """
    + This class is the one that define confnodes.
    + """
    +
    + XSD = None
    + CTNChildrenTypes = []
    + CTNMaxCount = None
    + ConfNodeMethods = []
    + LibraryControler = None
    + EditorType = None
    +
    + def _AddParamsMembers(self):
    + self.CTNParams = None
    + if self.XSD:
    + self.Classes = GenerateClassesFromXSDstring(self.XSD)
    + Classes = [(name, XSDclass) for name, XSDclass in self.Classes.items() if XSDclass.IsBaseClass]
    + if len(Classes) == 1:
    + name, XSDclass = Classes[0]
    + obj = XSDclass()
    + self.CTNParams = (name, obj)
    + setattr(self, name, obj)
    +
    + def __init__(self):
    + # Create BaseParam
    + self.BaseParams = _BaseParamsClass()
    + self.MandatoryParams = ("BaseParams", self.BaseParams)
    + self._AddParamsMembers()
    + self.Children = {}
    + self._View = None
    + # copy ConfNodeMethods so that it can be later customized
    + self.ConfNodeMethods = [dic.copy() for dic in self.ConfNodeMethods]
    + self.LoadSTLibrary()
    +
    + def ConfNodeBaseXmlFilePath(self, CTNName=None):
    + return os.path.join(self.CTNPath(CTNName), "baseconfnode.xml")
    +
    + def ConfNodeXmlFilePath(self, CTNName=None):
    + return os.path.join(self.CTNPath(CTNName), "confnode.xml")
    +
    + def ConfNodeLibraryFilePath(self):
    + return os.path.join(self.ConfNodePath(), "pous.xml")
    +
    + def ConfNodePath(self):
    + return os.path.join(self.CTNParent.ConfNodePath(), self.CTNType)
    +
    + def CTNPath(self,CTNName=None):
    + if not CTNName:
    + CTNName = self.CTNName()
    + return os.path.join(self.CTNParent.CTNPath(),
    + CTNName + NameTypeSeparator + self.CTNType)
    +
    + def CTNName(self):
    + return self.BaseParams.getName()
    +
    + def CTNEnabled(self):
    + return self.BaseParams.getEnabled()
    +
    + def CTNFullName(self):
    + parent = self.CTNParent.CTNFullName()
    + if parent != "":
    + return parent + "." + self.CTNName()
    + return self.BaseParams.getName()
    +
    + def GetIconPath(self, name):
    + return opjimg(name)
    +
    + def CTNTestModified(self):
    + return self.ChangesToSave
    +
    + def ProjectTestModified(self):
    + """
    + recursively check modified status
    + """
    + if self.CTNTestModified():
    + return True
    +
    + for CTNChild in self.IterChildren():
    + if CTNChild.ProjectTestModified():
    + return True
    +
    + return False
    +
    + def RemoteExec(self, script, **kwargs):
    + return self.CTNParent.RemoteExec(script, **kwargs)
    +
    + def OnCTNSave(self):
    + #Default, do nothing and return success
    + return True
    +
    + def GetParamsAttributes(self, path = None):
    + if path:
    + parts = path.split(".", 1)
    + if self.MandatoryParams and parts[0] == self.MandatoryParams[0]:
    + return self.MandatoryParams[1].getElementInfos(parts[0], parts[1])
    + elif self.CTNParams and parts[0] == self.CTNParams[0]:
    + return self.CTNParams[1].getElementInfos(parts[0], parts[1])
    + else:
    + params = []
    + if self.CTNParams:
    + params.append(self.CTNParams[1].getElementInfos(self.CTNParams[0]))
    + return params
    +
    + def SetParamsAttribute(self, path, value):
    + self.ChangesToSave = True
    + # Filter IEC_Channel and Name, that have specific behavior
    + if path == "BaseParams.IEC_Channel":
    + old_leading = ".".join(map(str, self.GetCurrentLocation()))
    + new_value = self.FindNewIEC_Channel(value)
    + new_leading = ".".join(map(str, self.CTNParent.GetCurrentLocation() + (new_value,)))
    + self.GetCTRoot().UpdateProjectVariableLocation(old_leading, new_leading)
    + return new_value, True
    + elif path == "BaseParams.Name":
    + res = self.FindNewName(value)
    + self.CTNRequestSave()
    + return res, True
    +
    + parts = path.split(".", 1)
    + if self.MandatoryParams and parts[0] == self.MandatoryParams[0]:
    + self.MandatoryParams[1].setElementValue(parts[1], value)
    + elif self.CTNParams and parts[0] == self.CTNParams[0]:
    + self.CTNParams[1].setElementValue(parts[1], value)
    + return value, False
    +
    + def CTNMakeDir(self):
    + os.mkdir(self.CTNPath())
    +
    + def CTNRequestSave(self):
    + if self.GetCTRoot().CheckProjectPathPerm(False):
    + # If confnode do not have corresponding directory
    + ctnpath = self.CTNPath()
    + if not os.path.isdir(ctnpath):
    + # Create it
    + os.mkdir(ctnpath)
    +
    + # generate XML for base XML parameters controller of the confnode
    + if self.MandatoryParams:
    + BaseXMLFile = open(self.ConfNodeBaseXmlFilePath(),'w')
    + BaseXMLFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n")
    + BaseXMLFile.write(self.MandatoryParams[1].generateXMLText(self.MandatoryParams[0], 0).encode("utf-8"))
    + BaseXMLFile.close()
    +
    + # generate XML for XML parameters controller of the confnode
    + if self.CTNParams:
    + XMLFile = open(self.ConfNodeXmlFilePath(),'w')
    + XMLFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n")
    + XMLFile.write(self.CTNParams[1].generateXMLText(self.CTNParams[0], 0).encode("utf-8"))
    + XMLFile.close()
    +
    + # Call the confnode specific OnCTNSave method
    + result = self.OnCTNSave()
    + if not result:
    + return _("Error while saving \"%s\"\n")%self.CTNPath()
    +
    + # mark confnode as saved
    + self.ChangesToSave = False
    + # go through all children and do the same
    + for CTNChild in self.IterChildren():
    + result = CTNChild.CTNRequestSave()
    + if result:
    + return result
    + return None
    +
    + def CTNImport(self, src_CTNPath):
    + shutil.copytree(src_CTNPath, self.CTNPath)
    + return True
    +
    + def CTNGenerate_C(self, buildpath, locations):
    + """
    + Generate C code
    + @param locations: List of complete variables locations \
    + [{"IEC_TYPE" : the IEC type (i.e. "INT", "STRING", ...)
    + "NAME" : name of the variable (generally "__IW0_1_2" style)
    + "DIR" : direction "Q","I" or "M"
    + "SIZE" : size "X", "B", "W", "D", "L"
    + "LOC" : tuple of interger for IEC location (0,1,2,...)
    + }, ...]
    + @return: [(C_file_name, CFLAGS),...] , LDFLAGS_TO_APPEND
    + """
    + self.GetCTRoot().logger.write_warning(".".join(map(lambda x:str(x), self.GetCurrentLocation())) + " -> Nothing to do\n")
    + return [],"",False
    +
    + def _Generate_C(self, buildpath, locations):
    + # Generate confnodes [(Cfiles, CFLAGS)], LDFLAGS, DoCalls, extra_files
    + # extra_files = [(fname,fobject), ...]
    + gen_result = self.CTNGenerate_C(buildpath, locations)
    + CTNCFilesAndCFLAGS, CTNLDFLAGS, DoCalls = gen_result[:3]
    + extra_files = gen_result[3:]
    + # if some files have been generated put them in the list with their location
    + if CTNCFilesAndCFLAGS:
    + LocationCFilesAndCFLAGS = [(self.GetCurrentLocation(), CTNCFilesAndCFLAGS, DoCalls)]
    + else:
    + LocationCFilesAndCFLAGS = []
    +
    + # confnode asks for some LDFLAGS
    + if CTNLDFLAGS:
    + # LDFLAGS can be either string
    + if type(CTNLDFLAGS)==type(str()):
    + LDFLAGS=[CTNLDFLAGS]
    + #or list of strings
    + elif type(CTNLDFLAGS)==type(list()):
    + LDFLAGS=CTNLDFLAGS[:]
    + else:
    + LDFLAGS=[]
    +
    + # recurse through all children, and stack their results
    + for CTNChild in self.IECSortedChildren():
    + new_location = CTNChild.GetCurrentLocation()
    + # How deep are we in the tree ?
    + depth=len(new_location)
    + _LocationCFilesAndCFLAGS, _LDFLAGS, _extra_files = \
    + CTNChild._Generate_C(
    + #keep the same path
    + buildpath,
    + # filter locations that start with current IEC location
    + [loc for loc in locations if loc["LOC"][0:depth] == new_location ])
    + # stack the result
    + LocationCFilesAndCFLAGS += _LocationCFilesAndCFLAGS
    + LDFLAGS += _LDFLAGS
    + extra_files += _extra_files
    +
    + return LocationCFilesAndCFLAGS, LDFLAGS, extra_files
    +
    + def ConfNodeTypesFactory(self):
    + if self.LibraryControler is not None:
    + return [{"name" : self.CTNType, "types": self.LibraryControler.Project}]
    + return []
    +
    + def ParentsTypesFactory(self):
    + return self.CTNParent.ParentsTypesFactory() + self.ConfNodeTypesFactory()
    +
    + def ConfNodesTypesFactory(self):
    + list = self.ConfNodeTypesFactory()
    + for CTNChild in self.IterChildren():
    + list += CTNChild.ConfNodesTypesFactory()
    + return list
    +
    + def STLibraryFactory(self):
    + if self.LibraryControler is not None:
    + program, errors, warnings = self.LibraryControler.GenerateProgram()
    + return program + "\n"
    + return ""
    +
    + def ConfNodesSTLibraryFactory(self):
    + program = self.STLibraryFactory()
    + for CTNChild in self.IECSortedChildren():
    + program += CTNChild.ConfNodesSTLibraryFactory()
    + return program
    +
    + def IterChildren(self):
    + for CTNType, Children in self.Children.items():
    + for CTNInstance in Children:
    + yield CTNInstance
    +
    + def IECSortedChildren(self):
    + # reorder children by IEC_channels
    + ordered = [(chld.BaseParams.getIEC_Channel(),chld) for chld in self.IterChildren()]
    + if ordered:
    + ordered.sort()
    + return zip(*ordered)[1]
    + else:
    + return []
    +
    + def _GetChildBySomething(self, something, toks):
    + for CTNInstance in self.IterChildren():
    + # if match component of the name
    + if getattr(CTNInstance.BaseParams, something) == toks[0]:
    + # if Name have other components
    + if len(toks) >= 2:
    + # Recurse in order to find the latest object
    + return CTNInstance._GetChildBySomething( something, toks[1:])
    + # No sub name -> found
    + return CTNInstance
    + # Not found
    + return None
    +
    + def GetChildByName(self, Name):
    + if Name:
    + toks = Name.split('.')
    + return self._GetChildBySomething("Name", toks)
    + else:
    + return self
    +
    + def GetChildByIECLocation(self, Location):
    + if Location:
    + return self._GetChildBySomething("IEC_Channel", Location)
    + else:
    + return self
    +
    + def GetCurrentLocation(self):
    + """
    + @return: Tupple containing confnode IEC location of current confnode : %I0.0.4.5 => (0,0,4,5)
    + """
    + return self.CTNParent.GetCurrentLocation() + (self.BaseParams.getIEC_Channel(),)
    +
    + def GetCurrentName(self):
    + """
    + @return: String "ParentParentName.ParentName.Name"
    + """
    + return self.CTNParent._GetCurrentName() + self.BaseParams.getName()
    +
    + def _GetCurrentName(self):
    + """
    + @return: String "ParentParentName.ParentName.Name."
    + """
    + return self.CTNParent._GetCurrentName() + self.BaseParams.getName() + "."
    +
    + def GetCTRoot(self):
    + return self.CTNParent.GetCTRoot()
    +
    + def GetFullIEC_Channel(self):
    + return ".".join([str(i) for i in self.GetCurrentLocation()]) + ".x"
    +
    + def GetLocations(self):
    + location = self.GetCurrentLocation()
    + return [loc for loc in self.CTNParent.GetLocations() if loc["LOC"][0:len(location)] == location]
    +
    + def GetVariableLocationTree(self):
    + '''
    + This function is meant to be overridden by confnodes.
    +
    + It should returns an list of dictionaries
    +
    + - IEC_type is an IEC type like BOOL/BYTE/SINT/...
    + - location is a string of this variable's location, like "%IX0.0.0"
    + '''
    + children = []
    + for child in self.IECSortedChildren():
    + children.append(child.GetVariableLocationTree())
    + return {"name": self.BaseParams.getName(),
    + "type": LOCATION_CONFNODE,
    + "location": self.GetFullIEC_Channel(),
    + "children": children}
    +
    + def FindNewName(self, DesiredName):
    + """
    + Changes Name to DesiredName if available, Name-N if not.
    + @param DesiredName: The desired Name (string)
    + """
    + # Get Current Name
    + CurrentName = self.BaseParams.getName()
    + # Do nothing if no change
    + #if CurrentName == DesiredName: return CurrentName
    + # Build a list of used Name out of parent's Children
    + AllNames=[]
    + for CTNInstance in self.CTNParent.IterChildren():
    + if CTNInstance != self:
    + AllNames.append(CTNInstance.BaseParams.getName())
    +
    + # Find a free name, eventually appending digit
    + res = DesiredName
    + suffix = 1
    + while res in AllNames:
    + res = "%s-%d"%(DesiredName, suffix)
    + suffix += 1
    +
    + # Get old path
    + oldname = self.CTNPath()
    + # Check previous confnode existance
    + dontexist = self.BaseParams.getName() == "__unnamed__"
    + # Set the new name
    + self.BaseParams.setName(res)
    + # Rename confnode dir if exist
    + if not dontexist:
    + shutil.move(oldname, self.CTNPath())
    + # warn user he has two left hands
    + if DesiredName != res:
    + self.GetCTRoot().logger.write_warning(_("A child names \"%s\" already exist -> \"%s\"\n")%(DesiredName,res))
    + return res
    +
    + def GetAllChannels(self):
    + AllChannels=[]
    + for CTNInstance in self.CTNParent.IterChildren():
    + if CTNInstance != self:
    + AllChannels.append(CTNInstance.BaseParams.getIEC_Channel())
    + AllChannels.sort()
    + return AllChannels
    +
    + def FindNewIEC_Channel(self, DesiredChannel):
    + """
    + Changes IEC Channel number to DesiredChannel if available, nearest available if not.
    + @param DesiredChannel: The desired IEC channel (int)
    + """
    + # Get Current IEC channel
    + CurrentChannel = self.BaseParams.getIEC_Channel()
    + # Do nothing if no change
    + #if CurrentChannel == DesiredChannel: return CurrentChannel
    + # Build a list of used Channels out of parent's Children
    + AllChannels = self.GetAllChannels()
    +
    + # Now, try to guess the nearest available channel
    + res = DesiredChannel
    + while res in AllChannels: # While channel not free
    + if res < CurrentChannel: # Want to go down ?
    + res -= 1 # Test for n-1
    + if res < 0 :
    + self.GetCTRoot().logger.write_warning(_("Cannot find lower free IEC channel than %d\n")%CurrentChannel)
    + return CurrentChannel # Can't go bellow 0, do nothing
    + else : # Want to go up ?
    + res += 1 # Test for n-1
    + # Finally set IEC Channel
    + self.BaseParams.setIEC_Channel(res)
    + return res
    +
    + def _OpenView(self, name=None):
    + if self.EditorType is not None and self._View is None:
    + app_frame = self.GetCTRoot().AppFrame
    +
    + self._View = self.EditorType(app_frame.TabsOpened, self, app_frame)
    +
    + app_frame.EditProjectElement(self._View, self.CTNName())
    +
    + return self._View
    + return None
    +
    + def OnCloseEditor(self, view):
    + if self._View == view:
    + self._View = None
    +
    + def OnCTNClose(self):
    + if self._View is not None:
    + app_frame = self.GetCTRoot().AppFrame
    + if app_frame is not None:
    + app_frame.DeletePage(self._View)
    + return True
    +
    + def _doRemoveChild(self, CTNInstance):
    + # Remove all children of child
    + for SubCTNInstance in CTNInstance.IterChildren():
    + CTNInstance._doRemoveChild(SubCTNInstance)
    + # Call the OnCloseMethod
    + CTNInstance.OnCTNClose()
    + # Delete confnode dir
    + shutil.rmtree(CTNInstance.CTNPath())
    + # Remove child of Children
    + self.Children[CTNInstance.CTNType].remove(CTNInstance)
    + # Forget it... (View have to refresh)
    +
    + def CTNRemove(self):
    + # Fetch the confnode
    + #CTNInstance = self.GetChildByName(CTNName)
    + # Ask to his parent to remove it
    + self.CTNParent._doRemoveChild(self)
    +
    + def CTNAddChild(self, CTNName, CTNType, IEC_Channel=0):
    + """
    + Create the confnodes that may be added as child to this node self
    + @param CTNType: string desining the confnode class name (get name from CTNChildrenTypes)
    + @param CTNName: string for the name of the confnode instance
    + """
    + # reorganize self.CTNChildrenTypes tuples from (name, CTNClass, Help)
    + # to ( name, (CTNClass, Help)), an make a dict
    + transpose = zip(*self.CTNChildrenTypes)
    + CTNChildrenTypes = dict(zip(transpose[0],zip(transpose[1],transpose[2])))
    + # Check that adding this confnode is allowed
    + try:
    + CTNClass, CTNHelp = CTNChildrenTypes[CTNType]
    + except KeyError:
    + raise Exception, _("Cannot create child %s of type %s ")%(CTNName, CTNType)
    +
    + # if CTNClass is a class factory, call it. (prevent unneeded imports)
    + if type(CTNClass) == types.FunctionType:
    + CTNClass = CTNClass()
    +
    + # Eventualy Initialize child instance list for this class of confnode
    + ChildrenWithSameClass = self.Children.setdefault(CTNType, list())
    + # Check count
    + if getattr(CTNClass, "CTNMaxCount", None) and len(ChildrenWithSameClass) >= CTNClass.CTNMaxCount:
    + raise Exception, _("Max count (%d) reached for this confnode of type %s ")%(CTNClass.CTNMaxCount, CTNType)
    +
    + # create the final class, derived of provided confnode and template
    + class FinalCTNClass(CTNClass, ConfigTreeNode):
    + """
    + ConfNode class is derivated into FinalCTNClass before being instanciated
    + This way __init__ is overloaded to ensure ConfigTreeNode.__init__ is called
    + before CTNClass.__init__, and to do the file related stuff.
    + """
    + def __init__(_self):
    + # self is the parent
    + _self.CTNParent = self
    + # Keep track of the confnode type name
    + _self.CTNType = CTNType
    + # remind the help string, for more fancy display
    + _self.CTNHelp = CTNHelp
    + # Call the base confnode template init - change XSD into class members
    + ConfigTreeNode.__init__(_self)
    + # check name is unique
    + NewCTNName = _self.FindNewName(CTNName)
    + # If dir have already be made, and file exist
    + if os.path.isdir(_self.CTNPath(NewCTNName)): #and os.path.isfile(_self.ConfNodeXmlFilePath(CTNName)):
    + #Load the confnode.xml file into parameters members
    + _self.LoadXMLParams(NewCTNName)
    + # Basic check. Better to fail immediately.
    + if (_self.BaseParams.getName() != NewCTNName):
    + raise Exception, _("Project tree layout do not match confnode.xml %s!=%s ")%(NewCTNName, _self.BaseParams.getName())
    +
    + # Now, self.CTNPath() should be OK
    +
    + # Check that IEC_Channel is not already in use.
    + _self.FindNewIEC_Channel(_self.BaseParams.getIEC_Channel())
    + # Call the confnode real __init__
    + if getattr(CTNClass, "__init__", None):
    + CTNClass.__init__(_self)
    + #Load and init all the children
    + _self.LoadChildren()
    + #just loaded, nothing to saved
    + _self.ChangesToSave = False
    + else:
    + # If confnode do not have corresponding file/dirs - they will be created on Save
    + _self.CTNMakeDir()
    + # Find an IEC number
    + _self.FindNewIEC_Channel(IEC_Channel)
    + # Call the confnode real __init__
    + if getattr(CTNClass, "__init__", None):
    + CTNClass.__init__(_self)
    + _self.CTNRequestSave()
    + #just created, must be saved
    + _self.ChangesToSave = True
    +
    + def _getBuildPath(_self):
    + return self._getBuildPath()
    +
    + # Create the object out of the resulting class
    + newConfNodeOpj = FinalCTNClass()
    + # Store it in CTNgedChils
    + ChildrenWithSameClass.append(newConfNodeOpj)
    +
    + return newConfNodeOpj
    +
    + def ClearChildren(self):
    + for child in self.IterChildren():
    + child.ClearChildren()
    + self.Children = {}
    +
    + def LoadSTLibrary(self):
    + # Get library blocks if plcopen library exist
    + library_path = self.ConfNodeLibraryFilePath()
    + if os.path.isfile(library_path):
    + self.LibraryControler = PLCControler()
    + self.LibraryControler.OpenXMLFile(library_path)
    + self.LibraryControler.ClearConfNodeTypes()
    + self.LibraryControler.AddConfNodeTypesList(self.ParentsTypesFactory())
    +
    + def LoadXMLParams(self, CTNName = None):
    + methode_name = os.path.join(self.CTNPath(CTNName), "methods.py")
    + if os.path.isfile(methode_name):
    + execfile(methode_name)
    +
    + # Get the base xml tree
    + if self.MandatoryParams:
    + try:
    + basexmlfile = open(self.ConfNodeBaseXmlFilePath(CTNName), 'r')
    + basetree = minidom.parse(basexmlfile)
    + self.MandatoryParams[1].loadXMLTree(basetree.childNodes[0])
    + basexmlfile.close()
    + except Exception, exc:
    + self.GetCTRoot().logger.write_error(_("Couldn't load confnode base parameters %s :\n %s") % (CTNName, str(exc)))
    + self.GetCTRoot().logger.write_error(traceback.format_exc())
    +
    + # Get the xml tree
    + if self.CTNParams:
    + try:
    + xmlfile = open(self.ConfNodeXmlFilePath(CTNName), 'r')
    + tree = minidom.parse(xmlfile)
    + self.CTNParams[1].loadXMLTree(tree.childNodes[0])
    + xmlfile.close()
    + except Exception, exc:
    + self.GetCTRoot().logger.write_error(_("Couldn't load confnode parameters %s :\n %s") % (CTNName, str(exc)))
    + self.GetCTRoot().logger.write_error(traceback.format_exc())
    +
    + def LoadChildren(self):
    + # Iterate over all CTNName@CTNType in confnode directory, and try to open them
    + for CTNDir in os.listdir(self.CTNPath()):
    + if os.path.isdir(os.path.join(self.CTNPath(), CTNDir)) and \
    + CTNDir.count(NameTypeSeparator) == 1:
    + pname, ptype = CTNDir.split(NameTypeSeparator)
    + try:
    + self.CTNAddChild(pname, ptype)
    + except Exception, exc:
    + self.GetCTRoot().logger.write_error(_("Could not add child \"%s\", type %s :\n%s\n")%(pname, ptype, str(exc)))
    + self.GetCTRoot().logger.write_error(traceback.format_exc())
    +
    + def EnableMethod(self, method, value):
    + for d in self.ConfNodeMethods:
    + if d["method"]==method:
    + d["enabled"]=value
    + return True
    + return False
    +
    + def ShowMethod(self, method, value):
    + for d in self.ConfNodeMethods:
    + if d["method"]==method:
    + d["shown"]=value
    + return True
    + return False
    +
    + def CallMethod(self, method):
    + for d in self.ConfNodeMethods:
    + if d["method"]==method and d.get("enabled", True) and d.get("shown", True):
    + getattr(self, method)()
    +
    --- a/LPCBeremiz.py Tue May 08 22:27:49 2012 +0200
    +++ b/LPCBeremiz.py Wed May 09 00:00:50 2012 +0200
    @@ -59,7 +59,10 @@
    __builtin__.__dict__['_'] = wx.GetTranslation#unicode_translation
    from Beremiz import *
    -from ConfigTree import ConfigTreeRoot, ConfigTreeNode, opjimg, connectors
    +from ProjectController import ProjectController
    +from ConfigTreeNode import ConfigTreeNode
    +import connectors
    +from util import opjimg
    from plcopen.structures import LOCATIONDATATYPES
    from PLCControler import LOCATION_CONFNODE, LOCATION_MODULE, LOCATION_GROUP,\
    LOCATION_VAR_INPUT, LOCATION_VAR_OUTPUT, LOCATION_VAR_MEMORY
    @@ -456,7 +459,7 @@
    #-------------------------------------------------------------------------------
    -# LPCConfigTreeRoot Class
    +# LPCProjectController Class
    #-------------------------------------------------------------------------------
    def mycopytree(src, dst):
    @@ -479,7 +482,7 @@
    [SIMULATION_MODE, TRANSFER_MODE] = range(2)
    -class LPCConfigTreeRoot(ConfigTreeRoot):
    +class LPCProjectController(ProjectController):
    ConfNodeMethods = [
    {"bitmap" : opjimg("Debug"),
    @@ -510,7 +513,7 @@
    def __init__(self, frame, logger, buildpath):
    self.OrigBuildPath = buildpath
    - ConfigTreeRoot.__init__(self, frame, logger)
    + ProjectController.__init__(self, frame, logger)
    if havecanfestival:
    self.CTNChildrenTypes += [("LPCBus", LPCBus, "LPC bus"), ("CanOpen", LPCCanOpen, "CanOpen bus")]
    @@ -532,19 +535,19 @@
    if self.OrigBuildPath is not None:
    return os.path.join(self.OrigBuildPath, "pous.xml")
    else:
    - return ConfigTreeRoot.ConfNodeLibraryFilePath(self)
    + return ProjectController.ConfNodeLibraryFilePath(self)
    def GetProjectName(self):
    return self.Project.getname()
    def GetDefaultTargetName(self):
    if self.CurrentMode == SIMULATION_MODE:
    - return ConfigTreeRoot.GetDefaultTargetName(self)
    + return ProjectController.GetDefaultTargetName(self)
    else:
    return "LPC"
    def GetTarget(self):
    - target = ConfigTreeRoot.GetTarget(self)
    + target = ProjectController.GetTarget(self)
    if self.CurrentMode != SIMULATION_MODE:
    target.getcontent()["value"].setBuildPath(self.BuildPath)
    return target
    @@ -555,7 +558,7 @@
    self.SimulationBuildPath = os.path.join(tempfile.mkdtemp(), os.path.basename(self.ProjectPath), "build")
    return self.SimulationBuildPath
    else:
    - return ConfigTreeRoot._getBuildPath(self)
    + return ProjectController._getBuildPath(self)
    def _Build(self):
    save = self.ProjectTestModified()
    @@ -564,7 +567,7 @@
    self.AppFrame._Refresh(TITLE, FILEMENU)
    if self.BuildPath is not None:
    mycopytree(self.OrigBuildPath, self.BuildPath)
    - ConfigTreeRoot._Build(self)
    + ProjectController._Build(self)
    if save:
    wx.CallAfter(self.AppFrame.RefreshAll)
    @@ -970,7 +973,7 @@
    self.ApplyOnlineMode()
    def _Stop(self):
    - ConfigTreeRoot._Stop(self)
    + ProjectController._Stop(self)
    if self.CurrentMode == SIMULATION_MODE:
    self.StopSimulation()
    @@ -1001,7 +1004,7 @@
    if self.CurrentMode is None and self.OnlineMode != "OFF":
    self.CurrentMode = TRANSFER_MODE
    - if ConfigTreeRoot._Build(self):
    + if ProjectController._Build(self):
    ID_ABORTTRANSFERTIMER = wx.NewId()
    self.AbortTransferTimer = wx.Timer(self.AppFrame, ID_ABORTTRANSFERTIMER)
    @@ -1023,7 +1026,7 @@
    self.logger.write(_("Start PLC transfer\n"))
    self.AbortTransferTimer.Stop()
    - ConfigTreeRoot._Transfer(self)
    + ProjectController._Transfer(self)
    self.AbortTransferTimer.Start(milliseconds=5000, oneShot=True)
    def AbortTransfer(self, event):
    @@ -1743,7 +1746,7 @@
    Log = StdoutPseudoFile(port)
    - CTR = LPCConfigTreeRoot(None, Log, buildpath)
    + CTR = LPCProjectController(None, Log, buildpath)
    if projectOpen is not None and os.path.isdir(projectOpen):
    result = CTR.LoadProject(projectOpen)
    if result:
    --- /dev/null Thu Jan 01 00:00:00 1970 +0000
    +++ b/ProjectController.py Wed May 09 00:00:50 2012 +0200
    @@ -0,0 +1,1359 @@
    +"""
    +Base definitions for beremiz confnodes
    +"""
    +
    +import os,sys,traceback
    +import time
    +import features
    +import shutil
    +import wx
    +import re, tempfile
    +from threading import Timer, Lock, Thread
    +from time import localtime
    +from datetime import datetime
    +from weakref import WeakKeyDictionary
    +
    +import targets
    +import connectors
    +from util import MiniTextControler, opjimg, CheckPathPerm, GetClassImporter
    +from ProcessLogger import ProcessLogger
    +from PLCControler import PLCControler
    +from PLCOpenEditor import ProjectDialog
    +from TextViewer import TextViewer
    +from plcopen.structures import IEC_KEYWORDS
    +from targets.typemapping import DebugTypesSize
    +from discovery import DiscoveryDialog
    +from ConfigTreeNode import ConfigTreeNode
    +
    +base_folder = os.path.split(sys.path[0])[0]
    +
    +MATIEC_ERROR_MODEL = re.compile(".*\.st:(\d+)-(\d+)\.\.(\d+)-(\d+): error : (.*)$")
    +
    +DEBUG_RETRIES_WARN = 3
    +DEBUG_RETRIES_REREGISTER = 4
    +
    +class ProjectController(ConfigTreeNode, PLCControler):
    + """
    + This class define Root object of the confnode tree.
    + It is responsible of :
    + - Managing project directory
    + - Building project
    + - Handling PLCOpenEditor controler and view
    + - Loading user confnodes and instanciante them as children
    + - ...
    +
    + """
    +
    + # For root object, available Children Types are modules of the confnode packages.
    + CTNChildrenTypes = [(n, GetClassImporter(c), d) for n,d,h,c in features.catalog]
    +
    + XSD = """<?xml version="1.0" encoding="ISO-8859-1" ?>
    + <xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema">
    + <xsd:element name="BeremizRoot">
    + <xsd:complexType>
    + <xsd:sequence>
    + <xsd:element name="TargetType">
    + <xsd:complexType>
    + <xsd:choice minOccurs="0">
    + """+targets.targetchoices+"""
    + </xsd:choice>
    + </xsd:complexType>
    + </xsd:element>
    + </xsd:sequence>
    + <xsd:attribute name="URI_location" type="xsd:string" use="optional" default=""/>
    + <xsd:attribute name="Enable_ConfNodes" type="xsd:boolean" use="optional" default="true"/>
    + </xsd:complexType>
    + </xsd:element>
    + </xsd:schema>
    + """
    +
    + def __init__(self, frame, logger):
    + PLCControler.__init__(self)
    +
    + self.MandatoryParams = None
    + self.SetAppFrame(frame, logger)
    + self._builder = None
    + self._connector = None
    +
    + self.iec2c_path = os.path.join(base_folder, "matiec", "iec2c"+(".exe" if wx.Platform == '__WXMSW__' else ""))
    + self.ieclib_path = os.path.join(base_folder, "matiec", "lib")
    +
    + # Setup debug information
    + self.IECdebug_datas = {}
    + self.IECdebug_lock = Lock()
    +
    + self.DebugTimer=None
    + self.ResetIECProgramsAndVariables()
    +
    + #This method are not called here... but in NewProject and OpenProject
    + #self._AddParamsMembers()
    + #self.Children = {}
    +
    + # In both new or load scenario, no need to save
    + self.ChangesToSave = False
    + # root have no parent
    + self.CTNParent = None
    + # Keep track of the confnode type name
    + self.CTNType = "Beremiz"
    + self.Children = {}
    + # After __init__ root confnode is not valid
    + self.ProjectPath = None
    + self._setBuildPath(None)
    + self.DebugThread = None
    + self.debug_break = False
    + self.previous_plcstate = None
    + # copy ConfNodeMethods so that it can be later customized
    + self.ConfNodeMethods = [dic.copy() for dic in self.ConfNodeMethods]
    + self.LoadSTLibrary()
    +
    + def __del__(self):
    + if self.DebugTimer:
    + self.DebugTimer.cancel()
    + self.KillDebugThread()
    +
    + def SetAppFrame(self, frame, logger):
    + self.AppFrame = frame
    + self.logger = logger
    + self.StatusTimer = None
    +
    + if frame is not None:
    + # Timer to pull PLC status
    + ID_STATUSTIMER = wx.NewId()
    + self.StatusTimer = wx.Timer(self.AppFrame, ID_STATUSTIMER)
    + self.AppFrame.Bind(wx.EVT_TIMER, self.PullPLCStatusProc, self.StatusTimer)
    +
    + self.RefreshConfNodesBlockLists()
    +
    + def ResetAppFrame(self, logger):
    + if self.AppFrame is not None:
    + self.AppFrame.Unbind(wx.EVT_TIMER, self.StatusTimer)
    + self.StatusTimer = None
    + self.AppFrame = None
    +
    + self.logger = logger
    +
    + def ConfNodeLibraryFilePath(self):
    + return os.path.join(os.path.split(__file__)[0], "pous.xml")
    +
    + def CTNTestModified(self):
    + return self.ChangesToSave or not self.ProjectIsSaved()
    +
    + def CTNFullName(self):
    + return ""
    +
    + def GetCTRoot(self):
    + return self
    +
    + def GetIECLibPath(self):
    + return self.ieclib_path
    +
    + def GetIEC2cPath(self):
    + return self.iec2c_path
    +
    + def GetCurrentLocation(self):
    + return ()
    +
    + def GetCurrentName(self):
    + return ""
    +
    + def _GetCurrentName(self):
    + return ""
    +
    + def GetProjectPath(self):
    + return self.ProjectPath
    +
    + def GetProjectName(self):
    + return os.path.split(self.ProjectPath)[1]
    +
    + def GetDefaultTargetName(self):
    + if wx.Platform == '__WXMSW__':
    + return "Win32"
    + else:
    + return "Linux"
    +
    + def GetTarget(self):
    + target = self.BeremizRoot.getTargetType()
    + if target.getcontent() is None:
    + target = self.Classes["BeremizRoot_TargetType"]()
    + target_name = self.GetDefaultTargetName()
    + target.setcontent({"name": target_name, "value": self.Classes["TargetType_%s"%target_name]()})
    + return target
    +
    + def GetParamsAttributes(self, path = None):
    + params = ConfigTreeNode.GetParamsAttributes(self, path)
    + if params[0]["name"] == "BeremizRoot":
    + for child in params[0]["children"]:
    + if child["name"] == "TargetType" and child["value"] == '':
    + child.update(self.GetTarget().getElementInfos("TargetType"))
    + return params
    +
    + def SetParamsAttribute(self, path, value):
    + if path.startswith("BeremizRoot.TargetType.") and self.BeremizRoot.getTargetType().getcontent() is None:
    + self.BeremizRoot.setTargetType(self.GetTarget())
    + return ConfigTreeNode.SetParamsAttribute(self, path, value)
    +
    + # helper func to check project path write permission
    + def CheckProjectPathPerm(self, dosave=True):
    + if CheckPathPerm(self.ProjectPath):
    + return True
    + dialog = wx.MessageDialog(self.AppFrame,
    + _('You must have permission to work on the project\nWork on a project copy ?'),
    + _('Error'),
    + wx.YES_NO | wx.NO_DEFAULT | wx.ICON_QUESTION)
    + answer = dialog.ShowModal()
    + dialog.Destroy()
    + if answer == wx.ID_YES:
    + if self.SaveProjectAs():
    + self.AppFrame.RefreshAll()
    + self.AppFrame.RefreshTitle()
    + self.AppFrame.RefreshFileMenu()
    + return True
    + return False
    +
    + def NewProject(self, ProjectPath, BuildPath=None):
    + """
    + Create a new project in an empty folder
    + @param ProjectPath: path of the folder where project have to be created
    + @param PLCParams: properties of the PLCOpen program created
    + """
    + # Verify that chosen folder is empty
    + if not os.path.isdir(ProjectPath) or len(os.listdir(ProjectPath)) > 0:
    + return _("Chosen folder isn't empty. You can't use it for a new project!")
    +
    + dialog = ProjectDialog(self.AppFrame)
    + if dialog.ShowModal() == wx.ID_OK:
    + values = dialog.GetValues()
    + values["creationDateTime"] = datetime(*localtime()[:6])
    + dialog.Destroy()
    + else:
    + dialog.Destroy()
    + return _("Project not created")
    +
    + # Create PLCOpen program
    + self.CreateNewProject(values)
    + # Change XSD into class members
    + self._AddParamsMembers()
    + self.Children = {}
    + # Keep track of the root confnode (i.e. project path)
    + self.ProjectPath = ProjectPath
    + self._setBuildPath(BuildPath)
    + # get confnodes bloclist (is that usefull at project creation?)
    + self.RefreshConfNodesBlockLists()
    + # this will create files base XML files
    + self.SaveProject()
    + return None
    +
    + def LoadProject(self, ProjectPath, BuildPath=None):
    + """
    + Load a project contained in a folder
    + @param ProjectPath: path of the project folder
    + """
    + if os.path.basename(ProjectPath) == "":
    + ProjectPath = os.path.dirname(ProjectPath)
    + # Verify that project contains a PLCOpen program
    + plc_file = os.path.join(ProjectPath, "plc.xml")
    + if not os.path.isfile(plc_file):
    + return _("Chosen folder doesn't contain a program. It's not a valid project!")
    + # Load PLCOpen file
    + result = self.OpenXMLFile(plc_file)
    + if result:
    + return result
    + # Change XSD into class members
    + self._AddParamsMembers()
    + self.Children = {}
    + # Keep track of the root confnode (i.e. project path)
    + self.ProjectPath = ProjectPath
    + self._setBuildPath(BuildPath)
    + # If dir have already be made, and file exist
    + if os.path.isdir(self.CTNPath()) and os.path.isfile(self.ConfNodeXmlFilePath()):
    + #Load the confnode.xml file into parameters members
    + result = self.LoadXMLParams()
    + if result:
    + return result
    + #Load and init all the children
    + self.LoadChildren()
    + self.RefreshConfNodesBlockLists()
    +
    + if os.path.exists(self._getBuildPath()):
    + self.EnableMethod("_Clean", True)
    +
    + if os.path.isfile(self._getIECrawcodepath()):
    + self.ShowMethod("_showIECcode", True)
    +
    + return None
    +
    + def CloseProject(self):
    + self.ClearChildren()
    + self.ResetAppFrame(None)
    +
    + def SaveProject(self):
    + if self.CheckProjectPathPerm(False):
    + self.SaveXMLFile(os.path.join(self.ProjectPath, 'plc.xml'))
    + result = self.CTNRequestSave()
    + if result:
    + self.logger.write_error(result)
    +
    + def SaveProjectAs(self, dosave=True):
    + # Ask user to choose a path with write permissions
    + if wx.Platform == '__WXMSW__':
    + path = os.getenv("USERPROFILE")
    + else:
    + path = os.getenv("HOME")
    + dirdialog = wx.DirDialog(self.AppFrame , _("Choose a directory to save project"), path, wx.DD_NEW_DIR_BUTTON)
    + answer = dirdialog.ShowModal()
    + dirdialog.Destroy()
    + if answer == wx.ID_OK:
    + newprojectpath = dirdialog.GetPath()
    + if os.path.isdir(newprojectpath):
    + self.ProjectPath = newprojectpath
    + if dosave:
    + self.SaveProject()
    + self._setBuildPath(self.BuildPath)
    + return True
    + return False
    +
    + # Update PLCOpenEditor ConfNode Block types from loaded confnodes
    + def RefreshConfNodesBlockLists(self):
    + if getattr(self, "Children", None) is not None:
    + self.ClearConfNodeTypes()
    + self.AddConfNodeTypesList(self.ConfNodesTypesFactory())
    + if self.AppFrame is not None:
    + self.AppFrame.RefreshLibraryPanel()
    + self.AppFrame.RefreshEditor()
    +
    + # Update a PLCOpenEditor Pou variable location
    + def UpdateProjectVariableLocation(self, old_leading, new_leading):
    + self.Project.updateElementAddress(old_leading, new_leading)
    + self.BufferProject()
    + if self.AppFrame is not None:
    + self.AppFrame.RefreshTitle()
    + self.AppFrame.RefreshInstancesTree()
    + self.AppFrame.RefreshFileMenu()
    + self.AppFrame.RefreshEditMenu()
    + self.AppFrame.RefreshEditor()
    +
    + def GetVariableLocationTree(self):
    + '''
    + This function is meant to be overridden by confnodes.
    +
    + It should returns an list of dictionaries
    +
    + - IEC_type is an IEC type like BOOL/BYTE/SINT/...
    + - location is a string of this variable's location, like "%IX0.0.0"
    + '''
    + children = []
    + for child in self.IECSortedChildren():
    + children.append(child.GetVariableLocationTree())
    + return children
    +
    + def ConfNodePath(self):
    + return os.path.split(__file__)[0]
    +
    + def CTNPath(self, CTNName=None):
    + return self.ProjectPath
    +
    + def ConfNodeXmlFilePath(self, CTNName=None):
    + return os.path.join(self.CTNPath(CTNName), "beremiz.xml")
    +
    + def ParentsTypesFactory(self):
    + return self.ConfNodeTypesFactory()
    +
    + def _setBuildPath(self, buildpath):
    + if CheckPathPerm(buildpath):
    + self.BuildPath = buildpath
    + else:
    + self.BuildPath = None
    + self.BuildPath = buildpath
    + self.DefaultBuildPath = None
    + if self._builder is not None:
    + self._builder.SetBuildPath(self._getBuildPath())
    +
    + def _getBuildPath(self):
    + # BuildPath is defined by user
    + if self.BuildPath is not None:
    + return self.BuildPath
    + # BuildPath isn't defined by user but already created by default
    + if self.DefaultBuildPath is not None:
    + return self.DefaultBuildPath
    + # Create a build path in project folder if user has permissions
    + if CheckPathPerm(self.ProjectPath):
    + self.DefaultBuildPath = os.path.join(self.ProjectPath, "build")
    + # Create a build path in temp folder
    + else:
    + self.DefaultBuildPath = os.path.join(tempfile.mkdtemp(), os.path.basename(self.ProjectPath), "build")
    +
    + if not os.path.exists(self.DefaultBuildPath):
    + os.makedirs(self.DefaultBuildPath)
    + return self.DefaultBuildPath
    +
    + def _getExtraFilesPath(self):
    + return os.path.join(self._getBuildPath(), "extra_files")
    +
    + def _getIECcodepath(self):
    + # define name for IEC code file
    + return os.path.join(self._getBuildPath(), "plc.st")
    +
    + def _getIECgeneratedcodepath(self):
    + # define name for IEC generated code file
    + return os.path.join(self._getBuildPath(), "generated_plc.st")
    +
    + def _getIECrawcodepath(self):
    + # define name for IEC raw code file
    + return os.path.join(self.CTNPath(), "raw_plc.st")
    +
    + def GetLocations(self):
    + locations = []
    + filepath = os.path.join(self._getBuildPath(),"LOCATED_VARIABLES.h")
    + if os.path.isfile(filepath):
    + # IEC2C compiler generate a list of located variables : LOCATED_VARIABLES.h
    + location_file = open(os.path.join(self._getBuildPath(),"LOCATED_VARIABLES.h"))
    + # each line of LOCATED_VARIABLES.h declares a located variable
    + lines = [line.strip() for line in location_file.readlines()]
    + # This regular expression parses the lines genereated by IEC2C
    + LOCATED_MODEL = re.compile("__LOCATED_VAR\((?P<IEC_TYPE>[A-Z]*),(?P<NAME>[_A-Za-z0-9]*),(?P<DIR>[QMI])(?:,(?P<SIZE>[XBWDL]))?,(?P<LOC>[,0-9]*)\)")
    + for line in lines:
    + # If line match RE,
    + result = LOCATED_MODEL.match(line)
    + if result:
    + # Get the resulting dict
    + resdict = result.groupdict()
    + # rewrite string for variadic location as a tuple of integers
    + resdict['LOC'] = tuple(map(int,resdict['LOC'].split(',')))
    + # set located size to 'X' if not given
    + if not resdict['SIZE']:
    + resdict['SIZE'] = 'X'
    + # finally store into located variable list
    + locations.append(resdict)
    + return locations
    +
    + def _Generate_SoftPLC(self):
    + """
    + Generate SoftPLC ST/IL/SFC code out of PLCOpenEditor controller, and compile it with IEC2C
    + @param buildpath: path where files should be created
    + """
    +
    + # Update PLCOpenEditor ConfNode Block types before generate ST code
    + self.RefreshConfNodesBlockLists()
    +
    + self.logger.write(_("Generating SoftPLC IEC-61131 ST/IL/SFC code...\n"))
    + buildpath = self._getBuildPath()
    + # ask PLCOpenEditor controller to write ST/IL/SFC code file
    + program, errors, warnings = self.GenerateProgram(self._getIECgeneratedcodepath())
    + if len(warnings) > 0:
    + self.logger.write_warning(_("Warnings in ST/IL/SFC code generator :\n"))
    + for warning in warnings:
    + self.logger.write_warning("%s\n"%warning)
    + if len(errors) > 0:
    + # Failed !
    + self.logger.write_error(_("Error in ST/IL/SFC code generator :\n%s\n")%errors[0])
    + return False
    + plc_file = open(self._getIECcodepath(), "w")
    + # Add ST Library from confnodes
    + plc_file.write(self.ConfNodesSTLibraryFactory())
    + if os.path.isfile(self._getIECrawcodepath()):
    + plc_file.write(open(self._getIECrawcodepath(), "r").read())
    + plc_file.write("\n")
    + plc_file.close()
    + plc_file = open(self._getIECcodepath(), "r")
    + self.ProgramOffset = 0
    + for line in plc_file.xreadlines():
    + self.ProgramOffset += 1
    + plc_file.close()
    + plc_file = open(self._getIECcodepath(), "a")
    + plc_file.write(open(self._getIECgeneratedcodepath(), "r").read())
    + plc_file.close()
    +
    + self.logger.write(_("Compiling IEC Program into C code...\n"))
    +
    + # Now compile IEC code into many C files
    + # files are listed to stdout, and errors to stderr.
    + status, result, err_result = ProcessLogger(
    + self.logger,
    + "\"%s\" -f -I \"%s\" -T \"%s\" \"%s\""%(
    + self.iec2c_path,
    + self.ieclib_path,
    + buildpath,
    + self._getIECcodepath()),
    + no_stdout=True, no_stderr=True).spin()
    + if status:
    + # Failed !
    +
    + # parse iec2c's error message. if it contains a line number,
    + # then print those lines from the generated IEC file.
    + for err_line in err_result.split('\n'):
    + self.logger.write_warning(err_line + "\n")
    +
    + m_result = MATIEC_ERROR_MODEL.match(err_line)
    + if m_result is not None:
    + first_line, first_column, last_line, last_column, error = m_result.groups()
    + first_line, last_line = int(first_line), int(last_line)
    +
    + last_section = None
    + f = open(self._getIECcodepath())
    +
    + for i, line in enumerate(f.readlines()):
    + i = i + 1
    + if line[0] not in '\t \r\n':
    + last_section = line
    +
    + if first_line <= i <= last_line:
    + if last_section is not None:
    + self.logger.write_warning("In section: " + last_section)
    + last_section = None # only write section once
    + self.logger.write_warning("%04d: %s" % (i, line))
    +
    + f.close()
    +
    + self.logger.write_error(_("Error : IEC to C compiler returned %d\n")%status)
    + return False
    +
    + # Now extract C files of stdout
    + C_files = [ fname for fname in result.splitlines() if fname[-2:]==".c" or fname[-2:]==".C" ]
    + # remove those that are not to be compiled because included by others
    + C_files.remove("POUS.c")
    + if not C_files:
    + self.logger.write_error(_("Error : At least one configuration and one resource must be declared in PLC !\n"))
    + return False
    + # transform those base names to full names with path
    + C_files = map(lambda filename:os.path.join(buildpath, filename), C_files)
    + self.logger.write(_("Extracting Located Variables...\n"))
    + # Keep track of generated located variables for later use by self._Generate_C
    + self.PLCGeneratedLocatedVars = self.GetLocations()
    + # Keep track of generated C files for later use by self.CTNGenerate_C
    + self.PLCGeneratedCFiles = C_files
    + # compute CFLAGS for plc
    + self.plcCFLAGS = "\"-I"+self.ieclib_path+"\""
    + return True
    +
    + def GetBuilder(self):
    + """
    + Return a Builder (compile C code into machine code)
    + """
    + # Get target, module and class name
    + targetname = self.GetTarget().getcontent()["name"]
    + modulename = "targets." + targetname
    + classname = targetname + "_target"
    +
    + # Get module reference
    + try :
    + targetmodule = getattr(__import__(modulename), targetname)
    +
    + except Exception, msg:
    + self.logger.write_error(_("Can't find module for target %s!\n")%targetname)
    + self.logger.write_error(str(msg))
    + return None
    +
    + # Get target class
    + targetclass = getattr(targetmodule, classname)
    +
    + # if target already
    + if self._builder is None or not isinstance(self._builder,targetclass):
    + # Get classname instance
    + self._builder = targetclass(self)
    + return self._builder
    +
    + def ResetBuildMD5(self):
    + builder=self.GetBuilder()
    + if builder is not None:
    + builder.ResetBinaryCodeMD5()
    + self.EnableMethod("_Transfer", False)
    +
    + def GetLastBuildMD5(self):
    + builder=self.GetBuilder()
    + if builder is not None:
    + return builder.GetBinaryCodeMD5()
    + else:
    + return None
    +
    + #######################################################################
    + #
    + # C CODE GENERATION METHODS
    + #
    + #######################################################################
    +
    + def CTNGenerate_C(self, buildpath, locations):
    + """
    + Return C code generated by iec2c compiler
    + when _generate_softPLC have been called
    + @param locations: ignored
    + @return: [(C_file_name, CFLAGS),...] , LDFLAGS_TO_APPEND
    + """
    +
    + return ([(C_file_name, self.plcCFLAGS)
    + for C_file_name in self.PLCGeneratedCFiles ],
    + "", # no ldflags
    + False) # do not expose retreive/publish calls
    +
    + def ResetIECProgramsAndVariables(self):
    + """
    + Reset variable and program list that are parsed from
    + CSV file generated by IEC2C compiler.
    + """
    + self._ProgramList = None
    + self._VariablesList = None
    + self._IECPathToIdx = {}
    + self._Ticktime = 0
    + self.TracedIECPath = []
    +
    + def GetIECProgramsAndVariables(self):
    + """
    + Parse CSV-like file VARIABLES.csv resulting from IEC2C compiler.
    + Each section is marked with a line staring with '//'
    + list of all variables used in various POUs
    + """
    + if self._ProgramList is None or self._VariablesList is None:
    + try:
    + csvfile = os.path.join(self._getBuildPath(),"VARIABLES.csv")
    + # describes CSV columns
    + ProgramsListAttributeName = ["num", "C_path", "type"]
    + VariablesListAttributeName = ["num", "vartype", "IEC_path", "C_path", "type"]
    + self._ProgramList = []
    + self._VariablesList = []
    + self._IECPathToIdx = {}
    +
    + # Separate sections
    + ListGroup = []
    + for line in open(csvfile,'r').xreadlines():
    + strippedline = line.strip()
    + if strippedline.startswith("//"):
    + # Start new section
    + ListGroup.append([])
    + elif len(strippedline) > 0 and len(ListGroup) > 0:
    + # append to this section
    + ListGroup[-1].append(strippedline)
    +
    + # first section contains programs
    + for line in ListGroup[0]:
    + # Split and Maps each field to dictionnary entries
    + attrs = dict(zip(ProgramsListAttributeName,line.strip().split(';')))
    + # Truncate "C_path" to remove conf an ressources names
    + attrs["C_path"] = '__'.join(attrs["C_path"].split(".",2)[1:])
    + # Push this dictionnary into result.
    + self._ProgramList.append(attrs)
    +
    + # second section contains all variables
    + for line in ListGroup[1]:
    + # Split and Maps each field to dictionnary entries
    + attrs = dict(zip(VariablesListAttributeName,line.strip().split(';')))
    + # Truncate "C_path" to remove conf an ressources names
    + parts = attrs["C_path"].split(".",2)
    + if len(parts) > 2:
    + attrs["C_path"] = '__'.join(parts[1:])
    + else:
    + attrs["C_path"] = '__'.join(parts)
    + # Push this dictionnary into result.
    + self._VariablesList.append(attrs)
    + # Fill in IEC<->C translation dicts
    + IEC_path=attrs["IEC_path"]
    + Idx=int(attrs["num"])
    + self._IECPathToIdx[IEC_path]=(Idx, attrs["type"])
    +
    + # third section contains ticktime
    + if len(ListGroup) > 2:
    + self._Ticktime = int(ListGroup[2][0])
    +
    + except Exception,e:
    + self.logger.write_error(_("Cannot open/parse VARIABLES.csv!\n"))
    + self.logger.write_error(traceback.format_exc())
    + self.ResetIECProgramsAndVariables()
    + return False
    +
    + return True
    +
    + def Generate_plc_debugger(self):
    + """
    + Generate trace/debug code out of PLC variable list
    + """
    + self.GetIECProgramsAndVariables()
    +
    + # prepare debug code
    + debug_code = targets.code("plc_debug") % {
    + "buffer_size": reduce(lambda x, y: x + y, [DebugTypesSize.get(v["type"], 0) for v in self._VariablesList], 0),
    + "programs_declarations":
    + "\n".join(["extern %(type)s %(C_path)s;"%p for p in self._ProgramList]),
    + "extern_variables_declarations":"\n".join([
    + {"EXT":"extern __IEC_%(type)s_p %(C_path)s;",
    + "IN":"extern __IEC_%(type)s_p %(C_path)s;",
    + "MEM":"extern __IEC_%(type)s_p %(C_path)s;",
    + "OUT":"extern __IEC_%(type)s_p %(C_path)s;",
    + "VAR":"extern __IEC_%(type)s_t %(C_path)s;"}[v["vartype"]]%v
    + for v in self._VariablesList if v["vartype"] != "FB" and v["C_path"].find('.')<0]),
    + "for_each_variable_do_code":"\n".join([
    + {"EXT":" (*fp)((void*)&%(C_path)s,%(type)s_P_ENUM);\n",
    + "IN":" (*fp)((void*)&%(C_path)s,%(type)s_P_ENUM);\n",
    + "MEM":" (*fp)((void*)&%(C_path)s,%(type)s_O_ENUM);\n",
    + "OUT":" (*fp)((void*)&%(C_path)s,%(type)s_O_ENUM);\n",
    + "VAR":" (*fp)((void*)&%(C_path)s,%(type)s_ENUM);\n"}[v["vartype"]]%v
    + for v in self._VariablesList if v["vartype"] != "FB" and v["type"] in DebugTypesSize ]),
    + "find_variable_case_code":"\n".join([
    + " case %(num)s:\n"%v+
    + " *varp = (void*)&%(C_path)s;\n"%v+
    + {"EXT":" return %(type)s_P_ENUM;\n",
    + "IN":" return %(type)s_P_ENUM;\n",
    + "MEM":" return %(type)s_O_ENUM;\n",
    + "OUT":" return %(type)s_O_ENUM;\n",
    + "VAR":" return %(type)s_ENUM;\n"}[v["vartype"]]%v
    + for v in self._VariablesList if v["vartype"] != "FB" and v["type"] in DebugTypesSize ])}
    +
    + return debug_code
    +
    + def Generate_plc_common_main(self):
    + """
    + Use confnodes layout given in LocationCFilesAndCFLAGS to
    + generate glue code that dispatch calls to all confnodes
    + """
    + # filter location that are related to code that will be called
    + # in retreive, publish, init, cleanup
    + locstrs = map(lambda x:"_".join(map(str,x)),
    + [loc for loc,Cfiles,DoCalls in self.LocationCFilesAndCFLAGS if loc and DoCalls])
    +
    + # Generate main, based on template
    + if self.BeremizRoot.getEnable_ConfNodes():
    + plc_main_code = targets.code("plc_common_main") % {
    + "calls_prototypes":"\n".join([(
    + "int __init_%(s)s(int argc,char **argv);\n"+
    + "void __cleanup_%(s)s(void);\n"+
    + "void __retrieve_%(s)s(void);\n"+
    + "void __publish_%(s)s(void);")%{'s':locstr} for locstr in locstrs]),
    + "retrieve_calls":"\n ".join([
    + "__retrieve_%s();"%locstrs[i-1] for i in xrange(len(locstrs), 0, -1)]),
    + "publish_calls":"\n ".join([ #Call publish in reverse order
    + "__publish_%s();"%locstr for locstr in locstrs]),
    + "init_calls":"\n ".join([
    + "init_level=%d; "%(i+1)+
    + "if((res = __init_%s(argc,argv))){"%locstr +
    + #"printf(\"%s\"); "%locstr + #for debug
    + "return res;}" for i,locstr in enumerate(locstrs)]),
    + "cleanup_calls":"\n ".join([
    + "if(init_level >= %d) "%i+
    + "__cleanup_%s();"%locstrs[i-1] for i in xrange(len(locstrs), 0, -1)])
    + }
    + else:
    + plc_main_code = targets.code("plc_common_main") % {
    + "calls_prototypes":"\n",
    + "retrieve_calls":"\n",
    + "publish_calls":"\n",
    + "init_calls":"\n",
    + "cleanup_calls":"\n"
    + }
    + plc_main_code += targets.targetcode(self.GetTarget().getcontent()["name"])
    + return plc_main_code
    +
    +
    + def _Build(self):
    + """
    + Method called by user to (re)build SoftPLC and confnode tree
    + """
    + if self.AppFrame is not None:
    + self.AppFrame.ClearErrors()
    +
    + buildpath = self._getBuildPath()
    +
    + # Eventually create build dir
    + if not os.path.exists(buildpath):
    + os.mkdir(buildpath)
    + # There is something to clean
    + self.EnableMethod("_Clean", True)
    +
    + self.logger.flush()
    + self.logger.write(_("Start build in %s\n") % buildpath)
    +
    + # Generate SoftPLC IEC code
    + IECGenRes = self._Generate_SoftPLC()
    + self.ShowMethod("_showIECcode", True)
    +
    + # If IEC code gen fail, bail out.
    + if not IECGenRes:
    + self.logger.write_error(_("IEC-61131-3 code generation failed !\n"))
    + self.ResetBuildMD5()
    + return False
    +
    + # Reset variable and program list that are parsed from
    + # CSV file generated by IEC2C compiler.
    + self.ResetIECProgramsAndVariables()
    +
    + # Generate C code and compilation params from confnode hierarchy
    + try:
    + self.LocationCFilesAndCFLAGS, self.LDFLAGS, ExtraFiles = self._Generate_C(
    + buildpath,
    + self.PLCGeneratedLocatedVars)
    + except Exception, exc:
    + self.logger.write_error(_("Runtime extensions C code generation failed !\n"))
    + self.logger.write_error(traceback.format_exc())
    + self.ResetBuildMD5()
    + return False
    +
    + # Get temporary directory path
    + extrafilespath = self._getExtraFilesPath()
    + # Remove old directory
    + if os.path.exists(extrafilespath):
    + shutil.rmtree(extrafilespath)
    + # Recreate directory
    + os.mkdir(extrafilespath)
    + # Then write the files
    + for fname,fobject in ExtraFiles:
    + fpath = os.path.join(extrafilespath,fname)
    + open(fpath, "wb").write(fobject.read())
    + # Now we can forget ExtraFiles (will close files object)
    + del ExtraFiles
    +
    + # Template based part of C code generation
    + # files are stacked at the beginning, as files of confnode tree root
    + for generator, filename, name in [
    + # debugger code
    + (self.Generate_plc_debugger, "plc_debugger.c", "Debugger"),
    + # init/cleanup/retrieve/publish, run and align code
    + (self.Generate_plc_common_main,"plc_common_main.c","Common runtime")]:
    + try:
    + # Do generate
    + code = generator()
    + if code is None:
    + raise
    + code_path = os.path.join(buildpath,filename)
    + open(code_path, "w").write(code)
    + # Insert this file as first file to be compiled at root confnode
    + self.LocationCFilesAndCFLAGS[0][1].insert(0,(code_path, self.plcCFLAGS))
    + except Exception, exc:
    + self.logger.write_error(name+_(" generation failed !\n"))
    + self.logger.write_error(traceback.format_exc())
    + self.ResetBuildMD5()
    + return False
    +
    + self.logger.write(_("C code generated successfully.\n"))
    +
    + # Get current or fresh builder
    + builder = self.GetBuilder()
    + if builder is None:
    + self.logger.write_error(_("Fatal : cannot get builder.\n"))
    + self.ResetBuildMD5()
    + return False
    +
    + # Build
    + try:
    + if not builder.build() :
    + self.logger.write_error(_("C Build failed.\n"))
    + return False
    + except Exception, exc:
    + self.logger.write_error(_("C Build crashed !\n"))
    + self.logger.write_error(traceback.format_exc())
    + self.ResetBuildMD5()
    + return False
    +
    + self.logger.write(_("Successfully built.\n"))
    + # Update GUI status about need for transfer
    + self.CompareLocalAndRemotePLC()
    + return True
    +
    + def ShowError(self, logger, from_location, to_location):
    + chunk_infos = self.GetChunkInfos(from_location, to_location)
    + for infos, (start_row, start_col) in chunk_infos:
    + start = (from_location[0] - start_row, from_location[1] - start_col)
    + end = (to_location[0] - start_row, to_location[1] - start_col)
    + #print from_location, to_location, start_row, start_col, start, end
    + if self.AppFrame is not None:
    + self.AppFrame.ShowError(infos, start, end)
    +
    + def _showIECcode(self):
    + self._OpenView("IEC code")
    +
    + def _editIECrawcode(self):
    + self._OpenView("IEC raw code")
    +
    + def _OpenView(self, name=None):
    + if name == "IEC code":
    + plc_file = self._getIECcodepath()
    +
    + IEC_code_viewer = TextViewer(self.AppFrame.TabsOpened, "", None, None, instancepath=name)
    + #IEC_code_viewer.Enable(False)
    + IEC_code_viewer.SetTextSyntax("ALL")
    + IEC_code_viewer.SetKeywords(IEC_KEYWORDS)
    + try:
    + text = file(plc_file).read()
    + except:
    + text = '(* No IEC code have been generated at that time ! *)'
    + IEC_code_viewer.SetText(text = text)
    + IEC_code_viewer.SetIcon(self.AppFrame.GenerateBitmap("ST"))
    +
    + self.AppFrame.EditProjectElement(IEC_code_viewer, name)
    +
    + return IEC_code_viewer
    +
    + elif name == "IEC raw code":
    + controler = MiniTextControler(self._getIECrawcodepath())
    + IEC_raw_code_viewer = TextViewer(self.AppFrame.TabsOpened, "", None, controler, instancepath=name)
    + #IEC_raw_code_viewer.Enable(False)
    + IEC_raw_code_viewer.SetTextSyntax("ALL")
    + IEC_raw_code_viewer.SetKeywords(IEC_KEYWORDS)
    + IEC_raw_code_viewer.RefreshView()
    + IEC_raw_code_viewer.SetIcon(self.AppFrame.GenerateBitmap("ST"))
    +
    + self.AppFrame.EditProjectElement(IEC_raw_code_viewer, name)
    +
    + return IEC_raw_code_viewer
    +
    + return None
    +
    + def _Clean(self):
    + if os.path.isdir(os.path.join(self._getBuildPath())):
    + self.logger.write(_("Cleaning the build directory\n"))
    + shutil.rmtree(os.path.join(self._getBuildPath()))
    + else:
    + self.logger.write_error(_("Build directory already clean\n"))
    + self.ShowMethod("_showIECcode", False)
    + self.EnableMethod("_Clean", False)
    + # kill the builder
    + self._builder = None
    + self.CompareLocalAndRemotePLC()
    +
    + ############# Real PLC object access #############
    + def UpdateMethodsFromPLCStatus(self):
    + # Get PLC state : Running or Stopped
    + # TODO : use explicit status instead of boolean
    + status = None
    + if self._connector is not None:
    + status = self._connector.GetPLCstatus()
    + if status is None:
    + self._connector = None
    + status = "Disconnected"
    + if(self.previous_plcstate != status):
    + for args in {
    + "Started" : [("_Run", False),
    + ("_Stop", True)],
    + "Stopped" : [("_Run", True),
    + ("_Stop", False)],
    + "Empty" : [("_Run", False),
    + ("_Stop", False)],
    + "Broken" : [],
    + "Disconnected" :[("_Run", False),
    + ("_Stop", False),
    + ("_Transfer", False),
    + ("_Connect", True),
    + ("_Disconnect", False)],
    + }.get(status,[]):
    + self.ShowMethod(*args)
    + self.previous_plcstate = status
    + return True
    + return False
    +
    + def PullPLCStatusProc(self, event):
    + if self._connector is None:
    + self.StatusTimer.Stop()
    + if self.UpdateMethodsFromPLCStatus():
    +
    + status = _(self.previous_plcstate)
    + {"Broken": self.logger.write_error,
    + None: lambda x: None}.get(
    + self.previous_plcstate, self.logger.write)(_("PLC is %s\n")%status)
    + self.AppFrame.RefreshAll()
    +
    + def RegisterDebugVarToConnector(self):
    + self.DebugTimer=None
    + Idxs = []
    + self.TracedIECPath = []
    + if self._connector is not None:
    + self.IECdebug_lock.acquire()
    + IECPathsToPop = []
    + for IECPath,data_tuple in self.IECdebug_datas.iteritems():
    + WeakCallableDict, data_log, status, fvalue = data_tuple
    + if len(WeakCallableDict) == 0:
    + # Callable Dict is empty.
    + # This variable is not needed anymore!
    + #print "Unused : " + IECPath
    + IECPathsToPop.append(IECPath)
    + elif IECPath != "__tick__":
    + # Convert
    + Idx, IEC_Type = self._IECPathToIdx.get(IECPath,(None,None))
    + if Idx is not None:
    + if IEC_Type in DebugTypesSize:
    + Idxs.append((Idx, IEC_Type, fvalue, IECPath))
    + else:
    + self.logger.write_warning(_("Debug : Unsuppoted type to debug %s\n")%IEC_Type)
    + else:
    + self.logger.write_warning(_("Debug : Unknown variable %s\n")%IECPath)
    + for IECPathToPop in IECPathsToPop:
    + self.IECdebug_datas.pop(IECPathToPop)
    +
    + if Idxs:
    + Idxs.sort()
    + self.TracedIECPath = zip(*Idxs)[3]
    + self._connector.SetTraceVariablesList(zip(*zip(*Idxs)[0:3]))
    + else:
    + self.TracedIECPath = []
    + self._connector.SetTraceVariablesList([])
    + self.IECdebug_lock.release()
    +
    + #for IEC_path, IECdebug_data in self.IECdebug_datas.iteritems():
    + # print IEC_path, IECdebug_data[0].keys()
    +
    + def ReArmDebugRegisterTimer(self):
    + if self.DebugTimer is not None:
    + self.DebugTimer.cancel()
    +
    + # Timer to prevent rapid-fire when registering many variables
    + # use wx.CallAfter use keep using same thread. TODO : use wx.Timer instead
    + self.DebugTimer=Timer(0.5,wx.CallAfter,args = [self.RegisterDebugVarToConnector])
    + # Rearm anti-rapid-fire timer
    + self.DebugTimer.start()
    +
    + def GetDebugIECVariableType(self, IECPath):
    + Idx, IEC_Type = self._IECPathToIdx.get(IECPath,(None,None))
    + return IEC_Type
    +
    + def SubscribeDebugIECVariable(self, IECPath, callableobj, *args, **kwargs):
    + """
    + Dispatching use a dictionnary linking IEC variable paths
    + to a WeakKeyDictionary linking
    + weakly referenced callables to optionnal args
    + """
    + if IECPath != "__tick__" and not self._IECPathToIdx.has_key(IECPath):
    + return None
    +
    + self.IECdebug_lock.acquire()
    + # If no entry exist, create a new one with a fresh WeakKeyDictionary
    + IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    + if IECdebug_data is None:
    + IECdebug_data = [
    + WeakKeyDictionary(), # Callables
    + [], # Data storage [(tick, data),...]
    + "Registered", # Variable status
    + None] # Forced value
    + self.IECdebug_datas[IECPath] = IECdebug_data
    +
    + IECdebug_data[0][callableobj]=(args, kwargs)
    +
    + self.IECdebug_lock.release()
    +
    + self.ReArmDebugRegisterTimer()
    +
    + return IECdebug_data[1]
    +
    + def UnsubscribeDebugIECVariable(self, IECPath, callableobj):
    + #print "Unsubscribe", IECPath, callableobj
    + self.IECdebug_lock.acquire()
    + IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    + if IECdebug_data is not None:
    + IECdebug_data[0].pop(callableobj,None)
    + self.IECdebug_lock.release()
    +
    + self.ReArmDebugRegisterTimer()
    +
    + def UnsubscribeAllDebugIECVariable(self):
    + self.IECdebug_lock.acquire()
    + IECdebug_data = {}
    + self.IECdebug_lock.release()
    +
    + self.ReArmDebugRegisterTimer()
    +
    + def ForceDebugIECVariable(self, IECPath, fvalue):
    + if not self.IECdebug_datas.has_key(IECPath):
    + return
    +
    + self.IECdebug_lock.acquire()
    +
    + # If no entry exist, create a new one with a fresh WeakKeyDictionary
    + IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    + IECdebug_data[2] = "Forced"
    + IECdebug_data[3] = fvalue
    +
    + self.IECdebug_lock.release()
    +
    + self.ReArmDebugRegisterTimer()
    +
    + def ReleaseDebugIECVariable(self, IECPath):
    + if not self.IECdebug_datas.has_key(IECPath):
    + return
    +
    + self.IECdebug_lock.acquire()
    +
    + # If no entry exist, create a new one with a fresh WeakKeyDictionary
    + IECdebug_data = self.IECdebug_datas.get(IECPath, None)
    + IECdebug_data[2] = "Registered"
    + IECdebug_data[3] = None
    +
    + self.IECdebug_lock.release()
    +
    + self.ReArmDebugRegisterTimer()
    +
    + def CallWeakcallables(self, IECPath, function_name, *cargs):
    + data_tuple = self.IECdebug_datas.get(IECPath, None)
    + if data_tuple is not None:
    + WeakCallableDict, data_log, status, fvalue = data_tuple
    + #data_log.append((debug_tick, value))
    + for weakcallable,(args,kwargs) in WeakCallableDict.iteritems():
    + #print weakcallable, value, args, kwargs
    + function = getattr(weakcallable, function_name, None)
    + if function is not None:
    + if status == "Forced" and cargs[1] == fvalue:
    + function(*(cargs + (True,) + args), **kwargs)
    + else:
    + function(*(cargs + args), **kwargs)
    + # This will block thread if more than one call is waiting
    +
    + def GetTicktime(self):
    + return self._Ticktime
    +
    + def RemoteExec(self, script, **kwargs):
    + if self._connector is None:
    + return -1, "No runtime connected!"
    + return self._connector.RemoteExec(script, **kwargs)
    +
    + def DebugThreadProc(self):
    + """
    + This thread waid PLC debug data, and dispatch them to subscribers
    + """
    + self.debug_break = False
    + debug_getvar_retry = 0
    + while (not self.debug_break) and (self._connector is not None):
    + Trace = self._connector.GetTraceVariables()
    + if(Trace):
    + plc_status, debug_tick, debug_vars = Trace
    + else:
    + plc_status = None
    + debug_getvar_retry += 1
    + #print debug_tick, debug_vars
    + if plc_status == "Started":
    + self.IECdebug_lock.acquire()
    + if len(debug_vars) == len(self.TracedIECPath):
    + if debug_getvar_retry > DEBUG_RETRIES_WARN:
    + self.logger.write(_("... debugger recovered\n"))
    + debug_getvar_retry = 0
    + for IECPath,value in zip(self.TracedIECPath, debug_vars):
    + if value is not None:
    + self.CallWeakcallables(IECPath, "NewValue", debug_tick, value)
    + self.CallWeakcallables("__tick__", "NewDataAvailable")
    + self.IECdebug_lock.release()
    + if debug_getvar_retry == DEBUG_RETRIES_WARN:
    + self.logger.write(_("Waiting debugger to recover...\n"))
    + if debug_getvar_retry == DEBUG_RETRIES_REREGISTER:
    + # re-register debug registry to PLC
    + wx.CallAfter(self.RegisterDebugVarToConnector)
    + if debug_getvar_retry != 0:
    + # Be patient, tollerate PLC to come up before debugging
    + time.sleep(0.1)
    + else:
    + self.debug_break = True
    + self.logger.write(_("Debugger disabled\n"))
    + self.DebugThread = None
    +
    + def KillDebugThread(self):
    + tmp_debugthread = self.DebugThread
    + self.debug_break = True
    + if tmp_debugthread is not None:
    + self.logger.writeyield(_("Stopping debugger...\n"))
    + tmp_debugthread.join(timeout=5)
    + if tmp_debugthread.isAlive() and self.logger:
    + self.logger.write_warning(_("Couldn't stop debugger.\n"))
    + else:
    + self.logger.write(_("Debugger stopped.\n"))
    + self.DebugThread = None
    +
    + def _connect_debug(self):
    + if self.AppFrame:
    + self.AppFrame.ResetGraphicViewers()
    + self.RegisterDebugVarToConnector()
    + if self.DebugThread is None:
    + self.DebugThread = Thread(target=self.DebugThreadProc)
    + self.DebugThread.start()
    +
    + def _Run(self):
    + """
    + Start PLC
    + """
    + if self.GetIECProgramsAndVariables():
    + self._connector.StartPLC()
    + self.logger.write(_("Starting PLC\n"))
    + self._connect_debug()
    + else:
    + self.logger.write_error(_("Couldn't start PLC !\n"))
    + wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    +
    + def _Stop(self):
    + """
    + Stop PLC
    + """
    + if self._connector is not None and not self._connector.StopPLC():
    + self.logger.write_error(_("Couldn't stop PLC !\n"))
    +
    + # debugthread should die on his own
    + #self.KillDebugThread()
    +
    + wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    +
    + def _Connect(self):
    + # don't accept re-connetion is already connected
    + if self._connector is not None:
    + self.logger.write_error(_("Already connected. Please disconnect\n"))
    + return
    +
    + # Get connector uri
    + uri = self.\
    + BeremizRoot.\
    + getURI_location().\
    + strip()
    +
    + # if uri is empty launch discovery dialog
    + if uri == "":
    + # Launch Service Discovery dialog
    + dialog = DiscoveryDialog(self.AppFrame)
    + answer = dialog.ShowModal()
    + uri = dialog.GetURI()
    + dialog.Destroy()
    +
    + # Nothing choosed or cancel button
    + if uri is None or answer == wx.ID_CANCEL:
    + self.logger.write_error(_("Connection canceled!\n"))
    + return
    + else:
    + self.\
    + BeremizRoot.\
    + setURI_location(uri)
    +
    + # Get connector from uri
    + try:
    + self._connector = connectors.ConnectorFactory(uri, self)
    + except Exception, msg:
    + self.logger.write_error(_("Exception while connecting %s!\n")%uri)
    + self.logger.write_error(traceback.format_exc())
    +
    + # Did connection success ?
    + if self._connector is None:
    + # Oups.
    + self.logger.write_error(_("Connection failed to %s!\n")%uri)
    + else:
    + self.ShowMethod("_Connect", False)
    + self.ShowMethod("_Disconnect", True)
    + self.ShowMethod("_Transfer", True)
    +
    + self.CompareLocalAndRemotePLC()
    +
    + # Init with actual PLC status and print it
    + self.UpdateMethodsFromPLCStatus()
    + if self.previous_plcstate is not None:
    + status = _(self.previous_plcstate)
    + else:
    + status = ""
    + self.logger.write(_("PLC is %s\n")%status)
    +
    + # Start the status Timer
    + self.StatusTimer.Start(milliseconds=500, oneShot=False)
    +
    + if self.previous_plcstate=="Started":
    + if self.DebugAvailable() and self.GetIECProgramsAndVariables():
    + self.logger.write(_("Debug connect matching running PLC\n"))
    + self._connect_debug()
    + else:
    + self.logger.write_warning(_("Debug do not match PLC - stop/transfert/start to re-enable\n"))
    +
    + def CompareLocalAndRemotePLC(self):
    + if self._connector is None:
    + return
    + # We are now connected. Update button status
    + MD5 = self.GetLastBuildMD5()
    + # Check remote target PLC correspondance to that md5
    + if MD5 is not None:
    + if not self._connector.MatchMD5(MD5):
    +# self.logger.write_warning(
    +# _("Latest build does not match with target, please transfer.\n"))
    + self.EnableMethod("_Transfer", True)
    + else:
    +# self.logger.write(
    +# _("Latest build matches target, no transfer needed.\n"))
    + self.EnableMethod("_Transfer", True)
    + # warns controller that program match
    + self.ProgramTransferred()
    + #self.EnableMethod("_Transfer", False)
    + else:
    +# self.logger.write_warning(
    +# _("Cannot compare latest build to target. Please build.\n"))
    + self.EnableMethod("_Transfer", False)
    +
    +
    + def _Disconnect(self):
    + self._connector = None
    + self.StatusTimer.Stop()
    + wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    +
    + def _Transfer(self):
    + # Get the last build PLC's
    + MD5 = self.GetLastBuildMD5()
    +
    + # Check if md5 file is empty : ask user to build PLC
    + if MD5 is None :
    + self.logger.write_error(_("Failed : Must build before transfer.\n"))
    + return False
    +
    + # Compare PLC project with PLC on target
    + if self._connector.MatchMD5(MD5):
    + self.logger.write(
    + _("Latest build already matches current target. Transfering anyway...\n"))
    +
    + # Get temprary directory path
    + extrafilespath = self._getExtraFilesPath()
    + extrafiles = [(name, open(os.path.join(extrafilespath, name),
    + 'rb').read()) \
    + for name in os.listdir(extrafilespath) \
    + if not name=="CVS"]
    +
    + # Send PLC on target
    + builder = self.GetBuilder()
    + if builder is not None:
    + data = builder.GetBinaryCode()
    + if data is not None :
    + if self._connector.NewPLC(MD5, data, extrafiles) and self.GetIECProgramsAndVariables():
    + self.UnsubscribeAllDebugIECVariable()
    + self.ProgramTransferred()
    + if self.AppFrame is not None:
    + self.AppFrame.RefreshInstancesTree()
    + self.AppFrame.CloseObsoleteDebugTabs()
    + self.logger.write(_("Transfer completed successfully.\n"))
    + else:
    + self.logger.write_error(_("Transfer failed\n"))
    + else:
    + self.logger.write_error(_("No PLC to transfer (did build succeed ?)\n"))
    +
    + wx.CallAfter(self.UpdateMethodsFromPLCStatus)
    +
    + ConfNodeMethods = [
    + {"bitmap" : opjimg("Build"),
    + "name" : _("Build"),
    + "tooltip" : _("Build project into build folder"),
    + "method" : "_Build"},
    + {"bitmap" : opjimg("Clean"),
    + "name" : _("Clean"),
    + "enabled" : False,
    + "tooltip" : _("Clean project build folder"),
    + "method" : "_Clean"},
    + {"bitmap" : opjimg("Run"),
    + "name" : _("Run"),
    + "shown" : False,
    + "tooltip" : _("Start PLC"),
    + "method" : "_Run"},
    + {"bitmap" : opjimg("Stop"),
    + "name" : _("Stop"),
    + "shown" : False,
    + "tooltip" : _("Stop Running PLC"),
    + "method" : "_Stop"},
    + {"bitmap" : opjimg("Connect"),
    + "name" : _("Connect"),
    + "tooltip" : _("Connect to the target PLC"),
    + "method" : "_Connect"},
    + {"bitmap" : opjimg("Transfer"),
    + "name" : _("Transfer"),
    + "shown" : False,
    + "tooltip" : _("Transfer PLC"),
    + "method" : "_Transfer"},
    + {"bitmap" : opjimg("Disconnect"),
    + "name" : _("Disconnect"),
    + "shown" : False,
    + "tooltip" : _("Disconnect from PLC"),
    + "method" : "_Disconnect"},
    + {"bitmap" : opjimg("ShowIECcode"),
    + "name" : _("Show code"),
    + "shown" : False,
    + "tooltip" : _("Show IEC code generated by PLCGenerator"),
    + "method" : "_showIECcode"},
    + {"bitmap" : opjimg("editIECrawcode"),
    + "name" : _("Raw IEC code"),
    + "tooltip" : _("Edit raw IEC code added to code generated by PLCGenerator"),
    + "method" : "_editIECrawcode"},
    + ]
    --- a/c_ext/c_ext.py Tue May 08 22:27:49 2012 +0200
    +++ b/c_ext/c_ext.py Wed May 09 00:00:50 2012 +0200
    @@ -5,7 +5,7 @@
    from xmlclass import *
    -from ConfigTree import ConfigTreeNode, opjimg
    +from ConfigTreeNode import ConfigTreeNode, opjimg
    from CFileEditor import CFileEditor
    from PLCControler import PLCControler, UndoBuffer, LOCATION_CONFNODE, LOCATION_MODULE, LOCATION_GROUP, LOCATION_VAR_INPUT, LOCATION_VAR_OUTPUT, LOCATION_VAR_MEMORY
    --- a/canfestival/canfestival.py Tue May 08 22:27:49 2012 +0200
    +++ b/canfestival/canfestival.py Wed May 09 00:00:50 2012 +0200
    @@ -9,7 +9,7 @@
    from networkedit import networkedit
    from objdictedit import objdictedit
    import canfestival_config as local_canfestival_config
    -from ConfigTree import ConfigTreeNode
    +from ConfigTreeNode import ConfigTreeNode
    from commondialogs import CreateNodeDialog
    import wx
    --- a/py_ext/modules/svgui/svgui.py Tue May 08 22:27:49 2012 +0200
    +++ b/py_ext/modules/svgui/svgui.py Wed May 09 00:00:50 2012 +0200
    @@ -1,7 +1,7 @@
    import wx
    import os, sys, shutil
    -from ConfigTree import opjimg
    +from ConfigTreeNode import opjimg
    from py_ext import PythonCodeTemplate
    from pyjs import translate
    --- a/py_ext/modules/wxglade_hmi/wxglade_hmi.py Tue May 08 22:27:49 2012 +0200
    +++ b/py_ext/modules/wxglade_hmi/wxglade_hmi.py Wed May 09 00:00:50 2012 +0200
    @@ -2,7 +2,7 @@
    import os, sys
    from xml.dom import minidom
    -from ConfigTree import opjimg
    +from ConfigTreeNode import opjimg
    from py_ext import PythonCodeTemplate
    class RootClass(PythonCodeTemplate):
    --- a/py_ext/py_ext.py Tue May 08 22:27:49 2012 +0200
    +++ b/py_ext/py_ext.py Wed May 09 00:00:50 2012 +0200
    @@ -1,7 +1,7 @@
    import wx
    import os
    import modules
    -from ConfigTree import ConfigTreeNode, opjimg
    +from ConfigTreeNode import ConfigTreeNode, opjimg
    from PLCControler import UndoBuffer
    from PythonEditor import PythonEditor
    --- a/targets/LPC/__init__.py Tue May 08 22:27:49 2012 +0200
    +++ b/targets/LPC/__init__.py Wed May 09 00:00:50 2012 +0200
    @@ -6,9 +6,9 @@
    class LPC_target(toolchain_makefile):
    #extension = ".ld"
    #DebugEnabled = False
    - def __init__(self, ConfigTreeRootInstance):
    + def __init__(self, CTRInstance):
    self.binmd5key = None
    - toolchain_makefile.__init__(self, ConfigTreeRootInstance)
    + toolchain_makefile.__init__(self, CTRInstance)
    def _GetBinMD5FileName(self):
    return os.path.join(self.buildpath, "lastbuildPLCbin.md5")
    @@ -64,7 +64,7 @@
    f.write(self.binmd5key)
    f.close()
    try:
    - self.ConfigTreeRootInstance.logger.write(
    + self.CTRInstance.logger.write(
    _("Binary is %s bytes long\n")%
    str(os.path.getsize(
    os.path.join(self.buildpath, "ArmPLC_rom.bin"))))
    --- a/targets/Xenomai/__init__.py Tue May 08 22:27:49 2012 +0200
    +++ b/targets/Xenomai/__init__.py Wed May 09 00:00:50 2012 +0200
    @@ -4,14 +4,14 @@
    extension = ".so"
    def getXenoConfig(self, flagsname):
    """ Get xeno-config from target parameters """
    - xeno_config=self.ConfigTreeRootInstance.GetTarget().getcontent()["value"].getXenoConfig()
    + xeno_config=self.CTRInstance.GetTarget().getcontent()["value"].getXenoConfig()
    if xeno_config:
    from ProcessLogger import ProcessLogger
    - status, result, err_result = ProcessLogger(self.ConfigTreeRootInstance.logger,
    + status, result, err_result = ProcessLogger(self.CTRInstance.logger,
    xeno_config + " --skin=native --"+flagsname,
    no_stdout=True).spin()
    if status:
    - self.ConfigTreeRootInstance.logger.write_error(_("Unable to get Xenomai's %s \n")%flagsname)
    + self.CTRInstance.logger.write_error(_("Unable to get Xenomai's %s \n")%flagsname)
    return [result.strip()]
    return []
    --- a/targets/toolchain_gcc.py Tue May 08 22:27:49 2012 +0200
    +++ b/targets/toolchain_gcc.py Wed May 09 00:00:50 2012 +0200
    @@ -10,23 +10,23 @@
    It cannot be used as this and should be inherited in a target specific
    class such as target_linux or target_win32
    """
    - def __init__(self, ConfigTreeRootInstance):
    - self.ConfigTreeRootInstance = ConfigTreeRootInstance
    + def __init__(self, CTRInstance):
    + self.CTRInstance = CTRInstance
    self.buildpath = None
    - self.SetBuildPath(self.ConfigTreeRootInstance._getBuildPath())
    + self.SetBuildPath(self.CTRInstance._getBuildPath())
    def getBuilderCFLAGS(self):
    """
    Returns list of builder specific CFLAGS
    """
    - return [self.ConfigTreeRootInstance.GetTarget().getcontent()["value"].getCFLAGS()]
    + return [self.CTRInstance.GetTarget().getcontent()["value"].getCFLAGS()]
    def getBuilderLDFLAGS(self):
    """
    Returns list of builder specific LDFLAGS
    """
    - return self.ConfigTreeRootInstance.LDFLAGS + \
    - [self.ConfigTreeRootInstance.GetTarget().getcontent()["value"].getLDFLAGS()]
    + return self.CTRInstance.LDFLAGS + \
    + [self.CTRInstance.GetTarget().getcontent()["value"].getLDFLAGS()]
    def GetBinaryCode(self):
    try:
    @@ -56,7 +56,7 @@
    def SetBuildPath(self, buildpath):
    if self.buildpath != buildpath:
    self.buildpath = buildpath
    - self.exe = self.ConfigTreeRootInstance.GetProjectName() + self.extension
    + self.exe = self.CTRInstance.GetProjectName() + self.extension
    self.exe_path = os.path.join(self.buildpath, self.exe)
    self.md5key = None
    self.srcmd5 = {}
    @@ -89,7 +89,7 @@
    def build(self):
    # Retrieve toolchain user parameters
    - toolchain_params = self.ConfigTreeRootInstance.GetTarget().getcontent()["value"]
    + toolchain_params = self.CTRInstance.GetTarget().getcontent()["value"]
    self.compiler = toolchain_params.getCompiler()
    self.linker = toolchain_params.getLinker()
    @@ -99,11 +99,11 @@
    obns = []
    objs = []
    relink = False
    - for Location, CFilesAndCFLAGS, DoCalls in self.ConfigTreeRootInstance.LocationCFilesAndCFLAGS:
    + for Location, CFilesAndCFLAGS, DoCalls in self.CTRInstance.LocationCFilesAndCFLAGS:
    if Location:
    - self.ConfigTreeRootInstance.logger.write(_("ConfNode : ") + self.ConfigTreeRootInstance.GetChildByIECLocation(Location).GetCurrentName() + " " + str(Location)+"\n")
    + self.CTRInstance.logger.write(_("ConfNode : ") + self.CTRInstance.GetChildByIECLocation(Location).GetCurrentName() + " " + str(Location)+"\n")
    else:
    - self.ConfigTreeRootInstance.logger.write(_("PLC :\n"))
    + self.CTRInstance.logger.write(_("PLC :\n"))
    for CFile, CFLAGS in CFilesAndCFLAGS:
    if CFile.endswith(".c"):
    @@ -114,21 +114,21 @@
    match = self.check_and_update_hash_and_deps(bn)
    if match:
    - self.ConfigTreeRootInstance.logger.write(" [pass] "+bn+" -> "+obn+"\n")
    + self.CTRInstance.logger.write(" [pass] "+bn+" -> "+obn+"\n")
    else:
    relink = True
    - self.ConfigTreeRootInstance.logger.write(" [CC] "+bn+" -> "+obn+"\n")
    + self.CTRInstance.logger.write(" [CC] "+bn+" -> "+obn+"\n")
    status, result, err_result = ProcessLogger(
    - self.ConfigTreeRootInstance.logger,
    + self.CTRInstance.logger,
    "\"%s\" -c \"%s\" -o \"%s\" %s %s"%
    (self.compiler, CFile, objectfilename, Builder_CFLAGS, CFLAGS)
    ).spin()
    if status :
    self.srcmd5.pop(bn)
    - self.ConfigTreeRootInstance.logger.write_error(_("C compilation of %s failed.\n")%bn)
    + self.CTRInstance.logger.write_error(_("C compilation of %s failed.\n")%bn)
    return False
    obns.append(obn)
    objs.append(objectfilename)
    @@ -138,7 +138,7 @@
    ######### GENERATE library FILE ########################################
    # Link all the object files into one binary file
    - self.ConfigTreeRootInstance.logger.write(_("Linking :\n"))
    + self.CTRInstance.logger.write(_("Linking :\n"))
    if relink:
    objstring = []
    @@ -147,10 +147,10 @@
    ALLldflags = ' '.join(self.getBuilderLDFLAGS())
    - self.ConfigTreeRootInstance.logger.write(" [CC] " + ' '.join(obns)+" -> " + self.exe + "\n")
    + self.CTRInstance.logger.write(" [CC] " + ' '.join(obns)+" -> " + self.exe + "\n")
    status, result, err_result = ProcessLogger(
    - self.ConfigTreeRootInstance.logger,
    + self.CTRInstance.logger,
    "\"%s\" %s -o \"%s\" %s"%
    (self.linker,
    listobjstring,
    @@ -162,7 +162,7 @@
    return False
    else:
    - self.ConfigTreeRootInstance.logger.write(" [pass] " + ' '.join(obns)+" -> " + self.exe + "\n")
    + self.CTRInstance.logger.write(" [pass] " + ' '.join(obns)+" -> " + self.exe + "\n")
    # Calculate md5 key and get data for the new created PLC
    data=self.GetBinaryCode()
    --- a/targets/toolchain_makefile.py Tue May 08 22:27:49 2012 +0200
    +++ b/targets/toolchain_makefile.py Wed May 09 00:00:50 2012 +0200
    @@ -7,11 +7,11 @@
    includes_re = re.compile('\s*#include\s*["<]([^">]*)[">].*')
    class toolchain_makefile():
    - def __init__(self, ConfigTreeRootInstance):
    - self.ConfigTreeRootInstance = ConfigTreeRootInstance
    + def __init__(self, CTRInstance):
    + self.CTRInstance = CTRInstance
    self.md5key = None
    self.buildpath = None
    - self.SetBuildPath(self.ConfigTreeRootInstance._getBuildPath())
    + self.SetBuildPath(self.CTRInstance._getBuildPath())
    def SetBuildPath(self, buildpath):
    if self.buildpath != buildpath:
    @@ -60,7 +60,7 @@
    srcfiles= []
    cflags = []
    wholesrcdata = ""
    - for Location, CFilesAndCFLAGS, DoCalls in self.ConfigTreeRootInstance.LocationCFilesAndCFLAGS:
    + for Location, CFilesAndCFLAGS, DoCalls in self.CTRInstance.LocationCFilesAndCFLAGS:
    # Get CFiles list to give it to makefile
    for CFile, CFLAGS in CFilesAndCFLAGS:
    CFileName = os.path.basename(CFile)
    @@ -72,7 +72,7 @@
    oldmd5 = self.md5key
    self.md5key = hashlib.md5(wholesrcdata).hexdigest()
    - props = self.ConfigTreeRootInstance.GetProjectProperties()
    + props = self.CTRInstance.GetProjectProperties()
    self.md5key += '#'.join([props[key] for key in ['companyName',
    'projectName',
    'productName']])
    @@ -88,21 +88,21 @@
    "md5": '"'+self.md5key+'"'
    }
    - target = self.ConfigTreeRootInstance.GetTarget().getcontent()["value"]
    + target = self.CTRInstance.GetTarget().getcontent()["value"]
    command = target.getCommand().split(' ') +\
    [target.getBuildPath()] +\
    [arg % beremizcommand for arg in target.getArguments().split(' ')] +\
    target.getRule().split(' ')
    # Call Makefile to build PLC code and link it with target specific code
    - status, result, err_result = ProcessLogger(self.ConfigTreeRootInstance.logger,
    + status, result, err_result = ProcessLogger(self.CTRInstance.logger,
    command).spin()
    if status :
    self.md5key = None
    - self.ConfigTreeRootInstance.logger.write_error(_("C compilation failed.\n"))
    + self.CTRInstance.logger.write_error(_("C compilation failed.\n"))
    return False
    return True
    else :
    - self.ConfigTreeRootInstance.logger.write(_("Source didn't change, no build.\n"))
    + self.CTRInstance.logger.write(_("Source didn't change, no build.\n"))
    return True
    --- /dev/null Thu Jan 01 00:00:00 1970 +0000
    +++ b/util/MiniTextControler.py Wed May 09 00:00:50 2012 +0200
    @@ -0,0 +1,51 @@
    +"""
    +Minimal tab controller for a simple text editor
    +"""
    +
    +import os
    +
    +class MiniTextControler:
    +
    + def __init__(self, filepath):
    + self.FilePath = filepath
    +
    + def CTNFullName(self):
    + return ""
    +
    + def SetEditedElementText(self, tagname, text):
    + file = open(self.FilePath, "w")
    + file.write(text)
    + file.close()
    +
    + def GetEditedElementText(self, tagname, debug = False):
    + if os.path.isfile(self.FilePath):
    + file = open(self.FilePath, "r")
    + text = file.read()
    + file.close()
    + return text
    + return ""
    +
    + def GetEditedElementInterfaceVars(self, tagname, debug = False):
    + return []
    +
    + def GetEditedElementType(self, tagname, debug = False):
    + return "program"
    +
    + def GetBlockTypes(self, tagname = "", debug = False):
    + return []
    +
    + def GetDataTypes(self, tagname = "", basetypes = True, only_locatables = False, debug = False):
    + return []
    +
    + def GetEnumeratedDataValues(self, debug = False):
    + return []
    +
    + def StartBuffering(self):
    + pass
    +
    + def EndBuffering(self):
    + pass
    +
    + def BufferProject(self):
    + pass
    +
    --- a/util/__init__.py Tue May 08 22:27:49 2012 +0200
    +++ b/util/__init__.py Wed May 09 00:00:50 2012 +0200
    @@ -1,2 +1,4 @@
    import TextCtrlAutoComplete
    import BrowseValuesLibraryDialog
    +from misc import *
    +
    --- /dev/null Thu Jan 01 00:00:00 1970 +0000
    +++ b/util/misc.py Wed May 09 00:00:50 2012 +0200
    @@ -0,0 +1,29 @@
    +"""
    +Misc definitions
    +"""
    +
    +import os,sys
    +
    +# helper func to get path to images
    +def opjimg(imgname):
    + return os.path.join(sys.path[0], "images",imgname)
    +
    +# helper func to check path write permission
    +def CheckPathPerm(path):
    + if path is None or not os.path.isdir(path):
    + return False
    + for root, dirs, files in os.walk(path):
    + for name in files:
    + if os.access(root, os.W_OK) is not True or os.access(os.path.join(root, name), os.W_OK) is not True:
    + return False
    + return True
    +
    +def GetClassImporter(classpath):
    + if type(classpath)==str:
    + def fac():
    + mod=__import__(classpath.rsplit('.',1)[0])
    + return reduce(getattr, classpath.split('.')[1:], mod)
    + return fac
    + else:
    + return lambda:classpath
    +