Add log of sessions
This commit is contained in:
parent
0e1a2dc817
commit
770a55fb2c
1 changed files with 13 additions and 0 deletions
|
@ -12,6 +12,7 @@ pub use sessions::{
|
||||||
};
|
};
|
||||||
|
|
||||||
use std::path::Path;
|
use std::path::Path;
|
||||||
|
use std::time::Duration;
|
||||||
#[cfg(unix)]
|
#[cfg(unix)]
|
||||||
use tokio::net::UnixListener;
|
use tokio::net::UnixListener;
|
||||||
|
|
||||||
|
@ -31,6 +32,18 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||||
let uds = UnixListener::bind(libcommand::SOCK_FILE)?;
|
let uds = UnixListener::bind(libcommand::SOCK_FILE)?;
|
||||||
let uds_stream = UnixListenerStream::new(uds);
|
let uds_stream = UnixListenerStream::new(uds);
|
||||||
|
|
||||||
|
std::thread::spawn(|| {
|
||||||
|
loop {
|
||||||
|
if let Ok(lock) = get_sessions_lock() {
|
||||||
|
println!("Sessions log");
|
||||||
|
for session in lock.iter() {
|
||||||
|
println!("ID: {id}, PID: {pid}", id = session.id, pid = session.pid);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
std::thread::sleep(Duration::from_millis(1000));
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
Server::builder()
|
Server::builder()
|
||||||
.add_service(UnixServer::new(server))
|
.add_service(UnixServer::new(server))
|
||||||
.serve_with_incoming(uds_stream)
|
.serve_with_incoming(uds_stream)
|
||||||
|
|
Reference in a new issue