1 /* -*- mode: c; c-basic-offset: 8; -*-
2 * vim: noexpandtab sw=8 ts=8 sts=0:
6 * Code which implements online file check.
8 * Copyright (C) 2016 SuSE. All rights reserved.
10 * This program is free software; you can redistribute it and/or
11 * modify it under the terms of the GNU General Public
12 * License as published by the Free Software Foundation, version 2.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 * General Public License for more details.
20 #include <linux/list.h>
21 #include <linux/spinlock.h>
22 #include <linux/module.h>
23 #include <linux/slab.h>
24 #include <linux/kmod.h>
26 #include <linux/kobject.h>
27 #include <linux/sysfs.h>
28 #include <linux/sysctl.h>
29 #include <cluster/masklog.h>
33 #include "stackglue.h"
36 #include "filecheck.h"
39 /* File check error strings,
40 * must correspond with error number in header file.
42 static const char * const ocfs2_filecheck_errs[] = {
56 struct ocfs2_filecheck_entry {
57 struct list_head fe_list;
60 unsigned int fe_done:1;
61 unsigned int fe_status:31;
64 struct ocfs2_filecheck_args {
73 ocfs2_filecheck_error(int errno)
76 return ocfs2_filecheck_errs[errno];
78 BUG_ON(errno < OCFS2_FILECHECK_ERR_START ||
79 errno > OCFS2_FILECHECK_ERR_END);
80 return ocfs2_filecheck_errs[errno - OCFS2_FILECHECK_ERR_START + 1];
83 static ssize_t ocfs2_filecheck_attr_show(struct kobject *kobj,
84 struct kobj_attribute *attr,
86 static ssize_t ocfs2_filecheck_attr_store(struct kobject *kobj,
87 struct kobj_attribute *attr,
88 const char *buf, size_t count);
89 static struct kobj_attribute ocfs2_filecheck_attr_chk =
90 __ATTR(check, S_IRUSR | S_IWUSR,
91 ocfs2_filecheck_attr_show,
92 ocfs2_filecheck_attr_store);
93 static struct kobj_attribute ocfs2_filecheck_attr_fix =
94 __ATTR(fix, S_IRUSR | S_IWUSR,
95 ocfs2_filecheck_attr_show,
96 ocfs2_filecheck_attr_store);
97 static struct kobj_attribute ocfs2_filecheck_attr_set =
98 __ATTR(set, S_IRUSR | S_IWUSR,
99 ocfs2_filecheck_attr_show,
100 ocfs2_filecheck_attr_store);
101 static struct attribute *ocfs2_filecheck_attrs[] = {
102 &ocfs2_filecheck_attr_chk.attr,
103 &ocfs2_filecheck_attr_fix.attr,
104 &ocfs2_filecheck_attr_set.attr,
108 static void ocfs2_filecheck_release(struct kobject *kobj)
110 struct ocfs2_filecheck_sysfs_entry *entry = container_of(kobj,
111 struct ocfs2_filecheck_sysfs_entry, fs_kobj);
113 complete(&entry->fs_kobj_unregister);
117 ocfs2_filecheck_show(struct kobject *kobj, struct attribute *attr, char *buf)
120 struct kobj_attribute *kattr = container_of(attr,
121 struct kobj_attribute, attr);
125 ret = kattr->show(kobj, kattr, buf);
131 ocfs2_filecheck_store(struct kobject *kobj, struct attribute *attr,
132 const char *buf, size_t count)
135 struct kobj_attribute *kattr = container_of(attr,
136 struct kobj_attribute, attr);
140 ret = kattr->store(kobj, kattr, buf, count);
145 static const struct sysfs_ops ocfs2_filecheck_ops = {
146 .show = ocfs2_filecheck_show,
147 .store = ocfs2_filecheck_store,
150 static struct kobj_type ocfs2_ktype_filecheck = {
151 .default_attrs = ocfs2_filecheck_attrs,
152 .sysfs_ops = &ocfs2_filecheck_ops,
153 .release = ocfs2_filecheck_release,
157 ocfs2_filecheck_sysfs_free(struct ocfs2_filecheck_sysfs_entry *entry)
159 struct ocfs2_filecheck_entry *p;
161 spin_lock(&entry->fs_fcheck->fc_lock);
162 while (!list_empty(&entry->fs_fcheck->fc_head)) {
163 p = list_first_entry(&entry->fs_fcheck->fc_head,
164 struct ocfs2_filecheck_entry, fe_list);
165 list_del(&p->fe_list);
166 BUG_ON(!p->fe_done); /* To free a undone file check entry */
169 spin_unlock(&entry->fs_fcheck->fc_lock);
171 kfree(entry->fs_fcheck);
172 entry->fs_fcheck = NULL;
175 int ocfs2_filecheck_create_sysfs(struct ocfs2_super *osb)
178 struct ocfs2_filecheck *fcheck;
179 struct ocfs2_filecheck_sysfs_entry *entry = &osb->osb_fc_ent;
181 fcheck = kmalloc(sizeof(struct ocfs2_filecheck), GFP_NOFS);
185 INIT_LIST_HEAD(&fcheck->fc_head);
186 spin_lock_init(&fcheck->fc_lock);
187 fcheck->fc_max = OCFS2_FILECHECK_MINSIZE;
191 entry->fs_kobj.kset = osb->osb_dev_kset;
192 init_completion(&entry->fs_kobj_unregister);
193 ret = kobject_init_and_add(&entry->fs_kobj, &ocfs2_ktype_filecheck,
200 entry->fs_fcheck = fcheck;
204 void ocfs2_filecheck_remove_sysfs(struct ocfs2_super *osb)
206 if (!osb->osb_fc_ent.fs_fcheck)
209 kobject_del(&osb->osb_fc_ent.fs_kobj);
210 kobject_put(&osb->osb_fc_ent.fs_kobj);
211 wait_for_completion(&osb->osb_fc_ent.fs_kobj_unregister);
212 ocfs2_filecheck_sysfs_free(&osb->osb_fc_ent);
216 ocfs2_filecheck_erase_entries(struct ocfs2_filecheck_sysfs_entry *ent,
219 ocfs2_filecheck_adjust_max(struct ocfs2_filecheck_sysfs_entry *ent,
224 if ((len < OCFS2_FILECHECK_MINSIZE) || (len > OCFS2_FILECHECK_MAXSIZE))
227 spin_lock(&ent->fs_fcheck->fc_lock);
228 if (len < (ent->fs_fcheck->fc_size - ent->fs_fcheck->fc_done)) {
230 "Cannot set online file check maximum entry number "
231 "to %u due to too many pending entries(%u)\n",
232 len, ent->fs_fcheck->fc_size - ent->fs_fcheck->fc_done);
235 if (len < ent->fs_fcheck->fc_size)
236 BUG_ON(!ocfs2_filecheck_erase_entries(ent,
237 ent->fs_fcheck->fc_size - len));
239 ent->fs_fcheck->fc_max = len;
242 spin_unlock(&ent->fs_fcheck->fc_lock);
247 #define OCFS2_FILECHECK_ARGS_LEN 24
249 ocfs2_filecheck_args_get_long(const char *buf, size_t count,
252 char buffer[OCFS2_FILECHECK_ARGS_LEN];
254 memcpy(buffer, buf, count);
255 buffer[count] = '\0';
257 if (kstrtoul(buffer, 0, val))
264 ocfs2_filecheck_type_parse(const char *name, unsigned int *type)
266 if (!strncmp(name, "fix", 4))
267 *type = OCFS2_FILECHECK_TYPE_FIX;
268 else if (!strncmp(name, "check", 6))
269 *type = OCFS2_FILECHECK_TYPE_CHK;
270 else if (!strncmp(name, "set", 4))
271 *type = OCFS2_FILECHECK_TYPE_SET;
279 ocfs2_filecheck_args_parse(const char *name, const char *buf, size_t count,
280 struct ocfs2_filecheck_args *args)
282 unsigned long val = 0;
285 /* too short/long args length */
286 if ((count < 1) || (count >= OCFS2_FILECHECK_ARGS_LEN))
289 if (ocfs2_filecheck_type_parse(name, &type))
291 if (ocfs2_filecheck_args_get_long(buf, count, &val))
297 args->fa_type = type;
298 if (type == OCFS2_FILECHECK_TYPE_SET)
299 args->fa_len = (unsigned int)val;
306 static ssize_t ocfs2_filecheck_attr_show(struct kobject *kobj,
307 struct kobj_attribute *attr,
311 ssize_t ret = 0, total = 0, remain = PAGE_SIZE;
313 struct ocfs2_filecheck_entry *p;
314 struct ocfs2_filecheck_sysfs_entry *ent = container_of(kobj,
315 struct ocfs2_filecheck_sysfs_entry, fs_kobj);
317 if (ocfs2_filecheck_type_parse(attr->attr.name, &type))
320 if (type == OCFS2_FILECHECK_TYPE_SET) {
321 spin_lock(&ent->fs_fcheck->fc_lock);
322 total = snprintf(buf, remain, "%u\n", ent->fs_fcheck->fc_max);
323 spin_unlock(&ent->fs_fcheck->fc_lock);
327 ret = snprintf(buf, remain, "INO\t\tDONE\tERROR\n");
330 spin_lock(&ent->fs_fcheck->fc_lock);
331 list_for_each_entry(p, &ent->fs_fcheck->fc_head, fe_list) {
332 if (p->fe_type != type)
335 ret = snprintf(buf + total, remain, "%lu\t\t%u\t%s\n",
336 p->fe_ino, p->fe_done,
337 ocfs2_filecheck_error(p->fe_status));
343 /* snprintf() didn't fit */
350 spin_unlock(&ent->fs_fcheck->fc_lock);
357 ocfs2_filecheck_is_dup_entry(struct ocfs2_filecheck_sysfs_entry *ent,
360 struct ocfs2_filecheck_entry *p;
362 list_for_each_entry(p, &ent->fs_fcheck->fc_head, fe_list) {
364 if (p->fe_ino == ino)
373 ocfs2_filecheck_erase_entry(struct ocfs2_filecheck_sysfs_entry *ent)
375 struct ocfs2_filecheck_entry *p;
377 list_for_each_entry(p, &ent->fs_fcheck->fc_head, fe_list) {
379 list_del(&p->fe_list);
381 ent->fs_fcheck->fc_size--;
382 ent->fs_fcheck->fc_done--;
391 ocfs2_filecheck_erase_entries(struct ocfs2_filecheck_sysfs_entry *ent,
395 unsigned int ret = 0;
397 while (i++ < count) {
398 if (ocfs2_filecheck_erase_entry(ent))
404 return (ret == count ? 1 : 0);
408 ocfs2_filecheck_done_entry(struct ocfs2_filecheck_sysfs_entry *ent,
409 struct ocfs2_filecheck_entry *entry)
411 spin_lock(&ent->fs_fcheck->fc_lock);
413 ent->fs_fcheck->fc_done++;
414 spin_unlock(&ent->fs_fcheck->fc_lock);
418 ocfs2_filecheck_handle(struct ocfs2_super *osb,
419 unsigned long ino, unsigned int flags)
421 unsigned int ret = OCFS2_FILECHECK_ERR_SUCCESS;
422 struct inode *inode = NULL;
425 inode = ocfs2_iget(osb, ino, flags, 0);
427 rc = (int)(-(long)inode);
428 if (rc >= OCFS2_FILECHECK_ERR_START &&
429 rc < OCFS2_FILECHECK_ERR_END)
432 ret = OCFS2_FILECHECK_ERR_FAILED;
440 ocfs2_filecheck_handle_entry(struct ocfs2_filecheck_sysfs_entry *ent,
441 struct ocfs2_filecheck_entry *entry)
443 struct ocfs2_super *osb = container_of(ent, struct ocfs2_super,
446 if (entry->fe_type == OCFS2_FILECHECK_TYPE_CHK)
447 entry->fe_status = ocfs2_filecheck_handle(osb,
448 entry->fe_ino, OCFS2_FI_FLAG_FILECHECK_CHK);
449 else if (entry->fe_type == OCFS2_FILECHECK_TYPE_FIX)
450 entry->fe_status = ocfs2_filecheck_handle(osb,
451 entry->fe_ino, OCFS2_FI_FLAG_FILECHECK_FIX);
453 entry->fe_status = OCFS2_FILECHECK_ERR_UNSUPPORTED;
455 ocfs2_filecheck_done_entry(ent, entry);
458 static ssize_t ocfs2_filecheck_attr_store(struct kobject *kobj,
459 struct kobj_attribute *attr,
460 const char *buf, size_t count)
463 struct ocfs2_filecheck_args args;
464 struct ocfs2_filecheck_entry *entry;
465 struct ocfs2_filecheck_sysfs_entry *ent = container_of(kobj,
466 struct ocfs2_filecheck_sysfs_entry, fs_kobj);
471 if (ocfs2_filecheck_args_parse(attr->attr.name, buf, count, &args))
474 if (args.fa_type == OCFS2_FILECHECK_TYPE_SET) {
475 ret = ocfs2_filecheck_adjust_max(ent, args.fa_len);
479 entry = kmalloc(sizeof(struct ocfs2_filecheck_entry), GFP_NOFS);
485 spin_lock(&ent->fs_fcheck->fc_lock);
486 if (ocfs2_filecheck_is_dup_entry(ent, args.fa_ino)) {
489 } else if ((ent->fs_fcheck->fc_size >= ent->fs_fcheck->fc_max) &&
490 (ent->fs_fcheck->fc_done == 0)) {
492 "Cannot do more file check "
493 "since file check queue(%u) is full now\n",
494 ent->fs_fcheck->fc_max);
498 if ((ent->fs_fcheck->fc_size >= ent->fs_fcheck->fc_max) &&
499 (ent->fs_fcheck->fc_done > 0)) {
500 /* Delete the oldest entry which was done,
501 * make sure the entry size in list does
502 * not exceed maximum value
504 BUG_ON(!ocfs2_filecheck_erase_entry(ent));
507 entry->fe_ino = args.fa_ino;
508 entry->fe_type = args.fa_type;
510 entry->fe_status = OCFS2_FILECHECK_ERR_INPROGRESS;
511 list_add_tail(&entry->fe_list, &ent->fs_fcheck->fc_head);
512 ent->fs_fcheck->fc_size++;
514 spin_unlock(&ent->fs_fcheck->fc_lock);
517 ocfs2_filecheck_handle_entry(ent, entry);
520 return (!ret ? count : ret);