1

#!/usr/bin/env python

     2

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

     3

     4

# This file is part of Beremiz runtime.

     5

     6

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

     7

# Copyright (C) 2017: Andrey Skvortsov

     8

# Copyright (C) 2018: Edouard TISSERANT

     9

    10

# See COPYING file for copyrights details.

    11

    12

from __future__ import absolute_import

    13

from __future__ import print_function

    14

import sys

    15

    16

import Pyro

    17

import Pyro.core as pyro

    18

import runtime

    19

from runtime.ServicePublisher import ServicePublisher

    20

    21

    22

class PyroServer(object):

    23

    def __init__(self, servicename, ip_addr, port):

    24

        self.continueloop = True

    25

        self.daemon = None

    26

        self.servicename = servicename

    27

        self.ip_addr = ip_addr

    28

        self.port = port

    29

        self.servicepublisher = None

    30

    31

    def _to_be_published(self):

    32

        return self.servicename is not None and \

    33

               self.ip_addr not in ["", "localhost", "127.0.0.1"]

    34

    35

    def PrintServerInfo(self):

    36

        print(_("Pyro port :"), self.port)

    37

    38

        if self._to_be_published():

    39

            print(_("Publishing service on local network"))

    40

    41

        sys.stdout.flush()

    42

    43

    def PyroLoop(self, when_ready):

    44

        if self._to_be_published():

    45

            self.Publish()

    46

    47

        while self.continueloop:

    48

            Pyro.config.PYRO_MULTITHREADED = 0

    49

            pyro.initServer()

    50

            self.daemon = pyro.Daemon(host=self.ip_addr, port=self.port)

    51

    52

            # pyro never frees memory after connection close if no timeout set

    53

            # taking too small timeout value may cause

    54

            # unwanted diconnection when IDE is kept busy for long periods

    55

            self.daemon.setTimeout(60)

    56

    57

            pyro_obj = Pyro.core.ObjBase()

    58

            pyro_obj.delegateTo(runtime.GetPLCObjectSingleton())

    59

    60

            self.daemon.connect(pyro_obj, "PLCObject")

    61

    62

            when_ready()

    63

            self.daemon.requestLoop()

    64

            self.daemon.sock.close()

    65

        self.Unpublish()

    66

    67

    def Restart(self):

    68

        self.daemon.shutdown(True)

    69

    70

    def Quit(self):

    71

        self.continueloop = False

    72

        self.daemon.shutdown(True)

    73

    74

    def Publish(self):

    75

        self.servicepublisher = ServicePublisher("PYRO")

    76

        self.servicepublisher.RegisterService(self.servicename,

    77

                                              self.ip_addr, self.port)

    78

    79

    def Unpublish(self):

    80

        if self.servicepublisher is not None:

    81

            self.servicepublisher.UnRegisterService()

    82

            self.servicepublisher = None