Lines Matching refs:rreq
168 static void ceph_netfs_expand_readahead(struct netfs_io_request *rreq) in ceph_netfs_expand_readahead() argument
170 struct inode *inode = rreq->inode; in ceph_netfs_expand_readahead()
174 loff_t end = rreq->start + rreq->len, new_end; in ceph_netfs_expand_readahead()
175 struct ceph_netfs_request_data *priv = rreq->netfs_priv; in ceph_netfs_expand_readahead()
199 new_end = umin(round_up(end, lo->stripe_unit), rreq->i_size); in ceph_netfs_expand_readahead()
200 if (new_end > end && new_end <= rreq->start + max_len) in ceph_netfs_expand_readahead()
201 rreq->len = new_end - rreq->start; in ceph_netfs_expand_readahead()
204 div_u64_rem(rreq->start, lo->stripe_unit, &blockoff); in ceph_netfs_expand_readahead()
205 if (rreq->len + blockoff <= max_len) { in ceph_netfs_expand_readahead()
206 rreq->start -= blockoff; in ceph_netfs_expand_readahead()
207 rreq->len += blockoff; in ceph_netfs_expand_readahead()
241 subreq->rreq->origin != NETFS_UNBUFFERED_READ && in finish_netfs_read()
242 subreq->rreq->origin != NETFS_DIO_READ) in finish_netfs_read()
274 struct netfs_io_request *rreq = subreq->rreq; in ceph_netfs_issue_op_inline() local
275 struct inode *inode = rreq->inode; in ceph_netfs_issue_op_inline()
285 if (rreq->origin != NETFS_UNBUFFERED_READ && in ceph_netfs_issue_op_inline()
286 rreq->origin != NETFS_DIO_READ) in ceph_netfs_issue_op_inline()
336 struct netfs_io_request *rreq = subreq->rreq; in ceph_netfs_prepare_read() local
337 struct inode *inode = rreq->inode; in ceph_netfs_prepare_read()
346 rreq->io_streams[0].sreq_max_len = umin(xlen, fsc->mount_options->rsize); in ceph_netfs_prepare_read()
352 struct netfs_io_request *rreq = subreq->rreq; in ceph_netfs_issue_read() local
353 struct inode *inode = rreq->inode; in ceph_netfs_issue_read()
458 static int ceph_init_request(struct netfs_io_request *rreq, struct file *file) in ceph_init_request() argument
460 struct inode *inode = rreq->inode; in ceph_init_request()
468 __set_bit(NETFS_RREQ_USE_PGPRIV2, &rreq->flags); in ceph_init_request()
470 if (rreq->origin != NETFS_READAHEAD) in ceph_init_request()
486 rreq->netfs_priv = priv; in ceph_init_request()
512 rreq->netfs_priv = priv; in ceph_init_request()
513 rreq->io_streams[0].sreq_max_len = fsc->mount_options->rsize; in ceph_init_request()
525 static void ceph_netfs_free_request(struct netfs_io_request *rreq) in ceph_netfs_free_request() argument
527 struct ceph_netfs_request_data *priv = rreq->netfs_priv; in ceph_netfs_free_request()
533 ceph_put_cap_refs(ceph_inode(rreq->inode), priv->caps); in ceph_netfs_free_request()
535 rreq->netfs_priv = NULL; in ceph_netfs_free_request()