From 259e0f95daee0dbd10c5d5ca06ee3531728c3a7b Mon Sep 17 00:00:00 2001 From: weisd Date: Sun, 22 Dec 2024 11:01:50 +0800 Subject: [PATCH] todo: rpc walk_dir use writer --- ecstore/src/disk/remote.rs | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/ecstore/src/disk/remote.rs b/ecstore/src/disk/remote.rs index 760b53927..5d87fb5e9 100644 --- a/ecstore/src/disk/remote.rs +++ b/ecstore/src/disk/remote.rs @@ -351,19 +351,18 @@ impl DiskAPI for RemoteDisk { } // FIXME: TODO: use writer - async fn walk_dir(&self, opts: WalkDirOptions, _wr: &mut W) -> Result<()> { + async fn walk_dir(&self, _opts: WalkDirOptions, _wr: &mut W) -> Result<()> { info!("walk_dir"); - let walk_dir_options = serde_json::to_string(&opts)?; - let mut client = node_service_time_out_client(&self.addr) - .await - .map_err(|err| Error::from_string(format!("can not get client, err: {}", err)))?; - let request = Request::new(WalkDirRequest { - disk: self.endpoint.to_string(), - walk_dir_options, - }); - // TODO: use writer unimplemented!() + // let walk_dir_options = serde_json::to_string(&opts)?; + // let mut client = node_service_time_out_client(&self.addr) + // .await + // .map_err(|err| Error::from_string(format!("can not get client, err: {}", err)))?; + // let request = Request::new(WalkDirRequest { + // disk: self.endpoint.to_string(), + // walk_dir_options, + // }); // let response = client.walk_dir(request).await?.into_inner();