/linux/fs/netfs/ |
H A D | write_issue.c | 95 struct netfs_io_request *wreq; in netfs_create_write_req() local 102 wreq = netfs_alloc_request(mapping, file, start, 0, origin); in netfs_create_write_req() 103 if (IS_ERR(wreq)) in netfs_create_write_req() 104 return wreq; in netfs_create_write_req() 106 _enter("R=%x", wreq->debug_id); in netfs_create_write_req() 108 ictx = netfs_inode(wreq->inode); in netfs_create_write_req() 110 fscache_begin_write_operation(&wreq->cache_resources, netfs_i_cookie(ictx)); in netfs_create_write_req() 111 if (rolling_buffer_init(&wreq->buffer, wreq->debug_id, ITER_SOURCE) < 0) in netfs_create_write_req() 114 wreq->cleaned_to = wreq->start; in netfs_create_write_req() 116 wreq->io_streams[0].stream_nr = 0; in netfs_create_write_req() [all …]
|
H A D | write_collect.c | 111 static void netfs_writeback_unlock_folios(struct netfs_io_request *wreq, in netfs_writeback_unlock_folios() argument 114 struct folio_queue *folioq = wreq->buffer.tail; in netfs_writeback_unlock_folios() 115 unsigned long long collected_to = wreq->collected_to; in netfs_writeback_unlock_folios() 116 unsigned int slot = wreq->buffer.first_tail_slot; in netfs_writeback_unlock_folios() 120 netfs_dump_request(wreq); in netfs_writeback_unlock_folios() 124 if (wreq->origin == NETFS_PGPRIV2_COPY_TO_CACHE) { in netfs_writeback_unlock_folios() 125 if (netfs_pgpriv2_unlock_copied_folios(wreq)) in netfs_writeback_unlock_folios() 131 folioq = rolling_buffer_delete_spent(&wreq->buffer); in netfs_writeback_unlock_folios() 146 wreq->debug_id, folio->index)) in netfs_writeback_unlock_folios() 154 fend = min_t(unsigned long long, fpos + flen, wreq->i_size); in netfs_writeback_unlock_folios() [all …]
|
H A D | direct_write.c | 12 static void netfs_cleanup_dio_write(struct netfs_io_request *wreq) in netfs_cleanup_dio_write() argument 14 struct inode *inode = wreq->inode; in netfs_cleanup_dio_write() 15 unsigned long long end = wreq->start + wreq->transferred; in netfs_cleanup_dio_write() 17 if (!wreq->error && in netfs_cleanup_dio_write() 19 if (wreq->netfs_ops->update_i_size) in netfs_cleanup_dio_write() 20 wreq->netfs_ops->update_i_size(inode, end); in netfs_cleanup_dio_write() 33 struct netfs_io_request *wreq; in netfs_unbuffered_write_iter_locked() local 50 wreq = netfs_create_write_req(iocb->ki_filp->f_mapping, iocb->ki_filp, start, in netfs_unbuffered_write_iter_locked() 53 if (IS_ERR(wreq)) in netfs_unbuffered_write_iter_locked() 54 return PTR_ERR(wreq); in netfs_unbuffered_write_iter_locked() [all …]
|
H A D | write_retry.c | 17 static void netfs_retry_write_stream(struct netfs_io_request *wreq, in netfs_retry_write_stream() argument 22 _enter("R=%x[%x:]", wreq->debug_id, stream->stream_nr); in netfs_retry_write_stream() 28 wreq->netfs_ops->retry_request) in netfs_retry_write_stream() 29 wreq->netfs_ops->retry_request(wreq, stream); in netfs_retry_write_stream() 145 subreq = netfs_alloc_subrequest(wreq); in netfs_retry_write_stream() 148 subreq->debug_index = atomic_inc_return(&wreq->subreq_counter); in netfs_retry_write_stream() 152 trace_netfs_sreq_ref(wreq->debug_id, subreq->debug_index, in netfs_retry_write_stream() 166 stream->sreq_max_len = umin(len, wreq->wsize); in netfs_retry_write_stream() 200 void netfs_retry_writes(struct netfs_io_request *wreq) in netfs_retry_writes() argument 212 stream = &wreq->io_streams[s]; in netfs_retry_writes() [all …]
|
H A D | buffered_write.c | 110 struct netfs_io_request *wreq = NULL; in netfs_perform_write() local 129 wreq = netfs_begin_writethrough(iocb, iter->count); in netfs_perform_write() 130 if (IS_ERR(wreq)) { in netfs_perform_write() 132 ret = PTR_ERR(wreq); in netfs_perform_write() 133 wreq = NULL; in netfs_perform_write() 137 wreq->iocb = iocb; in netfs_perform_write() 354 if (likely(!wreq)) { in netfs_perform_write() 358 netfs_advance_writethrough(wreq, &wbc, folio, copied, in netfs_perform_write() 384 if (unlikely(wreq)) { in netfs_perform_write() 385 ret2 = netfs_end_writethrough(wreq, &wbc, writethrough); in netfs_perform_write()
|
H A D | internal.h | 106 bool netfs_pgpriv2_unlock_copied_folios(struct netfs_io_request *wreq); 180 void netfs_wake_write_collector(struct netfs_io_request *wreq, bool was_async); 192 void netfs_issue_write(struct netfs_io_request *wreq, 194 size_t netfs_advance_write(struct netfs_io_request *wreq, 198 int netfs_advance_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc, 201 int netfs_end_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc, 203 int netfs_unbuffered_write(struct netfs_io_request *wreq, bool may_wait, size_t len); 208 void netfs_retry_writes(struct netfs_io_request *wreq);
|
/linux/include/trace/events/ |
H A D | netfs.h | 519 TP_PROTO(const struct netfs_io_request *wreq, 522 TP_ARGS(wreq, what), 525 __field(unsigned int, wreq) 534 struct netfs_inode *__ctx = netfs_inode(wreq->inode); 536 __entry->wreq = wreq->debug_id; 538 __entry->ino = wreq->inode->i_ino; 540 __entry->start = wreq->start; 541 __entry->len = wreq->len; 545 __entry->wreq, 553 TP_PROTO(const struct netfs_io_request *wreq), [all …]
|
/linux/fs/afs/ |
H A D | write.c | 36 static void afs_get_writeback_key(struct netfs_io_request *wreq) in afs_get_writeback_key() argument 38 struct afs_wb_key *wbk, *old = wreq->netfs_priv2; in afs_get_writeback_key() 39 struct afs_vnode *vnode = AFS_FS_I(wreq->inode); in afs_get_writeback_key() 41 key_put(wreq->netfs_priv); in afs_get_writeback_key() 42 wreq->netfs_priv = NULL; in afs_get_writeback_key() 43 wreq->netfs_priv2 = NULL; in afs_get_writeback_key() 55 wreq->netfs_priv = key_get(wbk->key); in afs_get_writeback_key() 56 wreq->netfs_priv2 = wbk; in afs_get_writeback_key() 106 struct netfs_io_request *wreq = subreq->rreq; in afs_issue_write_worker() local 108 struct afs_vnode *vnode = AFS_FS_I(wreq->inode); in afs_issue_write_worker() [all …]
|
H A D | file.c | 442 static void afs_netfs_invalidate_cache(struct netfs_io_request *wreq) in afs_netfs_invalidate_cache() argument 444 struct afs_vnode *vnode = AFS_FS_I(wreq->inode); in afs_netfs_invalidate_cache()
|
H A D | internal.h | 1650 void afs_begin_writeback(struct netfs_io_request *wreq); 1651 void afs_retry_request(struct netfs_io_request *wreq, struct netfs_io_stream *stream);
|
/linux/fs/9p/ |
H A D | vfs_addr.c | 33 static void v9fs_begin_writeback(struct netfs_io_request *wreq) in v9fs_begin_writeback() argument 37 fid = v9fs_fid_find_inode(wreq->inode, true, INVALID_UID, true); in v9fs_begin_writeback() 40 wreq->inode->i_ino); in v9fs_begin_writeback() 44 wreq->wsize = fid->clnt->msize - P9_IOHDRSZ; in v9fs_begin_writeback() 46 wreq->wsize = min(wreq->wsize, fid->iounit); in v9fs_begin_writeback() 47 wreq->netfs_priv = fid; in v9fs_begin_writeback() 48 wreq->io_streams[0].avail = true; in v9fs_begin_writeback()
|
/linux/fs/cachefiles/ |
H A D | io.c | 630 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_prepare_write_subreq() local 631 struct netfs_cache_resources *cres = &wreq->cache_resources; in cachefiles_prepare_write_subreq() 632 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_prepare_write_subreq() 634 _enter("W=%x[%x] %llx", wreq->debug_id, subreq->debug_index, subreq->start); in cachefiles_prepare_write_subreq() 649 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_issue_write() local 650 struct netfs_cache_resources *cres = &wreq->cache_resources; in cachefiles_issue_write() 653 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_issue_write() 660 wreq->debug_id, subreq->debug_index, start, start + len - 1); in cachefiles_issue_write() 678 if (start + len == wreq->i_size) { in cachefiles_issue_write()
|
/linux/net/9p/ |
H A D | trans_fd.c | 120 struct p9_req_t *wreq; member 476 m->wreq = req; in p9_write_work() 499 p9_req_put(m->client, m->wreq); in p9_write_work() 500 m->wreq = NULL; in p9_write_work() 918 if (m->wreq) { in p9_conn_destroy() 919 p9_req_put(m->client, m->wreq); in p9_conn_destroy() 920 m->wreq = NULL; in p9_conn_destroy()
|
H A D | client.c | 1680 struct netfs_io_request *wreq = subreq->rreq; in p9_client_write_subreq() local 1681 struct p9_fid *fid = wreq->netfs_priv; in p9_client_write_subreq() 1694 0, wreq->len, P9_ZC_HDR_SZ, "dqd", in p9_client_write_subreq()
|
/linux/drivers/net/ethernet/chelsio/inline_crypto/ch_ipsec/ |
H A D | chcr_ipsec.h | 33 struct fw_ulptx_wr wreq; member
|
H A D | chcr_ipsec.c | 600 wr->wreq.op_to_compl = htonl(FW_WR_OP_V(FW_ULPTX_WR)); in ch_ipsec_crypto_wreq() 610 wr->wreq.flowid_len16 = htonl(wr_mid); in ch_ipsec_crypto_wreq()
|
/linux/include/linux/ |
H A D | netfs.h | 312 void (*begin_writeback)(struct netfs_io_request *wreq); 315 void (*retry_request)(struct netfs_io_request *wreq, struct netfs_io_stream *stream); 316 void (*invalidate_cache)(struct netfs_io_request *wreq);
|
/linux/drivers/crypto/chelsio/ |
H A D | chcr_core.h | 89 struct fw_crypto_lookaside_wr wreq; member
|
/linux/fs/smb/client/ |
H A D | compress.c | 307 const struct smb2_write_req *wreq = rq->rq_iov->iov_base; in should_compress() local 309 if (le32_to_cpu(wreq->Length) < SMB_COMPRESS_MIN_LEN) in should_compress()
|
H A D | file.c | 137 static void cifs_netfs_invalidate_cache(struct netfs_io_request *wreq) in cifs_netfs_invalidate_cache() argument 139 cifs_invalidate_cache(wreq->inode, 0); in cifs_netfs_invalidate_cache() 240 static void cifs_begin_writeback(struct netfs_io_request *wreq) in cifs_begin_writeback() argument 242 struct cifs_io_request *req = container_of(wreq, struct cifs_io_request, rreq); in cifs_begin_writeback() 245 ret = cifs_get_writable_file(CIFS_I(wreq->inode), FIND_WR_ANY, &req->cfile); in cifs_begin_writeback() 251 wreq->io_streams[0].avail = true; in cifs_begin_writeback() 2401 struct netfs_io_request *wreq = wdata->rreq; in cifs_write_subrequest_terminated() local 2402 struct netfs_inode *ictx = netfs_inode(wreq->inode); in cifs_write_subrequest_terminated()
|