|
@@ -76,7 +76,6 @@ async fn main() -> Result<(), Box<dyn Error>> {
|
|
|
continue;
|
|
|
}
|
|
|
};
|
|
|
- log!("accepted {}", stream.peer_addr()?);
|
|
|
let acceptor = acceptor.clone();
|
|
|
let writer_db = writer_db.clone();
|
|
|
let snd_db = snd_db.clone();
|
|
@@ -130,6 +129,7 @@ async fn handle_handshake<const REGISTRATION_PHASE: bool>(
|
|
|
snd_db: Arc<RwLock<SndDb>>,
|
|
|
phase_notify: Arc<Notify>,
|
|
|
) {
|
|
|
+ log!("accepted {}", stream.peer_addr().unwrap());
|
|
|
let stream = match acceptor.accept(stream).await {
|
|
|
Ok(stream) => stream,
|
|
|
Err(e) => {
|