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

    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):

    45

        while self.continueloop:

    46

            Pyro.config.PYRO_MULTITHREADED = 0

    47

            pyro.initServer()

    48

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

    49

    50

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

    51

            # taking too small timeout value may cause

    52

            # unwanted diconnection when IDE is kept busy for long periods

    53

            self.daemon.setTimeout(60)

    54

    55

            pyro_obj = Pyro.core.ObjBase()

    56

            pyro_obj.delegateTo(runtime.GetPLCObjectSingleton())

    57

    58

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

    59

    60

            when_ready()

    61

            self.daemon.requestLoop()

    62

            self.daemon.sock.close()

    64

    65

    def Restart(self):

    67

    68

    def Quit(self):

    69

        self.continueloop = False

    71

    78

        if self.servicepublisher is not None:

    79

            self.servicepublisher.UnRegisterService()

    80

            self.servicepublisher = None