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

            """

    95

            if pluginsroot._connector.GetPyroProxy().GetPLCstatus() == "Dirty":

    96

                """

    97

                Some bad libs with static symbols may polute PLC

    98

                ask runtime to suicide and come back again

    99

                """

   100

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

   101

                pluginsroot._connector.GetPyroProxy().ForceReload()

   102

                pluginsroot._Disconnect()

   103

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

   104

                sleep(0.5)

   105

                pluginsroot._Connect()

   106

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

   107

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

   108

        StartPLC = PyroCatcher(_PyroStartPLC, False)

   109

   110

   111

        def _PyroGetTraceVariables(self):

   112

            """

   113

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

   114

            """

   115

            if self.RemotePLCObjectProxyCopy is not None and self.RemotePLCObjectProxyCopy.GetPLCstatus() == "Started":

   116

                return self.RemotePLCObjectProxyCopy.GetTraceVariables()

   117

            else:

   118

                return None,None

   119

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

   120

   121

        def _PyroPLCIsStarting(self):

   122

            """

   123

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

   124

            """

   125

            return self.RemotePLCObjectProxyCopy is not None and self.RemotePLCObjectProxyCopy.GetPLCstatus() == "Starting"

   126

        PLCIsStarting = PyroCatcher(_PyroPLCIsStarting,False)

   127

   128

        def __getattr__(self, attrName):

   129

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

   130

            if member is None:

   131

                def my_local_func(*args,**kwargs):

   132

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

   133

                member = PyroCatcher(my_local_func, None)

   134

                self.__dict__[attrName] = member

   135

            return member

   136

   137

    return PyroProxyProxy()

   138

   139