|
@@ -65,7 +65,6 @@ async fn main() -> Result<(), Box<dyn Error>> {
|
|
|
|
|
|
// Allow registering or reconnecting during the registration time.
|
|
|
while let Ok(accepted) = timeout_at(reg_time, listener.accept()).await {
|
|
|
- log!("foo");
|
|
|
let stream = match accepted {
|
|
|
Ok((stream, _)) => stream,
|
|
|
Err(e) => {
|
|
@@ -84,6 +83,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
|
|
|
.await;
|
|
|
}
|
|
|
|
|
|
+ log!("registration phase complete");
|
|
|
// Notify all the listener threads that registration is over.
|
|
|
phase_notify.notify_waiters();
|
|
|
|