This is an automated email from the ASF dual-hosted git repository. xuanwo pushed a commit to branch lazy-reader in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git
commit 48291521884399f104d603e574fe705ab3b5efe9 Author: Xuanwo <[email protected]> AuthorDate: Thu Oct 26 22:39:19 2023 +0800 Fix dbfs Signed-off-by: Xuanwo <[email protected]> --- core/src/services/dbfs/backend.rs | 25 +------------------------ 1 file changed, 1 insertion(+), 24 deletions(-) diff --git a/core/src/services/dbfs/backend.rs b/core/src/services/dbfs/backend.rs index c01acb043..be4822309 100644 --- a/core/src/services/dbfs/backend.rs +++ b/core/src/services/dbfs/backend.rs @@ -200,32 +200,9 @@ impl Accessor for DbfsBackend { } async fn read(&self, path: &str, args: OpRead) -> Result<(RpRead, Self::Reader)> { - let mut meta = Metadata::new(EntryMode::FILE); - - if let Some(length) = args.range().size() { - meta.set_content_length(length); - } else { - let stat_resp = self.core.dbfs_get_status(path).await?; - meta = parse_into_metadata(path, stat_resp.headers())?; - let decoded_response = - serde_json::from_slice::<DbfsStatus>(&stat_resp.into_body().bytes().await?) - .map_err(new_json_deserialize_error)?; - meta.set_last_modified(parse_datetime_from_from_timestamp_millis( - decoded_response.modification_time, - )?); - meta.set_mode(if decoded_response.is_dir { - EntryMode::DIR - } else { - EntryMode::FILE - }); - if !decoded_response.is_dir { - meta.set_content_length(decoded_response.file_size as u64); - } - } - let op = DbfsReader::new(self.core.clone(), args, path.to_string()); - Ok((RpRead::with_metadata(meta), op)) + Ok((RpRead::new(), op)) } async fn write(&self, path: &str, args: OpWrite) -> Result<(RpWrite, Self::Writer)> {
