1

#!/usr/bin/env python

     2

# -*- coding: utf-8 -*-

     3

#

     4

#Copyright (C) 2007: Edouard TISSERANT and Laurent BESSARD

     5

#

     6

#See COPYING file for copyrights details.

     7

#

     8

#This library is free software; you can redistribute it and/or

     9

#modify it under the terms of the GNU General Public

    10

#License as published by the Free Software Foundation; either

    11

#version 2.1 of the License, or (at your option) any later version.

    12

#

    13

#This library is distributed in the hope that it will be useful,

    14

#but WITHOUT ANY WARRANTY; without even the implied warranty of

    15

#MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

    16

#General Public License for more details.

    17

#

    18

#You should have received a copy of the GNU General Public

    19

#License along with this library; if not, write to the Free Software

    20

#Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

    21

import Pyro.core as pyro

    22

from Pyro.errors import PyroError

    23

import traceback

    24

from time import sleep

    25

import copy

    26

    27

# this module attribute contains a list of DNS-SD (Zeroconf) service types

    28

# supported by this connector plugin.

    29

#

    30

# for connectors that do not support DNS-SD, this attribute can be omitted

    31

# or set to an empty list.

    32

supported_dnssd_services = ["_PYRO._tcp.local."]

    33

    34

def PYRO_connector_factory(uri, pluginsroot):

    35

    """

    36

    This returns the connector to Pyro style PLCobject

    37

    """

    38

    pluginsroot.logger.write(_("Connecting to URI : %s\n")%uri)

    39

    40

    servicetype, location = uri.split("://")

    41

    42

    # Try to get the proxy object

    43

    try :

    44

        RemotePLCObjectProxy = pyro.getAttrProxyForURI("PYROLOC://"+location+"/PLCObject")

    45

    except Exception, msg:

    46

        pluginsroot.logger.write_error(_("Wrong URI, please check it !\n"))

    47

        pluginsroot.logger.write_error(traceback.format_exc())

    48

        return None

    49

    50

    def PyroCatcher(func, default=None):

    51

        """

    52

        A function that catch a pyro exceptions, write error to logger

    53

        and return defaul value when it happen

    54

        """

    55

        def catcher_func(*args,**kwargs):

    56

            try:

    57

                return func(*args,**kwargs)

    58

            except PyroError,e:

    59

                #pluginsroot.logger.write_error(traceback.format_exc())

    60

                pluginsroot.logger.write_error(str(e)+"\n")

    61

                pluginsroot._connector = None

    62

                return default

    63

        return catcher_func

    64

    65

    # Check connection is effective. 

    66

    # lambda is for getattr of GetPLCstatus to happen inside catcher

    67

    if PyroCatcher(lambda:RemotePLCObjectProxy.GetPLCstatus())() == None:

    68

        pluginsroot.logger.write_error(_("Cannot get PLC status - connection failed.\n"))

    69

        return None

    70

    71

    72

    class PyroProxyProxy:

    73

        """

    74

        A proxy proxy class to handle Beremiz Pyro interface specific behavior.

    75

        And to put pyro exception catcher in between caller and pyro proxy

    76

        """

    77

        def __init__(self):

    78

            # for safe use in from debug thread, must create a copy

    79

            self.RemotePLCObjectProxyCopy = None

    80

    81

        def GetPyroProxy(self):

    82

            """

    83

            This func returns the real Pyro Proxy.

    84

            Use this if you musn't keep reference to it.

    85

            """

    86

            return RemotePLCObjectProxy

    87

    88

        def _PyroStartPLC(self, *args, **kwargs):

    89

            """

    90

            pluginsroot._connector.GetPyroProxy() is used 

    91

            rather than RemotePLCObjectProxy because

    92

            object is recreated meanwhile, 

    93

            so we must not keep ref to it here

    94

            """

    97

                """

    98

                Some bad libs with static symbols may polute PLC

    99

                ask runtime to suicide and come back again

   100

                """

   101

                pluginsroot.logger.write(_("Force runtime reload\n"))

   102

                pluginsroot._connector.GetPyroProxy().ForceReload()

   103

                pluginsroot._Disconnect()

   104

                # let remote PLC time to resurect.(freeze app)

   105

                sleep(0.5)

   106

                pluginsroot._Connect()

   107

            self.RemotePLCObjectProxyCopy = copy.copy(pluginsroot._connector.GetPyroProxy())

   108

            return pluginsroot._connector.GetPyroProxy().StartPLC(*args, **kwargs)

   109

        StartPLC = PyroCatcher(_PyroStartPLC, False)

   110

   111

   112

        def _PyroGetTraceVariables(self):

   113

            """

   114

            for safe use in from debug thread, must use the copy

   115

            """

   118

            return self.RemotePLCObjectProxyCopy.GetTraceVariables()

   119

        GetTraceVariables = PyroCatcher(_PyroGetTraceVariables,("Broken",None,None))

   120

   121

        def _PyroGetPLCstatus(self):

   122

            return RemotePLCObjectProxy.GetPLCstatus()

   123

        GetPLCstatus = PyroCatcher(_PyroGetPLCstatus, "Broken")

   124

   125

        def __getattr__(self, attrName):

   126

            member = self.__dict__.get(attrName, None)

   127

            if member is None:

   128

                def my_local_func(*args,**kwargs):

   129

                    return RemotePLCObjectProxy.__getattr__(attrName)(*args,**kwargs)

   130

                member = PyroCatcher(my_local_func, None)

   131

                self.__dict__[attrName] = member

   132

            return member

   133

   134

    return PyroProxyProxy()

   135

   136