fs/fuse/fuse_ipc.c

103 static void fuse_interrupt_send(struct fuse_ticket *otick, int err);
188 /* Interrupt the operation otick.  Return err as its error code */
190 fuse_interrupt_send(struct fuse_ticket *otick, int err)
218 					otick->tk_aw_errno = err;
422 	int err = 0, stops_deferred;
444 		err = ENOTCONN;
449 	err = msleep(ftick, &ftick->tk_aw_mtx, PCATCH, "fu_ans",
452 	if (err == EWOULDBLOCK) {
460 		err = ETIMEDOUT;
462 	} else if ((err == EINTR || err == ERESTART)) {
479 		fuse_interrupt_send(ftick, err);
506 	} else if (err) {
513 	if (!(err || fticket_answered(ftick))) {
516 		err = ENXIO;
521 	return err;
528 	int err = 0;
533 		err = uiomove(fticket_resp(ftick)->base, len, uio);
535 	return err;
541 	int err = 0;
546 	err = fuse_body_audit(ftick, uio_resid(uio));
547 	if (!err) {
548 		err = fticket_aw_pull_uio(ftick, uio);
550 	return err;
614 	int err = 0;
623 			err = msleep(&data->ticketer, &fuse_mtx, PCATCH | PDROP,
625 			if (err)
689 	int err = 0;
696 		err = (blen == sizeof(struct fuse_bmap_out)) ? 0 : EINVAL;
705 			err = (blen == sizeof(struct fuse_entry_out)) ?
708 			err = (blen == FUSE_COMPAT_ENTRY_OUT_SIZE) ? 0 : EINVAL;
719 			err = (blen == sizeof(struct fuse_attr_out)) ?
722 			err = (blen == FUSE_COMPAT_ATTR_OUT_SIZE) ? 0 : EINVAL;
727 		err = (PAGE_SIZE >= blen) ? 0 : EINVAL;
731 		err = (blen == 0) ? 0 : EINVAL;
735 		err = (blen == 0) ? 0 : EINVAL;
739 		err = (blen == 0) ? 0 : EINVAL;
743 		err = (blen == sizeof(struct fuse_open_out)) ? 0 : EINVAL;
747 		err = (((struct fuse_read_in *)(
754 		err = (blen == sizeof(struct fuse_write_out)) ? 0 : EINVAL;
759 			err = (blen == sizeof(struct fuse_statfs_out)) ?
762 			err = (blen == FUSE_COMPAT_STATFS_SIZE) ? 0 : EINVAL;
767 		err = (blen == 0) ? 0 : EINVAL;
771 		err = (blen == 0) ? 0 : EINVAL;
775 		err = (blen == 0) ? 0 : EINVAL;
784 		err = 0;
788 		err = (blen == 0) ? 0 : EINVAL;
792 		err = (blen == 0) ? 0 : EINVAL;
799 			err = 0;
801 			err = EINVAL;
806 		err = (blen == sizeof(struct fuse_open_out)) ? 0 : EINVAL;
810 		err = (((struct fuse_read_in *)(
817 		err = (blen == 0) ? 0 : EINVAL;
821 		err = (blen == 0) ? 0 : EINVAL;
825 		err = (blen == sizeof(struct fuse_lk_out)) ? 0 : EINVAL;
829 		err = (blen == 0) ? 0 : EINVAL;
833 		err = (blen == 0) ? 0 : EINVAL;
837 		err = (blen == 0) ? 0 : EINVAL;
842 			err = (blen == sizeof(struct fuse_entry_out) +
845 			err = (blen == FUSE_COMPAT_ENTRY_OUT_SIZE +
851 		err = (blen == 0) ? 0 : EINVAL;
855 		err = (blen == sizeof(struct fuse_lseek_out)) ? 0 : EINVAL;
859 		err = (blen == sizeof(struct fuse_write_out)) ? 0 : EINVAL;
866 	return err;
893 	int err = 0;
895 	err = fticket_pull(ftick, uio);
901 		ftick->tk_aw_errno = err;
906 	return err;
990 	int err = 0;
996 	if ((err = fticket_wait_answer(fdip->tick))) {
1006 				"IPC: interrupted, already answered", err);
1016 				"IPC: interrupted, setting to answered", err);
1019 			return err;
1025 		err = ENOTCONN;
1034 		err = EIO;
1037 	if ((err = fdip->tick->tk_aw_ohead.error)) {
1049 		fdip->answ_stat = err;
1058 	return err;