diff --git a/crates/server/src/bgp_server.rs b/crates/server/src/bgp_server.rs index 0a555a5..a7403b2 100644 --- a/crates/server/src/bgp_server.rs +++ b/crates/server/src/bgp_server.rs @@ -122,49 +122,6 @@ async fn start_http_server( } } - // async fn rm_large_community( - // chan: UnboundedSender, - // ld1: u32, - // ld2: u32, - // ) -> Result { - // let (tx, rx) = tokio::sync::oneshot::channel::(); - // if let Err(e) = chan.send(PeerCommands::RemoveLargeCommunity((ld1, ld2), tx)) { - // warn!("Failed to send RemoveLargeCommunity request: {}", e); - // return Err(warp::reject()); - // } - - // match rx.await { - // Ok(result) => Ok(warp::reply::json(&result)), - // Err(e) => { - // warn!( - // "RemoveLargeCommunity response from peer state machine: {}", - // e - // ); - // Err(warp::reject()) - // } - // } - // } - - // async fn add_large_community( - // chan: UnboundedSender, - // ld1: u32, - // ld2: u32, - // ) -> Result { - // let (tx, rx) = tokio::sync::oneshot::channel::(); - // if let Err(e) = chan.send(PeerCommands::AddLargeCommunity((ld1, ld2), tx)) { - // warn!("Failed to send AddLargeCommunity request: {}", e); - // return Err(warp::reject()); - // } - - // match rx.await { - // Ok(result) => Ok(warp::reply::json(&result)), - // Err(e) => { - // warn!("AddLargeCommunity response from peer state machine: {}", e); - // Err(warp::reject()) - // } - // } - // } - // reset_peer_connection causes the PSM to close the connection, flush state, and reconnect to the peer. async fn reset_peer_connection( peer_name: String, diff --git a/crates/server/src/peer.rs b/crates/server/src/peer.rs index 32dadf3..6ed11e6 100644 --- a/crates/server/src/peer.rs +++ b/crates/server/src/peer.rs @@ -124,10 +124,6 @@ pub enum PeerCommands { TimerEvent(PeerTimerEvent), - // Adds a community to all announcements. - AddLargeCommunity((u32, u32), oneshot::Sender), - RemoveLargeCommunity((u32, u32), oneshot::Sender), - // GetStatus is a crude hack to get a status string out of the PSM for debugging. GetStatus(oneshot::Sender), } @@ -523,47 +519,6 @@ where todo!(); } - PeerCommands::AddLargeCommunity(c, sender) => { - for a in self.config.announcements.iter_mut() { - if let Some(lcs) = a.large_communities.as_mut() { - lcs.push(format!("{}:{}:{}", self.config.asn, c.0, c.1)); - } else { - a.large_communities = - Some(vec![format!("{}:{}:{}", self.config.asn, c.0, c.1)]); - } - } - for a in &self.config.announcements.clone() { - if let Err(e) = self.announce_static(&a).await { - if let Err(se) = sender.send(e) { - warn!("Failed to send to sender: {}", se); - } - return Ok(()); - } - } - if let Err(se) = sender.send("Ok".to_string()) { - warn!("Failed to send to sender: {}", se); - } - } - PeerCommands::RemoveLargeCommunity(c, sender) => { - let communities_str = format!("{}:{}:{}", self.config.asn, c.0, c.1); - for a in self.config.announcements.iter_mut() { - if let Some(lcs) = a.large_communities.as_mut() { - lcs.retain(|e| *e != communities_str); - } - } - for a in &self.config.announcements.clone() { - if let Err(e) = self.announce_static(&a).await { - if let Err(se) = sender.send(e) { - warn!("Failed to send to sender: {}", se); - } - return Ok(()); - } - } - if let Err(se) = sender.send("Ok".to_string()) { - warn!("Failed to send to sender: {}", se); - } - } - PeerCommands::MessageFromPeer(msg) => match self.handle_msg(msg).await { Ok(_) => { let mut last_time = self