Lines Matching refs:in_header
117 let in_header = InHeader::from_reader(&mut r).map_err(Error::DecodeMessage)?; in handle_message() localVariable
118 if in_header.len in handle_message()
123 in_header.unique, in handle_message()
127 match Opcode::n(in_header.opcode) { in handle_message()
128 Some(Opcode::Lookup) => self.lookup(in_header, r, w), in handle_message()
129 Some(Opcode::Forget) => self.forget(in_header, r), // No reply. in handle_message()
130 Some(Opcode::Getattr) => self.getattr(in_header, r, w), in handle_message()
131 Some(Opcode::Setattr) => self.setattr(in_header, r, w), in handle_message()
132 Some(Opcode::Readlink) => self.readlink(in_header, w), in handle_message()
133 Some(Opcode::Symlink) => self.symlink(in_header, r, w), in handle_message()
134 Some(Opcode::Mknod) => self.mknod(in_header, r, w), in handle_message()
135 Some(Opcode::Mkdir) => self.mkdir(in_header, r, w), in handle_message()
136 Some(Opcode::Unlink) => self.unlink(in_header, r, w), in handle_message()
137 Some(Opcode::Rmdir) => self.rmdir(in_header, r, w), in handle_message()
138 Some(Opcode::Rename) => self.rename(in_header, r, w), in handle_message()
139 Some(Opcode::Link) => self.link(in_header, r, w), in handle_message()
140 Some(Opcode::Open) => self.open(in_header, r, w), in handle_message()
141 Some(Opcode::Read) => self.read(in_header, r, w), in handle_message()
142 Some(Opcode::Write) => self.write(in_header, r, w), in handle_message()
143 Some(Opcode::Statfs) => self.statfs(in_header, w), in handle_message()
144 Some(Opcode::Release) => self.release(in_header, r, w), in handle_message()
145 Some(Opcode::Fsync) => self.fsync(in_header, r, w), in handle_message()
146 Some(Opcode::Setxattr) => self.setxattr(in_header, r, w), in handle_message()
147 Some(Opcode::Getxattr) => self.getxattr(in_header, r, w), in handle_message()
148 Some(Opcode::Listxattr) => self.listxattr(in_header, r, w), in handle_message()
149 Some(Opcode::Removexattr) => self.removexattr(in_header, r, w), in handle_message()
150 Some(Opcode::Flush) => self.flush(in_header, r, w), in handle_message()
151 Some(Opcode::Init) => self.init(in_header, r, w), in handle_message()
152 Some(Opcode::Opendir) => self.opendir(in_header, r, w), in handle_message()
153 Some(Opcode::Readdir) => self.readdir(in_header, r, w), in handle_message()
154 Some(Opcode::Releasedir) => self.releasedir(in_header, r, w), in handle_message()
155 Some(Opcode::Fsyncdir) => self.fsyncdir(in_header, r, w), in handle_message()
156 Some(Opcode::Getlk) => self.getlk(in_header, r, w), in handle_message()
157 Some(Opcode::Setlk) => self.setlk(in_header, r, w), in handle_message()
158 Some(Opcode::Setlkw) => self.setlkw(in_header, r, w), in handle_message()
159 Some(Opcode::Access) => self.access(in_header, r, w), in handle_message()
160 Some(Opcode::Create) => self.create(in_header, r, w), in handle_message()
161 Some(Opcode::Interrupt) => self.interrupt(in_header), in handle_message()
162 Some(Opcode::Bmap) => self.bmap(in_header, r, w), in handle_message()
164 Some(Opcode::Ioctl) => self.ioctl(in_header, r, w), in handle_message()
165 Some(Opcode::Poll) => self.poll(in_header, r, w), in handle_message()
166 Some(Opcode::NotifyReply) => self.notify_reply(in_header, r, w), in handle_message()
167 Some(Opcode::BatchForget) => self.batch_forget(in_header, r, w), in handle_message()
168 Some(Opcode::Fallocate) => self.fallocate(in_header, r, w), in handle_message()
169 Some(Opcode::Readdirplus) => self.readdirplus(in_header, r, w), in handle_message()
170 Some(Opcode::Rename2) => self.rename2(in_header, r, w), in handle_message()
171 Some(Opcode::Lseek) => self.lseek(in_header, r, w), in handle_message()
172 Some(Opcode::CopyFileRange) => self.copy_file_range(in_header, r, w), in handle_message()
173 Some(Opcode::ChromeOsTmpfile) => self.chromeos_tmpfile(in_header, r, w), in handle_message()
174 Some(Opcode::SetUpMapping) => self.set_up_mapping(in_header, r, w, mapper), in handle_message()
175 Some(Opcode::RemoveMapping) => self.remove_mapping(in_header, r, w, mapper), in handle_message()
178 in_header.unique, in handle_message()
184 fn lookup<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in lookup()
185 let namelen = (in_header.len as usize) in lookup()
197 .lookup(Context::from(in_header), in_header.nodeid.into(), &name) in lookup()
202 reply_ok(Some(out), None, in_header.unique, w) in lookup()
204 Err(e) => reply_error(e, in_header.unique, w), in lookup()
208 fn forget<R: Reader>(&self, in_header: InHeader, mut r: R) -> Result<usize> { in forget()
212 .forget(Context::from(in_header), in_header.nodeid.into(), nlookup); in forget()
218 fn getattr<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in getattr()
233 .getattr(Context::from(in_header), in_header.nodeid.into(), handle) in getattr()
242 reply_ok(Some(out), None, in_header.unique, w) in getattr()
244 Err(e) => reply_error(e, in_header.unique, w), in getattr()
248 fn setattr<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in setattr()
262 Context::from(in_header), in setattr()
263 in_header.nodeid.into(), in setattr()
275 reply_ok(Some(out), None, in_header.unique, w) in setattr()
277 Err(e) => reply_error(e, in_header.unique, w), in setattr()
281 fn readlink<W: Writer>(&self, in_header: InHeader, w: W) -> Result<usize> { in readlink()
284 .readlink(Context::from(in_header), in_header.nodeid.into()) in readlink()
288 reply_ok(None::<u8>, Some(&linkname), in_header.unique, w) in readlink()
290 Err(e) => reply_error(e, in_header.unique, w), in readlink()
294 fn symlink<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in symlink()
297 let len = (in_header.len as usize) in symlink()
315 Context::from(in_header), in symlink()
317 in_header.nodeid.into(), in symlink()
323 reply_ok(Some(out), None, in_header.unique, w) in symlink()
325 Err(e) => reply_error(e, in_header.unique, w), in symlink()
329 fn mknod<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in mknod()
334 let buflen = (in_header.len as usize) in mknod()
349 Context::from(in_header), in mknod()
350 in_header.nodeid.into(), in mknod()
359 reply_ok(Some(out), None, in_header.unique, w) in mknod()
361 Err(e) => reply_error(e, in_header.unique, w), in mknod()
365 fn mkdir<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in mkdir()
368 let buflen = (in_header.len as usize) in mkdir()
383 Context::from(in_header), in mkdir()
384 in_header.nodeid.into(), in mkdir()
392 reply_ok(Some(out), None, in_header.unique, w) in mkdir()
394 Err(e) => reply_error(e, in_header.unique, w), in mkdir()
400 in_header: InHeader, in chromeos_tmpfile()
408 Context::from(in_header), in chromeos_tmpfile()
409 in_header.nodeid.into(), in chromeos_tmpfile()
416 reply_ok(Some(out), None, in_header.unique, w) in chromeos_tmpfile()
418 Err(e) => reply_error(e, in_header.unique, w), in chromeos_tmpfile()
422 fn unlink<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in unlink()
423 let namelen = (in_header.len as usize) in unlink()
431 Context::from(in_header), in unlink()
432 in_header.nodeid.into(), in unlink()
435 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in unlink()
436 Err(e) => reply_error(e, in_header.unique, w), in unlink()
440 fn rmdir<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in rmdir()
441 let namelen = (in_header.len as usize) in rmdir()
449 Context::from(in_header), in rmdir()
450 in_header.nodeid.into(), in rmdir()
453 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in rmdir()
454 Err(e) => reply_error(e, in_header.unique, w), in rmdir()
460 in_header: InHeader, in do_rename()
467 let buflen = (in_header.len as usize) in do_rename()
485 Context::from(in_header), in do_rename()
486 in_header.nodeid.into(), in do_rename()
492 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in do_rename()
493 Err(e) => reply_error(e, in_header.unique, w), in do_rename()
497 fn rename<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in rename()
500 self.do_rename(in_header, size_of::<RenameIn>(), newdir, 0, r, w) in rename()
503 fn rename2<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in rename2()
509 self.do_rename(in_header, size_of::<Rename2In>(), newdir, flags, r, w) in rename2()
512 fn link<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in link()
515 let namelen = (in_header.len as usize) in link()
524 Context::from(in_header), in link()
526 in_header.nodeid.into(), in link()
532 reply_ok(Some(out), None, in_header.unique, w) in link()
534 Err(e) => reply_error(e, in_header.unique, w), in link()
538 fn open<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in open()
543 .open(Context::from(in_header), in_header.nodeid.into(), flags) in open()
552 reply_ok(Some(out), None, in_header.unique, w) in open()
554 Err(e) => reply_error(e, in_header.unique, w), in open()
560 in_header: InHeader, in read()
577 in_header.unique, in read()
591 Context::from(in_header), in read()
592 in_header.nodeid.into(), in read()
607 unique: in_header.unique, in read()
614 Err(e) => reply_error(e, in_header.unique, w), in read()
620 in_header: InHeader, in write()
637 in_header.unique, in write()
651 Context::from(in_header), in write()
652 in_header.nodeid.into(), in write()
667 reply_ok(Some(out), None, in_header.unique, w) in write()
669 Err(e) => reply_error(e, in_header.unique, w), in write()
673 fn statfs<W: Writer>(&self, in_header: InHeader, w: W) -> Result<usize> { in statfs()
676 .statfs(Context::from(in_header), in_header.nodeid.into()) in statfs()
678 Ok(st) => reply_ok(Some(Kstatfs::from(st)), None, in_header.unique, w), in statfs()
679 Err(e) => reply_error(e, in_header.unique, w), in statfs()
683 fn release<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in release()
700 Context::from(in_header), in release()
701 in_header.nodeid.into(), in release()
708 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in release()
709 Err(e) => reply_error(e, in_header.unique, w), in release()
713 fn fsync<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in fsync()
720 Context::from(in_header), in fsync()
721 in_header.nodeid.into(), in fsync()
725 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in fsync()
726 Err(e) => reply_error(e, in_header.unique, w), in fsync()
730 fn setxattr<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in setxattr()
735 let len = (in_header.len as usize) in setxattr()
757 Context::from(in_header), in setxattr()
758 in_header.nodeid.into(), in setxattr()
763 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in setxattr()
764 Err(e) => reply_error(e, in_header.unique, w), in setxattr()
768 fn getxattr<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in getxattr()
772 let namelen = (in_header.len as usize) in getxattr()
783 in_header.unique, in getxattr()
789 Context::from(in_header), in getxattr()
790 in_header.nodeid.into(), in getxattr()
794 Ok(GetxattrReply::Value(val)) => reply_ok(None::<u8>, Some(&val), in_header.unique, w), in getxattr()
801 reply_ok(Some(out), None, in_header.unique, w) in getxattr()
803 Err(e) => reply_error(e, in_header.unique, w), in getxattr()
809 in_header: InHeader, in listxattr()
819 in_header.unique, in listxattr()
826 .listxattr(Context::from(in_header), in_header.nodeid.into(), size) in listxattr()
828 Ok(ListxattrReply::Names(val)) => reply_ok(None::<u8>, Some(&val), in_header.unique, w), in listxattr()
835 reply_ok(Some(out), None, in_header.unique, w) in listxattr()
837 Err(e) => reply_error(e, in_header.unique, w), in listxattr()
843 in_header: InHeader, in removexattr()
847 let namelen = (in_header.len as usize) in removexattr()
859 .removexattr(Context::from(in_header), in_header.nodeid.into(), name) in removexattr()
861 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in removexattr()
862 Err(e) => reply_error(e, in_header.unique, w), in removexattr()
866 fn flush<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in flush()
875 Context::from(in_header), in flush()
876 in_header.nodeid.into(), in flush()
880 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in flush()
881 Err(e) => reply_error(e, in_header.unique, w), in flush()
885 fn init<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in init()
897 in_header.unique, in init()
910 return reply_ok(Some(out), None, in_header.unique, w); in init()
920 in_header.unique, in init()
968 reply_ok(Some(out), None, in_header.unique, w) in init()
970 Err(e) => reply_error(e, in_header.unique, w), in init()
974 fn opendir<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in opendir()
979 .opendir(Context::from(in_header), in_header.nodeid.into(), flags) in opendir()
988 reply_ok(Some(out), None, in_header.unique, w) in opendir()
990 Err(e) => reply_error(e, in_header.unique, w), in opendir()
996 in_header: InHeader, in readdir()
1007 in_header.unique, in readdir()
1015 in_header.unique, in readdir()
1021 let unique = in_header.unique; in readdir()
1024 Context::from(in_header), in readdir()
1025 in_header.nodeid.into(), in readdir()
1057 in_header: &InHeader, in handle_dirent()
1060 let parent = in_header.nodeid.into(); in handle_dirent()
1079 .lookup(Context::from(*in_header), parent, dir_entry.name)? in handle_dirent()
1087 in_header: InHeader, in readdirplus()
1098 in_header.unique, in readdirplus()
1106 in_header.unique, in readdirplus()
1112 let unique = in_header.unique; in readdirplus()
1115 Context::from(in_header), in readdirplus()
1116 in_header.nodeid.into(), in readdirplus()
1125 match self.handle_dirent(&in_header, dirent).and_then(|(d, e)| { in readdirplus()
1135 self.fs.forget(Context::from(in_header), inode.into(), 1); in readdirplus()
1144 self.fs.forget(Context::from(in_header), inode.into(), 1); in readdirplus()
1174 in_header: InHeader, in releasedir()
1182 Context::from(in_header), in releasedir()
1183 in_header.nodeid.into(), in releasedir()
1187 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in releasedir()
1188 Err(e) => reply_error(e, in_header.unique, w), in releasedir()
1192 fn fsyncdir<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in fsyncdir()
1199 Context::from(in_header), in fsyncdir()
1200 in_header.nodeid.into(), in fsyncdir()
1204 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in fsyncdir()
1205 Err(e) => reply_error(e, in_header.unique, w), in fsyncdir()
1209 fn getlk<R: Reader, W: Writer>(&self, in_header: InHeader, mut _r: R, w: W) -> Result<usize> { in getlk()
1211 reply_error(e, in_header.unique, w) in getlk()
1217 fn setlk<R: Reader, W: Writer>(&self, in_header: InHeader, mut _r: R, w: W) -> Result<usize> { in setlk()
1219 reply_error(e, in_header.unique, w) in setlk()
1225 fn setlkw<R: Reader, W: Writer>(&self, in_header: InHeader, mut _r: R, w: W) -> Result<usize> { in setlkw()
1227 reply_error(e, in_header.unique, w) in setlkw()
1233 fn access<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in access()
1238 .access(Context::from(in_header), in_header.nodeid.into(), mask) in access()
1240 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in access()
1241 Err(e) => reply_error(e, in_header.unique, w), in access()
1245 fn create<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in create()
1250 let buflen = (in_header.len as usize) in create()
1266 Context::from(in_header), in create()
1267 in_header.nodeid.into(), in create()
1293 in_header.unique, in create()
1297 Err(e) => reply_error(e, in_header.unique, w), in create()
1306 fn bmap<R: Reader, W: Writer>(&self, in_header: InHeader, mut _r: R, w: W) -> Result<usize> { in bmap()
1308 reply_error(e, in_header.unique, w) in bmap()
1322 fn ioctl<R: Reader, W: Writer>(&self, in_header: InHeader, mut r: R, w: W) -> Result<usize> { in ioctl()
1333 in_header.into(), in ioctl()
1334 in_header.nodeid.into(), in ioctl()
1347 retry_ioctl(in_header.unique, input, output, w) in ioctl()
1349 IoctlReply::Done(res) => finish_ioctl(in_header.unique, res, w), in ioctl()
1351 Err(e) => reply_error(e, in_header.unique, w), in ioctl()
1355 fn poll<R: Reader, W: Writer>(&self, in_header: InHeader, mut _r: R, w: W) -> Result<usize> { in poll()
1357 reply_error(e, in_header.unique, w) in poll()
1365 in_header: InHeader, in notify_reply()
1370 reply_error(e, in_header.unique, w) in notify_reply()
1378 in_header: InHeader, in batch_forget()
1389 in_header.unique, in batch_forget()
1396 in_header.unique, in batch_forget()
1410 self.fs.batch_forget(Context::from(in_header), requests); in batch_forget()
1418 in_header: InHeader, in fallocate()
1431 Context::from(in_header), in fallocate()
1432 in_header.nodeid.into(), in fallocate()
1438 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in fallocate()
1439 Err(e) => reply_error(e, in_header.unique, w), in fallocate()
1443 fn lseek<R: Reader, W: Writer>(&self, in_header: InHeader, mut _r: R, w: W) -> Result<usize> { in lseek()
1445 reply_error(e, in_header.unique, w) in lseek()
1453 in_header: InHeader, in copy_file_range()
1468 Context::from(in_header), in copy_file_range()
1469 in_header.nodeid.into(), in copy_file_range()
1484 reply_ok(Some(out), None, in_header.unique, w) in copy_file_range()
1486 Err(e) => reply_error(e, in_header.unique, w), in copy_file_range()
1492 in_header: InHeader, in set_up_mapping()
1524 in_header.unique, in set_up_mapping()
1530 Context::from(in_header), in set_up_mapping()
1531 in_header.nodeid.into(), in set_up_mapping()
1539 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in set_up_mapping()
1542 reply_error(e, in_header.unique, w) in set_up_mapping()
1549 in_header: InHeader, in remove_mapping()
1569 in_header.unique, in remove_mapping()
1580 Ok(()) => reply_ok(None::<u8>, None, in_header.unique, w), in remove_mapping()
1581 Err(e) => reply_error(e, in_header.unique, w), in remove_mapping()