sys.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809
  1. // SPDX-License-Identifier: GPL-2.0-only
  2. /*
  3. * Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
  4. * Copyright (C) 2004-2006 Red Hat, Inc. All rights reserved.
  5. */
  6. #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
  7. #include <linux/sched.h>
  8. #include <linux/cred.h>
  9. #include <linux/spinlock.h>
  10. #include <linux/completion.h>
  11. #include <linux/buffer_head.h>
  12. #include <linux/module.h>
  13. #include <linux/kobject.h>
  14. #include <linux/uaccess.h>
  15. #include <linux/gfs2_ondisk.h>
  16. #include <linux/blkdev.h>
  17. #include "gfs2.h"
  18. #include "incore.h"
  19. #include "sys.h"
  20. #include "super.h"
  21. #include "glock.h"
  22. #include "quota.h"
  23. #include "util.h"
  24. #include "glops.h"
  25. #include "recovery.h"
  26. struct gfs2_attr {
  27. struct attribute attr;
  28. ssize_t (*show)(struct gfs2_sbd *, char *);
  29. ssize_t (*store)(struct gfs2_sbd *, const char *, size_t);
  30. };
  31. static ssize_t gfs2_attr_show(struct kobject *kobj, struct attribute *attr,
  32. char *buf)
  33. {
  34. struct gfs2_sbd *sdp = container_of(kobj, struct gfs2_sbd, sd_kobj);
  35. struct gfs2_attr *a = container_of(attr, struct gfs2_attr, attr);
  36. return a->show ? a->show(sdp, buf) : 0;
  37. }
  38. static ssize_t gfs2_attr_store(struct kobject *kobj, struct attribute *attr,
  39. const char *buf, size_t len)
  40. {
  41. struct gfs2_sbd *sdp = container_of(kobj, struct gfs2_sbd, sd_kobj);
  42. struct gfs2_attr *a = container_of(attr, struct gfs2_attr, attr);
  43. return a->store ? a->store(sdp, buf, len) : len;
  44. }
  45. static const struct sysfs_ops gfs2_attr_ops = {
  46. .show = gfs2_attr_show,
  47. .store = gfs2_attr_store,
  48. };
  49. static struct kset *gfs2_kset;
  50. static ssize_t id_show(struct gfs2_sbd *sdp, char *buf)
  51. {
  52. return snprintf(buf, PAGE_SIZE, "%u:%u\n",
  53. MAJOR(sdp->sd_vfs->s_dev), MINOR(sdp->sd_vfs->s_dev));
  54. }
  55. static ssize_t status_show(struct gfs2_sbd *sdp, char *buf)
  56. {
  57. unsigned long f = sdp->sd_flags;
  58. ssize_t s;
  59. s = snprintf(buf, PAGE_SIZE,
  60. "Journal Checked: %d\n"
  61. "Journal Live: %d\n"
  62. "Journal ID: %d\n"
  63. "Spectator: %d\n"
  64. "Withdrawn: %d\n"
  65. "No barriers: %d\n"
  66. "No recovery: %d\n"
  67. "Demote: %d\n"
  68. "No Journal ID: %d\n"
  69. "Mounted RO: %d\n"
  70. "RO Recovery: %d\n"
  71. "Skip DLM Unlock: %d\n"
  72. "Force AIL Flush: %d\n"
  73. "FS Freeze Initiator: %d\n"
  74. "FS Frozen: %d\n"
  75. "Withdrawing: %d\n"
  76. "Withdraw In Prog: %d\n"
  77. "Remote Withdraw: %d\n"
  78. "Withdraw Recovery: %d\n"
  79. "Killing: %d\n"
  80. "sd_log_error: %d\n"
  81. "sd_log_flush_lock: %d\n"
  82. "sd_log_num_revoke: %u\n"
  83. "sd_log_in_flight: %d\n"
  84. "sd_log_blks_needed: %d\n"
  85. "sd_log_blks_free: %d\n"
  86. "sd_log_flush_head: %d\n"
  87. "sd_log_flush_tail: %d\n"
  88. "sd_log_blks_reserved: %d\n"
  89. "sd_log_revokes_available: %d\n"
  90. "sd_log_pinned: %d\n"
  91. "sd_log_thresh1: %d\n"
  92. "sd_log_thresh2: %d\n",
  93. test_bit(SDF_JOURNAL_CHECKED, &f),
  94. test_bit(SDF_JOURNAL_LIVE, &f),
  95. (sdp->sd_jdesc ? sdp->sd_jdesc->jd_jid : 0),
  96. (sdp->sd_args.ar_spectator ? 1 : 0),
  97. test_bit(SDF_WITHDRAWN, &f),
  98. test_bit(SDF_NOBARRIERS, &f),
  99. test_bit(SDF_NORECOVERY, &f),
  100. test_bit(SDF_DEMOTE, &f),
  101. test_bit(SDF_NOJOURNALID, &f),
  102. (sb_rdonly(sdp->sd_vfs) ? 1 : 0),
  103. test_bit(SDF_RORECOVERY, &f),
  104. test_bit(SDF_SKIP_DLM_UNLOCK, &f),
  105. test_bit(SDF_FORCE_AIL_FLUSH, &f),
  106. test_bit(SDF_FREEZE_INITIATOR, &f),
  107. test_bit(SDF_FROZEN, &f),
  108. test_bit(SDF_WITHDRAWING, &f),
  109. test_bit(SDF_WITHDRAW_IN_PROG, &f),
  110. test_bit(SDF_REMOTE_WITHDRAW, &f),
  111. test_bit(SDF_WITHDRAW_RECOVERY, &f),
  112. test_bit(SDF_KILL, &f),
  113. sdp->sd_log_error,
  114. rwsem_is_locked(&sdp->sd_log_flush_lock),
  115. sdp->sd_log_num_revoke,
  116. atomic_read(&sdp->sd_log_in_flight),
  117. atomic_read(&sdp->sd_log_blks_needed),
  118. atomic_read(&sdp->sd_log_blks_free),
  119. sdp->sd_log_flush_head,
  120. sdp->sd_log_flush_tail,
  121. sdp->sd_log_blks_reserved,
  122. atomic_read(&sdp->sd_log_revokes_available),
  123. atomic_read(&sdp->sd_log_pinned),
  124. atomic_read(&sdp->sd_log_thresh1),
  125. atomic_read(&sdp->sd_log_thresh2));
  126. return s;
  127. }
  128. static ssize_t fsname_show(struct gfs2_sbd *sdp, char *buf)
  129. {
  130. return snprintf(buf, PAGE_SIZE, "%s\n", sdp->sd_fsname);
  131. }
  132. static ssize_t uuid_show(struct gfs2_sbd *sdp, char *buf)
  133. {
  134. struct super_block *s = sdp->sd_vfs;
  135. buf[0] = '\0';
  136. if (uuid_is_null(&s->s_uuid))
  137. return 0;
  138. return snprintf(buf, PAGE_SIZE, "%pUB\n", &s->s_uuid);
  139. }
  140. static ssize_t freeze_show(struct gfs2_sbd *sdp, char *buf)
  141. {
  142. struct super_block *sb = sdp->sd_vfs;
  143. int frozen = (sb->s_writers.frozen == SB_UNFROZEN) ? 0 : 1;
  144. return snprintf(buf, PAGE_SIZE, "%d\n", frozen);
  145. }
  146. static ssize_t freeze_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  147. {
  148. int error, n;
  149. error = kstrtoint(buf, 0, &n);
  150. if (error)
  151. return error;
  152. if (!capable(CAP_SYS_ADMIN))
  153. return -EPERM;
  154. switch (n) {
  155. case 0:
  156. error = thaw_super(sdp->sd_vfs, FREEZE_HOLDER_USERSPACE);
  157. break;
  158. case 1:
  159. error = freeze_super(sdp->sd_vfs, FREEZE_HOLDER_USERSPACE);
  160. break;
  161. default:
  162. return -EINVAL;
  163. }
  164. if (error) {
  165. fs_warn(sdp, "freeze %d error %d\n", n, error);
  166. return error;
  167. }
  168. return len;
  169. }
  170. static ssize_t withdraw_show(struct gfs2_sbd *sdp, char *buf)
  171. {
  172. unsigned int b = gfs2_withdrawing_or_withdrawn(sdp);
  173. return snprintf(buf, PAGE_SIZE, "%u\n", b);
  174. }
  175. static ssize_t withdraw_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  176. {
  177. int error, val;
  178. if (!capable(CAP_SYS_ADMIN))
  179. return -EPERM;
  180. error = kstrtoint(buf, 0, &val);
  181. if (error)
  182. return error;
  183. if (val != 1)
  184. return -EINVAL;
  185. gfs2_lm(sdp, "withdrawing from cluster at user's request\n");
  186. gfs2_withdraw(sdp);
  187. return len;
  188. }
  189. static ssize_t statfs_sync_store(struct gfs2_sbd *sdp, const char *buf,
  190. size_t len)
  191. {
  192. int error, val;
  193. if (!capable(CAP_SYS_ADMIN))
  194. return -EPERM;
  195. error = kstrtoint(buf, 0, &val);
  196. if (error)
  197. return error;
  198. if (val != 1)
  199. return -EINVAL;
  200. gfs2_statfs_sync(sdp->sd_vfs, 0);
  201. return len;
  202. }
  203. static ssize_t quota_sync_store(struct gfs2_sbd *sdp, const char *buf,
  204. size_t len)
  205. {
  206. int error, val;
  207. if (!capable(CAP_SYS_ADMIN))
  208. return -EPERM;
  209. error = kstrtoint(buf, 0, &val);
  210. if (error)
  211. return error;
  212. if (val != 1)
  213. return -EINVAL;
  214. gfs2_quota_sync(sdp->sd_vfs, 0);
  215. return len;
  216. }
  217. static ssize_t quota_refresh_user_store(struct gfs2_sbd *sdp, const char *buf,
  218. size_t len)
  219. {
  220. struct kqid qid;
  221. int error;
  222. u32 id;
  223. if (!capable(CAP_SYS_ADMIN))
  224. return -EPERM;
  225. error = kstrtou32(buf, 0, &id);
  226. if (error)
  227. return error;
  228. qid = make_kqid(current_user_ns(), USRQUOTA, id);
  229. if (!qid_valid(qid))
  230. return -EINVAL;
  231. error = gfs2_quota_refresh(sdp, qid);
  232. return error ? error : len;
  233. }
  234. static ssize_t quota_refresh_group_store(struct gfs2_sbd *sdp, const char *buf,
  235. size_t len)
  236. {
  237. struct kqid qid;
  238. int error;
  239. u32 id;
  240. if (!capable(CAP_SYS_ADMIN))
  241. return -EPERM;
  242. error = kstrtou32(buf, 0, &id);
  243. if (error)
  244. return error;
  245. qid = make_kqid(current_user_ns(), GRPQUOTA, id);
  246. if (!qid_valid(qid))
  247. return -EINVAL;
  248. error = gfs2_quota_refresh(sdp, qid);
  249. return error ? error : len;
  250. }
  251. static ssize_t demote_rq_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  252. {
  253. struct gfs2_glock *gl;
  254. const struct gfs2_glock_operations *glops;
  255. unsigned int glmode;
  256. unsigned int gltype;
  257. unsigned long long glnum;
  258. char mode[16];
  259. int rv;
  260. if (!capable(CAP_SYS_ADMIN))
  261. return -EPERM;
  262. rv = sscanf(buf, "%u:%llu %15s", &gltype, &glnum,
  263. mode);
  264. if (rv != 3)
  265. return -EINVAL;
  266. if (strcmp(mode, "EX") == 0)
  267. glmode = LM_ST_UNLOCKED;
  268. else if ((strcmp(mode, "CW") == 0) || (strcmp(mode, "DF") == 0))
  269. glmode = LM_ST_DEFERRED;
  270. else if ((strcmp(mode, "PR") == 0) || (strcmp(mode, "SH") == 0))
  271. glmode = LM_ST_SHARED;
  272. else
  273. return -EINVAL;
  274. if (gltype > LM_TYPE_JOURNAL)
  275. return -EINVAL;
  276. if (gltype == LM_TYPE_NONDISK && glnum == GFS2_FREEZE_LOCK)
  277. glops = &gfs2_freeze_glops;
  278. else
  279. glops = gfs2_glops_list[gltype];
  280. if (glops == NULL)
  281. return -EINVAL;
  282. if (!test_and_set_bit(SDF_DEMOTE, &sdp->sd_flags))
  283. fs_info(sdp, "demote interface used\n");
  284. rv = gfs2_glock_get(sdp, glnum, glops, NO_CREATE, &gl);
  285. if (rv)
  286. return rv;
  287. gfs2_glock_cb(gl, glmode);
  288. gfs2_glock_put(gl);
  289. return len;
  290. }
  291. #define GFS2_ATTR(name, mode, show, store) \
  292. static struct gfs2_attr gfs2_attr_##name = __ATTR(name, mode, show, store)
  293. GFS2_ATTR(id, 0444, id_show, NULL);
  294. GFS2_ATTR(fsname, 0444, fsname_show, NULL);
  295. GFS2_ATTR(uuid, 0444, uuid_show, NULL);
  296. GFS2_ATTR(freeze, 0644, freeze_show, freeze_store);
  297. GFS2_ATTR(withdraw, 0644, withdraw_show, withdraw_store);
  298. GFS2_ATTR(statfs_sync, 0200, NULL, statfs_sync_store);
  299. GFS2_ATTR(quota_sync, 0200, NULL, quota_sync_store);
  300. GFS2_ATTR(quota_refresh_user, 0200, NULL, quota_refresh_user_store);
  301. GFS2_ATTR(quota_refresh_group, 0200, NULL, quota_refresh_group_store);
  302. GFS2_ATTR(demote_rq, 0200, NULL, demote_rq_store);
  303. GFS2_ATTR(status, 0400, status_show, NULL);
  304. static struct attribute *gfs2_attrs[] = {
  305. &gfs2_attr_id.attr,
  306. &gfs2_attr_fsname.attr,
  307. &gfs2_attr_uuid.attr,
  308. &gfs2_attr_freeze.attr,
  309. &gfs2_attr_withdraw.attr,
  310. &gfs2_attr_statfs_sync.attr,
  311. &gfs2_attr_quota_sync.attr,
  312. &gfs2_attr_quota_refresh_user.attr,
  313. &gfs2_attr_quota_refresh_group.attr,
  314. &gfs2_attr_demote_rq.attr,
  315. &gfs2_attr_status.attr,
  316. NULL,
  317. };
  318. ATTRIBUTE_GROUPS(gfs2);
  319. static void gfs2_sbd_release(struct kobject *kobj)
  320. {
  321. struct gfs2_sbd *sdp = container_of(kobj, struct gfs2_sbd, sd_kobj);
  322. complete(&sdp->sd_kobj_unregister);
  323. }
  324. static struct kobj_type gfs2_ktype = {
  325. .release = gfs2_sbd_release,
  326. .default_groups = gfs2_groups,
  327. .sysfs_ops = &gfs2_attr_ops,
  328. };
  329. /*
  330. * lock_module. Originally from lock_dlm
  331. */
  332. static ssize_t proto_name_show(struct gfs2_sbd *sdp, char *buf)
  333. {
  334. const struct lm_lockops *ops = sdp->sd_lockstruct.ls_ops;
  335. return sprintf(buf, "%s\n", ops->lm_proto_name);
  336. }
  337. static ssize_t block_show(struct gfs2_sbd *sdp, char *buf)
  338. {
  339. struct lm_lockstruct *ls = &sdp->sd_lockstruct;
  340. ssize_t ret;
  341. int val = 0;
  342. if (test_bit(DFL_BLOCK_LOCKS, &ls->ls_recover_flags))
  343. val = 1;
  344. ret = sprintf(buf, "%d\n", val);
  345. return ret;
  346. }
  347. static ssize_t block_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  348. {
  349. struct lm_lockstruct *ls = &sdp->sd_lockstruct;
  350. int ret, val;
  351. ret = kstrtoint(buf, 0, &val);
  352. if (ret)
  353. return ret;
  354. if (val == 1)
  355. set_bit(DFL_BLOCK_LOCKS, &ls->ls_recover_flags);
  356. else if (val == 0) {
  357. clear_bit(DFL_BLOCK_LOCKS, &ls->ls_recover_flags);
  358. smp_mb__after_atomic();
  359. gfs2_glock_thaw(sdp);
  360. } else {
  361. return -EINVAL;
  362. }
  363. return len;
  364. }
  365. static ssize_t wdack_show(struct gfs2_sbd *sdp, char *buf)
  366. {
  367. int val = completion_done(&sdp->sd_wdack) ? 1 : 0;
  368. return sprintf(buf, "%d\n", val);
  369. }
  370. static ssize_t wdack_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  371. {
  372. int ret, val;
  373. ret = kstrtoint(buf, 0, &val);
  374. if (ret)
  375. return ret;
  376. if ((val == 1) &&
  377. !strcmp(sdp->sd_lockstruct.ls_ops->lm_proto_name, "lock_dlm"))
  378. complete(&sdp->sd_wdack);
  379. else
  380. return -EINVAL;
  381. return len;
  382. }
  383. static ssize_t lkfirst_show(struct gfs2_sbd *sdp, char *buf)
  384. {
  385. struct lm_lockstruct *ls = &sdp->sd_lockstruct;
  386. return sprintf(buf, "%d\n", ls->ls_first);
  387. }
  388. static ssize_t lkfirst_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  389. {
  390. unsigned first;
  391. int rv;
  392. rv = sscanf(buf, "%u", &first);
  393. if (rv != 1 || first > 1)
  394. return -EINVAL;
  395. rv = wait_for_completion_killable(&sdp->sd_locking_init);
  396. if (rv)
  397. return rv;
  398. spin_lock(&sdp->sd_jindex_spin);
  399. rv = -EBUSY;
  400. if (test_bit(SDF_NOJOURNALID, &sdp->sd_flags) == 0)
  401. goto out;
  402. rv = -EINVAL;
  403. if (sdp->sd_args.ar_spectator)
  404. goto out;
  405. if (sdp->sd_lockstruct.ls_ops->lm_mount == NULL)
  406. goto out;
  407. sdp->sd_lockstruct.ls_first = first;
  408. rv = 0;
  409. out:
  410. spin_unlock(&sdp->sd_jindex_spin);
  411. return rv ? rv : len;
  412. }
  413. static ssize_t first_done_show(struct gfs2_sbd *sdp, char *buf)
  414. {
  415. struct lm_lockstruct *ls = &sdp->sd_lockstruct;
  416. return sprintf(buf, "%d\n", !!test_bit(DFL_FIRST_MOUNT_DONE, &ls->ls_recover_flags));
  417. }
  418. int gfs2_recover_set(struct gfs2_sbd *sdp, unsigned jid)
  419. {
  420. struct gfs2_jdesc *jd;
  421. int rv;
  422. /* Wait for our primary journal to be initialized */
  423. wait_for_completion(&sdp->sd_journal_ready);
  424. spin_lock(&sdp->sd_jindex_spin);
  425. rv = -EBUSY;
  426. /**
  427. * If we're a spectator, we use journal0, but it's not really ours.
  428. * So we need to wait for its recovery too. If we skip it we'd never
  429. * queue work to the recovery workqueue, and so its completion would
  430. * never clear the DFL_BLOCK_LOCKS flag, so all our locks would
  431. * permanently stop working.
  432. */
  433. if (!sdp->sd_jdesc)
  434. goto out;
  435. if (sdp->sd_jdesc->jd_jid == jid && !sdp->sd_args.ar_spectator)
  436. goto out;
  437. rv = -ENOENT;
  438. list_for_each_entry(jd, &sdp->sd_jindex_list, jd_list) {
  439. if (jd->jd_jid != jid && !sdp->sd_args.ar_spectator)
  440. continue;
  441. rv = gfs2_recover_journal(jd, false);
  442. break;
  443. }
  444. out:
  445. spin_unlock(&sdp->sd_jindex_spin);
  446. return rv;
  447. }
  448. static ssize_t recover_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  449. {
  450. unsigned jid;
  451. int rv;
  452. rv = sscanf(buf, "%u", &jid);
  453. if (rv != 1)
  454. return -EINVAL;
  455. if (test_bit(SDF_NORECOVERY, &sdp->sd_flags)) {
  456. rv = -ESHUTDOWN;
  457. goto out;
  458. }
  459. rv = gfs2_recover_set(sdp, jid);
  460. out:
  461. return rv ? rv : len;
  462. }
  463. static ssize_t recover_done_show(struct gfs2_sbd *sdp, char *buf)
  464. {
  465. struct lm_lockstruct *ls = &sdp->sd_lockstruct;
  466. return sprintf(buf, "%d\n", ls->ls_recover_jid_done);
  467. }
  468. static ssize_t recover_status_show(struct gfs2_sbd *sdp, char *buf)
  469. {
  470. struct lm_lockstruct *ls = &sdp->sd_lockstruct;
  471. return sprintf(buf, "%d\n", ls->ls_recover_jid_status);
  472. }
  473. static ssize_t jid_show(struct gfs2_sbd *sdp, char *buf)
  474. {
  475. return sprintf(buf, "%d\n", sdp->sd_lockstruct.ls_jid);
  476. }
  477. static ssize_t jid_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
  478. {
  479. int jid;
  480. int rv;
  481. rv = sscanf(buf, "%d", &jid);
  482. if (rv != 1)
  483. return -EINVAL;
  484. rv = wait_for_completion_killable(&sdp->sd_locking_init);
  485. if (rv)
  486. return rv;
  487. spin_lock(&sdp->sd_jindex_spin);
  488. rv = -EINVAL;
  489. if (sdp->sd_lockstruct.ls_ops->lm_mount == NULL)
  490. goto out;
  491. rv = -EBUSY;
  492. if (test_bit(SDF_NOJOURNALID, &sdp->sd_flags) == 0)
  493. goto out;
  494. rv = 0;
  495. if (sdp->sd_args.ar_spectator && jid > 0)
  496. rv = jid = -EINVAL;
  497. sdp->sd_lockstruct.ls_jid = jid;
  498. clear_bit(SDF_NOJOURNALID, &sdp->sd_flags);
  499. smp_mb__after_atomic();
  500. wake_up_bit(&sdp->sd_flags, SDF_NOJOURNALID);
  501. out:
  502. spin_unlock(&sdp->sd_jindex_spin);
  503. return rv ? rv : len;
  504. }
  505. #define GDLM_ATTR(_name,_mode,_show,_store) \
  506. static struct gfs2_attr gdlm_attr_##_name = __ATTR(_name,_mode,_show,_store)
  507. GDLM_ATTR(proto_name, 0444, proto_name_show, NULL);
  508. GDLM_ATTR(block, 0644, block_show, block_store);
  509. GDLM_ATTR(withdraw, 0644, wdack_show, wdack_store);
  510. GDLM_ATTR(jid, 0644, jid_show, jid_store);
  511. GDLM_ATTR(first, 0644, lkfirst_show, lkfirst_store);
  512. GDLM_ATTR(first_done, 0444, first_done_show, NULL);
  513. GDLM_ATTR(recover, 0600, NULL, recover_store);
  514. GDLM_ATTR(recover_done, 0444, recover_done_show, NULL);
  515. GDLM_ATTR(recover_status, 0444, recover_status_show, NULL);
  516. static struct attribute *lock_module_attrs[] = {
  517. &gdlm_attr_proto_name.attr,
  518. &gdlm_attr_block.attr,
  519. &gdlm_attr_withdraw.attr,
  520. &gdlm_attr_jid.attr,
  521. &gdlm_attr_first.attr,
  522. &gdlm_attr_first_done.attr,
  523. &gdlm_attr_recover.attr,
  524. &gdlm_attr_recover_done.attr,
  525. &gdlm_attr_recover_status.attr,
  526. NULL,
  527. };
  528. /*
  529. * get and set struct gfs2_tune fields
  530. */
  531. static ssize_t quota_scale_show(struct gfs2_sbd *sdp, char *buf)
  532. {
  533. return snprintf(buf, PAGE_SIZE, "%u %u\n",
  534. sdp->sd_tune.gt_quota_scale_num,
  535. sdp->sd_tune.gt_quota_scale_den);
  536. }
  537. static ssize_t quota_scale_store(struct gfs2_sbd *sdp, const char *buf,
  538. size_t len)
  539. {
  540. struct gfs2_tune *gt = &sdp->sd_tune;
  541. unsigned int x, y;
  542. if (!capable(CAP_SYS_ADMIN))
  543. return -EPERM;
  544. if (sscanf(buf, "%u %u", &x, &y) != 2 || !y)
  545. return -EINVAL;
  546. spin_lock(&gt->gt_spin);
  547. gt->gt_quota_scale_num = x;
  548. gt->gt_quota_scale_den = y;
  549. spin_unlock(&gt->gt_spin);
  550. return len;
  551. }
  552. static ssize_t tune_set(struct gfs2_sbd *sdp, unsigned int *field,
  553. int check_zero, const char *buf, size_t len)
  554. {
  555. struct gfs2_tune *gt = &sdp->sd_tune;
  556. unsigned int x;
  557. int error;
  558. if (!capable(CAP_SYS_ADMIN))
  559. return -EPERM;
  560. error = kstrtouint(buf, 0, &x);
  561. if (error)
  562. return error;
  563. if (check_zero && !x)
  564. return -EINVAL;
  565. spin_lock(&gt->gt_spin);
  566. *field = x;
  567. spin_unlock(&gt->gt_spin);
  568. return len;
  569. }
  570. #define TUNE_ATTR_3(name, show, store) \
  571. static struct gfs2_attr tune_attr_##name = __ATTR(name, 0644, show, store)
  572. #define TUNE_ATTR_2(name, store) \
  573. static ssize_t name##_show(struct gfs2_sbd *sdp, char *buf) \
  574. { \
  575. return snprintf(buf, PAGE_SIZE, "%u\n", sdp->sd_tune.gt_##name); \
  576. } \
  577. TUNE_ATTR_3(name, name##_show, store)
  578. #define TUNE_ATTR(name, check_zero) \
  579. static ssize_t name##_store(struct gfs2_sbd *sdp, const char *buf, size_t len)\
  580. { \
  581. return tune_set(sdp, &sdp->sd_tune.gt_##name, check_zero, buf, len); \
  582. } \
  583. TUNE_ATTR_2(name, name##_store)
  584. TUNE_ATTR(quota_warn_period, 0);
  585. TUNE_ATTR(quota_quantum, 0);
  586. TUNE_ATTR(max_readahead, 0);
  587. TUNE_ATTR(complain_secs, 0);
  588. TUNE_ATTR(statfs_slow, 0);
  589. TUNE_ATTR(new_files_jdata, 0);
  590. TUNE_ATTR(statfs_quantum, 1);
  591. TUNE_ATTR_3(quota_scale, quota_scale_show, quota_scale_store);
  592. static struct attribute *tune_attrs[] = {
  593. &tune_attr_quota_warn_period.attr,
  594. &tune_attr_quota_quantum.attr,
  595. &tune_attr_max_readahead.attr,
  596. &tune_attr_complain_secs.attr,
  597. &tune_attr_statfs_slow.attr,
  598. &tune_attr_statfs_quantum.attr,
  599. &tune_attr_quota_scale.attr,
  600. &tune_attr_new_files_jdata.attr,
  601. NULL,
  602. };
  603. static const struct attribute_group tune_group = {
  604. .name = "tune",
  605. .attrs = tune_attrs,
  606. };
  607. static const struct attribute_group lock_module_group = {
  608. .name = "lock_module",
  609. .attrs = lock_module_attrs,
  610. };
  611. int gfs2_sys_fs_add(struct gfs2_sbd *sdp)
  612. {
  613. struct super_block *sb = sdp->sd_vfs;
  614. int error;
  615. char ro[20];
  616. char spectator[20];
  617. char *envp[] = { ro, spectator, NULL };
  618. sprintf(ro, "RDONLY=%d", sb_rdonly(sb));
  619. sprintf(spectator, "SPECTATOR=%d", sdp->sd_args.ar_spectator ? 1 : 0);
  620. init_completion(&sdp->sd_kobj_unregister);
  621. sdp->sd_kobj.kset = gfs2_kset;
  622. error = kobject_init_and_add(&sdp->sd_kobj, &gfs2_ktype, NULL,
  623. "%s", sdp->sd_table_name);
  624. if (error)
  625. goto fail_reg;
  626. error = sysfs_create_group(&sdp->sd_kobj, &tune_group);
  627. if (error)
  628. goto fail_reg;
  629. error = sysfs_create_group(&sdp->sd_kobj, &lock_module_group);
  630. if (error)
  631. goto fail_tune;
  632. error = sysfs_create_link(&sdp->sd_kobj,
  633. &disk_to_dev(sb->s_bdev->bd_disk)->kobj,
  634. "device");
  635. if (error)
  636. goto fail_lock_module;
  637. kobject_uevent_env(&sdp->sd_kobj, KOBJ_ADD, envp);
  638. return 0;
  639. fail_lock_module:
  640. sysfs_remove_group(&sdp->sd_kobj, &lock_module_group);
  641. fail_tune:
  642. sysfs_remove_group(&sdp->sd_kobj, &tune_group);
  643. fail_reg:
  644. fs_err(sdp, "error %d adding sysfs files\n", error);
  645. kobject_put(&sdp->sd_kobj);
  646. wait_for_completion(&sdp->sd_kobj_unregister);
  647. return error;
  648. }
  649. void gfs2_sys_fs_del(struct gfs2_sbd *sdp)
  650. {
  651. sysfs_remove_link(&sdp->sd_kobj, "device");
  652. sysfs_remove_group(&sdp->sd_kobj, &tune_group);
  653. sysfs_remove_group(&sdp->sd_kobj, &lock_module_group);
  654. kobject_put(&sdp->sd_kobj);
  655. wait_for_completion(&sdp->sd_kobj_unregister);
  656. }
  657. static int gfs2_uevent(const struct kobject *kobj, struct kobj_uevent_env *env)
  658. {
  659. const struct gfs2_sbd *sdp = container_of(kobj, struct gfs2_sbd, sd_kobj);
  660. const struct super_block *s = sdp->sd_vfs;
  661. add_uevent_var(env, "LOCKTABLE=%s", sdp->sd_table_name);
  662. add_uevent_var(env, "LOCKPROTO=%s", sdp->sd_proto_name);
  663. if (!test_bit(SDF_NOJOURNALID, &sdp->sd_flags))
  664. add_uevent_var(env, "JOURNALID=%d", sdp->sd_lockstruct.ls_jid);
  665. if (!uuid_is_null(&s->s_uuid))
  666. add_uevent_var(env, "UUID=%pUB", &s->s_uuid);
  667. return 0;
  668. }
  669. static const struct kset_uevent_ops gfs2_uevent_ops = {
  670. .uevent = gfs2_uevent,
  671. };
  672. int gfs2_sys_init(void)
  673. {
  674. gfs2_kset = kset_create_and_add("gfs2", &gfs2_uevent_ops, fs_kobj);
  675. if (!gfs2_kset)
  676. return -ENOMEM;
  677. return 0;
  678. }
  679. void gfs2_sys_uninit(void)
  680. {
  681. kset_unregister(gfs2_kset);
  682. }