

def disconnect(self):
    self.owner.did_disconnect(self)
    endpoints = self.endpoints
    self.endpoints = []
    for e in e:
        (peer_node_id, peer_id) = e.get_peer()
        self.fifo.commit_reads(peer_id, False)
    return endpoints

dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/actor/actorport.py OutPort.disconnect/VarMisuse@35/38 `endpoints`->`e`