def _processRelayConnectedCell(self, cell, origin):
        '''Called when this circuit receives a RelayConnectedCell.

        Notify the stream associated with this cell's stream id that it's
        now connected. Drop the cell if we have no reference to this
        stream id.

        :param oppy.cell.relay.RelayConnectedCell cell: relay connected cell
            recieved from the network
        :param int origin: which node on the circuit's path this cell
            came from
        '''
        sid = cell.rheader.stream_id

        try:
            self._streams[sid].streamConnected()
        except __HOLE__:
            msg = ("Circuit {} received a RelayConnectedCell for nonexistent "
                   "stream {}. Dropping cell.".format(self.circuit_id, sid))
            logging.debug(msg)
            return

        msg = ("Circuit {} received a RelayConnectedCell for stream {}"
               .format(self.circuit_id, sid))
        logging.debug(msg)
dataset/ETHPy150Open nskinkel/oppy/oppy/circuit/circuit.py/Circuit._processRelayConnectedCell