Skip to content

Commit

Permalink
debug stat 404 issue: add debug log
Browse files Browse the repository at this point in the history
  • Loading branch information
zhaohaiyuan committed Feb 6, 2025
1 parent 02a6325 commit 2e92ca4
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 13 deletions.
6 changes: 3 additions & 3 deletions core/src/services/swift/backend.rs
Original file line number Diff line number Diff line change
Expand Up @@ -233,13 +233,13 @@ impl Access for SwiftBackend {
match resp.status() {
StatusCode::OK | StatusCode::NO_CONTENT => {
let headers = resp.headers();
let meta = parse_into_metadata(path, headers)?;
let mut meta = parse_into_metadata(path, headers)?;

// 添加日志:记录解析前的原始头部
debug!("swift: parsing user metadata from headers: {:?}", headers);
log::debug!("swift: parsing user metadata from headers: {:?}", headers);

let user_meta = parse_prefixed_headers(headers, "X-Object-Meta-");
debug!("swift: parsed user metadata: {:?}", user_meta);
log::debug!("swift: parsed user metadata: {:?}", user_meta);

if !user_meta.is_empty() {
meta.with_user_metadata(user_meta);
Expand Down
22 changes: 12 additions & 10 deletions core/src/services/swift/core.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
// specific language governing permissions and limitations
// under the License.

use log::debug;
use std::fmt::Debug;

use http::header;
Expand Down Expand Up @@ -103,9 +104,9 @@ impl SwiftCore {
pub async fn swift_create_object(
&self,
path: &str,
size: u64,
op: &OpWrite,
bs: Buffer,
length: u64,
args: &OpWrite,
body: Buffer,
) -> Result<Response<Buffer>> {
let p = build_abs_path(&self.root, path);
let url = format!(
Expand All @@ -118,7 +119,7 @@ impl SwiftCore {
let mut req = Request::put(&url);

// Set user metadata headers.
if let Some(user_metadata) = op.user_metadata() {
if let Some(user_metadata) = args.user_metadata() {
debug!(
"swift: setting user metadata for path {}: {:?}",
path, user_metadata
Expand All @@ -129,12 +130,12 @@ impl SwiftCore {
}

req = req.header("X-Auth-Token", &self.token);
req = req.header(header::CONTENT_LENGTH, size);
req = req.header(header::CONTENT_LENGTH, length);

let req = req.body(bs).map_err(new_request_build_error)?;
let req = req.body(body).map_err(new_request_build_error)?;

let resp = self.client.send(req).await?;

// 添加日志:记录响应状态和头部
debug!(
"swift: create object response status: {}, headers: {:?}",
Expand Down Expand Up @@ -214,7 +215,7 @@ impl SwiftCore {

pub async fn swift_get_metadata(&self, path: &str) -> Result<Response<Buffer>> {
let p = build_abs_path(&self.root, path);

debug!("swift: getting metadata for path: {}", p);

let url = format!(
Expand All @@ -231,7 +232,7 @@ impl SwiftCore {
let req = req.body(Buffer::new()).map_err(new_request_build_error)?;

let resp = self.client.send(req).await?;

// 添加日志:记录所有响应头部
debug!(
"swift: get metadata response status: {}, all headers: {:?}",
Expand All @@ -240,7 +241,8 @@ impl SwiftCore {
);

// 添加日志:特别关注元数据相关的头部
let meta_headers: Vec<_> = resp.headers()
let meta_headers: Vec<_> = resp
.headers()
.iter()
.filter(|(name, _)| name.as_str().starts_with("x-object-meta-"))
.collect();
Expand Down

0 comments on commit 2e92ca4

Please sign in to comment.