String,
)> = vec![];
- let global = config::startup(
+ config::startup(
"hippotatd", LinkEnd::Server,
&opts.config, &opts.log, |ics|
{
});
tasks.push((ipif, format!("ipif")));
- Ok(global)
+ Ok(())
});
- let died = future::select_all(
+ let (output, died_i, _) = future::select_all(
tasks.iter_mut().map(|e| &mut e.0)
).await;
- error!("xxx {:?}", &died);
- dbg!(global);
+ let task = &tasks[died_i].1;
+ match output {
+ Err(je) => error!("task panicked! {}: {}", task, &je),
+ Ok(e) => error!("task failed! {}: {}", task, &e),
+ }
}
response: WebResponse
| {
reply_to.send(response)
- .unwrap_or_else(|_: WebResponse| () /* oh dear */ /* xxx trace? */);
+ .unwrap_or_else(|_: WebResponse| {
+ /* oh dear */
+ error!("unable to send response back to webserver! user={}",
+ &ic.link.client);
+ });
};
loop {
}
}
}
- //Err(anyhow!("xxx"))
}