We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3b32908 commit 96d511cCopy full SHA for 96d511c
broker/src/serve_health.rs
@@ -7,6 +7,7 @@ use futures_core::Stream;
7
use serde::{Serialize, Deserialize};
8
use shared::{crypto_jwt::Authorized, Msg, config::CONFIG_CENTRAL};
9
use tokio::sync::{Mutex, OwnedMutexGuard, RwLock};
10
+use tracing::info;
11
12
use crate::compare_client_server_version::log_version_mismatch;
13
@@ -145,7 +146,8 @@ async fn get_control_tasks(
145
146
.clone();
147
let Ok(connect_guard) = tokio::time::timeout(Duration::from_secs(60), status_mutex.lock_owned()).await
148
else {
- return Err(StatusCode::CONFLICT);
149
+ info!("Double connection!");
150
+ return Err(StatusCode::OK);
151
};
152
153
Ok(Sse::new(ForeverStream(connect_guard)).keep_alive(KeepAlive::new()))
0 commit comments