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,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License version 2 for more details. A copy is
14 * included in the COPYING file that accompanied this code.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
23 * Copyright (c) 2017, Intel Corporation.
26 * lustre/mdt/mdt_som.c
30 * Author: Jinshan Xiong <jinshan.xiong@intel.com>
31 * Author: Yingjin Qian <qian@ddn.com>
34 #define DEBUG_SUBSYSTEM S_MDS
36 #include "mdt_internal.h"
39 * Swab and extract SOM attributes from on-disk xattr.
41 * \param buf - is a buffer containing the on-disk LSOM extended attribute.
42 * \param rc - is the SOM xattr stored in \a buf
43 * \param ms - is the md_som structure where to extract SOM attributes.
45 int lustre_buf2som(void *buf, int rc, struct md_som *ms)
47 struct lustre_som_attrs *attrs = (struct lustre_som_attrs *)buf;
50 if (rc == 0 || rc == -ENODATA)
51 /* no LSOM attributes */
55 /* error hit while fetching xattr */
58 /* unpack LSOM attributes */
59 lustre_som_swab(attrs);
61 /* fill in-memory md_som structure */
62 ms->ms_valid = attrs->lsa_valid;
63 ms->ms_size = attrs->lsa_size;
64 ms->ms_blocks = attrs->lsa_blocks;
69 int mdt_get_som(struct mdt_thread_info *info, struct mdt_object *obj,
72 struct lu_buf *buf = &info->mti_buf;
73 struct lu_attr *attr = &ma->ma_attr;
76 buf->lb_buf = info->mti_xattr_buf;
77 buf->lb_len = sizeof(info->mti_xattr_buf);
78 CLASSERT(sizeof(struct lustre_som_attrs) <=
79 sizeof(info->mti_xattr_buf));
80 rc = mo_xattr_get(info->mti_env, mdt_object_child(obj), buf,
82 rc = lustre_buf2som(info->mti_xattr_buf, rc, &ma->ma_som);
84 struct md_som *som = &ma->ma_som;
86 ma->ma_valid |= MA_SOM;
88 if ((som->ms_valid & SOM_FL_STRICT)) {
89 attr->la_valid |= LA_SIZE | LA_BLOCKS;
90 attr->la_size = som->ms_size;
91 attr->la_blocks = som->ms_blocks;
94 * Size on MDS is valid and could be returned
97 info->mti_som_valid = 1;
99 CDEBUG(D_INODE, DFID": Reading som attrs: "
100 "valid: %x, size: %lld, blocks: %lld\n",
101 PFID(mdt_object_fid(obj)), som->ms_valid,
102 som->ms_size, som->ms_blocks);
104 } else if (rc == -ENODATA) {
112 * Update SOM on-disk attributes.
114 int mdt_set_som(struct mdt_thread_info *info, struct mdt_object *obj,
115 enum lustre_som_flags flag, __u64 size, __u64 blocks)
117 struct md_object *next = mdt_object_child(obj);
118 struct lu_buf *buf = &info->mti_buf;
119 struct lustre_som_attrs *som;
125 DFID": Set SOM attrs S/B/F: %lld/%lld/%x.\n",
126 PFID(mdt_object_fid(obj)), size, blocks, flag);
128 som = (struct lustre_som_attrs *)info->mti_xattr_buf;
129 CLASSERT(sizeof(info->mti_xattr_buf) >= sizeof(*som));
131 som->lsa_valid = flag;
132 som->lsa_size = size;
133 som->lsa_blocks = blocks;
134 memset(&som->lsa_reserved, 0, sizeof(som->lsa_reserved));
135 lustre_som_swab(som);
137 /* update SOM attributes */
139 buf->lb_len = sizeof(*som);
140 rc = mo_xattr_set(info->mti_env, next, buf, XATTR_NAME_SOM, 0);
146 * SOM state transition from STRICT to STALE,
148 int mdt_lsom_downgrade(struct mdt_thread_info *info, struct mdt_object *o)
150 struct md_attr *tmp_ma;
155 mutex_lock(&o->mot_som_mutex);
156 tmp_ma = &info->mti_u.som.attr;
157 tmp_ma->ma_need = MA_SOM;
158 tmp_ma->ma_valid = 0;
160 rc = mdt_get_som(info, o, tmp_ma);
164 if (tmp_ma->ma_valid & MA_SOM) {
165 struct md_som *som = &tmp_ma->ma_som;
167 info->mti_som_valid = 0;
168 /* The size and blocks info should be still correct. */
169 if (som->ms_valid & SOM_FL_STRICT)
170 rc = mdt_set_som(info, o, SOM_FL_STALE,
171 som->ms_size, som->ms_blocks);
174 mutex_unlock(&o->mot_som_mutex);
178 int mdt_lsom_update(struct mdt_thread_info *info,
179 struct mdt_object *o, bool truncate)
181 struct md_attr *ma, *tmp_ma;
187 ma = &info->mti_attr;
190 mutex_lock(&o->mot_som_mutex);
191 tmp_ma = &info->mti_u.som.attr;
192 tmp_ma->ma_need = MA_INODE | MA_SOM;
193 tmp_ma->ma_valid = 0;
195 rc = mdt_attr_get_complex(info, o, tmp_ma);
199 rc = mo_xattr_get(info->mti_env, mdt_object_child(o), &LU_BUF_NULL,
201 if (rc < 0 && rc != -ENODATA)
203 else if (rc > 0) /* has LOV EA*/
204 tmp_ma->ma_valid |= MA_LOV;
208 * Check if a Lazy Size-on-MDS update is needed. Skip the
209 * file with no LOV EA or unlink files.
210 * MDS only updates LSOM of the file if the size or block
211 * size is being increased or the file is being truncated.
213 if ((tmp_ma->ma_valid & MA_LOV) &&
214 !(tmp_ma->ma_valid & MA_INODE &&
215 tmp_ma->ma_attr.la_nlink == 0)) {
218 bool changed = false;
219 struct md_som *som = &tmp_ma->ma_som;
225 } else if (!(tmp_ma->ma_valid & MA_SOM) ||
226 size < som->ms_size) {
227 /* We cannot rely to blocks after
228 * truncate especially for spare file,
229 * and the truncate operation is usually
230 * followed with a close, so just set blocks
231 * to 1 here, and the following close will
232 * update it accordingly.
236 blocks = som->ms_blocks;
239 if (!(tmp_ma->ma_valid & MA_SOM)) {
240 /* Only set initial SOM Xattr data when both
241 * size and blocks are valid.
243 if (la->la_valid & (LA_SIZE | LA_LSIZE) &&
244 la->la_valid & (LA_BLOCKS | LA_LBLOCKS)) {
247 blocks = la->la_blocks;
250 /* Double check whether it is already set
251 * to SOM_FL_STRICT in mdt_mfd_close.
252 * If file is in SOM_FL_STALE state, and
253 * the close indicates there is no data
254 * modified, skip to transimit to LAZY
257 if (som->ms_valid & SOM_FL_STRICT ||
258 (som->ms_valid & SOM_FL_STALE &&
259 !(ma->ma_attr_flags & MDS_DATA_MODIFIED)))
263 blocks = som->ms_blocks;
264 if (la->la_valid & (LA_SIZE | LA_LSIZE) &&
265 la->la_size > som->ms_size) {
269 if (la->la_valid & (LA_BLOCKS | LA_LBLOCKS) &&
270 la->la_blocks > som->ms_blocks) {
272 blocks = la->la_blocks;
276 if (truncate || changed)
277 rc = mdt_set_som(info, o, SOM_FL_LAZY, size, blocks);
281 mutex_unlock(&o->mot_som_mutex);