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

import sys

    13

    14

import Pyro

    15

import Pyro.core as pyro

    16

import runtime

    17

from runtime.ServicePublisher import ServicePublisher

    18

    19

class Server(object):

    20

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

    21

        self.continueloop = True

    22

        self.daemon = None

    23

        self.servicename = servicename

    24

        self.ip_addr = ip_addr

    25

        self.port = port

    26

        self.servicepublisher = None

    27

    28

    def _to_be_published(self):

    29

        return self.servicename is not None and \

    30

               self.ip_addr is not None and \

    31

               self.ip_addr != "localhost" and \

    32

               self.ip_addr != "127.0.0.1"

    33

    34

    def PrintServerInfo(self):

    35

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

    36

    37

        if self._to_be_published():

    38

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

    39

    40

        sys.stdout.flush()

    41

    42

    def PyroLoop(self, when_ready):

    43

        while self.continueloop:

    44

            Pyro.config.PYRO_MULTITHREADED = 0

    45

            pyro.initServer()

    46

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

    47

    48

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

    49

            # taking too small timeout value may cause

    50

            # unwanted diconnection when IDE is kept busy for long periods

    51

            self.daemon.setTimeout(60)

    52

    53

            pyro_obj=Pyro.core.ObjBase()

    54

            pyro_obj.delegateTo(runtime.GetPLCObjectSingleton())

    55

    56

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

    57

    58

            if self._to_be_published():

    59

                self.servicepublisher = ServicePublisher()

    60

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

    61

    62

            when_ready()

    63

            self.daemon.requestLoop()

    64

            self.daemon.sock.close()

    65

    66

    def Restart(self):

    67

        self._stop()

    68

    69

    def Quit(self):

    70

        self.continueloop = False

    71

        self._stop()

    72

    73

    def _stop(self):

    74

        if self.servicepublisher is not None:

    75

            self.servicepublisher.UnRegisterService()

    76

            self.servicepublisher = None

    77

        self.daemon.shutdown(True)

    78

    79

    80