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