tyler/proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

src/pxar/fuse.rs: impl readlink callback for fuse

Browse Source 
Signed-off-by: Christian Ebner <c.ebner@proxmox.com>
This commit is contained in:
Christian Ebner 2019-09-09 18:27:31 +02:00 committed by Dietmar Maurer
parent 3710b23db5
commit 1652192f4d
1 changed files with 18 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/pxar/fuse.rs
View File

@ -6,8 +6,8 @@ use std::collections::HashMap;
use std::convert::TryFrom; use std::convert::TryFrom;
use std::ffi::{CStr, CString, OsStr}; use std::ffi::{CStr, CString, OsStr};
use std::fs::File; use std::fs::File;
use std::os::unix::ffi::OsStrExt;
use std::io::{BufReader, Read, Seek}; use std::io::{BufReader, Read, Seek};
use std::os::unix::ffi::{OsStrExt, OsStringExt};
use std::path::Path; use std::path::Path;
use std::sync::Mutex; use std::sync::Mutex;
@ -72,6 +72,7 @@ extern "C" {
fn fuse_reply_open(req: Request, fileinfo: ConstPtr) -> c_int; fn fuse_reply_open(req: Request, fileinfo: ConstPtr) -> c_int;
fn fuse_reply_buf(req: Request, buf: MutStrPtr, size: size_t) -> c_int; fn fuse_reply_buf(req: Request, buf: MutStrPtr, size: size_t) -> c_int;
fn fuse_reply_entry(req: Request, entry: Option<&EntryParam>) -> c_int; fn fuse_reply_entry(req: Request, entry: Option<&EntryParam>) -> c_int;
fn fuse_reply_readlink(req: Request, link: StrPtr) -> c_int;
fn fuse_req_userdata(req: Request) -> MutPtr; fn fuse_req_userdata(req: Request) -> MutPtr;
} }
@ -176,6 +177,7 @@ impl Session {
oprs.destroy = Some(destroy); oprs.destroy = Some(destroy);
oprs.lookup = Some(lookup); oprs.lookup = Some(lookup);
oprs.getattr = Some(getattr); oprs.getattr = Some(getattr);
oprs.readlink = Some(readlink);
oprs.open = Some(open); oprs.open = Some(open);
oprs.read = Some(read); oprs.read = Some(read);
oprs.opendir = Some(opendir); oprs.opendir = Some(opendir);
@ -428,6 +430,21 @@ extern "C" fn getattr(req: Request, inode: u64, _fileinfo: MutPtr) {
}); });
} }
extern "C" fn readlink(req: Request, inode: u64) {
run_in_context(req, inode, |decoder, ino_offset| {
let (target, _) = decoder
.read_link(ino_offset)
.map_err(|err| {
println!("{}", err);
libc::EIO
})?;
let link = CString::new(target.into_os_string().into_vec()).map_err(|_| libc::EIO)?;
let _ret = unsafe { fuse_reply_readlink(req, link.as_ptr()) };
Ok(())
});
}
extern "C" fn open(req: Request, inode: u64, fileinfo: MutPtr) { extern "C" fn open(req: Request, inode: u64, fileinfo: MutPtr) {
run_in_context(req, inode, |decoder, ino_offset| { run_in_context(req, inode, |decoder, ino_offset| {
decoder.open(ino_offset).map_err(|_| libc::ENOENT)?; decoder.open(ino_offset).map_err(|_| libc::ENOENT)?;