

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