Lines Matching refs:op
67 static void afs_store_data_success(struct afs_operation *op) in afs_store_data_success() argument
69 struct afs_vnode *vnode = op->file[0].vnode; in afs_store_data_success()
71 op->ctime = op->file[0].scb.status.mtime_client; in afs_store_data_success()
72 afs_vnode_commit_status(op, &op->file[0]); in afs_store_data_success()
73 if (!afs_op_error(op)) { in afs_store_data_success()
74 afs_pages_written_back(vnode, op->store.pos, op->store.size); in afs_store_data_success()
76 atomic_long_add(op->store.size, &afs_v2net(vnode)->n_store_bytes); in afs_store_data_success()
107 struct afs_operation *op; in afs_issue_write_worker() local
131 op = afs_alloc_operation(wreq->netfs_priv, vnode->volume); in afs_issue_write_worker()
132 if (IS_ERR(op)) in afs_issue_write_worker()
135 afs_op_set_vnode(op, 0, vnode); in afs_issue_write_worker()
136 op->file[0].dv_delta = 1; in afs_issue_write_worker()
137 op->file[0].modification = true; in afs_issue_write_worker()
138 op->store.pos = pos; in afs_issue_write_worker()
139 op->store.size = len; in afs_issue_write_worker()
140 op->flags |= AFS_OPERATION_UNINTR; in afs_issue_write_worker()
141 op->ops = &afs_store_data_operation; in afs_issue_write_worker()
143 afs_begin_vnode_operation(op); in afs_issue_write_worker()
145 op->store.write_iter = &subreq->io_iter; in afs_issue_write_worker()
146 op->store.i_size = umax(pos + len, vnode->netfs.remote_i_size); in afs_issue_write_worker()
147 op->mtime = inode_get_mtime(&vnode->netfs.inode); in afs_issue_write_worker()
149 afs_wait_for_operation(op); in afs_issue_write_worker()
150 ret = afs_put_operation(op); in afs_issue_write_worker()