def get_peers(self):
        peers = []
        for ep in self.endpoints:
            peers.append(ep.get_peer())
        if len(peers) < len(self.fifo.readers):
            all = copy.copy(self.fifo.readers)
            all -= set([p[1] for p in peers])
            peers.extend([(None, p) for p in all])
        return peers
dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/actor/actorport.py/OutPort.get_peers/original