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

    14

import sys

    15

    16

import Pyro

    17

import Pyro.core as pyro

    18

import runtime

    19

from runtime.ServicePublisher import ServicePublisher

    20

    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 is not None and \

    34

               self.ip_addr != "localhost" and \

    35

               self.ip_addr != "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

        while self.continueloop:

    47

            Pyro.config.PYRO_MULTITHREADED = 0

    48

            pyro.initServer()

    49

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

    50

    51

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

    52

            # taking too small timeout value may cause

    53

            # unwanted diconnection when IDE is kept busy for long periods

    54

            self.daemon.setTimeout(60)

    57

            pyro_obj.delegateTo(runtime.GetPLCObjectSingleton())

    58

    59

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

    60

    61

            if self._to_be_published():

    62

                self.servicepublisher = ServicePublisher()

    63

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

    64

    65

            when_ready()

    66

            self.daemon.requestLoop()

    67

            self.daemon.sock.close()

    68

    69

    def Restart(self):

    70

        self._stop()

    71

    72

    def Quit(self):

    73

        self.continueloop = False

    74

        self._stop()

    75

    76

    def _stop(self):

    77

        if self.servicepublisher is not None:

    78

            self.servicepublisher.UnRegisterService()

    79

            self.servicepublisher = None

    80

        self.daemon.shutdown(True)