def METHOD_NAME(self, ctns, rf):
    for rs_client in ctns.values():
        done = False
        for _ in range(self.retry_limit):
            if done:
                break
            state = self.gobgp.get_neighbor_state(rs_client)
            self.assertEqual(state, BGP_FSM_ESTABLISHED)
            local_rib = self.gobgp.get_local_rib(rs_client, rf=rf)
            local_rib = [p['prefix'] for p in local_rib]
            if len(local_rib) < (len(ctns) - 1):
                time.sleep(self.wait_per_retry)
                continue
            self.assertEqual(len(local_rib), (len(ctns) - 1))
            for c in ctns.values():
                if rs_client != c:
                    for r in c.routes:
                        self.assertTrue(r in local_rib)
            done = True
        if done:
            continue
        # should not reach here
        raise AssertionError