proxmox-mirrors/proxmox-backup
1
0
Fork 1
mirror of https://git.proxmox.com/git/proxmox-backup synced 2025-04-28 18:50:04 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

pxar-fuse: use ReplyBufState::is_full() when possible

Browse Source 
Signed-off-by: Maximiliano Sandoval <m.sandoval@proxmox.com>
Signed-off-by: Thomas Lamprecht <t.lamprecht@proxmox.com>
This commit is contained in:
Maximiliano Sandoval 2024-02-14 09:23:34 +01:00 committed by Thomas Lamprecht
parent 0f7204a4da
commit 87b4b63e55
1 changed files with 17 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
pbs-pxar-fuse/src/lib.rs
View File

@ -525,9 +525,11 @@ impl SessionImpl {
let file = file?.decode_entry().await?;
let stat = to_stat(to_inode(&file), &file)?;
let name = file.file_name();
match request.add_entry(name, &stat, next, 1, f64::MAX, f64::MAX)? {
ReplyBufState::Ok => (),
ReplyBufState::Full => return Ok(lookups),
if request
.add_entry(name, &stat, next, 1, f64::MAX, f64::MAX)?
.is_full()
{
return Ok(lookups);
}
lookups.push(self.make_lookup(request.inode, stat.st_ino, &file)?);
}
@ -537,9 +539,11 @@ impl SessionImpl {
let file = dir.lookup_self().await?;
let stat = to_stat(to_inode(&file), &file)?;
let name = OsStr::new(".");
match request.add_entry(name, &stat, next, 1, f64::MAX, f64::MAX)? {
ReplyBufState::Ok => (),
ReplyBufState::Full => return Ok(lookups),
if request
.add_entry(name, &stat, next, 1, f64::MAX, f64::MAX)?
.is_full()
{
return Ok(lookups);
}
lookups.push(LookupRef::clone(&dir_lookup));
}
@ -551,9 +555,11 @@ impl SessionImpl {
let file = parent_dir.lookup_self().await?;
let stat = to_stat(to_inode(&file), &file)?;
let name = OsStr::new("..");
match request.add_entry(name, &stat, next, 1, f64::MAX, f64::MAX)? {
ReplyBufState::Ok => (),
ReplyBufState::Full => return Ok(lookups),
if request
.add_entry(name, &stat, next, 1, f64::MAX, f64::MAX)?
.is_full()
{
return Ok(lookups);
}
lookups.push(lookup);
}
@ -619,9 +625,8 @@ impl SessionImpl {
let xattrs = self.listxattrs(request.inode).await?;
for entry in xattrs {
match request.add_c_string(entry.name()) {
ReplyBufState::Ok => (),
ReplyBufState::Full => return Ok(ReplyBufState::Full),
if request.add_c_string(entry.name()).is_full() {
return Ok(ReplyBufState::Full);
}
}