|
|
|
@ -105,7 +105,7 @@ impl Listener { |
|
|
|
.context("binding listener")?;
|
|
|
|
let address = inner.local_addr().context("accessing local address")?;
|
|
|
|
|
|
|
|
info!("Listening for control connections on {}", address);
|
|
|
|
info!("Bound listener for control connections to {}", address);
|
|
|
|
|
|
|
|
Ok(Self { inner, address })
|
|
|
|
}
|
|
|
|
@ -122,6 +122,8 @@ impl Listener { |
|
|
|
message_tx: mpsc::UnboundedSender<Message>,
|
|
|
|
mut response_rx: mpsc::Receiver<Response>,
|
|
|
|
) -> anyhow::Result<()> {
|
|
|
|
info!("Accepting control connections on {}", self.address());
|
|
|
|
|
|
|
|
loop {
|
|
|
|
let (raw_stream, remote_address) = tokio::select! {
|
|
|
|
result = self.inner.accept() => {
|
|
|
|
|