summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorAlejandro Soto <alejandro@34project.org>2022-01-04 06:25:40 -0600
committerAlejandro Soto <alejandro@34project.org>2022-01-04 06:25:40 -0600
commita134847d49224acaf4089e7bad0850a4032c2606 (patch)
treef986d250c686c6ed8321121a4494692fe8793209 /examples
parentc3c7a5b25a47e54df5d6b887d19f23c6fb20be8b (diff)
Remove use of individual ops in ext2 example
Diffstat (limited to 'examples')
-rw-r--r--examples/ext2.rs14
1 files changed, 7 insertions, 7 deletions
diff --git a/examples/ext2.rs b/examples/ext2.rs
index f82b34a..0a1722e 100644
--- a/examples/ext2.rs
+++ b/examples/ext2.rs
@@ -33,7 +33,7 @@ use nix::{
use blown_fuse::{
io::{Attrs, Entry, FsInfo, Known, Stat},
mount::{mount_sync, Options},
- ops::{Getattr, Init, Lookup, Readdir, Readlink, Statfs},
+ ops,
session::{Dispatch, Start},
Done, FuseResult, Ino, Op, Ttl,
};
@@ -301,7 +301,7 @@ impl Ext2 {
}
impl Ext2 {
- fn init<'o>(&self, (_, reply): Op<'o, Init>) -> Done<'o> {
+ fn init<'o>(&self, (_, reply): Op<'o, ops::Init>) -> Done<'o> {
let label = &self.superblock.s_volume_name;
let label = &label[..=label.iter().position(|byte| *byte == b'\0').unwrap_or(0)];
let label = CStr::from_bytes_with_nul(label)
@@ -323,7 +323,7 @@ impl Ext2 {
reply.ok()
}
- async fn statfs<'o>(&self, (_, reply): Op<'o, Statfs>) -> Done<'o> {
+ async fn statfs<'o>(&self, (_, reply): Op<'o, ops::Statfs>) -> Done<'o> {
let total_blocks = self.superblock.s_blocks_count as u64;
let free_blocks = self.superblock.s_free_blocks_count as u64;
let available_blocks = free_blocks - self.superblock.s_r_blocks_count as u64;
@@ -343,14 +343,14 @@ impl Ext2 {
reply.info(&info)
}
- async fn getattr<'o>(&self, (request, reply): Op<'o, Getattr>) -> Done<'o> {
+ async fn getattr<'o>(&self, (request, reply): Op<'o, ops::Getattr>) -> Done<'o> {
let ino = request.ino();
let (reply, inode) = reply.and_then(self.inode(ino))?;
reply.known(&Resolved { ino, inode })
}
- async fn lookup<'o>(&self, (request, reply): Op<'o, Lookup>) -> Done<'o> {
+ async fn lookup<'o>(&self, (request, reply): Op<'o, ops::Lookup>) -> Done<'o> {
let name = request.name();
let (mut reply, parent) = reply.and_then(self.inode(request.ino()))?;
@@ -376,7 +376,7 @@ impl Ext2 {
}
}
- async fn readlink<'o>(&self, (request, reply): Op<'o, Readlink>) -> Done<'o> {
+ async fn readlink<'o>(&self, (request, reply): Op<'o, ops::Readlink>) -> Done<'o> {
let ino = request.ino();
let (mut reply, inode) = reply.and_then(self.inode(ino))?;
@@ -410,7 +410,7 @@ impl Ext2 {
reply.gather_target(&segments)
}
- async fn readdir<'o>(&self, (request, reply): Op<'o, Readdir>) -> Done<'o> {
+ async fn readdir<'o>(&self, (request, reply): Op<'o, ops::Readdir>) -> Done<'o> {
let (reply, inode) = reply.and_then(self.inode(request.ino()))?;
let mut reply = reply.buffered(Vec::new());