4 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License version 2 only,
8 * as published by the Free Software Foundation.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License version 2 for more details (a copy is included
14 * in the LICENSE file that accompanied this code).
16 * You should have received a copy of the GNU General Public License
17 * version 2 along with this program; If not, see
18 * http://www.gnu.org/licenses/gpl-2.0.html
23 * Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved.
24 * Use is subject to license terms.
26 * Copyright (c) 2011, 2014, Intel Corporation.
29 #define DEBUG_SUBSYSTEM S_LLITE
31 #include "../include/lustre/lustre_idl.h"
32 #include "../include/cl_object.h"
33 #include "../include/obd.h"
34 #include "../include/obd_support.h"
35 #include "../include/lustre_lite.h"
36 #include "llite_internal.h"
37 #include "vvp_internal.h"
39 static inline struct vvp_req *cl2vvp_req(const struct cl_req_slice *slice)
41 return container_of0(slice, struct vvp_req, vrq_cl);
45 * Implementation of struct cl_req_operations::cro_attr_set() for VVP
46 * layer. VVP is responsible for
63 static void vvp_req_attr_set(const struct lu_env *env,
64 const struct cl_req_slice *slice,
65 const struct cl_object *obj,
66 struct cl_req_attr *attr, u64 flags)
73 inode = vvp_object_inode(obj);
74 valid_flags = OBD_MD_FLTYPE;
76 if (slice->crs_req->crq_type == CRT_WRITE) {
77 if (flags & OBD_MD_FLEPOCH) {
78 oa->o_valid |= OBD_MD_FLEPOCH;
79 oa->o_ioepoch = ll_i2info(inode)->lli_ioepoch;
80 valid_flags |= OBD_MD_FLMTIME | OBD_MD_FLCTIME |
81 OBD_MD_FLUID | OBD_MD_FLGID;
84 obdo_from_inode(oa, inode, valid_flags & flags);
85 obdo_set_parent_fid(oa, &ll_i2info(inode)->lli_fid);
86 memcpy(attr->cra_jobid, ll_i2info(inode)->lli_jobid,
90 static void vvp_req_completion(const struct lu_env *env,
91 const struct cl_req_slice *slice, int ioret)
96 cl_stats_tally(slice->crs_dev, slice->crs_req->crq_type, ioret);
98 vrq = cl2vvp_req(slice);
99 kmem_cache_free(vvp_req_kmem, vrq);
102 static const struct cl_req_operations vvp_req_ops = {
103 .cro_attr_set = vvp_req_attr_set,
104 .cro_completion = vvp_req_completion
107 int vvp_req_init(const struct lu_env *env, struct cl_device *dev,
113 vrq = kmem_cache_zalloc(vvp_req_kmem, GFP_NOFS);
115 cl_req_slice_add(req, &vrq->vrq_cl, dev, &vvp_req_ops);