from __future__ import print_function
import threading
import Pyro4

# A message bouncer. Passes messages back to the callback
# object, until a certain limit is reached.
# In this example however, it will never reach the limit,
# because the client will deadlock first.


@Pyro4.expose
class Bouncer(object):
    def __init__(self, name):
        self.name = name
        self.count = 0
        self.callbackMutex = threading.Lock()

    def register(self, callback):
        self.callback = callback

    def process(self, message):
        print("in process", self.name)
        if len(message) >= 3:
            print("Back in", self.name, ", message is large enough... stopping!")
            return ["complete at " + self.name + ":" + str(self.count)]

        print("I'm", self.name, ", bouncing back...")
        message.append(self.name)
        with self.callbackMutex:
            result = self.callback.process(message)
        self.count += 1
        result.insert(0, "passed on from " + self.name + ":" + str(self.count))
        print("returned from callback")
        return result

from __future__ import print_function
import threading
import Pyro4

# A message bouncer. Passes messages back to the callback
# object, until a certain limit is reached.
# In this example however, it will never reach the limit,
# because the client will deadlock first.


@Pyro4.expose
class Bouncer(object):
    def __init__(self, name):
        self.name = name
        self.count = 0
        self.callbackMutex = threading.Lock()

    def register(self, callback):
        self.callback = callback

    def process(self, message):
        print("in process", self.name)
        if len(message) >= 3:
            print("Back in", self.name, ", message is large enough... stopping!")
            return ["complete at " + self.name + ":" + str(self.count)]

        print("I'm", self.name, ", bouncing back...")
        message.append(self.name)
        with self.callbackMutex:
            result = self.callback.process(message)
        self.count += 1
        result.insert(0, "passed on from " + self.name + ":" + str(self.count))
        print("returned from callback")
        return result

# A message bouncer. Passes messages back to the callback # object, until a certain limit is reached. # In this example however, it will never reach the limit, # because the client will deadlock first.