Exa-Networks / exabgp

        return False

@Command.register('text', 'announce route-refresh')

def announce_refresh(self, reactor, service, command):

    def callback(self, command, peers):

        refreshes = self.api_refresh(command)

        if not refreshes:

            self.log_failure("Command could not parse route-refresh command : %s" % command)

            reactor.processes.answer_error(service)

            yield True

            return

        reactor.configuration.inject_refresh(peers, refreshes)

        for refresh in refreshes:

            self.log_message(

                "Sent to %s : %s"

                % (', '.join(peers if peers else []) if peers is not None else 'all peers', refresh.extensive())

            )

        yield False

        reactor.processes.answer_done(service)

    try:

        descriptions, command = extract_neighbors(command)

        peers = match_neighbors(reactor.established_peers(), descriptions)

        if not peers:

            self.log_failure('no neighbor matching the command : %s' % command)

            reactor.processes.answer_error(service)

            return False

        reactor.asynchronous.schedule(service, command, callback(self, command, peers))

        return True

    except ValueError:

        self.log_failure('issue parsing the command')

        reactor.processes.answer_error(service)

        return False

    except IndexError:

        self.log_failure('issue parsing the command')

        reactor.processes.answer_error(service)

        return False

    return True

@Command.register('text', 'announce eor')

def announce_eor(self, reactor, service, command):

    def callback(self, command, peers):

        family = self.api_eor(command)

        if not family:

            self.log_failure("Command could not parse eor : %s" % command)

            reactor.processes.answer_error(service)

            yield True

            return

        reactor.configuration.inject_eor(peers, family)

        self.log_message(

            "Sent to %s : %s"

            % (', '.join(peers if peers else []) if peers is not None else 'all peers', family.extensive())

        )

        yield False

        reactor.processes.answer_done(service)

    try:

        descriptions, command = extract_neighbors(command)

        peers = match_neighbors(reactor.established_peers(), descriptions)

        if not peers:

            self.log_failure('no neighbor matching the command : %s' % command)

            reactor.processes.answer_error(service)

            return False

        reactor.asynchronous.schedule(service, command, callback(self, command, peers))

        return True

    except ValueError:

        self.log_failure('issue parsing the command')

        reactor.processes.answer_error(service)

        return False

    except IndexError:

        self.log_failure('issue parsing the command')

        reactor.processes.answer_error(service)

        return False