remove shutdown notification from downstream disconnect

Shourya742 · Shourya742 · commit 94f7e4997888 · 2025-02-01T06:36:04.000+05:30
diff --git a/roles/translator/src/lib/mod.rs b/roles/translator/src/lib/mod.rs
@@ -94,7 +94,7 @@ impl TranslatorSv2 {
                         match task_status_.state {
                             State::DownstreamShutdown(err) | State::BridgeShutdown(err) | State::UpstreamShutdown(err) => {
                                 error!("SHUTDOWN from: {}", err);
-                                self.shutdown().notify_one();
+                                break;
                             }
                             State::UpstreamTryReconnect(err) => {
                                 error!("Trying to reconnect the Upstream because of: {}", err);
@@ -126,7 +126,6 @@ impl TranslatorSv2 {
                             }
                             State::Healthy(msg) => {
                                 info!("HEALTHY message: {}", msg);
-                                self.shutdown().notify_one();
                             }
                         }
                     } else {

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ impl TranslatorSv2 {`
`94`	`94`	`match task_status_.state {`
`95`	`95`	`State::DownstreamShutdown(err) \| State::BridgeShutdown(err) \| State::UpstreamShutdown(err) => {`
`96`	`96`	`error!("SHUTDOWN from: {}", err);`
`97`		`- self.shutdown().notify_one();`
	`97`	`+ break;`
`98`	`98`	`}`
`99`	`99`	`State::UpstreamTryReconnect(err) => {`
`100`	`100`	`error!("Trying to reconnect the Upstream because of: {}", err);`
`@@ -126,7 +126,6 @@ impl TranslatorSv2 {`
`126`	`126`	`}`
`127`	`127`	`State::Healthy(msg) => {`
`128`	`128`	`info!("HEALTHY message: {}", msg);`
`129`		`- self.shutdown().notify_one();`
`130`	`129`	`}`
`131`	`130`	`}`
`132`	`131`	`} else {`