diff --git a/olivefs_common/src/networking.rs b/olivefs_common/src/networking.rs index a159024..455db29 100644 --- a/olivefs_common/src/networking.rs +++ b/olivefs_common/src/networking.rs @@ -1,5 +1,5 @@ use crate::messages::HelloMessage; -use anyhow::{anyhow, bail}; +use anyhow::{anyhow, bail, Context}; use quinn::{ReadExactError, RecvStream, SendStream}; use serde::de::DeserializeOwned; use serde::Serialize; @@ -15,8 +15,7 @@ pub async fn read_bare_message( return if err == ReadExactError::FinishedEarly { Ok(None) } else { - Err(err)?; - todo!() + return Err(err).context("reading BARE message"); }; } let control_message_length = u32::from_be_bytes(u32_buf) as usize; diff --git a/olivefsd/src/server/connections.rs b/olivefsd/src/server/connections.rs index 9d3dd40..06f5b06 100644 --- a/olivefsd/src/server/connections.rs +++ b/olivefsd/src/server/connections.rs @@ -1,7 +1,7 @@ use crate::server::file_access::{ClientInformation, ClientSpecificState, ServerwideState}; use anyhow::Context; use futures_util::StreamExt; -use log::error; +use log::{error, info}; use olivefs_common::messages::DataCommand; use olivefs_common::networking::read_bare_message; use quinn::{NewConnection, RecvStream, SendStream}; @@ -19,7 +19,9 @@ pub async fn handle_command_stream( .context("Whilst waiting for Data Command")? { match command { - DataCommand::GetAttr { vnode: _ } => {} + DataCommand::GetAttr { vnode: _ } => { + info!("getattr Not Implemented"); + } } }