From b45520c4ac9e3fc382869e32a305419ae81764f5 Mon Sep 17 00:00:00 2001
From: Mark Stapp <mjs@cisco.com>
Date: Thu, 19 Sep 2024 15:46:56 -0400
Subject: [PATCH] tests: add bgp peer-shutdown topotest

Add a simple topotest using multiple bgp peers; based on the
ecmp_topo1 test.

Signed-off-by: Mark Stapp <mjs@cisco.com>
---
 tests/topotests/bgp_peer_shut/__init__.py     |   0
 .../topotests/bgp_peer_shut/bgp-peer-shut.dot | 206 ++++++++++++++++++
 .../topotests/bgp_peer_shut/bgp-peer-shut.pdf | Bin 0 -> 11891 bytes
 tests/topotests/bgp_peer_shut/exabgp.env      |  55 +++++
 .../topotests/bgp_peer_shut/peer1/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer1/exabgp.cfg  |  18 ++
 .../bgp_peer_shut/peer10/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer10/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer11/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer11/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer12/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer12/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer13/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer13/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer14/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer14/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer15/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer15/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer16/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer16/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer17/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer17/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer18/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer18/exabgp.cfg |  18 ++
 .../bgp_peer_shut/peer19/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer19/exabgp.cfg |  18 ++
 .../topotests/bgp_peer_shut/peer2/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer2/exabgp.cfg  |  18 ++
 .../bgp_peer_shut/peer20/exa-send.py          |  66 ++++++
 .../topotests/bgp_peer_shut/peer20/exabgp.cfg |  18 ++
 .../topotests/bgp_peer_shut/peer3/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer3/exabgp.cfg  |  18 ++
 .../topotests/bgp_peer_shut/peer4/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer4/exabgp.cfg  |  18 ++
 .../topotests/bgp_peer_shut/peer5/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer5/exabgp.cfg  |  18 ++
 .../topotests/bgp_peer_shut/peer6/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer6/exabgp.cfg  |  18 ++
 .../topotests/bgp_peer_shut/peer7/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer7/exabgp.cfg  |  18 ++
 .../topotests/bgp_peer_shut/peer8/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer8/exabgp.cfg  |  18 ++
 .../topotests/bgp_peer_shut/peer9/exa-send.py |  66 ++++++
 .../topotests/bgp_peer_shut/peer9/exabgp.cfg  |  18 ++
 tests/topotests/bgp_peer_shut/r1/bgpd.conf    |  51 +++++
 tests/topotests/bgp_peer_shut/r1/summary.txt  | 131 +++++++++++
 tests/topotests/bgp_peer_shut/r1/zebra.conf   |  16 ++
 .../bgp_peer_shut/test_bgp_peer_shut.py       | 180 +++++++++++++++
 48 files changed, 2319 insertions(+)
 create mode 100644 tests/topotests/bgp_peer_shut/__init__.py
 create mode 100644 tests/topotests/bgp_peer_shut/bgp-peer-shut.dot
 create mode 100644 tests/topotests/bgp_peer_shut/bgp-peer-shut.pdf
 create mode 100644 tests/topotests/bgp_peer_shut/exabgp.env
 create mode 100755 tests/topotests/bgp_peer_shut/peer1/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer1/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer10/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer10/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer11/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer11/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer12/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer12/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer13/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer13/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer14/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer14/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer15/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer15/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer16/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer16/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer17/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer17/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer18/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer18/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer19/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer19/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer2/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer2/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer20/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer20/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer3/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer3/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer4/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer4/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer5/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer5/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer6/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer6/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer7/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer7/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer8/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer8/exabgp.cfg
 create mode 100755 tests/topotests/bgp_peer_shut/peer9/exa-send.py
 create mode 100644 tests/topotests/bgp_peer_shut/peer9/exabgp.cfg
 create mode 100644 tests/topotests/bgp_peer_shut/r1/bgpd.conf
 create mode 100644 tests/topotests/bgp_peer_shut/r1/summary.txt
 create mode 100644 tests/topotests/bgp_peer_shut/r1/zebra.conf
 create mode 100644 tests/topotests/bgp_peer_shut/test_bgp_peer_shut.py

diff --git a/tests/topotests/bgp_peer_shut/__init__.py b/tests/topotests/bgp_peer_shut/__init__.py
new file mode 100644
index 000000000000..e69de29bb2d1
diff --git a/tests/topotests/bgp_peer_shut/bgp-peer-shut.dot b/tests/topotests/bgp_peer_shut/bgp-peer-shut.dot
new file mode 100644
index 000000000000..290b31509df4
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/bgp-peer-shut.dot
@@ -0,0 +1,206 @@
+## Color coding:
+#########################
+##  Main FRR: #f08080  red
+##  Switches: #d0e0d0  gray
+##  RIP:      #19e3d9  Cyan
+##  RIPng:    #fcb314  dark yellow
+##  OSPFv2:   #32b835  Green
+##  OSPFv3:   #19e3d9  Cyan
+##  ISIS IPv4 #fcb314  dark yellow
+##  ISIS IPv6 #9a81ec  purple
+##  BGP IPv4  #eee3d3  beige
+##  BGP IPv6  #fdff00  yellow
+##### Colors (see http://www.color-hex.com/)
+
+graph ospf_ecmp_iBGP_topo1 {
+	label="bgp peer shut - eBGP peer shut";
+    labelloc="t";
+
+	# Routers
+	r1 [
+		label="r1\nrtr-id 10.0.255.1/32",
+		shape=doubleoctagon,
+		fillcolor="#f08080",
+		style=filled,
+	];
+
+	# 4 Switches for eBGP Peers
+	s1 [
+		label="s1\n10.0.1.0/24",
+		shape=oval,
+		fillcolor="#d0e0d0",
+		style=filled,
+	];
+	s2 [
+		label="s2\n10.0.2.0/24",
+		shape=oval,
+		fillcolor="#d0e0d0",
+		style=filled,
+	];
+	s3 [
+		label="s3\n10.0.3.0/24",
+		shape=oval,
+		fillcolor="#d0e0d0",
+		style=filled,
+	];
+	s4 [
+		label="s4\n10.0.4.0/24",
+		shape=oval,
+		fillcolor="#d0e0d0",
+		style=filled,
+	];
+
+	# 20 ExaBGP Peers AS 101...120
+	peer1 [
+		label="eBGP peer1\nAS99\nrtr-id 10.0.1.101/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer2 [
+		label="eBGP peer2\nAS99\nrtr-id 10.0.1.102/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer3 [
+		label="eBGP peer3\nAS99\nrtr-id 10.0.1.103/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer4 [
+		label="eBGP peer4\nAS99\nrtr-id 10.0.1.104/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer5 [
+		label="eBGP peer5\nAS99\nrtr-id 10.0.1.105/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer6 [
+		label="eBGP peer6\nAS99\nrtr-id 10.0.2.106/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer7 [
+		label="eBGP peer7\nAS99\nrtr-id 10.0.2.107/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer8 [
+		label="eBGP peer8\nAS99\nrtr-id 10.0.2.108/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer9 [
+		label="eBGP peer9\nAS99\nrtr-id 10.0.2.109/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer10 [
+		label="eBGP peer10\nAS99\nrtr-id 10.0.2.110/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer11 [
+		label="eBGP peer11\nAS111\nrtr-id 10.0.3.111/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer12 [
+		label="eBGP peer12\nAS112\nrtr-id 10.0.3.112/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer13 [
+		label="eBGP peer13\nAS113\nrtr-id 10.0.3.113/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer14 [
+		label="eBGP peer14\nAS114\nrtr-id 10.0.3.114/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer15 [
+		label="eBGP peer15\nAS115\nrtr-id 10.0.3.115/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer16 [
+		label="eBGP peer16\nAS116\nrtr-id 10.0.4.116/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer17 [
+		label="eBGP peer17\nAS117\nrtr-id 10.0.4.117/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer18 [
+		label="eBGP peer18\nAS118\nrtr-id 10.0.4.118/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer19 [
+		label="eBGP peer19\nAS119\nrtr-id 10.0.4.119/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+	peer20 [
+		label="eBGP peer20\nAS120\nrtr-id 10.0.4.120/32",
+		shape=rectangle,
+		fillcolor="#eee3d3",
+		style=filled,
+	];
+
+	# Connections
+	r1 -- s1 [label="eth0\n.1"];
+	r1 -- s2 [label="eth1\n.1"];
+	r1 -- s3 [label="eth2\n.1"];
+	r1 -- s4 [label="eth3\n.1"];
+
+	peer1 -- s1 [label="eth0\n.101"];
+	peer2 -- s1 [label="eth0\n.102"];
+	peer3 -- s1 [label="eth0\n.103"];
+	peer4 -- s1 [label="eth0\n.104"];
+	peer5 -- s1 [label="eth0\n.105"];
+	peer6 -- s2 [label="eth0\n.106"];
+	peer7 -- s2 [label="eth0\n.107"];
+	peer8 -- s2 [label="eth0\n.108"];
+	peer9 -- s2 [label="eth0\n.109"];
+	peer10 -- s2 [label="eth0\n.110"];
+	peer11 -- s3 [label="eth0\n.111"];
+	peer12 -- s3 [label="eth0\n.112"];
+	peer13 -- s3 [label="eth0\n.113"];
+	peer14 -- s3 [label="eth0\n.114"];
+	peer15 -- s3 [label="eth0\n.115"];
+	peer16 -- s4 [label="eth0\n.116"];
+	peer17 -- s4 [label="eth0\n.117"];
+	peer18 -- s4 [label="eth0\n.118"];
+	peer19 -- s4 [label="eth0\n.119"];
+	peer20 -- s4 [label="eth0\n.120"];
+
+	# Arrange network to make cleaner diagram
+	{ rank=same peer1 peer2 peer3 peer4 peer5 } -- s1 -- { rank=same peer6 peer7 peer8 peer9 peer10 } -- s2
+		-- { rank=same peer11 peer12 peer13 peer14 peer15 } -- s3 -- { rank=same peer16 peer17 peer18 peer19 peer20 } -- s4
+		-- { rank=same r1 } [style=invis]
+}
diff --git a/tests/topotests/bgp_peer_shut/bgp-peer-shut.pdf b/tests/topotests/bgp_peer_shut/bgp-peer-shut.pdf
new file mode 100644
index 0000000000000000000000000000000000000000..fff66bb39bcf873005e6405f5dac7ec68e7ffcae
GIT binary patch
literal 11891
zcmch7byS<((r?k?P}~YZi<5*vfZ|SZr$})LF2P-jJCx$Cg%%1et}RfsP~6>H-2Fmd
zIp<yHeBZr)-6ZRI_ROBW_w1R;tTpR549XHx>>v&(2E*r_4_6ov01#krY=t2p0N|82
zv$KF(0=Vy4su%zOfKv))12=QJf7=+r%_PiB>`l!ugoH4h;Z9~owixaibGkitPwR>1
zCbUKmVF#8tZ{MzhQ3FxQ(c(I$xjo~%t1<zI{JY2(HyO^>p2O8i@1ULGC~_L*%W(Hy
ziFu6XZ-YXMTCCH;0xo`gO>cZ|W?Qck_k{1Jn_Kq+dG~w>$qcgX3sEN2SvZ_sb3c>n
z_}z^*Uwu0BS_r+pRXZEm9dx_;bamY~C$x9j*!;`a!@EhYv7+hImBHRAXs6|x;PqXb
znGtMyXD<*(D|T=1l*Xlzdh*NO&RXtMuP~ih11}-Z@$Z9Y!mh2&drj8(i0kY6r@1g~
z4qzu9q%lpG+S^6+s<^PgDdF=S1=Z(YO<k|XK9?}T6!hd=m^XC@N$A<$6a{{qD^v`d
zk_->s;gB?FSV8b1Cs~aZe)QdMX<hpI&iZU*FePkH*tPwv^~xaS+v8;JB(o^?I>Jy<
z9EPz*mLq_3Z?n`yVARtHDni3JDii(^2vO7yhl`jEhdG~(8}sF1G=h)z<Q?%&kP=FB
zgSK<Gr@VW<D-dHBlz>_vR<h?!lYB;9tc6-L!!Y^E)$fA0S4M2dXUgN&sY(9>ZN=f-
ztAjEMj46`cg}K*Fa!nDKSFEVoJ-0gV=&StL+6gU;*K{)Nhrf|#Dq)NCGsx<nkPYkC
zMX9`FEj%VO7Sb0!Hf9A8!JB2A2Y%{#v{0w}X}|Dx{3wr&T&`jx{&U48^zFBnjpC7^
zkOt0gw?nN4wPAcB1jitC618Y<O3sxWr7o8!Lm8RRE!y8;nQ-l}H5LJbMz>M(8dosq
zcVs`-_BSbQ1HogtmHwQYII4`BSV|(Q&)Qf;Ffc-N$YpfV<T`^@NObC4{L!kvPP3GW
z(&lT4B>BhJA#MT@p5Y~hewL`fW{oeC(?Klq4IWx4uWEHqPj=H`kyz%Fv5OBqDHtWR
zF_LUP_yuETjx%F!_Ea*KVdwZJWb$Q&fmfW#tm!cwP5J7Kx^oNljIZ_!3562{Y<iI9
z%ayO(%zP&TLYa?wG=2GwPcr(^Gm@}g>m~WLeCcr~f41VOh)Nwak|b|blu-I!(6m#F
z=@MC&nhUe73@@rE_a#DBZ%3adg%9FkmA@N;Cz-@qkGqV}XGCtXpGb=b4Vsoa<IgNj
zyeJab4eej(rA^jG6}5G2o%s9agrfLy*R;?NF*%|n%4MPE^TkN}GxupF&P!<+)_AXU
zEYSMY@ovF9+9_?LC4AE`hd2flDpIghv}oy{2f=6tCk%a55?t9fFWIKr(pZ$vOn&0Z
zArMJqZCi&+>GBA@qSy-kaPKkY&<0Mamb62Rr?01#ca=d4fnJ8*{Lu$6%oR1VBo2M#
zI$l$Ol8r6EY7cf`HlfH*y=?~q8pfb0zNVcl;ZNy$H1w*)P;PPJAvuIsMO-Y`;ii5a
z$xM!TbDq;WW#|btfwc!>P3&gc$Lr}T`!ME!l})3pNKzO%a-|4UI(pu_gD7ZPRKT2`
z5nD>ScZwWKbAwLtG?C025c2#!?B*tyuHlq}>KAKa)HqLn-Gy$In?~|P=pXH~g4GYp
z=3_G$-Kr#a4R<#)Q)WAjor;&Okc)Gj$mK=$CFOT%-(%b3tl8E7)^xaSQl|*Yn#LBU
z$};!tE4k`ISV1uXii|+xEWP{dd3vpQsVjwcISS+ohTHrmZq)LoFi9tOb6_Psx;Rbl
zV#x{Li2?P*yZJ}K1m)|x7(uzU;6vibCbKZbknXDk4&3(0>73lbz>a*_%{s^SE>c=}
zqm=Kb0F|Ekn58_&c#2nBMQ+Dqb(TbRDr<0f;@Ml#TJMU@<f9>t&FaJ-8t0@WqP4yi
zo8w1A?Ce=F9Lr06IWsL<@EMQIi1U#jL>*Tb;PaTo^~L&|c%qMeZU~3VWEnV4V#i%!
z+DqK_TCHD{$z!(D%{>IWjTjPbS$A_#;}qGGPlsLj$+nK!3k((>=@mz4C`zY&oMDKM
zNso_#O7Lfe!e1}*l5JT<tT@RO56Bc#&}M#D|KSj=B*h=<s#0LaHS8o_uqIG|gt(9x
zkE6p80iTb8x6lk<$QR=fe`J!1aChYz?qoA&9$TAsH}zs1w$5)sfi>d{AF>w=V%@Mn
zwG<^AQcvqBhpp+_P`2(j8^l6Faw}Jo<PY&yDVUH7!W=#ck;x{*XFMsU%hai3x)=P4
zvgP_9h|6^rdM}tR*@QOih>oj8>!ZA~E%QyTBaEH)5rXPLFt327c|(#`6)(^JMQdx%
zlUIg67ospMs9%m1c8q3PKCV_`dh(nGx3r-P$${v36882^zt#(ZZh=LQhJuzLoLWL!
zMkfg4JdjhqDzkOw;w7u4?M-sSNfrBETd|%y<@JD|i~Kw%%|!_5mu&eDc_d5Y(}w5k
zv!2{ISv#JxCWxYN3`W6rZIVU|2MG@z;>d;+QbfpecLgCz2iCR4QQgzFICen$Opn6x
za@`Fpncr(>0izj&))QwGS6iW1i?GY^<A_I#_}4m(C=SlP&Ez+OX~Je&J9ShItUyr)
z*lNsnPUE#Z>G!x#*u6|O;$tZIVhpd-^gk7FGw})lrjq!q`w6WU$u)7{FDvSo*P}``
zW?$$E;`Oho+m*hJbg<qj`ZiF1vhDk=iJE*2=XJEMu?H`W4u^@1tqhv=avo=pez0QS
z&>3cZU8d0#1tcm(92JGYP1=y;vqNogUw72E?XZJO6EB=4jN^ppW0smduROEzTiRot
z#t~;{&*p|6u6!sXMZ&B4mucZ{spy!?M(7AnAlj&_2p|c|_nfBF{T!11${2GTaSk%c
zr<!=pI~^0I7qU;13j1o(^cW_};#jG#P#^h^;jaeY(s&~+v{ehKyaFCWDBq*Y`#jmn
zM@_jCFuzS*x9?}==-=HdfwMbmIypji<=54*qyVlB?K`GWR<05rgq&|(tR~<%a-^Iv
zGEUOGX)FZBmqlW45Renf(s;{}kdZILGhGmwQt;S%;bSyNZ_-PKQ+$=EnTNxt7b$YH
ztwoe$Tx_Jg!#_VmF2{MwO2&}EZv&)#q|kW~gfFJT_O=%(3mwVIRGz2|mqH&R#$eGG
zkl;U2nq&oG_|7($r<=rfRgZ{zf)=!0_O+XsSR{g776@AC<9bt_g0M`Py87-U4z(BV
zz=9YaM<VqlCrHe|p_dGsfX;WD7N5P)wV6e^9s_v?Es&B`tebyGBwTcz-f#my@EhV2
z!vq#M&w8{hXoWiCyGwt|2gjR&s&d6Rz2~JtM`sp}E@Gx52@JJPf}~n%WRFX%ibB%8
zzmT;Ba_76p$nOw67c<iN;C4-$yMp-Dtx^d<yX<V1Kt3CeuM*i)Kb8@Df>udkHF%d%
zT7w?oV6zMe{)~gBjzu=w^~S6Q5y1%2=KZ=30b*A;;{g})yHjTI(8#3~w6(|P`^!WE
zxjzer;6;RWC{K6{+k9fI4IOOOtp^zUkx=EIz1LQ<axOFommNi}5B6qRO<br^kFo9Y
ze;$^D0Ay<arGp-UfK~bhNTlaGEozq4ym0tZdb~^|E~YRYIawCZa+7O35j!3={BdaA
z1`ji=%^sc2;Uzr+S7?S?(RMdgQ3)5F`jU?-^U%~mJvOA<EQqNxo7K=EW0Bm2o)>1A
zeMVo$eLN(CBpTfNK1L=6vo5RDW9<=Az-?Kl<zgtr7b3xLiEVd&>~xO*-M!L`I(SYG
zA<)FHLfO5ZjyR+aV_M`Lp9m48q_@M$cOi7fxU)a1VrZ`i-wlS6O1GflYmC~AaW`u0
zI|^A*ITuAQOYd1Q-k8MQ_pvU%Aw-K2Y%#~N<3_70MFdhTX((VJ&>07sQZs69Lbn@f
z(I9V97hL*L3|MDHj>y&cPZtfBm@>X5ZMK2vVtm~c@Lrg^MQBg<Wmw}wL3cXE8f!6f
zUv%|t`6Gmq$$lAXdY;(so6}a0mi3%_8dqntia7jg`%yk}07gTEVg&noK?W3Mqm!#}
zv@#myD_cDuJ<?c+`-Mv}<T%q=L&{>fRwTepTlb2B&}7<p<%A_s*maK7RrR&=Ar^SC
zU3zA>gqgP}>EJnU13M8$gmFcGV|Fp_PRQn4RcyB|dH%1p-AXjq`#lxgIo$8;;EPj(
zW;9`gl+D8MJJj;rw;wRf>`ecx4emz|RmDRo@$kMcCb)pSd=CN-B-h_X$L}&j(j6|X
z2EQ*c00IIJjQbC#5%8V>aEglpKmbk?qx<K5;c-9l$CFda-VXk6(&p?yb|3)ySK)Fm
zbpQMFFy6lp18}N)IG6!Am5i;_;I_Yy{<Gxa`)ehqA^`MzLJH>O3<p5|9RKfS5SJQo
zF=9Pp4e=2wFM|GmTH#^$Kdk`b`AaPj=->4EQw<RKZ$187>GfcjKO{i_US1&NAGO%p
zOAl}Lv1Z|o+uc;3dbi|$(=Rru^y1yy!FY)AuZZI%X)#VjZRm{=O#?&_0y<JkBx^(-
zfso~CSUMvxkR-`brlPdfU+9W{n$~2{+==w488|XZn{8TXPJDFQe0p;+zj3tg;Iud8
z*LPN%fteeOhXezNAmXyM_-%!LJ574BjE}YyLFMisnZvyCno4ZB3@!ILF`Itf`B8|l
z8(xBcWOvbP4QpZv9Id_fGZOT0R(*9>KiIVWUW)%p^d!{kiR&a{S8Zjqwajo{C#$A?
zrkN+%jDg`*?z`>ByU#v3(9?W<@o}#5{B}(4f<HNEN73eS@@=KfRxfv&J=(!xaOD-6
zG;#O9HDV2J=@@>j>GA@78niTq$XTFgyKdA4^9hHG{&sIoq$r4w36*5Oz@Cr(*oP5n
z%|3B^D6YV=3vyj#S@__H_ZU54rf?NNkSXH*9KQRMSO=+3Cc02!!cuOZ)Okm*L2dOb
z{d1Mgtq2KzIze|aO)U#8gSSKM@W>C>*T3jaXkJ7fbtu~@Q%XD2@)QSQG86@8w(D(&
z^@T_EK261cG0NMBGjgahIOeL?IIeOv%jEHl-7nAasKz#(BD=&;Rq}3m*yB*Qx%u$I
zqwtD#vv*`e_-50My45A3L}24c>q53eX}AZG`B|oRsXi&Ozq;y*!kp2>&X2UT^P!k?
zDKGRp6MO3rA@QGbxLDO8vUU;D=_F8E@y)GYs$_T#Dq{NjnHV>%cPjwg8t?13>|3%$
zaWAvU23BDpqNn7q!)Ga}t03E&R=K$n9Bu{d&+s>TvH4+9#iV}TiVJVoiZ_xbsVcn8
zi@z+_PRxrCZ_(DTg?F*f)Y!tj5fzW;uBK|4nf<iY507GshCLt^wQpm@G+EcW)a-q(
z8)Jn8{nD74V&3d6&BSXFpvUjYZ6$@h0v<gVSSPp6t6(&oT(Ue)LZ<p$!+0?gJ|6T*
zd$<`9J-s^dLz&EGQ@iPELsrcAGwDP=(*ch}%`YX~8v{B7&dT<D@P#<L>DK(uK{p0e
z>qSYpEE{XRH_#-;XX=_P4PrKPLC4RBBrq7Li=D^u<~YVpouKi>Hqk{1M*Phq;`k-s
z_>EJ<KwnOt(vyVm;G2%d=ArAhv3mS$c8J$2AgPc19*JH~ijLdGG}xz-B<duckb(BY
ze7RAoZ(-!@g3D`MU~M7(b}W^1ZP0SI*so}oVW8&ZWCkT>^Mkjxfg95c=T#wo)fT7o
zu?fYNJZ&Ju2wH$!{41!3>Wk5>ohW?kXc=w2{FerFHRRa*96@MXJo=MKc0Dm#{)Agi
zqYUtzr*JpvRp$-mwv7(&Cp}c`cmWt0j}SS5?aUqM9POEF@nI4SiiqKFC+Uj`pViaX
z62z`2^&pThLNJ_1^1n|xzoI)pDt2U|iiGI&QwY9|pm`&1ArD%PYgt~L!_egQxvA;9
zAvu-a%2Ro41*Te5TeII~6L|7QkcbG_c>Q_%MdX*2!+<geWDj`;YMGTMU9#<tjQN9u
z9!M)uj4N3A%y_FSn<E9$+^<)%Tx&eiY@(MEo*?8iZ;sW2Gv*yN^(XoG!uu){W~9&r
zpX$HmH#v<>PRynrq5AUSiUI{THDWRF10%U&U!&|cGu@p&E`&oYjo>sCX~~cmM9Bgs
zB#V@nT&ML@$zjq?;(c~pcX!aX(*BKr8khSj9ciF_y<>gI_wKgscJa33hNdD(GuyS>
zvD<@bH|}TLmGU+7H|CAfI<*gKyJ`o?#;O@m%TlzTY-zI2(lM%RV|+{k(iz#8c;^uc
zoE3{ud+*I39*yI6B|dwfrz(V$+bay}jWvEW>^z_Fy*>RB^Kn8`P+P$5P_Wjt;LfuB
z^k$2$MZ0c!xAECLH!YpD^U3$O!xbwbds5Wf3}dPd-*UOtCUlTSE6vb(Fo(#+^F=yz
zcfJmDkHftt1wxe0EWgla_MLX(jgE{l!&zL@G=}DOB958AsGFwxu=N@2#a=F<(t5Md
zdTSepb%*DQoP2f^uMDfFv+37ti#xK>fZqwFE<CR&S~}nvYo1s8y!!s^a!^CvVfCa)
zD;6MT?7f=X>>EZUlvSRDub<at>gr&9Vh4v7Xc&A+gp**3^FK9_CHYdshO1*^p=4nY
zAjT)uFw`tz986a)^;!=%-a!}l04qbYM^GmlPhs(c^NLFS0n>=_InFyuCgRM5vO}UH
zMdPqW`3=e>w+#U`kMsH)cvde4^=`VhV_x3nH4#T^)m=}uuF`eXD~*e`6jY;{sJd?2
zo}Xa6_Sw}%mjbD;pZQ<R>WCI>d9DVV*1yg|><nHAUm{+3j$AJu<!GoW123bj3-^jc
z>go9;zcI@1!aPl=uj%dMt#&={F8)z4IB@Vu(09=^6JKVAGq*v3BMkP0v)Bv)GsIfi
zTC<sX>h|y#{0c&vQwB}DF?)kEr|0V%L}`(mL?6O*V?OG+r_u>9H04}=k=rw!ah#xy
z=?>PNkGMv78FJ8?q|eAtn?UcBPIw9{J5kJ?=3Y>IcY-^E9F*MPBO8^%j^4yTY9TjF
z@Z*WRrk+jlvT0)yAg)4Uj|1yTN$vHoRYNu`fd427WSF!DPYWkn6GSQ`;{}`kaU<;U
zvW0DLrrtT5t%Bbp;c9hc@N}2|BINqDcVXU1+mVunK$EYyzP&RF-J6O}6>}!etu1?J
ztu#R`q0Qf0q>kq~7}6w~>!;rtECWvFRkfFy-IC73$E-o&^Ms-%jtp1vvvQd}Ppwj<
z=u~JYy&}v^sWFkOklauS8$}Xv9P&g6<0C~SqC#*{&|Hz}n&eDxhxP`0s^qy3s|<+y
zvPZsuK71{HC|aLUGgObQK0DADb0;svBE6Q~_gFf%C|3Qn^|=YEPt5oHqb;Q_;%=`b
z-tz9}uim%`q%xt%em(*v)=YyJ%u2?sOGkPe#e-`n`!5T4X~~1KX!tPw2u*}QWzP?>
zyFzz=(H-HJ;5VU~3DO%=y{1rYi$xq4oSMEY@Kzw&nTm}+oR3|D3U7Q6oU1BhXB;cD
zP;@)Jvl}w^dV(j&q=xj89eYJCHAJ*DWZ)6DQfiT&^jm^v%~f;@LJk-BF>^eI#(ZuU
zQz!Ju0ETi~Rv#Yb78K}~AK^v^!dcR%1|Xyr4ubbP#Wii!2gXbKH8z-xE$VwPE@5GZ
zhmD`C=+;=z7g}z$wd|u`JS#qz`4Ft%DX9q7a0-~$T(KmQ=O#uZcWz*|sV$0}a@@qD
z^T~WW+5sL8of0{XXC!G}x?3L2U#aYfsVVy)xZbxj5wx66Pz`>j*xj3UUh(+qj!=@i
zJK0PzEh&}T=*vQg39!kF30lveayHLg*l~ck-hA-9|MscQ$F3NUikgnu?y2ES#9$bI
z&(n2Klrp|S=Ta%vUSl{XV-yXII(0+{&`6%@&{$kHPmFMNK8f*=Po;iM%GEuN!;-oe
zhn3}YK?c2kG@`XxUnqs}os(WD9Gcq_y*VeAkeQSUF{^P>3#V|fZtk*zvr4#j%1dp2
zSB#mIK&a+};HR_3mlWk)ukq|y!KMmFTYK-MI$KYbMQ=U9nX(o?rr?a^9g&A}PR9tJ
z5*a?F)pSR$+8(-k#7ER~A!%*R6i~oOeMZY^I_UMbf2L4<Uf|v+K{#S<$q`{<O7X(v
z!#MjXCoiL96Qu&QGBKI*fHLp)KfUmH{o3Qgjg4Gio0q@BA;hVRF{<=+_XZFwj*&*$
zVa3Q=r>aE83a!9@YMvNLS|XQUO^R&A<q5)7nbl!)U^zWisGVgm$<hNW^2qZj@+i2<
zyMiTDWw4Vi9o6#-F%0*uz%gA(;@onq!rI3SpSxS(>8mb!C%rAYTNDG>!t;}(y`1?W
z*MUldzDx%2CGEy0d(e*M?MzqZ;~J)8Dv9QDQR<~<oU%PR2Omz8V8KM=VCmE@39a~x
zq6B}fRV<<9;Z2{s_Ffca4jFi;*ilZ+cV>ycOdjs*O$*j_*S+Hsm(%93YySvuNLQ{l
zpP<!OveU^NtIr5#s{K}K<%VnT``>-Ede3j&G-jeuiBs+QUMP`>Q{H#E_$7U$6;Lbh
zyY{I_h9$byci|*{=2E!KD)&vbv|Ymn=P0`$j|g!~t4-?d)U#7ccVGJ-A+uhSYd(j+
z3h3)MA}dz!!d8bm*auoYZ+=O_XeZux2V==E#^lKRN5x6t?91};2hptwNHdu>=NCl^
z?sX(cxV|dg40o~&tNwiAR{ODUfkX3PJfiBoG+UGiTftVdneP>bZfaS-y@I}IuWE13
ztWE;){#J9YIubezLKWR(1mNLN7*MSEN_*!?s<IXZ8l;j-{}5WcSD7v4Y@hHoowZ{2
zYzg{UXJ#Q;_-)1e>#qrgAwgcQPlbpxN%-KFKO0<>(%x3BANNoAHteqXZ}eie-UiV|
zzkiOi7t_*YICJ`qhg%@3=1Q;wPI$2hwA*`=P_No7sw9VvdV^&Jj9()rY;zLlbKrj^
zF2SW8&HtV8SdT^IoBmL4j)ZJAhfy+kvk9fsi|cq^y6Sk7J{IK|!MP0)BrPatr8;EN
zf<TjwK|_&D8cbgs@40Eo|K^aKBZk6`v@@D#_PYYel1MM?lICYvAvfRb4EXW4%MI_j
z*1#F37|*pbgOOMJ$2ThD>O-rYLn9U?Ny6&hqo|`=)!X?AJxHWm;YIx~dNXcW7Sfbo
ziq%)sGZ^l726U}MV8{Ko@}g>+4NIRx5PfQr%As2Wc}@YtXgVqu(5Zny$x4hsrlK^}
zf!DWRM2v<sGrVsa1L<%=+9+Q{6(Wd-3xC_0njNmHFRfpDBg?6I6A*a4_V(s*0*<KA
za<tgoCm+kf=jC+RS#802yZjltu+owxgstL3q`yM$Nv*Ghd+EK9q|x1~;k_?{yN*On
z`+<*eO>S6UBD_J5c@08tPQZt-QlYUU##uH7E6o|vsU%m(csaE7iHkS7Fb$3I>Hb*S
z1u7m&S*Oh?%n^aXypifx%CV8M$}Uo-K1V;DP0+TvK|QU`>6=5Pq0)B~@AQMPJK7!6
zooXZ0qGqi=>Rc?@)S1_L)G_GGSC@`cjnb9>=or;T7i~*2fxe}8J5%zAa=uP-7W#45
zbK7v+)!>uy_W2pq9;NJ;PgP!^V*JeGqi7P9+U#6AHJEl<&O9~B$|8y?aIQ{dJYP9E
zcx5}YFpHt)kb*>}EU_A2|D9U;sse-NZfmPZ7XWZ~gQ7~>Ad0b#JxnUor<k5v19?vq
zO|;+;I+Bk=v_q$!%^Mg+dKk_cLZKRsVWWCe8Zc^TwQT9rVie^V1&iWaNZ6xTp(Y?D
z=vShAnr4+^m0_M{m9?Bro<g3H#ybI=;GKX>2ta{QUg$?L1G5saW-80To7;CH8kH;`
z1=OuexX0712CUgW-%g9zR`NJ1FjcU#r*$#cs{A;ao3T`7V>sWnRX-4V_O^PZIEK=|
z^;h&6j*8r1o^^Cz$5+n1iyrX}1CJ|)3#CJ?&q!)Oerk8uqlR}x9wy(ieQsCn!NaT7
zUOd98x-Zq@+<sbn37<3J_tjE~3ff8ucIIOf%gJ^SFd=!pv5hY4$H)Q;HuMvQwo5^1
z%$+>BYj~rLU-yQ7{E+M2D6TwLU>u6>yS;I}xN+0JcXV}w;5U@bJ1;a3nul=|L45*L
z*mf`9f+?DBHEc{VGBVs94))d%wlAx)b=DFOr7d0L24Xpcyi|qi%{IQX>$=uB2xkdJ
zr?u3*ko3sBj%w0rnb~O6)RauTkbv|XWJ-UHGQzvrG_ex874N~!@fJdO(Ss!q)P!xQ
zEi&QFi$F471!(mrc{X(X)Fk90=I)|ZK7OY=YEsW!#d5>qf86W->u@{IZZYB{Wd${p
z2GlJ)zHm$b_J=_o{)fu#dD~yfu9rwBzBNY5r!QiXCA(z9W$l=pxBI-utDda2B>bYU
z?dkf$m@EoGSBz$)gqX7ipJKg!m%F;tY`4bfsWy!UZT@Dg$pm6{TP<nIjin^*TO4cF
zt=-kI+U^Rqg4(|Gu{0SANIZm2+=}0xC361qzMOtct>=|i^XaM3?CJ5+*ZsxI<m3|y
z9i8uu9KUV`#>!f!yxQM5Sl;}IB#HeXOjzwM*^;vIB#X79I2LWvgyzKbky_`~menP2
z?tA8n5Jtgbp^f}vr{Qv&|6z05ryq?l^q2|km>EZbyUTOoTjm9*P+lX9buOsTwld@E
zA?76}<;LC83%ZXh18q{}DPxWM!@Cm4UXHa!e$c_7S*)A>J2R5VOX!kcPP`$O#k;~S
zWm@Rnqp}do1F53BVy|oAI~AmtF~io+>`gpK7Ipzd?jx_Hr}uBTRLf4Ymt0=7XW^!R
z&-8~C)f}mc3HyzRF0wm(oE&~}Wwbt;u{CYspT{H_t)k#?C>s**@2E}Pj^G)_G4Y_{
z=y=z#ZR^D9@rF`)ehOtc>S&iyt5Uvgt~j1x73q?6N}4l~zbchYi)OPB^;nchd%e2P
z>LTr0MDXQSnc>?5*C{EMxIu!ts}^lxg+e!RbhaGlIPn-Nf9A=?Wc7Up?JriT1&1Un
z0V`Gq*P^~XD7%mKSg4C0?^CWtVb<LtII#{lK4Q)ce51A*$|+01gcfUI(GA&wH2GV8
zaxvwJ85hHudw-CCull&!F;wi=j6B8`kpN2cdP>N_rl72+NSITPnq2;{zB6KL3Pr!n
zU8A|k5Ne*O`Dhd4kPr~)jFa8AE;UujME^6-+i5e=4{|Omb$OiXjQHcIR)Ku>q$WXj
z5^9ap!ovQm>vo3GtivX%u|j`-24bA`d2u1!pm=$GW!_)|SFqKm)h}wlW!J=pg)|pr
z_#{uC&FhCq^Fqr)t-8Bk<z3g{V17qRc2ws(A-=U5k3cqmw;qU40Govo7~7g^b!k#X
zwL^%e4^lWOoXuv!G2F+!R97`FIleT_bv_$>0&qj-5+{LmUJ8~|Or|3VmM1rb?Zp~u
zWKp2PQi6$&WFkH}+kSkPlSm!@yj=Qm;GPb2+^zDJ_-S77=E140$R-)^mJG9U*>l9I
zoI01nTH@PlFYOjUM}+fh;#KNzHmu4On|G9Tq1BQXezF?mzKTl2GLbCY0l&oTCEe+6
zSZgj^KZstQE0BGkT8fULKb2x`qB(dfyWc?eJqx|My3m0Ut2lB={b>g9iz8jrWkgUj
zd4Lw>5LG~SpM!kJTeI_2ENN3-%I3_cyRSEQ9ArX*T=o;NICU0ZBQc%^BH^SgUZ7on
zBFs8!Z$T5dl4thP46%5zv}KOz#ZNY^NujL^{*{U2g?#SF`02yhM@_P<Y4*zErb=CZ
zeRkp+Rx%xjSCJ?>^uEtHX1Dw^vAwHN(im=gOeYWWZED0rp4H4u5%g60q^H`}em!+%
zk@fVQ(L|at53$`zl2N;Ok2>j@X8-PkiNZIdK02uy$zXQ;R<Z@2*nlpDZ!hz)(s_uh
z@2Av|S{=o~Gul`b48BOipJ~X(D+s1MsmtxDdD*e|e@bXaN>{MIrZ)R(;<#_gC14yJ
zGORid5chf0w!N~n#E<F4i|9h^UNYWGRVDtO$STb!8m$bwa=ZPJ?ieQS2g)ugthQdG
zN<@<P`|VC-zD!@M3e9WeLki8cSq{crDoqb~YYOm*V}stkASlDnc^6Ot5iRV{T8t-Z
zR&LqkWqoV(<BM_4CNG=SA_<3#IcB6$ZU?7K2slH19J8=+-=AQ;&!H8I;RyUP9P0?Y
zBt#ZrcHR!JtHp^hO?i&K-o4KWo^_^d;rv>zS~r8>CTX~ysmW7~v-?SG$sL9`YZMGC
z1ahl<E8_W@gf@$V*f@uiXzM^>VOZPwwIJM;rxc%25pPoBxjd=8DFHGm=hl=vos4H3
zA>a4q)(NbYb1WV^)LETH!&=4Az>lb!i~fk=)Ykr>3m%>#(nIM;wguFD$!@N%Ok_^d
z{MsL|=$wDq6d*a#q9&V!cC&jDgGA_yvUQK+GS|$f5&^6uJyo-DE@^|uWZFdpV2X1r
zALc&GkYmVWxojL*w?rD!FugBwf>0izYN$o^=mC%togxd{$UE3fh776494f~VQV<u-
zFc65xfjI@BKM3bXL!D*Q#zJWAMzllASif;kF+lc1+T-$9T5hHxHGdsUzu#fOHOLnB
zO@F1jojnK>*QE#Vng7U=;rAB~lRN!Ok3u_Ub_~CI)T{vV+$G77z0nBTB93*_+XGFA
z$@=R8rm)S!p*@BjAu8nh=%^VcB}hKZo1bV$_(WI(LnKp*a7aIxJXv()5<+rN`~C<{
zj7MhqoL#>$wdf}MCjQPA@pcP0f7lNZ>&=Sge*zo7@rpl@4IVHA@;A2eFM#JS!~y_%
z=rsF(Yb(=N?XwF4;x%2ddduTJ310glgI4;2lk!p-ChR}?b5s?SO!N4*<&}NX3&FOS
z39gm+iK$Y*-AsM6Qz~=rMV4q6{zb4skeEkTq|36hjP01GZeeSh6lWC^RgGC^shc^m
zEo*gbU46MxV&gNx>;q95=IYuUkhWWVW5r0@`=#w0T*Xbz)W{Es<O-j>$Zme}=JqGJ
zFZ`^tpRlDi^NSiB$Y&eAY>OW)cRa}d0&KvH;2C^AMLvQKzg(bNW#gkb5k&nlE?Kbd
z!S)0il^&KZu%s=a3*<nXAaZ6|uB@T4MT!dGjqUd+5IRcl;3RvyS~{gBtyiTaE5u;I
z#4O&qp$X@p#E)UPq@KEyNfER@L|zx~jrtWkYT*a)TNDuS!1zij?(-ctiF%SC!D67U
z$R;DV0E_6TtYhPT(*Fo)?Qu(}wk2LIMREMlO#PsazId34A}-s&TSn`r^9woIf~CV}
zm^IDS^#8@Be>DW&gH2pK|MKWxNZtb|_Xmph0KrL^Ih#1a9N_j&e*k6oEJY*R2Z&8g
zUQOo(tAv@Ak*159nG?+XZviPITbPXpfa#Ap!0$=sKW1%=ESv#c;J-!1#O&Pxx&U@4
z4<CS?3&H~cgMi!s5D3Tz(ElwY3pcWXnTXn1*q8x;zd54LCT920ARn0bH~FC81I-TR
z;{MGLH*%0MgIQR@e{b`fr3N>%)dcYVvHpRO`HOhC;yn;&2EG^m9lifT6(6w1hsgh@
zJ^t9w#Tfn@XH<7`F?+DpZ?2e;v)OOd@_)3=1L7!dY2@^m1>}wXq(LC)?=AjmaRBIF
zjhd2n_q~}gI|~4(7R*l6&KdR><M%o(m?_-S`QDIRASeef^xk|APX6y-F0OkKJ|GX6
z``@LxxOh1DK#+SjfaiV)<^n?QUGo27_)jIFU@!-W2g-MUHk1p(!OO!1=6!I?A73aR
zF9+{E<6iZ@Sbx2FpkNMOZV>mq{tql3UTzK`H!t`9Vu#;i5FiJLiw6pN0C0K!MR4=o
z_s{b2@IoIB`Zqog1i}G?fFIQ30`cAJ0s;SC`j-~}5C#GuP+kro`2Hdg05^z>1H{Yq
zpb!KIx>uF^w|)P$-|uk0|L56j*ufs!Z~>r)6s!7gFgNJolz&E~(tqIGpa(Ggk0h-4
zH@N)(bc4D6h_L@l!>>ksyVX}9p2Xg5M19h9Xcz0Vh;&1zFr?h1Ku1qjK{QF;5Mwe~
zj)4WOs+FX?5g~I(H5-zo4Yr~RYS+sSCpKp)B9!4X>xwwdJQW_qxRx4=NL*9E=sBfI
zY3TO=$;P?Ok|-fuRk9A%Pf|hblShGg1{pthcod|kNq-pVz(}ScvS1&RB!~CAIA54M
zLT#m{B0#;cug=R#9n|3oe5)12RNnA?tuG}*bP$U6bpBf73O{fC!&tMZ%ASd{@ysL7
z$gw#Gi07sXp%K~<A$XW9Q-C|K+6OIhf~>VIRdhgYOXKm$+zSorGla|GfQjDib{Vse
zO%_>ADh;KLCl=?m2Fw}f!vnU0et|QtuZ}SjPwk)lmn8aE&%u2X1w;RCd-xp;|8$YI
zs@Wfz@y`wb=pSk8e?tG&V4h|G@E@5<3!n=EfC1n?GNG!y{e4RNy90t#*3R4>0OI*8
zNd9iwHZe3jzsn8}hzvlG0D=xb0f9j9J`#GCUL5J;xWX-*WnX0crcM#DE7Y(t1o}~L
z5ebaAp}5CS%<<GnMUlDkIb_6Y(*h74k;kBS{O84;;YLnycc=S1fj~SEE(`_+NhK+a
F{{u5ZdG7!K

literal 0
HcmV?d00001

diff --git a/tests/topotests/bgp_peer_shut/exabgp.env b/tests/topotests/bgp_peer_shut/exabgp.env
new file mode 100644
index 000000000000..ec978c66e76e
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/exabgp.env
@@ -0,0 +1,55 @@
+
+[exabgp.api]
+ack = false
+encoder = text
+highres = false
+respawn = false
+socket = ''
+
+[exabgp.bgp]
+openwait = 60
+
+[exabgp.cache]
+attributes = true
+nexthops = true
+
+[exabgp.daemon]
+daemonize = true
+pid = '/var/run/exabgp/exabgp.pid'
+user = 'exabgp'
+##daemonize = false
+
+[exabgp.log]
+all = false
+configuration = true
+daemon = true
+destination = '/var/log/exabgp.log'
+enable = true
+level = INFO
+message = false
+network = true
+packets = false
+parser = false
+processes = true
+reactor = true
+rib = false
+routes = false
+short = false
+timers = false
+
+[exabgp.pdb]
+enable = false
+
+[exabgp.profile]
+enable = false
+file = ''
+
+[exabgp.reactor]
+speed = 1.0
+
+[exabgp.tcp]
+acl = false
+bind = ''
+delay = 0
+once = false
+port = 179
diff --git a/tests/topotests/bgp_peer_shut/peer1/exa-send.py b/tests/topotests/bgp_peer_shut/peer1/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer1/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer1/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer1/exabgp.cfg
new file mode 100644
index 000000000000..97a024ce9620
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer1/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 1 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 1;
+    encoder text;
+}
+
+neighbor 10.0.1.1 {
+    router-id 10.0.1.101;
+    local-address 10.0.1.101;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer10/exa-send.py b/tests/topotests/bgp_peer_shut/peer10/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer10/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer10/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer10/exabgp.cfg
new file mode 100644
index 000000000000..e318162a1faf
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer10/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 10 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 10;
+    encoder text;
+}
+
+neighbor 10.0.2.1 {
+    router-id 10.0.2.110;
+    local-address 10.0.2.110;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer11/exa-send.py b/tests/topotests/bgp_peer_shut/peer11/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer11/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer11/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer11/exabgp.cfg
new file mode 100644
index 000000000000..ea5bdcce804a
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer11/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 11 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 11;
+    encoder text;
+}
+
+neighbor 10.0.3.1 {
+    router-id 10.0.3.111;
+    local-address 10.0.3.111;
+    local-as 111;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer12/exa-send.py b/tests/topotests/bgp_peer_shut/peer12/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer12/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer12/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer12/exabgp.cfg
new file mode 100644
index 000000000000..81fb5035f756
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer12/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 12 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 12;
+    encoder text;
+}
+
+neighbor 10.0.3.1 {
+    router-id 10.0.3.112;
+    local-address 10.0.3.112;
+    local-as 112;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer13/exa-send.py b/tests/topotests/bgp_peer_shut/peer13/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer13/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer13/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer13/exabgp.cfg
new file mode 100644
index 000000000000..40078411ec10
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer13/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 13 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 13;
+    encoder text;
+}
+
+neighbor 10.0.3.1 {
+    router-id 10.0.3.113;
+    local-address 10.0.3.113;
+    local-as 113;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer14/exa-send.py b/tests/topotests/bgp_peer_shut/peer14/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer14/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer14/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer14/exabgp.cfg
new file mode 100644
index 000000000000..afb8741636d1
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer14/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 14 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 14;
+    encoder text;
+}
+
+neighbor 10.0.3.1 {
+    router-id 10.0.3.114;
+    local-address 10.0.3.114;
+    local-as 114;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer15/exa-send.py b/tests/topotests/bgp_peer_shut/peer15/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer15/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer15/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer15/exabgp.cfg
new file mode 100644
index 000000000000..9a4ca7f695b8
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer15/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 15 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 15;
+    encoder text;
+}
+
+neighbor 10.0.3.1 {
+    router-id 10.0.3.115;
+    local-address 10.0.3.115;
+    local-as 115;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer16/exa-send.py b/tests/topotests/bgp_peer_shut/peer16/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer16/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer16/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer16/exabgp.cfg
new file mode 100644
index 000000000000..a0bb88a3f3a3
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer16/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 16 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 16;
+    encoder text;
+}
+
+neighbor 10.0.4.1 {
+    router-id 10.0.4.116;
+    local-address 10.0.4.116;
+    local-as 116;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer17/exa-send.py b/tests/topotests/bgp_peer_shut/peer17/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer17/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer17/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer17/exabgp.cfg
new file mode 100644
index 000000000000..870d33d45599
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer17/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 17 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 17;
+    encoder text;
+}
+
+neighbor 10.0.4.1 {
+    router-id 10.0.4.117;
+    local-address 10.0.4.117;
+    local-as 117;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer18/exa-send.py b/tests/topotests/bgp_peer_shut/peer18/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer18/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer18/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer18/exabgp.cfg
new file mode 100644
index 000000000000..c5a1ca62e416
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer18/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 18 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 18;
+    encoder text;
+}
+
+neighbor 10.0.4.1 {
+    router-id 10.0.4.118;
+    local-address 10.0.4.118;
+    local-as 118;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer19/exa-send.py b/tests/topotests/bgp_peer_shut/peer19/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer19/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer19/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer19/exabgp.cfg
new file mode 100644
index 000000000000..f662ccf93e2b
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer19/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 19 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 19;
+    encoder text;
+}
+
+neighbor 10.0.4.1 {
+    router-id 10.0.4.119;
+    local-address 10.0.4.119;
+    local-as 119;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer2/exa-send.py b/tests/topotests/bgp_peer_shut/peer2/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer2/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer2/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer2/exabgp.cfg
new file mode 100644
index 000000000000..673d6ec0eef9
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer2/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 2 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 2;
+    encoder text;
+}
+
+neighbor 10.0.1.1 {
+    router-id 10.0.1.102;
+    local-address 10.0.1.102;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer20/exa-send.py b/tests/topotests/bgp_peer_shut/peer20/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer20/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer20/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer20/exabgp.cfg
new file mode 100644
index 000000000000..5ea2c91de142
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer20/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 20 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 20;
+    encoder text;
+}
+
+neighbor 10.0.4.1 {
+    router-id 10.0.4.120;
+    local-address 10.0.4.120;
+    local-as 120;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer3/exa-send.py b/tests/topotests/bgp_peer_shut/peer3/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer3/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer3/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer3/exabgp.cfg
new file mode 100644
index 000000000000..47a25cab223c
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer3/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 3 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 3;
+    encoder text;
+}
+
+neighbor 10.0.1.1 {
+    router-id 10.0.1.103;
+    local-address 10.0.1.103;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer4/exa-send.py b/tests/topotests/bgp_peer_shut/peer4/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer4/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer4/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer4/exabgp.cfg
new file mode 100644
index 000000000000..376ac5f37dca
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer4/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 4 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 4;
+    encoder text;
+}
+
+neighbor 10.0.1.1 {
+    router-id 10.0.1.104;
+    local-address 10.0.1.104;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer5/exa-send.py b/tests/topotests/bgp_peer_shut/peer5/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer5/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer5/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer5/exabgp.cfg
new file mode 100644
index 000000000000..878d728de645
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer5/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 5 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 5;
+    encoder text;
+}
+
+neighbor 10.0.1.1 {
+    router-id 10.0.1.105;
+    local-address 10.0.1.105;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer6/exa-send.py b/tests/topotests/bgp_peer_shut/peer6/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer6/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer6/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer6/exabgp.cfg
new file mode 100644
index 000000000000..fc702674cf48
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer6/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 6 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 6;
+    encoder text;
+}
+
+neighbor 10.0.2.1 {
+    router-id 10.0.2.106;
+    local-address 10.0.2.106;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer7/exa-send.py b/tests/topotests/bgp_peer_shut/peer7/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer7/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer7/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer7/exabgp.cfg
new file mode 100644
index 000000000000..09827a89024b
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer7/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 7 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 7;
+    encoder text;
+}
+
+neighbor 10.0.2.1 {
+    router-id 10.0.2.107;
+    local-address 10.0.2.107;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer8/exa-send.py b/tests/topotests/bgp_peer_shut/peer8/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer8/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer8/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer8/exabgp.cfg
new file mode 100644
index 000000000000..37c01dabb790
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer8/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 8 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 8;
+    encoder text;
+}
+
+neighbor 10.0.2.1 {
+    router-id 10.0.2.108;
+    local-address 10.0.2.108;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/peer9/exa-send.py b/tests/topotests/bgp_peer_shut/peer9/exa-send.py
new file mode 100755
index 000000000000..1a8e6bfe2ffd
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer9/exa-send.py
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+"""
+exa-send.py: Send a few testroutes with ExaBGP
+"""
+
+from sys import stdout, argv
+from time import sleep
+
+sleep(5)
+
+# 1st arg is peer number
+# 2nd arg is number of routes to send
+peer = int(argv[1])
+numRoutes = int(argv[2])
+if peer <= 10:
+    asnum = 99
+else:
+    asnum = peer + 100
+
+# Announce numRoutes equal routes per PE - different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.201.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes per PE - different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.202.%s.0/24 med 100 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.203.%s.0/24 med %i next-hop 10.0.%i.%i origin igp\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100)
+    )
+    stdout.flush()
+
+# Announce numRoutes equal routes with different med per PE and different neighbor AS, but same source AS
+for i in range(0, numRoutes):
+    stdout.write(
+        "announce route 10.204.%s.0/24 med %i next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+        % (i, peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+    )
+    stdout.flush()
+
+# Announce 2 different route per peer
+stdout.write(
+    "announce route 10.205.%i.0/24 next-hop 10.0.%i.%i origin igp\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100)
+)
+stdout.write(
+    "announce route 10.206.%i.0/24 next-hop 10.0.%i.%i origin igp as-path [ %i 200 ]\n"
+    % (peer, (((peer - 1) / 5) + 1), peer + 100, asnum)
+)
+stdout.flush()
+
+# Loop endlessly to allow ExaBGP to continue running
+while True:
+    sleep(1)
diff --git a/tests/topotests/bgp_peer_shut/peer9/exabgp.cfg b/tests/topotests/bgp_peer_shut/peer9/exabgp.cfg
new file mode 100644
index 000000000000..8fb5c58b6b97
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/peer9/exabgp.cfg
@@ -0,0 +1,18 @@
+process announce-routes {
+    run /etc/exabgp/exa-send.py 9 10;
+    encoder text;
+}
+
+process receive-routes {
+    run /etc/exabgp/exa-receive.py 9;
+    encoder text;
+}
+
+neighbor 10.0.2.1 {
+    router-id 10.0.2.109;
+    local-address 10.0.2.109;
+    local-as 99;
+    peer-as 100;
+    capability {graceful-restart;}
+    api {processes [ announce-routes, receive-routes ];}
+}
diff --git a/tests/topotests/bgp_peer_shut/r1/bgpd.conf b/tests/topotests/bgp_peer_shut/r1/bgpd.conf
new file mode 100644
index 000000000000..49981ac58968
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/r1/bgpd.conf
@@ -0,0 +1,51 @@
+!
+hostname r1
+log file bgpd.log
+!
+router bgp 100
+ bgp router-id 10.0.255.1
+ bgp bestpath as-path multipath-relax
+ no bgp ebgp-requires-policy
+ neighbor 10.0.1.101 remote-as 99
+ neighbor 10.0.1.101 timers 3 10
+ neighbor 10.0.1.102 remote-as 99
+ neighbor 10.0.1.102 timers 3 10
+ neighbor 10.0.1.103 remote-as 99
+ neighbor 10.0.1.103 timers 3 10
+ neighbor 10.0.1.104 remote-as 99
+ neighbor 10.0.1.104 timers 3 10
+ neighbor 10.0.1.105 remote-as 99
+ neighbor 10.0.1.105 timers 3 10
+ neighbor 10.0.2.106 remote-as 99
+ neighbor 10.0.2.106 timers 3 10
+ neighbor 10.0.2.107 remote-as 99
+ neighbor 10.0.2.107 timers 3 10
+ neighbor 10.0.2.108 remote-as 99
+ neighbor 10.0.2.108 timers 3 10
+ neighbor 10.0.2.109 remote-as 99
+ neighbor 10.0.2.109 timers 3 10
+ neighbor 10.0.2.110 remote-as 99
+ neighbor 10.0.2.110 timers 3 10
+ neighbor 10.0.3.111 remote-as 111
+ neighbor 10.0.3.111 timers 3 10
+ neighbor 10.0.3.112 remote-as 112
+ neighbor 10.0.3.112 timers 3 10
+ neighbor 10.0.3.113 remote-as 113
+ neighbor 10.0.3.113 timers 3 10
+ neighbor 10.0.3.114 remote-as 114
+ neighbor 10.0.3.114 timers 3 10
+ neighbor 10.0.3.115 remote-as 115
+ neighbor 10.0.3.115 timers 3 10
+ neighbor 10.0.4.116 remote-as 116
+ neighbor 10.0.4.116 timers 3 10
+ neighbor 10.0.4.117 remote-as 117
+ neighbor 10.0.4.117 timers 3 10
+ neighbor 10.0.4.118 remote-as 118
+ neighbor 10.0.4.118 timers 3 10
+ neighbor 10.0.4.119 remote-as 119
+ neighbor 10.0.4.119 timers 3 10
+ neighbor 10.0.4.120 remote-as 120
+ neighbor 10.0.4.120 timers 3 10
+ !
+!
+
diff --git a/tests/topotests/bgp_peer_shut/r1/summary.txt b/tests/topotests/bgp_peer_shut/r1/summary.txt
new file mode 100644
index 000000000000..68de28a35be5
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/r1/summary.txt
@@ -0,0 +1,131 @@
+{
+"ipv4Unicast":{
+  "routerId":"10.0.255.1",
+  "as":100,
+  "vrfName":"default",
+  "peerCount":20,
+  "peers":{
+    "10.0.1.101":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.1.102":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.1.103":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.1.104":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.1.105":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.2.106":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.2.107":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.2.108":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.2.109":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.2.110":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.3.111":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.3.112":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.3.113":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.3.114":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.3.115":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.4.116":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.4.117":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.4.118":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.4.119":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    },
+    "10.0.4.120":{
+      "outq":0,
+      "inq":0,
+      "pfxRcd":42,
+      "state":"Established"
+    }
+  },
+  "totalPeers":20
+}
+}
diff --git a/tests/topotests/bgp_peer_shut/r1/zebra.conf b/tests/topotests/bgp_peer_shut/r1/zebra.conf
new file mode 100644
index 000000000000..77c76cd4907a
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/r1/zebra.conf
@@ -0,0 +1,16 @@
+!
+hostname r1
+log file zebra.log
+!
+interface r1-eth0
+ ip address 10.0.1.1/24
+!
+interface r1-eth1
+ ip address 10.0.2.1/24
+!
+interface r1-eth2
+ ip address 10.0.3.1/24
+!
+interface r1-eth3
+ ip address 10.0.4.1/24
+!
diff --git a/tests/topotests/bgp_peer_shut/test_bgp_peer_shut.py b/tests/topotests/bgp_peer_shut/test_bgp_peer_shut.py
new file mode 100644
index 000000000000..17533b604747
--- /dev/null
+++ b/tests/topotests/bgp_peer_shut/test_bgp_peer_shut.py
@@ -0,0 +1,180 @@
+#!/usr/bin/env python3
+# SPDX-License-Identifier: ISC
+
+#
+# test_bgp_peer_shut.py
+# Part of FRR Topology Tests
+#
+# Copyright (c) 2017, 2024 by
+# Network Device Education Foundation, Inc. ("NetDEF")
+#
+
+"""
+test_bgp_peer_shut.py: Test BGP peer shutdown
+"""
+
+import json
+import functools
+import os
+import sys
+import pytest
+
+# Save the Current Working Directory to find configuration files.
+CWD = os.path.dirname(os.path.realpath(__file__))
+sys.path.append(os.path.join(CWD, "../"))
+
+# pylint: disable=C0413
+# Import topogen and topotest helpers
+from lib import topotest
+from lib.topogen import Topogen, TopoRouter, get_topogen
+from lib.topolog import logger
+
+# Required to instantiate the topology builder class.
+
+
+pytestmark = [pytest.mark.bgpd]
+
+
+total_ebgp_peers = 20
+
+#####################################################
+#
+#   Network Topology Definition
+#
+#####################################################
+
+
+def build_topo(tgen):
+    router = tgen.add_router("r1")
+
+    # Setup Switches - 1 switch per 5 peering routers
+    for swNum in range(1, (total_ebgp_peers + 4) // 5 + 1):
+        switch = tgen.add_switch("s{}".format(swNum))
+        switch.add_link(router)
+
+    # Add 'total_ebgp_peers' number of eBGP ExaBGP neighbors
+    for peerNum in range(1, total_ebgp_peers + 1):
+        swNum = (peerNum - 1) // 5 + 1
+
+        peer_ip = "10.0.{}.{}".format(swNum, peerNum + 100)
+        peer_route = "via 10.0.{}.1".format(swNum)
+        peer = tgen.add_exabgp_peer(
+            "peer{}".format(peerNum), ip=peer_ip, defaultRoute=peer_route
+        )
+
+        switch = tgen.gears["s{}".format(swNum)]
+        switch.add_link(peer)
+
+
+#####################################################
+#
+#   Tests starting
+#
+#####################################################
+
+
+def setup_module(module):
+    tgen = Topogen(build_topo, module.__name__)
+    tgen.start_topology()
+
+    # Starting Routers
+    router_list = tgen.routers()
+    for rname, router in router_list.items():
+        router.load_config(
+            TopoRouter.RD_ZEBRA, os.path.join(CWD, "{}/zebra.conf".format(rname))
+        )
+        router.load_config(
+            TopoRouter.RD_BGP, os.path.join(CWD, "{}/bgpd.conf".format(rname))
+        )
+        router.start()
+
+    # Starting Hosts and init ExaBGP on each of them
+    topotest.sleep(10, "starting BGP on all {} peers".format(total_ebgp_peers))
+    peer_list = tgen.exabgp_peers()
+    for pname, peer in peer_list.items():
+        peer_dir = os.path.join(CWD, pname)
+        env_file = os.path.join(CWD, "exabgp.env")
+        peer.start(peer_dir, env_file)
+        logger.info(pname)
+
+
+def teardown_module(module):
+    del module
+    tgen = get_topogen()
+    tgen.stop_topology()
+
+
+def test_bgp_convergence():
+    "Test for BGP topology convergence"
+    tgen = get_topogen()
+
+    # Skip if previous fatal error condition is raised
+    if tgen.routers_have_failure():
+        pytest.skip(tgen.errors)
+
+    # Expected result
+    router = tgen.gears["r1"]
+    reffile = os.path.join(CWD, "r1/summary.txt")
+
+    expected = json.loads(open(reffile).read())
+
+    def _output_summary_cmp(router, cmd, data):
+        """
+        Runs `cmd` that returns JSON data (normally the command ends
+        with 'json') and compare with `data` contents.
+        """
+        output = router.vtysh_cmd(cmd, isjson=True)
+        return topotest.json_cmp(output, data)
+
+    test_func = functools.partial(
+        _output_summary_cmp, router, "show ip bgp summary json", expected
+    )
+    _, res = topotest.run_and_expect(test_func, None, count=30, wait=1.0)
+    assertmsg = "BGP router network did not converge"
+    assert res is None, assertmsg
+
+
+def test_bgp_peer_shut():
+    "Test shutdown of all exabgp peers"
+
+    tgen = get_topogen()
+
+    # Skip if previous fatal error condition is raised
+    if tgen.routers_have_failure():
+        pytest.skip(tgen.errors)
+
+    logger.info("=== Checking for bgp routes ===")
+
+    expect = {
+        "routerId": "10.0.255.1",
+        "routes": {},
+    }
+
+    for net in range(1, 5):
+        for subnet in range(0, 10):
+            netkey = "10.20{}.{}.0/24".format(net, subnet)
+            expect["routes"][netkey] = []
+            for _ in range(0, 10):
+                peer = {"multipath": True, "valid": True}
+                expect["routes"][netkey].append(peer)
+
+    test_func = functools.partial(
+        topotest.router_json_cmp, tgen.gears["r1"], "show ip bgp json", expect
+    )
+    _, res = topotest.run_and_expect(test_func, None, count=40, wait=0.5)
+    assertmsg = 'expected multipath routes in "show ip bgp" output'
+    assert res is None, assertmsg
+
+    logger.info("=== Stopping all dynamic peers ===")
+
+    # Stop the dynamic peers
+    epeers = tgen.exabgp_peers()
+    for key in epeers:
+        epeers[key].stop()
+
+    # for debugging
+    #tgen.cli()
+
+if __name__ == "__main__":
+    args = ["-s"] + sys.argv[1:]
+    sys.exit(pytest.main(args))