Lines Matching refs:iocb

433 static ssize_t ceph_sync_read(struct kiocb *iocb, struct iov_iter *i,  in ceph_sync_read()  argument
436 struct file *file = iocb->ki_filp; in ceph_sync_read()
439 u64 off = iocb->ki_pos; in ceph_sync_read()
460 if (iocb->ki_flags & IOCB_DIRECT) { in ceph_sync_read()
510 if (off > iocb->ki_pos) { in ceph_sync_read()
511 ret = off - iocb->ki_pos; in ceph_sync_read()
512 iocb->ki_pos = off; in ceph_sync_read()
560 ceph_sync_direct_write(struct kiocb *iocb, struct iov_iter *from, loff_t pos) in ceph_sync_direct_write() argument
562 struct file *file = iocb->ki_filp; in ceph_sync_direct_write()
662 iocb->ki_pos = pos; in ceph_sync_direct_write()
677 ceph_sync_write(struct kiocb *iocb, struct iov_iter *from, loff_t pos) in ceph_sync_write() argument
679 struct file *file = iocb->ki_filp; in ceph_sync_write()
794 iocb->ki_pos = pos; in ceph_sync_write()
806 static ssize_t ceph_read_iter(struct kiocb *iocb, struct iov_iter *to) in ceph_read_iter() argument
808 struct file *filp = iocb->ki_filp; in ceph_read_iter()
820 inode, ceph_vinop(inode), iocb->ki_pos, (unsigned)len, inode); in ceph_read_iter()
831 (iocb->ki_flags & IOCB_DIRECT) || in ceph_read_iter()
835 inode, ceph_vinop(inode), iocb->ki_pos, (unsigned)len, in ceph_read_iter()
840 ret = ceph_sync_read(iocb, to, &retry_op); in ceph_read_iter()
846 inode, ceph_vinop(inode), iocb->ki_pos, (unsigned)len, in ceph_read_iter()
849 ret = generic_file_read_iter(iocb, to); in ceph_read_iter()
882 if (iocb->ki_pos < i_size && in ceph_read_iter()
883 iocb->ki_pos < PAGE_CACHE_SIZE) { in ceph_read_iter()
885 iocb->ki_pos + len); in ceph_read_iter()
890 iocb->ki_pos & ~PAGE_MASK, in ceph_read_iter()
891 end - iocb->ki_pos, to); in ceph_read_iter()
892 iocb->ki_pos += ret; in ceph_read_iter()
895 if (iocb->ki_pos < i_size && read < len) { in ceph_read_iter()
897 i_size - iocb->ki_pos); in ceph_read_iter()
899 iocb->ki_pos += ret; in ceph_read_iter()
907 if (retry_op == CHECK_EOF && iocb->ki_pos < i_size && in ceph_read_iter()
910 ", reading more\n", iocb->ki_pos, in ceph_read_iter()
936 static ssize_t ceph_write_iter(struct kiocb *iocb, struct iov_iter *from) in ceph_write_iter() argument
938 struct file *file = iocb->ki_filp; in ceph_write_iter()
956 err = generic_write_checks(iocb, from); in ceph_write_iter()
960 pos = iocb->ki_pos; in ceph_write_iter()
998 (iocb->ki_flags & IOCB_DIRECT) || (fi->flags & CEPH_F_SYNC)) { in ceph_write_iter()
1003 if (iocb->ki_flags & IOCB_DIRECT) in ceph_write_iter()
1004 written = ceph_sync_direct_write(iocb, &data, pos); in ceph_write_iter()
1006 written = ceph_sync_write(iocb, &data, pos); in ceph_write_iter()
1028 iocb->ki_pos = pos + written; in ceph_write_iter()