try:

import urllib2

updateinfo = urllib2.urlopen(self.updateinfo_url, None).read()

updateinfo = _("update info unavailable.")

from threading import Thread

self.LastRefreshTime = gettime()

try:

self.RefreshLock.release()

pass

newtime = time.time()

if newtime - self.rising_timer > 1:

try:

recent_projects = map(DecodeFileSystemPath,

self.GetConfigEntry("RecentProjects", []))

recent_projects = []

while self.RecentProjectsMenu.GetMenuItemCount() > len(recent_projects):

try:

recent_projects = map(DecodeFileSystemPath,

self.GetConfigEntry("RecentProjects", []))

recent_projects = []

if projectpath in recent_projects:

recent_projects.remove(projectpath)

try:

defaultpath = DecodeFileSystemPath(self.Config.Read("lastopenedfolder"))

defaultpath = os.path.expanduser("~")

dialog = wx.DirDialog(self, _("Choose an empty directory for new project"), defaultpath)

try:

defaultpath = DecodeFileSystemPath(self.Config.Read("lastopenedfolder"))

defaultpath = os.path.expanduser("~")

dialog = wx.DirDialog(self, _("Choose a project"), defaultpath,

if 'self' in exception_locals:

try:

info['self'] = format_namespace(exception_locals['self'].__dict__)

pass

if not os.path.exists(path):

os.mkdir(path)

run_old(*args, **kw)

except (KeyboardInterrupt, SystemExit):

raise

sys.excepthook(*sys.exc_info())

self.run = run_with_except_hook

threading.Thread.__init__ = init

wxversion.select(['2.8', '3.0'])

import wx

havewx = True

print "Wx unavailable !"

havewx = False

from twisted.internet import reactor

havetwisted = True

print _("Twisted unavailable.")

havetwisted = False

run_old(*args, **kw)

except (KeyboardInterrupt, SystemExit):

raise

sys.excepthook(*sys.exc_info())

self.run = run_with_except_hook

threading.Thread.__init__ = init

'''

try:

new_pou, error = LoadPou(pou_xml)

error = ""

if error is not None:

return _("Couldn't paste non-POU object.")

try:

instances, error = LoadPouInstances(text, bodytype)

instances, error = [], ""

if error is not None or len(instances) == 0:

return _("Invalid plcopen element(s)!!!")

self._IECCodeView.SetKeywords(IEC_KEYWORDS)

try:

text = file(plc_file).read()

text = '(* No IEC code have been generated at that time ! *)'

self._IECCodeView.SetText(text=text)

self._IECCodeView.Editor.SetReadOnly(True)

answer = dialog.ShowModal()

uri = dialog.GetURI()

dialog.Destroy()

self.logger.write_error(_("Local service discovery failed!\n"))

self.logger.write_error(traceback.format_exc())

uri = None

values = eval(data)

if not isinstance(values, TupleType):

raise ValueError

message = _("Invalid value \"%s\" for debug variable") % data

values = None

values = eval(data)

if not isinstance(values, TupleType):

raise ValueError

message = _("Invalid value \"%s\" for debug variable") % data

values = None

values = eval(data)

if not isinstance(values, TupleType):

raise ValueError

message = _("Invalid value \"%s\" for debug variable") % data

values = None

else:

try:

files = os.listdir(folderpath)

return []

for filename in files:

if not filename.startswith("."):

element_type = self.ParentWindow.ElementType

try:

values = eval(data)

message = _("Invalid value \"%s\" for variable grid element") % data

values = None

if not isinstance(values, TupleType):

try:

self.criteria = infos

CompilePattern(self.criteria)

self.criteria.clear()

message = self.RegExpSyntaxErrMsg

self.SetStatusText(message)

def get_function(v):

try:

return f(v)

return None

return get_function

self.criteria = infos

CompilePattern(self.criteria)

self.infosPrev = infos

self.criteria.clear()

message = _("Syntax error in regular expression of pattern to search!")

try:

res = _winreg.QueryValue(_winreg.HKEY_LOCAL_MACHINE, 'Software\\Adobe\\%s\\%s\\InstallPath' % (key, numver))

return res

pass

return None

if wx.Platform == '__WXMSW__':

try:

readerpath = get_acroversion()

wx.MessageBox("Acrobat Reader is not found or installed !")

return None

if wx.Platform == '__WXMSW__':

try:

open_win_svg(get_inkscape_path(), svgfile)

wx.MessageBox("Inkscape is not found or installed !")

return None

else:

def OnDoDrop(self, event):

try:

values = eval(event.GetDragText())

values = event.GetDragText()

if isinstance(values, tuple):

message = None

def OnDoDrop(self, event):

try:

values = eval(event.GetDragText())

values = event.GetDragText()

if isinstance(values, tuple):

message = None

message = None

try:

values = eval(data)

message = _("Invalid value \"%s\" for viewer block") % data

values = None

if not isinstance(values, TupleType):

for element in self.value:

try:

repetition = int(element.getrepetitionValue())

repetition = 1

if repetition > 1:

value = element.getvalue()

self.PythonRuntimeInit()

return True

self._loading_error = traceback.format_exc()

PLCprint(self._loading_error)

return False

method = self.python_runtime_vars.get("_%s_%s" % (name, methodname), None)

if method is not None:

self.python_runtime_vars["_runtime_%s" % methodname].append(method)

self.LogMessage(0, traceback.format_exc())

raise

for filename in file(extra_files_log, "r").readlines() + [extra_files_log]:

try:

os.remove(os.path.join(self.workingdir, filename.strip()))

pass

pass

try:

# Store new PLC filename

self.CurrentPLCFilename = NewFileName

self.PLCStatus = "Broken"

self.StatusChange()

PLCprint(traceback.format_exc())

try:

last_md5 = open(self._GetMD5FileName(), "r").read()

return last_md5 == MD5

pass

return False

def RemoteExec(self, script, *kwargs):

try:

exec script in kwargs

e_type, e_value, e_traceback = sys.exc_info()

line_no = traceback.tb_lineno(get_last_traceback(e_traceback))

return (-1, "RemoteExec script failed!\n\nLine %d: %s\n\t%s" %

try:

# Python 2.5 and above

from hashlib import md5

import md5

import re

names = os.listdir(src)

try:

os.mkdir(dst)

pass

errors = []

os.path.getmtime(html_output_filename):

try:

shutil.copy(html_input_filename, html_output_filename)

print >>sys.stderr, "Warning: Missing module HTML file %s" % html_input_filename

print "Copying: %(html_input_filename)s" % locals()

except BaseException:

etype, eval, etb = sys.exc_info()

return self.error(id, 100, '%s: %s' % (etype.__name__, eval))

etype, eval, etb = sys.exc_info()

return self.error(id, 100, 'Exception %s: %s' % (etype, eval))

else:

if self.endcallback:

try:

err = self.Proc.wait()

err = self.retval

self.finished = True

self.endcallback(self.Proc.pid, err)

sig = SIGKILL

try:

os.kill(self.Proc.pid, sig)

pass

self.outt.join()

self.errt.join()

"""Class accessor"""

try:

return _CLASSES[clazz]

return "?(%s)" % (clazz)

def getType(self, type):

"""Type accessor"""

try:

return _TYPES[type]

return "?(%s)" % (type)

def toString(self, hdr, other):

"""String representation"""

try:

return socket.inet_ntoa(self.address)

return self.address

"""Adds an entry"""

try:

list = self.cache[entry.key]

list = self.cache[entry.key] = []

list.append(entry)

try:

list = self.cache[entry.key]

list.remove(entry)

pass

def get(self, entry):

try:

list = self.cache[entry.key]

return list[list.index(entry)]

return None

def getByDetails(self, name, type, clazz):

"""Returns a list of entries whose key matches the name."""

try:

return self.cache[name]

return []

def entries(self):

def add(x, y): return x+y

try:

return reduce(add, self.cache.values())

return []

for socket in rr:

try:

self.readers[socket].handle_read()

# Ignore errors that occur on shutdown

pass

pass

def getReaders(self):

del(self.services[record.alias.lower()])

self.list.append(callback)

return

if not expired:

def callback(x):

return self.listener.addService(x, self.type, record.alias)

result[key] = value

self.properties = result

traceback.print_exc()

self.properties = None

try:

self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)

# SO_REUSEADDR should be equivalent to SO_REUSEPORT for

# multicast UDP sockets (p 731, "TCP/IP Illustrated,

# Volume 2"), but some BSD-derived systems require

self.socket.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_LOOP, 1)

try:

self.socket.bind(self.group)

# Some versions of linux raise an exception even though

# the SO_REUSE* options have been set, so ignore it

#

"""Unregister a service."""

try:

del(self.services[info.name.lower()])

pass

now = currentTimeMillis()

nextTime = now

try:

self.listeners.remove(listener)

self.notifyAll()

pass

def updateRecord(self, now, rec):

out.addAnswer(msg, DNSText(question.name, _TYPE_TXT, _CLASS_IN | _CLASS_UNIQUE, _DNS_TTL, service.text))

if question.type == _TYPE_SRV:

out.addAdditionalAnswer(DNSAddress(service.server, _TYPE_A, _CLASS_IN | _CLASS_UNIQUE, _DNS_TTL, service.address))

traceback.print_exc()

if out is not None and out.answers:

#temp = DNSIncoming(out.packet())

try:

bytes_sent = self.socket.sendto(out.packet(), 0, (addr, port))

# Ignore this, it may be a temporary loss of network connection

pass

rev = pipe.communicate()[0]

if pipe.returncode != 0:

rev = None

pass

# if this is not mercurial repository

try:

f = open(os.path.join(app_dir, "revision"))

rev = f.readline()

pass

return rev

raise ValueError("\"%s\" isn't a valid hexadecimal integer!" % value)

try:

return int(value, 16)

raise ValueError("\"%s\" isn't a valid hexadecimal integer!" % value)

try:

# TODO: permit to write value like 1E2

value = int(value)

raise ValueError("\"%s\" isn't a valid integer!" % value)

if minInclusive is not None and value < minInclusive:

raise ValueError("\"%d\" isn't greater or equal to %d!" %

return value

try:

return float(value)

raise ValueError("\"%s\" isn't a valid %s!" % (value, type))

return GetFloat

raise ValueError("Member limit can't be defined to \"unbounded\"!")

try:

limit = int(value)

raise ValueError("\"%s\" isn't a valid value for this member limit!" % value)

if limit < 0:

raise ValueError("Member limit can't be negative!")

raise ValueError("\"length\" and \"maxLength\" facets can't be defined at the same time!")

try:

value = int(value)

raise ValueError("\"length\" must be an integer!")

if value < 0:

raise ValueError("\"length\" can't be negative!")

raise ValueError("\"length\" and \"minLength\" facets can't be defined at the same time!")

try:

value = int(value)

raise ValueError("\"minLength\" must be an integer!")

if value < 0:

raise ValueError("\"minLength\" can't be negative!")

raise ValueError("\"length\" and \"maxLength\" facets can't be defined at the same time!")

try:

value = int(value)

raise ValueError("\"maxLength\" must be an integer!")

if value < 0:

raise ValueError("\"maxLength\" can't be negative!")

for infos in membertypesinfos:

try:

return infos["extract"](attr, False)

pass

raise ValueError("\"%s\" isn't valid for type defined for union!")