Commit 2997af22 authored by nanamicat's avatar nanamicat

fix

parent 77d4d359
Pipeline #42133 passed with stages
in 2 minutes and 56 seconds
...@@ -85,7 +85,7 @@ async fn main() -> Result<()> { ...@@ -85,7 +85,7 @@ async fn main() -> Result<()> {
let old_updating_exists = updating.router_id != 0; let old_updating_exists = updating.router_id != 0;
if let Some(change) = router.on_message(report, addr, &mut updating) { if let Some(change) = router.on_message(report, addr, &mut updating) {
// 新上线的客户端,发送 rst,seq 不增加 // 新上线的客户端,发送 rst,seq 不增加
send(&change, &mut buf, &socket, &router.addr.unwrap()).await?; send(&change, &mut buf, &socket, &addr).await?;
} }
if old_updating_exists && updating.router_id == 0 { // an updating just resolved if old_updating_exists && updating.router_id == 0 { // an updating just resolved
tick(&mut routers, &mut cursor, &socket, &mut buf, &mut updating, &connections).await? tick(&mut routers, &mut cursor, &socket, &mut buf, &mut updating, &connections).await?
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment