boundary_finder: multipart::BoundaryFinder,
reply_to: tokio::sync::oneshot::Sender<WebResponse>,
warnings: Warnings,
+ conn: Arc<String>,
}
/// Reply from client task to hyper worker pool task
type WebResponseData = Vec<u8>;
#[throws(PacketError)]
-pub fn route_packet(packet: Box<[u8]>, daddr: IpAddr) {
- trace!("xxx discarding packet daddr={:?} len={}", daddr, packet.len());
+pub fn route_packet(conn: &str, link: &dyn Display,
+ packet: Box<[u8]>, daddr: IpAddr)
+{
+ // xxx
+ trace!("{} {} discarding packet daddr={:?} len={}",
+ conn, link, daddr, packet.len());
}
async fn handle(
// boundary, start, &comp.name, &client.ic);
let (reply_to, reply_recv) = tokio::sync::oneshot::channel();
- trace!("{} request xxx={}", &client.ic, initial.len());
+ trace!("{} {} request, Content-Length={}",
+ &conn, &client_name, length_hint);
let wreq = WebRequest {
initial,
initial_remaining,
boundary_finder: boundary_finder.into_owned(),
body,
warnings: mem::take(&mut warnings),
- reply_to
+ reply_to,
+ conn: conn.clone(),
};
client.web.try_send(wreq)
warnings = reply.warnings;
let data = reply.data?;
- if ! warnings.warnings.is_empty()
- && log::log_enabled!(log::Level::Trace) {
- trace!("{} {}: warnings {:?}", &conn, &client_name, &warnings.warnings);
+ if warnings.warnings.is_empty() {
+ trace!("{} {} responding, {}",
+ &conn, &client_name, data.len());
+ } else {
+ debug!("{} {} responding, {} warnings={:?}",
+ &conn, &client_name, data.len(),
+ &warnings.warnings);
}
let data = hyper::Body::from(data);
warnings: default(),
};
- dbg!(&response);
try_send_response(ret.reply_to, response);
}
let WebRequest {
initial, initial_remaining, length_hint, mut body,
boundary_finder,
- reply_to, mut warnings,
+ reply_to, conn, mut warnings,
} = req.ok_or_else(|| anyhow!("webservers all shut down!"))?;
match async {
)?
Ok::<_,AE>($ret)
})().context(stringify!($v))?;
- dbg!(&$v);
+ //dbg!(&$v);
}
}
if saddr != ic.link.client.0 { throw!(PE::Src(saddr)) }
let daddr = ip_packet_addr::<true>(header)?;
Ok(daddr)
- }, |(daddr,packet)| route_packet(daddr,packet),
- |e| Ok::<_,SlipFramesError<_>>({ warnings.add(&e)?; })
+ }, |(daddr,packet)| route_packet(
+ &conn, &ic.link.client, daddr,packet
+ ),
+ |e| Ok::<_,SlipFramesError<_>>({ warnings.add(&e)?; })
)?;
}
for addr in &global.addrs {
let all_clients_ = all_clients.clone();
- let make_service = hyper::service::make_service_fn(move |conn| {
- let all_clients_ = all_clients_.clone();
- let conn = Arc::new(format!("[conn:{:?}]", conn));
- async { Ok::<_, Void>( hyper::service::service_fn(move |req| {
- handle(conn.clone(), all_clients_.clone(), req)
- }) ) } }
+ let make_service = hyper::service::make_service_fn(
+ move |conn: &hyper::server::conn::AddrStream| {
+ let all_clients_ = all_clients_.clone();
+ let conn = Arc::new(format!("[{}]", conn.remote_addr()));
+ async { Ok::<_, Void>( hyper::service::service_fn(move |req| {
+ handle(conn.clone(), all_clients_.clone(), req)
+ }) ) }
+ }
);
let addr = SocketAddr::new(*addr, global.port);