From 6fbf63a7b90bac7b054cf09fc6d071aade22f0ce Mon Sep 17 00:00:00 2001 From: Gregor Reitzenstein Date: Mon, 7 Dec 2020 12:13:50 +0100 Subject: [PATCH] Remove unused handshake code --- src/connection.rs | 27 --------------------------- 1 file changed, 27 deletions(-) diff --git a/src/connection.rs b/src/connection.rs index e958405..4f4961e 100644 --- a/src/connection.rs +++ b/src/connection.rs @@ -46,33 +46,6 @@ impl Session { } } -async fn handshake(log: &Logger, stream: &mut TcpStream) -> Result<()> { - if let Some(m) = capnp_futures::serialize::read_message(stream.clone(), Default::default()).await? { - let greeting = m.get_root::()?; - let major = greeting.get_major(); - let minor = greeting.get_minor(); - - if major != 0 { - Err(Error::BadVersion((major, minor))) - } else { - let program = format!("{}-{}", env!("CARGO_PKG_NAME"), env!("CARGO_PKG_VERSION")); - - let mut answer = ::capnp::message::Builder::new_default(); - let mut b = answer.init_root::(); - b.set_program(&program); - b.set_host("localhost"); - b.set_major(0); - b.set_minor(1); - capnp_futures::serialize::write_message(stream, answer).await?; - info!(log, "Handshake successful with peer {} running {}, API {}.{}", - greeting.get_host()?, greeting.get_program()?, major, minor); - Ok(()) - } - } else { - unimplemented!() - } -} - pub struct ConnectionHandler { log: Logger, db: Databases,