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

import os

    16

    17

import Pyro

    18

import Pyro.core as pyro

    19

import runtime

    20

from runtime.ServicePublisher import ServicePublisher

    21

    22

    23

class PyroServer(object):

    24

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

    25

        self.continueloop = True

    26

        self.daemon = None

    27

        self.servicename = servicename

    28

        self.ip_addr = ip_addr

    29

        self.port = port

    30

        self.servicepublisher = None

    31

        self.piper, self.pipew = None, None

    32

    33

    def _to_be_published(self):

    34

        return self.servicename is not None and \

    35

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

    36

    37

    def PrintServerInfo(self):

    38

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

    39

    40

        if self._to_be_published():

    41

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

    42

    43

        sys.stdout.flush()

    44

    45

    def PyroLoop(self, when_ready):

    46

        if self._to_be_published():

    47

            self.Publish()

    48

    49

        while self.continueloop:

    50

            Pyro.config.PYRO_MULTITHREADED = 0

    51

            pyro.initServer()

    52

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

    53

    54

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

    55

            # taking too small timeout value may cause

    56

            # unwanted diconnection when IDE is kept busy for long periods

    57

            self.daemon.setTimeout(60)

    58

    59

            pyro_obj = Pyro.core.ObjBase()

    60

            pyro_obj.delegateTo(runtime.GetPLCObjectSingleton())

    61

    62

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

    63

    64

            when_ready()

    65

            self.piper, self.pipew = os.pipe()

    66

            self.daemon.requestLoop(others=[self.piper], callback=lambda x: None)

    67

            self.piper, self.pipew = None, None

    68

            if hasattr(self, 'sock'):

    69

                self.daemon.sock.close()

    70

        self.Unpublish()

    71

    72

    def Restart(self):

    73

        self.daemon.shutdown(True)

    74

    75

    def Quit(self):

    76

        self.continueloop = False

    77

        self.daemon.shutdown(True)

    78

        self.daemon.closedown()

    79

        if self.pipew is not None:

    80

            os.write(self.pipew, "goodbye")

    81

    82

    def Publish(self):

    83

        self.servicepublisher = ServicePublisher("PYRO")

    84

        self.servicepublisher.RegisterService(self.servicename,

    85

                                              self.ip_addr, self.port)

    86

    87

    def Unpublish(self):

    88

        if self.servicepublisher is not None:

    89

            self.servicepublisher.UnRegisterService()

    90

            self.servicepublisher = None