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 Server(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

        while self.continueloop:

    45

            Pyro.config.PYRO_MULTITHREADED = 0

    46

            pyro.initServer()

    47

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

    48

    49

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

    50

            # taking too small timeout value may cause

    51

            # unwanted diconnection when IDE is kept busy for long periods

    52

            self.daemon.setTimeout(60)

    53

    54

            pyro_obj = Pyro.core.ObjBase()

    55

            pyro_obj.delegateTo(runtime.GetPLCObjectSingleton())

    56

    57

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

    58

    59

            if self._to_be_published():

    60

                self.servicepublisher = ServicePublisher()

    61

                self.servicepublisher.RegisterService(self.servicename, self.ip_addr, self.port)

    62

    63

            when_ready()

    64

            self.daemon.requestLoop()

    65

            self.daemon.sock.close()

    66

    67

    def Restart(self):

    68

        self._stop()

    69

    70

    def Quit(self):

    71

        self.continueloop = False

    72

        self._stop()

    73

    74

    def _stop(self):

    75

        if self.servicepublisher is not None:

    76

            self.servicepublisher.UnRegisterService()

    77

            self.servicepublisher = None

    78

        self.daemon.shutdown(True)